SSE

#include "sse/sse.h"
#include "util/allocator.h"  /* _memcpy, _memset */
#include "util/string.h"     /* _itoa, _strnlen  */

static bool on_event(SSEEvent* event, void* user_data)
{
  /* Fill in the event fields — return true to broadcast, false to skip */
  _memcpy(event->data, "hello", 5);
  _memcpy(event->event_type, "greeting", 8);
  return true;
}

int main(void)
{
  SSEServerConfig config = {
    .port              = 8080,
    .backlog           = 128,
    .event_interval_ms = 2000  /* call on_event every 2 seconds */
  };

  SSEServer server;
  sse_server_init(&server, &config);
  sse_server_on_event(&server, on_event, NULL);
  sse_server_run(&server);     /* blocks until SIGINT/SIGTERM */
  sse_server_cleanup(&server);
  return 0;
}

typedef struct {
  uint16_t port;              /* TCP port to listen on */
  int32_t  backlog;           /* listen() backlog (0 defaults to 128) */
  int32_t  event_interval_ms; /* epoll timeout / event callback interval */
  char     cors_origin[256];  /* CORS origin ("*", "https://...", or "" to disable) */
} SSEServerConfig;

typedef struct {
  char    data[4096];        /* Event payload (required for broadcast) */
  char    event_type[64];    /* Event type name (optional, "message" if empty) */
  char    id[64];            /* Event ID for Last-Event-ID (optional) */
  int32_t retry_ms;          /* Reconnection interval hint (optional, -1 = unset) */
} SSEEvent;

#include "sse/sse.h"
#include "util/allocator.h"
#include "util/string.h"

typedef struct {
  uint32_t counter;
  uint32_t clients;
} AppState;

static bool on_tick(SSEEvent* event, void* user_data)
{
  AppState* state = (AppState*)user_data;
  state->counter++;

  char buf[16];
  _memset(buf, 0, sizeof(buf));
  _itoa(state->counter, buf, sizeof(buf));

  size_t len = _strnlen(buf, sizeof(buf));
  _memcpy(event->data, "count:", 6);
  _memcpy(event->data + 6, buf, len);
  _memcpy(event->event_type, "tick", 4);
  _memcpy(event->id, buf, len);

  return true;
}

static void on_connect(int32_t fd, void* user_data)
{
  AppState* state = (AppState*)user_data;
  state->clients++;
}

static void on_disconnect(int32_t fd, void* user_data)
{
  AppState* state = (AppState*)user_data;
  state->clients--;
}

int main(void)
{
  SSEServerConfig config = {
    .port              = 8080,
    .backlog           = 128,
    .event_interval_ms = 2000
  };

  SSEServer server;
  static AppState state = {0, 0};

  sse_server_init(&server, &config);
  sse_server_on_event(&server, on_tick, &state);
  sse_server_on_connect(&server, on_connect);
  sse_server_on_disconnect(&server, on_disconnect);
  sse_server_run(&server);
  sse_server_cleanup(&server);

  return 0;
}