electron-rpc-server
Advanced tools
Comparing version 1.0.1 to 1.1.0
@@ -1,5 +0,6 @@ | ||
import { Event, IpcMain, IpcRenderer } from 'electron'; | ||
import { Resolver, ChannelsNamesParameters, Request } from 'electron-rpc-types'; | ||
import { IpcMain, IpcRenderer } from 'electron'; | ||
import { Resolver, ChannelsNamesParameters } from 'electron-rpc-types'; | ||
import { Loggable } from 'electron-rpc-utils'; | ||
/** Electron RPC Server */ | ||
export declare class Server { | ||
export declare class Server extends Loggable { | ||
/** RPC resolver */ | ||
@@ -22,10 +23,10 @@ private resolver; | ||
/** Common requests handler */ | ||
protected onRequest(event: Event, { type, ...rest }: Request): Promise<void>; | ||
private onRequest; | ||
/** Unblocking requests handler */ | ||
protected onNonblockingRequest(event: Event, request: Request): Promise<void>; | ||
private onNonblockingRequest; | ||
/** Blocking requests handler */ | ||
protected onBlockingRequest(event: Event, request: Request): Promise<void>; | ||
private onBlockingRequest; | ||
/** Common process requestor */ | ||
protected processRequest({ sender }: Event, { uuid, type, procedure, args }: Request): Promise<void>; | ||
private processRequest; | ||
} | ||
//# sourceMappingURL=Server.d.ts.map |
@@ -8,11 +8,14 @@ "use strict"; | ||
/** Electron RPC Server */ | ||
var Server = /** @class */ (function () { | ||
var Server = /** @class */ (function (_super) { | ||
tslib_1.__extends(Server, _super); | ||
/** @constructor */ | ||
function Server(bus, resolver, channels) { | ||
var _this = _super.call(this) || this; | ||
var _a = electron_rpc_utils_1.resolve(channels), rpcRequestChannelName = _a.rpcRequestChannelName, rpcResponseChannelName = _a.rpcResponseChannelName; | ||
this.rpcRequestChannelName = rpcRequestChannelName; | ||
this.rpcResponseChannelName = rpcResponseChannelName; | ||
this.resolver = resolver; | ||
this.bus = bus; | ||
this.queue = new TaskQueue_1.TaskQueue(); | ||
_this.rpcRequestChannelName = rpcRequestChannelName; | ||
_this.rpcResponseChannelName = rpcResponseChannelName; | ||
_this.resolver = resolver; | ||
_this.bus = bus; | ||
_this.queue = new TaskQueue_1.TaskQueue(); | ||
return _this; | ||
} | ||
@@ -29,3 +32,3 @@ /** Start server */ | ||
Server.prototype.onRequest = function (event, _a) { | ||
var type = _a.type, rest = tslib_1.__rest(_a, ["type"]); | ||
var type = _a.type, procedure = _a.procedure, uuid = _a.uuid, rest = tslib_1.__rest(_a, ["type", "procedure", "uuid"]); | ||
return tslib_1.__awaiter(this, void 0, void 0, function () { | ||
@@ -36,2 +39,3 @@ var _b; | ||
case 0: | ||
this.logRequest({ type: type, procedure: procedure, uuid: uuid }, rest.args); | ||
_b = type; | ||
@@ -43,7 +47,7 @@ switch (_b) { | ||
return [3 /*break*/, 3]; | ||
case 1: return [4 /*yield*/, this.onNonblockingRequest(event, tslib_1.__assign({ type: type }, rest))]; | ||
case 1: return [4 /*yield*/, this.onNonblockingRequest(event, tslib_1.__assign({ type: type, procedure: procedure, uuid: uuid }, rest))]; | ||
case 2: | ||
_c.sent(); | ||
return [3 /*break*/, 5]; | ||
case 3: return [4 /*yield*/, this.onBlockingRequest(event, tslib_1.__assign({ type: type }, rest))]; | ||
case 3: return [4 /*yield*/, this.onBlockingRequest(event, tslib_1.__assign({ type: type, procedure: procedure, uuid: uuid }, rest))]; | ||
case 4: | ||
@@ -104,2 +108,3 @@ _c.sent(); | ||
_d.result = _e.sent(); | ||
this.logSuccess({ uuid: uuid, type: type, procedure: procedure }, args, response.result); | ||
return [3 /*break*/, 4]; | ||
@@ -109,2 +114,3 @@ case 3: | ||
response.error = String(error_1); | ||
this.logError({ uuid: uuid, type: type, procedure: procedure }, args, response.error); | ||
return [3 /*break*/, 4]; | ||
@@ -126,3 +132,3 @@ case 4: | ||
return Server; | ||
}()); | ||
}(electron_rpc_utils_1.Loggable)); | ||
exports.Server = Server; |
@@ -1,2 +0,2 @@ | ||
window.ElectronRPC=function(e){var t={};function n(r){if(t[r])return t[r].exports;var o=t[r]={i:r,l:!1,exports:{}};return e[r].call(o.exports,o,o.exports,n),o.l=!0,o.exports}return n.m=e,n.c=t,n.d=function(e,t,r){n.o(e,t)||Object.defineProperty(e,t,{enumerable:!0,get:r})},n.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},n.t=function(e,t){if(1&t&&(e=n(e)),8&t)return e;if(4&t&&"object"==typeof e&&e&&e.__esModule)return e;var r=Object.create(null);if(n.r(r),Object.defineProperty(r,"default",{enumerable:!0,value:e}),2&t&&"string"!=typeof e)for(var o in e)n.d(r,o,function(t){return e[t]}.bind(null,o));return r},n.n=function(e){var t=e&&e.__esModule?function(){return e.default}:function(){return e};return n.d(t,"a",t),t},n.o=function(e,t){return Object.prototype.hasOwnProperty.call(e,t)},n.p="",n(n.s=3)}([function(e,t,n){"use strict";n.r(t),n.d(t,"__extends",function(){return o}),n.d(t,"__assign",function(){return i}),n.d(t,"__rest",function(){return s}),n.d(t,"__decorate",function(){return u}),n.d(t,"__param",function(){return c}),n.d(t,"__metadata",function(){return a}),n.d(t,"__awaiter",function(){return l}),n.d(t,"__generator",function(){return f}),n.d(t,"__exportStar",function(){return p}),n.d(t,"__values",function(){return h}),n.d(t,"__read",function(){return v}),n.d(t,"__spread",function(){return y}),n.d(t,"__await",function(){return d}),n.d(t,"__asyncGenerator",function(){return _}),n.d(t,"__asyncDelegator",function(){return b}),n.d(t,"__asyncValues",function(){return m}),n.d(t,"__makeTemplateObject",function(){return w}),n.d(t,"__importStar",function(){return g}),n.d(t,"__importDefault",function(){return O}); | ||
window.ElectronRPC=function(e){var t={};function n(r){if(t[r])return t[r].exports;var o=t[r]={i:r,l:!1,exports:{}};return e[r].call(o.exports,o,o.exports,n),o.l=!0,o.exports}return n.m=e,n.c=t,n.d=function(e,t,r){n.o(e,t)||Object.defineProperty(e,t,{enumerable:!0,get:r})},n.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},n.t=function(e,t){if(1&t&&(e=n(e)),8&t)return e;if(4&t&&"object"==typeof e&&e&&e.__esModule)return e;var r=Object.create(null);if(n.r(r),Object.defineProperty(r,"default",{enumerable:!0,value:e}),2&t&&"string"!=typeof e)for(var o in e)n.d(r,o,function(t){return e[t]}.bind(null,o));return r},n.n=function(e){var t=e&&e.__esModule?function(){return e.default}:function(){return e};return n.d(t,"a",t),t},n.o=function(e,t){return Object.prototype.hasOwnProperty.call(e,t)},n.p="",n(n.s=3)}([function(e,t,n){"use strict";n.r(t),n.d(t,"__extends",function(){return o}),n.d(t,"__assign",function(){return i}),n.d(t,"__rest",function(){return s}),n.d(t,"__decorate",function(){return u}),n.d(t,"__param",function(){return c}),n.d(t,"__metadata",function(){return a}),n.d(t,"__awaiter",function(){return l}),n.d(t,"__generator",function(){return f}),n.d(t,"__exportStar",function(){return p}),n.d(t,"__values",function(){return h}),n.d(t,"__read",function(){return y}),n.d(t,"__spread",function(){return v}),n.d(t,"__await",function(){return d}),n.d(t,"__asyncGenerator",function(){return _}),n.d(t,"__asyncDelegator",function(){return b}),n.d(t,"__asyncValues",function(){return g}),n.d(t,"__makeTemplateObject",function(){return m}),n.d(t,"__importStar",function(){return w}),n.d(t,"__importDefault",function(){return O}); | ||
/*! ***************************************************************************** | ||
@@ -16,2 +16,2 @@ Copyright (c) Microsoft Corporation. All rights reserved. | ||
***************************************************************************** */ | ||
var r=function(e,t){return(r=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(e,t){e.__proto__=t}||function(e,t){for(var n in t)t.hasOwnProperty(n)&&(e[n]=t[n])})(e,t)};function o(e,t){function n(){this.constructor=e}r(e,t),e.prototype=null===t?Object.create(t):(n.prototype=t.prototype,new n)}var i=function(){return(i=Object.assign||function(e){for(var t,n=1,r=arguments.length;n<r;n++)for(var o in t=arguments[n])Object.prototype.hasOwnProperty.call(t,o)&&(e[o]=t[o]);return e}).apply(this,arguments)};function s(e,t){var n={};for(var r in e)Object.prototype.hasOwnProperty.call(e,r)&&t.indexOf(r)<0&&(n[r]=e[r]);if(null!=e&&"function"==typeof Object.getOwnPropertySymbols){var o=0;for(r=Object.getOwnPropertySymbols(e);o<r.length;o++)t.indexOf(r[o])<0&&(n[r[o]]=e[r[o]])}return n}function u(e,t,n,r){var o,i=arguments.length,s=i<3?t:null===r?r=Object.getOwnPropertyDescriptor(t,n):r;if("object"==typeof Reflect&&"function"==typeof Reflect.decorate)s=Reflect.decorate(e,t,n,r);else for(var u=e.length-1;u>=0;u--)(o=e[u])&&(s=(i<3?o(s):i>3?o(t,n,s):o(t,n))||s);return i>3&&s&&Object.defineProperty(t,n,s),s}function c(e,t){return function(n,r){t(n,r,e)}}function a(e,t){if("object"==typeof Reflect&&"function"==typeof Reflect.metadata)return Reflect.metadata(e,t)}function l(e,t,n,r){return new(n||(n=Promise))(function(o,i){function s(e){try{c(r.next(e))}catch(e){i(e)}}function u(e){try{c(r.throw(e))}catch(e){i(e)}}function c(e){e.done?o(e.value):new n(function(t){t(e.value)}).then(s,u)}c((r=r.apply(e,t||[])).next())})}function f(e,t){var n,r,o,i,s={label:0,sent:function(){if(1&o[0])throw o[1];return o[1]},trys:[],ops:[]};return i={next:u(0),throw:u(1),return:u(2)},"function"==typeof Symbol&&(i[Symbol.iterator]=function(){return this}),i;function u(i){return function(u){return function(i){if(n)throw new TypeError("Generator is already executing.");for(;s;)try{if(n=1,r&&(o=2&i[0]?r.return:i[0]?r.throw||((o=r.return)&&o.call(r),0):r.next)&&!(o=o.call(r,i[1])).done)return o;switch(r=0,o&&(i=[2&i[0],o.value]),i[0]){case 0:case 1:o=i;break;case 4:return s.label++,{value:i[1],done:!1};case 5:s.label++,r=i[1],i=[0];continue;case 7:i=s.ops.pop(),s.trys.pop();continue;default:if(!(o=(o=s.trys).length>0&&o[o.length-1])&&(6===i[0]||2===i[0])){s=0;continue}if(3===i[0]&&(!o||i[1]>o[0]&&i[1]<o[3])){s.label=i[1];break}if(6===i[0]&&s.label<o[1]){s.label=o[1],o=i;break}if(o&&s.label<o[2]){s.label=o[2],s.ops.push(i);break}o[2]&&s.ops.pop(),s.trys.pop();continue}i=t.call(e,s)}catch(e){i=[6,e],r=0}finally{n=o=0}if(5&i[0])throw i[1];return{value:i[0]?i[1]:void 0,done:!0}}([i,u])}}}function p(e,t){for(var n in e)t.hasOwnProperty(n)||(t[n]=e[n])}function h(e){var t="function"==typeof Symbol&&e[Symbol.iterator],n=0;return t?t.call(e):{next:function(){return e&&n>=e.length&&(e=void 0),{value:e&&e[n++],done:!e}}}}function v(e,t){var n="function"==typeof Symbol&&e[Symbol.iterator];if(!n)return e;var r,o,i=n.call(e),s=[];try{for(;(void 0===t||t-- >0)&&!(r=i.next()).done;)s.push(r.value)}catch(e){o={error:e}}finally{try{r&&!r.done&&(n=i.return)&&n.call(i)}finally{if(o)throw o.error}}return s}function y(){for(var e=[],t=0;t<arguments.length;t++)e=e.concat(v(arguments[t]));return e}function d(e){return this instanceof d?(this.v=e,this):new d(e)}function _(e,t,n){if(!Symbol.asyncIterator)throw new TypeError("Symbol.asyncIterator is not defined.");var r,o=n.apply(e,t||[]),i=[];return r={},s("next"),s("throw"),s("return"),r[Symbol.asyncIterator]=function(){return this},r;function s(e){o[e]&&(r[e]=function(t){return new Promise(function(n,r){i.push([e,t,n,r])>1||u(e,t)})})}function u(e,t){try{!function(e){e.value instanceof d?Promise.resolve(e.value.v).then(c,a):l(i[0][2],e)}(o[e](t))}catch(e){l(i[0][3],e)}}function c(e){u("next",e)}function a(e){u("throw",e)}function l(e,t){e(t),i.shift(),i.length&&u(i[0][0],i[0][1])}}function b(e){var t,n;return t={},r("next"),r("throw",function(e){throw e}),r("return"),t[Symbol.iterator]=function(){return this},t;function r(r,o){t[r]=e[r]?function(t){return(n=!n)?{value:d(e[r](t)),done:"return"===r}:o?o(t):t}:o}}function m(e){if(!Symbol.asyncIterator)throw new TypeError("Symbol.asyncIterator is not defined.");var t,n=e[Symbol.asyncIterator];return n?n.call(e):(e=h(e),t={},r("next"),r("throw"),r("return"),t[Symbol.asyncIterator]=function(){return this},t);function r(n){t[n]=e[n]&&function(t){return new Promise(function(r,o){(function(e,t,n,r){Promise.resolve(r).then(function(t){e({value:t,done:n})},t)})(r,o,(t=e[n](t)).done,t.value)})}}}function w(e,t){return Object.defineProperty?Object.defineProperty(e,"raw",{value:t}):e.raw=t,e}function g(e){if(e&&e.__esModule)return e;var t={};if(null!=e)for(var n in e)Object.hasOwnProperty.call(e,n)&&(t[n]=e[n]);return t.default=e,t}function O(e){return e&&e.__esModule?e:{default:e}}},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0}),t.isNil=function(e){return null===e||void 0===e}},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0}),function(e){e.START="TaskEventType.START",e.SUCCESS="TaskEventType.SUCCESS",e.ERROR="TaskEventType.ERROR",e.END="TaskEventType.END"}(t.TaskEventType||(t.TaskEventType={}))},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0});var r=n(4);t.Server=r.Server},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0});var r=n(0),o=n(5),i=n(6),s=n(8),u=function(){function e(e,t,n){var r=i.resolve(n),o=r.rpcRequestChannelName,u=r.rpcResponseChannelName;this.rpcRequestChannelName=o,this.rpcResponseChannelName=u,this.resolver=t,this.bus=e,this.queue=new s.TaskQueue}return e.prototype.start=function(){this.bus.on(this.rpcRequestChannelName,this.onRequest)},e.prototype.stop=function(){this.bus.removeListener(this.rpcRequestChannelName,this.onRequest)},e.prototype.onRequest=function(e,t){var n=t.type,o=r.__rest(t,["type"]);return r.__awaiter(this,void 0,void 0,function(){return r.__generator(this,function(t){switch(t.label){case 0:switch(n){case"EnvelopeType.NONBLOCKING":return[3,1];case"EnvelopeType.BLOCKING":return[3,3]}return[3,3];case 1:return[4,this.onNonblockingRequest(e,r.__assign({type:n},o))];case 2:return t.sent(),[3,5];case 3:return[4,this.onBlockingRequest(e,r.__assign({type:n},o))];case 4:return t.sent(),[3,5];case 5:return[2]}})})},e.prototype.onNonblockingRequest=function(e,t){return r.__awaiter(this,void 0,void 0,function(){return r.__generator(this,function(n){switch(n.label){case 0:return[4,this.processRequest(e,t)];case 1:return n.sent(),[2]}})})},e.prototype.onBlockingRequest=function(e,t){return r.__awaiter(this,void 0,void 0,function(){return r.__generator(this,function(n){return this.queue.push(this.processRequest,e,t),[2]})})},e.prototype.processRequest=function(e,t){var n=e.sender,o=t.uuid,s=t.type,u=t.procedure,c=t.args;return r.__awaiter(this,void 0,void 0,function(){var e,t,a,l;return r.__generator(this,function(r){switch(r.label){case 0:return t={uuid:o,type:s,procedure:u,error:null,result:null},i.isNil(this.resolver[u])?(t.error='Procedure "'+u+'" not found',[3,5]):[3,1];case 1:return r.trys.push([1,3,,4]),a=t,[4,(e=this.resolver)[u].apply(e,c)];case 2:return a.result=r.sent(),[3,4];case 3:return l=r.sent(),t.error=String(l),[3,4];case 4:n.send(this.rpcResponseChannelName,t),r.label=5;case 5:return[2]}})})},r.__decorate([o.default],e.prototype,"onRequest",null),r.__decorate([o.default],e.prototype,"processRequest",null),e}();t.Server=u},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0});var r="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e};function o(e,t,n){var o=n.value;if("function"!=typeof o)throw new Error("@autobind decorator can only be applied to methods not: "+(void 0===o?"undefined":r(o)));var i=!1;return{configurable:!0,get:function(){if(i||this===e.prototype||this.hasOwnProperty(t)||"function"!=typeof o)return o;var n=o.bind(this);return i=!0,Object.defineProperty(this,t,{configurable:!0,get:function(){return n},set:function(e){o=e,delete this[t]}}),i=!1,n},set:function(e){o=e}}}t.default=function(){return 1===arguments.length?function(e){var t=void 0;"undefined"!=typeof Reflect&&"function"==typeof Reflect.ownKeys?t=Reflect.ownKeys(e.prototype):(t=Object.getOwnPropertyNames(e.prototype),"function"==typeof Object.getOwnPropertySymbols&&(t=t.concat(Object.getOwnPropertySymbols(e.prototype))));return t.forEach(function(t){if("constructor"!==t){var n=Object.getOwnPropertyDescriptor(e.prototype,t);"function"==typeof n.value&&Object.defineProperty(e.prototype,t,o(e,t,n))}}),e}.apply(void 0,arguments):o.apply(void 0,arguments)}},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0});var r=n(1);t.isNil=r.isNil;var o=n(7);t.resolve=o.resolve},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0});var r=n(1);t.resolve=function(e){return{rpcRequestChannelName:r.isNil(e)||r.isNil(e.rpcRequestChannelName)?"RpcChannelDefaultNames.REQUEST":e.rpcRequestChannelName,rpcResponseChannelName:r.isNil(e)||r.isNil(e.rpcResponseChannelName)?"RpcChannelDefaultNames.RESPONSE":e.rpcResponseChannelName}}},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0});var r=n(0),o=n(9),i=n(2),s=function(){function e(){this.queue=[]}return e.prototype.push=function(e){for(var t=[],n=1;n<arguments.length;n++)t[n-1]=arguments[n];return r.__awaiter(this,void 0,void 0,function(){var n,s,u,c,a=this;return r.__generator(this,function(r){switch(r.label){case 0:return n=new(o.Task.bind.apply(o.Task,[void 0,e].concat(t))),s=new Promise(function(e){return n.once(i.TaskEventType.END,function(n,r){a.queue.shift(),e({error:n,result:r,args:t})})}),this.queue.push(n),this.queue.length>1?(u=this.queue.length-1,c=u-1,this.queue[c].once(i.TaskEventType.END,function(){n.run()})):n.run(),[4,s];case 1:return[2,r.sent()]}})})},e}();t.TaskQueue=s},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0});var r=n(0),o=n(10),i=n(2),s=function(e){function t(t){for(var n=[],r=1;r<arguments.length;r++)n[r-1]=arguments[r];var o=e.call(this)||this;return o.body=t,o.args=n,o}return r.__extends(t,e),t.prototype.run=function(){return r.__awaiter(this,void 0,void 0,function(){var e,t,n;return r.__generator(this,function(r){switch(r.label){case 0:e=null,t=null,this.emit(i.TaskEventType.START),r.label=1;case 1:return r.trys.push([1,3,,4]),[4,this.body.apply(this,this.args)];case 2:return e=r.sent(),this.emit(i.TaskEventType.SUCCESS,e),[3,4];case 3:return n=r.sent(),t=String(n),this.emit(i.TaskEventType.ERROR,t),[3,4];case 4:return this.emit(i.TaskEventType.END,t,e),[2]}})})},t}(o.EventEmitter);t.Task=s},function(e,t){function n(){this._events=this._events||{},this._maxListeners=this._maxListeners||void 0}function r(e){return"function"==typeof e}function o(e){return"object"==typeof e&&null!==e}function i(e){return void 0===e}e.exports=n,n.EventEmitter=n,n.prototype._events=void 0,n.prototype._maxListeners=void 0,n.defaultMaxListeners=10,n.prototype.setMaxListeners=function(e){if(!function(e){return"number"==typeof e}(e)||e<0||isNaN(e))throw TypeError("n must be a positive number");return this._maxListeners=e,this},n.prototype.emit=function(e){var t,n,s,u,c,a;if(this._events||(this._events={}),"error"===e&&(!this._events.error||o(this._events.error)&&!this._events.error.length)){if((t=arguments[1])instanceof Error)throw t;var l=new Error('Uncaught, unspecified "error" event. ('+t+")");throw l.context=t,l}if(i(n=this._events[e]))return!1;if(r(n))switch(arguments.length){case 1:n.call(this);break;case 2:n.call(this,arguments[1]);break;case 3:n.call(this,arguments[1],arguments[2]);break;default:u=Array.prototype.slice.call(arguments,1),n.apply(this,u)}else if(o(n))for(u=Array.prototype.slice.call(arguments,1),s=(a=n.slice()).length,c=0;c<s;c++)a[c].apply(this,u);return!0},n.prototype.addListener=function(e,t){var s;if(!r(t))throw TypeError("listener must be a function");return this._events||(this._events={}),this._events.newListener&&this.emit("newListener",e,r(t.listener)?t.listener:t),this._events[e]?o(this._events[e])?this._events[e].push(t):this._events[e]=[this._events[e],t]:this._events[e]=t,o(this._events[e])&&!this._events[e].warned&&(s=i(this._maxListeners)?n.defaultMaxListeners:this._maxListeners)&&s>0&&this._events[e].length>s&&(this._events[e].warned=!0,console.error("(node) warning: possible EventEmitter memory leak detected. %d listeners added. Use emitter.setMaxListeners() to increase limit.",this._events[e].length),"function"==typeof console.trace&&console.trace()),this},n.prototype.on=n.prototype.addListener,n.prototype.once=function(e,t){if(!r(t))throw TypeError("listener must be a function");var n=!1;function o(){this.removeListener(e,o),n||(n=!0,t.apply(this,arguments))}return o.listener=t,this.on(e,o),this},n.prototype.removeListener=function(e,t){var n,i,s,u;if(!r(t))throw TypeError("listener must be a function");if(!this._events||!this._events[e])return this;if(s=(n=this._events[e]).length,i=-1,n===t||r(n.listener)&&n.listener===t)delete this._events[e],this._events.removeListener&&this.emit("removeListener",e,t);else if(o(n)){for(u=s;u-- >0;)if(n[u]===t||n[u].listener&&n[u].listener===t){i=u;break}if(i<0)return this;1===n.length?(n.length=0,delete this._events[e]):n.splice(i,1),this._events.removeListener&&this.emit("removeListener",e,t)}return this},n.prototype.removeAllListeners=function(e){var t,n;if(!this._events)return this;if(!this._events.removeListener)return 0===arguments.length?this._events={}:this._events[e]&&delete this._events[e],this;if(0===arguments.length){for(t in this._events)"removeListener"!==t&&this.removeAllListeners(t);return this.removeAllListeners("removeListener"),this._events={},this}if(r(n=this._events[e]))this.removeListener(e,n);else if(n)for(;n.length;)this.removeListener(e,n[n.length-1]);return delete this._events[e],this},n.prototype.listeners=function(e){return this._events&&this._events[e]?r(this._events[e])?[this._events[e]]:this._events[e].slice():[]},n.prototype.listenerCount=function(e){if(this._events){var t=this._events[e];if(r(t))return 1;if(t)return t.length}return 0},n.listenerCount=function(e,t){return e.listenerCount(t)}}]); | ||
var r=function(e,t){return(r=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(e,t){e.__proto__=t}||function(e,t){for(var n in t)t.hasOwnProperty(n)&&(e[n]=t[n])})(e,t)};function o(e,t){function n(){this.constructor=e}r(e,t),e.prototype=null===t?Object.create(t):(n.prototype=t.prototype,new n)}var i=function(){return(i=Object.assign||function(e){for(var t,n=1,r=arguments.length;n<r;n++)for(var o in t=arguments[n])Object.prototype.hasOwnProperty.call(t,o)&&(e[o]=t[o]);return e}).apply(this,arguments)};function s(e,t){var n={};for(var r in e)Object.prototype.hasOwnProperty.call(e,r)&&t.indexOf(r)<0&&(n[r]=e[r]);if(null!=e&&"function"==typeof Object.getOwnPropertySymbols){var o=0;for(r=Object.getOwnPropertySymbols(e);o<r.length;o++)t.indexOf(r[o])<0&&(n[r[o]]=e[r[o]])}return n}function u(e,t,n,r){var o,i=arguments.length,s=i<3?t:null===r?r=Object.getOwnPropertyDescriptor(t,n):r;if("object"==typeof Reflect&&"function"==typeof Reflect.decorate)s=Reflect.decorate(e,t,n,r);else for(var u=e.length-1;u>=0;u--)(o=e[u])&&(s=(i<3?o(s):i>3?o(t,n,s):o(t,n))||s);return i>3&&s&&Object.defineProperty(t,n,s),s}function c(e,t){return function(n,r){t(n,r,e)}}function a(e,t){if("object"==typeof Reflect&&"function"==typeof Reflect.metadata)return Reflect.metadata(e,t)}function l(e,t,n,r){return new(n||(n=Promise))(function(o,i){function s(e){try{c(r.next(e))}catch(e){i(e)}}function u(e){try{c(r.throw(e))}catch(e){i(e)}}function c(e){e.done?o(e.value):new n(function(t){t(e.value)}).then(s,u)}c((r=r.apply(e,t||[])).next())})}function f(e,t){var n,r,o,i,s={label:0,sent:function(){if(1&o[0])throw o[1];return o[1]},trys:[],ops:[]};return i={next:u(0),throw:u(1),return:u(2)},"function"==typeof Symbol&&(i[Symbol.iterator]=function(){return this}),i;function u(i){return function(u){return function(i){if(n)throw new TypeError("Generator is already executing.");for(;s;)try{if(n=1,r&&(o=2&i[0]?r.return:i[0]?r.throw||((o=r.return)&&o.call(r),0):r.next)&&!(o=o.call(r,i[1])).done)return o;switch(r=0,o&&(i=[2&i[0],o.value]),i[0]){case 0:case 1:o=i;break;case 4:return s.label++,{value:i[1],done:!1};case 5:s.label++,r=i[1],i=[0];continue;case 7:i=s.ops.pop(),s.trys.pop();continue;default:if(!(o=(o=s.trys).length>0&&o[o.length-1])&&(6===i[0]||2===i[0])){s=0;continue}if(3===i[0]&&(!o||i[1]>o[0]&&i[1]<o[3])){s.label=i[1];break}if(6===i[0]&&s.label<o[1]){s.label=o[1],o=i;break}if(o&&s.label<o[2]){s.label=o[2],s.ops.push(i);break}o[2]&&s.ops.pop(),s.trys.pop();continue}i=t.call(e,s)}catch(e){i=[6,e],r=0}finally{n=o=0}if(5&i[0])throw i[1];return{value:i[0]?i[1]:void 0,done:!0}}([i,u])}}}function p(e,t){for(var n in e)t.hasOwnProperty(n)||(t[n]=e[n])}function h(e){var t="function"==typeof Symbol&&e[Symbol.iterator],n=0;return t?t.call(e):{next:function(){return e&&n>=e.length&&(e=void 0),{value:e&&e[n++],done:!e}}}}function y(e,t){var n="function"==typeof Symbol&&e[Symbol.iterator];if(!n)return e;var r,o,i=n.call(e),s=[];try{for(;(void 0===t||t-- >0)&&!(r=i.next()).done;)s.push(r.value)}catch(e){o={error:e}}finally{try{r&&!r.done&&(n=i.return)&&n.call(i)}finally{if(o)throw o.error}}return s}function v(){for(var e=[],t=0;t<arguments.length;t++)e=e.concat(y(arguments[t]));return e}function d(e){return this instanceof d?(this.v=e,this):new d(e)}function _(e,t,n){if(!Symbol.asyncIterator)throw new TypeError("Symbol.asyncIterator is not defined.");var r,o=n.apply(e,t||[]),i=[];return r={},s("next"),s("throw"),s("return"),r[Symbol.asyncIterator]=function(){return this},r;function s(e){o[e]&&(r[e]=function(t){return new Promise(function(n,r){i.push([e,t,n,r])>1||u(e,t)})})}function u(e,t){try{!function(e){e.value instanceof d?Promise.resolve(e.value.v).then(c,a):l(i[0][2],e)}(o[e](t))}catch(e){l(i[0][3],e)}}function c(e){u("next",e)}function a(e){u("throw",e)}function l(e,t){e(t),i.shift(),i.length&&u(i[0][0],i[0][1])}}function b(e){var t,n;return t={},r("next"),r("throw",function(e){throw e}),r("return"),t[Symbol.iterator]=function(){return this},t;function r(r,o){t[r]=e[r]?function(t){return(n=!n)?{value:d(e[r](t)),done:"return"===r}:o?o(t):t}:o}}function g(e){if(!Symbol.asyncIterator)throw new TypeError("Symbol.asyncIterator is not defined.");var t,n=e[Symbol.asyncIterator];return n?n.call(e):(e=h(e),t={},r("next"),r("throw"),r("return"),t[Symbol.asyncIterator]=function(){return this},t);function r(n){t[n]=e[n]&&function(t){return new Promise(function(r,o){(function(e,t,n,r){Promise.resolve(r).then(function(t){e({value:t,done:n})},t)})(r,o,(t=e[n](t)).done,t.value)})}}}function m(e,t){return Object.defineProperty?Object.defineProperty(e,"raw",{value:t}):e.raw=t,e}function w(e){if(e&&e.__esModule)return e;var t={};if(null!=e)for(var n in e)Object.hasOwnProperty.call(e,n)&&(t[n]=e[n]);return t.default=e,t}function O(e){return e&&e.__esModule?e:{default:e}}},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0}),t.isNil=function(e){return null===e||void 0===e}},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0}),function(e){e.START="TaskEventType.START",e.SUCCESS="TaskEventType.SUCCESS",e.ERROR="TaskEventType.ERROR",e.END="TaskEventType.END"}(t.TaskEventType||(t.TaskEventType={}))},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0});var r=n(4);t.Server=r.Server},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0});var r=n(0),o=n(5),i=n(6),s=n(9),u=function(e){function t(t,n,r){var o=e.call(this)||this,u=i.resolve(r),c=u.rpcRequestChannelName,a=u.rpcResponseChannelName;return o.rpcRequestChannelName=c,o.rpcResponseChannelName=a,o.resolver=n,o.bus=t,o.queue=new s.TaskQueue,o}return r.__extends(t,e),t.prototype.start=function(){this.bus.on(this.rpcRequestChannelName,this.onRequest)},t.prototype.stop=function(){this.bus.removeListener(this.rpcRequestChannelName,this.onRequest)},t.prototype.onRequest=function(e,t){var n=t.type,o=t.procedure,i=t.uuid,s=r.__rest(t,["type","procedure","uuid"]);return r.__awaiter(this,void 0,void 0,function(){return r.__generator(this,function(t){switch(t.label){case 0:switch(this.logRequest({type:n,procedure:o,uuid:i},s.args),n){case"EnvelopeType.NONBLOCKING":return[3,1];case"EnvelopeType.BLOCKING":return[3,3]}return[3,3];case 1:return[4,this.onNonblockingRequest(e,r.__assign({type:n,procedure:o,uuid:i},s))];case 2:return t.sent(),[3,5];case 3:return[4,this.onBlockingRequest(e,r.__assign({type:n,procedure:o,uuid:i},s))];case 4:return t.sent(),[3,5];case 5:return[2]}})})},t.prototype.onNonblockingRequest=function(e,t){return r.__awaiter(this,void 0,void 0,function(){return r.__generator(this,function(n){switch(n.label){case 0:return[4,this.processRequest(e,t)];case 1:return n.sent(),[2]}})})},t.prototype.onBlockingRequest=function(e,t){return r.__awaiter(this,void 0,void 0,function(){return r.__generator(this,function(n){return this.queue.push(this.processRequest,e,t),[2]})})},t.prototype.processRequest=function(e,t){var n=e.sender,o=t.uuid,s=t.type,u=t.procedure,c=t.args;return r.__awaiter(this,void 0,void 0,function(){var e,t,a,l;return r.__generator(this,function(r){switch(r.label){case 0:return t={uuid:o,type:s,procedure:u,error:null,result:null},i.isNil(this.resolver[u])?(t.error='Procedure "'+u+'" not found',[3,5]):[3,1];case 1:return r.trys.push([1,3,,4]),a=t,[4,(e=this.resolver)[u].apply(e,c)];case 2:return a.result=r.sent(),this.logSuccess({uuid:o,type:s,procedure:u},c,t.result),[3,4];case 3:return l=r.sent(),t.error=String(l),this.logError({uuid:o,type:s,procedure:u},c,t.error),[3,4];case 4:n.send(this.rpcResponseChannelName,t),r.label=5;case 5:return[2]}})})},r.__decorate([o.default],t.prototype,"onRequest",null),r.__decorate([o.default],t.prototype,"processRequest",null),t}(i.Loggable);t.Server=u},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0});var r="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e};function o(e,t,n){var o=n.value;if("function"!=typeof o)throw new Error("@autobind decorator can only be applied to methods not: "+(void 0===o?"undefined":r(o)));var i=!1;return{configurable:!0,get:function(){if(i||this===e.prototype||this.hasOwnProperty(t)||"function"!=typeof o)return o;var n=o.bind(this);return i=!0,Object.defineProperty(this,t,{configurable:!0,get:function(){return n},set:function(e){o=e,delete this[t]}}),i=!1,n},set:function(e){o=e}}}t.default=function(){return 1===arguments.length?function(e){var t=void 0;"undefined"!=typeof Reflect&&"function"==typeof Reflect.ownKeys?t=Reflect.ownKeys(e.prototype):(t=Object.getOwnPropertyNames(e.prototype),"function"==typeof Object.getOwnPropertySymbols&&(t=t.concat(Object.getOwnPropertySymbols(e.prototype))));return t.forEach(function(t){if("constructor"!==t){var n=Object.getOwnPropertyDescriptor(e.prototype,t);"function"==typeof n.value&&Object.defineProperty(e.prototype,t,o(e,t,n))}}),e}.apply(void 0,arguments):o.apply(void 0,arguments)}},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0});var r=n(7);t.Loggable=r.Loggable;var o=n(1);t.isNil=o.isNil;var i=n(8);t.resolve=i.resolve},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0});var r=n(1),o=function(){function e(){this.requestLogger=null,this.successLogger=null,this.errorLogger=null}return e.prototype.setRequestLogger=function(e){this.requestLogger=e},e.prototype.setSuccessLogger=function(e){this.successLogger=e},e.prototype.setErrorLogger=function(e){this.errorLogger=e},e.prototype.logRequest=function(e,t){r.isNil(this.requestLogger)||this.requestLogger(e,t)},e.prototype.logSuccess=function(e,t,n){r.isNil(this.successLogger)||this.successLogger(e,t,n)},e.prototype.logError=function(e,t,n){r.isNil(this.errorLogger)||this.errorLogger(e,t,n)},e}();t.Loggable=o},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0});var r=n(1);t.resolve=function(e){return{rpcRequestChannelName:r.isNil(e)||r.isNil(e.rpcRequestChannelName)?"RpcChannelDefaultNames.REQUEST":e.rpcRequestChannelName,rpcResponseChannelName:r.isNil(e)||r.isNil(e.rpcResponseChannelName)?"RpcChannelDefaultNames.RESPONSE":e.rpcResponseChannelName}}},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0});var r=n(0),o=n(10),i=n(2),s=function(){function e(){this.queue=[]}return e.prototype.push=function(e){for(var t=[],n=1;n<arguments.length;n++)t[n-1]=arguments[n];return r.__awaiter(this,void 0,void 0,function(){var n,s,u,c,a=this;return r.__generator(this,function(r){switch(r.label){case 0:return n=new(o.Task.bind.apply(o.Task,[void 0,e].concat(t))),s=new Promise(function(e){return n.once(i.TaskEventType.END,function(n,r){a.queue.shift(),e({error:n,result:r,args:t})})}),this.queue.push(n),this.queue.length>1?(u=this.queue.length-1,c=u-1,this.queue[c].once(i.TaskEventType.END,function(){n.run()})):n.run(),[4,s];case 1:return[2,r.sent()]}})})},e}();t.TaskQueue=s},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0});var r=n(0),o=n(11),i=n(2),s=function(e){function t(t){for(var n=[],r=1;r<arguments.length;r++)n[r-1]=arguments[r];var o=e.call(this)||this;return o.body=t,o.args=n,o}return r.__extends(t,e),t.prototype.run=function(){return r.__awaiter(this,void 0,void 0,function(){var e,t,n;return r.__generator(this,function(r){switch(r.label){case 0:e=null,t=null,this.emit(i.TaskEventType.START),r.label=1;case 1:return r.trys.push([1,3,,4]),[4,this.body.apply(this,this.args)];case 2:return e=r.sent(),this.emit(i.TaskEventType.SUCCESS,e),[3,4];case 3:return n=r.sent(),t=String(n),this.emit(i.TaskEventType.ERROR,t),[3,4];case 4:return this.emit(i.TaskEventType.END,t,e),[2]}})})},t}(o.EventEmitter);t.Task=s},function(e,t){function n(){this._events=this._events||{},this._maxListeners=this._maxListeners||void 0}function r(e){return"function"==typeof e}function o(e){return"object"==typeof e&&null!==e}function i(e){return void 0===e}e.exports=n,n.EventEmitter=n,n.prototype._events=void 0,n.prototype._maxListeners=void 0,n.defaultMaxListeners=10,n.prototype.setMaxListeners=function(e){if(!function(e){return"number"==typeof e}(e)||e<0||isNaN(e))throw TypeError("n must be a positive number");return this._maxListeners=e,this},n.prototype.emit=function(e){var t,n,s,u,c,a;if(this._events||(this._events={}),"error"===e&&(!this._events.error||o(this._events.error)&&!this._events.error.length)){if((t=arguments[1])instanceof Error)throw t;var l=new Error('Uncaught, unspecified "error" event. ('+t+")");throw l.context=t,l}if(i(n=this._events[e]))return!1;if(r(n))switch(arguments.length){case 1:n.call(this);break;case 2:n.call(this,arguments[1]);break;case 3:n.call(this,arguments[1],arguments[2]);break;default:u=Array.prototype.slice.call(arguments,1),n.apply(this,u)}else if(o(n))for(u=Array.prototype.slice.call(arguments,1),s=(a=n.slice()).length,c=0;c<s;c++)a[c].apply(this,u);return!0},n.prototype.addListener=function(e,t){var s;if(!r(t))throw TypeError("listener must be a function");return this._events||(this._events={}),this._events.newListener&&this.emit("newListener",e,r(t.listener)?t.listener:t),this._events[e]?o(this._events[e])?this._events[e].push(t):this._events[e]=[this._events[e],t]:this._events[e]=t,o(this._events[e])&&!this._events[e].warned&&(s=i(this._maxListeners)?n.defaultMaxListeners:this._maxListeners)&&s>0&&this._events[e].length>s&&(this._events[e].warned=!0,console.error("(node) warning: possible EventEmitter memory leak detected. %d listeners added. Use emitter.setMaxListeners() to increase limit.",this._events[e].length),"function"==typeof console.trace&&console.trace()),this},n.prototype.on=n.prototype.addListener,n.prototype.once=function(e,t){if(!r(t))throw TypeError("listener must be a function");var n=!1;function o(){this.removeListener(e,o),n||(n=!0,t.apply(this,arguments))}return o.listener=t,this.on(e,o),this},n.prototype.removeListener=function(e,t){var n,i,s,u;if(!r(t))throw TypeError("listener must be a function");if(!this._events||!this._events[e])return this;if(s=(n=this._events[e]).length,i=-1,n===t||r(n.listener)&&n.listener===t)delete this._events[e],this._events.removeListener&&this.emit("removeListener",e,t);else if(o(n)){for(u=s;u-- >0;)if(n[u]===t||n[u].listener&&n[u].listener===t){i=u;break}if(i<0)return this;1===n.length?(n.length=0,delete this._events[e]):n.splice(i,1),this._events.removeListener&&this.emit("removeListener",e,t)}return this},n.prototype.removeAllListeners=function(e){var t,n;if(!this._events)return this;if(!this._events.removeListener)return 0===arguments.length?this._events={}:this._events[e]&&delete this._events[e],this;if(0===arguments.length){for(t in this._events)"removeListener"!==t&&this.removeAllListeners(t);return this.removeAllListeners("removeListener"),this._events={},this}if(r(n=this._events[e]))this.removeListener(e,n);else if(n)for(;n.length;)this.removeListener(e,n[n.length-1]);return delete this._events[e],this},n.prototype.listeners=function(e){return this._events&&this._events[e]?r(this._events[e])?[this._events[e]]:this._events[e].slice():[]},n.prototype.listenerCount=function(e){if(this._events){var t=this._events[e];if(r(t))return 1;if(t)return t.length}return 0},n.listenerCount=function(e,t){return e.listenerCount(t)}}]); |
@@ -20,3 +20,3 @@ { | ||
}, | ||
"version": "1.0.1", | ||
"version": "1.1.0", | ||
"main": "dist/index.js", | ||
@@ -27,7 +27,7 @@ "types": "dist/index.d.ts", | ||
"autobind-decorator": "2.1.0", | ||
"electron-rpc-types": "^1.0.1", | ||
"electron-rpc-utils": "^1.0.1", | ||
"electron-rpc-types": "^1.1.0", | ||
"electron-rpc-utils": "^1.1.0", | ||
"tslib": "1.9.3" | ||
}, | ||
"gitHead": "aa93afeccf9067045acf383dcb097ec283c32375" | ||
"gitHead": "7835360ae4bf43137aa92624c1673ea0d5682f90" | ||
} |
43847
575
Updatedelectron-rpc-types@^1.1.0
Updatedelectron-rpc-utils@^1.1.0