workspace repo fct and emitter

packages/server/modules/workspaces/events/emitter.ts

@@ -0,0 +1,6 @@
+import { initializeModuleEventEmitter } from "@/modules/shared/services/moduleEventEmitterSetup"
+import { WorkspaceEvents, WorkspaceEventsPayloads } from "@/modules/workspaces/domain/events"
+
+const { emit, listen } = initializeModuleEventEmitter<WorkspaceEventsPayloads>({ moduleName: 'workspaces' })
+
+export const WorkspacesEmitter = { emit, listen, events: WorkspaceEvents }

packages/server/modules/workspaces/repositories/workspaces.ts

@@ -0,0 +1,28 @@
+import { StoreWorkspace, UpsertWorkspaceRole } from '@/modules/workspaces/domain/operations'
+import { Workspace, WorkspaceAcl } from '@/modules/workspaces/domain/types'
+import { Roles } from '@speckle/shared'
+import { Knex } from 'knex'
+
+const tables = {
+  workspaces: (db: Knex) => db<Workspace>('workspaces'),
+  workspacesAcl: (db: Knex) => db<WorkspaceAcl>('workspace_acl')
+}
+
+export const storeWorkspaceFactory =
+  ({ db }: { db: Knex }): StoreWorkspace =>
+    async ({ workspace }) => {
+      await tables.workspaces(db).insert(workspace)
+    }
+
+// TODO: Authorise requester for given role change operation?
+export const upsertWorkspaceRole =
+  ({ db }: { db: Knex }): UpsertWorkspaceRole =>
+    async ({ userId, workspaceId, role }) => {
+      const validRoles = Object.values(Roles.Workspace)
+      if (!validRoles.includes(role)) {
+        throw new Error(`Unexpected workspace role provided: ${role}`)
+      }
+
+      await tables.workspacesAcl(db).insert({ userId, workspaceId, role })
+    }
+