feat: service and user session queries
This commit is contained in:
44
queries/service_sessions.sql
Normal file
44
queries/service_sessions.sql
Normal file
@ -0,0 +1,44 @@
|
|||||||
|
-- name: CreateServiceSession :one
|
||||||
|
INSERT INTO service_sessions (
|
||||||
|
client_id, user_id, issued_at, expires_at, last_active,
|
||||||
|
ip_address, user_agent, is_active, scope, claims
|
||||||
|
) VALUES (
|
||||||
|
$1, $2, NOW(), $3, $4,
|
||||||
|
$5, $6, $6, TRUE, $7, $8
|
||||||
|
)
|
||||||
|
RETURNING *;
|
||||||
|
|
||||||
|
-- name: ListActiveServiceSessionsByClient :many
|
||||||
|
SELECT * FROM service_sessions
|
||||||
|
WHERE client_id = $1
|
||||||
|
AND is_active = TRUE
|
||||||
|
ORDER BY issued_at DESC;
|
||||||
|
|
||||||
|
-- name: ListActiveServiceSessionsByUser :many
|
||||||
|
SELECT * FROM service_sessions
|
||||||
|
WHERE user_id = $1
|
||||||
|
AND is_active = TRUE
|
||||||
|
ORDER BY issued_at DESC;
|
||||||
|
|
||||||
|
-- name: GetServiceSessionByToken :one
|
||||||
|
SELECT * FROM service_sessions
|
||||||
|
WHERE refresh_token = $1
|
||||||
|
AND is_active = TRUE;
|
||||||
|
|
||||||
|
-- name: RevokeServiceSession :exec
|
||||||
|
UPDATE service_sessions
|
||||||
|
SET is_active = FALSE,
|
||||||
|
revoked_at = NOW()
|
||||||
|
WHERE id = $1
|
||||||
|
AND is_active = TRUE;
|
||||||
|
|
||||||
|
-- name: UpdateServiceSessionLastActive :exec
|
||||||
|
UPDATE service_sessions
|
||||||
|
SET last_active = NOW()
|
||||||
|
WHERE id = $1
|
||||||
|
AND is_active = TRUE;
|
||||||
|
|
||||||
|
-- name: ListAllServiceSessions :many
|
||||||
|
SELECT * FROM service_sessions
|
||||||
|
ORDER BY issued_at DESC
|
||||||
|
LIMIT $1 OFFSET $2;
|
40
queries/user_sessions.sql
Normal file
40
queries/user_sessions.sql
Normal file
@ -0,0 +1,40 @@
|
|||||||
|
-- name: CreateUserSession :one
|
||||||
|
INSERT INTO user_sessions (
|
||||||
|
user_id, session_type, issued_at, expires_at, last_active,
|
||||||
|
ip_address, user_agent,
|
||||||
|
device_info, is_active
|
||||||
|
) VALUES (
|
||||||
|
$1, $2, NOW(), $3, $4,
|
||||||
|
$5, $6,
|
||||||
|
$7, TRUE
|
||||||
|
)
|
||||||
|
RETURNING *;
|
||||||
|
|
||||||
|
-- name: ListActiveUserSessions :many
|
||||||
|
SELECT * FROM user_sessions
|
||||||
|
WHERE user_id = $1
|
||||||
|
AND is_active = TRUE
|
||||||
|
ORDER BY issued_at DESC;
|
||||||
|
|
||||||
|
-- name: GetUserSessionByToken :one
|
||||||
|
SELECT * FROM user_sessions
|
||||||
|
WHERE refresh_token = $1
|
||||||
|
AND is_active = TRUE;
|
||||||
|
|
||||||
|
-- name: RevokeUserSession :exec
|
||||||
|
UPDATE user_sessions
|
||||||
|
SET is_active = FALSE,
|
||||||
|
revoked_at = NOW()
|
||||||
|
WHERE id = $1
|
||||||
|
AND is_active = TRUE;
|
||||||
|
|
||||||
|
-- name: UpdateSessionLastActive :exec
|
||||||
|
UPDATE user_sessions
|
||||||
|
SET last_active = NOW()
|
||||||
|
WHERE id = $1
|
||||||
|
AND is_active = TRUE;
|
||||||
|
|
||||||
|
-- name: ListAllSessions :many
|
||||||
|
SELECT * FROM user_sessions
|
||||||
|
ORDER BY issued_at DESC
|
||||||
|
LIMIT $1 OFFSET $2;
|
Reference in New Issue
Block a user