summaryrefslogtreecommitdiff
path: root/frontend-old/node_modules/websocket-driver/lib/websocket/driver/hybi
diff options
context:
space:
mode:
authoraltaf-creator <dev@altafcreator.com>2025-11-09 11:15:19 +0800
committeraltaf-creator <dev@altafcreator.com>2025-11-09 11:15:19 +0800
commit8eff962cab608341a6f2fedc640a0e32d96f26e2 (patch)
tree05534d1a720ddc3691d346c69b4972555820a061 /frontend-old/node_modules/websocket-driver/lib/websocket/driver/hybi
pain
Diffstat (limited to 'frontend-old/node_modules/websocket-driver/lib/websocket/driver/hybi')
-rw-r--r--frontend-old/node_modules/websocket-driver/lib/websocket/driver/hybi/frame.js21
-rw-r--r--frontend-old/node_modules/websocket-driver/lib/websocket/driver/hybi/message.js34
2 files changed, 55 insertions, 0 deletions
diff --git a/frontend-old/node_modules/websocket-driver/lib/websocket/driver/hybi/frame.js b/frontend-old/node_modules/websocket-driver/lib/websocket/driver/hybi/frame.js
new file mode 100644
index 0000000..0fb003f
--- /dev/null
+++ b/frontend-old/node_modules/websocket-driver/lib/websocket/driver/hybi/frame.js
@@ -0,0 +1,21 @@
+'use strict';
+
+var Frame = function() {};
+
+var instance = {
+ final: false,
+ rsv1: false,
+ rsv2: false,
+ rsv3: false,
+ opcode: null,
+ masked: false,
+ maskingKey: null,
+ lengthBytes: 1,
+ length: 0,
+ payload: null
+};
+
+for (var key in instance)
+ Frame.prototype[key] = instance[key];
+
+module.exports = Frame;
diff --git a/frontend-old/node_modules/websocket-driver/lib/websocket/driver/hybi/message.js b/frontend-old/node_modules/websocket-driver/lib/websocket/driver/hybi/message.js
new file mode 100644
index 0000000..e881273
--- /dev/null
+++ b/frontend-old/node_modules/websocket-driver/lib/websocket/driver/hybi/message.js
@@ -0,0 +1,34 @@
+'use strict';
+
+var Buffer = require('safe-buffer').Buffer;
+
+var Message = function() {
+ this.rsv1 = false;
+ this.rsv2 = false;
+ this.rsv3 = false;
+ this.opcode = null;
+ this.length = 0;
+ this._chunks = [];
+};
+
+var instance = {
+ read: function() {
+ return this.data = this.data || Buffer.concat(this._chunks, this.length);
+ },
+
+ pushFrame: function(frame) {
+ this.rsv1 = this.rsv1 || frame.rsv1;
+ this.rsv2 = this.rsv2 || frame.rsv2;
+ this.rsv3 = this.rsv3 || frame.rsv3;
+
+ if (this.opcode === null) this.opcode = frame.opcode;
+
+ this._chunks.push(frame.payload);
+ this.length += frame.length;
+ }
+};
+
+for (var key in instance)
+ Message.prototype[key] = instance[key];
+
+module.exports = Message;