feat: Add published_at column to flows and adjust update flow status

packages/backend/src/db/migrations/20220817121241_add_published_at_column_to_flows.ts

@@ -0,0 +1,13 @@
+import { Knex } from 'knex';
+
+export async function up(knex: Knex): Promise<void> {
+  return knex.schema.table('flows', (table) => {
+    table.timestamp('published_at').nullable();
+  });
+}
+
+export async function down(knex: Knex): Promise<void> {
+  return knex.schema.table('flows', (table) => {
+    table.dropColumn('published_at');
+  });
+}

packages/backend/src/graphql/mutations/update-flow-status.ts

@@ -36,9 +36,13 @@ const updateFlowStatus = async (
   const interval = trigger.interval;
   const repeatOptions = {
     cron: interval || EVERY_15_MINUTES_CRON,
-  }
+  };
 
   if (flow.active) {
+    flow = await flow.$query().patchAndFetch({
+      published_at: new Date().toISOString(),
+    });
+
     await processorQueue.add(
       JOB_NAME,
       { flowId: flow.id },
@@ -49,7 +53,7 @@ const updateFlowStatus = async (
     );
   } else {
     const repeatableJobs = await processorQueue.getRepeatableJobs();
-    const job = repeatableJobs.find(job => job.id === flow.id);
+    const job = repeatableJobs.find((job) => job.id === flow.id);
 
     await processorQueue.removeRepeatableByKey(job.key);
   }

packages/backend/src/models/flow.ts

@@ -11,6 +11,7 @@ class Flow extends Base {
   userId!: string;
   active = false;
   steps?: [Step];
+  published_at: string;
 
   static tableName = 'flows';