feat: implement fly deployment action

Author: sweatybridge

.eslintrc.json

@@ -24,7 +24,7 @@
       "@typescript-eslint/func-call-spacing": ["error", "never"],
       "@typescript-eslint/no-array-constructor": "error",
       "@typescript-eslint/no-empty-interface": "error",
-      "@typescript-eslint/no-explicit-any": "error",
+      "@typescript-eslint/no-explicit-any": "warn",
       "@typescript-eslint/no-extraneous-class": "error",
       "@typescript-eslint/no-for-in-array": "error",
       "@typescript-eslint/no-inferrable-types": "error",
@@ -35,6 +35,8 @@
       "@typescript-eslint/no-unnecessary-type-assertion": "error",
       "@typescript-eslint/no-useless-constructor": "error",
       "@typescript-eslint/no-var-requires": "error",
+      "no-shadow": "off",
+      "@typescript-eslint/no-shadow": "error",
       "@typescript-eslint/prefer-for-of": "warn",
       "@typescript-eslint/prefer-function-type": "warn",
       "@typescript-eslint/prefer-includes": "error",

__tests__/app.test.ts

@@ -0,0 +1,81 @@
+import nock from 'nock'
+import {describe, it} from '@jest/globals'
+import {FLY_API_GRAPHQL} from '../src/fly/client'
+import {createApp, deleteApp} from '../src/fly/app'
+
+describe('app', () => {
+  const organizationId = 'personal'
+
+  it('creates app', async () => {
+    nock(FLY_API_GRAPHQL)
+      .post('/graphql')
+      .reply(200, {
+        data: {
+          createApp: {
+            app: {
+              id: 'ctwntjgykzxhfncfwrfo',
+              name: 'ctwntjgykzxhfncfwrfo',
+              organization: {slug: 'supabase-dev'},
+              config: {
+                definition: {
+                  kill_timeout: 5,
+                  kill_signal: 'SIGINT',
+                  processes: [],
+                  experimental: {auto_rollback: true},
+                  services: [
+                    {
+                      processes: ['app'],
+                      protocol: 'tcp',
+                      internal_port: 8080,
+                      concurrency: {
+                        soft_limit: 20,
+                        hard_limit: 25,
+                        type: 'connections'
+                      },
+                      ports: [
+                        {port: 80, handlers: ['http'], force_https: true},
+                        {port: 443, handlers: ['tls', 'http']}
+                      ],
+                      tcp_checks: [
+                        {
+                          interval: '15s',
+                          timeout: '2s',
+                          grace_period: '1s',
+                          restart_limit: 0
+                        }
+                      ],
+                      http_checks: [],
+                      script_checks: []
+                    }
+                  ],
+                  env: {}
+                }
+              },
+              regions: [{name: 'Hong Kong, Hong Kong', code: 'hkg'}]
+            }
+          }
+        }
+      })
+    const data = await createApp({
+      name: 'ctwntjgykzxhfncfwrfo',
+      organizationId
+    })
+    console.dir(data, {depth: 10})
+  })
+
+  it('deletes app', async () => {
+    nock(FLY_API_GRAPHQL)
+      .post('/graphql')
+      .reply(200, {
+        data: {
+          deleteApp: {
+            organization: {
+              id: organizationId
+            }
+          }
+        }
+      })
+    const data = await deleteApp('ctwntjgykzxhfncfwrfo')
+    console.dir(data, {depth: 10})
+  })
+})

__tests__/machine.test.ts

@@ -0,0 +1,171 @@
+import nock from 'nock'
+import {describe, it} from '@jest/globals'
+import {
+  ConnectionHandler,
+  createMachine,
+  deleteMachine,
+  FLY_API_HOSTNAME,
+  MachineConfig,
+  startMachine,
+  stopMachine
+} from '../src/fly/machine'
+
+describe('machine', () => {
+  it('creates machine', async () => {
+    const name = 'ctwntjgykzxhfncfwrfo'
+    nock(FLY_API_HOSTNAME)
+      .post(`/v1/apps/${name}/machines`)
+      .reply(200, {
+        id: '9080e966ae7487',
+        name: 'ctwntjgykzxhfncfwrfo',
+        state: 'created',
+        region: 'hkg',
+        instance_id: '01GSYXD50E7F114CX7SRCT2H41',
+        private_ip: 'fdaa:1:698b:a7b:a8:33bd:e6da:2',
+        config: {
+          env: {PGDATA: '/mnt/postgres/data'},
+          init: {},
+          image: 'sweatybridge/postgres:all-in-one',
+          mounts: [
+            {
+              path: '/mnt/postgres',
+              size_gb: 2,
+              volume: 'vol_g67340kqe5pvydxw',
+              name: 'ctwntjgykzxhfncfwrfo_pgdata'
+            }
+          ],
+          restart: {},
+          services: [
+            {
+              protocol: 'tcp',
+              internal_port: 8000,
+              ports: [
+                {port: 443, handlers: ['tls', 'http']},
+                {port: 80, handlers: ['http']}
+              ]
+            },
+            {
+              protocol: 'tcp',
+              internal_port: 5432,
+              ports: [{port: 5432, handlers: ['pg_tls']}]
+            }
+          ],
+          size: 'shared-cpu-4x',
+          guest: {cpu_kind: 'shared', cpus: 4, memory_mb: 1024},
+          checks: {
+            pgrst: {
+              port: 3000,
+              type: 'http',
+              interval: '15s',
+              timeout: '10s',
+              method: 'HEAD',
+              path: '/'
+            }
+          }
+        },
+        image_ref: {
+          registry: 'registry-1.docker.io',
+          repository: 'sweatybridge/postgres',
+          tag: 'all-in-one',
+          digest:
+            'sha256:df2014e5d037bf960a1240e300a913a97ef0d4486d22cbd1b7b92a7cbf487a7c',
+          labels: null
+        },
+        created_at: '2023-02-23T10:34:20Z',
+        updated_at: '0001-01-01T00:00:00Z',
+        checks: [
+          {
+            name: 'pgrst',
+            status: 'warning',
+            output: 'the machine is created',
+            updated_at: '2023-02-23T10:34:20.084624847Z'
+          }
+        ]
+      })
+    const config: MachineConfig = {
+      image: 'sweatybridge/postgres:all-in-one',
+      size: 'shared-cpu-4x',
+      env: {
+        PGDATA: '/mnt/postgres/data'
+      },
+      services: [
+        {
+          ports: [
+            {
+              port: 443,
+              handlers: [ConnectionHandler.TLS, ConnectionHandler.HTTP]
+            },
+            {
+              port: 80,
+              handlers: [ConnectionHandler.HTTP]
+            }
+          ],
+          protocol: 'tcp',
+          internal_port: 8000
+        },
+        {
+          ports: [
+            {
+              port: 5432,
+              handlers: [ConnectionHandler.PG_TLS]
+            }
+          ],
+          protocol: 'tcp',
+          internal_port: 5432
+        }
+      ],
+      mounts: [
+        {
+          volume: 'vol_g67340kqe5pvydxw',
+          path: '/mnt/postgres'
+        }
+      ],
+      checks: {
+        pgrst: {
+          type: 'http',
+          port: 3000,
+          method: 'HEAD',
+          path: '/',
+          interval: '15s',
+          timeout: '10s'
+        }
+      }
+    }
+    const data = await createMachine({name, config})
+    console.dir(data, {depth: 10})
+  })
+
+  it('deletes machine', async () => {
+    const appId = 'ctwntjgykzxhfncfwrfo'
+    const machineId = '4d891ed1b96987'
+    nock(FLY_API_HOSTNAME)
+      .delete(`/v1/apps/${appId}/machines/${machineId}`)
+      .reply(200, {ok: true})
+    const data = await deleteMachine({appId, machineId})
+    console.dir(data, {depth: 5})
+  })
+
+  it('stops machine', async () => {
+    const appId = 'ctwntjgykzxhfncfwrfo'
+    const machineId = '9080e966ae2487'
+    nock(FLY_API_HOSTNAME)
+      .post(`/v1/apps/${appId}/machines/${machineId}/stop`, {
+        appId,
+        machineId,
+        signal: 'SIGTERM'
+      })
+      .reply(200, {ok: true})
+    const data = await stopMachine({appId, machineId})
+    console.dir(data, {depth: 5})
+  })
+
+  it('starts machine', async () => {
+    const appId = 'ctwntjgykzxhfncfwrfo'
+    const machineId = '9080e966ae2487'
+    nock(FLY_API_HOSTNAME)
+      .post(`/v1/apps/${appId}/machines/${machineId}/start`)
+      .reply(200, {ok: true})
+    const data = await startMachine({appId, machineId})
+    console.dir(data, {depth: 5})
+  })
+})

__tests__/main.test.ts

@@ -1,22 +1,8 @@
-import {wait} from '../src/wait'
 import * as process from 'process'
 import * as cp from 'child_process'
 import * as path from 'path'
 import {expect, test} from '@jest/globals'
 
-test('throws invalid number', async () => {
-  const input = parseInt('foo', 10)
-  await expect(wait(input)).rejects.toThrow('milliseconds not a number')
-})
-
-test('wait 500 ms', async () => {
-  const start = new Date()
-  await wait(500)
-  const end = new Date()
-  var delta = Math.abs(end.getTime() - start.getTime())
-  expect(delta).toBeGreaterThan(450)
-})
-
 // shows how the runner will run a javascript action with env / stdout protocol
 test('test runs', () => {
   process.env['INPUT_MILLISECONDS'] = '500'
@@ -25,5 +11,12 @@ test('test runs', () => {
   const options: cp.ExecFileSyncOptions = {
     env: process.env
   }
-  console.log(cp.execFileSync(np, [ip], options).toString())
+  try {
+    console.log(cp.execFileSync(np, [ip], options).toString())
+  } catch (error) {
+    // @ts-ignore TS18046: 'error' is of type 'unknown'.
+    expect(error.stdout).toStrictEqual(
+      Buffer.from('::error::missing required env: FLY_API_TOKEN\n')
+    )
+  }
 })

__tests__/network.test.ts

@@ -0,0 +1,52 @@
+import nock from 'nock'
+import {describe, it} from '@jest/globals'
+import {FLY_API_GRAPHQL} from '../src/fly/client'
+import {
+  AddressType,
+  allocateIpAddress,
+  releaseIpAddress
+} from '../src/fly/network'
+
+describe('network', () => {
+  it('allocates ip address', async () => {
+    nock(FLY_API_GRAPHQL)
+      .post('/graphql')
+      .reply(200, {
+        data: {
+          allocateIpAddress: {
+            ipAddress: {
+              id: 'ip_lm6k9x4qw0g1qp7r',
+              address: '2a09:8280:1::a:e929',
+              type: 'v6',
+              region: 'global',
+              createdAt: '2023-02-23T11:01:36Z'
+            }
+          }
+        }
+      })
+    const data = await allocateIpAddress({
+      appId: 'ctwntjgykzxhfncfwrfo',
+      type: AddressType.v6
+    })
+    console.dir(data, {depth: 5})
+  })
+
+  it('releases ip address', async () => {
+    nock(FLY_API_GRAPHQL)
+      .post('/graphql')
+      .reply(200, {
+        data: {
+          releaseIpAddress: {
+            app: {
+              name: 'ctwntjgykzxhfncfwrfo'
+            }
+          }
+        }
+      })
+    const data = await releaseIpAddress({
+      appId: 'ctwntjgykzxhfncfwrfo',
+      ip: '2a09:8280:1::1:e80d'
+    })
+    console.dir(data, {depth: 5})
+  })
+})