Deno application with just a Websocket connection gives 504 in Prod Deno Deploy

import "@std/dotenv/load";

import { createClient } from "@supabase/supabase-js";
import { useWebSocket } from "@effection-contrib/websocket";
import { each, main } from "@effection/effection";
import { generate } from "@babia/uuid-v7";

const supabase = createClient(
  Deno.env.get("SUPABASE_URL")!,
  Deno.env.get("SUPABASE_ANON_KEY")!,
);

async function insertToSupabase(aggregate: Schema) {
  try {
    const { error } = await supabase
      .from("test_table")
      .insert({
        id: generate(),
        created_at: new Date().toISOString(),
        ...aggregate,
      });

    if (error) throw error;
    console.log("Data inserted successfully");
  } catch (error) {
    console.error("Error inserting data:", error);
  }
}

await main(function* () {
  const socket = yield* useWebSocket(Deno.env.get("WEBSOCKET_CLUSTER_URL")!);

  socket.send(JSON.stringify({
    action: "auth",
    params: Deno.env.get("WEBSOCKET_API_KEY"),
  }));

  for (const message of yield* each(socket)) {
    const wsMessage = message as WebSocketMessageEvent;
    const [data] = JSON.parse(wsMessage.data);

    if (data.message === "authenticated") {
      socket.send(
        JSON.stringify({ "action": "subscribe", "params": "A.AAPL" }),
      );
    }

    if (data.sym) {
      const wsData = data as Aggregate;
      insertToSupabase({
        ticker: wsData.sym,
        open: wsData.o,
        close: wsData.c,
        high: wsData.h,
        low: wsData.l,
        vwap: wsData.vw,
        aggregate_start_time: wsData.s,
        aggregate_end_time: wsData.e,
        aggregate_type: wsData.ev,
      });
    }

    yield* each.next();
  }
});

import "@std/dotenv/load";

import { createClient } from "@supabase/supabase-js";
import { useWebSocket } from "@effection-contrib/websocket";
import { each, main } from "@effection/effection";
import { generate } from "@babia/uuid-v7";

const supabase = createClient(
  Deno.env.get("SUPABASE_URL")!,
  Deno.env.get("SUPABASE_ANON_KEY")!,
);

async function insertToSupabase(aggregate: Schema) {
  try {
    const { error } = await supabase
      .from("test_table")
      .insert({
        id: generate(),
        created_at: new Date().toISOString(),
        ...aggregate,
      });

    if (error) throw error;
    console.log("Data inserted successfully");
  } catch (error) {
    console.error("Error inserting data:", error);
  }
}

await main(function* () {
  const socket = yield* useWebSocket(Deno.env.get("WEBSOCKET_CLUSTER_URL")!);

  socket.send(JSON.stringify({
    action: "auth",
    params: Deno.env.get("WEBSOCKET_API_KEY"),
  }));

  for (const message of yield* each(socket)) {
    const wsMessage = message as WebSocketMessageEvent;
    const [data] = JSON.parse(wsMessage.data);

    if (data.message === "authenticated") {
      socket.send(
        JSON.stringify({ "action": "subscribe", "params": "A.AAPL" }),
      );
    }

    if (data.sym) {
      const wsData = data as Aggregate;
      insertToSupabase({
        ticker: wsData.sym,
        open: wsData.o,
        close: wsData.c,
        high: wsData.h,
        low: wsData.l,
        vwap: wsData.vw,
        aggregate_start_time: wsData.s,
        aggregate_end_time: wsData.e,
        aggregate_type: wsData.ev,
      });
    }

    yield* each.next();
  }
});

By default, if the connection between the client and server closes, the connection is restarted.

By default, if the connection between the client and server closes, the connection is restarted.

Note: The comment line can be used to prevent connections from timing out; a server can send a comment periodically to keep the connection alive.

Note: The comment line can be used to prevent connections from timing out; a server can send a comment periodically to keep the connection alive.

async function* sse() {
  while (true) { // every minute you send a comment line
    await new Promise(r => setTimeout(r, 60000));
    yield ': comments are ignored by the client \n\n';
  }
}

router.get('/sse', contentType(['text/event-stream']), (req, { type }) => {
  return new StreamResponse(sse(), { headers: [['content-type', type]] })
})

async function* sse() {
  while (true) { // every minute you send a comment line
    await new Promise(r => setTimeout(r, 60000));
    yield ': comments are ignored by the client \n\n';
  }
}

router.get('/sse', contentType(['text/event-stream']), (req, { type }) => {
  return new StreamResponse(sse(), { headers: [['content-type', type]] })
})