Update example

Author: kibertoad

examples/sns-sqs/lib/common/TestMessages.ts

@@ -3,7 +3,7 @@ import {
   enrichMessageSchemaWithBaseStrict,
 } from '@message-queue-toolkit/schemas'
 import type { CommonEventDefinition } from '@message-queue-toolkit/schemas'
-import { z } from 'zod'
+import { z } from 'zod/v3'
 
 type AllConsumerMessageSchemas<MessageDefinitionTypes extends CommonEventDefinition[]> = z.infer<
   MessageDefinitionTypes[number]['consumerSchema']

examples/sns-sqs/lib/common/UserConsumer.ts

@@ -26,14 +26,20 @@ export class UserConsumer extends AbstractSnsSqsConsumer<SupportedMessages, Exec
           .addConfig(UserEvents.updated, userUpdatedHandler, {})
           .build(),
         messageTypeField: 'type',
+        // Consumer creates its own queue
         creationConfig: {
           queue: {
             QueueName: UserConsumer.CONSUMED_QUEUE_NAME,
           },
         },
         locatorConfig: {
+          // Topic is created by a publisher, consumer relies on it already existing.
+          // Note that in order for this to work correctly you need to ensure that
+          // publisher gets initialized first. If consumer will initialize first,
+          // publisher may delete already existing topic and subscription and break the setup
           topicName: UserConsumer.SUBSCRIBED_TOPIC_NAME,
         },
+        // consumer creates its own subscription
         subscriptionConfig: {
           updateAttributesIfExists: false,
         },

examples/sns-sqs/lib/common/handlers/UserCreatedHandler.ts

@@ -1,5 +1,5 @@
 import type { Either } from '@lokalise/node-core'
-import type { z } from 'zod'
+import type { z } from 'zod/v3'
 import type { USER_SCHEMA, UserEvents } from '../TestMessages.ts'
 
 let _latestData: z.infer<typeof USER_SCHEMA>

examples/sns-sqs/lib/common/handlers/UserUpdatedHandler.ts

@@ -1,5 +1,5 @@
 import type { Either } from '@lokalise/node-core'
-import type { z } from 'zod'
+import type { z } from 'zod/v3'
 import type { USER_SCHEMA, UserEvents } from '../TestMessages.ts'
 
 let _latestData: z.infer<typeof USER_SCHEMA>

examples/sns-sqs/package.json

@@ -19,12 +19,12 @@
         "@aws-sdk/client-sns": "^3.812.0",
         "@aws-sdk/client-sts": "^3.812.0",
         "@aws-sdk/client-sqs": "^3.812.0",
-        "@message-queue-toolkit/core": "^21.1.1",
-        "@message-queue-toolkit/schemas": "^6.1.0",
-        "@message-queue-toolkit/sns": "22.0.1",
-        "@message-queue-toolkit/sqs": "21.0.1",
+        "@message-queue-toolkit/core": "^21.2.0",
+        "@message-queue-toolkit/schemas": "^6.2.0",
+        "@message-queue-toolkit/sns": "22.2.0",
+        "@message-queue-toolkit/sqs": "21.1.0",
         "pino": "^9.7.0",
-        "zod": "^3.24.4"
+        "zod": "^3.25.3"
     },
     "devDependencies": {
         "@biomejs/biome": "1.9.4",