Merge branch 'develop' into chore-remove-gql-from-v2

opencrvs · Jan 2, 2025 · 7b0683c · 7b0683c
2 parents 4da8fc9 + d27be1d
commit 7b0683c
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 10 deletions.
diff --git a/packages/commons/src/events/ActionDocument.ts b/packages/commons/src/events/ActionDocument.ts
@@ -14,6 +14,7 @@ import { z } from 'zod'
 const ActionBase = z.object({
   createdAt: z.string().datetime(),
   createdBy: z.string(),
+  createdAtLocation: z.string(),
   data: z.record(z.string(), z.any())
 })
 
@@ -60,15 +61,13 @@ const DraftAction = ActionBase.merge(
 
 const CreatedAction = ActionBase.merge(
   z.object({
-    type: z.literal(ActionType.CREATE),
-    createdAtLocation: z.string()
+    type: z.literal(ActionType.CREATE)
   })
 )
 
 const NotifiedAction = ActionBase.merge(
   z.object({
-    type: z.literal(ActionType.NOTIFY),
-    createdAtLocation: z.string()
+    type: z.literal(ActionType.NOTIFY)
   })
 )
 

diff --git a/packages/events/src/router/router.ts b/packages/events/src/router/router.ts
@@ -112,19 +112,22 @@ export const appRouter = router({
       notify: publicProcedure.input(NotifyActionInput).mutation((options) => {
         return addAction(options.input, {
           eventId: options.input.eventId,
-          createdBy: options.ctx.user.id
+          createdBy: options.ctx.user.id,
+          createdAtLocation: options.ctx.user.primaryOfficeId
         })
       }),
       draft: publicProcedure.input(DraftActionInput).mutation((options) => {
         return addAction(options.input, {
           eventId: options.input.eventId,
-          createdBy: options.ctx.user.id
+          createdBy: options.ctx.user.id,
+          createdAtLocation: options.ctx.user.primaryOfficeId
         })
       }),
       declare: publicProcedure.input(DeclareActionInput).mutation((options) => {
         return addAction(options.input, {
           eventId: options.input.eventId,
-          createdBy: options.ctx.user.id
+          createdBy: options.ctx.user.id,
+          createdAtLocation: options.ctx.user.primaryOfficeId
         })
       }),
       register: publicProcedure
@@ -140,7 +143,8 @@ export const appRouter = router({
             },
             {
               eventId: options.input.eventId,
-              createdBy: options.ctx.user.id
+              createdBy: options.ctx.user.id,
+              createdAtLocation: options.ctx.user.primaryOfficeId
             }
           )
         })

diff --git a/packages/events/src/service/events.ts b/packages/events/src/service/events.ts
@@ -101,7 +101,11 @@ export async function createEvent({
 
 export async function addAction(
   input: ActionInput,
-  { eventId, createdBy }: { eventId: string; createdBy: string }
+  {
+    eventId,
+    createdBy,
+    createdAtLocation
+  }: { eventId: string; createdBy: string; createdAtLocation: string }
 ) {
   const db = await getClient()
   const now = new Date().toISOString()
@@ -115,7 +119,8 @@ export async function addAction(
         actions: {
           ...input,
           createdBy,
-          createdAt: now
+          createdAt: now,
+          createdAtLocation
         }
       }
     }