try {
const res = await chatMessageSentWorkflow.trigger({
payload: { dealId: opts.dealId },
to: {
type: 'topic',
topicKey: allTopicKey,
},
actor: {
subscriberId: opts.subscriberIdToExlude ?? '',
},
});
logger.info(
`Recieved novu workflow ${chatMessageSentWorkflow.id}, topic key ${allTopicKey} response: ${JSON.stringify(res.data)}`,
);
} catch (e) {
logger.error(
`Failed to trigger chat message on topic: ${allTopicKey}`,
e,
);
}
try {
const res = await chatMessageSentWorkflow.trigger({
payload: { dealId: opts.dealId },
to: {
type: 'topic',
topicKey: allTopicKey,
},
actor: {
subscriberId: opts.subscriberIdToExlude ?? '',
},
});
logger.info(
`Recieved novu workflow ${chatMessageSentWorkflow.id}, topic key ${allTopicKey} response: ${JSON.stringify(res.data)}`,
);
} catch (e) {
logger.error(
`Failed to trigger chat message on topic: ${allTopicKey}`,
e,
);
}