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

fix: wrap datetime() in jikan cache expiry queries

Browse Source
This commit is contained in:
mkelvers
2026-05-20 17:01:54 +02:00
committed by Mikkel Elvers
parent 285367ad84
commit db654c8dee
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
internal/db/queries.sql
View File

@@ -212,7 +212,7 @@ ORDER BY related.id DESC;
-- name: GetJikanCache :one -- name: GetJikanCache :one
SELECT data FROM jikan_cache SELECT data FROM jikan_cache
WHERE key = ? AND expires_at > CURRENT_TIMESTAMP LIMIT 1; WHERE key = ? AND datetime(expires_at) > CURRENT_TIMESTAMP LIMIT 1;
-- name: GetJikanCacheStale :one -- name: GetJikanCacheStale :one
SELECT data FROM jikan_cache SELECT data FROM jikan_cache
@@ -227,7 +227,7 @@ ON CONFLICT (key) DO UPDATE SET
created_at = CURRENT_TIMESTAMP; created_at = CURRENT_TIMESTAMP;
-- name: DeleteExpiredJikanCache :exec -- name: DeleteExpiredJikanCache :exec
DELETE FROM jikan_cache WHERE expires_at <= CURRENT_TIMESTAMP; DELETE FROM jikan_cache WHERE datetime(expires_at) <= CURRENT_TIMESTAMP;
-- name: EnqueueAnimeFetchRetry :exec -- name: EnqueueAnimeFetchRetry :exec
INSERT INTO anime_fetch_retry (anime_id, attempts, next_retry_at, last_error, updated_at) INSERT INTO anime_fetch_retry (anime_id, attempts, next_retry_at, last_error, updated_at)

4
internal/db/queries.sql.go
View File

@@ -107,7 +107,7 @@ func (q *Queries) DeleteContinueWatchingEntry(ctx context.Context, arg DeleteCon
} }
const deleteExpiredJikanCache = `-- name: DeleteExpiredJikanCache :exec const deleteExpiredJikanCache = `-- name: DeleteExpiredJikanCache :exec
DELETE FROM jikan_cache WHERE expires_at <= CURRENT_TIMESTAMP DELETE FROM jikan_cache WHERE datetime(expires_at) <= CURRENT_TIMESTAMP
` `
func (q *Queries) DeleteExpiredJikanCache(ctx context.Context) error { func (q *Queries) DeleteExpiredJikanCache(ctx context.Context) error {
@@ -443,7 +443,7 @@ func (q *Queries) GetEpisodeProviderMapping(ctx context.Context, arg GetEpisodeP
const getJikanCache = `-- name: GetJikanCache :one const getJikanCache = `-- name: GetJikanCache :one
SELECT data FROM jikan_cache SELECT data FROM jikan_cache
WHERE key = ? AND expires_at > CURRENT_TIMESTAMP LIMIT 1 WHERE key = ? AND datetime(expires_at) > CURRENT_TIMESTAMP LIMIT 1
` `
func (q *Queries) GetJikanCache(ctx context.Context, key string) (string, error) { func (q *Queries) GetJikanCache(ctx context.Context, key string) (string, error) {