Skip to content

Commit

Permalink
Add more logs for /connections/ endpoint of the signal server
Browse files Browse the repository at this point in the history
  • Loading branch information
MaciejWas committed Jan 30, 2025
1 parent 836367f commit 9c99329
Showing 1 changed file with 11 additions and 0 deletions.
11 changes: 11 additions & 0 deletions bin/utils.js
Original file line number Diff line number Diff line change
Expand Up @@ -480,13 +480,22 @@ export const setupWSConnection = async (conn, req, { docName = req.url.slice(1).
const URL_PREFIX = process.env.URL_PREFIX || "";

export const handleRequest = (/** @type {http.IncomingMessage} */ request) => {
console.log(`[handleRequest] Received ${request.method} request with url: ${request.url}`);
const params = new URLSearchParams(request.url?.split("?")[1]);
console.log(`[handleRequest] parsed parameters: ${[...params.entries()]}`);

if (request.url.startsWith(URL_PREFIX + "/connections/") && request.method == "PATCH") {
const room = request.url?.split("?")[0].replace(URL_PREFIX + "/connections/", "");

console.log(`[handleRequest] room is ${room} (${new TextEncoder().encode(room)})`);
console.log(`[handleRequest] room is present: ${docs.has(room)}`);
console.log(`[handleRequest] Total rooms: ${docs.size}`);

const doc = docs.get(room);
if (!doc) return { code: 404, error: `Room ${room} does not exist` };

console.log(`Disconnecting ${params.get("users")}`);

if (!params.get("users")) {
return { code: 400, error: "No users were supplied" };
}
Expand All @@ -497,6 +506,8 @@ export const handleRequest = (/** @type {http.IncomingMessage} */ request) => {
});

const usersWithAccess = params.get("users").split(",");
console.log(`[handleRequest] Users with access ${usersWithAccess}`);

for (const conn of doc.conns.keys()) {
if (!usersWithAccess.includes(conn.__username)) {
conn.close();
Expand Down

0 comments on commit 9c99329

Please sign in to comment.