Function helloAndSubscribe

packages/server/test/fs-watch.e2e.test.ts:210–224

(
  conn: Conn,
  clientId: string,
  sessionId: string,
)

}

async function helloAndSubscribe(
  conn: Conn,
  clientId: string,
  sessionId: string,
): Promise<void> {
  await receiveType(conn, 'server_hello', 1000);
  conn.ws.send(
    JSON.stringify({
      type: 'client_hello',
      id: `cli_${clientId}`,
      payload: { client_id: clientId, subscriptions: [sessionId] },
    }),
  );
  await receiveType(conn, 'ack', 1000);
}

const sleep = (ms: number): Promise<void> =>
  new Promise((r) => setTimeout(r, ms));