melosh/mal
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: extract helpers to reduce funlen in command_palette

Browse Source
This commit is contained in:
mkelvers
2026-06-11 13:08:44 +02:00
parent f360e22beb
commit 8e4ce81232
1 changed files with 33 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

56
internal/db/command_palette.go
View File

@@ -9,9 +9,7 @@ func (q *Queries) GetCommandPaletteContinueWatching(ctx context.Context, userID
if userID == "" { if userID == "" {
return nil, nil return nil, nil
} }
if limit <= 0 { limit = commandPaletteLimit(limit)
limit = 5
}
needle, pattern := commandPalettePattern(query) needle, pattern := commandPalettePattern(query)
rows, err := q.db.QueryContext(ctx, ` rows, err := q.db.QueryContext(ctx, `
@@ -85,9 +83,7 @@ func (q *Queries) GetCommandPaletteWatchlist(ctx context.Context, userID string,
if userID == "" { if userID == "" {
return nil, nil return nil, nil
} }
if limit <= 0 { limit = commandPaletteLimit(limit)
limit = 5
}
needle, pattern := commandPalettePattern(query) needle, pattern := commandPalettePattern(query)
rows, err := q.db.QueryContext(ctx, ` rows, err := q.db.QueryContext(ctx, `
@@ -132,23 +128,8 @@ LIMIT ?`, userID, needle, pattern, pattern, pattern, pattern, limit)
items := make([]GetUserWatchListRow, 0, int(limit)) items := make([]GetUserWatchListRow, 0, int(limit))
for rows.Next() { for rows.Next() {
var item GetUserWatchListRow item, err := scanWatchListEntry(rows)
if err := rows.Scan( if err != nil {
&item.ID,
&item.UserID,
&item.AnimeID,
&item.Status,
&item.CreatedAt,
&item.UpdatedAt,
&item.CurrentEpisode,
&item.LastEpisodeAt,
&item.CurrentTimeSeconds,
&item.TitleOriginal,
&item.TitleEnglish,
&item.TitleJapanese,
&item.ImageUrl,
&item.Airing,
); err != nil {
return nil, err return nil, err
} }
items = append(items, item) items = append(items, item)
@@ -160,11 +141,40 @@ LIMIT ?`, userID, needle, pattern, pattern, pattern, pattern, limit)
return items, nil return items, nil
} }
func scanWatchListEntry(rows scanner) (GetUserWatchListRow, error) {
var item GetUserWatchListRow
err := rows.Scan(
&item.ID,
&item.UserID,
&item.AnimeID,
&item.Status,
&item.CreatedAt,
&item.UpdatedAt,
&item.CurrentEpisode,
&item.LastEpisodeAt,
&item.CurrentTimeSeconds,
&item.TitleOriginal,
&item.TitleEnglish,
&item.TitleJapanese,
&item.ImageUrl,
&item.Airing,
)
return item, err
}
func commandPalettePattern(query string) (string, string) { func commandPalettePattern(query string) (string, string) {
needle := strings.ToLower(strings.TrimSpace(query)) needle := strings.ToLower(strings.TrimSpace(query))
return needle, "%" + needle + "%" return needle, "%" + needle + "%"
} }
func commandPaletteLimit(limit int64) int64 {
if limit <= 0 {
return 5
}
return limit
}
type scanner interface { type scanner interface {
Scan(dest ...interface{}) error Scan(dest ...interface{}) error
} }