Installation

import { createChat } from '@klastra/ksync';

// Optimized for chat with presence
const chat = createChat('room-name', {
  serverUrl: 'ws://localhost:8080'
});

await chat.setPresence({ 
  status: 'online', 
  metadata: { name: 'Alice' } 
});

import { createGame } from '@klastra/ksync';

// Optimized for low-latency gaming
const game = createGame('game-id', {
  performance: { batchDelay: 5 }
});

await game.send('player-move', { x: 100, y: 200 });

import { createAI } from '@klastra/ksync';

// Optimized for AI streaming
const ai = createAI('assistant', {
  features: { streaming: true }
});

ai.on('stream-chunk', (data) => {
  process.stdout.write(data.data);
});

import { createTodos } from '@klastra/ksync';

// Optimized for task management
const todos = createTodos({
  offline: { persistence: true }
});

await todos.send('todo-created', {
  id: 'todo-1',
  title: 'Learn kSync v0.2'
});

import { WebSocketServer } from 'ws';

const wss = new WebSocketServer({ port: 8080 });
console.log('🚀 kSync server running on ws://localhost:8080');

wss.on('connection', (ws) => {
  console.log('📱 Client connected');

  ws.on('message', (data) => {
    // Broadcast to all other clients
    wss.clients.forEach((client) => {
      if (client !== ws && client.readyState === 1) {
        client.send(data);
      }
    });
  });
});

// Ultra-fast Bun WebSocket server
const server = Bun.serve({
  port: 8080,
  fetch(req, server) {
    if (server.upgrade(req)) return;
    return new Response("Upgrade failed", { status: 500 });
  },
  websocket: {
    message(ws, message) {
      ws.publish("global", message); // Broadcast
    },
    open(ws) {
      ws.subscribe("global");
      console.log("📱 Client connected");
    },
  },
});

console.log(`🚀 kSync server on ws://localhost:${server.port}`);

import { WebSocketServer } from 'ws';
import { createServer } from 'http';

const server = createServer();
const wss = new WebSocketServer({ server });

// Room-based routing
const rooms = new Map();

wss.on('connection', (ws, request) => {
  let currentRoom = null;
  
  ws.on('message', (data) => {
    try {
      const message = JSON.parse(data.toString());
      
      // Handle room joining
      if (message.type === 'join-room') {
        currentRoom = message.room;
        if (!rooms.has(currentRoom)) {
          rooms.set(currentRoom, new Set());
        }
        rooms.get(currentRoom).add(ws);
        return;
      }
      
      // Broadcast to room
      if (currentRoom && rooms.has(currentRoom)) {
        rooms.get(currentRoom).forEach(client => {
          if (client !== ws && client.readyState === 1) {
            client.send(data);
          }
        });
      }
    } catch (error) {
      console.error('Message error:', error);
    }
  });
  
  ws.on('close', () => {
    if (currentRoom && rooms.has(currentRoom)) {
      rooms.get(currentRoom).delete(ws);
    }
  });
});

server.listen(8080, () => {
  console.log('🚀 Production kSync server on port 8080');
});