From a51a5e17e1fd5bb771c7a4c3ed0abad82a5ff86e Mon Sep 17 00:00:00 2001 From: mkelvers Date: Thu, 23 Apr 2026 16:45:41 +0200 Subject: [PATCH] db: add DeleteUser --- internal/db/querier.go | 1 + internal/db/queries.sql.go | 9 +++++++++ 2 files changed, 10 insertions(+) diff --git a/internal/db/querier.go b/internal/db/querier.go index fd56ec3..68a4522 100644 --- a/internal/db/querier.go +++ b/internal/db/querier.go @@ -16,6 +16,7 @@ type Querier interface { DeleteContinueWatchingEntry(ctx context.Context, arg DeleteContinueWatchingEntryParams) error DeleteExpiredJikanCache(ctx context.Context) error DeleteSession(ctx context.Context, id string) error + DeleteUser(ctx context.Context, id string) error DeleteUserSessions(ctx context.Context, userID string) error DeleteWatchListEntry(ctx context.Context, arg DeleteWatchListEntryParams) error EnqueueAnimeFetchRetry(ctx context.Context, arg EnqueueAnimeFetchRetryParams) error diff --git a/internal/db/queries.sql.go b/internal/db/queries.sql.go index 4645bba..63ff6fd 100644 --- a/internal/db/queries.sql.go +++ b/internal/db/queries.sql.go @@ -115,6 +115,15 @@ func (q *Queries) DeleteSession(ctx context.Context, id string) error { return err } +const deleteUser = `-- name: DeleteUser :exec +DELETE FROM user WHERE id = ? +` + +func (q *Queries) DeleteUser(ctx context.Context, id string) error { + _, err := q.db.ExecContext(ctx, deleteUser, id) + return err +} + const deleteUserSessions = `-- name: DeleteUserSessions :exec DELETE FROM session WHERE user_id = ? `