alexbcberio/twitch-channel-redemptions
Archived
1
0
Fork 0
Code Releases Activity

♻️ Extract code from onRedemption to functions

Browse Source
This commit is contained in:
Alexander BC
2022-01-07 13:13:10 +01:00
parent 6d95a754cc
commit d538491e07
1 changed files with 74 additions and 44 deletions
Download Patch File Download Diff File Expand all files Collapse all files

118
src/backend/pubSubClient/index.ts
View File

@@ -46,6 +46,68 @@ function getRedemptionHandlerFromRewardId(rewardId: string): RedemptionHandler {
} }
} }
function keepInQueue(rewardId: string): boolean {
const keepInQueueRewards = [RedemptionIds.KaraokeTime];
// @ts-expect-error String is not assignable to... but all keys are strings
if (keepInQueueRewards.includes(rewardId)) {
return true;
}
return false;
}
async function cancelReward(message: PubSubRedemptionMessage): Promise<void> {
if (!message.rewardIsQueued) {
return;
}
if (keepInQueue(message.rewardId)) {
console.log(`${LOG_PREFIX}Reward kept in queue due to config`);
return;
}
try {
await cancelRewards(message.channelId, message.rewardId, message.id);
console.log(`${LOG_PREFIX}Reward removed from queue (canceled)`);
} catch (e) {
if (e instanceof Error) {
console.log(`${LOG_PREFIX}${e.message}`);
}
}
}
async function completeReward(message: PubSubRedemptionMessage): Promise<void> {
if (!message.rewardIsQueued) {
return;
}
if (keepInQueue(message.rewardId)) {
console.log(`${LOG_PREFIX}Reward kept in queue due to config`);
return;
}
try {
await completeRewards(message.channelId, message.rewardId, message.id);
console.log(`${LOG_PREFIX}Reward removed from queue (completed)`);
} catch (e) {
if (e instanceof Error) {
console.log(`${LOG_PREFIX}${e.message}`);
}
}
}
function rewardNameFromRewardId(rewardId: string): string {
const rewardEnumValues = Object.values(RedemptionIds);
// @ts-expect-error String is not assignable to... but all keys are strings
const rewardIdValueIndex = rewardEnumValues.indexOf(rewardId);
const rewardName = Object.keys(RedemptionIds)[rewardIdValueIndex];
return rewardName;
}
async function onRedemption(message: PubSubRedemptionMessage) { async function onRedemption(message: PubSubRedemptionMessage) {
console.log( console.log(
`${LOG_PREFIX}Reward: "${message.rewardTitle}" (${message.rewardId}) redeemed by ${message.userDisplayName}` `${LOG_PREFIX}Reward: "${message.rewardTitle}" (${message.rewardId}) redeemed by ${message.userDisplayName}`
@@ -67,63 +129,31 @@ async function onRedemption(message: PubSubRedemptionMessage) {
backgroundColor: raw.data.redemption.reward.background_color, backgroundColor: raw.data.redemption.reward.background_color,
}; };
let handledMessage: RedemptionMessage | undefined; let handledMessage: RedemptionMessage;
const redemptionHandler = getRedemptionHandlerFromRewardId(msg.rewardId); const redemptionHandler = getRedemptionHandlerFromRewardId(msg.rewardId);
try { try {
handledMessage = await redemptionHandler(msg); handledMessage = {
...(await redemptionHandler(msg)),
rewardId: rewardNameFromRewardId(message.rewardId),
};
} catch (e) { } catch (e) {
if (e instanceof Error) { if (e instanceof Error) {
console.error(`${LOG_PREFIX}${e.message}`); console.error(`${LOG_PREFIX}${e.message}`);
} }
}
let completeOrCancelReward = cancelRewards; await cancelReward(message);
if (typeof handledMessage !== "undefined") {
const rewardEnumValues = Object.values(RedemptionIds);
const rewardIdValueIndex = rewardEnumValues.indexOf(
// @ts-expect-error String is not assignable to... but all keys are strings
handledMessage.rewardId
);
const rewardName = Object.keys(RedemptionIds)[rewardIdValueIndex];
handledMessage.rewardId = rewardName;
broadcast(JSON.stringify(handledMessage));
if (isProduction) {
completeOrCancelReward = completeRewards;
}
}
// 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)) {
completeOrCancelReward = cancelRewards;
console.log(`${LOG_PREFIX}Reward kept in queue due to config`);
return; return;
} }
if (message.rewardIsQueued) { broadcast(JSON.stringify(handledMessage));
try {
await completeOrCancelReward( if (isProduction) {
message.channelId, await completeReward(message);
message.rewardId, } else {
message.id await cancelReward(message);
);
console.log(
`${LOG_PREFIX}Reward removed from queue (completed or canceled)`
);
} catch (e) {
if (e instanceof Error) {
console.log(`${LOG_PREFIX}${e.message}`);
}
}
} }
} }