@node-ts/bus-sqs - npm Package Compare versions

Comparing version 1.1.0-beta.0 to 1.1.0-beta.1

dist/sqs-transport.d.ts

 import { MessageAttributeValue, SNSClient } from '@aws-sdk/client-sns';
 import { Message as SQSMessage, SQSClient } from '@aws-sdk/client-sqs';
 import { Command, Event, MessageAttributes } from '@node-ts/bus-messages';
-import { Transport, TransportMessage, CoreDependencies } from '@node-ts/bus-core';
+import { Transport, TransportMessage, CoreDependencies, TransportInitializationOptions } from '@node-ts/bus-core';
 import { SqsTransportConfiguration } from './sqs-transport-configuration';
-import { TransportInitializationOptions } from '@node-ts/bus-core/dist/transport';
 export type SnsMessageAttributeMap = Record<string, MessageAttributeValue>;
@@ -8,0 +7,0 @@ export declare const MAX_SQS_DELAY_SECONDS: Seconds;

dist/sqs-transport.js

@@ -138,2 +138,6 @@ "use strict";
         return tslib_1.__awaiter(this, void 0, void 0, function* () {
+            this.resolveTopicName =
+                (_a = this.sqsConfiguration.resolveTopicName) !== null && _a !== void 0 ? _a : queue_resolvers_1.resolveTopicName;
+            this.resolveTopicArn =
+                (_b = this.sqsConfiguration.resolveTopicArn) !== null && _b !== void 0 ? _b : queue_resolvers_1.resolveTopicArn;
             if (!sendOnly) {
@@ -176,6 +180,2 @@ if (!this.sqsConfiguration.queueArn &&
             }
-            this.resolveTopicName =
-                (_a = this.sqsConfiguration.resolveTopicName) !== null && _a !== void 0 ? _a : queue_resolvers_1.resolveTopicName;
-            this.resolveTopicArn =
-                (_b = this.sqsConfiguration.resolveTopicArn) !== null && _b !== void 0 ? _b : queue_resolvers_1.resolveTopicArn;
         });
@@ -182,0 +182,0 @@ }

package.json

 {
   "name": "@node-ts/bus-sqs",
   "description": "An AWS SQS transport adapter for @node-ts/bus-core.",
-  "version": "1.1.0-beta.0",
+  "version": "1.1.0-beta.1",
   "license": "MIT",
@@ -30,4 +30,4 @@ "main": "./dist/index.js",
     "typescript": "^5.3.3",
-    "@node-ts/bus-core": "^1.1.0-beta.0",
-    "@node-ts/bus-test": "^0.0.22"
+    "@node-ts/bus-test": "^0.0.22",
+    "@node-ts/bus-core": "^1.1.0-beta.2"
   },
@@ -34,0 +34,0 @@ "peerDependencies": {

src/sqs-transport.ts

@@ -33,5 +33,5 @@ import { AssertionError } from 'assert'
   CoreDependencies,
-  Logger
+  Logger,
+  TransportInitializationOptions
 } from '@node-ts/bus-core'
-
 import { generatePolicy } from './generate-policy'
@@ -47,3 +47,2 @@ import {
 import { SqsTransportConfiguration } from './sqs-transport-configuration'
-import { TransportInitializationOptions } from '@node-ts/bus-core/dist/transport'
 
@@ -244,2 +243,7 @@ export type SnsMessageAttributeMap = Record<string, MessageAttributeValue>
   }: TransportInitializationOptions): Promise<void> {
+    this.resolveTopicName =
+      this.sqsConfiguration.resolveTopicName ?? defaultResolveTopicName
+    this.resolveTopicArn =
+      this.sqsConfiguration.resolveTopicArn ?? defaultResolveTopicArn
+
     if (!sendOnly) {
@@ -312,7 +316,2 @@ if (
     }
-
-    this.resolveTopicName =
-      this.sqsConfiguration.resolveTopicName ?? defaultResolveTopicName
-    this.resolveTopicArn =
-      this.sqsConfiguration.resolveTopicArn ?? defaultResolveTopicArn
   }
@@ -319,0 +318,0 @@

No alert changes

Worsened metrics

Total package byte prevSize

69936

-0.14%

Lines of code

1697

-0.06%

No dependency changes