fix(mu): make prevSortKey also optional to allow undefined. Add loggi…

…ng on message endpoint
permaweb · Oct 24, 2023 · 428df60 · 428df60
1 parent 5c34af0
commit 428df60
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 5 deletions.
diff --git a/servers/mu/src/domain/lib/processMsg/cache-and-write-tx.js b/servers/mu/src/domain/lib/processMsg/cache-and-write-tx.js
@@ -7,7 +7,7 @@ const ctxSchema = z.object({
     id: z.string(),
     sortKey: z.string(),
     timestamp: z.number(),
-    prevSortKey: z.string().nullable()
+    prevSortKey: z.string().nullable().optional()
   })
 }).passthrough()
 

diff --git a/servers/mu/src/routes/message.js b/servers/mu/src/routes/message.js
@@ -22,11 +22,17 @@ export const withMessageRoutes = (app) => {
          */
         of({ raw: body })
           .chain(initMsgs)
-          .map(res => ({ msgs: res.msgs, spawns: res.spawns }))
-          .chain(crankMsgs)
           .bimap(
-            logger.tap('Failed to crank messages'),
-            logger.tap('Successfully cranked messages')
+            logger.tap('Failed to forward initial message to the SU and read result from the CU'),
+            logger.tap('Successfully forwarded initial message to the SU and read result from the CU. Beginning to crank...')
+          )
+          .map(res => ({ msgs: res.msgs, spawns: res.spawns }))
+          .chain(res =>
+            crankMsgs(res)
+              .bimap(
+                logger.tap('Failed to crank messages'),
+                logger.tap('Successfully cranked messages')
+              )
           )
           .toPromise()