Skip to content

Commit 344bea6

Browse files
fix encoder creation
1 parent 4914303 commit 344bea6

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

packages/core/src/lib/message/version_0.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -128,7 +128,7 @@ export function createEncoder({
128128
return new Encoder(
129129
contentTopic,
130130
ephemeral,
131-
pubsubTopicShardInfo?.clusterId
131+
pubsubTopicShardInfo
132132
? singleShardInfoToPubsubTopic(pubsubTopicShardInfo)
133133
: DefaultPubsubTopic,
134134
metaSetter
@@ -193,7 +193,7 @@ export function createDecoder(
193193
pubsubTopicShardInfo?: SingleShardInfo
194194
): Decoder {
195195
return new Decoder(
196-
pubsubTopicShardInfo?.clusterId
196+
pubsubTopicShardInfo
197197
? singleShardInfoToPubsubTopic(pubsubTopicShardInfo)
198198
: DefaultPubsubTopic,
199199
contentTopic

packages/message-encryption/src/ecies.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,7 @@ export function createEncoder({
107107
metaSetter
108108
}: EncoderOptions): Encoder {
109109
return new Encoder(
110-
pubsubTopicShardInfo?.clusterId
110+
pubsubTopicShardInfo
111111
? singleShardInfoToPubsubTopic(pubsubTopicShardInfo)
112112
: DefaultPubsubTopic,
113113
contentTopic,
@@ -200,7 +200,7 @@ export function createDecoder(
200200
pubsubTopicShardInfo?: SingleShardInfo
201201
): Decoder {
202202
return new Decoder(
203-
pubsubTopicShardInfo?.clusterId
203+
pubsubTopicShardInfo
204204
? singleShardInfoToPubsubTopic(pubsubTopicShardInfo)
205205
: DefaultPubsubTopic,
206206
contentTopic,

packages/message-encryption/src/symmetric.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,7 @@ export function createEncoder({
107107
metaSetter
108108
}: EncoderOptions): Encoder {
109109
return new Encoder(
110-
pubsubTopicShardInfo?.clusterId
110+
pubsubTopicShardInfo
111111
? singleShardInfoToPubsubTopic(pubsubTopicShardInfo)
112112
: DefaultPubsubTopic,
113113
contentTopic,
@@ -200,7 +200,7 @@ export function createDecoder(
200200
pubsubTopicShardInfo?: SingleShardInfo
201201
): Decoder {
202202
return new Decoder(
203-
pubsubTopicShardInfo?.clusterId
203+
pubsubTopicShardInfo
204204
? singleShardInfoToPubsubTopic(pubsubTopicShardInfo)
205205
: DefaultPubsubTopic,
206206
contentTopic,

0 commit comments

Comments
 (0)