import { log, error, time, timeEnd } from './utils.js';
/*
管理所有事件处理函数，并生成一个代理函数，允许用户替换其中的某些实现
受制于小程序的运行时机制，在 locked 之后，不允许变更 handlerNames
*/
var HandlersController = /** @class */ (function () {
function HandlersController(elementTag) {
if (elementTag === void 0) { elementTag = ''; }
this.elementTag = ''; // 主要是 debug 使用
this.locked = false; // 是否已经锁定，锁定之后不允许新增 handler
this.executionInProgress = false;
this.executionQueue = [];
this.handlerNames = [];
this.handlerImpl = {};
this.elementTag = elementTag;
}
HandlersController.prototype.addHandler = function (name, bindContext, impl, disableMultiImpl) {
var _this = this;
if (this.locked && this.handlerNames.indexOf(name) < 0) {
throw new Error("\u4E0D\u5141\u8BB8\u52A8\u6001\u65B0\u589E handler: ".concat(name));
}
if (impl && !bindContext) {
throw new Error("bindContext \u4E0D\u80FD\u4E3A\u7A7A\uFF0C\u8FD0\u884C\u65F6\u9700\u8981\u7528\u5230\u5B83");
}
if (bindContext && !impl) {
throw new Error('missing impl');
}
if (typeof name !== 'string') {
throw new Error("name \u7684\u7C7B\u578B\u4E0D\u5408\u6CD5\uFF08".concat(typeof name, "\uFF09\uFF0C\u5B83\u5E94\u8BE5\u662F\u4E00\u4E2A\u5B57\u7B26\u4E32"));
}
else if (typeof impl !== 'function' && typeof impl !== 'undefined') {
throw new Error("impl \u7684\u7C7B\u578B\u4E0D\u5408\u6CD5\uFF08".concat(typeof impl, "\uFF09\uFF0C\u5B83\u5E94\u8BE5\u662F\u4E00\u4E2A\u51FD\u6570"));
}
if (this.handlerNames.indexOf(name) < 0) {
this.handlerNames.push(name);
}
this.handlerImpl[name] = this.handlerImpl[name] || [];
var self = this;
if (!impl) {
return function () { };
}
if (disableMultiImpl &&
this.getHandlersByName(name, bindContext).length > 0) {
throw new Error("".concat(name, " \u5DF2\u7ECF\u6CE8\u518C\u4E86\u4E00\u4E2A\u5B9E\u73B0\uFF0C\u4E0D\u80FD\u518D\u65B0\u589E"));
}
var implInfo = {
// 裹一层，把 off 方法收集下来
fn: function () {
var args = [];
for (var _i = 0; _i < arguments.length; _i++) {
args[_i] = arguments[_i];
}
if (!this)
throw new Error('missing context, cannot find matching handler');
var ctx = self.filterContext(bindContext, this);
// context 不匹配，不处理
if (!ctx)
throw new Error('handler context mismatch, refuse executing');
try {
var ret = impl.apply(this, args);
if (typeof ret === 'function') {
implInfo.off = ret; // 这个 off 其实已经不用了
}
else {
return ret; // 如果不是 function，认为这个返回值有用，不是 off
}
}
catch (e) {
error("".concat(self.elementTag, " ").concat(name, " \u6267\u884C\u51FA\u9519\uFF0C\u9519\u8BEF\u4FE1\u606F\uFF1A").concat(e.message));
throw e;
}
},
bindContext: bindContext,
};
this.handlerImpl[name].push(implInfo);
return function () {
log("off ".concat(name, " - ").concat(_this.elementTag));
var handlers = _this.handlerImpl[name]; // 这里闭包里有明确的 implInfo, 不需要根据 context 过滤
if (!handlers) {
var msg = "\u6CA1\u6709\u627E\u5230 ".concat(name, " \u5BF9\u5E94\u7684\u5B9E\u73B0\uFF0C\u662F\u5426\u5DF2\u7ECF\u88AB reset \u4E86 \uFF1F\u8BF7\u68C0\u67E5\u751F\u547D\u5468\u671F\u6D41\u7A0B");
error(msg);
throw new Error(msg);
}
var index = handlers.indexOf(implInfo);
var offFunction = handlers[index].off;
if (offFunction) {
try {
offFunction.call(undefined);
}
catch (e) {
error("\u6267\u884C ".concat(name, " \u7684\u53CD\u6CE8\u518C\u65B9\u6CD5\u65F6\u51FA\u9519\uFF1A"));
error(e);
throw e;
}
}
if (index >= 0) {
handlers.splice(index, 1);
}
};
};
HandlersController.prototype.lockHandlerNames = function () {
this.locked = true;
};
HandlersController.prototype.resetAllImpl = function () {
this.handlerImpl = {};
};
HandlersController.prototype.getHandlersByName = function (name, context) {
var _this = this;
if (!context)
throw new Error('context is required');
return this.handlerImpl[name].filter(function (handler) {
return _this.filterContext(handler.bindContext, context);
});
};
HandlersController.prototype.callHandlers = function (name, context, args) {
var controller = this;
var handlers = (controller.handlerImpl[name] || []).filter(function (handler) {
var targetCtx = controller.filterContext(handler === null || handler === void 0 ? void 0 : handler.bindContext, context);
return !!targetCtx;
}); // 过滤并复制出来，防止执行过程中有人往里面塞东西造成乱序
var callId = "".concat(controller.elementTag, "-handlerCalled-").concat(name, "-").concat(Math.floor(Math.random() * 1000));
var tipText = "".concat(callId, " - handlers count ").concat(handlers.length);
log(Date.now(), tipText);
var returnValue;
for (var i = 0; i < handlers.length; i++) {
log(Date.now(), "".concat(tipText, " - executing ").concat(i + 1, "/").concat(handlers.length));
time(callId);
var handler = handlers[i];
var ret = handler.fn.apply(context, args);
if (i === 0) {
// 只返回第一个
returnValue = ret;
}
timeEnd(callId);
}
return returnValue;
};
// 返回给 appx 的可能是一个 Promise，无论 appx 等不等，这里都会串行执行
HandlersController.prototype.getHandlersImplProxy = function () {
var _this = this;
if (!this.locked) {
throw new Error('please lock the handler names first');
}
var handlers = this.handlerNames.reduce(function (acc, handlerName) {
var controller = _this;
//@ts-expect-error
acc[handlerName] = function () {
var args = [];
for (var _i = 0; _i < arguments.length; _i++) {
args[_i] = arguments[_i];
}
// 这里要保留调用方的 this
var appxCaller = this;
if (!appxCaller) {
console.warn('cannot find appx caller instance');
}
// deriveData 的时候，异步可能会有问题，直接改同步看看疗效
var err;
var ret;
try {
ret = controller.callHandlers(handlerName, appxCaller, args);
}
catch (e) {
err = e;
}
// await unlock();
// 防止后续所有事情被死锁
if (err)
throw err;
// setTimeout(() => {
// unlock();
// }, 0);
return ret;
// return Promise.resolve(
// (async () => {
// })(),
// );
};
return acc;
}, {});
return handlers;
};
//@ts-expect-error
HandlersController.prototype.filterContext = function (bindContext, nowContext) {
if (typeof bindContext === 'function') {
if (!bindContext(nowContext)) {
return false;
}
}
else if (bindContext !== nowContext) {
return false;
}
return nowContext;
};
return HandlersController;
}());
export default HandlersController;