How to consume data from a sse server in Nodejs?

Using Server-Sent Events (SSE) in Node.js enables the server to proactively send updates to the client. SSE is typically used for creating real-time notifications and updates without requiring the client to periodically poll the server. The following outlines the steps to use data from an SSE server in Node.js:

1. Setting Up the SSE Server

First, create a server in Node.js capable of sending events. Typically, this involves setting up an endpoint that handles HTTP requests and maintains an open connection to send events. Here's a simple example using Express.js:

javascript
const express = require('express');
const app = express();

app.get('/events', function(req, res) {
    // Set response headers to establish an SSE connection
    res.writeHead(200, {
        'Content-Type': 'text/event-stream',
        'Cache-Control': 'no-cache',
        'Connection': 'keep-alive'
    });

    // Send a simple event
    setInterval(() => {
        const date = new Date();
        res.write(`data: ${date.toISOString()}

`);
    }, 1000);

    // Handle connection closure
    req.on('close', () => {
        console.log('Client closed the connection');
    });
});

const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
    console.log(`SSE server running at http://localhost:${PORT}`);
});

2. Implementing SSE on the Client Side

On the client side, use the browser's EventSource interface to connect to your SSE endpoint. Here's how to connect and receive events using JavaScript:

javascript
const eventSource = new EventSource('/events');

eventSource.onmessage = function(event) {
    // Log data received from the server
    console.log('Data from server:', event.data);
};

eventSource.onerror = function(error) {
    // Handle error cases
    console.error('EventSource encountered an error:', error);
};

3. Handling Reconnection Logic

The EventSource interface automatically attempts reconnection when the connection is lost, but you can implement custom logic to control reconnection behavior:

javascript
eventSource.onopen = function() {
    console.log('Connection opened');
};

eventSource.onerror = function(error) {
    if (eventSource.readyState === EventSource.CLOSED) {
        console.log('Connection closed');
    } else {
        console.log('An error occurred; connection will attempt reconnection');
    }
};

4. Closing the Connection

To close the connection when no longer receiving events, call the close method:

javascript
eventSource.close();

This code provides a simplified example of an SSE application; in real-world scenarios, you may need to handle additional edge cases and optimizations, such as ensuring the server can manage high concurrency, handling various event types, and implementing more sophisticated reconnection strategies on the client side. In production environments, consider using HTTPS for encrypted connections and adding appropriate authentication and authorization mechanisms.