Function fbBlockFeatures

scripts/fb_blockSeenAndTyping.js:51–194

({
  block_seen_chat = true,
  block_typing_chat = true,
})

}

export function fbBlockFeatures({
  block_seen_chat = true,
  block_typing_chat = true,
}) {
  const ignoreTopic = [
    "/send_additional_contacts",
    "/br_sr",
    "/sr_res",
    "/ls_app_settings",
  ];
  const ignoreCmd = ["pingreq", "subscribe"];
  const c_user = getUserID();
  const opts = { protocolVersion: 3 };
  let qq = [];

  function getCurrentTimestamp() {
    return Date.now() * 1000;
  }

  const wsProxy = new Proxy(window.WebSocket, {
    construct: function (target, args) {
      const instance = new target(...args),
        openHandler = (e) => {},
        messageHandler = (e) => {
          e = new Uint8Array(e.data);
          let t = parser(opts);

          // mes_block_delivery
          2e3 < e.length &&
            (t.on("packet", (e) => {
              "publish" === e.cmd &&
                "/ls_resp" === e.topic &&
                1 === e.qos &&
                qq.push(e.messageId);
            }),
            t.parse(e));
        },
        closeHandler = (e) => {
          instance.removeEventListener("open", openHandler);
          instance.removeEventListener("close", closeHandler);
          instance.removeEventListener("message", messageHandler);
        };
      instance.addEventListener("message", messageHandler);
      instance.addEventListener("open", openHandler);
      instance.addEventListener("close", closeHandler);

      instance.send = new Proxy(instance.send, {
        apply: function (target, thisArg, args) {
          const e = new Uint8Array(args[0]);
          let t = parser(opts);

          t.on("packet", (i) => {
            let rPayload;
            try {
              if (ignoreTopic.includes(i.topic) || ignoreCmd.includes(i.cmd)) {
                return target.apply(thisArg, args);
              }