robot/HausApp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: temporarily disable WebSocket server to unblock deployment

Browse Source 
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
René Schober
2026-03-20 12:42:19 +01:00
parent bba33d0f00
commit 1e10b980c2
1 changed files with 35 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

70
apps/server/src/index.ts
View File

@@ -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;