From d7d142152c510c89900c5125fb79520262f35d84 Mon Sep 17 00:00:00 2001 From: LandaMm Date: Sun, 15 Jun 2025 19:26:18 +0200 Subject: [PATCH] feat: repo update --- internal/repository/service_sessions.sql.go | 12 +++++++++++- internal/repository/user_sessions.sql.go | 12 +++++++++++- 2 files changed, 22 insertions(+), 2 deletions(-) diff --git a/internal/repository/service_sessions.sql.go b/internal/repository/service_sessions.sql.go index d5f4bdc..c52ab2d 100644 --- a/internal/repository/service_sessions.sql.go +++ b/internal/repository/service_sessions.sql.go @@ -102,7 +102,6 @@ func (q *Queries) GetServiceSessionByAccessJTI(ctx context.Context, accessTokenI const getServiceSessionByRefreshJTI = `-- name: GetServiceSessionByRefreshJTI :one SELECT id, service_id, client_id, user_id, issued_at, expires_at, last_active, ip_address, user_agent, access_token_id, refresh_token_id, is_active, revoked_at, scope, claims FROM service_sessions WHERE refresh_token_id = $1 - AND is_active = TRUE ` func (q *Queries) GetServiceSessionByRefreshJTI(ctx context.Context, refreshTokenID *uuid.UUID) (ServiceSession, error) { @@ -210,6 +209,17 @@ func (q *Queries) GetServiceSessions(ctx context.Context, arg GetServiceSessions return items, nil } +const getServiceSessionsCount = `-- name: GetServiceSessionsCount :one +SELECT COUNT(*) FROM service_sessions +` + +func (q *Queries) GetServiceSessionsCount(ctx context.Context) (int64, error) { + row := q.db.QueryRow(ctx, getServiceSessionsCount) + var count int64 + err := row.Scan(&count) + return count, err +} + const listActiveServiceSessionsByClient = `-- name: ListActiveServiceSessionsByClient :many SELECT id, service_id, client_id, user_id, issued_at, expires_at, last_active, ip_address, user_agent, access_token_id, refresh_token_id, is_active, revoked_at, scope, claims FROM service_sessions WHERE client_id = $1 diff --git a/internal/repository/user_sessions.sql.go b/internal/repository/user_sessions.sql.go index 0344d8e..c520a87 100644 --- a/internal/repository/user_sessions.sql.go +++ b/internal/repository/user_sessions.sql.go @@ -98,7 +98,6 @@ func (q *Queries) GetUserSessionByAccessJTI(ctx context.Context, accessTokenID * const getUserSessionByRefreshJTI = `-- name: GetUserSessionByRefreshJTI :one SELECT id, user_id, session_type, issued_at, expires_at, last_active, ip_address, user_agent, access_token_id, refresh_token_id, device_info, is_active, revoked_at FROM user_sessions WHERE refresh_token_id = $1 - AND is_active = TRUE ` func (q *Queries) GetUserSessionByRefreshJTI(ctx context.Context, refreshTokenID *uuid.UUID) (UserSession, error) { @@ -188,6 +187,17 @@ func (q *Queries) GetUserSessions(ctx context.Context, arg GetUserSessionsParams return items, nil } +const getUserSessionsCount = `-- name: GetUserSessionsCount :one +SELECT COUNT(*) FROM user_sessions +` + +func (q *Queries) GetUserSessionsCount(ctx context.Context) (int64, error) { + row := q.db.QueryRow(ctx, getUserSessionsCount) + var count int64 + err := row.Scan(&count) + return count, err +} + const listActiveUserSessions = `-- name: ListActiveUserSessions :many SELECT id, user_id, session_type, issued_at, expires_at, last_active, ip_address, user_agent, access_token_id, refresh_token_id, device_info, is_active, revoked_at FROM user_sessions WHERE user_id = $1