[WIP] Operations on pg-boss PoC

api/db.ts

@@ -36,6 +36,8 @@ export {
     EmbeddingSecretModelColumn,
 } from '../src/db/models/new/embedding-secret';
 
+export {JobOperationModel, JobOperationColumn} from '../src/db/models/new/job-operation';
+
 export {ColorPaletteModel, ColorPaletteModelColumn} from '../src/db/models/new/color-palette';
 
 export {

src/db/migrations/20240730135215_add_job_operations_table.ts

@@ -0,0 +1,17 @@
+import type {Knex} from 'knex';
+
+export async function up(knex: Knex): Promise<void> {
+    return knex.raw(`
+        CREATE TABLE job_operations (
+            operation_id BIGINT DEFAULT get_id() PRIMARY KEY,
+            current_job_id VARCHAR(255),
+            meta JSONB NOT NULL DEFAULT '{}'::jsonb
+        );
+    `);
+}
+
+export async function down(knex: Knex): Promise<void> {
+    return knex.raw(`
+        DROP TABLE job_operations;
+    `);
+}

src/db/models/new/job-operation/index.ts

@@ -0,0 +1,21 @@
+import {Model} from '../../..';
+
+export const JobOperationColumn = {
+    OperationId: 'operationId',
+    CurrentJobId: 'currentJobId',
+    Meta: 'meta',
+} as const;
+
+export class JobOperationModel extends Model {
+    static get tableName() {
+        return 'job_operations';
+    }
+
+    static get idColumn() {
+        return JobOperationColumn.OperationId;
+    }
+
+    [JobOperationColumn.OperationId]!: string;
+    [JobOperationColumn.CurrentJobId]!: Nullable<string>;
+    [JobOperationColumn.Meta]!: Record<string, unknown>;
+}