* add getMessageType function (#168)

kibertoad · Jun 19, 2024 · 3745669 · 3745669
1 parent b994795
commit 3745669
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 2 deletions.
diff --git a/packages/schemas/lib/messages/baseMessageSchemas.ts b/packages/schemas/lib/messages/baseMessageSchemas.ts
@@ -113,3 +113,9 @@ export function enrichMessageSchemaWithBase<
     publisherSchema: publisherSchema,
   }
 }
+
+export function getMessageType<T extends ZodObject<Y>, Y extends ZodRawShape, Z extends string>(
+  richMessageSchema: ReturnType<T, Y, Z>,
+): Z {
+  return richMessageSchema.consumerSchema.shape.type.value
+}
diff --git a/packages/sns/package.json b/packages/sns/package.json
@@ -41,7 +41,7 @@
     "@aws-sdk/client-sns": "^3.569.0",
     "@aws-sdk/client-sqs": "^3.569.0",
     "@message-queue-toolkit/core": "*",
-    "@message-queue-toolkit/s3-payload-store": "^0.1.0",
+    "@message-queue-toolkit/s3-payload-store": "^1.0.0",
     "@message-queue-toolkit/sqs": "*",
     "@types/node": "^20.12.8",
     "@typescript-eslint/eslint-plugin": "^7.7.1",

diff --git a/packages/sqs/package.json b/packages/sqs/package.json
@@ -37,7 +37,7 @@
     "@aws-sdk/client-s3": "^3.598.0",
     "@aws-sdk/client-sqs": "^3.569.0",
     "@message-queue-toolkit/core": "*",
-    "@message-queue-toolkit/s3-payload-store": "^0.1.0",
+    "@message-queue-toolkit/s3-payload-store": "^1.0.0",
     "@types/node": "^20.12.8",
     "@typescript-eslint/eslint-plugin": "^7.1.1",
     "@typescript-eslint/parser": "^7.1.1",