1import{u as h}from"./D88Eo5-m.js";import{al as q,P as A,bQ as C,ak as P,bR as W,_ as B}from"./app-CV4xOXyd.js";import{b as D,r as k,a as T,o as L,g as w,l as y,q as t,L as $,C as M,j as a,H as l,u as d}from"./BmgbSMd9.js";import"./BX8RwoyW.js";const c=(s,g=0)=>{if(s==null)return"N/A";if(s===0)return"0";const b=["","K","M","G","T","P","E","Z","Y","R","Q"],u=s<0;u&&(s=-s);const r=Math.floor(Math.log(s)/Math.log(1e3));return(u?"-":"")+(s/Math.pow(1e3,r)).toFixed(g).replace(/(\.[1-9]*)0+$/,"$1").replace(/\.$/,"")+(b[r]??`e+${r*3}`)},V={class:"inbox"},z={class:"label"},E={key:0,class:"ti ti-alert-triangle icon"},J={class:"values"},F=["title"],I=["title"],R=["title"],G=["title"],H={class:"deliver"},K={class:"label"},U={key:0,class:"ti ti-alert-triangle icon"},Y={class:"values"},Z=["title"],O=["title"],X=["title"],ee=["title"],Q="jobQueue",ie=D({__name:"WidgetJobQueue",props:{widget:{}},emits:["updateProps"],setup(s,{expose:g,emit:b}){const u={transparent:{type:"boolean",default:!1},sound:{type:"boolean",default:!1}},r=s,j=b,{widgetProps:S,configure:N}=h(Q,u,r,j),v=q().useChannel("queueStats"),e=k({inbox:{activeSincePrevTick:0,active:0,waiting:0,delayed:0},deliver:{activeSincePrevTick:0,active:0,waiting:0,delayed:0}}),n=k({}),f=T(null),m=T(!1);A.state.sound_masterVolume&&C("/client-assets/sounds/syuilo/queue-jammed.mp3").then(o=>{if(!o)throw new Error("[WidgetJobQueue] Failed to initialize AudioBuffer");f.value=o});for(const o of["inbox","deliver"])n[o]=P(e[o]);const x=o=>{for(const i of["inbox","deliver"])if(n[i]=P(e[i]),e[i].activeSincePrevTick=o[i].activeSincePrevTick,e[i].active=o[i].active,e[i].waiting=o[i].waiting,e[i].delayed=o[i].delayed,e[i].waiting>0&&S.sound&&f.value&&!m.value){const p=W(f.value,{}).soundSource;p&&(m.value=!0,p.onended=()=>m.value=!1,p.start())}},_=o=>{for(const i of[...o].reverse())x(i)};return v.on("stats",x),v.on("statsLog",_),v.send("requestLog",{id:Math.random().toString().substring(2,10),length:1}),L(()=>{v.off("stats",x),v.off("statsLog",_),v.dispose()}),g({name:Q,configure:N,id:r.widget?r.widget.id:null}),(o,i)=>(w(),y("div",{"data-cy-mkw-jobQueue":"",class:a(["mkw-jobQueue _monospace",{_panel:!d(S).transparent}])},[t("div",V,[t("div",z,[i[0]||(i[0]=$("Inbox queue")),e.inbox.waiting>0?(w(),y("i",E)):M("",!0)]),t("div",J,[t("div",null,[i[1]||(i[1]=t("div",null,"Process",-1)),t("div",{class:a({inc:e.inbox.activeSincePrevTick>n.inbox.activeSincePrevTick,dec:e.inbox.activeSincePrevTick<n.inbox.activeSincePrevTick}),title:`${e.inbox.activeSincePrevTick}`},l(d(c)(e.inbox.activeSincePrevTick,2)),11,F)]),t("div",null,[i[2]||(i[2]=t("div",null,"Active",-1)),t("div",{class:a({inc:e.inbox.active>n.inbox.active,dec:e.inbox.active<n.inbox.active}),title:`${e.inbox.active}`},l(d(c)(e.inbox.active,2)),11,I)]),t("div",null,[i[3]||(i[3]=t("div",null,"Delayed",-1)),t("div",{class:a({inc:e.inbox.delayed>n.inbox.delayed,dec:e.inbox.delayed<n.inbox.delayed}),title:`${e.inbox.delayed}`},l(d(c)(e.inbox.delayed,2)),11,R)]),t("div",null,[i[4]||(i[4]=t("div",null,"Waiting",-1)),t("div",{class:a({inc:e.inbox.waiting>n.inbox.waiting,dec:e.inbox.waiting<n.inbox.waiting}),title:`${e.inbox.waiting}`},l(d(c)(e.inbox.waiting,2)),11,G)])])]),t("div",H,[t("div",K,[i[5]||(i[5]=$("Deliver queue")),e.deliver.waiting>0?(w(),y("i",U)):M("",!0)]),t("div",Y,[t("div",null,[i[6]||(i[6]=t("div",null,"Process",-1)),t("div",{class:a({inc:e.deliver.activeSincePrevTick>n.deliver.activeSincePrevTick,dec:e.deliver.activeSincePrevTick<n.deliver.activeSincePrevTick}),title:`${e.deliver.activeSincePrevTick}`},l(d(c)(e.deliver.activeSincePrevTick,2)),11,Z)]),t("div",null,[i[7]||(i[7]=t("div",null,"Active",-1)),t("div",{class:a({inc:e.deliver.active>n.deliver.active,dec:e.deliver.active<n.deliver.active}),title:`${e.deliver.active}`},l(d(c)(e.deliver.active,2)),11,O)]),t("div",null,[i[8]||(i[8]=t("div",null,"Delayed",-1)),t("div",{class:a({inc:e.deliver.delayed>n.deliver.delayed,dec:e.deliver.delayed<n.deliver.delayed}),title:`${e.deliver.delayed}`},l(d(c)(e.deliver.delayed,2)),11,X)]),t("div",null,[i[9]||(i[9]=t("div",null,"Waiting",-1)),t("div",{class:a({inc:e.deliver.waiting>n.deliver.waiting,dec:e.deliver.waiting<n.deliver.waiting}),title:`${e.deliver.waiting}`},l(d(c)(e.deliver.waiting,2)),11,ee)])])])],2))}}
1),ae=B(ie,[["__scopeId","data-v-7343207a"]]);export{ae as default};
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.