Zero-Config Quickstart

1import http from "node:http";
1import { subatomPulse } from "subatom-pulse";
1 
1const httpServer = http.createServer((req, res) => {
1  if (req.url === "/health") {
1    res.writeHead(200, { "content-type": "application/json" });
1    res.end(JSON.stringify({ status: "healthy", timestamp: Date.now() }));
1    return;
1  }
1  res.writeHead(404);
1  res.end();
1});
2 
1// Attach subatom-pulse directly to HTTP server upgrade pipeline
1const io = subatomPulse({
1  server: httpServer,
1  path: "/ws",
1  maxConnections: 10_000,
1  rateLimitPerSec: 50,
1  overflowPolicy: "drop-oldest",
1  authenticator: async (req) => {
1    const url = new URL(req.url ?? "/", `http://${req.headers.host}`);
1    const token = url.searchParams.get("token");
1    const userId = url.searchParams.get("user") ?? "guest";
3 
1    if (!token || token !== "Bearer secret-app-token") {
1      return { authenticated: false };
1    }
1    return { authenticated: true, userId, metadata: { userId, role: "member" } };
2  }
2});
4 
1io.onConnection((socket) => {
1  console.log(`[Connection Opened] ID: ${socket.id} for User: ${socket.metadata.userId}`);
5 
1  // Greet new connection
1  socket.emit("system.welcome", { id: socket.id, time: Date.now() });
3});
6 
1// Idempotent SIGTERM/SIGINT teardown orchestration
1io.installSignalHandlers();
1httpServer.listen(3000, () => console.log("Server active on :3000"));

1import { SubAtomPulse } from "subatom-pulse";
1 
1// Note: If running inside Node.js, inject native WebSocket into globalThis:
1// import { WebSocket } from "ws"; globalThis.WebSocket = WebSocket as any;
2 
1const socket = new SubAtomPulse("ws://localhost:3000/ws", {
1  auth: { token: "Bearer secret-app-token" },
1  reconnect: true,
1  reconnectAttempts: 10,
1  reconnectDelayMs: 1500,
1  autoConnect: true
1});
3 
1socket.on("connect", () => {
1  console.log("[WS Connected] Active state:", socket.state);
2});
4 
1socket.on("system.welcome", (data) => {
1  console.log("Handshake confirmation:", data);
3});
5 
1socket.on("error", (err) => {
1  console.error("Socket Protocol Error:", err);
4});