mirror of
https://github.com/spacebarchat/server.git
synced 2024-11-11 05:02:37 +01:00
✨ use rabbitmq for event transmission
This commit is contained in:
parent
b1a58ba7bd
commit
2ef830f4b2
@ -1,13 +1,25 @@
|
||||
import { Event, EventModel } from "@fosscord/server-util";
|
||||
import { Config, Event, EventModel, rabbitCon, rabbitCh } from "@fosscord/server-util";
|
||||
|
||||
export async function emitEvent(payload: Omit<Event, "created_at">) {
|
||||
const obj = {
|
||||
created_at: new Date(), // in seconds
|
||||
...payload,
|
||||
};
|
||||
// TODO: bigint isn't working
|
||||
if (rabbitCon) {
|
||||
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
|
||||
|
||||
return await new EventModel(obj).save();
|
||||
// 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 });
|
||||
if (!successful) throw new Error("failed to send event");
|
||||
} else {
|
||||
// use mongodb for event transmission
|
||||
// TODO: use event emitter for local server bundle
|
||||
const obj = {
|
||||
created_at: new Date(), // in seconds
|
||||
...payload
|
||||
};
|
||||
// TODO: bigint isn't working
|
||||
|
||||
return await new EventModel(obj).save();
|
||||
}
|
||||
}
|
||||
|
||||
export async function emitAuditLog(payload: any) {}
|
||||
|
Loading…
Reference in New Issue
Block a user