diff --git a/client/app.js b/client/app.js index 21f2a2d..fd2fa59 100644 --- a/client/app.js +++ b/client/app.js @@ -64,19 +64,6 @@ async function checkEvent(e) { case "ac750bd6-fb4c-4259-b06d-56953601243b": await createCard(data.rewardName, data.message, data.backgroundColor, data.rewardImage); break; - // hidratate - case "232e951f-93d1-4138-a0e3-9e822b4852e0": - data.message = `@${data.userDisplayName} ha invitado a una ronda.`; - sendWsActions({ - type: "say", - channelId: data.channelId, - userId: data.userId, - data: { - message: "waterGang waterGang waterGang" - } - }); - await createCard(data.rewardName, data.message, data.backgroundColor, data.rewardImage); - break; default: await createCard(data.rewardName, data.message ? data.message : "", data.backgroundColor, data.rewardImage); } diff --git a/src/backend/pubSubClient/actions/hidrate.ts b/src/backend/pubSubClient/actions/hidrate.ts new file mode 100644 index 0000000..0028f70 --- /dev/null +++ b/src/backend/pubSubClient/actions/hidrate.ts @@ -0,0 +1,23 @@ +import { LOG_PREFIX } from ".."; +import { RedemptionMessage } from "../../../interfaces/RedemptionMessage"; +import { broadcast } from "../../helpers/webServer"; +import { getUsernameFromId } from "../../helpers/twitch"; +import { say } from "../../chatClient"; + +async function hidrate(msg: RedemptionMessage): Promise { + const channel = await getUsernameFromId(parseInt(msg.channelId)); + + if (!channel) { + console.log(`${LOG_PREFIX}No channel found`); + + return; + } + + msg.message = `@${msg.userDisplayName} ha invitado a una ronda`; + + broadcast(JSON.stringify(msg)); + + await say(channel, "waterGang waterGang waterGang"); +} + +export { hidrate }; diff --git a/src/backend/pubSubClient/index.ts b/src/backend/pubSubClient/index.ts index 483bd21..c6c7a9f 100644 --- a/src/backend/pubSubClient/index.ts +++ b/src/backend/pubSubClient/index.ts @@ -6,6 +6,7 @@ import { UserIdResolvable } from "twitch"; import { broadcast } from "../helpers/webServer"; import { getApiClient } from "../helpers/twitch"; import { getVip } from "./actions/getVip"; +import { hidrate } from "./actions/hidrate"; import { russianRoulette } from "./actions/russianRoulette"; import { stealVip } from "./actions/stealVip"; import { timeoutFriend } from "./actions/timeoutFriend"; @@ -66,6 +67,7 @@ async function onRedemption(message: PubSubRedemptionMessage) { } break; case RedemptionIds.Hidrate: + await hidrate(msg); break; default: console.log(LOG_PREFIX, msg);