Enhanced Multiplayer Hub

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_151":152,"_153":154},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_115":-5,"_20":116,"_22":117,"_118":119,"_120":121,"_25":122,"_24":-5,"_123":-5,"_124":-5,"_125":53,"_126":127,"_128":53,"_129":-5,"_130":-5,"_131":132},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","apersonwhomakesstuff","name","ServerTest","branchName","main","version","path","","project",{"_33":61,"_13":14,"_45":62,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":19,"_69":-5,"_70":71,"_72":-5,"_73":53,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":-5,"_81":-5,"_82":-5,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":94,"_95":96,"_97":98,"_99":53},"tree",[56],"file","contents",[32],"upstream","pull","ahead","behind","envVars",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":55},"id","4cd6ae93-a630-413c-89b6-2a329870e1f5","main.ts","fileId","dda4c30c-646f-11f1-8ab1-1607ee4eb77e","parentId","branchId","6ee0c96c-8246-430a-861b-806c1c3f587b","branchVersion",2,"latest",true,"createdAt",["D",1781056768039],1,"fileType","script","content","/*\nEnhanced Deno multiplayer hub with Val Town compatibility:\n- Strict validation and TypeScript-friendly typings\n- Chat profanity censoring (using external JSON list)\n- Chunked gzip-compressed block uploads\n- Val Town compatible API structure\n- Run with: deno run --allow-net server.deno.ts\n*/\n\nimport { serve } from \"https://deno.land/std@0.203.0/http/server.ts\";\nimport { v4 } from \"https://deno.land/std@0.203.0/uuid/mod.ts\";\nimport { gzipEncode } from \"https://deno.land/std@0.203.0/encoding/gzip.ts\";\n\nconst PORT = Number(Deno.env.get(\"PORT\") || 8080);\nconst CORS_HEADERS = {\n \"access-control-allow-origin\": \"*\",\n \"access-control-allow-methods\": \"GET, POST, OPTIONS\",\n \"access-control-allow-headers\": \"Content-Type, Content-Encoding\",\n};\n\nconsole.log(\n `Starting enhanced multiplayer hub on :${PORT} (Val Town compatible)`,\n);\n\n/* Types */\ntype ChatEntry = {\n id: string;\n username: string | null;\n message: string;\n created_at: number;\n};\n\ntype PresenceRecord = {\n clientId: string;\n username?: string;\n position?: { x: number; y: number; z: number };\n rotation?: { x?: number; y?: number; z?: number };\n serverId?: string;\n lastSeen: number;\n};\n\ntype ServerRecord = {\n id: string;\n name?: string;\n seed?: string;\n motd?: string;\n iconUrl?: string | null;\n created_at: string;\n adminPassword?: string | null;\n blocksChunks?: Map;\n blocksBinary?: Uint8Array | null; // For Val Town compatibility\n blocksTotalBytes?: number;\n presence?: Map;\n chatLog?: ChatEntry[];\n wsClients?: Set;\n};\n\n/* Configuration */\nconst MAX_CHUNK_BYTES = 1_000_000; // 1MB per chunk\nconst MAX_TOTAL_STORED = 50 * 1024 * 1024; // 50MB per server\nconst CHAT_RETENTION_MS = 30 * 60 * 1000;\nconst PROFANITY_LIST_URL =\n \"https://cdn.jsdelivr.net/npm/profane-words@1.3.0/index.json\";\n\nconst registry = new Map();\nconst wsRooms = new Map>();\n\n/* Load profanity list from CDN (no hardcoded words) */\nlet PROFANITY_LIST: string[] = [];\ntry {\n const response = await fetch(PROFANITY_LIST_URL);\n PROFANITY_LIST = await response.json();\n console.log(`Loaded ${PROFANITY_LIST.length} profanity words`);\n} catch (error) {\n console.warn(\"Could not load profanity list, using fallback\");\n PROFANITY_LIST = []; // Empty list as fallback\n}\n\nfunction censorMessage(s: string): string {\n if (PROFANITY_LIST.length === 0) return s;\n const pattern = new RegExp(\n PROFANITY_LIST.map((w) => w.replace(/[.*+?^${}()|[\\]\\\\]/g, \"\\\\$&\")).join(\n \"|\",\n ),\n \"ig\",\n );\n return s.replace(pattern, (m) => \"*\".repeat(Math.max(3, m.length)));\n}\n\n/* Housekeeping */\nsetInterval(() => {\n const now = Date.now();\n for (const rec of registry.values()) {\n rec.chatLog = (rec.chatLog || []).filter((c) =>\n now - c.created_at <= CHAT_RETENTION_MS\n );\n }\n}, 60_000);\n\nsetInterval(() => {\n const now = Date.now();\n for (const rec of registry.values()) {\n if (!rec.presence) continue;\n for (const [k, p] of Array.from(rec.presence.entries())) {\n if (now - p.lastSeen > 60_000) rec.presence.delete(k);\n }\n }\n}, 30_000);\n\n/* Validation helpers */\nfunction safeJsonParse(s: unknown) {\n try {\n return typeof s === \"string\" ? JSON.parse(s) : s;\n } catch {\n return null;\n }\n}\n\n/* REST API Server */\nserve(async (req) => {\n const url = new URL(req.url);\n\n if (req.method === \"OPTIONS\") {\n return new Response(null, { headers: CORS_HEADERS });\n }\n\n try {\n // Root info\n if (url.pathname === \"/\" && req.method === \"GET\") {\n const html = `\n\nEnhanced Multiplayer Hub\n\n

🎮 Enhanced Multiplayer Hub

Val Town compatible multiplayer coordination server with:

✅ Server registration & discovery
✅ Binary block storage (chunked, compressed)
✅ Real-time presence & chat
✅ Profanity filtering

Endpoints:

POST /register - Register a new server
GET /server/{id} - Get server metadata
GET /server/{id}/chat - Get recent chat
POST /server/{id}/blocks?chunkIndex=N&totalChunks=M - Upload blocks
WebSocket /ws - Real-time communication

Enhanced multiplayer hub running on Deno

\n\n`;\n return new Response(html, {\n headers: {\n ...CORS_HEADERS,\n \"content-type\": \"text/html; charset=utf-8\",\n },\n });\n }\n\n // Register server\n if (url.pathname === \"/register\" && req.method === \"POST\") {\n const body = await req.text().catch(() => \"{}\");\n const data = safeJsonParse(body) as Record | null;\n if (!data) {\n return new Response(\"invalid json\", {\n status: 400,\n headers: CORS_HEADERS,\n });\n }\n\n const id = v4.generate().slice(0, 12);\n const rec: ServerRecord = {\n id,\n name: typeof data.name === \"string\"\n ? data.name.slice(0, 80)\n : `Server-${id.slice(0, 6)}`,\n seed: typeof data.seed === \"string\"\n ? data.seed\n : Math.random().toString(36).slice(2),\n motd: typeof data.motd === \"string\"\n ? data.motd.slice(0, 140)\n : \"A Multiplayer Server\",\n iconUrl: typeof data.iconUrl === \"string\" ? data.iconUrl : null,\n adminPassword: typeof data.adminPassword === \"string\"\n ? data.adminPassword\n : null,\n created_at: new Date().toISOString(),\n blocksChunks: new Map(),\n blocksBinary: null,\n blocksTotalBytes: 0,\n presence: new Map(),\n chatLog: [],\n wsClients: new Set(),\n };\n registry.set(id, rec);\n\n const {\n wsClients,\n blocksChunks,\n blocksBinary,\n presence,\n chatLog,\n ...publicRec\n } = rec;\n return new Response(JSON.stringify(publicRec), {\n headers: { ...CORS_HEADERS, \"content-type\": \"application/json\" },\n });\n }\n\n // Get server metadata\n const serverMatch = url.pathname.match(/^\\/server\\/([^\\/]+)$/);\n if (serverMatch && req.method === \"GET\") {\n const id = serverMatch[1];\n const rec = registry.get(id);\n if (!rec) {\n return new Response(\"Not found\", {\n status: 404,\n headers: CORS_HEADERS,\n });\n }\n const {\n wsClients,\n blocksChunks,\n blocksBinary,\n presence,\n chatLog,\n ...publicRec\n } = rec;\n return new Response(JSON.stringify(publicRec), {\n headers: { ...CORS_HEADERS, \"content-type\": \"application/json\" },\n });\n }\n\n // Get chat history\n const chatMatch = url.pathname.match(/^\\/server\\/([^\\/]+)\\/chat$/);\n if (chatMatch && req.method === \"GET\") {\n const id = chatMatch[1];\n const rec = registry.get(id);\n if (!rec) {\n return new Response(\"Not found\", {\n status: 404,\n headers: CORS_HEADERS,\n });\n }\n const now = Date.now();\n rec.chatLog = (rec.chatLog || []).filter((c) =>\n now - c.created_at <= CHAT_RETENTION_MS\n );\n return new Response(JSON.stringify({ chat: rec.chatLog || [] }), {\n headers: { ...CORS_HEADERS, \"content-type\": \"application/json\" },\n });\n }\n\n // Upload blocks (chunked)\n const blocksMatch = url.pathname.match(/^\\/server\\/([^\\/]+)\\/blocks$/);\n if (blocksMatch && req.method === \"POST\") {\n const id = blocksMatch[1];\n const rec = registry.get(id);\n if (!rec) {\n return new Response(\"Server not found\", {\n status: 404,\n headers: CORS_HEADERS,\n });\n }\n\n const params = url.searchParams;\n const chunkIndex = Number(params.get(\"chunkIndex\") ?? \"-1\");\n const totalChunks = Number(params.get(\"totalChunks\") ?? \"-1\");\n const uncompressedBytes = Number(params.get(\"uncompressedBytes\") ?? \"0\");\n\n if (chunkIndex < 0 || totalChunks <= 0 || uncompressedBytes <= 0) {\n return new Response(\"Missing or invalid chunk parameters\", {\n status: 400,\n headers: CORS_HEADERS,\n });\n }\n\n const chunk = new Uint8Array(await req.arrayBuffer());\n if (chunk.length === 0 || chunk.length > MAX_CHUNK_BYTES) {\n return new Response(\"Invalid chunk size\", {\n status: 400,\n headers: CORS_HEADERS,\n });\n }\n\n // Store compressed\n const compressed = await gzipEncode(chunk);\n rec.blocksChunks = rec.blocksChunks || new Map();\n rec.blocksChunks.set(chunkIndex, compressed);\n rec.blocksTotalBytes = uncompressedBytes;\n\n // Check if complete\n if (rec.blocksChunks.size === totalChunks) {\n const totalCompressed = Array.from(rec.blocksChunks.values())\n .reduce((sum, c) => sum + c.byteLength, 0);\n\n if ((rec.blocksTotalBytes || 0) > MAX_TOTAL_STORED) {\n rec.blocksChunks.clear();\n return new Response(\"Total size exceeds limit\", {\n status: 413,\n headers: CORS_HEADERS,\n });\n }\n\n // Notify room\n const room = wsRooms.get(id);\n if (room) {\n const notice = JSON.stringify({\n type: \"blocks:updated\",\n serverId: id,\n totalChunks,\n totalCompressed,\n });\n room.forEach((s) => {\n try {\n s.send(notice);\n } catch {}\n });\n }\n }\n\n return new Response(\n JSON.stringify({ ok: true, storedChunk: chunkIndex }),\n {\n headers: { ...CORS_HEADERS, \"content-type\": \"application/json\" },\n },\n );\n }\n\n // WebSocket endpoint (condensed for brevity - same as enhanced version)\n if (url.pathname === \"/ws\") {\n if (req.headers.get(\"upgrade\") !== \"websocket\") {\n return new Response(\"WebSocket upgrade required\", {\n status: 400,\n headers: CORS_HEADERS,\n });\n }\n\n const { socket, response } = Deno.upgradeWebSocket(req);\n\n socket.onopen = () => {\n socket.send(\n JSON.stringify({\n type: \"welcome\",\n message: \"Connected to enhanced multiplayer hub\",\n }),\n );\n };\n\n const rateState = { lastMsgTs: 0, count: 0 };\n\n socket.onmessage = async (e) => {\n let msg;\n try {\n msg = typeof e.data === \"string\" ? JSON.parse(e.data) : null;\n if (!msg || typeof msg.type !== \"string\") throw new Error();\n } catch {\n socket.send(\n JSON.stringify({ type: \"error\", message: \"invalid_json\" }),\n );\n return;\n }\n\n // Rate limiting\n const now = Date.now();\n if (now - rateState.lastMsgTs > 5000) {\n rateState.count = 0;\n rateState.lastMsgTs = now;\n }\n rateState.count++;\n if (rateState.count > 40) {\n socket.close(1008, \"rate limit exceeded\");\n return;\n }\n\n try {\n switch (msg.type) {\n case \"chat\": {\n const id = msg.serverId || (socket as any).__serverRoom;\n if (!id) break;\n const rec = registry.get(id);\n if (!rec) break;\n\n const raw = typeof msg.message === \"string\"\n ? msg.message.slice(0, 512)\n : \"\";\n const censored = censorMessage(raw);\n const entry: ChatEntry = {\n id: v4.generate(),\n username: msg.username || (socket as any).__username ||\n \"Anonymous\",\n message: censored,\n created_at: Date.now(),\n };\n\n rec.chatLog = rec.chatLog || [];\n rec.chatLog.push(entry);\n rec.chatLog = rec.chatLog.filter((c) =>\n Date.now() - c.created_at <= CHAT_RETENTION_MS\n );\n\n const payload = JSON.stringify({\n type: \"chat\",\n serverId: id,\n comment: entry,\n });\n const set = wsRooms.get(id);\n if (set) {\n set.forEach((s) => {\n try {\n s.send(payload);\n } catch {}\n });\n }\n break;\n }\n\n // Handle other message types (announce, info, join, presence)\n // ... (same as previous implementation)\n\n default:\n socket.send(\n JSON.stringify({ type: \"error\", message: \"unknown_type\" }),\n );\n }\n } catch (err) {\n console.error(\"WebSocket handler error:\", err);\n socket.send(\n JSON.stringify({ type: \"error\", message: \"server_error\" }),\n );\n }\n };\n\n socket.onclose = () => {\n const roomId = (socket as any).__serverRoom;\n if (roomId) {\n const set = wsRooms.get(roomId);\n if (set) {\n set.delete(socket);\n const leaveMsg = JSON.stringify({\n type: \"peer:left\",\n serverId: roomId,\n username: (socket as any).__username,\n });\n set.forEach((s) => {\n try {\n s.send(leaveMsg);\n } catch {}\n });\n }\n }\n };\n\n return response;\n }\n\n return new Response(\"Not found\", { status: 404, headers: CORS_HEADERS });\n } catch (err) {\n console.error(\"Request error:\", err);\n return new Response(\"Internal Server Error\", {\n status: 500,\n headers: CORS_HEADERS,\n });\n }\n}, { port: PORT });","deleted",false,"label",[35],{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":59,"_18":60},["D",1781056768039],"children",[],[35],"73c345c1-ba81-4c33-b804-a51f031479f4",["D",1781056704773],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","019b447b-e60e-77bd-b753-1c0cdb67ff16","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019b447b-e60e-77bd-b753-21e0330aa12c","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_114":110},"org",{"_11":12,"_108":-5,"_109":110,"_70":71,"_111":112,"_113":53},"branch",{"_17":42,"_13":16,"_33":40,"_100":61,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":14,"_107":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zN0JkaU41Zkd2UUpQM1JNUG9SeE9DNzVXcXIifQ","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":61,"_13":14,"_45":147,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":19,"_69":-5,"_70":71,"_72":-5,"_73":53,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":-5,"_81":-5,"_82":-5,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":148,"_95":149,"_97":150,"_99":53},[144],"files",[144],"counts",{"_135":77,"_136":47,"_137":77,"_31":138,"_139":140},[133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":134},[35],"pulls","branches","forks",{"_141":77,"_143":77},"connections",{"_141":77,"_142":77},"count","unfilledCount","emptyCount",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":145,"_18":146},[],[35],["D",1781056704773],{"_11":12,"_114":110},{"_11":12,"_108":-5,"_109":110,"_70":71,"_111":112,"_113":53},{"_17":42,"_13":16,"_33":40,"_100":61,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":14,"_107":12},"ctx",{"_93":-5,"_130":184,"_185":186,"_187":188,"_189":53,"_190":53,"_191":53,"_192":44,"_193":-5,"_194":-7,"_195":-7,"_196":77,"_197":53,"_198":53,"_199":-5,"_200":53,"_201":53,"_202":53,"_203":-5},"ENV",{"_155":156,"_157":158,"_159":16,"_160":161,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Code