query.sql 4.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110
  1. -- Queries added to query.sql must be compiled into Go code with sqlc. Read README.md for details.
  2. -- Federation related queries.
  3. -- name: GetFollowerCount :one
  4. SElECT count(*) FROM ap_followers WHERE approved_at is not null;
  5. -- name: GetLocalPostCount :one
  6. SElECT count(*) FROM ap_outbox;
  7. -- name: GetFederationFollowersWithOffset :many
  8. SELECT iri, inbox, name, username, image, created_at FROM ap_followers WHERE approved_at is not null ORDER BY created_at DESC LIMIT $1 OFFSET $2;
  9. -- name: GetRejectedAndBlockedFollowers :many
  10. SELECT iri, name, username, image, created_at, disabled_at FROM ap_followers WHERE disabled_at is not null;
  11. -- name: GetFederationFollowerApprovalRequests :many
  12. SELECT iri, inbox, name, username, image, created_at FROM ap_followers WHERE approved_at IS null AND disabled_at is null;
  13. -- name: ApproveFederationFollower :exec
  14. UPDATE ap_followers SET approved_at = $1, disabled_at = null WHERE iri = $2;
  15. -- name: RejectFederationFollower :exec
  16. UPDATE ap_followers SET approved_at = null, disabled_at = $1 WHERE iri = $2;
  17. -- name: GetFollowerByIRI :one
  18. SELECT iri, inbox, name, username, image, request, request_object, created_at, approved_at, disabled_at FROM ap_followers WHERE iri = $1;
  19. -- name: GetOutboxWithOffset :many
  20. SELECT value FROM ap_outbox LIMIT $1 OFFSET $2;
  21. -- name: GetObjectFromOutboxByIRI :one
  22. SELECT value, live_notification, created_at FROM ap_outbox WHERE iri = $1;
  23. -- name: RemoveFollowerByIRI :exec
  24. DELETE FROM ap_followers WHERE iri = $1;
  25. -- name: AddFollower :exec
  26. INSERT INTO ap_followers(iri, inbox, request, request_object, name, username, image, approved_at) values($1, $2, $3, $4, $5, $6, $7, $8);
  27. -- name: AddToOutbox :exec
  28. INSERT INTO ap_outbox(iri, value, type, live_notification) values($1, $2, $3, $4);
  29. -- name: AddToAcceptedActivities :exec
  30. INSERT INTO ap_accepted_activities(iri, actor, type, timestamp) values($1, $2, $3, $4);
  31. -- name: GetInboundActivityCount :one
  32. SELECT count(*) FROM ap_accepted_activities;
  33. -- name: GetInboundActivitiesWithOffset :many
  34. SELECT iri, actor, type, timestamp FROM ap_accepted_activities ORDER BY timestamp DESC LIMIT $1 OFFSET $2;
  35. -- name: DoesInboundActivityExist :one
  36. SELECT count(*) FROM ap_accepted_activities WHERE iri = $1 AND actor = $2 AND TYPE = $3;
  37. -- name: UpdateFollowerByIRI :exec
  38. UPDATE ap_followers SET inbox = $1, name = $2, username = $3, image = $4 WHERE iri = $5;
  39. -- name: BanIPAddress :exec
  40. INSERT INTO ip_bans(ip_address, notes) values($1, $2);
  41. -- name: RemoveIPAddressBan :exec
  42. DELETE FROM ip_bans WHERE ip_address = $1;
  43. -- name: IsIPAddressBlocked :one
  44. SELECT count(*) FROM ip_bans WHERE ip_address = $1;
  45. -- name: GetIPAddressBans :many
  46. SELECT * FROM ip_bans;
  47. -- name: AddNotification :exec
  48. INSERT INTO notifications (channel, destination) VALUES($1, $2);
  49. -- name: GetNotificationDestinationsForChannel :many
  50. SELECT destination FROM notifications WHERE channel = $1;
  51. -- name: RemoveNotificationDestinationForChannel :exec
  52. DELETE FROM notifications WHERE channel = $1 AND destination = $2;
  53. -- name: AddAuthForUser :exec
  54. INSERT INTO auth(user_id, token, type) values($1, $2, $3);
  55. -- name: GetUserByAuth :one
  56. SELECT users.id, display_name, display_color, users.created_at, disabled_at, previous_names, namechanged_at, authenticated_at, scopes FROM auth, users WHERE token = $1 AND auth.type = $2 AND users.id = auth.user_id;
  57. -- name: AddAccessTokenForUser :exec
  58. INSERT INTO user_access_tokens(token, user_id) values($1, $2);
  59. -- name: GetUserByAccessToken :one
  60. SELECT users.id, display_name, display_color, users.created_at, disabled_at, previous_names, namechanged_at, authenticated_at, scopes FROM users, user_access_tokens WHERE token = $1 AND users.id = user_id;
  61. -- name: GetUserDisplayNameByToken :one
  62. SELECT display_name FROM users, user_access_tokens WHERE token = $1 AND users.id = user_id AND disabled_at = NULL;
  63. -- name: SetAccessTokenToOwner :exec
  64. UPDATE user_access_tokens SET user_id = $1 WHERE token = $2;
  65. -- name: SetUserAsAuthenticated :exec
  66. UPDATE users SET authenticated_at = CURRENT_TIMESTAMP WHERE id = $1;
  67. -- name: GetMessagesFromUser :many
  68. SELECT id, body, hidden_at, timestamp FROM messages WHERE eventType = 'CHAT' AND user_id = $1 ORDER BY TIMESTAMP DESC;
  69. -- name: IsDisplayNameAvailable :one
  70. SELECT count(*) FROM users WHERE display_name = $1 AND ( type='API' OR authenticated_at IS NOT NULL ) AND disabled_at IS NULL;
  71. -- name: ChangeDisplayName :exec
  72. UPDATE users SET display_name = $1, previous_names = previous_names || $2, namechanged_at = $3 WHERE id = $4;
  73. -- name: ChangeDisplayColor :exec
  74. UPDATE users SET display_color = $1 WHERE id = $2;