Something went wrong. Try again.
This repository has no description
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206-- name: GetAccount :oneSELECT * FROM account WHERE did = $1LIMIT 1;
-- name: UpsertIdentity :execINSERT INTO account (did, handle, upstream_status) VALUES ($1, $2, $3)ON CONFLICT (did) DO UPDATE SET handle = EXCLUDED.handle, upstream_status = EXCLUDED.upstream_status;
-- name: UpsertRecord :execINSERT INTO record (account_did, collection, rkey, version, data_json) VALUES ($1, $2, $3, $4, $5)ON CONFLICT (account_did, collection, rkey) DO UPDATE SET version = EXCLUDED.version, data_json = EXCLUDED.data_json;
-- name: DeleteRecord :execDELETE FROM record WHERE account_did = $1 AND collection = $2 AND rkey = $3;
-- name: UpsertItem :execINSERT INTO item (scene_did, account_did, rkey, version) VALUES ($1, $2, $3, $4)ON CONFLICT (scene_did, account_did, rkey) DO UPDATE SET version = EXCLUDED.version;
-- name: DeleteItem :execDELETE FROM item WHERE scene_did = $1 AND account_did = $2 AND rkey = $3;
-- name: GetRecord :oneSELECT * FROM record WHERE account_did = $1 AND collection = $2 AND rkey = $3LIMIT 1;
-- name: ListSceneItems :manySELECT sqlc.embed(item), sqlc.embed(record)FROM itemJOIN record ON record.rkey = item.rkey AND record.account_did = item.account_did AND record.collection = 'social.scrumble.beta.collection.item'JOIN account ON account.did = item.account_did AND account.upstream_status = 'active' AND account.status = 'active'WHERE -- TODO: filter by membership status (etc) item.scene_did = $1ORDER BY item.created_at DESCLIMIT 30;
-- name: ListAccountItems :manySELECT sqlc.embed(item), sqlc.embed(record)FROM itemJOIN record ON record.rkey = item.rkey AND record.account_did = item.account_did AND record.collection = 'social.scrumble.beta.collection.item'WHERE -- TODO: filter by membership status (etc) item.account_did = $1ORDER BY item.created_at DESCLIMIT 30;
-- name: UpsertAccountJoin :execINSERT INTO membership (account_did, scene_did, joined_at) VALUES ($1, $2, $3)ON CONFLICT (account_did, scene_did) DO UPDATE SET joined_at = EXCLUDED.joined_at;
-- name: DeleteAccountJoin :execINSERT INTO membership (account_did, scene_did, joined_at) VALUES ($1, $2, NULL)ON CONFLICT (account_did, scene_did) DO UPDATE SET joined_at = NULL;
-- name: UpsertSceneMember :execINSERT INTO membership (scene_did, account_did, invited_at, role) VALUES ($1, $2, $3, $4)ON CONFLICT (account_did, scene_did) DO UPDATE SET invited_at = EXCLUDED.invited_at, role = EXCLUDED.role;
-- name: DeleteSceneMember :execINSERT INTO membership (scene_did, account_did, invited_at, role) VALUES ($1, $2, NULL, NULL)ON CONFLICT (account_did, scene_did) DO UPDATE SET invited_at = NULL, role = NULL;
-- name: ListSceneMembers :manySELECT sqlc.embed(membership), sqlc.embed(record)FROM membershipJOIN account ON account.did = membership.account_did AND account.upstream_status = 'active' AND account.status = 'active'JOIN record ON record.account_did = membership.account_did AND record.collection = 'social.scrumble.beta.account.profile' AND record.rkey = 'self'WHERE membership.scene_did = $1 AND membership.invited_at IS NOT NULL AND membership.joined_at IS NOT NULL AND (sqlc.narg('cursor')::timestamptz IS NULL OR membership.invited_at > sqlc.narg('cursor')::timestamptz)ORDER BY membership.invited_at ASCLIMIT 30;
-- name: ListSceneOpenInvites :manySELECT sqlc.embed(membership), sqlc.embed(record)FROM membershipJOIN account ON account.did = membership.account_did AND account.upstream_status = 'active' AND account.status = 'active'JOIN record ON record.account_did = membership.account_did AND record.collection = 'social.scrumble.beta.account.profile' AND record.rkey = 'self'WHERE membership.scene_did = $1 AND membership.invited_at IS NOT NULL AND membership.joined_at IS NULL AND (sqlc.narg('cursor')::timestamptz IS NULL OR membership.invited_at > sqlc.narg('cursor')::timestamptz)ORDER BY membership.invited_at ASCLIMIT 30;
-- name: ListSceneMemberRequests :manySELECT sqlc.embed(membership), sqlc.embed(record)FROM membershipJOIN account ON account.did = membership.account_did AND account.upstream_status = 'active' AND account.status = 'active'JOIN record ON record.account_did = membership.account_did AND record.collection = 'social.scrumble.beta.account.profile' AND record.rkey = 'self'WHERE membership.scene_did = $1 AND membership.invited_at IS NULL AND membership.joined_at IS NOT NULL AND (sqlc.narg('cursor')::timestamptz IS NULL OR membership.joined_at > sqlc.narg('cursor')::timestamptz)ORDER BY membership.joined_at ASCLIMIT 30;
-- name: ListAccountScenes :manySELECT sqlc.embed(membership), sqlc.embed(record)FROM membershipJOIN account ON account.did = membership.scene_did AND account.upstream_status = 'active' AND account.status = 'active'JOIN record ON record.account_did = membership.scene_did AND record.collection = 'social.scrumble.beta.scene.declaration' AND record.rkey = 'self'WHERE membership.account_did = $1 AND membership.invited_at IS NOT NULL AND membership.joined_at IS NOT NULL AND (sqlc.narg('cursor')::timestamptz IS NULL OR membership.joined_at > sqlc.narg('cursor')::timestamptz)ORDER BY membership.joined_at ASCLIMIT 30;
-- ### OAuth Queries ###
-- name: GetOAuthSession :oneSELECT * FROM oauth_session WHERE account_did = $1 AND session_id = $2LIMIT 1;
-- name: UpsertOAuthSession :execINSERT INTO oauth_session (account_did, session_id, data_json) VALUES ($1, $2, $3)ON CONFLICT (account_did, session_id) DO UPDATE SET data_json = EXCLUDED.data_json, updated_at = now();
-- name: DeleteOAuthSession :execDELETE FROM oauth_session WHERE account_did = $1 AND session_id = $2;
-- name: GetOAuthAuthRequest :oneSELECT * FROM oauth_auth_request WHERE state = $1LIMIT 1;
-- name: InsertOAuthAuthRequest :execINSERT INTO oauth_auth_request (state, data_json) VALUES ($1, $2);
-- name: DeleteOAuthAuthRequest :execDELETE FROM oauth_auth_request WHERE state = $1;