view seobeo/examples/websocket_server_example.c @ 279:b3b547563ec7

Add Google connector service and agent wiki Implement the C/Seobeo Google Drive and Gmail connector with encrypted OAuth storage, Zenbu authentication, browser testing, AI tool discovery, chunked HTTP decoding, and Bazel coverage. Consolidate repository guidance into progressive wiki documentation and enforce arena-first allocation for new first-party C code. Co-authored-by: Copilot <[email protected]> Copilot-Session: 84c338fd-0939-4bb3-b7f3-1062eb213e5d
author MrJuneJune <me@mrjunejune.com>
date Mon, 17 Aug 2026 22:22:36 -0700
parents 7eb79fd91c7e
children
line wrap: on
line source

#include "seobeo/seobeo.h"
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

void Echo_Handler(Seobeo_WebSocket_Server_Connection *p_conn, Seobeo_WebSocket_Message *p_msg, void *p_user_data)
{
  (void)p_user_data;

  if (p_msg->opcode == SEOBEO_WS_OPCODE_TEXT)
  {
    printf("[Echo] Received text: %.*s\n", (int)p_msg->length, (char*)p_msg->data);
    Seobeo_WebSocket_Server_Send_Text(p_conn, (char*)p_msg->data);
  }
  else if (p_msg->opcode == SEOBEO_WS_OPCODE_BINARY)
  {
    printf("[Echo] Received %zu bytes of binary data\n", p_msg->length);
    Seobeo_WebSocket_Server_Send_Binary(p_conn, p_msg->data, p_msg->length);
  }
}

void Chat_Handler(Seobeo_WebSocket_Server_Connection *p_conn, Seobeo_WebSocket_Message *p_msg, void *p_user_data)
{
  (void)p_user_data;

  if (p_msg->opcode == SEOBEO_WS_OPCODE_TEXT)
  {
    char message[2048];
    snprintf(message, sizeof(message), "[%s]: %.*s", p_conn->client_id, (int)p_msg->length, (char*)p_msg->data);

    printf("[Chat] Broadcasting: %s\n", message);
    Seobeo_WebSocket_Server_Broadcast_Text(message, p_conn);
  }
}

void Binary_Handler(Seobeo_WebSocket_Server_Connection *p_conn, Seobeo_WebSocket_Message *p_msg, void *p_user_data)
{
  (void)p_user_data;
  (void)p_conn;

  if (p_msg->opcode == SEOBEO_WS_OPCODE_BINARY)
  {
    printf("[Binary] Received %zu bytes, broadcasting to all clients\n", p_msg->length);
    Seobeo_WebSocket_Server_Broadcast_Binary(p_msg->data, p_msg->length);
  }
}

int main()
{
  printf("=== Seobeo WebSocket Server Example ===\n\n");

  Seobeo_WebSocket_Server_Init();

  Seobeo_WebSocket_Server_Register("/echo", Echo_Handler, NULL);
  printf("Registered /echo endpoint\n");

  Seobeo_WebSocket_Server_Register("/chat", Chat_Handler, NULL);
  printf("Registered /chat endpoint\n");

  Seobeo_WebSocket_Server_Register("/binary", Binary_Handler, NULL);
  printf("Registered /binary endpoint\n");

  printf("\nStarting server on port 8080...\n");
  printf("\nTest with:\n");
  printf("  ws://localhost:8080/echo   - Echo server\n");
  printf("  ws://localhost:8080/chat   - Chat room\n");
  printf("  ws://localhost:8080/binary - Binary data broadcast\n");
  printf("\n");

  Seobeo_Web_Server_Start(NULL, "8080", SEOBEO_MODE_FORK, 0);

  return 0;
}