refactor(sio): internalize base64id dependency

This dependency is a one-file package used to generate Base64 identifiers.

Repository: https://github.com/faeldt/base64id

Author: darrachequesne

package-lock.json

@@ -0,0 +1,110 @@
+// imported from https://github.com/faeldt/base64id/blob/af13114809291393846a56eddbb1ac2035ae397c/lib/base64id.js
+/*!
+ * base64id v0.1.0
+ */
+
+/**
+ * Module dependencies
+ */
+
+import crypto = require("crypto");
+
+/**
+ * Constructor
+ */
+
+var Base64Id = function () {};
+
+/**
+ * Get random bytes
+ *
+ * Uses a buffer if available, falls back to crypto.randomBytes
+ */
+
+Base64Id.prototype.getRandomBytes = function (bytes) {
+  var BUFFER_SIZE = 4096;
+  var self = this;
+
+  bytes = bytes || 12;
+
+  if (bytes > BUFFER_SIZE) {
+    return crypto.randomBytes(bytes);
+  }
+
+  // var bytesInBuffer = parseInt(BUFFER_SIZE / bytes);
+  // var threshold = parseInt(bytesInBuffer * 0.85);
+  var bytesInBuffer = Math.floor(BUFFER_SIZE / bytes);
+  var threshold = Math.floor(bytesInBuffer * 0.85);
+
+  if (!threshold) {
+    return crypto.randomBytes(bytes);
+  }
+
+  if (this.bytesBufferIndex == null) {
+    this.bytesBufferIndex = -1;
+  }
+
+  if (this.bytesBufferIndex == bytesInBuffer) {
+    this.bytesBuffer = null;
+    this.bytesBufferIndex = -1;
+  }
+
+  // No buffered bytes available or index above threshold
+  if (this.bytesBufferIndex == -1 || this.bytesBufferIndex > threshold) {
+    if (!this.isGeneratingBytes) {
+      this.isGeneratingBytes = true;
+      crypto.randomBytes(BUFFER_SIZE, function (err, bytes) {
+        self.bytesBuffer = bytes;
+        self.bytesBufferIndex = 0;
+        self.isGeneratingBytes = false;
+      });
+    }
+
+    // Fall back to sync call when no buffered bytes are available
+    if (this.bytesBufferIndex == -1) {
+      return crypto.randomBytes(bytes);
+    }
+  }
+
+  var result = this.bytesBuffer.slice(
+    bytes * this.bytesBufferIndex,
+    bytes * (this.bytesBufferIndex + 1),
+  );
+  this.bytesBufferIndex++;
+
+  return result;
+};
+
+/**
+ * Generates a base64 id
+ *
+ * (Original version from socket.io <http://socket.io>)
+ */
+
+Base64Id.prototype.generateId = function () {
+  var rand = Buffer.alloc(15); // multiple of 3 for base64
+  if (!rand.writeInt32BE) {
+    return (
+      Math.abs((Math.random() * Math.random() * Date.now()) | 0).toString() +
+      Math.abs((Math.random() * Math.random() * Date.now()) | 0).toString()
+    );
+  }
+  this.sequenceNumber = (this.sequenceNumber + 1) | 0;
+  rand.writeInt32BE(this.sequenceNumber, 11);
+  // @ts-expect-error
+  if (crypto.randomBytes) {
+    this.getRandomBytes(12).copy(rand);
+  } else {
+    // not secure for node 0.4
+    [0, 4, 8].forEach(function (i) {
+      rand.writeInt32BE((Math.random() * Math.pow(2, 32)) | 0, i);
+    });
+  }
+  return rand.toString("base64").replace(/\//g, "_").replace(/\+/g, "-");
+};
+
+/**
+ * Export
+ */
+
+export const base64id = new Base64Id();

packages/socket.io/lib/contrib/base64id.ts

@@ -25,7 +25,7 @@ import type {
   Session,
   SocketId,
 } from "socket.io-adapter";
-import base64id from "base64id";
+import { base64id } from "./contrib/base64id";
 import { BroadcastOperator } from "./broadcast-operator";
 import {
   DisconnectReason,

packages/socket.io/lib/socket.ts

@@ -30,7 +30,7 @@
       "types": "./dist/index.d.ts",
       "import": "./wrapper.mjs",
       "require": "./dist/index.js"
-     },
+    },
     "./package.json": "./package.json"
   },
   "types": "./dist/index.d.ts",
@@ -54,7 +54,6 @@
   },
   "dependencies": {
     "accepts": "~1.3.4",
-    "base64id": "~2.0.0",
     "cors": "~2.8.5",
     "debug": "~4.4.1",
     "engine.io": "~6.6.0",