From b2769812fa3297a81f26788e4a69c7ff6eefc230 Mon Sep 17 00:00:00 2001
From: "Emma [it/its]@Rory&" <root@rory.gay>
Date: Sat, 2 Nov 2024 21:06:18 +0100
Subject: [PATCH] Log rabbitmq channel allocations

---
 src/gateway/listener/listener.ts | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/gateway/listener/listener.ts b/src/gateway/listener/listener.ts
index b624b8e0..503e1198 100644
--- a/src/gateway/listener/listener.ts
+++ b/src/gateway/listener/listener.ts
@@ -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?.());