Compare commits

..

1 Commits

+43 -31
View File
@@ -21,13 +21,50 @@ import cuid from "cuid";
// Setup global event debugger in non-production environments // Setup global event debugger in non-production environments
if (Bun.env.NODE_ENV == "development") setupEventDebugger(); if (Bun.env.NODE_ENV == "development") setupEventDebugger();
// Ensure administrator role exists // Helper to run a startup sync safely — failures are logged but never crash the process.
const existingAdmin = await prisma.role.findFirst({ const safeStartup = async (label: string, fn: () => Promise<void>) => {
where: { moniker: "administrator" }, try {
include: { users: { include: { roles: true } } }, await fn();
} catch (err) {
console.error(
`[startup] ${label} failed — will retry on next interval`,
err,
);
}
};
// ---------------------------------------------------------------------------
// Start the HTTP server FIRST so the pod is reachable immediately.
// All data-sync tasks run afterwards and are non-blocking.
// ---------------------------------------------------------------------------
Bun.serve({
port: PORT,
websocket: engine.handler().websocket,
fetch: (req, server) => {
const url = new URL(req.url);
if (url.pathname.startsWith("/socket.io/")) {
return engine.handleRequest(req, server as any);
}
return app.fetch(req, server);
},
}); });
if (!existingAdmin) { console.log(`[startup] Server listening on port ${PORT}`);
// ---------------------------------------------------------------------------
// Background initialisation — none of this blocks the server.
// ---------------------------------------------------------------------------
// Ensure administrator role exists
await safeStartup("ensureAdminRole", async () => {
const existingAdmin = await prisma.role.findFirst({
where: { moniker: "administrator" },
include: { users: { include: { roles: true } } },
});
if (!existingAdmin) {
const id = cuid(); const id = cuid();
const created = await prisma.role.create({ const created = await prisma.role.create({
data: { data: {
@@ -43,19 +80,8 @@ if (!existingAdmin) {
include: { users: { include: { roles: true } } }, include: { users: { include: { roles: true } } },
}); });
events.emit("role:created", new RoleController(created)); events.emit("role:created", new RoleController(created));
}
// Helper to run a startup sync safely — failures are logged but never crash the process.
const safeStartup = async (label: string, fn: () => Promise<void>) => {
try {
await fn();
} catch (err) {
console.error(
`[startup] ${label} failed — will retry on next interval`,
err,
);
} }
}; });
// Refresh the internal list of companies every minute // Refresh the internal list of companies every minute
await safeStartup("refreshCompanies", refreshCompanies); await safeStartup("refreshCompanies", refreshCompanies);
@@ -98,17 +124,3 @@ setInterval(() => {
.syncSites() .syncSites()
.catch((err) => console.error("[interval] syncSites failed", err)); .catch((err) => console.error("[interval] syncSites failed", err));
}, 60 * 1000); }, 60 * 1000);
Bun.serve({
port: PORT,
websocket: engine.handler().websocket,
fetch: (req, server) => {
const url = new URL(req.url);
if (url.pathname.startsWith("/socket.io/")) {
return engine.handleRequest(req, server as any);
}
return app.fetch(req, server);
},
});