Method start

tests/mcp/server.test.js:25–58

()

  }

  start() {
    return new Promise((resolve, reject) => {
      this.proc = spawn(VIBIUM, ['mcp'], {
        stdio: ['pipe', 'pipe', 'pipe'],
      });

      this.proc.stdout.on('data', (data) => {
        this.buffer += data.toString();
        // Process complete JSON lines
        const lines = this.buffer.split('\n');
        this.buffer = lines.pop(); // Keep incomplete line in buffer
        for (const line of lines) {
          if (line.trim()) {
            try {
              const response = JSON.parse(line);
              if (this.resolvers.length > 0) {
                const resolver = this.resolvers.shift();
                resolver(response);
              } else {
                this.responses.push(response);
              }
            } catch (e) {
              // Ignore parse errors for non-JSON output
            }
          }
        }
      });

      this.proc.on('error', reject);

      // Give process a moment to start
      setTimeout(resolve, 100);
    });
  }

  send(method, params = {}, id = null) {
    const msg = {