[fix] pluginApi not compiled
This commit is contained in:
@@ -1,3 +1,14 @@
|
|||||||
|
var __assign = (this && this.__assign) || function () {
|
||||||
|
__assign = Object.assign || function(t) {
|
||||||
|
for (var s, i = 1, n = arguments.length; i < n; i++) {
|
||||||
|
s = arguments[i];
|
||||||
|
for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
|
||||||
|
t[p] = s[p];
|
||||||
|
}
|
||||||
|
return t;
|
||||||
|
};
|
||||||
|
return __assign.apply(this, arguments);
|
||||||
|
};
|
||||||
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
|
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
|
||||||
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
|
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
|
||||||
return new (P || (P = Promise))(function (resolve, reject) {
|
return new (P || (P = Promise))(function (resolve, reject) {
|
||||||
@@ -34,163 +45,209 @@ var __generator = (this && this.__generator) || function (thisArg, body) {
|
|||||||
if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
|
if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
var __risuPlugin__ = {
|
(function () {
|
||||||
providers: [],
|
var __risuPlugin__ = {
|
||||||
fetchResponseQueue: []
|
providers: [],
|
||||||
};
|
fetchResponseQueue: []
|
||||||
var sleep = function (ms) { return new Promise(function (r) { return setTimeout(r, ms); }); };
|
};
|
||||||
function risuFetch(url, arg) {
|
var sleep = function (ms) { return new Promise(function (r) { return setTimeout(r, ms); }); };
|
||||||
return __awaiter(this, void 0, void 0, function () {
|
function transferDataAsync(type, body) {
|
||||||
var id, i, q;
|
return __awaiter(this, void 0, void 0, function () {
|
||||||
return __generator(this, function (_a) {
|
var id, i, q;
|
||||||
switch (_a.label) {
|
return __generator(this, function (_a) {
|
||||||
case 0:
|
switch (_a.label) {
|
||||||
id = "".concat(Date.now(), "_").concat(Math.random());
|
case 0:
|
||||||
postMessage({
|
id = "".concat(Date.now(), "_").concat(Math.random());
|
||||||
type: 'fetch',
|
postMessage({
|
||||||
body: {
|
type: 'fetch',
|
||||||
id: id,
|
body: __assign({ id: id }, body)
|
||||||
url: url,
|
});
|
||||||
arg: arg
|
_a.label = 1;
|
||||||
|
case 1:
|
||||||
|
if (!true) return [3 /*break*/, 3];
|
||||||
|
return [4 /*yield*/, sleep(50)];
|
||||||
|
case 2:
|
||||||
|
_a.sent();
|
||||||
|
for (i = 0; i < __risuPlugin__.fetchResponseQueue.length; i++) {
|
||||||
|
q = __risuPlugin__.fetchResponseQueue[i];
|
||||||
|
if (q.id === id) {
|
||||||
|
__risuPlugin__.fetchResponseQueue.splice(i, 1);
|
||||||
|
return [2 /*return*/, q.data];
|
||||||
|
}
|
||||||
}
|
}
|
||||||
});
|
return [3 /*break*/, 1];
|
||||||
_a.label = 1;
|
case 3: return [2 /*return*/];
|
||||||
case 1:
|
}
|
||||||
if (!true) return [3 /*break*/, 3];
|
});
|
||||||
return [4 /*yield*/, sleep(50)];
|
|
||||||
case 2:
|
|
||||||
_a.sent();
|
|
||||||
for (i = 0; i < __risuPlugin__.fetchResponseQueue.length; i++) {
|
|
||||||
q = __risuPlugin__.fetchResponseQueue[i];
|
|
||||||
if (q.id === id) {
|
|
||||||
__risuPlugin__.fetchResponseQueue.splice(i, 1);
|
|
||||||
return [2 /*return*/, q.data];
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return [3 /*break*/, 1];
|
|
||||||
case 3: return [2 /*return*/];
|
|
||||||
}
|
|
||||||
});
|
});
|
||||||
});
|
}
|
||||||
}
|
function risuFetch(url, arg) {
|
||||||
function getArg(arg) {
|
return __awaiter(this, void 0, void 0, function () {
|
||||||
return __awaiter(this, void 0, void 0, function () {
|
var id, i, q;
|
||||||
var id, i, q;
|
return __generator(this, function (_a) {
|
||||||
return __generator(this, function (_a) {
|
switch (_a.label) {
|
||||||
switch (_a.label) {
|
case 0:
|
||||||
case 0:
|
id = "".concat(Date.now(), "_").concat(Math.random());
|
||||||
id = "".concat(Date.now(), "_").concat(Math.random());
|
postMessage({
|
||||||
postMessage({
|
type: 'fetch',
|
||||||
type: 'getArg',
|
body: {
|
||||||
body: {
|
id: id,
|
||||||
id: id,
|
url: url,
|
||||||
arg: arg
|
arg: arg
|
||||||
|
}
|
||||||
|
});
|
||||||
|
_a.label = 1;
|
||||||
|
case 1:
|
||||||
|
if (!true) return [3 /*break*/, 3];
|
||||||
|
return [4 /*yield*/, sleep(50)];
|
||||||
|
case 2:
|
||||||
|
_a.sent();
|
||||||
|
for (i = 0; i < __risuPlugin__.fetchResponseQueue.length; i++) {
|
||||||
|
q = __risuPlugin__.fetchResponseQueue[i];
|
||||||
|
if (q.id === id) {
|
||||||
|
__risuPlugin__.fetchResponseQueue.splice(i, 1);
|
||||||
|
return [2 /*return*/, q.data];
|
||||||
|
}
|
||||||
}
|
}
|
||||||
});
|
return [3 /*break*/, 1];
|
||||||
_a.label = 1;
|
case 3: return [2 /*return*/];
|
||||||
case 1:
|
}
|
||||||
if (!true) return [3 /*break*/, 3];
|
});
|
||||||
return [4 /*yield*/, sleep(50)];
|
|
||||||
case 2:
|
|
||||||
_a.sent();
|
|
||||||
for (i = 0; i < __risuPlugin__.fetchResponseQueue.length; i++) {
|
|
||||||
q = __risuPlugin__.fetchResponseQueue[i];
|
|
||||||
if (q.id === id) {
|
|
||||||
__risuPlugin__.fetchResponseQueue.splice(i, 1);
|
|
||||||
return [2 /*return*/, q.data];
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return [3 /*break*/, 1];
|
|
||||||
case 3: return [2 /*return*/];
|
|
||||||
}
|
|
||||||
});
|
});
|
||||||
});
|
}
|
||||||
}
|
function getArg(arg) {
|
||||||
function addProvider(name, func) {
|
return __awaiter(this, void 0, void 0, function () {
|
||||||
postMessage({
|
var id, i, q;
|
||||||
type: 'addProvider',
|
return __generator(this, function (_a) {
|
||||||
body: name
|
switch (_a.label) {
|
||||||
});
|
case 0:
|
||||||
__risuPlugin__.providers.push({
|
id = "".concat(Date.now(), "_").concat(Math.random());
|
||||||
name: name,
|
postMessage({
|
||||||
func: func
|
type: 'getArg',
|
||||||
});
|
body: {
|
||||||
}
|
id: id,
|
||||||
function printLog(data) {
|
arg: arg
|
||||||
postMessage({
|
}
|
||||||
type: 'log',
|
});
|
||||||
body: data
|
_a.label = 1;
|
||||||
});
|
case 1:
|
||||||
}
|
if (!true) return [3 /*break*/, 3];
|
||||||
function handleOnmessage(data) {
|
return [4 /*yield*/, sleep(50)];
|
||||||
return __awaiter(this, void 0, void 0, function () {
|
case 2:
|
||||||
var _a, body, providers, providerfunc, _i, providers_1, provider, _b, error_1;
|
_a.sent();
|
||||||
var _c;
|
for (i = 0; i < __risuPlugin__.fetchResponseQueue.length; i++) {
|
||||||
return __generator(this, function (_d) {
|
q = __risuPlugin__.fetchResponseQueue[i];
|
||||||
switch (_d.label) {
|
if (q.id === id) {
|
||||||
case 0:
|
__risuPlugin__.fetchResponseQueue.splice(i, 1);
|
||||||
if (!data.type) {
|
return [2 /*return*/, q.data];
|
||||||
return [2 /*return*/];
|
}
|
||||||
}
|
|
||||||
_a = data.type;
|
|
||||||
switch (_a) {
|
|
||||||
case "requestProvider": return [3 /*break*/, 1];
|
|
||||||
case "fetchData": return [3 /*break*/, 6];
|
|
||||||
}
|
|
||||||
return [3 /*break*/, 7];
|
|
||||||
case 1:
|
|
||||||
body = data.body;
|
|
||||||
providers = __risuPlugin__.providers;
|
|
||||||
providerfunc = null;
|
|
||||||
for (_i = 0, providers_1 = providers; _i < providers_1.length; _i++) {
|
|
||||||
provider = providers_1[_i];
|
|
||||||
if (provider.name === body.key) {
|
|
||||||
providerfunc = provider.func;
|
|
||||||
}
|
}
|
||||||
}
|
return [3 /*break*/, 1];
|
||||||
if (!!providerfunc) return [3 /*break*/, 2];
|
case 3: return [2 /*return*/];
|
||||||
postMessage({
|
}
|
||||||
type: 'resProvider',
|
});
|
||||||
body: {
|
});
|
||||||
'success': false,
|
}
|
||||||
'content': 'unknown provider'
|
function addProvider(name, func) {
|
||||||
|
postMessage({
|
||||||
|
type: 'addProvider',
|
||||||
|
body: name
|
||||||
|
});
|
||||||
|
__risuPlugin__.providers.push({
|
||||||
|
name: name,
|
||||||
|
func: func
|
||||||
|
});
|
||||||
|
}
|
||||||
|
function printLog(data) {
|
||||||
|
postMessage({
|
||||||
|
type: 'log',
|
||||||
|
body: data
|
||||||
|
});
|
||||||
|
}
|
||||||
|
function getChar() {
|
||||||
|
return transferDataAsync('getChar', '');
|
||||||
|
}
|
||||||
|
function setChar(char) {
|
||||||
|
postMessage({
|
||||||
|
type: 'setChar',
|
||||||
|
body: char
|
||||||
|
});
|
||||||
|
}
|
||||||
|
function handleOnmessage(data) {
|
||||||
|
return __awaiter(this, void 0, void 0, function () {
|
||||||
|
var _a, body, providers, providerfunc, _i, providers_1, provider, _b, error_1;
|
||||||
|
var _c;
|
||||||
|
return __generator(this, function (_d) {
|
||||||
|
switch (_d.label) {
|
||||||
|
case 0:
|
||||||
|
if (!data.type) {
|
||||||
|
return [2 /*return*/];
|
||||||
}
|
}
|
||||||
});
|
_a = data.type;
|
||||||
return [3 /*break*/, 5];
|
switch (_a) {
|
||||||
case 2:
|
case "requestProvider": return [3 /*break*/, 1];
|
||||||
_d.trys.push([2, 4, , 5]);
|
case "fetchData": return [3 /*break*/, 6];
|
||||||
_b = postMessage;
|
|
||||||
_c = {
|
|
||||||
type: 'resProvider'
|
|
||||||
};
|
|
||||||
return [4 /*yield*/, providerfunc(body.arg)];
|
|
||||||
case 3:
|
|
||||||
_b.apply(void 0, [(_c.body = _d.sent(),
|
|
||||||
_c)]);
|
|
||||||
return [3 /*break*/, 5];
|
|
||||||
case 4:
|
|
||||||
error_1 = _d.sent();
|
|
||||||
postMessage({
|
|
||||||
type: 'resProvider',
|
|
||||||
body: {
|
|
||||||
'success': false,
|
|
||||||
'content': "providerError: ".concat(error_1)
|
|
||||||
}
|
}
|
||||||
});
|
|
||||||
return [3 /*break*/, 5];
|
|
||||||
case 5: return [3 /*break*/, 7];
|
|
||||||
case 6:
|
|
||||||
{
|
|
||||||
__risuPlugin__.fetchResponseQueue.push(data.body);
|
|
||||||
return [3 /*break*/, 7];
|
return [3 /*break*/, 7];
|
||||||
}
|
case 1:
|
||||||
_d.label = 7;
|
body = data.body;
|
||||||
case 7: return [2 /*return*/];
|
providers = __risuPlugin__.providers;
|
||||||
}
|
providerfunc = null;
|
||||||
|
for (_i = 0, providers_1 = providers; _i < providers_1.length; _i++) {
|
||||||
|
provider = providers_1[_i];
|
||||||
|
if (provider.name === body.key) {
|
||||||
|
providerfunc = provider.func;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (!!providerfunc) return [3 /*break*/, 2];
|
||||||
|
postMessage({
|
||||||
|
type: 'resProvider',
|
||||||
|
body: {
|
||||||
|
'success': false,
|
||||||
|
'content': 'unknown provider'
|
||||||
|
}
|
||||||
|
});
|
||||||
|
return [3 /*break*/, 5];
|
||||||
|
case 2:
|
||||||
|
_d.trys.push([2, 4, , 5]);
|
||||||
|
_b = postMessage;
|
||||||
|
_c = {
|
||||||
|
type: 'resProvider'
|
||||||
|
};
|
||||||
|
return [4 /*yield*/, providerfunc(body.arg)];
|
||||||
|
case 3:
|
||||||
|
_b.apply(void 0, [(_c.body = _d.sent(),
|
||||||
|
_c)]);
|
||||||
|
return [3 /*break*/, 5];
|
||||||
|
case 4:
|
||||||
|
error_1 = _d.sent();
|
||||||
|
postMessage({
|
||||||
|
type: 'resProvider',
|
||||||
|
body: {
|
||||||
|
'success': false,
|
||||||
|
'content': "providerError: ".concat(error_1)
|
||||||
|
}
|
||||||
|
});
|
||||||
|
return [3 /*break*/, 5];
|
||||||
|
case 5: return [3 /*break*/, 7];
|
||||||
|
case 6:
|
||||||
|
{
|
||||||
|
__risuPlugin__.fetchResponseQueue.push(data.body);
|
||||||
|
return [3 /*break*/, 7];
|
||||||
|
}
|
||||||
|
_d.label = 7;
|
||||||
|
case 7: return [2 /*return*/];
|
||||||
|
}
|
||||||
|
});
|
||||||
});
|
});
|
||||||
});
|
}
|
||||||
}
|
onmessage = function (ev) {
|
||||||
onmessage = function (ev) {
|
handleOnmessage(ev.data);
|
||||||
handleOnmessage(ev.data);
|
var data = ev.data;
|
||||||
var data = ev.data;
|
};
|
||||||
};
|
{
|
||||||
|
var __risuPlugin__1 = null;
|
||||||
|
var transferDataAsync_1 = null;
|
||||||
|
//{{placeholder}}
|
||||||
|
}
|
||||||
|
})();
|
||||||
|
|||||||
Reference in New Issue
Block a user