Method constructor

src/api/websocket.ts:35–66

(private options: WebSocketStreamOptions<Req, Res>)

  constructor(private options: WebSocketStreamOptions<Req, Res>) {
    const baseUrl = serverConnectUrl(options.config.url).replace(/^http/, "ws");
    let socket: WebSocket;
    try {
      socket = new WebSocket(`${baseUrl}/${options.service}/${options.method}`, [
        "grpc-websockets",
      ]);
    } catch (error) {
      queueMicrotask(() => this.end(null, String(error)));
      return;
    }
    this.socket = socket;
    socket.binaryType = "arraybuffer";
    socket.onopen = () => {
      let headers = `content-type: application/grpc-web+proto\r\nx-grpc-web: 1\r\naccept-language: ${options.language}\r\n`;
      if (options.config.secret) {
        headers += `authorization: Bearer ${options.config.secret}\r\n`;
      }
      socket.send(new TextEncoder().encode(headers));
      this.opened = true;
      for (const pending of this.pendingSends) {
        socket.send(pending);
      }
      this.pendingSends = [];
    };
    socket.onmessage = (event) => {
      this.receive(new Uint8Array(event.data as ArrayBuffer));
    };
    socket.onerror = () => {
      this.end(null, "websocket connection failed");
    };
    socket.onclose = (event) => {
      if (this.status) {
        this.end(this.status);
      } else {
        this.end(null, event.reason || "websocket closed unexpectedly");