Add cloudflare environment.

envs/cloudflare/index.js

@@ -0,0 +1,22 @@
+const makeMTProto = require("../../src");
+const SHA1 = require("../browser/sha1");
+const SHA256 = require("../browser/sha256");
+const PBKDF2 = require("../browser/pbkdf2");
+const Transport = require("./transport");
+const getRandomBytes = require("../browser/get-random-bytes");
+const getLocalStorage = require("../browser/get-local-storage");
+
+function createTransport(dc, crypto) {
+  return new Transport(dc, crypto);
+}
+
+const MTProto = makeMTProto({
+  SHA1,
+  SHA256,
+  PBKDF2,
+  getRandomBytes,
+  getLocalStorage,
+  createTransport,
+});
+
+module.exports = MTProto;

envs/cloudflare/transport.js

@@ -0,0 +1,89 @@
+const Obfuscated = require("../../src/transport/obfuscated");
+
+const subdomainsMap = {
+  1: "pluto",
+  2: "venus",
+  3: "aurora",
+  4: "vesta",
+  5: "flora",
+};
+
+class Transport extends Obfuscated {
+  constructor(dc, crypto) {
+    super();
+
+    this.dc = dc;
+    this.url = `https://${subdomainsMap[this.dc.id]}.web.telegram.org${
+      this.dc.test ? "/apiws_test" : "/apiws"
+    }`;
+    this.crypto = crypto;
+
+    this.connect();
+  }
+
+  get isAvailable() {
+    return this.socket.readyState === WebSocket.OPEN;
+  }
+
+  async connect() {
+    let resp = await fetch(this.url, {
+      headers: {
+        Connection: "Upgrade",
+        Upgrade: "websocket",
+      },
+    });
+
+    this.socket = resp.webSocket;
+    if (!this.socket) {
+      throw new Error("server didn't accept WebSocket");
+    }
+
+    this.socket.binaryType = "arraybuffer";
+    this.socket.accept();
+    this.socket.addEventListener("error", this.handleError.bind(this));
+    this.socket.addEventListener("open", this.handleOpen.bind(this));
+    this.socket.addEventListener("close", this.handleClose.bind(this));
+    this.socket.addEventListener("message", this.handleMessage.bind(this));
+    this.handleOpen();
+  }
+
+  async handleError() {
+    this.emit("error", {
+      type: "socket",
+    });
+  }
+
+  async handleOpen() {
+    const initialMessage = await this.generateObfuscationKeys();
+    this.socket.send(initialMessage);
+
+    this.emit("open");
+  }
+
+  async handleClose() {
+    if (this.isAvailable) {
+      this.socket.close();
+    }
+
+    this.connect();
+  }
+
+  async handleMessage(event) {
+    const obfuscatedBytes = new Uint8Array(event.data);
+    const bytes = await this.deobfuscate(obfuscatedBytes);
+
+    const payload = this.getIntermediatePayload(bytes);
+
+    this.emit("message", payload.buffer);
+  }
+
+  async send(bytes) {
+    const intermediateBytes = this.getIntermediateBytes(bytes);
+
+    const { buffer } = await this.obfuscate(intermediateBytes);
+
+    this.socket.send(buffer);
+  }
+}
+
+module.exports = Transport;