1"use strict";(self.webpackChunkexpert=self.webpackChunkexpert||[]).push([[6133],{76133(dn,Z,p){p.d(Z,{OpsModule:()=>cn});var T=p(49769),b=p(89417),W=p(92079),m=p(68018),tt=p(93049),_=p(10467),et=p(47419),nt=p(6688),l=p(71498),F=p(4001),A=p(53001),c=p(15215);const at=["default","init","fix"];let g=class{constructor(s){this.json=s,this.category="default"}};(0,c.Cg)([(0,l.qFN)()],g.prototype,"task_id",void 0),(0,c.Cg)([(0,l.qFN)()],g.prototype,"type",void 0),(0,c.Cg)([(0,l.qFN)()],g.prototype,"state",void 0),(0,c.Cg)([(0,l.qFN)({convert:()=>Date,rule:l.rjC.date})],g.prototype,"start_time",void 0),(0,c.Cg)([(0,l.qFN)({convert:()=>Date,rule:l.rjC.date})],g.prototype,"next_start",void 0),(0,c.Cg)([(0,l.qFN)({convert:()=>Date,rule:l.rjC.date})],g.prototype,"end_time",void 0),(0,c.Cg)([(0,l.qFN)()],g.prototype,"log_url",void 0),(0,c.Cg)([(0,l.qFN)()],g.prototype,"enable",void 0),(0,c.Cg)([(0,l.qFN)()],g.prototype,"cron",void 0),(0,c.Cg)([(0,l.qFN)()],g.prototype,"category",void 0),(0,c.Cg)([(0,l.qFN)()],g.prototype,"args",void 0),(0,c.Cg)([(0,l.qFN)()],g.prototype,"actions",void 0),(0,c.Cg)([(0,l.qFN)()],g.prototype,"args_required",void 0),(0,c.Cg)([(0,l.qFN)()],g.prototype,"on_event",void 0),(0,c.Cg)([(0,l.qFN)()],g.prototype,"conflicts_with",void 0),(0,c.Cg)([(0,l.qFN)({convert:()=>Date,rule:l.rjC.date})],g.prototype,"last_update",void 0),(0,c.Cg)([(0,l.qFN)()],g.prototype,"file_path",void 0),(0,c.Cg)([(0,l.qFN)({rule:l.rjC.field(["total_worktime",()=>Date,l.rjC.date],["average",()=>Date,l.rjC.date])})],g.prototype,"metrics",void 0),g=(0,c.Cg)([(0,l.r1x)()],g);var it=p(26290),S=p(13474),t=p(35547),r=p(85802),ot=p(76201),N=p(81566),V=p(62031);function st(a,s){1&a&&t.nrm(0,"div",2),2&a&&t.Y8G("innerHTML",s.$implicit,t.npT)}function rt(a,s){if(1&a&&(t.j41(0,"code",0),t.Z7z(1,st,1,1,"div",2,t.fX1),t.k0s()),2&a){const e=t.XpG();t.R7$(),t.Dyx(e.parsedData)}}function lt(a,s){1&a&&(t.j41(0,"div",1),t.EFF(1,"There is no log yet"),t.k0s())}let X=(()=>{class a{set data(e){this.parsedData=e.map(n=>((a,s="g-color_undefined",e="span")=>{const n=new RegExp(/^(\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2})/);return a.replace(n,`<${e} class="${s}">$1</${e}>`)})(n)).reverse()}static{this.\u0275fac=function(n){return new(n||a)}}static{this.\u0275cmp=t.VBU({type:a,selectors:[["cb-logs"]],inputs:{data:"data"},standalone:!1,decls:2,vars:1,consts:[[1,"adm-logs"],[1,"g-empty"],[3,"innerHTML"]],template:function(n,i){1&n&&t.nVh(0,rt,3,0,"code",0)(1,lt,2,0,"div",1),2&n&&t.vxM(0!==i.parsedData.length?0:1)},styles:[".adm-logs[_ngcontent-%COMP%]{white-space:pre-wrap;word-break:break-word;font-size:calc(12em / 14)}"]})}}return a})();function _t(a,s){1&a&&t.EFF(0," Manager logs ")}function dt(a,s){1&a&&t.EFF(0," Api logs ")}function pt(a,s){if(1&a&&t.EFF(0),2&a){const e=t.XpG();t.SpI(" Task ",e.data.task.task_id," log ")}}function ut(a,s){if(1&a){const e=t.RV6();t.j41(0,"cb-button",3),t.bIt("clickHandler",function(){r.eBV(e);const i=t.XpG();return r.Njj(i.loadLogHandler())}),t.k0s()}2&a&&t.Y8G("type","transparent")("icon","update")}function gt(a,s){if(1&a&&(t.j41(0,"div",4)(1,"div",5),t.nrm(2,"cb-logs",6),t.k0s()()),2&a){const e=t.XpG();t.R7$(2),t.Y8G("data",e.taskLog)}}let q=(()=>{class a extends((0,F.Jb)()){constructor(){super(...arguments),this.loading=!1,this.preload=!0}ngOnInit(){var e=this;return(0,_.A)(function*(){e.loadLogHandler(!0)})()}loadLogHandler(){var e=this;return(0,_.A)(function*(n=!1){const i=e.getTaskLoader();i&&(e.loading=!0,e.taskLog=yield i(),e.loading=!1,n&&(e.preload=!1))}).apply(this,arguments)}getTaskLoader(){const{env:e,task:n,service:i}=this.data;if(!n)return;if("log-manager"==n)return()=>i.getLogManager(e);if("log-api"==n)return()=>i.getLogApi(e);const{task_id:o}=n;return()=>i.getTaskLog(e,o)}static{this.\u0275fac=(()=>{let e;return function(i){return(e||(e=t.xGo(a)))(i||a)}})()}static{this.\u0275cmp=t.VBU({type:a,selectors:[["ng-component"]],inputs:{data:"data"},standalone:!1,features:[t.Vt3],decls:6,vars:3,consts:[[1,"g-dialog__title"],[3,"type","icon"],["class","g-dialog__main g-dialog__main_dynamic-max adm-task-log adm-logs",4,"cbLoader"],[3,"clickHandler","type","icon"],[1,"g-dialog__main","g-dialog__main_dynamic-max","adm-task-log","adm-logs"],["cbScroll","true"],[3,"data"]],template:function(n,i){if
1(1&n&&(t.j41(0,"div",0),t.nVh(1,_t,1,0)(2,dt,1,0)(3,pt,1,1),t.nVh(4,ut,1,2,"cb-button",1),t.k0s(),t.DNE(5,gt,3,1,"div",2)),2&n){let o;t.R7$(),t.vxM("log-manager"===(o=i.data.task)?1:"log-api"===o?2:3),t.R7$(3),t.vxM(i.preload||i.loading?-1:4),t.R7$(),t.Y8G("cbLoader",i.preload&&i.loading)}},dependencies:[ot.GB,N.Q,V.d,X],encapsulation:2})}}return a})();var bt=p(49803),mt=p(80878),j=p(99313),P=p(59611);function ht(a,s){if(1&a){const e=t.RV6();t.j41(0,"cb-form-field")(1,"label",9),t.EFF(2,"Args"),t.k0s(),t.j41(3,"input",10),t.nI1(4,"translate"),t.mxI("ngModelChange",function(i){r.eBV(e);const o=t.XpG(2);return t.DH7(o.args,i)||(o.args=i),r.Njj(i)}),t.k0s()()}if(2&a){const e=t.XpG(2);t.R7$(3),t.Y8G("placeholder",t.bMT(4,2,"Enter args")),t.R50("ngModel",e.args)}}function kt(a,s){if(1&a&&(t.j41(0,"option",14),t.EFF(1),t.k0s()),2&a){const e=s.$implicit;t.Y8G("value",e.value),t.R7$(),t.JRh(e.label)}}function ft(a,s){if(1&a){const e=t.RV6();t.j41(0,"cb-form-field")(1,"label",11),t.EFF(2,"Run options"),t.k0s(),t.j41(3,"div",12)(4,"select",13,1),t.mxI("ngModelChange",function(i){r.eBV(e);const o=t.XpG(2);return t.DH7(o.args,i)||(o.args=i),r.Njj(i)}),t.Z7z(6,kt,2,2,"option",14,t.fX1),t.k0s(),t.j41(8,"cb-dropdown",15),t.mxI("valueChange",function(i){r.eBV(e);const o=t.XpG(2);return t.DH7(o.args,i)||(o.args=i),r.Njj(i)}),t.k0s()()()}if(2&a){const e=t.sdS(5),n=t.XpG(2);t.R7$(4),t.R50("ngModel",n.args),t.R7$(2),t.Dyx(n.actions),t.R7$(2),t.Y8G("options",n.actions),t.R50("value",n.args),t.Y8G("control",e)}}function vt(a,s){if(1&a&&(t.j41(0,"div",5),t.nVh(1,ht,5,4,"cb-form-field"),t.nVh(2,ft,9,4,"cb-form-field"),t.k0s()),2&a){const e=t.XpG();t.R7$(),t.vxM(e.data.args_required?1:-1),t.R7$(),t.vxM(null!=e.actions&&e.actions.length?2:-1)}}let Ct=(()=>{class a{constructor(e){this.dialog=e,this.args=null}ngOnInit(){this.data.actions&&(this.actions=[{label:"Run",value:null},...this.data.actions.map(e=>({label:e.title,value:e.args}))])}submit(){this.dialog.close({args:this.args})}static{this.\u0275fac=function(n){return new(n||a)(t.rXU(A.o3))}}static{this.\u0275cmp=t.VBU({type:a,selectors:[["ng-component"]],inputs:{data:"data"},standalone:!1,decls:14,vars:9,consts:[["form","ngForm"],["actionModel","ngModel"],["translate","",1,"g-dialog__title"],[1,"g-dialog__desc"],[3,"ngSubmit"],[1,"g-dialog__main"],[1,"g-dialog__buttons"],["type","button","cb-button","","color","transparent",3,"click"],["type","submit","cb-raised-button","","color","primary"],["for","args","cbFieldLabel","","translate",""],["type","text","name","args","id","args","required","","required-trim","",1,"g-input",3,"ngModelChange","placeholder","ngModel"],["for","action","cbFieldLabel","","translate",""],[1,"g-dropdown","g-dropdown_list-small","g-input-wrapper"],["name","role","id","action","hidden","",3,"ngModelChange","ngModel"],[3,"value"],[3,"valueChange","options","value","control"]],template:function(n,i){if(1&n&&(t.j41(0,"div",2),t.EFF(1,"Run task"),t.k0s(),t.j41(2,"div",3),t.EFF(3),t.k0s(),t.j41(4,"form",4,0),t.bIt("ngSubmit",function(){return i.submit()}),t.nVh(6,vt,3,2,"div",5),t.j41(7,"div",6)(8,"button",7),t.bIt("click",function(){return i.dialog.close()}),t.EFF(9),t.nI1(10,"translate"),t.k0s(),t.j41(11,"button",8),t.EFF(12),t.nI1(13,"translate"),t.k0s()()()),2&n){const o=t.sdS(5);t.R7$(3),t.SpI("Are you sure want to run task ",i.data.task_id,"?"),t.R7$(3),t.vxM(null!=i.actions&&i.actions.length||i.data.args_required?6:-1),t.R7$(3),t.JRh(t.bMT(10,5,"Cancel")),t.R7$(2),t.BMQ("disabled",o.valid?null:""),t.R7$(),t.JRh(t.bMT(13,7,"Run"))}},dependencies:[b.qT,b.xH,b.y7,b.me,b.wz,b.BC,b.cb,b.YS,b.vS,b.cV,m.Mm,bt.b,mt.K,j.Q,P.P,m.D9],encapsulation:2})}}return a})();var yt=p(17705),B=p(59882);let R=class{constructor(s){this.json=s}};(0,c.Cg)([(0,l.qFN)({convert:()=>g,array:!0})],R.prototype,"tasks",void 0),(0,c.Cg)([(0,l.qFN)()],R.prototype,"manager",void 0),R=(0,c.Cg)([(0,l.r1x)()],R);let $=class{constructor(s){this.json=s}};(0,c.Cg)([(0,l.qFN)({convert:()=>k,array:!0})],$.prototype,"auth_locks",void 0),(0,c.Cg)([(0,l.qFN)({convert:()=>k,array:!0})],$.prototype,"curr_locks",void 0),$=(0,c.Cg)([(0,l.r1x)()],$);let k=class{constructor(s){this.json=s,this.isFullView=!1,this.isFullViewBlocking=!1}};(0,c.Cg)([(0,l.qFN)()],k.prototype,"blocked_app_name",void 0),(0,c.Cg)([(0,l.qFN)()],k.prototype,"blocked_pid",void 0),(0,c.Cg)([(0,l.qFN)({convert:()=>Date,rule:l.rjC.date})],k.prototype,"blocked_query_start",void 0),(0,c.Cg)([(0,l.qFN)()],k.prototype,"blocked_statement",void 0),(0,c.Cg)([(0,l.qFN)()],k.prototype,"blocking_app_name",void 0),(0,c.Cg)([(0,l.qFN)()],k.prototype,"blocking_pid",void 0),(0,c.Cg)([(0,l.qFN)({convert:()=>Date,rule:l.rjC.date})],k.prototype,"blocking_query_start",void 0),(0,c.Cg)([(0,l.qFN)()],k.prototype,"current_statement_in_blocking_process",void 0),k=(0,c.Cg)([(0,l.r1x)()],k);let G=class{constructor(s){this.json=s}};(0,c.Cg)([(0,l.qFN)({convert:()=>f,array:!0})],G.prototype,"auth_activity",void 0),(0,c.Cg)([(0,l.qFN)({convert:()=>f,array:!0})],G.prototype,"curr_activity",void 0),G=(0,c.Cg)([(0,l.r1x)()],G);let f=class{constructor(s){this.json=s,this.isFullView=!1}};(0,c.Cg)([(0,l.qFN)()],f.prototype,"application_name",void 0),(0,c.Cg)([(0,l.qFN)()],f.prototype,"pid",void 0),(0,c.Cg)([(0,l.qFN)()],f.prototype,"query",void 0),(0,c.Cg)([(0,l.qFN)()],f.prototype,"state",void 0),(0,c.Cg)([(0,l.qFN)({convert:()=>Date,rule:l.rjC.date})],f.prototype,"query_start",void 0),(0,c.Cg)([(0,l.qFN)({convert:()=>Date,rule:l.rjC.date})],f.prototype,"backend_start",void 0),(0,c.Cg)([(0,l.qFN)({convert:()=>Date,rule:l.rjC.date})],f.prototype,"xact_start",void 0),(0,c.Cg)([(0,l.qFN)({convert:()=>Date,rule:l.rjC.date})],f.prototype,"state_change",void 0),f=(0,c.Cg)([(0,l.r1x)()],f);let C=class{constructor(s){this.json=s,this.isFullView=!1}};(0,c.Cg)([(0,l.qFN)()],C.prototype,"elapsed",void 0),(0,c.Cg)([(0,l.qFN)()],C.prototype,"is_cancelled",void 0),(0,c.Cg)([(0,l.qFN)()],C.prototype,"memory_usage",void 0),(0,c.Cg)([(0,l.qFN)()],C.prototype,"peak_memory_usage",void 0),(0,c.Cg)([(0,l.qFN)()],C.prototype,"query",void 0),(0,c.Cg)([(0,l.qFN)()],C.prototype,"query_id",void 0),C=(0,c.Cg)([(0,l.r1x)()],C);let I=class{constructor(s){this.json=s}};(0,c.Cg)([(0,l.qFN)({convert:()=>C,array:!0})],I.prototype,"curr_activity",void 0),I=(0,c.Cg)([(0,l.r1x)()],I);let v=class{constructor(s){this.json=s}};(0,c.Cg)([(0,l.qFN)()],v.prototype,"average",void 0),(0,c.Cg)([(0,l.qFN)()],v.prototype,"count",void 0),(0,c.Cg)([(0,l.qFN)()],v.prototype,"errors",void 0),(0,c.Cg)([(0,l.qFN)()],v.prototype,"fatals",void 0),(0,c.Cg)([(0,l.qFN)()],v.prototype,"total_worktime",void 0),(0,c.Cg)([(0,l.qFN)()],v.prototype,"warnings",void 0),v=(0,c.Cg)([(0,l.r1x)()],v);var Tt=p(99437),Ft=p(7673),jt=p(91413);let Y=(()=>{class a{constructor(e,n){this.http=e,this.config=n}getEnvs(){return[{label:"Global",value:"global"},{label:"Altcoin",value:"altcoin"},{label:"Offchain server",value:"offchain"},...this.config.adminCurrencies.map(e=>({label:e.label,value:e}))]}getEtlData(e){var n=this;return(0,_.A)(function*(){let i=`${n.apiUrl(e)}/manager/tasks`,o=yield n.http.get(i).toPromise();return new R(o.data)})()}etlTaskEnable(e,n){var i=this;return(0,_.A)(function*(){let o=`${i.apiUrl(e)}/manager/tasks/${n}/enable`;return(yield i.http.post(o,{}).toPromise()).data})()}etlTaskDisable(e,n){var i=this;return(0,_.A)(function*(){let o=`${i.apiUrl(e)}/manager/tasks/${n}/disable`;return(yield i.http.post(o,{}).toPromise()).data})()}etlTaskKill(e,n){var i=this;return(0,_.A)(function*(){let o=`${i.apiUrl(e)}/manager/tasks/${n}/kill`;return(yield i.http.post(o,{}).toPromise()).data})()}etlTaskRun(e,n,i){var o=this;return(0,_.A)(function*(){let d=`${o.apiUrl(e)}/manager/tasks/${n}/run`;return(yield o.http.post(d,i?{args:i}:{}).toPromise()).data})()}etlManagerResume(e){var n=this;return(0,_.A)(function*(){let i=`${n.apiUrl(e)}/manager/resume`;return(yield n.http.post(i,{}).toPromise()).data})()}etlManagerPause(e){var n=this;return(0,_.A)(function*(){let i=`${n.apiUrl(e)}
1/manager/pause`;return(yield n.http.post(i,{}).toPromise()).data})()}etlManagerKillAll(e){var n=this;return(0,_.A)(function*(){let i=`${n.apiUrl(e)}/manager/tasks/kill_daemons`;return(yield n.http.post(i,{}).toPromise()).data})()}etlManagerGetHealthStatus(e){var n=this;return(0,_.A)(function*(){let i=`${n.apiUrl(e)}/manager/health`;return(yield n.http.get(i).toPromise()).data})()}etlManagerGetIndirectHealthStatus(e){var n=this;return(0,_.A)(function*(){let i=`${n.apiUrl(e)}/manager/health-indirect`;return(yield n.http.get(i).toPromise()).data})()}etlManagerIndirectAction(e,n){var i=this;return(0,_.A)(function*(){const o=`${i.apiUrl(e)}/manager/indirect-${n}`;return yield i.http.post(o,{}).pipe((0,Tt.W)(d=>(0,Ft.of)({data:d?.message??d}))).toPromise()})()}etlManagerGetJobsActivity(e,n){var i=this;return(0,_.A)(function*(){let o=`${i.apiUrl(e)}/manager/task-metrics/${n}`;const d=yield i.http.get(o).toPromise();let u={};return Object.keys(d.data).forEach(h=>{u[h]=typeof d.data[h].average<"u"?new v(d.data[h]):d.data[h]}),u})()}etlManagerPGLocks(e){var n=this;return(0,_.A)(function*(){let i=`${n.apiUrl(e)}
1/manager/pg-locks`;const o=yield n.http.get(i).toPromise();return new $(o.data)})()}etlManagerPGActivity(e){var n=this;return(0,_.A)(function*(){let i=`${n.apiUrl(e)}/manager/pg-activity`;const o=yield n.http.get(i).toPromise();return new G(o.data)})()}pgCancelBackend(e,n){var i=this;return(0,_.A)(function*(){let o=`${i.apiUrl(e)}/manager/pg-cancel-backend`;yield i.http.post(o,n).toPromise()})()}etlManagerCHActivity(e){var n=this;return(0,_.A)(function*(){let i=`${n.apiUrl(e)}/manager/ch-activity`;const o=yield n.http.get(i).toPromise();return new I(o.data)})()}chCancelBackend(e,n){var i=this;return(0,_.A)(function*(){let o=`${i.apiUrl(e)}/manager/ch-cancel-backend`;yield i.http.post(o,n).toPromise()})()}getTaskLog(e,n){var i=this;return(0,_.A)(function*(){const o=`${i.apiUrl(e)}/manager/tasks/${n}/log`;return(yield i.http.post(o,{}).toPromise()).data})()}getLogManager(e){var n=this;return(0,_.A)(function*(){const i=`${n.apiUrl(e)}/manager/log-manager`;return(yield n.http.post(i,{}).toPromise()).data})()}getLogApi(e){var n=this;return(0,_.A)(function*(){const i=`${n.apiUrl(e)}/manager/log-api`;return(yield n.http.post(i,{}).toPromise()).data})()}getLogIndirect(e){var n=this;return(0,_.A)(function*(){const i=`${n.apiUrl(e)}/manager/indirect-log`;return(yield n.http.post(i,{}).toPromise()).data})()}apiUrl(e){return e instanceof l.SjR?e.apiUrl:"global"==e?this.config.global_api_url:"offchain"==e?this.config.offchain_api_url:"altcoin"==e?this.config.altcoin_api_url:void 0}static{this.\u0275fac=function(n){return new(n||a)(r.KVO(jt.Qq),r.KVO(l.oO7))}}static{this.\u0275prov=r.jDH({token:a,factory:a.\u0275fac})}}return a})();var x=p(68635),Rt=p(93435),H=p(36103),J=p(58839),M=p(212),U=p(50994),$t=p(39709),y=p(45364);const Gt=["locksTable"],xt=a=>({value:"auth",label:a}),Dt=a=>({value:"curr",label:a}),It=(a,s)=>[a,s],At=a=>[a,"blocked_app_name"],Vt=a=>[a,"blocking_app_name"];function Mt(a,s){if(1&a&&(t.j41(0,"tr")(1,"td",13)(2,"div",14)(3,"div",15)(4,"b"),t.EFF(5,"Blocked Query:"),t.k0s(),t.nrm(6,"br"),t.j41(7,"code"),t.EFF(8),t.k0s()(),t.j41(9,"div",15)(10,"b"),t.EFF(11,"Blocking Query:"),t.k0s(),t.nrm(12,"br"),t.j41(13,"code"),t.EFF(14),t.k0s()()()(),t.nrm(15,"td"),t.k0s()),2&a){const e=t.XpG().$implicit;t.R7$(8),t.SpI(" ",e.blocked_statement," "),t.R7$(6),t.SpI(" ",e.current_statement_in_blocking_process," ")}}function Ot(a,s){if(1&a){const e=t.RV6();t.j41(0,"tr",6),t.bIt("click",function(){const i=r.eBV(e).$implicit;
1return r.Njj(i.isFullView=!i.isFullView)}),t.j41(1,"td",3)(2,"button",7),t.bIt("click",function(i){const o=r.eBV(e).$implicit,d=t.XpG(2);return i.stopPropagation(),r.Njj(d.killTask.emit({pid:o.blocked_pid,db:d.db}))}),t.nrm(3,"cb-icon",8),t.k0s(),t.EFF(4),t.k0s(),t.j41(5,"td",9),t.EFF(6),t.k0s(),t.j41(7,"td",10),t.EFF(8),t.nI1(9,"date"),t.k0s(),t.j41(10,"td",9),t.EFF(11),t.k0s(),t.j41(12,"td",3)(13,"button",11),t.bIt("click",function(i){const o=r.eBV(e).$implicit,d=t.XpG(2);return i.stopPropagation(),r.Njj(d.killTask.emit({pid:o.blocking_pid,db:d.db}))}),t.nrm(14,"cb-icon",8),t.k0s(),t.EFF(15),t.k0s(),t.j41(16,"td",10),t.EFF(17),t.nI1(18,"date"),t.k0s(),t.j41(19,"td",5)(20,"button",12),t.nrm(21,"cb-icon",8),t.k0s()()(),t.nVh(22,Mt,16,2,"tr")}if(2&a){const e=s.$implicit,n=t.XpG(2);t.R7$(2),t.Y8G("disabled",n.pending),t.R7$(),t.Y8G("iconType","stop"),t.R7$(),t.SpI(" ",e.blocked_pid," "),t.R7$(2),t.JRh(e.blocked_app_name),t.R7$(2),t.SpI(" ",t.ii3(9,12,e.blocked_query_start,"MMM dd, yyyy, hh:mm a","+0",n.translate.currentLang)," "),t.R7$(3),t.SpI(" ",e.blocking_app_name," "),t.R7$(2),t.Y8G("disabled",n.pending),t.R7$(),t.Y8G("iconType","stop"),t.R7$(),t.SpI(" ",e.blocking_pid," "),t.R7$(2),t.SpI(" ",t.ii3(18,17,e.blocking_query_start,"MMM dd, yyyy, hh:mm a","+0",n.translate.currentLang)," "),t.R7$(4),t.Y8G("iconType",e.isFullView?"minus":"plus"),t.R7$(),t.vxM(e.isFullView?22:-1)}}function Et(a,s){if(1&a&&t.Z7z(0,Ot,23,22,null,null,t.fX1),2&a){t.XpG();const e=t.sdS(4);t.Dyx(e.data)}}function wt(a,s){1&a&&(t.j41(0,"tr")(1,"td",16),t.EFF(2,"..."),t.k0s()())}let Lt=(()=>{class a{ngOnInit(){}constructor(e){this.translate=e,this.killTask=new r.bkB,this.orderChange=new r.bkB,this.db="curr"}static{this.\u0275fac=function(n){return new(n||a)(t.rXU(m.c$))}}static{this.\u0275cmp=t.VBU({type:a,selectors:[["cb-pg-locks"]],viewQuery:function(n,i){if(1&n&&t.GBs(Gt,5),2&n){let o;t.mGM(o=t.lsd())&&(i.cbTable=o.first)}},inputs:{pgLocks:"pgLocks",order:"order",pending:"pending"},outputs:{killTask:"killTask",orderChange:"orderChange"},standalone:!1,decls:23,vars:23,consts:[["locksTable","cbTable"],[1,"g-dialog-tabs",3,"valueChange","options","value"],[1,"g-table","adm-tasks__table",3,"cbTableOrderChange","cbTable","cbTableLimit","cbTableOrder"],[1,"g-table__td","g-table__td_pid"],[1,"g-table__td","g-table__td_application-name",3,"cbTableSort"],[1,"g-table__td","g-table__td_actions"],[1,"g-table__hover",3,"click"],["cb-icon-button","",3,"click","disabled"],[3,"iconType"],[1,"g-table__td","g-table__td_application-name"],[1,"g-table__td","g-table__td_small","g-color_undefined"],[3,"click","disabled"],["cb-icon-button",""],["colspan","6"],[1,"g-query-wrapper"],[1,"g-query-wrapper__item"],["colspan","7",1,"g-table__td","g-table__td-center"]],template:function(n,i){if(1&n){const o=t.RV6();t.j41(0,"cb-button-toggler",1),t.nI1(1,"translate"),t.nI1(2,"translate"),t.bIt("valueChange",function(u){return i.db=u}),t.k0s(),t.j41(3,"table",2,0),t.mxI("cbTableOrderChange",function(u){return r.eBV(o),t.DH7(i.order,u)||(i.order=u),r.Njj(u)}),t.bIt("cbTableOrderChange",function(u){return i.orderChange.emit(u)}),t.j41(5,"thead")(6,"tr")(7,"th",3),t.EFF(8,"PID"),t.k0s(),t.j41(9,"th",4),t.EFF(10,"Application Name "),t.k0s(),t.j41(11,"th"),t.EFF(12,"Query start"),t.k0s(),t.j41(13,"th",4),t.EFF(14,"Blocking App Name "),t.k0s(),t.j41(15,"th"),t.EFF(16,"Blocking PID"),t.k0s(),t.j41(17,"th"),t.EFF(18,"Blocking Query start"),t.k0s(),t.nrm(19,"th",5),t.k0s()(),t.j41(20,"tbody"),t.nVh(21,Et,2,0)(22,wt,3,0,"tr"),t.k0s()()}if(2&n){const o=t.sdS(4);t.Y8G("options",t.l_i(16,It,t.eq3(12,xt,t.bMT(1,8,"Auth")+(!!i.pgLocks.auth_locks.length&&" ("+i.pgLocks.auth_locks.length+")"||"")),t.eq3(14,Dt,t.bMT(2,10,"Curr")+(!!i.pgLocks.curr_locks.length&&" ("+i.pgLocks.curr_locks.length+")"||""))))("value",i.db),t.R7$(3),t.Y8G("cbTable","auth"==i.db?i.pgLocks.auth_locks:i.pgLocks.curr_locks)("cbTableLimit","auth"==i.db?i.pgLocks.auth_locks.length:i.pgLocks.curr_locks.length),t.R50("cbTableOrder",i.order),t.R7$(6),t.Y8G("cbTableSort",t.eq3(19,At,o)),t.R7$(4),t.Y8G("cbTableSort",t.eq3(21,Vt,o)),t.R7$(8),t.vxM(o.data.length>0?21:22)}},dependencies:[x.R,j.Q,M.a,y.t,y.N,T.vh,m.D9],encapsulation:2,changeDetection:0})}}return a})();var Q=p(87143);const St=["activityTable"],Nt=a=>({value:"auth",label:a}),Xt=a=>({value:"curr",label:a}),qt=(a,s)=>[a,s],Pt=a=>[a,"application_name"],Bt=a=>[a,"state"],O=()=>({main:"MMM dd, yyyy, hh:mm a"});function Yt(a,s){if(1&a){const e=t.RV6();t.j41(0,"tr")(1,"td",3)(2,"button",8),t.bIt("click",function(){const i=r.eBV(e).$implicit,o=t.XpG();
1return r.Njj(o.killTask.emit({pid:i.pid,db:o.db}))}),t.nrm(3,"cb-icon",9),t.k0s(),t.EFF(4),t.k0s(),t.j41(5,"td",10)(6,"div",11)(7,"span",12),t.EFF(8),t.k0s()()(),t.j41(9,"td",13),t.nrm(10,"cb-date",14),t.k0s(),t.j41(11,"td",15)(12,"div",16)(13,"button",17),t.bIt("click",function(){const i=r.eBV(e).$implicit,o=t.XpG();return r.Njj(o.toggleFullQuery(i))}),t.nrm(14,"cb-icon",18),t.k0s(),t.j41(15,"code",19),t.EFF(16),t.k0s()()(),t.j41(17,"td",13),t.nrm(18,"cb-date",14),t.k0s(),t.j41(19,"td",20)(20,"div",21)(21,"span",12),t.EFF(22),t.k0s()()(),t.j41(23,"td",13),t.nrm(24,"cb-date",14),t.k0s()()}if(2&a){const e=s.$implicit,n=t.XpG();t.R7$(2),t.Y8G("disabled",n.pending),t.R7$(2),t.SpI(" ",e.pid," "),t.R7$(3),t.Y8G("cbTitleOverflow",e.application_name),t.R7$(),t.JRh(e.application_name),t.R7$(2),t.Y8G("date",e.xact_start)("subdate",!1)("format",t.lJ4(25,O)),t.R7$(2),t.AVh("g-query_full",e.isFullView),t.R7$(2),t.Y8G("iconType",e.isFullView?"minus":"plus"),t.R7$(2),t.JRh(e.query),t.R7$(2),t.Y8G("date",e.query_start)("subdate",!1)("format",t.lJ4(26,O)),t.R7$(),t.AVh("g-color_green","active"==e.state)("g-color_undefined","idle"==e.state)("g-color_red","idle in transaction"==e.state),t.R7$(2),t.Y8G("cbTitleOverflow",e.state),t.R7$(),t.JRh(e.state),t.R7$(2),t.Y8G("date",e.state_change)("subdate",!1)("format",t.lJ4(27,O))}}let Ht=(()=>{class a{constructor(e){this.translate=e,this.killTask=new r.bkB,this.orderChange=new r.bkB,this.db="curr"}toggleFullQuery(e){e.isFullView=!e.isFullView}cast(e){return e}static{this.\u0275fac=function(n){return new(n||a)(t.rXU(m.c$))}}static{this.\u0275cmp=t.VBU({type:a,selectors:[["cb-pg-activity"]],viewQuery:function(n,i){if(1&n&&t.GBs(St,5),2&n){let o;t.mGM(o=t.lsd())&&(i.cbTable=o.first)}},inputs:{activity:"activity",order:"order",pending:"pending"},outputs:{killTask:"killTask",orderChange:"orderChange"},standalone:!1,decls:24,vars:22,consts:[["activityTable","cbTable"],[1,"g-dialog-tabs",3,"valueChange","options","value"],[1,"g-table","adm-tasks__table",3,"cbTableOrderChange","cbTable","cbTableLimit","cbTableOrder"],[1,"g-table__td","g-table__td_pid"],[1,"g-table__td","g-table__td_application-name",3,"cbTableSort"],["translate",""],[1,"g-table__td","g-table__td_query","g-table__query"],[1,"g-table_td","g-table__td_state",3,"cbTableSort"],["cb-icon-button","",3,"click","disabled"],["iconType","stop"],[1,"g-table__td","g-table__td_application-name"],[1,"g-value-wrapper","adm__app-name"],[1,"g-value-wrapper__value",3,"cbTitleOverflow"],[1,"g-table__td","g-table__td_small","g-color_undefined"],[3,"date","subdate","format"],[1,"g-table__td","g-table__td_query"],[1,"g-query"],["cb-icon-button","",3,"click"],[3,"iconType"],[1,"g-query__text"],[1,"g-table_td","g-table__td_state"],[1,"g-value-wrapper","adm__status"]],template:function(n,i){if(1&n){const o=t.RV6();t.j41(0,"cb-button-toggler",1),t.nI1(1,"translate"),t.nI1(2,"translate"),t.bIt("valueChange",function(u){return i.db=u}),t.k0s(),t.j41(3,"table",2,0),t.mxI("cbTableOrderChange",function(u){return r.eBV(o),t.DH7(i.order,u)||(i.order=u),r.Njj(u)}),t.bIt("cbTableOrderChange",function(u){return i.orderChange.emit(u)}),t.j41(5,"thead")(6,"tr")(7,"th",3),t.EFF(8,"PID"),t.k0s(),t.j41(9,"th",4),t.EFF(10,"Application Name "),t.k0s(),t.j41(11,"th",5),t.EFF(12,"Transaction Start"),t.k0s(),t.j41(13,"th",6),t.EFF(14,"Query"),t.k0s(),t.j41(15,"th"),t.EFF(16,"Query start"),t.k0s(),t.j41(17,"th",7),t.EFF(18,"State "),t.k0s(),t.j41(19,"th"),t.EFF(20,"State Change"),t.k0s()()(),t.j41(21,"tbody"),t.Z7z(22,Yt,25,28,"tr",null,t.fX1),t.k0s()()}if(2&n){const o=t.sdS(4);t.Y8G("options",t.l_i(15,qt,t.eq3(11,Nt,t.bMT(1,7,"Auth")+(!!i.activity.auth_activity.length&&" ("+i.activity.auth_activity.length+")"||"")),t.eq3(13,Xt,t.bMT(2,9,"Curr")+(!!i.activity.curr_activity.length&&" ("+i.activity.curr_activity.length+")"||""))))("value",i.db),t.R7$(3),t.Y8G("cbTable","auth"==i.db?i.activity.auth_activity:i.activity.curr_activity)("cbTableLimit","auth"==i.db?i.activity.auth_activity.length:i.activity.curr_activity.length),t.R50("cbTableOrder",i.order),t.R7$(6),t.Y8G("cbTableSort",t.eq3(18,Pt,o)),t.R7$(8),t.Y8G("cbTableSort",t.eq3(20,Bt,o)),t.R7$(5),t.Dyx(i.cast(o.data))}},dependencies:[m.Mm,x.R,j.Q,Q.P,M.a,U.g,y.t,y.N,m.D9],encapsulation:2,changeDetection:0})}}return a})();var E=p(88807);const Jt=["activityTable"],Ut=a=>[a,"is_canceled"];function Qt(a,s){if(1&a){const e=t.RV6();t.j41(0,"tr")(1,"td",2)(2,"button",8),t.bIt("click",function(){const i=r.eBV(e).$implicit,o=t.XpG();
1return r.Njj(o.killTask.emit({query_id:i.query_id}))}),t.nrm(3,"cb-icon",9),t.k0s()(),t.j41(4,"td",3)(5,"div",10),t.EFF(6),t.k0s()(),t.j41(7,"td",4)(8,"div",11)(9,"button",8),t.bIt("click",function(){const i=r.eBV(e).$implicit,o=t.XpG();return r.Njj(o.toggleFullQuery(i))}),t.nrm(10,"cb-icon",12),t.k0s(),t.j41(11,"code",13),t.EFF(12),t.k0s()()(),t.j41(13,"td",5)(14,"div",10),t.nI1(15,"cbNumber"),t.EFF(16),t.nI1(17,"cbNumber"),t.k0s()(),t.j41(18,"td",5)(19,"div",10),t.nI1(20,"cbNumber"),t.EFF(21),t.nI1(22,"cbNumber"),t.k0s()(),t.j41(23,"td",6)(24,"div",10),t.nI1(25,"cbNumber"),t.EFF(26),t.nI1(27,"cbNumber"),t.k0s()(),t.j41(28,"td",14),t.EFF(29),t.k0s()()}if(2&a){const e=s.$implicit;t.R7$(5),t.Y8G("cbTitleOverflow",e.query_id),t.R7$(),t.JRh(e.query_id),t.R7$(),t.AVh("cb-table-query_full",e.isFullView),t.R7$(),t.AVh("g-query_full",e.isFullView),t.R7$(2),t.Y8G("iconType",e.isFullView?"minus":"plus"),t.R7$(2),t.JRh(e.query),t.R7$(2),t.Y8G("cbTitleOverflow",t.bMT(15,15,e.memory_usage)),t.R7$(2),t.JRh(t.bMT(17,17,e.memory_usage)),t.R7$(3),t.Y8G("cbTitleOverflow",t.bMT(20,19,e.peak_memory_usage)),t.R7$(2),t.JRh(t.bMT(22,21,e.peak_memory_usage)),t.R7$(3),t.Y8G("cbTitleOverflow",t.bMT(25,23,e.elapsed)),t.R7$(2),t.JRh(t.bMT(27,25,e.elapsed)),t.R7$(3),t.SpI(" ",e.is_cancelled?"Yes":"No"," ")}}let zt=(()=>{class a{constructor(e){this.translate=e,this.killTask=new r.bkB,this.orderChange=new r.bkB}toggleFullQuery(e){e.isFullView=!e.isFullView}cast(e){return e}static{this.\u0275fac=function(n){return new(n||a)(t.rXU(m.c$))}}static{this.\u0275cmp=t.VBU({type:a,selectors:[["cb-ch-activity"]],viewQuery:function(n,i){if(1&n&&t.GBs(Jt,5),2&n){let o;t.mGM(o=t.lsd())&&(i.cbTable=o.first)}},inputs:{activity:"activity",order:"order",pending:"pending"},outputs:{killTask:"killTask",orderChange:"orderChange"},standalone:!1,decls:20,vars:6,consts:[["activityTable","cbTable"],[1,"g-table",3,"cbTableOrderChange","cbTable","cbTableLimit","cbTableOrder"],[1,"g-table__actions","cb-table-action"],[1,"cb-table-id"],[1,"cb-table-query"],[1,"cb-table-memory"],[1,"cb-table-elapsed"],[1,"cb-table-state",3,"cbTableSort"],["type","button","cb-icon-button","",3,"click"],["iconType","stop","specificColor","inherit"],["cbTooltip","",1,"truncate",3,"cbTitleOverflow"],[1,"g-query"],[3,"iconType"],[1,"g-query__text"],[1,"cb-table-state"]],template:function(n,i){if(1&n){const o=t.RV6();t.j41(0,"table",1,0),t.mxI("cbTableOrderChange",function(u){return r.eBV(o),t.DH7(i.order,u)||(i.order=u),r.Njj(u)}),t.bIt("cbTableOrderChange",function(u){return i.orderChange.emit(u)}),t.j41(2,"thead")(3,"tr"),t.nrm(4,"th",2),t.j41(5,"th",3),t.EFF(6,"Query ID"),t.k0s(),t.j41(7,"th",4),t.EFF(8,"Query"),t.k0s(),t.j41(9,"th",5),t.EFF(10,"Memory usage"),t.k0s(),t.j41(11,"th",5),t.EFF(12,"Peak memory usage"),t.k0s(),t.j41(13,"th",6),t.EFF(14,"Elapsed"),t.k0s(),t.j41(15,"th",7),t.EFF(16,"Cancelled"),t.k0s()()(),t.j41(17,"tbody"),t.Z7z(18,Qt,30,27,"tr",null,t.fX1),t.k0s()()}if(2&n){const o=t.sdS(1);t.Y8G("cbTable",i.activity.curr_activity)("cbTableLimit",i.activity.curr_activity.length),t.R50("cbTableOrder",i.order),t.R7$(15),t.Y8G("cbTableSort",t.eq3(4,Ut,o)),t.R7$(3),t.Dyx(i.cast(o.data))}},dependencies:[x.R,j.Q,J.A,Q.P,y.t,y.N,E.tw],styles:[".cb-table-query[_ngcontent-%COMP%]{width:calc(300em / 14)}.cb-table-query_full[_ngcontent-%COMP%]{width:calc(500em / 14)}.g-query__text[_ngcontent-%COMP%]{max-width:none!important}"],changeDetection:0})}}return a})();const z=a=>({$implicit:a});function Kt(a,s){if(1&a&&t.eu8(0,1),2&a){const e=t.XpG().$implicit;t.XpG(2);const n=t.sdS(2);t.Y8G("ngTemplateOutlet",n)("ngTemplateOutletContext",t.eq3(2,z,e.value))}}function Zt(a,s){if(1&a&&t.EFF(0),2&a){const e=t.XpG().$implicit;t.SpI(" ",e.value," ")}}function Wt(a,s){if(1&a&&(t.j41(0,"div",3)(1,"strong",4),t.EFF(2),t.k0s(),t.j41(3,"div",5),t.nVh(4,Kt,1,4,"ng-container",1)(5,Zt,1,1),t.k0s()()),2&a){const e=s.$implicit,n=t.XpG(2);t.R7$(2),t.SpI("",e.key,":"),t.R7$(2),t.vxM(n.isNestedObject(e.value)?4:5)}}function te(a,s){if(1&a&&(t.j41(0,"div",2),t.Z7z(1,Wt,6,2,"div",3,t.fX1),t.nI1(3,"keyvalue"),t.k0s()),2&a){const e=s.$implicit;t.R7$(),t.Dyx(t.bMT(3,0,e))}}let ee=(()=>
1{class a{isNestedObject(e){return e instanceof Object}static{this.\u0275fac=function(n){return new(n||a)}}static{this.\u0275cmp=t.VBU({type:a,selectors:[["cb-health-list"]],inputs:{healthData:"healthData"},standalone:!1,decls:3,vars:4,consts:[["listTmpl",""],[3,"ngTemplateOutlet","ngTemplateOutletContext"],[1,"g-row__wrapper"],[1,"g-row"],[1,"g-row__desc"],[1,"g-row__value"]],template:function(n,i){if(1&n&&(t.eu8(0,1),t.DNE(1,te,4,2,"ng-template",null,0,t.C5r)),2&n){const o=t.sdS(2);t.Y8G("ngTemplateOutlet",o)("ngTemplateOutletContext",t.eq3(2,z,i.healthData))}},dependencies:[T.T3,T.lG],encapsulation:2,changeDetection:0})}}return a})();var ne=p(20332);const ae=["dateInput"];function ie(a,s){if(1&a){const e=t.RV6();t.j41(0,"cb-button",12),t.bIt("clickHandler",function(){const i=r.eBV(e).$implicit,o=t.XpG(2);return r.Njj(o.changePickerMode(i))}),t.k0s()}if(2&a){const e=s.$implicit,n=t.XpG(2);t.Y8G("text",e)("type",e==n.currentState?"golden":"bordered")}}function oe(a,s){if(1&a){const e=t.RV6();t.j41(0,"cb-date-picker",13),t.mxI("dateChange",function(i){r.eBV(e);const o=t.XpG(2);return t.DH7(o.selectedDate,i)||(o.selectedDate=i),r.Njj(i)}),t.bIt("dateChange",function(){r.eBV(e);const i=t.XpG(2);return r.Njj(i.onDateChange())}),t.k0s()}if(2&a){const e=t.XpG(2);t.R50("date",e.selectedDate),t.Y8G("maxDate",e.maxDate)}}function se(a,s){if(1&a&&(t.j41(0,"div",6)(1,"div",9),t.Z7z(2,ie,1,2,"cb-button",10,t.fX1),t.k0s(),t.nVh(4,oe,1,2,"cb-date-picker",11),t.k0s()),2&a){const e=t.XpG();t.R7$(2),t.Dyx(e.pickerStates),t.R7$(2),t.vxM("date"==e.currentState?4:-1)}}function re(a,s){if(1&a){const e=t.RV6();t.j41(0,"cb-button",14),t.bIt("clickHandler",function(){r.eBV(e);const i=t.XpG();return r.Njj(i.changePickerMode("today"))}),t.k0s(),t.j41(1,"cb-button",14),t.bIt("clickHandler",function(){r.eBV(e);const i=t.XpG();return r.Njj(i.changeDateString())}),t.k0s()}2&a&&(t.Y8G("type","transparent")("icon","close"),t.R7$(),t.Y8G("type","transparent")("icon","check-mark"))}function le(a,s){if(1&a&&(t.j41(0,"th"),t.EFF(1),t.k0s()),2&a){const e=s.$implicit;t.R7$(),t.JRh(e)}}function ce(a,s){if(1&a&&(t.j41(0,"td"),t.EFF(1),t.k0s()),2&a){const e=s.$implicit,n=t.XpG().$implicit,i=t.XpG(3);t.R7$(),t.JRh(i.metrics[n][e])}}function _e(a,s){if(1&a&&(t.j41(0,"tr")(1,"td"),t.EFF(2),t.k0s(),t.Z7z(3,ce,2,1,"td",null,t.fX1),t.k0s()),2&a){const e=s.$implicit,n=t.XpG(3);t.AVh("adm-tasks__row_error",n.metrics[e].errors)("adm-tasks__row_fatal",n.metrics[e].fatals),t.R7$(2),t.JRh(e),t.R7$(),t.Dyx(n.tableColumns)}}function de(a,s){if(1&a&&(t.j41(0,"table",15)(1,"thead")(2,"th"),t.EFF(3,"Name"),t.k0s(),t.Z7z(4,le,2,1,"th",null,t.fX1),t.k0s(),t.j41(6,"tbody"),t.Z7z(7,_e,5,5,"tr",17,t.fX1),t.k0s()()),2&a){const e=t.XpG(2);t.R7$(4),t.Dyx(e.tableColumns),t.R7$(3),t.Dyx(e.tableRows)}}function pe(a,s){if(1&a&&(t.qex(0),t.nVh(1,de,9,0,"table",15),t.nrm(2,"p",16),t.nI1(3,"cbPrettyJSON"),t.bVm()),2&a){const e=t.XpG();t.R7$(),t.vxM(e.tableColumns.length&&e.tableRows.length?1:-1),t.R7$(),t.Y8G("innerHTML",t.bMT(3,2,e.listValues),t.npT)}}let ue=(()=>{class a{constructor(e){this.translate=e,this.changeDateHandler=new r.bkB,this.tableRows=[],this.tableColumns=[],this.listValues={},this.pickerOpened=!1,this.selectedDate=new Date,this.maxDate=new Date,this.currentState="today",this.pickerStates=["today","yesterday","date","pattern"]}ngOnInit(){this.updateDateString()}ngOnChanges(e){e.metrics&&this.metrics&&(this.tableRows=[],this.tableColumns=[],this.listValues={},Object.keys(this.metrics).forEach(n=>{this.metrics[n]instanceof v?this.tableRows.push(n):this.listValues[n]=this.metrics[n]}),this.tableRows.length>0&&(this.tableColumns=Object.keys(this.metrics[this.tableRows[0]])))}updateDateString(){this.selectedDateStr=(0,T.Yq)(this.selectedDate,"yyyy-MM-dd","en-US")}onDateChange(){var e=this;return(0,_.A)(function*(){e.pickerOpened=!1,e.updateDateString(),e.changeDateHandler.emit(e.selectedDateStr)})()}onDocumentClick(){this.pickerOpened=!1}changePickerMode(e){switch(this.currentState=e,this.currentState){case"today":this.pickerOpened=!1,this.selectedDate=new Date,this.updateDateString(),this.changeDateHandler.emit(this.selectedDateStr);break;case"yesterday":this.pickerOpened=!1,this.selectedDate=new Date,this.selectedDate.setDate(this.selectedDate.getDate()-1),this.updateDateString(),this.changeDateHandler.emit(this.selectedDateStr);break;case"pattern":this.dateInput.nativeElement.focus(),this.pickerOpened=!1}}changeDateString(){this.changeDateHandler.emit(this.selectedDateStr)}pickerStateChange(){"pattern"!==this.currentState&&(this.pickerOpened=!this.pickerOpened)}static{this.\u0275fac=function(n){return new(n||a)(t.rXU(m.c$))}}static{this.\u0275cmp=t.VBU({type:a,selectors:[["cb-jobs-activity"]],viewQuery:function(n,i){if
1(1&n&&t.GBs(ae,5),2&n){let o;t.mGM(o=t.lsd())&&(i.dateInput=o.first)}},hostBindings:function(n,i){1&n&&t.bIt("click",function(){return i.onDocumentClick()},t.EBC)},inputs:{metrics:"metrics",updated:"updated"},outputs:{changeDateHandler:"changeDateHandler"},standalone:!1,features:[t.OA$],decls:10,vars:6,consts:[["dateInput",""],[1,"adm-row"],[1,"adm-row__input",3,"click"],[1,"g-input",3,"ngModelChange","click","keyup.enter","readonly","ngModel"],[1,"adm-row__input-icon"],["iconType","calendar",3,"specificColor"],[1,"g-popup","g-popup_metrics"],[1,"adm-row__controls"],[4,"cbLoader"],[1,"g-popup__buttons"],[3,"text","type"],[3,"date","maxDate"],[3,"clickHandler","text","type"],[3,"dateChange","date","maxDate"],[3,"clickHandler","type","icon"],[1,"g-table"],[3,"innerHTML"],[3,"adm-tasks__row_error","adm-tasks__row_fatal"]],template:function(n,i){if(1&n){const o=t.RV6();t.j41(0,"div",1)(1,"div",2),t.bIt("click",function(u){return u.stopPropagation()}),t.j41(2,"input",3,0),t.mxI("ngModelChange",function(u){return r.eBV(o),t.DH7(i.selectedDateStr,u)||(i.selectedDateStr=u),r.Njj(u)}),t.bIt("click",function(){return i.pickerStateChange()})("keyup.enter",function(){return i.changeDateString()}),t.k0s(),t.j41(4,"div",4),t.nrm(5,"cb-icon",5),t.k0s(),t.nVh(6,se,5,1,"div",6),t.k0s(),t.j41(7,"div",7),t.nVh(8,re,2,4),t.k0s()(),t.DNE(9,pe,4,4,"ng-container",8)}2&n&&(t.R7$(2),t.Y8G("readonly","pattern"!==i.currentState),t.R50("ngModel",i.selectedDateStr),t.R7$(3),t.Y8G("specificColor","default"),t.R7$(),t.vxM(i.pickerOpened?6:-1),t.R7$(2),t.vxM("pattern"==i.currentState?8:-1),t.R7$(),t.Y8G("cbLoader",i.updated))},dependencies:[b.me,b.BC,b.vS,x.R,ne.I,N.Q,V.d,E.yT],encapsulation:2,changeDetection:0})}}return a})();const ge=["tasksTable"],be=["query"],me=a=>[a,"task_id"],he=a=>[a,"enable"],ke=a=>[a,"type"],fe=a=>[a,"state"],ve=a=>[a,"metrics.warnings"],Ce=a=>[a,"metrics.errors"],ye=a=>[a,"metrics.fatals"],w=()=>["day","hour","minute","second"],L=a=>({periods:a}),K=()=>({main:"yyyy-MM-dd HH:mm:ss"});function Te(a,s){if(1&a){const e=t.RV6();t.j41(0,"button",10),t.bIt("click",function(){const i=r.eBV(e).$implicit,o=t.XpG();return r.Njj(o.changeTab(i.value))}),t.EFF(1),t.nI1(2,"translate"),t.k0s()}if(2&a){const e=s.$implicit,n=t.XpG();t.AVh("cb-active",n.tab==e.value),t.R7$(),t.JRh(t.bMT(2,3,e.label))}}function Fe(a,s){if(1&a){const e=t.RV6();t.j41(0,"button",14),t.bIt("click",function(){r.eBV(e);const i=t.XpG(2);return r.Njj(i.killAll())}),t.nrm(1,"cb-icon",15),t.k0s()}if(2&a){const e=t.XpG(2);t.Y8G("cbTooltip","Kill all")("disabled",e.pending)}}function je(a,s){if(1&a){const e=t.RV6();t.qex(0,6),t.nVh(1,Fe,2,2,"button",11),t.j41(2,"button",12),t.bIt("click",function(){r.eBV(e);const i=t.XpG();return r.Njj(i.updateTabInfo())}),t.nrm(3,"cb-icon",13),t.k0s(),t.bVm()}if(2&a){const e=t.XpG();t.R7$(),t.vxM("etl-manager"==e.tab?1:-1),t.R7$(),t.Y8G("disabled",e.pending)}}function Re(a,s){if(1&a){const e=t.RV6();t.j41(0,"button",59),t.bIt("click",function(){r.eBV(e);const i=t.XpG().$implicit,o=t.XpG(3);return r.Njj(o.taskKill(i))}),t.nrm(1,"cb-icon",15),t.k0s()}if(2&a){const e=t.XpG(4);t.BMQ("disabled",e.pending?"":null)}}function $e(a,s){if(1&a){const e=t.RV6();t.j41(0,"button",60),t.bIt("click",function(){r.eBV(e);const i=t.XpG().$implicit,o=t.XpG(3);return r.Njj(o.taskRun(i))}),t.nrm(1,"cb-icon",61),t.k0s()}if(2&a){const e=t.XpG(4);t.BMQ("disabled",e.pending?"":null)}}function Ge(a,s){if(1&a&&(t.EFF(0),t.nI1(1,"translate"),t.nI1(2,"cbPeriodFormat")),2&a){const e=t.XpG(2).$implicit,n=t.XpG(3);t.SpI(" ",t.bMT(1,1,"in")+" "+t.brH(2,3,e.next_start,n.now,n.translate.currentLang)," ")}}function xe(a,s){if(1&a&&(t.j41(0,"span",62),t.EFF(1),t.nI1(2,"cbPeriodFormat"),t.nI1(3,"translate"),t.k0s()),2&a){const e=t.XpG(2).$implicit,n=t.XpG(3);t.R7$(),t.SpI(" ",t.brH(2,1,e.next_start,n.now,n.translate.currentLang)+" "+t.bMT(3,5,"late")," ")}}function De(a,s){if(1&a&&t.nVh(0,Ge,3,7)(1,xe,4,7,"span",62),2&a){const e=t.XpG().$implicit,n=t.XpG(3);t.vxM(e.next_start.getTime()>n.now.getTime()?0:1)}}function Ie(a,s){if(1&a&&(t.j41(0,"div",69),t.nrm(1,"cb-date",74),t.k0s()),2&a){const e=t.XpG(2).$implicit;t.R7$(),t.Y8G("date",e.start_time)("format",t.lJ4(3,K))("disableTooltip",!0)}}function Ae(a,s){if(1&a&&(t.j41(0,"div",69),t.EFF(1),t.nI1(2,"cbPeriodFormat"),t.k0s()),2&a){const e=t.XpG(2).$implicit,n=t.XpG(3);t.R7$(),t.SpI(" ",t.ii3(2,1,e.end_time,e.start_time,n.translate.currentLang,t.eq3(7,L,t.lJ4(6,w)))," ")}}function Ve(a,s){if(1&a&&(t.j41(0,"div",67)(1,"div",68),t.EFF(2,"Cron:"),t.k0s(),t.j41(3,"div",69),t.EFF(4),t.k0s()()),2&a){const e=t.XpG(2).$implicit;t.R7$(4),t.SpI(" ",e.cron," ")}}function Me(a,s){if(1&a&&(t.j41(0,"div",67)(1,"div",68),t.EFF(2,"On event:"),t.k0s(),t.j41(3,"div",71),t.EFF(4),t.k0s()()),2&a){const e=t.XpG(2).$implicit;t.R7$(4),t.SpI(" ",e.on_event," ")}}function Oe(a,s){if(1&a&&(t.j41(0,"div",67)(1,"div",68),t.EFF(2,"File path:"),t.k0s(),t.j41(3,"div",69),t.EFF(4),t.k0s()()),2&a){const e=t.XpG(2).$implicit;t.R7$(4),t.SpI(" ",e.file_path||"n/a"," ")}}function Ee(a,s){if(1&a&&(t.j41(0,"div",69),t.nrm(1,"cb-date",74),t.k0s()),2&a){const e=t.XpG(3).$implicit;t.R7$(),t.Y8G("date",e.last_update)("format",t.lJ4(3,K))("disableTooltip",!0)}}function we(a,s){if(1&a&&(t.j41(0,"div",67)(1,"div",68),t.EFF(2,"Last update:"),t.k0s(),t.nVh(3,Ee,2,4,"div",69),t.k0s()),2&a){const e=t.XpG(2).$implicit;t.R7$(3),t.vxM(null!=e.last_update&&e.last_update.getTime()?3:-1)}}function Le(a,s){if(1&a&&(t.j41(0,"li"),t.EFF(1),t.k0s()),2&a){const e=s.$implicit,n=t.XpG(6);t.AVh("g-task-conflicts__active",n.isWorkingConflict(e)),t.R7$(),t.SpI(" ",e.split(":")[0]," ")}}function Se(a,s){if(1&a&&(t.j41(0,"div",73)(1,"h3",19),t.EFF(2,"Conflicts"),t.k0s(),t.j41(3,"ul",75),t.Z7z(4,Le,2,3,"li",76,t.fX1),t.k0s()()),2&a){const e=t.XpG(2).$implicit;t.R7$(4),t.Dyx(e.conflicts_with)}}function Ne(a,s){if(1&a&&(t.j41(0,"tr",58),t.nrm(1,"td",30),t.j41(2,"td",63)(3,"div",64)(4,"div",65)(5,"h3",19),t.EFF(6,"Task info:"),t.k0s(),t.j41(7,"div",66)(8,"div",67)(9,"div",68),t.EFF(10,"Last start at:"),t.k0s(),t.nVh(11,Ie,2,4,"div",69),t.k0s(),t.j41(12,"div",67)(13,"div",68),t.EFF(14,"Last work time:"),t.k0s(),t.nVh(15,Ae,3,9,"div",69),t.k0s(),t.nVh(16,Ve,5,1,"div",67),t.nVh(17,Me,5,1,"div",67),t.nVh(18,Oe,5,1,"div",67),t.nVh(19,we,4,1,"div",67),t.j41(20,"div",70)(21,"div",68),t.EFF(22,"Arguments:"),t.k0s(),t.j41(23,"div",71),t.EFF(24),t.k0s()()()(),t.j41(25,"div",72)(26,"h3",19),t.EFF(27,"Metrics:"),t.k0s(),t.j41(28,"div",66)(29,"div",67)(30,"div",68),t.EFF(31,"Avg work time:"),t.k0s(),t.j41(32,"div",69),t.EFF(33),t.nI1(34,"cbPeriodFormat"),t.k0s()(),t.j41(35,"div",67)(36,"div",68),t.EFF(37,"Start count:"),t.k0s(),t.j41(38,"div",69),t.EFF(39),t.k0s()(),t.j41(40,"div",67)(41,"div",68),t.EFF(42,"Total work time:"),t.k0s(),t.j41(43,"div",69),t.EFF(44),t.nI1(45,"cbPeriodFormat"),t.k0s()()()(),t.nVh(46,Se,6,0,"div",73),t.k0s()()()),2&a){const e=t.XpG().$implicit,n=t.XpG(3);t.R7$(11),t.vxM(null!=e.start_time&&e.start_time.getTime()?11:-1),t.R7$(4),t.vxM(null!=e.end_time&&e.end_time.getTime()?15:-1),t.R7$(),t.vxM("cron"==e.type?16:-1),t.R7$(),t.vxM("event"==e.type?17:-1),t.R7$(),t.vxM("touch"==e.type?18:-1),t.R7$(),t.vxM("touch"==e.type?19:-1),t.R7$(5),t.SpI(" ",null==e.args?null:e.args.join(", ")," "),t.R7$(9),t.SpI(" ",null!=e.metrics&&e.metrics.average?t.ii3(34,11,e.metrics.average,n.start,n.translate.currentLang,t.eq3(22,L,t.lJ4(21,w))):"n/a"," "),t.R7$(6),t.SpI(" ",(null==e.metrics?null:e.metrics.count)||"n/a"," "),t.R7$(5),t.SpI(" ",null!=e.metrics&&e.metrics.total_worktime?t.ii3(45,16,null==e.metrics?null:e.metrics.total_worktime,n.start,n.translate.currentLang,t.eq3(25,L,t.lJ4(24,w))):"n/a"," "),t.R7$(2),t.vxM(null!=e.conflicts_with&&e.conflicts_with.length?46:-1)}}function Xe(a,s){if(1&a){const e=t.RV6();t.j41(0,"tr",40)(1,"td",30)(2,"button",41),t.bIt("click",function(){const i=r.eBV(e).$implicit,o=t.XpG(3);
1return r.Njj(o.toggleFullView(i.task_id))}),t.nrm(3,"cb-icon",42),t.k0s()(),t.j41(4,"td",43)(5,"button",44),t.bIt("click",function(){const i=r.eBV(e).$implicit,o=t.XpG(3);return r.Njj(o.openTaskLogHandler(i))}),t.EFF(6),t.k0s()(),t.j41(7,"td",45)(8,"div",46),t.nrm(9,"input",47),t.j41(10,"label",48),t.bIt("click",function(){const i=r.eBV(e).$implicit,o=t.XpG(3);return r.Njj(o.taskEnableToggler(i))}),t.nrm(11,"cb-icon",49),t.k0s()(),t.nVh(12,Re,2,1,"button",50),t.nVh(13,$e,2,1,"button",51),t.k0s(),t.j41(14,"td",52),t.EFF(15),t.k0s(),t.j41(16,"td",53),t.EFF(17),t.k0s(),t.j41(18,"td",54),t.EFF(19),t.k0s(),t.j41(20,"td",55),t.EFF(21),t.k0s(),t.j41(22,"td",56),t.EFF(23),t.k0s(),t.j41(24,"td",38),t.EFF(25),t.k0s(),t.j41(26,"td",57),t.nVh(27,De,2,1),t.k0s()(),t.nVh(28,Ne,47,27,"tr",58)}if(2&a){const e=s.$implicit,n=t.XpG(3);t.AVh("adm-tasks__row_error",null==e.metrics?null:e.metrics.errors)("adm-tasks__row_fatal",null==e.metrics?null:e.metrics.fatals),t.R7$(3),t.Y8G("iconType",t.mNQ(n.ifFullView(e.task_id)?"minus":"plus")),t.R7$(2),t.Y8G("disabled",n.pending),t.R7$(),t.SpI(" ",e.task_id," "),t.R7$(2),t.Y8G("cbTooltip",e.enable?"Task enabled":"Task disabled"),t.R7$(),t.Y8G("checked",e.enable),t.R7$(),t.BMQ("disabled",n.pending?"":null),t.R7$(2),t.vxM("stopped"!==e.state?12:-1),t.R7$(),t.vxM("stopped"==e.state?13:-1),t.R7$(2),t.JRh(e.type),t.R7$(),t.AVh("adm-tasks__state_running","running"===e.state),t.R7$(),t.SpI(" ",e.state," "),t.R7$(2),t.SpI(" ",(null==e.metrics?null:e.metrics.warnings)||""," "),t.R7$(2),t.SpI(" ",(null==e.metrics?null:e.metrics.errors)||""," "),t.R7$(2),t.SpI(" ",(null==e.metrics?null:e.metrics.fatals)||null," "),t.R7$(),t.AVh("adm-tasks__conflicts_active",e.conflicts_with&&n.hasWorkingConflicts(e)),t.R7$(),t.SpI(" ",(null==e.conflicts_with?null:e.conflicts_with.length)||""," "),t.R7$(2),t.vxM(null!=e.next_start&&e.next_start.getTime()?27:-1),t.R7$(),t.vxM(n.ifFullView(e.task_id)?28:-1)}}function qe(a,s){if(1&a&&(t.j41(0,"tr")(1,"td",77)(2,"div",78),t.EFF(3,"No matches were found for your query"),t.k0s()()()),2&a){t.XpG();const e=t.sdS(23);t.R7$(),t.Y8G("colSpan",e.childElementCount)}}function Pe(a,s){if(1&a){const e=t.RV6();t.qex(0),t.j41(1,"div",17)(2,"div",18)(3,"div",19),t.EFF(4," Manager state: "),t.j41(5,"span"),t.EFF(6),t.k0s()(),t.j41(7,"div",20)(8,"input",21),t.bIt("click",function(i){r.eBV(e);const o=t.XpG(2);return i.preventDefault(),r.Njj(o.managerStateToggle())}),t.k0s(),t.j41(9,"label",22),t.nrm(10,"cb-icon",23),t.k0s()(),t.j41(11,"button",24),t.bIt("click",function(){r.eBV(e);const i=t.XpG(2);return r.Njj(i.openManagerLogHandler())}),t.EFF(12," Manager logs "),t.k0s()()(),t.j41(13,"div",25)(14,"div",26)(15,"input",27,0),t.nI1(17,"translate"),t.bIt("input",function(i){r.eBV(e);const o=t.XpG(2);return o.taskQueryValue=null==i.target?null:i.target.value,r.Njj(o.cbTable.filter())}),t.k0s()(),t.j41(18,"cb-button-toggler",28),t.mxI("valueChange",function(i){r.eBV(e);const o=t.XpG(2);return t.DH7(o.taskCategory,i)||(o.taskCategory=i),r.Njj(i)}),t.bIt("valueChange",function(){r.eBV(e);const i=t.XpG(2);return r.Njj(i.cbTable.filter())}),t.k0s()(),t.j41(19,"table",29,1),t.mxI("cbTableOrderChange",function(i){r.eBV(e);const o=t.XpG(2);return t.DH7(o.taskOrder,i)||(o.taskOrder=i),r.Njj(i)}),t.j41(21,"thead")(22,"tr",null,2),t.nrm(24,"th",30),t.j41(25,"th",31),t.EFF(26,"Task id"),t.k0s(),t.j41(27,"th",32),t.EFF(28,"Action"),t.k0s(),t.j41(29,"th",33),t.EFF(30,"Type"),t.k0s(),t.j41(31,"th",34),t.EFF(32,"State"),t.k0s(),t.j41(33,"th",35),t.EFF(34," Warnings "),t.k0s(),t.j41(35,"th",36),t.EFF(36,"Errors "),t.k0s(),t.j41(37,"th",37),t.EFF(38,"Fatals "),t.k0s(),t.j41(39,"th",38),t.EFF(40,"Conflicts"),t.k0s(),t.j41(41,"th",39),t.EFF(42,"Next start"),t.k0s()()(),t.j41(43,"tbody"),t.Z7z(44,Xe,29,25,null,null,t.fX1),t.nVh(46,qe,4,1,"tr"),t.k0s()(),t.bVm()}if(2&a){const e=t.sdS(20),n=t.XpG(2);t.R7$(5),t.AVh("g-color_in","active"==n.etlData.manager.state),t.R7$(),t.JRh(n.etlData.manager.state),t.R7$(2),t.Y8G("checked","active"==n.etlData.manager.state),t.BMQ("disabled",n.pending?"":null),t.R7$(2),t.Y8G("specificColor","active"==n.etlData.manager.state?"default":"disabled"),t.R7$(5),t.Y8G("value",n.taskQueryValue)("placeholder",t.bMT(17,22,"Enter task id")),t.R7$(3),t.Y8G("options",n.taskCategories),t.R50("value",n.taskCategory),t.R7$(),t.Y8G("cbTable",n.etlData.tasks)("cbTableLimit",n.etlData.tasks.length)("cbTableFilter",n.tasksFilterer),t.R50("cbTableOrder",n.taskOrder),t.R7$(6),t.Y8G("cbTableSort",t.eq3(24,me,e)),t.R7$(2),t.Y8G("cbTableSort",t.eq3(26,he,e)),t.R7$(2),t.Y8G("cbTableSort",t.eq3(28,ke,e)),t.R7$(2),t.Y8G("cbTableSort",t.eq3(30,fe,e)),t.R7$(2),t.Y8G("cbTableSort",t.eq3(32,ve,e)),t.R7$(2),t.Y8G("cbTableSort",t.eq3(34,Ce,e)),t.R7$(2),t.Y8G("cbTableSort",t.eq3(36,ye,e)),t.R7$(7),t.Dyx(n.castTasks(e.data)),t.R7$(2),t.vxM(!e.data.length&&null!=n.taskQuery&&n.taskQuery.nativeElement.value.length?46:-1)}}function Be(a,s){if(1&a&&t.DNE(0,Pe,47,38,"ng-container",16),2&a){const e=t.XpG();t.Y8G("cbLoader",e.updated)("cbLoaderDelay",0)}}function Ye(a,s){if(1&a&&t.nrm(0,"cb-health-list",7),2&a){const e=t.XpG(2);t.Y8G("healthData",e.healthData)}}function He(a,s){if(1&a&&t.DNE(0,Ye,1,1,"cb-health-list",79),2&a){const e=t.XpG();t.Y8G("cbLoader",!e.healthData||e.updated)("cbLoaderDelay",0)}}
1function Je(a,s){if(1&a&&(t.qex(0),t.j41(1,"div",83),t.EFF(2,"Logs"),t.k0s(),t.nrm(3,"cb-logs",84),t.bVm()),2&a){const e=t.XpG(4);t.R7$(3),t.Y8G("data",e.indirectLogs)}}function Ue(a,s){if(1&a){const e=t.RV6();t.j41(0,"div",80)(1,"div")(2,"div",17)(3,"div",81),t.EFF(4),t.nI1(5,"translate"),t.k0s(),t.j41(6,"button",14),t.bIt("click",function(){r.eBV(e);const i=t.XpG(3);return r.Njj(i.indirectShutdown())}),t.nrm(7,"cb-icon",15),t.k0s(),t.j41(8,"button",14),t.bIt("click",function(){r.eBV(e);const i=t.XpG(3);return r.Njj(i.indirectRenew())}),t.nrm(9,"cb-icon",82),t.k0s(),t.j41(10,"button",14),t.bIt("click",function(){r.eBV(e);const i=t.XpG(3);return r.Njj(i.indirectUpdate())}),t.nrm(11,"cb-icon",13),t.k0s()(),t.nrm(12,"cb-health-list",7),t.DNE(13,Je,4,1,"ng-container",16),t.k0s()()}if(2&a){const e=t.XpG(3);t.R7$(4),t.JRh(t.bMT(5,10,e.indirectTabLabel.indirect)),t.R7$(2),t.Y8G("cbTooltip","Shutdown")("disabled",e.pending),t.R7$(2),t.Y8G("cbTooltip","Renew")("disabled",e.pending),t.R7$(2),t.Y8G("cbTooltip","Update")("disabled",e.pending),t.R7$(2),t.Y8G("healthData",e.healthIndirectData.indirect),t.R7$(),t.Y8G("cbLoader",!e.indirectLogs||e.updated)("cbLoaderDelay",0)}}function Qe(a,s){1&a&&(t.j41(0,"div",78),t.EFF(1,"No data"),t.k0s())}function ze(a,s){if(1&a&&(t.qex(0),t.nVh(1,Ue,14,12,"div",80)(2,Qe,2,0,"div",78),t.bVm()),2&a){const e=t.XpG(2);t.R7$(),t.vxM(e.hasHealhData(null==e.healthIndirectData?null:e.healthIndirectData.indirect)?1:2)}}function Ke(a,s){if(1&a&&t.DNE(0,ze,3,1,"ng-container",16),2&a){const e=t.XpG();t.Y8G("cbLoader",!e.healthIndirectData||e.updated)("cbLoaderDelay",0)}}function Ze(a,s){if(1&a){const e=t.RV6();t.j41(0,"cb-jobs-activity",85),t.bIt("changeDateHandler",function(i){r.eBV(e);const o=t.XpG();return r.Njj(o.updateActivityInfo(i))}),t.k0s()}if(2&a){const e=t.XpG();t.Y8G("metrics",e.jobsActivity)("updated",e.updated)}}function We(a,s){if(1&a){const e=t.RV6();t.j41(0,"cb-pg-locks",90),t.mxI("orderChange",function(i){r.eBV(e);const o=t.XpG(2);return t.DH7(o.pgLocksOrder,i)||(o.pgLocksOrder=i),r.Njj(i)}),t.bIt("killTask",function(i){r.eBV(e);const o=t.XpG(2);return r.Njj(o.killPostgressTask(i))}),t.k0s()}if(2&a){const e=t.XpG(2);t.Y8G("pgLocks",e.pgLocks)("pending",e.pending),t.R50("order",e.pgLocksOrder)}}function tn(a,s){if(1&a){const e=t.RV6();t.j41(0,"cb-pg-activity",91),t.mxI("orderChange",function(i){r.eBV(e);const o=t.XpG(2);return t.DH7(o.pgActivityOrder,i)||(o.pgActivityOrder=i),r.Njj(i)}),t.bIt("killTask",function(i){r.eBV(e);const o=t.XpG(2);return r.Njj(o.killPostgressTask(i))}),t.k0s()}if(2&a){const e=t.XpG(2);t.Y8G("activity",e.pgActivity)("pending",e.pending),t.R50("order",e.pgActivityOrder)}}function en(a,s){if(1&a&&(t.j41(0,"div",17)(1,"div",86),t.EFF(2,"Locks"),t.k0s()(),t.DNE(3,We,1,3,"cb-pg-locks",87),t.j41(4,"div",88)(5,"div",86),t.EFF(6,"Activity"),t.k0s()(),t.DNE(7,tn,1,3,"cb-pg-activity",89)),2&a){const e=t.XpG();t.R7$(3),t.Y8G("cbLoader",!e.pgLocks||e.updated)("cbLoaderDelay",0),t.R7$(4),t.Y8G("cbLoader",!e.pgActivity||e.updated)("cbLoaderDelay",0)}}function nn(a,s){if(1&a){const e=t.RV6();t.j41(0,"cb-ch-activity",91),t.mxI("orderChange",function(i){r.eBV(e);const o=t.XpG(2);return t.DH7(o.chActivityOrder,i)||(o.chActivityOrder=i),r.Njj(i)}),t.bIt("killTask",function(i){r.eBV(e);const o=t.XpG(2);return r.Njj(o.killClickhouseTask(i))}),t.k0s()}if(2&a){const e=t.XpG(2);t.Y8G("activity",e.chActivity)("pending",e.pending),t.R50("order",e.chActivityOrder)}}function an(a,s){if(1&a&&(t.j41(0,"div",88)(1,"div",86),t.EFF(2,"Activity"),t.k0s()(),t.DNE(3,nn,1,3,"cb-ch-activity",89)),2&a){const e=t.XpG();t.R7$(3),t.Y8G("cbLoader",!e.chActivity||e.updated)("cbLoaderDelay",0)}}function on(a,s){if(1&a&&(t.qex(0),t.nrm(1,"cb-logs",84),t.bVm()),2&a){const e=t.XpG(2);t.R7$(),t.Y8G("data",e.apiLogs)}}function sn(a,s){if(1&a&&t.DNE(0,on,2,1,"ng-container",16),2&a){const e=t.XpG();t.Y8G("cbLoader",!e.apiLogs||e.updated)("cbLoaderDelay",0)}}function rn(a,s){1&a&&(t.j41(0,"div",9),t.nrm(1,"cb-loader",92),t.k0s()),2&a&&(t.R7$(),t.Y8G("delay",0))}let ln=(()=>{class a{isIndirectTabAvailable(e){return e instanceof l.SjR}constructor(e,n,i,o,d,u,h,_n){this.route=e,this.router=n,this.service=i,this.dialoger=o,this.messager=d,this.config=u,this.ref=h,this.translate=_n,this.updated=!0,this.loading=!0,this.fullView=[],this.now=new Date,this.start=new Date(0),this.indirectTabLabel=F.kS.ops["indirect-tab"],this.pickerOpened=!1,this.jobsActivityDate=new Date,this.pending=!1,this.envs=this.service.getEnvs(),this.allTabs=(0,l.zOI)(F.kS.ops.tabs),this.taskCategories=[{label:"all",value:null},...at.map(D=>({label:D,value:D}))],this.tasksFilterer=D=>(0,l.K$i)(D.category,this.taskCategory)&&(0,l.K$i)(D.task_id,this.taskQueryValue)}hasHealhData(e){return!!e&&Object.keys(e).length>0}setDefaultTablesMeta(){this.taskCategory=null,this.taskQueryValue="",this.taskOrder=["task_id","asc"],this.pgLocksOrder=["blocked_app_name","asc"],this.pgActivityOrder=["application_name","asc"]}castTasks(e){return e}ngOnInit(){var e=this;return(0,_.A)(function*(){et.k.setTitle((0,nt.x)("Ops"),null),e.setDefaultTablesMeta(),yield e.changeTabEvent(),e.ref.detectChanges(),e.route.queryParams.subscribe(n=>{e.env=e.getEnvValue(n.env),e.tabs=e.getTabsListByEnv(e.env),e.tab=e.getTabValue(n.tab),e.changeTabEvent()})})()}getTabsListByEnv(e){return this.isIndirectTabAvailable(e)?[...this.allTabs]:this.allTabs.filter(n=>"health-indirect"!=n.value)}getTabValue(e){return(this.tabs.find(i=>i.value==e)??this.tabs[0]).value}getEnvValue(e){const n=this.envs.find(i=>"string"==typeof i.value?i.value==e:i.value.value==e);return n?n.value:this.envs[0].value}getEnvUrlParam(e){return e instanceof l.SjR?e.value:e}changeTab(e){this.pending||(this.setDefaultTablesMeta(),this.router.navigate([],{queryParams:{tab:e},queryParamsHandling:"merge",replaceUrl:!0}))}changeEnv(e){this.pending||(this.setDefaultTablesMeta(),this.router.navigate([],{queryParams:{env:this.getEnvUrlParam(e)},queryParamsHandling:"merge",replaceUrl:!0}))}changeTabEvent(){var e=this;return(0,_.A)(function*(){e.pickerOpened=!1,e.jobsActivityDate=new Date,yield e.updateTabInfo()})()}updateTabInfo(){var e=this;
1return(0,_.A)(function*(){switch(e.tab){case"etl-manager":yield e.loadList();break;case"health":yield e.updateHealth();break;case"health-indirect":yield e.updateIndirectHealth();break;case"activity":yield e.updateJobsActivity();break;case"postgres":yield e.updatePGInfo();break;case"clickhouse":yield e.updateCHInfo();break;case"log-api":yield e.updateApiLogs()}e.ref.detectChanges()})()}toggleFullView(e){const n=this.fullView.findIndex(i=>i===e);-1==n?this.fullView.push(e):this.fullView.splice(n,1)}ifFullView(e){return this.fullView.includes(e)}taskEnableToggler(e){var n=this;return(0,_.A)(function*(){if(n.pending)return;const i=e.enable;if(!(yield n.dialoger.confirm(i?"Disable task":"Enable task",i?`Are you sure want to disable task ${e.task_id}?`:`Are you sure want to enable task ${e.task_id}?`,new Map([[null,"Cancel"],[i?"danger":"ok","Confirm"]]))))return!1;n.pending=!0,n.ref.detectChanges();const d=i?`Failed to disable task ${e.task_id}`:`Failed to enable task ${e.task_id}`,u=i?`Task ${e.task_id} successfully disabled`:`Task ${e.task_id} successfully enabled`;try{let h;if(h=i?yield n.service.etlTaskDisable(n.env,e.task_id):yield n.service.etlTaskEnable(n.env,e.task_id),!h[e.task_id])return n.messager.error(d),!1;e.enable=!e.enable,n.ref.detectChanges(),n.messager.success(u)}catch{n.messager.error(d)}finally{n.pending=!1,n.ref.detectChanges()}})()}taskKill(e){var n=this;return(0,_.A)(function*(){if(!n.pending){if(!(yield n.dialoger.confirm("Kill task",`Are you sure want to kill task ${e.task_id}?`,new Map([[null,"Cancel"],["danger","Confirm"]]))))return!1;n.pending=!0,n.ref.detectChanges();try{(yield n.service.etlTaskKill(n.env,e.task_id))?(e.state="stopped",n.ref.detectChanges(),n.messager.success(`Task ${e.task_id} successfully stopped`)):n.messager.error(`Failed to stop task ${e.task_id}`)}catch{n.messager.error(`Failed to stop task ${e.task_id}`)}finally{n.pending=!1,n.ref.detectChanges()}}})()}taskRun(e){var n=this;return(0,_.A)(function*(){if(n.pending)return;const i=yield n.dialoger.create(Ct,e);if(!i)return!1;n.pending=!0,n.ref.detectChanges();try{(yield n.service.etlTaskRun(n.env,e.task_id,i.args))?(e.state="running",n.ref.detectChanges(),n.messager.success(`Task ${e.task_id} successfully run`)):n.messager.error(`Failed to run task ${e.task_id}`)}catch{n.messager.error(`Failed to run task ${e.task_id}`)}finally{n.pending=!1,n.ref.detectChanges()}})()}managerStateToggle(){var e=this;return(0,_.A)(function*(){if(e.pending)return;const i="active"==e.etlData.manager.state,o=i?"paused":"active";if(!(yield e.dialoger.confirm(i?"Pause manager":"Start manager",`Are you sure want to ${i?"pause":"start"} etl-manager?`,new Map([[null,"Cancel"],[i?"danger":"ok","Confirm"]]))))return!1;e.pending=!0,e.ref.detectChanges();const u=i?"Etl manager successfully paused":"Etl manager successfully resumed";try{(i?yield e.service.etlManagerPause(e.env):yield e.service.etlManagerResume(e.env))?(e.etlData.manager.state=o,e.messager.success(u)):e.messager.error("State was not changed")}catch{e.messager.error("State was not changed")}finally{e.pending=!1,e.ref.detectChanges()}})()}updateManager(){var e=this;return(0,_.A)(function*(){e.pending||(e.updated=!1,yield e.loadList(),e.ref.detectChanges())})()}updatePGInfo(){var e=this;return(0,_.A)(function*(){e.pending||(e.updated=!0,e.ref.detectChanges(),e.pgLocks=yield e.service.etlManagerPGLocks(e.env),e.pgActivity=yield e.service.etlManagerPGActivity(e.env),e.updated=!1)})()}updateCHInfo(){var e=this;return(0,_.A)(function*(){e.pending||(e.updated=!0,e.ref.detectChanges(),e.chActivity=yield e.service.etlManagerCHActivity(e.env),e.updated=!1)})()}updateHealth(){var e=this;return(0,_.A)(function*(){e.pending||(e.updated=!0,e.ref.detectChanges(),e.healthData=yield e.service.etlManagerGetHealthStatus(e.env),e.updated=!1)})()}updateIndirectHealth(){var e=this;return(0,_.A)(function*(){e.pending||(e.updated=!0,e.ref.detectChanges(),e.healthIndirectData=yield e.service.etlManagerGetIndirectHealthStatus(e.env),e.indirectLogs=e.hasHealhData(e.healthIndirectData?.indirect)?yield e.service.getLogIndirect(e.env):null,e.updated=!1)})()}updateJobsActivity(){var e=this;return(0,_.A)(function*(){e.pending||e.updateActivityInfo((0,T.Yq)(e.jobsActivityDate,"yyyy-MM-dd","en-US"))})()}updateActivityInfo(e){var n=this;return(0,_.A)(function*(){n.pending||(n.updated=!0,n.ref.detectChanges(),n.jobsActivity=yield n.service.etlManagerGetJobsActivity(n.env,e),n.updated=!1,n.ref.detectChanges())})()}updateApiLogs(){var e=this;return(0,_.A)(function*(){e.pending||(e.updated=!0,e.ref.detectChanges(),e.apiLogs=yield e.service.getLogApi(e.env),e.updated=!1,e.ref.detectChanges())})()}killAll(){var e=this;return(0,_.A)(function*(){if(!e.pending&&(yield(0,it.ic)("killall","single",{},["danger",F.kS.buttons.kill]))){e.pending=!0,e.ref.detectChanges();try{(yield e.service.etlManagerKillAll(e.env))?.result?(e.messager.success("All tasks successfully killed"),e.pending=!1,e.ref.detectChanges(),yield e.updateManager()):e.messager.error("Can't kill all tasks")}catch{e.messager.error("Can't kill all tasks")}finally{e.pending=!1,e.ref.detectChanges()}}})()}indirectRenew(){var e=this;return(0,_.A)(function*(){if(!e.pending){if(!(yield e.dialoger.confirm("Renew indirect","Are you sure want to start indirect renew?",new Map([[null,"Cancel"],["danger","Confirm"]]))))return!1;e.pending=!0,e.ref.detectChanges();try{e.ref.detectChanges(),yield e.service.etlManagerIndirectAction(e.env,"renew"),e.messager.success("Indirect renew started")}catch{e.messager.error("Failed to start Indirect renew")}finally{e.pending=!1,e.ref.detectChanges()}}})()}indirectUpdate(){var e=this;return(0,_.A)(function*(){if(!e.pending){e.pending=!0,e.ref.detectChanges();try{yield e.service.etlManagerIndirectAction(e.env,"update"),e.messager.success("Indirect update started")}catch{e.messager.error("Failed to start Indirect update")}finally{e.pending=!1,e.ref.detectChanges()}}})()}indirectShutdown(){var e=this;return(0,_.A)(function*(){if(e.pending)return;const i=`${e.env?.symbol} Indirect`;if(yield e.dialoger.confirm(`Shutdown ${i}`,`Are you sure want to shutdown ${i}?`,new Map([[null,"Cancel"],["danger","Confirm"]]))){e.pending=!0,e.ref.detectChanges();try{const d=yield e.service.etlManagerIndirectAction(e.env,"shutdown");yield e.dialoger.create(A.sD,{title:`${i} shutdown result`,body:d.data,buttons:new Map([[!0,F.kS.buttons.close]]),simple:!0})}catch{e.messager.error(`Failed to shutdown ${i}`)}finally{e.pending=!1,e.ref.detectChanges()}}})()}isWorkingConflict(e){const[n,i]=e.split(":");return this.etlData.tasks.some(o=>o.task_id===n&&o.state==i)}hasWorkingConflicts(e){return e.conflicts_with.some(n=>this.isWorkingConflict(n))}random(){return Math.random()}loadList(){var e=this;return(0,_.A)(function*(){e.pending||(e.updated=!0,e.ref.detectChanges(),e.etlData={...yield e.service.getEtlData(e.env)},e.loading=!1,e.updated=!1)})()}killPostgressTask(e){var n=this;return(0,_.A)(function*(){if(n.pending)return;let i=yield n.dialoger.create(S.H,e);if(i){n.pending=!0,n.ref.detectChanges();
1try{yield n.service.pgCancelBackend(n.env,i),n.pending=!1,n.updateTabInfo(),n.messager.success(`Task ${e.pid} successfully killed`)}catch{n.messager.error(`Unable to kill task ${e.pid}`)}finally{n.pending=!1,n.ref.detectChanges()}}})()}killClickhouseTask(e){var n=this;return(0,_.A)(function*(){if(n.pending)return;let i=yield n.dialoger.create(S.H,e);if(i){n.pending=!0,n.ref.detectChanges();try{yield n.service.chCancelBackend(n.env,i),n.pending=!1,n.updateTabInfo(),n.messager.success(`Task ${e.query_id} successfully killed`)}catch{n.messager.error(`Unable to kill task ${e.query_id}`)}finally{n.pending=!1,n.ref.detectChanges()}}})()}onDateChange(){var e=this;return(0,_.A)(function*(){e.pickerOpened=!1,yield e.updateJobsActivity(),e.ref.detectChanges()})()}onDocumentClick(){this.pickerOpened=!1}openTaskLogHandler(e){var n=this;return(0,_.A)(function*(){yield n.dialoger.create(q,{task:e,service:n.service,env:n.env})})()}openManagerLogHandler(){var e=this;return(0,_.A)(function*(){yield e.dialoger.create(q,{task:"log-manager",service:e.service,env:e.env})})()}static{this.\u0275fac=function(n){return new(n||a)(t.rXU(B.nX),t.rXU(B.Ix),t.rXU(Y),t.rXU(A.o3),t.rXU(l.bgN),t.rXU(l.oO7),t.rXU(yt.gRc),t.rXU(m.c$))}}static{this.\u0275cmp=t.VBU({type:a,selectors:[["ng-component"]],viewQuery:function(n,i){if(1&n&&t.GBs(ge,5)(be,5),2&n){let o;t.mGM(o=t.lsd())&&(i.cbTable=o.first),t.mGM(o=t.lsd())&&(i.taskQuery=o.first)}},hostBindings:function(n,i){1&n&&t.bIt("click",function(){return i.onDocumentClick()},t.EBC)},standalone:!1,decls:14,vars:7,consts:[["query",""],["tasksTable","cbTable"],["headRow",""],[1,"g-palette","g-palette_single","adm-tasks"],["left","",3,"valueChange","options","value"],["type","button",1,"g-button","g-button_tab",3,"cb-active"],["right",""],[3,"healthData"],[3,"metrics","updated"],[1,"g-palette-loader","g-palette-loader_fixed"],["type","button",1,"g-button","g-button_tab",3,"click"],["cb-icon-button","",3,"cbTooltip","disabled"],["cb-icon-button","",3,"click","disabled"],["iconType","update"],["cb-icon-button","",3,"click","cbTooltip","disabled"],["iconType","stop"],[4,"cbLoader","cbLoaderDelay"],[1,"g-palette-header"],[1,"g-palette-header__left","adm-manager"],[1,"g-title"],[1,"g-checkbox","g-checkbox_inline"],["type","checkbox","id","etl-state",1,"g-checkbox__input",3,"click","checked"],["for","etl-state",1,"g-checkbox__label"],["iconType","toggle",3,"specificColor"],["cb-link-button","","translate","",3,"click"],[1,"g-table-actions","g-table-actions_align_start"],["cbSearchInput","",1,"g-search","g-search_inline"],["cbSearchInputControl","",1,"g-input","g-search__input",3,"input","value","placeholder"],["size","default",3,"valueChange","options","value"],[1,"g-table","adm-tasks__table",3,"cbTableOrderChange","cbTable","cbTableLimit","cbTableFilter","cbTableOrder"],[1,"g-table__actions","adm-tasks__checkbox-colum"],["translate","",1,"adm-tasks__id",3,"cbTableSort"],["translate","",1,"adm-tasks__actions",3,"cbTableSort"],["translate","",1,"adm-tasks__type",3,"cbTableSort"],["translate","",1,"adm-tasks__state",3,"cbTableSort"],["translate","",1,"adm-tasks__warnings",3,"cbTableSort"],["translate","",1,"adm-tasks__errors",3,"cbTableSort"],["translate","",1,"adm-tasks__fatals",3,"cbTableSort"],[1,"adm-tasks__conflicts"],[1,"adm-tasks__next-start"],[1,"adm-tasks__row"],["type","button","cb-icon-button","",3,"click"],[3,"iconType"],[1,"adm-tasks__id","adm-table__big"],["cb-link-button","",3,"click","disabled"],[1,"adm-tasks__actions"],[1,"g-checkbox","g-checkbox_inline",3,"cbTooltip"],["type","checkbox",1,"g-checkbox__input",3,"checked"],[1,"g-checkbox__label",3,"click"],["iconType","toggle"],["type","button","cb-icon-button","","cbTooltip","Stop task"],["type","button","cb-icon-button","","cbTooltip","Run task"],[1,"adm-tasks__type"],[1,"adm-tasks__state"],[1,"adm-tasks__warnings"],[1,"adm-tasks__errors"],[1,"adm-tasks__fatals"],[1,"adm-tasks__next-start","adm-table__gray"],[1,"g-table__expand"],["type","button","cb-icon-button","","cbTooltip","Stop task",3,"click"],["type","button","cb-icon-button","","cbTooltip","Run task",3,"click"],["iconType","start"],[1,"g-color","g-color_red"],["colspan","9"],[1,"g-cols","g-table__expand-block"],[1,"g-col","g-col_4"],[1,"g-row__wrapper","g-row__wrapper_left"],[1,"g-row"],["translate","",1,"g-row__desc"],[1,"g-row__value"],[1,"g-row","g-color_undefined"],[1,"g-row__value","g-row__value_wrap"],[1,"g-col","g-col_2"],[1,"g-col","g-col_3"],[3,"date","format","disableTooltip"],[1,"g-task-conflicts"],[3,"g-task-conflicts__active"],[1,"g-table__empty",3,"colSpan"],["translate","",1,"g-empty"],[3,"healthData",4,"cbLoader","cbLoaderDelay"],[1,"g-grid-cols"],[1,"g-title","g-title_nomargin"],["iconType","reset"],["translate","",1,"g-title"],[3,"data"],[3,"changeDateHandler","metrics","updated"],["translate","",1,"g-title","g-title_nomargin"],[3,"pgLocks","pending","order","orderChange","killTask",4,"cbLoader","cbLoaderDelay"],[1,"g-palette-header","g-palette-header_padding"],[3,"activity","pen
1ding","order","orderChange","killTask",4,"cbLoader","cbLoaderDelay"],[3,"orderChange","killTask","pgLocks","pending","order"],[3,"orderChange","killTask","activity","pending","order"],[3,"delay"]],template:function(n,i){if(1&n&&(t.j41(0,"div",3)(1,"cb-palette-tabs")(2,"cb-dropdown",4),t.mxI("valueChange",function(d){return t.DH7(i.env,d)||(i.env=d),d}),t.bIt("valueChange",function(d){return i.changeEnv(d)}),t.k0s(),t.Z7z(3,Te,3,5,"button",5,t.fX1),t.nVh(5,je,4,2,"ng-container",6),t.k0s(),t.nVh(6,Be,1,2,"ng-container")(7,He,1,2,"cb-health-list",7)(8,Ke,1,2,"ng-container")(9,Ze,1,2,"cb-jobs-activity",8)(10,en,8,4)(11,an,4,2)(12,sn,1,2,"ng-container"),t.nVh(13,rn,2,1,"div",9),t.k0s()),2&n){let o;t.R7$(2),t.HbH("g-token-dropdown g-token-dropdown_single"),t.Y8G("options",i.envs),t.R50("value",i.env),t.R7$(),t.Dyx(i.tabs),t.R7$(2),t.vxM(i.updated?-1:5),t.R7$(),t.vxM("etl-manager"===(o=i.tab)?6:"health"===o?7:"health-indirect"===o?8:"activity"===o?9:"postgres"===o?10:"clickhouse"===o?11:"log-api"===o?12:-1),t.R7$(7),t.vxM(i.pending?13:-1)}},dependencies:[m.Mm,x.R,j.Q,P.P,Rt.VU,H.i,H.n,J.A,M.a,U.g,$t.R,V.d,y.t,y.N,Lt,Ht,zt,ee,ue,X,m.D9,E.CD],encapsulation:2,changeDetection:0})}}return a})(),cn=(()=>{class a{static{this.\u0275fac=function(n){return new(n||a)}}static{this.\u0275mod=t.$C({type:a})}static{this.\u0275inj=r.G2t({providers:[Y],imports:[T.MD,b.YN,W.Y,m.h,tt.iI.forChild([{path:"",pathMatch:"full",component:ln}])]})}}return a})()}}]);
Line numbers count LF bytes from the start of the resource, as the search results do. Vendor segments are library code the classifier recognised; they are stored but not indexed. Bytes are shown as Latin1 characters, one per byte.