Server Sent Events Question

[dbrucknr]

I wanted to reach out to the Encore community and see if there was any support for Server Sent Events from an encore.ts backend?

I was trying to dig through the source code and came up with an approach like this:

export const test = api.raw(
  { method: "GET", path: "/test", expose: true },
  async (req, res) => {
    res.setHeader("Content-Type", "text/event-stream");
    res.setHeader("Cache-Control", "no-cache");
    res.setHeader("Connection", "keep-alive");
    res.flushHeaders();

    const sendEvent = () =>
      res.write(`data: ${JSON.stringify({ message: "Hello, client!" })}\n\n`);

    const interval = setInterval(sendEvent, 5000);

    req.on("close", () => {
      clearInterval(interval);
    });
  }
);

[marcuskohlberg]

Could you not use e.g. a cron job for this? https://encore.dev/docs/ts/primitives/cron-jobs

[dbrucknr]

Hey there Marcus,

Many thanks for the reply!

May I ask a bit more on how the cron-job might help me subscribe external services and clients to background tasks, jobs, and even requests for data to the encore backend?

There's a reasonable chance I've misunderstood the entire functionality of the cron job api in encore. If I may explain further, what I had wondered about with regards to Server Sent Events might be akin to encore's streaming endpoints.

I looked at the documentation here Streaming APIs

I think the streaming endpoints are close to what I had originally wanted to achieve, but I experienced some difficulty in getting one to work with the JavaScript EventSource API. Inferring from the docs, it looked like these endpoints provided a full duplex Websocket tunnel to transmit data between services.

The type of development task I was interested in achieving was with the simplex communication type provided by the Server Sent Events protocol. In my case I wanted my clients, scripts, and other codebases to subscribe to the encore.ts backend, which would then forward events captured in another service, like Redis / Memcache / Kafka / NATS / etc. through the subscription tunnel in real-time.

Let me know your thoughts, or if I've crossed wires / misunderstood anything.

Also, many thanks for encore - I'm very excited to see where the library goes!

[marcuskohlberg]

Hey, I probably inferred incorrectly what you were looking to do.
Cron jobs are primarily useful for scheduling recurring/periodic tasks. However, they don’t directly handle real-time events like you are looking for.

Regarding Streaming APIs, would the streamOut variety not be suitable for your use case? It is intended for streaming from server to client.