Function createClient

npm_modules/cli/test/helpers/TypeScriptClient.ts:12–74

(workingDir: string)

}

export function createClient(workingDir: string): TSServerClient {
  const reserveSequence = createNonceService();
  const read = createMessageBuffer();

  // eslint-disable-next-line unicorn/prefer-event-target
  const queue = new EventEmitter<{
    response: [Record<string, unknown>];
    message: [Record<string, unknown>];
  }>();

  const service = run('npx', ['tsserver'], {cwd: workingDir});

  service.process.stdout?.on('data', (chunk: Buffer) => {
    for (const [message] of read(chunk)) {
      if ('type' in message && message['type'] === 'response') {
        queue.emit('response', message);
      }
      queue.emit('message', message);
    }
  });

  service.process.stderr?.pipe(process.stderr)

  const send = (
    request: Record<string, unknown>,
    { timeout = 300000 }: { timeout?: number } = {},
  ): Promise<Record<string, unknown>> => {
    const seq = reserveSequence();
    const body = JSON.stringify({
      seq,
      ...request,
    });
    const payload = body + '\r\n';
    service.process.stdin.write(payload);

    return withTimeout(
      new Promise(resolve => {
        const listener = (message: Record<string, unknown>) => {
          if ('request_seq' in message && message['request_seq'] !== seq) {
            return;
          }
          queue.removeListener('response', listener);
          resolve(message);
        };
        queue.addListener('response', listener);
      }),
      timeout,
    );
  };

  return {
    command: (command: string, args?: Record<string, unknown>) =>
      send({
        command,
        ...(args ? { arguments: args } : null),
      }),
    disconnect: () => {
      service.process.stdin.end();