Spacebar/server
1
0
Fork 0
mirror of https://github.com/spacebarchat/server.git synced 2024-11-25 11:43:07 +01:00
Code Issues Releases Activity

Log rabbitmq channel allocations

Browse Source
This commit is contained in:
Emma [it/its]@Rory& 2024-11-02 21:06:18 +01:00
parent 40b356ecdf
commit b2769812fa
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/gateway/listener/listener.ts
View File

@ -34,6 +34,7 @@ import { WebSocket } from "@spacebar/gateway";
import "missing-native-js-functions";
import { Channel as AMQChannel } from "amqplib";
import { Recipient } from "@spacebar/util";
import * as console from "node:console";
// TODO: close connection on Invalidated Token
// TODO: check intent
@ -88,9 +89,12 @@ export async function setupListener(this: WebSocket) {
this.listen_options = opts;
const consumer = consume.bind(this);
console.log("[RabbitMQ] setupListener: open for ", this.user_id);
if (RabbitMQ.connection) {
console.log("[RabbitMQ] setupListener: opts.channel = ", typeof opts.channel, opts.channel);
opts.channel = await RabbitMQ.connection.createChannel();
opts.channel.queues = {};
console.log("[RabbitMQ] channel created: ", typeof opts.channel, opts.channel);
}
this.events[this.user_id] = await listenEvent(this.user_id, consumer, opts);
@ -128,6 +132,7 @@ export async function setupListener(this: WebSocket) {
});
this.once("close", () => {
console.log("[RabbitMQ] setupListener: close for ", this.user_id, "=", typeof opts.channel, opts.channel);
if (opts.channel) opts.channel.close();
else {
Object.values(this.events).forEach((x) => x?.());