From 3aed655eb7e63385b5e7a120c67527346697c514 Mon Sep 17 00:00:00 2001 From: Flam3rboy <34555296+Flam3rboy@users.noreply.github.com> Date: Thu, 12 Aug 2021 16:47:51 +0200 Subject: :sparkles: RabbitMQ --- src/util/Event.ts | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'src/util/Event.ts') diff --git a/src/util/Event.ts b/src/util/Event.ts index d0b78a53..e0bcadd4 100644 --- a/src/util/Event.ts +++ b/src/util/Event.ts @@ -1,13 +1,14 @@ -import { Config, Event, EventModel, rabbitCon, rabbitCh } from "@fosscord/server-util"; +import { Config, Event, EventModel, RabbitMQ } from "@fosscord/server-util"; export async function emitEvent(payload: Omit) { - if (rabbitCon) { + if (RabbitMQ.connection) { const id = (payload.channel_id || payload.user_id || payload.guild_id) as string; if (!id) console.error("event doesn't contain any id", payload); const data = typeof payload.data === "object" ? JSON.stringify(payload.data) : payload.data; // use rabbitmq for event transmission + await RabbitMQ.channel?.assertQueue(id); // assertQueue isn't needed, because a queue will automatically created if it doesn't exist - const successful = rabbitCh.sendToQueue(id, Buffer.from(`${data}`), { type: payload.event }); + const successful = RabbitMQ.channel?.sendToQueue(id, Buffer.from(`${data}`), { type: payload.event }); if (!successful) throw new Error("failed to send event"); } else { // use mongodb for event transmission -- cgit 1.5.1