✨ Small check to keep some rewards in the queue
This commit is contained in:
@@ -93,6 +93,15 @@ async function onRedemption(message: PubSubRedemptionMessage) {
|
|||||||
broadcast(JSON.stringify(handledMessage));
|
broadcast(JSON.stringify(handledMessage));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// TODO: improve this check
|
||||||
|
const keepInQueueRewards = [RedemptionIds.KaraokeTime];
|
||||||
|
|
||||||
|
// @ts-expect-error String is not assignable to... but all keys are strings
|
||||||
|
if (keepInQueueRewards.includes(message.rewardId)) {
|
||||||
|
console.log(`${LOG_PREFIX}Reward kept in queue due to config`);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
const completeOrCancelReward =
|
const completeOrCancelReward =
|
||||||
handledMessage && isProduction ? completeRewards : cancelRewards;
|
handledMessage && isProduction ? completeRewards : cancelRewards;
|
||||||
|
|
||||||
@@ -103,6 +112,9 @@ async function onRedemption(message: PubSubRedemptionMessage) {
|
|||||||
message.rewardId,
|
message.rewardId,
|
||||||
message.id
|
message.id
|
||||||
);
|
);
|
||||||
|
console.log(
|
||||||
|
`${LOG_PREFIX}Reward removed from queue (completed or canceled)`
|
||||||
|
);
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
if (e instanceof Error) {
|
if (e instanceof Error) {
|
||||||
console.log(`${LOG_PREFIX}${e.message}`);
|
console.log(`${LOG_PREFIX}${e.message}`);
|
||||||
|
Reference in New Issue
Block a user