From 1e10b980c24a91f1cb3613fb701b4af8d912738a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ren=C3=A9=20Schober?= Date: Fri, 20 Mar 2026 12:42:19 +0100 Subject: [PATCH] fix: temporarily disable WebSocket server to unblock deployment Co-Authored-By: Claude Sonnet 4.6 --- apps/server/src/index.ts | 70 ++++++++++++++++++++-------------------- 1 file changed, 35 insertions(+), 35 deletions(-) diff --git a/apps/server/src/index.ts b/apps/server/src/index.ts index 9207700..554bceb 100644 --- a/apps/server/src/index.ts +++ b/apps/server/src/index.ts @@ -3,9 +3,9 @@ import { Hono } from "hono"; import { cors } from "hono/cors"; import { logger } from "hono/logger"; import { registerRoutes } from "./routes"; -import { shoppingWsHandlers } from "./ws/shopping-ws"; -import { db, eq } from "@haushaltsApp/db"; -import { session as sessionTable } from "@haushaltsApp/db/schema"; +// import { shoppingWsHandlers } from "./ws/shopping-ws"; +// import { db, eq } from "@haushaltsApp/db"; +// import { session as sessionTable } from "@haushaltsApp/db/schema"; const app = new Hono(); @@ -24,43 +24,43 @@ registerRoutes(app); // When running under Bun directly (not imported as a module for tests), // start Bun.serve with WebSocket support. -if (typeof Bun !== "undefined" && !process.env.BUN_TEST) { - Bun.serve({ - port: Number(process.env.PORT ?? 3000), - hostname: "0.0.0.0", - websocket: shoppingWsHandlers, - async fetch(req: Request, server) { - const url = new URL(req.url); - if (url.pathname === "/api/shopping-lists/ws") { - const token = url.searchParams.get("token") ?? ""; - const householdId = url.searchParams.get("householdId") ?? ""; +// if (typeof Bun !== "undefined" && !process.env.BUN_TEST) { +// Bun.serve({ +// port: Number(process.env.PORT ?? 3000), +// hostname: "0.0.0.0", +// websocket: shoppingWsHandlers, +// async fetch(req: Request, server) { +// const url = new URL(req.url); +// if (url.pathname === "/api/shopping-lists/ws") { +// const token = url.searchParams.get("token") ?? ""; +// const householdId = url.searchParams.get("householdId") ?? ""; - if (!householdId) { - return new Response("Missing householdId", { status: 400 }); - } +// if (!householdId) { +// return new Response("Missing householdId", { status: 400 }); +// } - const rawToken = token.includes(".") ? token.split(".")[0] : token; - if (!rawToken) return new Response("Unauthorized", { status: 401 }); +// const rawToken = token.includes(".") ? token.split(".")[0] : token; +// if (!rawToken) return new Response("Unauthorized", { status: 401 }); - const sessionRow = await db.query.session.findFirst({ - where: eq(sessionTable.token, rawToken), - with: { user: true }, - }); +// const sessionRow = await db.query.session.findFirst({ +// where: eq(sessionTable.token, rawToken), +// with: { user: true }, +// }); - if (!sessionRow?.user || sessionRow.expiresAt < new Date()) { - return new Response("Unauthorized", { status: 401 }); - } +// if (!sessionRow?.user || sessionRow.expiresAt < new Date()) { +// return new Response("Unauthorized", { status: 401 }); +// } - const upgraded = server.upgrade(req, { - data: { householdId, userId: sessionRow.user.id }, - }); - if (upgraded) return undefined as unknown as Response; - return new Response("WebSocket upgrade failed", { status: 400 }); - } +// const upgraded = server.upgrade(req, { +// data: { householdId, userId: sessionRow.user.id }, +// }); +// if (upgraded) return undefined as unknown as Response; +// return new Response("WebSocket upgrade failed", { status: 400 }); +// } - return app.fetch(req); - }, - }); -} +// return app.fetch(req); +// }, +// }); +// } export default app;