first commit

liusuyi

2023-04-24 4737f1e038743ced243c9e52423404d9034d6107

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
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;