Skip to content

Commit 04a8db6

Browse files
committed
🏷️ fix publish message type
1 parent 4856654 commit 04a8db6

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

src/util/token-util.ts

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -132,8 +132,11 @@ export async function updateProviderKey(
132132

133133
const newToken = { accessToken, isPending: false };
134134
await tokenCache.set(providerKey, newToken, getTokenCacheTtl());
135-
const { PUBSUB_TOPIC_NAME_UPDATE_PROVIDER_KEY } = process.env;
136135

136+
const { INTEGRATION_NAME } = process.env;
137+
assert(INTEGRATION_NAME, 'INTEGRATION_NAME is not defined');
138+
139+
const { PUBSUB_TOPIC_NAME_UPDATE_PROVIDER_KEY } = process.env;
137140
assert(
138141
PUBSUB_TOPIC_NAME_UPDATE_PROVIDER_KEY,
139142
'PUBSUB_TOPIC_NAME_UPDATE_PROVIDER_KEY is not defined',
@@ -142,7 +145,7 @@ export async function updateProviderKey(
142145
const pubSubClient = new PubSubClient(PUBSUB_TOPIC_NAME_UPDATE_PROVIDER_KEY);
143146
await pubSubClient.publishMessage({
144147
userId: config.userId,
148+
integrationName: INTEGRATION_NAME,
145149
providerKey,
146-
accessToken,
147150
});
148151
}

0 commit comments

Comments
 (0)