Method forStreamRequest

typescript/src/Vaas.ts:240–291

(stream: Readable)

  }

  private async forStreamRequest(stream: Readable): Promise<VaasVerdict> {
    const ws = this.getAuthenticatedWebSocket();
    return new Promise((resolve, reject) => {
      const guid = uuidv4();
      if (this.debug) console.debug("uuid", guid);
      let contentLength = 0;
      this.verdictPromises.set(guid, { // waits for the verdictRequestForStream response
        resolve: async (verdictResponse: VerdictResponse) => {
          if (verdictResponse.verdict !== Verdict.UNKNOWN) {
            throw new VaasServerError(
              "Server returned verdict without receiving content",
            );
          }
          if (verdictResponse.upload_token === undefined || verdictResponse.upload_token == "") {
            throw new VaasServerError(
              "No upload token set in response",
            );
          }
          if (verdictResponse.url === undefined || verdictResponse.url == "") {
            throw new VaasServerError(
              "No upload url set in response",
            );
          }
          this.verdictPromises.delete(guid);
          this.verdictPromises.set(guid, { // waits for the upload response
            resolve: async (verdictResponse: VerdictResponse) => {
              this.verdictPromises.delete(guid);
              resolve(
                new VaasVerdict(verdictResponse.sha256, verdictResponse.verdict, verdictResponse.detection, verdictResponse.file_type, verdictResponse.mime_type),
              );
            },
            reject: (reason) => reject(reason),
          });

          contentLength = stream.readableLength;
          await this.upload(verdictResponse, stream, contentLength);
          return;
        },
        reject: (reason) => reject(reason),
      });

      const verdictReq = JSON.stringify(
        defaultSerializer.serialize(
          new VerdictRequestForStream(
            guid,
            this.connection!.sessionId as string,
          ),
        ),
      );
      ws.send(verdictReq);
    });
  }

  /** Connect to VaaS
   * @throws {VaasAuthenticationError} Authentication failed.