add patreon integration (step 1)

api/proto/user_service/user_service.proto

@@ -284,3 +284,16 @@ service SocializeService {
   rpc GetChatsForChannel(GetChatsRequest) returns (ipc.ChatMessages);
   rpc GetModList(GetModListRequest) returns (GetModListResponse);
 }
+
+message Integration {
+  string uuid = 1;
+  string integration_name = 2;
+}
+
+message GetIntegrationsRequest {}
+
+message IntegrationsResponse { repeated Integration integrations = 1; }
+
+service IntegrationService {
+  rpc GetIntegrations(GetIntegrationsRequest) returns (IntegrationsResponse);
+}

bruno/patreon/Get Campaign.bru

@@ -0,0 +1,19 @@
+meta {
+  name: Get Campaign
+  type: http
+  seq: 3
+}
+
+get {
+  url: https://www.patreon.com/api/oauth2/v2/campaigns/1311241?fields[campaign]=created_at,creation_name,discord_server_id,image_small_url,image_url,is_charged_immediately,is_monthly,main_video_embed,main_video_url,one_liner,one_liner,patron_count,pay_per_name,pledge_url,published_at,summary,thanks_embed,thanks_msg,thanks_video_url
+  body: none
+  auth: inherit
+}
+
+params:query {
+  fields[campaign]: created_at,creation_name,discord_server_id,image_small_url,image_url,is_charged_immediately,is_monthly,main_video_embed,main_video_url,one_liner,one_liner,patron_count,pay_per_name,pledge_url,published_at,summary,thanks_embed,thanks_msg,thanks_video_url
+}
+
+headers {
+  Content-Type: application/json
+}

bruno/patreon/Get Identity.bru

@@ -0,0 +1,23 @@
+meta {
+  name: Get Identity
+  type: http
+  seq: 2
+}
+
+get {
+  url: https://www.patreon.com/api/oauth2/v2/identity?fields[user]=email,first_name,last_name&fields[campaign]=summary,is_monthly&fields[member]=full_name,is_follower,last_charge_date,last_charge_status,lifetime_support_cents,currently_entitled_amount_cents,patron_status&fields[tier]=amount_cents,created_at,description,discord_role_ids,edited_at,patron_count,published,published_at,requires_shipping,title,url&include=memberships
+  body: none
+  auth: inherit
+}
+
+params:query {
+  fields[user]: email,first_name,last_name
+  fields[campaign]: summary,is_monthly
+  fields[member]: full_name,is_follower,last_charge_date,last_charge_status,lifetime_support_cents,currently_entitled_amount_cents,patron_status
+  fields[tier]: amount_cents,created_at,description,discord_role_ids,edited_at,patron_count,published,published_at,requires_shipping,title,url
+  include: memberships
+}
+
+headers {
+  Content-Type: application/json
+}

bruno/patreon/Get Member.bru

@@ -0,0 +1,21 @@
+meta {
+  name: Get Member
+  type: http
+  seq: 4
+}
+
+get {
+  url: https://www.patreon.com/api/oauth2/v2/members/b2fddab5-1ba5-402c-b825-7b4d8189c56a?fields[address]=line_1,line_2,addressee,postal_code,city&fields[member]=full_name,is_follower,last_charge_date&include=address,user
+  body: none
+  auth: inherit
+}
+
+params:query {
+  fields[address]: line_1,line_2,addressee,postal_code,city
+  fields[member]: full_name,is_follower,last_charge_date
+  include: address,user
+}
+
+headers {
+  Content-Type: application/json
+}

bruno/patreon/bruno.json

@@ -0,0 +1,9 @@
+{
+  "version": "1",
+  "name": "patreon",
+  "type": "collection",
+  "ignore": [
+    "node_modules",
+    ".git"
+  ]
+}

bruno/patreon/collection.bru

@@ -0,0 +1,7 @@
+auth {
+  mode: bearer
+}
+
+auth:bearer {
+  token: {{PATREON_TOKEN}}
+}

bruno/patreon/environments/Cesar - Patreon.bru

@@ -0,0 +1,3 @@
+vars:secret [
+  PATREON_TOKEN
+]

bruno/woogles-api/AuthenticationService/ChangePassword.bru

@@ -0,0 +1,19 @@
+meta {
+  name: ChangePassword
+  type: http
+  seq: 2
+}
+
+post {
+  url: {{baseURL}}/api/user_service.AuthenticationService/ChangePassword
+  body: json
+  auth: none
+}
+
+headers {
+  Cookie: session=yTJ8D2zEKQkxmnyUAGe7dJ
+}
+
+body:json {
+  {"old_password": "cesar", "password": "{{goodpassword}}"}
+}

bruno/woogles-api/AuthenticationService/Login.bru

@@ -0,0 +1,19 @@
+meta {
+  name: Login
+  type: http
+  seq: 1
+}
+
+post {
+  url: {{baseURL}}/api/user_service.AuthenticationService/Login
+  body: json
+  auth: none
+}
+
+headers {
+  : 
+}
+
+body:json {
+  {"username": "cesar", "password": "{{goodpassword}}"}
+}

bruno/woogles-api/Get User Details.bru

@@ -0,0 +1,21 @@
+meta {
+  name: Get User Details
+  type: http
+  seq: 1
+}
+
+post {
+  url: {{baseURL}}/api/config_service.ConfigService/GetUserDetails
+  body: json
+  auth: none
+}
+
+body:json {
+  {
+      "username": "rightbehindyou"
+  }
+}
+
+assert {
+  res.body.is_admin: eq true
+}

bruno/woogles-api/RegistrationService/Register.bru

@@ -0,0 +1,19 @@
+meta {
+  name: Register
+  type: http
+  seq: 1
+}
+
+post {
+  url: {{baseURL}}/api/user_service.RegistrationService/Register
+  body: json
+  auth: none
+}
+
+headers {
+  : 
+}
+
+body:json {
+  {"username": "use-a-slur-here-for-testing", "password": "password", "email": "foo"}
+}

bruno/woogles-api/Set User Permissions.bru

@@ -0,0 +1,26 @@
+meta {
+  name: Set User Permissions
+  type: http
+  seq: 3
+}
+
+post {
+  url: {{baseURL}}/api/config_service.ConfigService/SetUserPermissions
+  body: json
+  auth: none
+}
+
+body:json {
+  {
+      "username": "penumbra",
+    "director": false,
+    "admin": false,
+    "mod": true,
+    "bot": false
+
+  }
+}
+
+assert {
+  res.body.is_admin: eq true
+}

bruno/woogles-api/UserService/GetChatsForChannel.bru

@@ -0,0 +1,17 @@
+meta {
+  name: GetChatsForChannel
+  type: http
+  seq: 1
+}
+
+post {
+  url: {{baseURL}}/api/user_service.SocializeService/GetChatsForChannel
+  body: json
+  auth: none
+}
+
+body:json {
+  {
+    "channel": "chat.game.q4JhmVVm"
+  }
+}

bruno/woogles-api/bruno.json

@@ -0,0 +1,9 @@
+{
+  "version": "1",
+  "name": "woogles-api",
+  "type": "collection",
+  "ignore": [
+    "node_modules",
+    ".git"
+  ]
+}

bruno/woogles-api/collection.bru

@@ -0,0 +1,8 @@
+headers {
+  X-Api-Key: {{APIKey}}
+  Content-Type: application/json
+}
+
+auth {
+  mode: none
+}

bruno/woogles-api/environments/local.bru

@@ -0,0 +1,6 @@
+vars {
+  baseURL: http://liwords.localhost
+}
+vars:secret [
+  goodpassword
+]

bruno/woogles-api/environments/prod.bru

@@ -0,0 +1,6 @@
+vars {
+  baseURL: https://woogles.io
+}
+vars:secret [
+  APIKey
+]

cmd/liwords-api/main.go

@@ -194,7 +194,8 @@ func main() {
 
 	mementoService := memento.NewMementoService(stores.UserStore, stores.GameStore,
 		stores.GameDocumentStore, cfg)
-	integrationService := integrations.NewIntegrationService(stores.SessionStore, cfg)
+	oauthIntegrationService := integrations.NewOAuthIntegrationService(stores.SessionStore, stores.Queries, cfg)
+	integrationService := integrations.NewIntegrationService(stores.Queries)
 	authenticationService := auth.NewAuthenticationService(stores.UserStore, stores.SessionStore, stores.ConfigStore,
 		cfg.SecretKey, cfg.MailgunKey, cfg.DiscordToken, cfg.ArgonConfig)
 	registrationService := registration.NewRegistrationService(stores.UserStore, cfg.ArgonConfig)
@@ -225,11 +226,12 @@ func main() {
 		"memento-api",
 		otelhttp.WithSpanNameFormatter(customHTTPSpanNameFormatter),
 	)))
-	router.Handle(integrations.IntegrationServicePrefix, otelhttp.WithRouteTag(integrations.IntegrationServicePrefix, otelhttp.NewHandler(
-		middlewares.Then(integrationService),
-		"integration-handlers",
-		otelhttp.WithSpanNameFormatter(customHTTPSpanNameFormatter),
-	)))
+	router.Handle(integrations.OAuthIntegrationServicePrefix,
+		otelhttp.WithRouteTag(integrations.OAuthIntegrationServicePrefix, otelhttp.NewHandler(
+			middlewares.Then(oauthIntegrationService),
+			"oauth-integration-handlers",
+			otelhttp.WithSpanNameFormatter(customHTTPSpanNameFormatter),
+		)))
 
 	interceptors := connect.WithInterceptors(otcInterceptor)
 	// We want to emit default values for backwards compatibility.
@@ -282,6 +284,9 @@ func main() {
 	connectapi.Handle(
 		comments_serviceconnect.NewGameCommentServiceHandler(commentService, options),
 	)
+	connectapi.Handle(
+		user_serviceconnect.NewIntegrationServiceHandler(integrationService, options),
+	)
 
 	connectapichain := middlewares.Then(connectapi)
 

db/migrations/20241130115623_integrations.up.sql

@@ -2,10 +2,12 @@ BEGIN;
 
 CREATE TABLE integrations (
     id BIGSERIAL PRIMARY KEY,
+    uuid UUID DEFAULT gen_random_uuid () NOT NULL UNIQUE,
     user_id BIGINT NOT NULL,
     integration_name TEXT NOT NULL,
     data JSONB NOT NULL DEFAULT '{}'::jsonb,
-    FOREIGN KEY (user_id) REFERENCES users (id)
+    FOREIGN KEY (user_id) REFERENCES users (id),
+    UNIQUE(user_id, integration_name)
 );
 
 CREATE INDEX integrations_user_idx ON integrations USING btree(user_id);

db/queries/integrations.sql

@@ -0,0 +1,18 @@
+-- name: AddOrUpdateIntegration :one
+INSERT INTO integrations(user_id, integration_name, data)
+VALUES (
+  (SELECT id FROM users WHERE users.uuid = @user_uuid),
+  $1,
+  $2
+)
+ON CONFLICT (user_id, integration_name)
+DO UPDATE SET data = EXCLUDED.data
+RETURNING integrations.uuid;
+
+-- name: GetIntegrations :many
+SELECT uuid, integration_name FROM integrations
+WHERE user_id = (SELECT id from users where users.uuid = @user_uuid);
+
+-- name: GetIntegrationData :one
+SELECT data FROM integrations
+WHERE uuid = $1;