echo.js

import { WebSocket } from "ws";

class EchoBot {
  constructor({ ws, http }) {
    this.wsEndpoint = ws;
    this.httpEndpoint = http;
    this.socket = null;
    this.botSession = null;
  }

  async connect() {
    return new Promise((resolve, reject) => {
      this.socket = new WebSocket(this.wsEndpoint);

      this.socket.onopen = () => {
        console.log("[bot.socket.open]");

        const loginData = {
          organization_id: process.env.BOT_ORGANIZATION_ID,
          device_id: "EchoBot_device",
          login: process.env.BOT_LOGIN,
          password: process.env.BOT_PASSWORD,
        };

        fetch(`${this.httpEndpoint}/login`, {
          method: "POST",
          credentials: "include",
          headers: { "Content-Type": "application/json" },
          body: JSON.stringify(loginData),
        })
          .then(async (res) => {
            const text = await res.text();

            if (!res.ok) {
              console.error("[bot.http.login.error]", text);
              throw text || res.statusText;
            }
            const responseData = text ? JSON.parse(text) : {};
            console.log("[bot.http.login.response]", responseData);
            this.botSession = responseData;

            if (responseData.access_token) {
              try {
                this.socket.send(
                  JSON.stringify({
                    request: {
                      connect: {
                        token: responseData.access_token,
                        device_id: loginData.device_id,
                      },
                    },
                  })
                );
              } catch (error) {
                console.error("[bot.socket.connect.error]", err);
                reject();
              }
            }
            resolve();
          })
          .catch((err) => {
            console.error("[bot.http.login.error]", err);
            reject();
          });
      };

      this.socket.onmessage = (e) => {
        const message = JSON.parse(e.data);
        console.log("[bot.socket.message]", message);

        if (message.message) {
          const botId = this.botSession.user._id;
          const { _id, body, cid, attachments } = message.message;
          this.socket.send(
            JSON.stringify({
              request: {
                message_read: { cid },
                id: "echoBot:markConversationAsRead",
              },
            })
          );

          const messageToSend = {
            message: {
              id: botId + Date.now(),
              cid,
              body: body ? "Echo: " + body : "",
              attachments,
            },
          };

          setTimeout(
            () => this.socket.send(JSON.stringify(messageToSend)),
            1000
          );
          return;
        }

        if (message.response?.user) {
          this.botSession = message.response;
        }
      };

      this.socket.onerror = (error) => {
        console.log("[bot.socket.error]", error);
        reject(error);
      };

      this.socket.onclose = () => {
        console.log("[bot.socket.close]");
      };
    });
  }
}

const echoBot = new EchoBot({
  ws: process.env.SOCKET_SERVER_ENDPOINT,
  http: process.env.HTTP_SERVER_ENDPOINT,
});
echoBot.connect();