wip

Author: jgoux

apps/deploy-worker/.gitignore

@@ -0,0 +1,28 @@
+# dev
+.yarn/
+!.yarn/releases
+.vscode/*
+!.vscode/launch.json
+!.vscode/*.code-snippets
+.idea/workspace.xml
+.idea/usage.statistics.xml
+.idea/shelf
+
+# deps
+node_modules/
+
+# env
+.env
+.env.production
+
+# logs
+logs/
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+pnpm-debug.log*
+lerna-debug.log*
+
+# misc
+.DS_Store

apps/deploy-worker/Dockerfile

@@ -0,0 +1,15 @@
+FROM node:22-alpine
+
+RUN apk add --no-cache postgresql-client
+
+WORKDIR /app
+
+COPY --link package.json ./
+COPY --link src/ ./src/
+
+RUN npm install
+
+EXPOSE 443
+EXPOSE 5432
+
+CMD ["node", "--experimental-strip-types", "src/index.ts"]

apps/deploy-worker/README.md

@@ -0,0 +1,8 @@
+```
+npm install
+npm run dev
+```
+
+```
+open http://localhost:3000
+```

apps/deploy-worker/fly.toml

@@ -0,0 +1,23 @@
+primary_region = 'iad'
+
+[[services]]
+internal_port = 5432
+protocol = "tcp"
+[[services.ports]]
+handlers = ["proxy_proto"]
+port = 5432
+
+[[services]]
+internal_port = 443
+protocol = "tcp"
+[[services.ports]]
+port = 443
+
+[[restart]]
+policy = "always"
+retries = 10
+
+[[vm]]
+memory = '512mb'
+cpu_kind = 'shared'
+cpus = 1

apps/deploy-worker/package.json

@@ -0,0 +1,25 @@
+{
+  "name": "@database.build/deploy-worker",
+  "type": "module",
+  "scripts": {
+    "start": "node --env-file=.env --experimental-strip-types src/index.ts",
+    "dev": "node --watch --env-file=.env --experimental-strip-types src/index.ts",
+    "type-check": "tsc",
+    "generate:types": "npx supabase gen types --lang=typescript --local > src/supabase/db-types.ts"
+  },
+  "dependencies": {
+    "@hono/node-server": "^1.13.2",
+    "@hono/zod-validator": "^0.4.1",
+    "@supabase/supabase-js": "^2.45.4",
+    "debug": "^4.3.7",
+    "hono": "^4.6.5",
+    "neverthrow": "^8.0.0",
+    "zod": "^3.23.8"
+  },
+  "devDependencies": {
+    "@total-typescript/tsconfig": "^1.0.4",
+    "@types/debug": "^4.1.12",
+    "@types/node": "^22.5.4",
+    "typescript": "^5.5.4"
+  }
+}

apps/deploy-worker/src/debug.ts

@@ -0,0 +1,3 @@
+import createDebug from 'debug'
+
+export const debug = createDebug('deploy-worker')

apps/deploy-worker/src/index.ts

@@ -0,0 +1,66 @@
+import { serve } from '@hono/node-server'
+import { Hono } from 'hono'
+import { z } from 'zod'
+import { zValidator } from '@hono/zod-validator'
+import { createClient } from './supabase/client.ts'
+import { HTTPException } from 'hono/http-exception'
+import { deployOnSupabase } from './supabase/deploy.ts'
+
+const app = new Hono()
+
+app.get(
+  '/',
+  zValidator(
+    'json',
+    z.object({
+      databaseId: z.string(),
+      integrationId: z.string(),
+      databaseUrl: z.string(),
+    })
+  ),
+  async (c) => {
+    const { databaseId, integrationId, databaseUrl: localDatabaseUrl } = c.req.valid('json')
+
+    const token = c.req.header('Authorization')?.replace('Bearer ', '')
+
+    if (!token) {
+      throw new HTTPException(401, { message: 'Unauthorized' })
+    }
+
+    const supabase = createClient()
+
+    const { error } = await supabase.auth.getUser(token)
+
+    if (error) {
+      throw new HTTPException(401, { message: 'Unauthorized' })
+    }
+
+    // TODO: create a lock in postgres to prevent multiple deployments
+    // await supabase.from('deployment_locks').insert({
+    //   local_database_id: databaseId,
+    // })
+    try {
+      const { databaseUrl } = await deployOnSupabase(
+        { supabase },
+        { databaseId, integrationId, localDatabaseUrl }
+      )
+      return c.json({ databaseUrl })
+    } catch (error: unknown) {
+      if (error instanceof Error) {
+        throw new HTTPException(500, { message: error.message })
+      }
+      throw new HTTPException(500, { message: 'Internal server error' })
+    } finally {
+      // TODO: remove the lock
+      // await supabase.from('deployment_locks').delete().eq('local_database_id', databaseId)
+    }
+  }
+)
+
+const port = 4000
+console.log(`Server is running on port ${port}`)
+
+serve({
+  fetch: app.fetch,
+  port,
+})

apps/deploy-worker/src/supabase/client.ts

@@ -0,0 +1,11 @@
+import { createClient as createSupabaseClient } from '@supabase/supabase-js'
+import type { Database } from './db-types.ts'
+
+export const supabaseAdmin = createSupabaseClient<Database>(
+  process.env.SUPABASE_URL!,
+  process.env.SUPABASE_SERVICE_ROLE_KEY!
+)
+
+export function createClient() {
+  return createSupabaseClient<Database>(process.env.SUPABASE_URL!, process.env.SUPABASE_ANON_KEY!)
+}