fix: various issues after ent refactor

dataloader/loaders.go

@@ -47,7 +47,7 @@
 						if u, ok := byID[id]; ok {
 							results[i] = &dataloader.Result[[]*ent.VersionDependency]{Data: u}
 						} else {
-							results[i] = &dataloader.Result[[]*ent.VersionDependency]{Error: errors.New("version not found")}
+							results[i] = &dataloader.Result[[]*ent.VersionDependency]{Data: []*ent.VersionDependency{}}
 						}
 					}
 
@@ -70,7 +70,7 @@
 						if u, ok := byID[id]; ok {
 							results[i] = &dataloader.Result[[]*ent.UserMod]{Data: u}
 						} else {
-							results[i] = &dataloader.Result[[]*ent.UserMod]{Error: errors.New("version not found")}
+							results[i] = &dataloader.Result[[]*ent.UserMod]{Error: errors.New("mod not found")}
 						}
 					}
 
@@ -97,7 +97,7 @@
 						if u, ok := byID[id]; ok {
 							results[i] = &dataloader.Result[[]*ent.Version]{Data: u}
 						} else {
-							results[i] = &dataloader.Result[[]*ent.Version]{Error: errors.New("version not found")}
+							results[i] = &dataloader.Result[[]*ent.Version]{Data: []*ent.Version{}}
 						}
 					}
 
@@ -145,7 +145,7 @@
 						if u, ok := byID[id]; ok {
 							results[i] = &dataloader.Result[[]*ent.Version]{Data: u}
 						} else {
-							results[i] = &dataloader.Result[[]*ent.Version]{Error: errors.New("version not found")}
+							results[i] = &dataloader.Result[[]*ent.Version]{Data: []*ent.Version{}}
 						}
 					}
 

db/mod.go

@@ -28,22 +28,31 @@
 
 		if filter.OrderBy != nil && *filter.OrderBy != generated.ModFieldsSearch {
 			if string(*filter.OrderBy) == "last_version_date" {
-				query = query.Modify(func(s *sql.Selector) {
-					s.OrderExpr(sql.ExprP("case when last_version_date is null then 1 else 0 end, last_version_date"))
-				}).Clone()
-			} else {
-				query = query.Order(sql.OrderByField(
-					filter.OrderBy.String(),
-					OrderToOrder(filter.Order.String()),
-				).ToFunc())
+				query = query.Order(func(s *sql.Selector) {
+					s.OrderExpr(sql.ExprP("case when last_version_date is null then 1 else 0 end"))
+				})
 			}
+			query = query.Order(sql.OrderByField(
+				filter.OrderBy.String(),
+				OrderToOrder(filter.Order.String()),
+			).ToFunc())
 		}
 
 		if filter.Search != nil && *filter.Search != "" {
 			cleanSearch := strings.ReplaceAll(strings.TrimSpace(*filter.Search), " ", " & ")
 
 			query = query.Where(func(s *sql.Selector) {
-				join := sql.SelectExpr(sql.ExprP("id, (similarity(name, ?) * 2 + similarity(short_description, ?) + similarity(full_description, ?) * 0.5) as s", cleanSearch, cleanSearch, cleanSearch))
+				join := sql.Select("id")
+				join = join.AppendSelectExprAs(
+					sql.P(func(builder *sql.Builder) {
+						builder.WriteString("similarity(name, ").Arg(cleanSearch).WriteString(") * 2").
+							WriteString(" + ").
+							WriteString("similarity(short_description, ").Arg(cleanSearch).WriteString(")").
+							WriteString(" + ").
+							WriteString("similarity(full_description, ").Arg(cleanSearch).WriteString(") * 0.5")
+					}),
+					"s",
+				)
 				join.From(sql.Table(mod.Table)).As("t1")
 				s.Join(join).On(s.C(mod.FieldID), join.C("id"))
 			})
@@ -64,10 +73,7 @@
 		}
 
 		if filter.TagIDs != nil && len(filter.TagIDs) > 0 {
-			query = query.Where(func(s *sql.Selector) {
-				t := sql.Table(modtag.Table)
-				s.Join(t).OnP(sql.ExprP("mod_tags.tag_id in ? AND mod_tags.mod_id = mods.id", filter.TagIDs))
-			})
+			query = query.Where(mod.HasModTagsWith(modtag.TagIDIn(filter.TagIDs...)))
 		}
 	}
 

db/oauth.go

@@ -5,6 +5,7 @@
 	"context"
 
 	"github.com/satisfactorymodding/smr-api/generated/ent"
+	"github.com/satisfactorymodding/smr-api/generated/ent/predicate"
 	"github.com/satisfactorymodding/smr-api/generated/ent/user"
 	"github.com/satisfactorymodding/smr-api/oauth"
 	"github.com/satisfactorymodding/smr-api/storage"
@@ -15,16 +16,18 @@
 	avatarURL := u.Avatar
 	u.Avatar = ""
 
-	find := From(ctx).User.Query().Where(user.Email(u.Email))
+	var oauthPredicate predicate.User
 
 	if u.Site == oauth.SiteGithub {
-		find = find.Where(user.GithubID(u.ID))
+		oauthPredicate = user.GithubID(u.ID)
 	} else if u.Site == oauth.SiteGoogle {
-		find = find.Where(user.GoogleID(u.ID))
+		oauthPredicate = user.GoogleID(u.ID)
 	} else if u.Site == oauth.SiteFacebook {
-		find = find.Where(user.FacebookID(u.ID))
+		oauthPredicate = user.FacebookID(u.ID)
 	}
 
+	find := From(ctx).User.Query().Where(user.Or(user.Email(u.Email), oauthPredicate))
+
 	found, err := find.First(ctx)
 	if err != nil && !ent.IsNotFound(err) {
 		return nil, err

gql/resolver_guides.go

@@ -207,9 +207,13 @@
 			).ToFunc())
 
 		if filter.Search != nil && *filter.Search != "" {
+			cleanedSearch := strings.ReplaceAll(*filter.Search, " ", " & ")
+
 			query = query.Modify(func(s *sql.Selector) {
-				s.Where(sql.ExprP("to_tsvector(name) @@ to_tsquery(?)", strings.ReplaceAll(*filter.Search, " ", " & ")))
-			}).Clone()
+				s.Where(sql.P(func(builder *sql.Builder) {
+					builder.WriteString("to_tsvector(name) @@ to_tsquery(").Arg(cleanedSearch).WriteString(")")
+				}))
+			}).GuideQuery
 		}
 
 		if filter.TagIDs != nil && len(filter.TagIDs) > 0 {

gql/resolver_mods.go

@@ -244,12 +244,28 @@
 				role = "editor"
 			}
 
-			if err := db.From(ctx).UserMod.Create().
-				SetUserID(userMod.UserID).
-				SetModID(modID).
-				SetRole(role).
-				Exec(ctx); err != nil {
-				return nil, err
+			var existing *ent.UserMod
+			for _, author := range authors {
+				if author.UserID == userMod.UserID {
+					existing = author
+					break
+				}
+			}
+
+			if existing != nil {
+				if err := db.From(ctx).UserMod.UpdateOne(existing).
+					SetRole(role).
+					Exec(ctx); err != nil {
+					return nil, err
+				}
+			} else {
+				if err := db.From(ctx).UserMod.Create().
+					SetUserID(userMod.UserID).
+					SetModID(modID).
+					SetRole(role).
+					Exec(ctx); err != nil {
+					return nil, err
+				}
 			}
 		}
 	}

gql/resolver_sml_versions.go

@@ -232,9 +232,13 @@
 			).ToFunc())
 
 		if filter.Search != nil && *filter.Search != "" {
+			cleanedSearch := strings.ReplaceAll(*filter.Search, " ", " & ")
+
 			query = query.Modify(func(s *sql.Selector) {
-				s.Where(sql.ExprP("to_tsvector(name) @@ to_tsquery(?)", strings.ReplaceAll(*filter.Search, " ", " & ")))
-			}).Clone()
+				s.Where(sql.P(func(builder *sql.Builder) {
+					builder.WriteString("to_tsvector(version) @@ to_tsquery(").Arg(cleanedSearch).WriteString(")")
+				}))
+			}).SmlVersionQuery
 		}
 	}
 	return query

gql/resolver_tags.go

@@ -95,9 +95,10 @@
 			cleanSearch := strings.ReplaceAll(strings.TrimSpace(*filter.Search), " ", " & ")
 
 			query = query.Modify(func(s *sql.Selector) {
-				s.AppendSelectExpr(sql.Expr("similarity(name, ?) as s", cleanSearch))
-				s.Where(sql.ExprP("s > 0.2"))
-			}).Clone()
+				s.Where(sql.P(func(builder *sql.Builder) {
+					builder.WriteString("similarity(name, ").Arg(cleanSearch).WriteString(") > 0.2")
+				}))
+			}).TagQuery
 		}
 
 		if filter.Ids != nil && len(filter.Ids) > 0 {

gql/resolver_users.go

@@ -300,7 +300,7 @@
 }
 
 func (r *userModResolver) Mod(ctx context.Context, obj *generated.UserMod) (*generated.Mod, error) {
-	result, err := db.From(ctx).Mod.Get(ctx, obj.ModID)
+	result, err := db.From(ctx).Mod.Query().WithTags().Where(mod.ID(obj.ModID)).Only(ctx)
 	if err != nil {
 		return nil, err
 	}

gql/resolver_versions.go

@@ -472,9 +472,13 @@
 			).ToFunc())
 
 		if filter.Search != nil && *filter.Search != "" {
+			cleanedSearch := strings.ReplaceAll(*filter.Search, " ", " & ")
+
 			query = query.Modify(func(s *sql.Selector) {
-				s.Where(sql.ExprP("to_tsvector(name) @@ to_tsquery(?)", strings.ReplaceAll(*filter.Search, " ", " & ")))
-			}).Clone()
+				s.Where(sql.P(func(builder *sql.Builder) {
+					builder.WriteString("to_tsvector(version) @@ to_tsquery(").Arg(cleanedSearch).WriteString(")")
+				}))
+			}).VersionQuery
 		}
 	}
 

migrations/utils/utils.go

@@ -16,7 +16,7 @@ func ReindexAllModFiles(ctx context.Context, withMetadata bool, modFilter func(*
 	offset := 0
 
 	for {
-		mods, err := db.From(ctx).Mod.Query().Limit(100).Offset(100).Order(mod.ByCreatedAt(sql.OrderDesc())).All(ctx)
+		mods, err := db.From(ctx).Mod.Query().Limit(100).Offset(offset).Order(mod.ByCreatedAt(sql.OrderDesc())).All(ctx)
 		if err != nil {
 			return err
 		}

util/converter/converter_windows.go

@@ -9,6 +9,7 @@ import (
 
 	"github.com/Vilsol/slox"
 	"github.com/chai2010/webp"
+
 	// GIF Support
 	_ "image/gif"
 	// JPEG Support