From d1bdc68408f7a3b4285871bbcf6dba64484be06c Mon Sep 17 00:00:00 2001
From: Ruben Fiszel <ruben@rubenfiszel.com>
Date: Thu, 27 Jul 2023 17:54:07 +0200
Subject: [PATCH] nits supabase

---
 backend/oauth_connect.json                    |  5 +++
 backend/tests/worker.rs                       |  1 -
 .../src/lib/components/SchemaEditor.svelte    |  4 +-
 .../oauth/callback_supabase/+page.svelte      | 45 +++++++++++++++++++
 4 files changed, 51 insertions(+), 4 deletions(-)
 create mode 100644 frontend/src/routes/(root)/(logged)/oauth/callback_supabase/+page.svelte

diff --git a/backend/oauth_connect.json b/backend/oauth_connect.json
index bc05e78472..1cdc7ca86a 100644
--- a/backend/oauth_connect.json
+++ b/backend/oauth_connect.json
@@ -19,6 +19,11 @@
     "token_url": "https://slack.com/api/oauth.access",
     "scopes": ["chat:write:user", "users:read", "users:read.email"]
   },
+  "supabase_management": {
+    "auth_url": "https://api.supabase.com/v1/oauth/authorize",
+    "token_url": "https://api.supabase.com/v1/oauth/token",
+    "scopes": ["all"]
+  },
   "gsheets": {
     "auth_url": "https://accounts.google.com/o/oauth2/v2/auth",
     "token_url": "https://oauth2.googleapis.com/token",
diff --git a/backend/tests/worker.rs b/backend/tests/worker.rs
index 3960254f5e..0ead56a7e3 100644
--- a/backend/tests/worker.rs
+++ b/backend/tests/worker.rs
@@ -2516,7 +2516,6 @@ async fn test_flow_lock_all(db: Pool<Postgres>) {
         .modules
         .into_iter()
         .for_each(|m| {
-            tracing::error!("Module: {:?}", m.value);
             assert!(matches!(
                 m.value,
                 windmill_api_client::types::FlowModuleValue::RawScript(RawScript {
diff --git a/frontend/src/lib/components/SchemaEditor.svelte b/frontend/src/lib/components/SchemaEditor.svelte
index cf52d6e29e..7430d22b00 100644
--- a/frontend/src/lib/components/SchemaEditor.svelte
+++ b/frontend/src/lib/components/SchemaEditor.svelte
@@ -102,9 +102,7 @@
 		}
 		schema = schema
 		schemaString = JSON.stringify(schema, null, '\t')
-		if (jsonEditor) {
-			jsonEditor.setCode(schemaString)
-		}
+		jsonEditor?.setCode(schemaString)
 		dispatch('change', schema)
 	}
 
diff --git a/frontend/src/routes/(root)/(logged)/oauth/callback_supabase/+page.svelte b/frontend/src/routes/(root)/(logged)/oauth/callback_supabase/+page.svelte
new file mode 100644
index 0000000000..fb5777e402
--- /dev/null
+++ b/frontend/src/routes/(root)/(logged)/oauth/callback_supabase/+page.svelte
@@ -0,0 +1,45 @@
+<script lang="ts">
+	import { goto } from '$app/navigation'
+	import { page } from '$app/stores'
+	import { sendUserToast } from '$lib/toast'
+	import { onMount } from 'svelte'
+	import { OauthService } from '$lib/gen'
+	import { oauthStore } from '$lib/stores'
+	import CenteredPage from '$lib/components/CenteredPage.svelte'
+	import PageHeader from '$lib/components/PageHeader.svelte'
+	import { Loader2 } from 'lucide-svelte'
+
+	let client_name = 'supabase'
+	let error = $page.url.searchParams.get('error')
+	let code = $page.url.searchParams.get('code') ?? undefined
+	let state = $page.url.searchParams.get('state') ?? undefined
+
+	onMount(async () => {
+		if (error) {
+			sendUserToast(`Error trying to fetch projects from windmill: ${error}`, true)
+			goto('/resources')
+		} else if (code && state) {
+			try {
+				const res = await OauthService.connectCallback({
+					clientName: client_name,
+					requestBody: { code, state }
+				})
+				$oauthStore = res
+				goto(`/resources?callback=${client_name}`)
+			} catch (e) {
+				sendUserToast(`Error parsing the response token, ${e.body}`, true)
+				goto('/resources')
+			}
+		} else {
+			sendUserToast('Missing code or state as query params', true)
+			goto('/resources')
+		}
+	})
+</script>
+
+<CenteredPage>
+	<PageHeader title="Connection to supabase in progress" />
+	<div class="mx-auto w-0">
+		<Loader2 class="animate-spin" />
+	</div>
+</CenteredPage>