ROS2:Basic:CloudflareArchitecture

// Durable Object: Agent 1개당 1개 인스턴스
export class AgentSession extends DurableObject {
  // Edge Agent WebSocket (1개)
  private agentSocket: WebSocket | null = null;
  // 브라우저 WebSocket (N개 - 대시보드 보는 사용자들)
  private viewers: Set<WebSocket> = new Set();

  async fetch(request: Request) {
    const url = new URL(request.url);

    if (url.pathname === '/connect-agent') {
      // Edge Agent가 연결
      const [client, server] = Object.values(new WebSocketPair());
      this.agentSocket = server;
      server.accept();
      server.addEventListener('message', (e) => {
        // 텔레메트리를 모든 viewer에 브로드캐스트
        for (const viewer of this.viewers) {
          viewer.send(e.data);
        }
        // 필요시 storage에 저장
      });
      return new Response(null, { status: 101, webSocket: client });
    }

    if (url.pathname === '/connect-viewer') {
      // 브라우저 대시보드가 연결
      const [client, server] = Object.values(new WebSocketPair());
      this.viewers.add(server);
      server.accept();
      server.addEventListener('message', (e) => {
        // 브라우저→Agent 명령 전달
        this.agentSocket?.send(e.data);
      });
      server.addEventListener('close', () => this.viewers.delete(server));
      return new Response(null, { status: 101, webSocket: client });
    }

    // REST: 명령 전송, 상태 조회 등
    if (url.pathname === '/command') {
      const cmd = await request.json();
      this.agentSocket?.send(JSON.stringify(cmd));
      // 명령 추적을 위해 storage에 저장
      await this.ctx.storage.put(`cmd:${cmd.id}`, cmd);
      return Response.json({ status: 'sent' });
    }
  }
}