Class WebAdapter

src/runtime/adapters/web.ts:79–553

// ---------------------------------------------------------------------------

export class WebAdapter implements PlatformAdapter {
  readonly name = "web";

  private wss: WebSocketServer | null = null;
  private agent: IPackAgent | null = null;
  private ipcBroadcaster: IpcBroadcaster | null = null;
  private conversationService: ConversationService | null = null;
  private socketsByChannel = new Map<string, Set<WebSocket>>();

  async start(ctx: AdapterContext): Promise<void> {
    const { agent, server, app, rootDir, lifecycle } = ctx;
    this.agent = agent;
    this.ipcBroadcaster = ctx.ipcBroadcaster ?? null;
    this.conversationService = new ConversationService(rootDir);

    // -- API key & provider (in-memory, can be overridden by frontend) ------

    const currentConf = configManager.getConfig();
    let apiKey = currentConf.apiKey || "";
    let currentProvider = currentConf.provider || "openai";

    // -- HTTP API routes ----------------------------------------------------

    app.get("/api/config", (_req, res) => {
      const config = getPackConfig(rootDir);
      const conf = configManager.getConfig();
      const currentProvider = conf.provider || "openai";
      const providerMeta = SUPPORTED_PROVIDERS[currentProvider];

      const oauthConnected = providerMeta?.authType === "oauth"
        ? agent.getAuthStorage().hasAuth(currentProvider)
        : false;

      res.json({
        name: config.name,
        description: config.description,
        prompts: config.prompts || [],
        skills: config.skills || [],
        hasApiKey: !!conf.apiKey,
        apiKey: conf.apiKey || "",
        provider: currentProvider,
        baseUrl: conf.baseUrl || "",
        modelId: conf.modelId || "",
        apiProtocol: conf.apiProtocol || "",
        adapters: conf.adapters || {},
        supportedProviders: SUPPORTED_PROVIDERS,
        oauthConnected,
      });
    });

    app.get("/api/skills", (_req, res) => {
      const config = getPackConfig(rootDir);
      res.json(config.skills || []);
    });

    app.post("/api/config/update", (req, res) => {
      const { key, provider, baseUrl, modelId, apiProtocol, adapters } = req.body;
      const updates: any = {};