mirror of
https://github.com/github/awesome-copilot.git
synced 2026-06-18 13:41:26 +00:00
Add Agent Arcade canvas extension (#2031)
* Add Agent Arcade canvas extension Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> * Refine Agent Arcade canvas behavior Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> * Update Agent Arcade canvas credits Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> * Update Agent Arcade canvas catalog anchor Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> * Ignoring the minified file * Configure codespell to skip minified Phaser file Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> --------- Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> Co-authored-by: Aaron Powell <me@aaron-powell.com>
This commit is contained in:
Dan Wahlin
GitHub
@@ -0,0 +1,546 @@
|
||||
import { createReadStream } from "node:fs";
|
||||
import { readFile, stat } from "node:fs/promises";
|
||||
import { createServer } from "node:http";
|
||||
import path from "node:path";
|
||||
import { fileURLToPath } from "node:url";
|
||||
|
||||
import { CanvasError, createCanvas, joinSession } from "@github/copilot-sdk/extension";
|
||||
|
||||
const __dirname = path.dirname(fileURLToPath(import.meta.url));
|
||||
const gameRoot = path.join(__dirname, "game");
|
||||
const assetsRoot = path.join(__dirname, "assets");
|
||||
const indexPath = path.join(gameRoot, "index.html");
|
||||
const gameJsPath = path.join(gameRoot, "game.js");
|
||||
const alienOnslaughtJsPath = path.join(gameRoot, "scenes", "AlienOnslaught.js");
|
||||
const galaxyBlasterJsPath = path.join(gameRoot, "scenes", "GalaxyBlaster.js");
|
||||
|
||||
const games = [
|
||||
{ key: "cosmic-rocks", label: "Cosmic Rocks", icon: "☄️" },
|
||||
{ key: "alien-onslaught", label: "Alien Onslaught", icon: "👾" },
|
||||
{ key: "galaxy-blaster", label: "Galaxy Blaster", icon: "🚀" },
|
||||
{ key: "ninja-runner", label: "Ninja Runner", icon: "🥷" },
|
||||
{ key: "defender", label: "Planet Guardian", icon: "🛡️" },
|
||||
];
|
||||
|
||||
const gameKeys = new Set(games.map((game) => game.key));
|
||||
const defaultGame = "ninja-runner";
|
||||
const canvasBackgroundGames = ["cosmic-rocks", "alien-onslaught", "galaxy-blaster", "defender"];
|
||||
const servers = new Map();
|
||||
|
||||
function normalizeGameKey(value) {
|
||||
return typeof value === "string" && gameKeys.has(value) ? value : defaultGame;
|
||||
}
|
||||
|
||||
function contentType(filePath) {
|
||||
switch (path.extname(filePath).toLowerCase()) {
|
||||
case ".html":
|
||||
return "text/html; charset=utf-8";
|
||||
case ".js":
|
||||
return "text/javascript; charset=utf-8";
|
||||
case ".css":
|
||||
return "text/css; charset=utf-8";
|
||||
case ".json":
|
||||
return "application/json; charset=utf-8";
|
||||
case ".png":
|
||||
return "image/png";
|
||||
case ".webp":
|
||||
return "image/webp";
|
||||
case ".xml":
|
||||
return "application/xml; charset=utf-8";
|
||||
case ".mp3":
|
||||
return "audio/mpeg";
|
||||
case ".ogg":
|
||||
return "audio/ogg";
|
||||
case ".m4a":
|
||||
return "audio/mp4";
|
||||
case ".wav":
|
||||
return "audio/wav";
|
||||
default:
|
||||
return "application/octet-stream";
|
||||
}
|
||||
}
|
||||
|
||||
function resolveUnder(root, requestPath) {
|
||||
const resolved = path.resolve(root, `.${requestPath}`);
|
||||
if (resolved !== root && !resolved.startsWith(`${root}${path.sep}`)) {
|
||||
throw new CanvasError("invalid_path", "Requested path is outside the arcade assets.");
|
||||
}
|
||||
return resolved;
|
||||
}
|
||||
|
||||
function sendJson(res, value) {
|
||||
res.writeHead(200, {
|
||||
"content-type": "application/json; charset=utf-8",
|
||||
"cache-control": "no-store",
|
||||
});
|
||||
res.end(JSON.stringify(value));
|
||||
}
|
||||
|
||||
function sendNotFound(res) {
|
||||
res.writeHead(404, { "content-type": "text/plain; charset=utf-8" });
|
||||
res.end("Not found");
|
||||
}
|
||||
|
||||
function sendSse(res, event, data) {
|
||||
res.write(`event: ${event}\n`);
|
||||
res.write(`data: ${JSON.stringify(data)}\n\n`);
|
||||
}
|
||||
|
||||
function broadcast(entry, event, data) {
|
||||
for (const client of entry.clients) {
|
||||
sendSse(client, event, data);
|
||||
}
|
||||
}
|
||||
|
||||
async function renderIndex(entry) {
|
||||
const html = await readFile(indexPath, "utf8");
|
||||
const bootstrap = `<script>
|
||||
(() => {
|
||||
const selectedGame = ${JSON.stringify(entry.selectedGame)};
|
||||
const games = ${JSON.stringify(games)};
|
||||
const canvasBackgroundGames = ${JSON.stringify(canvasBackgroundGames)};
|
||||
let switchingGames = false;
|
||||
try {
|
||||
localStorage.setItem("agentArcade_pauseKey", "Escape");
|
||||
localStorage.setItem("agentArcade_unpauseKey", "Ctrl+Escape");
|
||||
} catch {}
|
||||
|
||||
function storeGame(gameKey) {
|
||||
try { localStorage.setItem("agentArcade_lastGame", gameKey); } catch {}
|
||||
}
|
||||
|
||||
function selectGame(gameKey) {
|
||||
if (!games.some((game) => game.key === gameKey)) return;
|
||||
storeGame(gameKey);
|
||||
applyCanvasBackdrop(gameKey);
|
||||
setTimeout(() => applyCanvasBackdrop(gameKey), 150);
|
||||
const selector = document.getElementById("game-select");
|
||||
if (selector) selector.value = gameKey;
|
||||
if (window.__agentArcadeSwitchGame) {
|
||||
markSwitchingGame();
|
||||
window.__agentArcadeSwitchGame(gameKey);
|
||||
return;
|
||||
}
|
||||
let attempts = 0;
|
||||
const timer = setInterval(() => {
|
||||
attempts += 1;
|
||||
if (window.__agentArcadeSwitchGame) {
|
||||
clearInterval(timer);
|
||||
markSwitchingGame();
|
||||
window.__agentArcadeSwitchGame(gameKey);
|
||||
} else if (attempts > 40) {
|
||||
clearInterval(timer);
|
||||
}
|
||||
}, 100);
|
||||
}
|
||||
|
||||
function applyCanvasBackdrop(gameKey) {
|
||||
try {
|
||||
const useSpaceBackground = canvasBackgroundGames.includes(gameKey);
|
||||
document.body.classList.toggle("canvas-space-background", useSpaceBackground);
|
||||
localStorage.setItem("agentArcade_bgDefault_v2", "1");
|
||||
localStorage.setItem("agentArcade_bgTransparency", useSpaceBackground ? "0" : "100");
|
||||
const scenes = window.__phaserGame?.scene?.scenes ?? [];
|
||||
for (const scene of scenes) {
|
||||
if (typeof scene.setBackdropAlpha === "function") {
|
||||
scene.setBackdropAlpha(useSpaceBackground ? 0 : 100);
|
||||
}
|
||||
scene._backdrop?.setAlpha?.(useSpaceBackground ? 0 : 1);
|
||||
}
|
||||
} catch {}
|
||||
}
|
||||
|
||||
function isHudOverlayOpen() {
|
||||
return document.getElementById("settings-overlay")?.classList.contains("show")
|
||||
|| document.getElementById("help-overlay")?.classList.contains("show");
|
||||
}
|
||||
|
||||
function isTextInput(target) {
|
||||
const el = target;
|
||||
return !!el?.closest?.("input, textarea, select, [contenteditable='true']");
|
||||
}
|
||||
|
||||
function markSwitchingGame() {
|
||||
switchingGames = true;
|
||||
setTimeout(() => { switchingGames = false; }, 600);
|
||||
}
|
||||
|
||||
function pauseCanvas() {
|
||||
if (document.body.classList.contains("paused")) return;
|
||||
window.__agentArcadePauseScene?.(true);
|
||||
document.getElementById("hud")?.classList.add("paused");
|
||||
document.body.classList.add("paused");
|
||||
document.getElementById("gameover-overlay")?.style.setProperty("display", "none");
|
||||
document.getElementById("wave-banner")?.style.setProperty("display", "none");
|
||||
document.getElementById("help-overlay")?.classList.remove("show");
|
||||
document.getElementById("ready-overlay")?.remove();
|
||||
}
|
||||
|
||||
function resumeCanvas() {
|
||||
if (!document.body.classList.contains("paused") && !document.getElementById("hud")?.classList.contains("paused")) return;
|
||||
if (!switchingGames) {
|
||||
window.__agentArcadePauseScene?.(false);
|
||||
}
|
||||
document.getElementById("hud")?.classList.remove("paused");
|
||||
document.body.classList.remove("paused");
|
||||
setTimeout(() => document.querySelector("#game canvas")?.focus?.(), 50);
|
||||
}
|
||||
|
||||
window.agentArcade = {
|
||||
setClickThrough: () => {},
|
||||
setPaused: (paused) => paused ? pauseCanvas() : resumeCanvas(),
|
||||
onResumeRequest: () => {},
|
||||
quitApp: () => {},
|
||||
hideApp: () => {},
|
||||
};
|
||||
|
||||
function handleCanvasHotkey(event) {
|
||||
if (event.__agentArcadeCanvasHandled) return;
|
||||
if (event.code !== "Escape" || isTextInput(event.target) || isHudOverlayOpen()) return;
|
||||
event.__agentArcadeCanvasHandled = true;
|
||||
if (event.ctrlKey && !event.shiftKey && !event.altKey && !event.metaKey) {
|
||||
event.preventDefault();
|
||||
event.stopPropagation();
|
||||
resumeCanvas();
|
||||
return;
|
||||
}
|
||||
if (!event.altKey && !event.metaKey) {
|
||||
event.preventDefault();
|
||||
event.stopPropagation();
|
||||
pauseCanvas();
|
||||
}
|
||||
}
|
||||
|
||||
window.addEventListener("keydown", handleCanvasHotkey, true);
|
||||
document.addEventListener("keydown", handleCanvasHotkey, true);
|
||||
|
||||
document.getElementById("resume-btn")?.addEventListener("click", (event) => {
|
||||
event.preventDefault();
|
||||
event.stopImmediatePropagation();
|
||||
resumeCanvas();
|
||||
}, true);
|
||||
|
||||
document.getElementById("game-select")?.addEventListener("change", () => {
|
||||
markSwitchingGame();
|
||||
}, true);
|
||||
|
||||
storeGame(selectedGame);
|
||||
applyCanvasBackdrop(selectedGame);
|
||||
setTimeout(() => selectGame(selectedGame), 300);
|
||||
setTimeout(() => applyCanvasBackdrop(selectedGame), 800);
|
||||
|
||||
const style = document.createElement("style");
|
||||
style.textContent = \`
|
||||
html, body, body.paused, #game {
|
||||
background-color: #02040d !important;
|
||||
}
|
||||
body.canvas-space-background,
|
||||
body.canvas-space-background.paused,
|
||||
body.canvas-space-background #game {
|
||||
background-image:
|
||||
radial-gradient(circle at 50% 35%, rgba(18, 34, 88, 0.35), rgba(2, 4, 13, 0.18) 42%, rgba(2, 4, 13, 0.78) 100%),
|
||||
url('/assets/canvas-background.webp') !important;
|
||||
background-position: center, center !important;
|
||||
background-repeat: no-repeat, no-repeat !important;
|
||||
background-size: cover, cover !important;
|
||||
}
|
||||
canvas { background: transparent !important; }
|
||||
#bg-transparency { display: none !important; }
|
||||
#bg-transparency-value::before { content: 'Canvas backdrop'; }
|
||||
#bg-transparency-value { font-size: 0 !important; }
|
||||
#bg-transparency-value::before { font-size: 12px !important; }
|
||||
#hud { top: 12px !important; max-width: calc(100vw - 32px); gap: 12px !important; transform: translateX(-50%); transform-origin: top center; }
|
||||
#minimize-btn, #close-btn, #drag-handle { display: none !important; }
|
||||
#update-banner { display: none !important; }
|
||||
@media (max-width: 760px) {
|
||||
#hud { left: 12px !important; right: 12px !important; transform: none !important; justify-content: center; flex-wrap: wrap; white-space: normal !important; }
|
||||
.hud-divider, .hud-spacer { display: none !important; }
|
||||
}
|
||||
\`;
|
||||
document.head.appendChild(style);
|
||||
|
||||
window.__agentArcadeCanvasSelectGame = selectGame;
|
||||
window.__agentArcadeCanvasGames = games;
|
||||
|
||||
const events = new EventSource("/events");
|
||||
events.addEventListener("selectGame", (event) => {
|
||||
try { selectGame(JSON.parse(event.data).gameKey); } catch {}
|
||||
});
|
||||
events.addEventListener("reload", () => window.location.reload());
|
||||
})();
|
||||
</script>`;
|
||||
return html.replace('<script src="./hud.js"></script>', `${bootstrap}\n <script src="./hud.js"></script>`);
|
||||
}
|
||||
|
||||
async function renderGameJs() {
|
||||
const js = await readFile(gameJsPath, "utf8");
|
||||
return js
|
||||
.replaceAll("newW > 800 && newH > 400", "newW > 320 && newH > 220")
|
||||
.replaceAll("game && newH > 400", "game && newH > 220")
|
||||
.replaceAll("window.innerWidth > 800 && window.innerHeight > 400", "window.innerWidth > 320 && window.innerHeight > 220");
|
||||
}
|
||||
|
||||
async function renderAlienOnslaughtJs() {
|
||||
const js = await readFile(alienOnslaughtJsPath, "utf8");
|
||||
const layoutH = "Math.min(H, W * 3 / 4)";
|
||||
const layoutY = `((H - ${layoutH}) / 2)`;
|
||||
return js
|
||||
.replace("this.playerY = H * 0.92;", `this.playerY = ${layoutY} + ${layoutH} * 0.95;`)
|
||||
.replace("this.alienGridY = Math.max(H * 0.20, 120);", `this.alienGridY = Math.max(${layoutY} + ${layoutH} * 0.10, 80);`)
|
||||
.replace("const targetShieldH = H * 0.055;", `const targetShieldH = ${layoutH} * 0.065;`)
|
||||
.replace("SCALE = Math.min(W / 1920, H / 1080);", "SCALE = Math.max(1.25, Math.min(W / 1920, H / 1080));")
|
||||
.replace("this.alienCellW = Math.round(W * 0.055);", "this.alienCellW = Math.round(W * 0.068);");
|
||||
}
|
||||
|
||||
async function renderGalaxyBlasterJs() {
|
||||
const js = await readFile(galaxyBlasterJsPath, "utf8");
|
||||
return js
|
||||
.replaceAll("SCALE = Math.min(CONV_X, CONV_Y);", "SCALE = Math.max(1.7, Math.min(CONV_X, CONV_Y));")
|
||||
.replaceAll("OPPONENT_SIZE = Math.min(32 * SCALE, W / 35);", "OPPONENT_SIZE = Math.max(54, Math.min(32 * SCALE, W / 24));");
|
||||
}
|
||||
|
||||
async function streamFile(res, filePath) {
|
||||
const fileStat = await stat(filePath).catch(() => undefined);
|
||||
if (!fileStat?.isFile()) {
|
||||
sendNotFound(res);
|
||||
return;
|
||||
}
|
||||
|
||||
res.writeHead(200, {
|
||||
"content-type": contentType(filePath),
|
||||
"cache-control": "no-cache",
|
||||
});
|
||||
const stream = createReadStream(filePath);
|
||||
stream.on("error", () => {
|
||||
if (!res.headersSent) {
|
||||
sendNotFound(res);
|
||||
} else {
|
||||
res.destroy();
|
||||
}
|
||||
});
|
||||
stream.pipe(res);
|
||||
}
|
||||
|
||||
async function handleSelectGame(entry, req, res) {
|
||||
let body = "";
|
||||
req.setEncoding("utf8");
|
||||
req.on("data", (chunk) => {
|
||||
body += chunk;
|
||||
});
|
||||
req.on("end", () => {
|
||||
let input;
|
||||
try {
|
||||
input = JSON.parse(body || "{}");
|
||||
} catch {
|
||||
res.writeHead(400, { "content-type": "text/plain; charset=utf-8" });
|
||||
res.end("Invalid JSON request body");
|
||||
return;
|
||||
}
|
||||
entry.selectedGame = normalizeGameKey(input.gameKey);
|
||||
broadcast(entry, "selectGame", { gameKey: entry.selectedGame });
|
||||
sendJson(res, { selectedGame: entry.selectedGame });
|
||||
});
|
||||
}
|
||||
|
||||
async function handleRequest(entry, req, res) {
|
||||
const url = new URL(req.url ?? "/", entry.url);
|
||||
|
||||
if (url.pathname === "/events") {
|
||||
res.writeHead(200, {
|
||||
"content-type": "text/event-stream; charset=utf-8",
|
||||
"cache-control": "no-cache",
|
||||
connection: "keep-alive",
|
||||
});
|
||||
entry.clients.add(res);
|
||||
sendSse(res, "selectGame", { gameKey: entry.selectedGame });
|
||||
req.on("close", () => entry.clients.delete(res));
|
||||
return;
|
||||
}
|
||||
|
||||
if (url.pathname === "/state") {
|
||||
sendJson(res, { games, selectedGame: entry.selectedGame });
|
||||
return;
|
||||
}
|
||||
|
||||
if (url.pathname === "/favicon.ico") {
|
||||
await streamFile(res, path.join(assetsRoot, "icon.png"));
|
||||
return;
|
||||
}
|
||||
|
||||
if (url.pathname === "/select-game" && req.method === "POST") {
|
||||
await handleSelectGame(entry, req, res);
|
||||
return;
|
||||
}
|
||||
|
||||
try {
|
||||
if (url.pathname === "/" || url.pathname === "/index.html" || url.pathname === "/game" || url.pathname === "/game/") {
|
||||
res.writeHead(200, {
|
||||
"content-type": "text/html; charset=utf-8",
|
||||
"cache-control": "no-cache",
|
||||
});
|
||||
res.end(await renderIndex(entry));
|
||||
return;
|
||||
}
|
||||
|
||||
if (url.pathname === "/game.js" || url.pathname === "/game/game.js") {
|
||||
res.writeHead(200, {
|
||||
"content-type": "text/javascript; charset=utf-8",
|
||||
"cache-control": "no-cache",
|
||||
});
|
||||
res.end(await renderGameJs());
|
||||
return;
|
||||
}
|
||||
|
||||
if (url.pathname === "/scenes/AlienOnslaught.js" || url.pathname === "/game/scenes/AlienOnslaught.js") {
|
||||
res.writeHead(200, {
|
||||
"content-type": "text/javascript; charset=utf-8",
|
||||
"cache-control": "no-cache",
|
||||
});
|
||||
res.end(await renderAlienOnslaughtJs());
|
||||
return;
|
||||
}
|
||||
|
||||
if (url.pathname === "/scenes/GalaxyBlaster.js" || url.pathname === "/game/scenes/GalaxyBlaster.js") {
|
||||
res.writeHead(200, {
|
||||
"content-type": "text/javascript; charset=utf-8",
|
||||
"cache-control": "no-cache",
|
||||
});
|
||||
res.end(await renderGalaxyBlasterJs());
|
||||
return;
|
||||
}
|
||||
|
||||
const staticPath = url.pathname.startsWith("/assets/")
|
||||
? resolveUnder(assetsRoot, url.pathname.slice("/assets".length))
|
||||
: resolveUnder(gameRoot, url.pathname.startsWith("/game/") ? url.pathname.slice("/game".length) : url.pathname);
|
||||
await streamFile(res, staticPath);
|
||||
} catch (error) {
|
||||
if (error instanceof CanvasError) {
|
||||
res.writeHead(400, { "content-type": "text/plain; charset=utf-8" });
|
||||
res.end(error.message);
|
||||
return;
|
||||
}
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
async function startServer(instanceId, selectedGame) {
|
||||
const entry = {
|
||||
clients: new Set(),
|
||||
selectedGame,
|
||||
server: undefined,
|
||||
url: undefined,
|
||||
};
|
||||
const server = createServer((req, res) => {
|
||||
handleRequest(entry, req, res).catch((error) => {
|
||||
res.writeHead(500, { "content-type": "text/plain; charset=utf-8" });
|
||||
res.end(error instanceof Error ? error.message : "Arcade canvas server error");
|
||||
});
|
||||
});
|
||||
entry.server = server;
|
||||
|
||||
await new Promise((resolve) => server.listen(0, "127.0.0.1", resolve));
|
||||
const address = server.address();
|
||||
const port = typeof address === "object" && address ? address.port : 0;
|
||||
entry.url = `http://127.0.0.1:${port}/`;
|
||||
servers.set(instanceId, entry);
|
||||
return entry;
|
||||
}
|
||||
|
||||
function getOpenEntry(instanceId) {
|
||||
const entry = servers.get(instanceId);
|
||||
if (!entry) {
|
||||
throw new CanvasError("arcade_not_open", "Open the Arcade canvas before invoking this action.");
|
||||
}
|
||||
return entry;
|
||||
}
|
||||
|
||||
await joinSession({
|
||||
canvases: [
|
||||
createCanvas({
|
||||
id: "arcade-canvas",
|
||||
displayName: "Agent Arcade",
|
||||
description: "A retro arcade canvas with five mini-games for waiting while agents work.",
|
||||
inputSchema: {
|
||||
type: "object",
|
||||
properties: {
|
||||
defaultGame: {
|
||||
type: "string",
|
||||
enum: games.map((game) => game.key),
|
||||
description: "Game to show first.",
|
||||
},
|
||||
},
|
||||
additionalProperties: false,
|
||||
},
|
||||
actions: [
|
||||
{
|
||||
name: "list_games",
|
||||
description: "List the mini-games available in the arcade canvas.",
|
||||
handler: (ctx) => {
|
||||
const entry = servers.get(ctx.instanceId);
|
||||
return {
|
||||
games,
|
||||
selectedGame: entry?.selectedGame ?? defaultGame,
|
||||
};
|
||||
},
|
||||
},
|
||||
{
|
||||
name: "select_game",
|
||||
description: "Switch the open arcade canvas to a specific mini-game.",
|
||||
inputSchema: {
|
||||
type: "object",
|
||||
properties: {
|
||||
gameKey: {
|
||||
type: "string",
|
||||
enum: games.map((game) => game.key),
|
||||
},
|
||||
},
|
||||
required: ["gameKey"],
|
||||
additionalProperties: false,
|
||||
},
|
||||
handler: (ctx) => {
|
||||
const entry = getOpenEntry(ctx.instanceId);
|
||||
entry.selectedGame = normalizeGameKey(ctx.input?.gameKey);
|
||||
broadcast(entry, "selectGame", { gameKey: entry.selectedGame });
|
||||
return {
|
||||
selectedGame: entry.selectedGame,
|
||||
};
|
||||
},
|
||||
},
|
||||
{
|
||||
name: "restart_game",
|
||||
description: "Reload the open arcade canvas to restart the selected game.",
|
||||
handler: (ctx) => {
|
||||
const entry = getOpenEntry(ctx.instanceId);
|
||||
broadcast(entry, "reload", {});
|
||||
return {
|
||||
selectedGame: entry.selectedGame,
|
||||
};
|
||||
},
|
||||
},
|
||||
],
|
||||
open: async (ctx) => {
|
||||
let entry = servers.get(ctx.instanceId);
|
||||
if (!entry) {
|
||||
entry = await startServer(ctx.instanceId, normalizeGameKey(ctx.input?.defaultGame));
|
||||
} else if (ctx.input?.defaultGame) {
|
||||
entry.selectedGame = normalizeGameKey(ctx.input.defaultGame);
|
||||
}
|
||||
return {
|
||||
title: "Agent Arcade",
|
||||
status: games.find((game) => game.key === entry.selectedGame)?.label ?? "Ready",
|
||||
url: entry.url,
|
||||
};
|
||||
},
|
||||
onClose: async (ctx) => {
|
||||
const entry = servers.get(ctx.instanceId);
|
||||
if (!entry) return;
|
||||
|
||||
servers.delete(ctx.instanceId);
|
||||
for (const client of entry.clients) {
|
||||
client.end();
|
||||
}
|
||||
await new Promise((resolve) => entry.server.close(() => resolve()));
|
||||
},
|
||||
}),
|
||||
],
|
||||
});
|
||||
Reference in New Issue
Block a user