ci(global): go through and make sure all related files are working and good to go
This commit is contained in:
@@ -46,6 +46,8 @@ app.onError((err, ctx) => {
|
||||
|
||||
app.use("*", cors());
|
||||
|
||||
app.get("/healthz", (c) => c.json({ status: "ok" }));
|
||||
|
||||
app.notFound((c) => {
|
||||
const response = apiResponse.error(
|
||||
new GenericError({
|
||||
|
||||
+3
-2
@@ -37,7 +37,8 @@ export function ensureManagerSocketReady(): Promise<Socket> {
|
||||
return Promise.resolve(managerSocket);
|
||||
if (managerSocketReadyPromise) return managerSocketReadyPromise;
|
||||
|
||||
managerSocket = io("http://localhost:8671", {
|
||||
const managerUrl = process.env.MANAGER_SOCKET_URL ?? "http://localhost:8671";
|
||||
managerSocket = io(managerUrl, {
|
||||
reconnection: true,
|
||||
reconnectionDelay: 1000,
|
||||
reconnectionDelayMax: 5000,
|
||||
@@ -152,7 +153,7 @@ if (import.meta.main) {
|
||||
|
||||
console.log("[worker] Worker process starting...");
|
||||
console.log(
|
||||
"[worker] Connecting to PgBoss on DATABASE_URL and SocketIO on :8671"
|
||||
`[worker] Connecting to PgBoss on DATABASE_URL and SocketIO on ${process.env.MANAGER_SOCKET_URL ?? "http://localhost:8671"}`
|
||||
);
|
||||
|
||||
// Ensure PgBoss is connected and queues exist
|
||||
|
||||
Reference in New Issue
Block a user