Method #sendMessageToWebSocket

src/extensions/bingchat/bingchat-api.ts:101–163

(ws: WebSocket, text: string, options)

    });
  }

  #sendMessageToWebSocket(ws: WebSocket, text: string, options): Promise<void> {
    return (new Promise<void>((resolve, reject) => {
      rejectOnWebSocketError(ws, reject, options.signal);
      ws.on('message', (data) => {
        // Handle received messages from BingChat.
        const events = data.toString()
          .split(nullChar)
          .filter(s => s != '')
          .map(s => JSON.parse(s));
        for (const event of events) {
          if (event.type == 1) {
            // Updates.
            if (!event.arguments[0].messages)
              continue;
            this.#handlePayload(event.arguments[0].messages[0], options);
          } else if (event.type == 2) {
            // Possible denied service.
            if (event.item.result.value != 'Success') {
              const error = new APIError(event.item.result.message);
              if (event.item.result.value == 'InvalidSession')
                error.code = 'invalid-session';
              reject(error);
              return;
            }
            const message = event.item.messages[event.item.messages.length - 1];
            if (message['hiddenText']?.includes('Conversation disengaged.'))
              reject(new APIError('Conversation disengaged.'));
            else if (event.item.messages.find(m => m.contentOrigin == 'TurnLimiter'))
              reject(new APIError('Chat turn limit has been reached.'));
          } else if (event.type == 3) {
            // Finished.
            resolve();
          }
        }
      });
      // Send the message to BingChat.
      const params = {
        type: 4,
        target: 'chat',
        invocationId: String(this.session.invocationId),
        arguments: [
          {
            ...chatArgument,
            traceId: crypto.randomBytes(16).toString('hex'),
            isStartOfSession: this.session.invocationId == 0,
            message: {
              messageType: 'Chat',
              author: 'user',
              text,
            },
            conversationSignature: this.session.conversationSignature,
            participant: {id: this.session.clientId},
            conversationId: this.session.conversationId,
          },
        ],
      };
      params.arguments[0].optionsSets.push(this.getParam('tone'));