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 = ? `