fix: migrations run on service bootstrap (#8)

.github/workflows/manual-deploy.yml

@@ -0,0 +1,34 @@
+name: Manual deployment
+
+on:
+  workflow_dispatch:
+    inputs:
+      deployment-environment:
+        required: true
+        type: choice
+        options:
+          - prd
+          - dev
+        default: prd
+        description: Environment
+      tag:
+        required: true
+        default: "latest"
+        type: string
+        description: "Docker tag (quay.io)"
+
+jobs:
+  deployment:
+    if: ${{ inputs.deployment-environment }}
+    name: "Deploy to: ${{ inputs.deployment-environment }}"
+    runs-on: ubuntu-latest
+    environment: ${{ inputs.deployment-environment }}
+    steps:
+      - name: Trigger deployment
+        id: deploy
+        uses: decentraland/dcl-deploy-action@main
+        with:
+          dockerImage: "quay.io/decentraland/events-notifier:${{ inputs.tag }}"
+          serviceName: "events-notifier"
+          env: ${{ inputs.deployment-environment }}
+          token: ${{ secrets.GITHUB_TOKEN }}

entrypoint.sh

@@ -7,8 +7,25 @@ finish() {
 
 trap finish SIGINT SIGQUIT SIGTERM
 
+temp_migration_dir="./temp_migrations"
+mkdir -p "$temp_migration_dir"
+
+# Copy only .js migration files to the temporary directory
+cp ./dist/migrations/*.js "$temp_migration_dir"
+
+dbUser=$PG_COMPONENT_PSQL_USER
+dbPassword=$PG_COMPONENT_PSQL_PASSWORD
+dbHost=$PG_COMPONENT_PSQL_HOST
+dbPort=$PG_COMPONENT_PSQL_PORT
+dbDatabaseName=$PG_COMPONENT_PSQL_DATABASE
+
+# Build the CONNECTION_STRING
+export CONNECTION_STRING="postgres://${dbUser}:${dbPassword}@${dbHost}:${dbPort}/${dbDatabaseName}"
+
 echo "running migrations"
-./node_modules/.bin/node-pg-migrate -m lib/migrations -d CONNECTION_STRING up
+./node_modules/.bin/node-pg-migrate -m "$temp_migration_dir" -d CONNECTION_STRING up
+
+rm -r "$temp_migration_dir"
 
 echo "starting service..."
 /usr/local/bin/node --trace-warnings --abort-on-uncaught-exception --unhandled-rejections=strict dist/index.js &

src/components.ts

@@ -4,6 +4,7 @@ import { createLogComponent } from '@well-known-components/logger'
 import { createSubgraphComponent } from '@well-known-components/thegraph-component'
 import { createPgComponent } from '@well-known-components/pg-component'
 import { createFetchComponent } from '@dcl/platform-server-commons'
+import path from 'path'
 
 import { metricDeclarations } from './metrics'
 import { AppComponents, GlobalContext } from './types'

src/migrations/1721829390249_init.ts

@@ -0,0 +1,15 @@
+/* eslint-disable @typescript-eslint/naming-convention */
+import { MigrationBuilder } from 'node-pg-migrate'
+
+export async function up(pgm: MigrationBuilder): Promise<void> {
+  pgm.createTable('cursors', {
+    id: { type: 'varchar(255)', notNull: true, primaryKey: true },
+    last_successful_run_at: { type: 'bigint', notNull: false },
+    created_at: { type: 'bigint', notNull: true },
+    updated_at: { type: 'bigint', notNull: true }
+  })
+}
+
+export async function down(pgm: MigrationBuilder): Promise<void> {
+  pgm.dropTable('cursors')
+}