songliang/r2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

...

Browse Source
This commit is contained in:
lightings 2023-07-11 20:58:19 +08:00
parent 652979ec92
commit a1f0cd77d6
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
proxy/lib/deps/pomelo-jsclient.js
View File

@ -137,7 +137,7 @@ class PomeloClient extends EventEmitter {
this.send(obj); this.send(obj);
}); });
this.socket.on("data", (event) => { this.socket.on("data", (event) => {
console.log("socket data: ", event); // console.log("socket data: ", event);
let r = Package.decode(event); let r = Package.decode(event);
if (r instanceof Array) { if (r instanceof Array) {
for (var i = 0; i < r.length; i++) { for (var i = 0; i < r.length; i++) {
@ -170,7 +170,7 @@ class PomeloClient extends EventEmitter {
} }
processPackage(msg) { processPackage(msg) {
console.log("processPackage msg: ", msg); // console.log("processPackage msg: ", msg);
try { try {
this.handlers[msg.type](msg.body); this.handlers[msg.type](msg.body);
} }
@ -295,7 +295,7 @@ class PomeloClient extends EventEmitter {
} }
onData(data) { onData(data) {
console.log("************* onData: ", data); // console.log("************* onData: ", data);
//probuff decode //probuff decode
var msg = Message.decode(data); var msg = Message.decode(data);
@ -335,7 +335,7 @@ class PomeloClient extends EventEmitter {
} }
processMessage(msg) { processMessage(msg) {
console.warn('recv msg: ', msg); // console.warn('recv msg: ', msg);
if(!msg.id) { if(!msg.id) {
// server push message // server push message
this.emit(msg.route, msg.body); this.emit(msg.route, msg.body);