PLU-472: Collaborators (#1327)

[COLLAB-1]: Create flow_collaborators table, model, resolvers
[COLLAB-2]: Create flow_connections table, model
[COLLAB-3]: Add mutations to upsert and delete collaborators 
[COLLAB-4]: Automatically add connections when adding collaborator
[COLLAB-5]: Manage collaborators via UI 
[COLLAB-6]: Collaborators can view Pipes 
[COLLAB-7]: Owner creates Step with connection, Editor can create Step
[COLLAB-8]: Owner update Step connection, Editor can save Step 
[COLLAB-9]: Restrict UI based on role
[COLLAB-10]: Editors can edit, save, and check step
[COLLAB-11]: Editors can publish and unpublish
[COLLAB-12]: Editors can delete step 
[COLLAB-13]: Editor can change to shared connections
[COLLAB-14]: Editor add step with shared connection
[COLLAB-14.1]: Editor can duplicate and reorder step
[COLLAB-15]: Collaborators can view executions
[COLLAB-16]: Editor can retry failed execution 
[COLLAB-17]: Add feature flag
[COLLAB-18]: Pipe transfer
[COLLAB-19]: Refactor role to flow model
[COLLAB-20]: fix duplicate branch
[COLLAB-21]: Bug bash fixes
[COLLAB-22]: Error emails for collaborators
[COLLAB-23]: Verify Tiles permissions on role change or pipe transfer
chore: fixes and news item

Author: kevinkim-ogp

packages/backend/src/db/migrations/20250725070831_flow_collaborators.ts

@@ -0,0 +1,19 @@
+import { Knex } from 'knex'
+
+export async function up(knex: Knex): Promise<void> {
+  await knex.schema.createTable('flow_collaborators', (table) => {
+    table.uuid('flow_id').references('id').inTable('flows').notNullable()
+    table.uuid('user_id').references('id').inTable('users').notNullable()
+    table.string('role').notNullable()
+    table.timestamps(true, true)
+    table.timestamp('deleted_at').nullable()
+    table.timestamp('last_accessed_at').notNullable().defaultTo(knex.fn.now())
+    table.uuid('updated_by').references('id').inTable('users').notNullable()
+
+    table.primary(['flow_id', 'user_id'])
+  })
+}
+
+export async function down(knex: Knex): Promise<void> {
+  await knex.schema.dropTable('flow_collaborators')
+}

packages/backend/src/db/migrations/20250806004508_add_flows_updated_by.ts

@@ -0,0 +1,13 @@
+import { Knex } from 'knex'
+
+export async function up(knex: Knex): Promise<void> {
+  return knex.schema.table('flows', (table) => {
+    table.uuid('updated_by').references('id').inTable('users').nullable()
+  })
+}
+
+export async function down(knex: Knex): Promise<void> {
+  return knex.schema.table('flows', (table) => {
+    table.dropColumn('updated_by')
+  })
+}

packages/backend/src/db/migrations/20250806004700_add_steps_updated_by.ts

@@ -0,0 +1,13 @@
+import { Knex } from 'knex'
+
+export async function up(knex: Knex): Promise<void> {
+  return knex.schema.table('steps', (table) => {
+    table.uuid('updated_by').references('id').inTable('users').nullable()
+  })
+}
+
+export async function down(knex: Knex): Promise<void> {
+  return knex.schema.table('steps', (table) => {
+    table.dropColumn('updated_by')
+  })
+}

packages/backend/src/db/migrations/20250819135354_flow_connections.ts

@@ -0,0 +1,24 @@
+import { Knex } from 'knex'
+
+export async function up(knex: Knex): Promise<void> {
+  await knex.schema.createTable('flow_connections', (table) => {
+    table.uuid('flow_id').references('id').inTable('flows').notNullable()
+    // NOTE: this connection_id refers to either:
+    // - the connection id of a connection in the connections table; OR
+    // - the id of a Tile
+    table.uuid('connection_id').notNullable()
+    // NOTE: addedBy is the user id of the user who added the connection to the flow
+    table.uuid('added_by').references('id').inTable('users').notNullable()
+    table.string('connection_type').notNullable()
+    table.timestamps(true, true)
+    table.timestamp('deleted_at').nullable()
+    table.jsonb('metadata').notNullable().defaultTo('{}')
+
+    // use the primary key constraint to avoid duplicates
+    table.primary(['flow_id', 'connection_id'])
+  })
+}
+
+export async function down(knex: Knex): Promise<void> {
+  await knex.schema.dropTable('flow_connections')
+}