91 lines
3.1 KiB
JavaScript
91 lines
3.1 KiB
JavaScript
/*
|
|
* Tencent is pleased to support the open source community by making Puerts available.
|
|
* Copyright (C) 2020 THL A29 Limited, a Tencent company. All rights reserved.
|
|
* Puerts is licensed under the BSD 3-Clause License, except for the third-party components listed in the file 'LICENSE' which may be subject to their corresponding license terms.
|
|
* This file is subject to the terms and conditions defined in file 'LICENSE', which is part of this source code package.
|
|
*/
|
|
|
|
var global = global || (function () { return this; }());
|
|
(function (global) {
|
|
"use strict";
|
|
let puerts = global.puerts = global.puerts || {};
|
|
let sendMessage = global.prompt;
|
|
puerts.sendRawMessage = function(msg) {
|
|
return sendMessage(msg);
|
|
}
|
|
|
|
//TODO:支持多参数，多参数自动用#连接
|
|
puerts.sendRequestSync = function(cmd, ...args) {
|
|
var req = cmd + "#" + args.join('#');
|
|
let ret = sendMessage(req); //oneway ret === "", normal reply === "#msg", error === "info"
|
|
if (ret) {
|
|
var err;
|
|
var rpy;
|
|
if (!ret.startsWith('#')) {
|
|
err = new Error(ret);
|
|
} else {
|
|
rpy = ret.substring(1);
|
|
}
|
|
if (err) throw err;
|
|
return rpy;
|
|
}
|
|
}
|
|
|
|
let requestHandlers = Object.create(null);
|
|
|
|
puerts.registerRequestHandler = function(cmd, callback) {
|
|
requestHandlers[cmd] = callback;
|
|
}
|
|
|
|
function sendReply(replyId, reply, err) {
|
|
let errMsg = err ? (typeof err == 'string' ? err : err.message) : ''
|
|
if (replyId) {
|
|
puerts.sendRequestSync('onReply', replyId + '#' + (errMsg ? errMsg : ('#' + reply)));
|
|
}
|
|
}
|
|
|
|
function handleMessage(cmd, data, replyId) {
|
|
let handler = requestHandlers[cmd];
|
|
if (!handler) {
|
|
return sendReply(replyId, null, "can not find handler for " + cmd);
|
|
}
|
|
|
|
if (replyId) {
|
|
handler(data, (err, reply) => sendReply(replyId, reply, err));
|
|
} else {
|
|
handler(data);
|
|
}
|
|
}
|
|
|
|
var lastPollTime = new Date();
|
|
|
|
setInterval(() => {
|
|
let now = new Date();
|
|
//puerts.console.log('interval:' + (now - lastPollTime));
|
|
lastPollTime = now;
|
|
let msg = puerts.sendRequestSync('pollRequest');
|
|
let cmd, replyId
|
|
if (msg) {
|
|
try {
|
|
//puerts.console.log('msg:' + msg);
|
|
let firstSplit = msg.indexOf('#');
|
|
let secondSplit = msg.indexOf('#', firstSplit + 1);
|
|
replyId = msg.substring(0, firstSplit);
|
|
cmd = msg.substring(firstSplit + 1, secondSplit);
|
|
let data = msg.substring(secondSplit + 1);
|
|
//puerts.console.warn(replyId);
|
|
//puerts.console.log(cmd);
|
|
//puerts.console.log(data);
|
|
handleMessage(cmd, data, replyId);
|
|
} catch(e) {
|
|
if (replyId) {
|
|
sendReply(replyId, null, e.stack);
|
|
} else {
|
|
puerts.console.error("handle " + (cmd || "unknow") + " fail, info = " + e.stack);
|
|
}
|
|
}
|
|
}
|
|
}, 1);
|
|
|
|
}(global));
|