Method connect

typescript/src/Vaas.ts:297–384

Connect to VaaS * @throws {VaasAuthenticationError} Authentication failed. * @throws {VaasConnectionClosedError} Connection was closed. Call connect() to reconnect.

(token: string, url = VAAS_URL)

   * @throws {VaasConnectionClosedError} Connection was closed. Call connect() to reconnect.
   */
  public connect(token: string, url = VAAS_URL): Promise<void> {
    return new Promise((resolve, reject) => {
      const ws = this.webSocketFactory(url);
      this.connection = { ws: ws };
      this.closeEvent = undefined;
      this.authenticationError = undefined;
      this.pingTimeout = undefined;

      // ws library does not have auto-keepalive
      // https://github.com/websockets/ws/issues/767
      if (ws.on !== undefined) {
        ws.on("ping", (payload) => {
          ws.pong(payload);
        });
        ws.on("pong", () => {
          this.pingTimeout = setTimeout(() => ws.ping(), 10000);
        });
      }
      ws.onopen = () => {
        try {
          this.authenticate(token);
        } catch (error) {
          reject(error);
        }
      };
      ws.onclose = (event) => {
        if (this.pingTimeout) {
          clearTimeout(this.pingTimeout);
          this.pingTimeout = undefined;
        }
        if (!event.wasClean) {
          this.closeEvent = event;
        }
        const reason = new VaasConnectionClosedError(event);
        if (this.verdictPromises.size > 0) {
          this.verdictPromises.forEach((c) => c.reject(reason));
          this.verdictPromises.clear();
        }
        reject(reason);
      };
      ws.onmessage = async (event) => {
        const message = defaultSerializer.deserializeObject(
          event.data,
          Message,
        ) as Message;

        switch (message.kind) {
          case Kind.AuthResponse:
            const authResponse = defaultSerializer.deserializeObject(
              event.data,
              AuthenticationResponse,
            ) as AuthenticationResponse;
            if (authResponse.success) {
              this.connection!.sessionId = authResponse.session_id;
              resolve();
              return;
            }
            this.authenticationError = authResponse;