https://flowmq.io/_nuxt/C_ZKlDst.js

1import{_ as Ke}from"./DzYU8giY.js";import{a as Qe,b as qe,c as Ye,d as Ze,e as Je,_ as Xe}from"./DteklFc3.js";import{_ as _e}from"./BKfUJqhE.js";import{_ as xe,a as be}from"./_TtA5Tsl.js";import he from"./C1tSitqM.js";import{d as fe,u as pe,s as ye,w as de,o as r,c as g,Z as o,_ as a,a as t,i as p,j as s,U as e,a6 as ee,a7 as le,a9 as ge,a1 as c,a2 as J,g as w,t as ue,H as We,q as et,h as Z,n as tt,K as re,e as st,a3 as at,a4 as ot}from"./B5ypgLFi.js";import{_ as nt,a as rt,n as lt,i as it}from"./BoZWgc4I.js";import{_ as Ge}from"./3sHOUTE6.js";import{a as ct,b as dt,_ as mt}from"./D1VYwGKt.js";import{_ as ut}from"./yyvD9b_q.js";import{_ as we,a as $e,b as ke,c as Te,d as Se,e as Ce}from"./ChWKMCm1.js";import{f as Ee}from"./BKr2gSsa.js";import{u as Me}from"./D760BmmB.js";import{g as se}from"./CKidQALd.js";import{_ as ft}from"./Dqr1R4e4.js";import{a as pt,_ as _t}from"./DE_vZzYC.js";import{_ as ht}from"./DYV0ab8n.js";import{_ as gt,u as vt}from"./hy_wHyiC.js";import{_ as xt}from"./B7fCO2tf.js";import{_ as bt}from"./B2cu2pV_.js";import{_ as yt,a as wt,b as $t,c as kt,d as Tt}from"./CpKqLNFw.js";import{a as St,_ as Ct}from"./B2SBFMO9.js";import{_ as Dt}from"./kHv3GrG3.js";import{a as Ie}from"./BZ-M58A3.js";import{a as Ft,_ as Pt}from"./DNPaFA5k.js";import{_ as Gt,a as Et,b as Mt}from"./C6rzpH6n.js";import{_ as It}from"./DlAUqK2U.js";import{a as Nt,b as Bt,c as Ot,d as At,_ as zt}from"./CN0_uVTB.js";import{u as jt}from"./-HKf9EHN.js";import{_ as Lt}from"./mauPQu7x.js";import{u as Ut}from"./B6zPI7NO.js";import{u as Rt}from"./Bfn-nj-u.js";import"./CjMghhTy.js";import"./FrAQO-h2.js";import"./DmTjTZK9.js";import"./CeXtrIGW.js";import"./D8QuksZR.js";import"./B9XI9Wk7.js";import"./DNIe5Eja.js";import"./B_2CejD5.js";import"./DO0c_oJ9.js";import"./FUKBWQwh.js";import"./BFv9G3aH.js";import"./CPYVXSHG.js";import"./B6AGUFzi.js";import"./q0IVNwP9.js";import"./D_YSECl6.js";import"./C9Nsyr5t.js";import"./B68jF18q.js";import"./CplkJ2fU.js";import"./jFYhBC76.js";import"./C_YeUtWc.js";import"./CzUTk3fd.js";import"./DB3uAXBF.js";import"./DXjxXx8E.js";import"./DrFF-_Eh.js";import"./B_QpV7S7.js";import"./D3VfEJkO.js";import"./_-4i6Y1m.js";import"./DqVHIdJ9.js";import"./CUomUwTM.js";import"./Cqn-kKL7.js";import"./B2fAmnXM.js";const Vt={class:"space-y-3"},Ht={class:"text-base font-semibold text-foreground"},Kt={class:"mt-1 text-sm text-muted-foreground"},Qt={class:"max-w-xl break-words text-sm text-foreground"},qt={class:"min-w-0 break-words"},Yt={class:"overflow-x-auto"},Zt={class:"text-sm text-muted-foreground"},Jt={class:"flex items-center justify-center gap-2"},Fe=20,Xt=fe({__name:"PartitionsTable",props:{fetchPartitions:{},refreshKey:{default:0}},emits:["browse"],setup(x,{emit:b}){const _=x,j=b,{t:l}=pe(),S=w([]),C=w(!1),T=w(null),{isFetchingData:D,isLoadingNext:E,isLoadingPrevious:L,hasNextPage:v,hasPreviousPage:y,fetchData:A,goToNextPage:F,goToPreviousPage:R}=Me({limit:Fe,onFetch:async h=>{const P=await _.fetchPartitions({cursor:h,limit:Fe});if(P.has_next&&(!P.cursor||P.cursor===h))throw new Error(l("d.streams.detail.partitions.invalidPagination"));return S.value=P.partitions??[],{data:S.value,cursor:P.cursor??"",has_next:P.has_next??!1}}});async function B(){try{C.value=!0,T.value=null,await A("",!0)}catch(h){console.error("Failed to fetch stream partitions:",h),T.value=se(h,l("d.streams.detail.partitions.loadError"))}finally{C.value=!1}}async function H(h){try{T.value=null,h==="next"?await F():await R()}catch(P){console.error("Failed to navigate stream partitions:",P),T.value=se(P,l("d.streams.detail.partitions.loadError"))}}function Q(h){j("browse",h)}return ye(B),de(()=>_.refreshKey,B),(h,P)=>{const q=_e,M=xe,d=be,m=he,f=ge,n=Te,$=ke,O=$e,z=Ce,i=Se,u=we;return r(),g("div",Vt,[o("div",null,[o("h3",Ht,a(h.$t("d.streams.detail.partitions.title")),1),o("p",Kt,a(h.$t("d.streams.detail.partitions.subtitle")),1)]),t(C)&&t(S).length===0?(r(),p(d,{key:0,class:"shadow-sm"},{default:s(()=>[e(M,{class:"grid gap-3 p-4"},{default:s(()=>[(r(),g(ee,null,le(3,G=>e(q,{key:G,class:"h-8 w-full"})),64))]),_:1})]),_:1})):t(T)&&t(S).length===0?(r(),p(d,{key:1,class:"shadow-sm"},{default:s(()=>[e(M,{class:"flex flex-col items-center gap-3 p-6 text-center"},{default:s(()=>[e(m,{name:"lucide:alert-circle",class:"h-8 w-8 text-destructive"}),o("p",Qt,a(t(T)),1),e(f,{variant:"outline",size:"sm",onClick:B},{default:s(()=>[c(a(h.$t("common.retry")),1)]),_:1})]),_:1})]),_:1})):(r(),p(d,{key:2,class:"shadow-sm"},{default:s(()=>[t(T)?(r(),p(M,{key:0,class:"flex items-center gap-2 border-b px-4 py-3 text-sm text-destructive"},{default:s(()=>[e(m,{name:"lucide:alert-circle",class:"h-4 w-4 shrink-0"}),o("span",qt,a(t(T)),1)]),_:1})):J("",!0),t(S).length>0?(r(),p(M,{key:1,class:"p-0"},{default:s(()=>[o("div",Yt,[e(u,null,{default:s(()=>[e(O,null,{default:s(()=>[e($,null,{default:s(()=>[e(n,{class:"min-w-[120px] px-4 py-3"},{default:s(()=>[c(a(h.$t("d.streams.detail.partitions.table.partitionIndex")),1

1)]),_:1}),e(n,{class:"min-w-[120px] px-4 py-3"},{default:s(()=>[c(a(h.$t("d.streams.detail.partitions.table.startOffset")),1)]),_:1}),e(n,{class:"min-w-[120px] px-4 py-3"},{default:s(()=>[c(a(h.$t("d.streams.detail.partitions.table.endOffset")),1)]),_:1}),e(n,{class:"min-w-[140px] px-4 py-3"},{default:s(()=>[c(a(h.$t("d.streams.detail.partitions.table.estimatedBytes")),1)]),_:1}),e(n,{class:"w-[150px] min-w-[150px] px-4 py-3"})]),_:1})]),_:1}),e(i,null,{default:s(()=>[(r(!0),g(ee,null,le(t(S),G=>(r(),p($,{key:G.partition_index},{default:s(()=>[e(z,{class:"px-4 py-3 font-medium"},{default:s(()=>[c(a(G.partition_index),1)]),_:2},1024),e(z,{class:"px-4 py-3"},{default:s(()=>[c(a(G.start_offset),1)]),_:2},1024),e(z,{class:"px-4 py-3"},{default:s(()=>[c(a(G.end_offset),1)]),_:2},1024),e(z,{class:"px-4 py-3"},{default:s(()=>[c(a(("formatBytes"in h?h.formatBytes:t(Ee))(G.estimated_bytes??0)),1)]),_:2},1024),e(z,{class:"w-[150px] min-w-[150px] px-4 py-3 text-right"},{default:s(()=>[e(f,{variant:"ghost",size:"sm",class:"h-8",onClick:K=>Q(G)},{default:s(()=>[e(m,{name:"lucide:list",class:"h-4 w-4"}),c(" "+a(h.$t("d.streams.detail.partitions.browseButtonLabel")),1)]),_:1},8,["onClick"])]),_:2},1024)]),_:2},1024))),128))]),_:1})]),_:1})])]),_:1})):(r(),p(M,{key:2,class:"flex flex-col items-center justify-center py-10 text-center"},{default:s(()=>[o("p",Zt,a(h.$t("d.streams.detail.partitions.noPartitions")),1)]),_:1})),t(v)||t(y)?(r(),p(M,{key:3,class:"border-t px-4 py-3"},{default:s(()=>[o("div",Jt,[e(f,{variant:"outline",size:"sm",disabled:t(D)||!t(y),onClick:P[0]||(P[0]=G=>H("previous"))},{default:s(()=>[t(L)?(r(),p(m,{key:1,name:"lucide:loader-2",class:"h-4 w-4 animate-spin"})):(r(),p(m,{key:0,name:"lucide:chevron-left",class:"h-4 w-4"})),c(" "+a(h.$t("common.pagination.previous")),1)]),_:1},8,["disabled"]),e(f,{variant:"outline",size:"sm",disabled:t(D)||!t(v),onClick:P[1]||(P[1]=G=>H("next"))},{default:s(()=>[c(a(h.$t("common.pagination.next"))+" ",1),t(E)?(r(),p(m,{key:1,name:"lucide:loader-2",class:"h-4 w-4 animate-spin"})):(r(),p(m,{key:0,name:"lucide:chevron-right",class:"h-4 w-4"}))]),_:1},8,["disabled"])])]),_:1})):J("",!0)]),_:1}))])}}}),Wt=Object.assign(Xt,{__name:"SharedStreamsPartitionsTable"});function es(x,b){return(x??[]).flatMap(_=>{const j=(_.partitions??[]).filter(l=>l.topic===b);return j.length>0?[{..._,partitions:j}]:[]})}const ts={class:"space-y-3"},ss={class:"text-base font-semibold text-foreground"},as={class:"mt-1 text-sm text-muted-foreground"},os={class:"max-w-xl break-words text-sm text-foreground"},ns={key:2,class:"space-y-3"},rs={key:0,class:"flex items-center gap-2 border px-4 py-3 text-sm text-destructive"},ls={class:"min-w-0 break-words"},is={class:"flex min-w-0 items-center justify-between gap-3"},cs={class:"grid min-w-0 gap-1"},ds={class:"flex items-center gap-2"},ms=["title"],us={class:"flex flex-wrap items-center gap-x-4 gap-y-1 text-xs text-muted-foreground"},fs={class:"flex shrink-0 items-center gap-2"}

1,ps={key:0,class:"grid gap-3"},_s={key:1,class:"flex flex-col items-center gap-3 py-5 text-center"},hs={class:"max-w-xl break-words text-sm text-destructive"},gs={class:"mb-4 grid grid-cols-1 gap-3 border bg-muted/20 p-3 md:grid-cols-3"},vs={class:"grid min-w-0 gap-1"},xs={class:"text-xs font-medium text-muted-foreground"},bs={class:"text-sm text-foreground"},ys={class:"grid min-w-0 gap-1"},ws={class:"text-xs font-medium text-muted-foreground"},$s=["title"],ks={class:"grid min-w-0 gap-1"},Ts={class:"text-xs font-medium text-muted-foreground"},Ss={class:"truncate text-sm text-foreground"},Cs={key:0,class:"overflow-x-auto border"},Ds=["title"],Fs=["title"],Ps=["title"],Gs={key:0,class:"flex flex-wrap gap-1"},Es={key:0,class:"ml-1 text-orange-600"},Ms={key:1,class:"text-sm text-muted-foreground"},Is={key:1,class:"py-4 text-center text-sm text-muted-foreground"},Ns={key:1,class:"flex items-center justify-center gap-2 pt-1"},Bs={key:3,class:"flex flex-col items-center justify-center py-10 text-center"},Os={class:"text-sm text-muted-foreground"},Pe=20,As=fe({__name:"ConsumerGroupsTable",props:{streamName:{},fetchConsumerGroups:{},fetchConsumerGroup:{},fetchConsumerGroupOffsets:{type:Function,default:void 0},refreshKey:{default:0}},setup(x){const b=x,{t:_}=pe(),j=w([]),l=w({}),S=w([]),C=w({}),T=w(!1),D=w(null),{isFetchingData:E,isLoadingNext:L,isLoadingPrevious:v,hasNextPage:y,hasPreviousPage:A,fetchData:F,goToNextPage:R,goToPreviousPage:B}=Me({limit:Pe,onFetch:async n=>{const $=await b.fetchConsumerGroups({cursor:n,limit:Pe});if($.has_next&&(!$.cursor||$.cursor===n))throw new Error(_("d.streams.detail.consumerGroups.invalidPagination"));return j.value=($.groups??[]).filter(O=>!!O.id),{data:j.value,cursor:$.cursor??"",has_next:$.has_next??!1}}});async function H(){try{T.value=!0,D.value=null,l.value={},C.value={},await F("",!0)}catch(n){console.error("Failed to fetch stream consumer groups:",n),D.value=se(n,_("d.streams.detail.consumerGroups.loadError"))}finally{T.value=!1}}async function Q(n){try{D.value=null,n==="next"?await R():await B()}catch($){console.error("Failed to navigate stream consumer groups:",$),D.value=se($,_("d.streams.detail.consumerGroups.loadError"))}}function h(n){return S.value.includes(n)}function P(n){return!!l.value[n]}function q(n){return l.value[n]??{}}function M(n){return es(l.value[n]?.members,b.streamName)}function d(n){return"lag"in n&&typeof n.lag=="number"?n.lag:void 0}async function m(n,$=!1){if(!(!$&&l.value[n]||h(n)))try{S.value=[...S.value,n];const{[n]:O,...z}=C.value;C.value=z,l.value={...l.value,[n]:await b.fetchConsumerGroup(n)}}catch(O){console.error("Failed to fetch consumer group details:",O),C.value={...C.value,[n]:se(O,_("d.streams.detail.consumerGroups.detailLoadError"))}}finally{S.value=S.value.filter(O=>O!==n)}}function f(n,$){$&&m(n)}return ye(H),de(()=>b.refreshKey,H),(n,$)=>{const O=_e,z=xe,i=be,u=he,G=ge,K=Ge,ae=ft,me=ht,te=Te,ce=ke,oe=$e,I=Ce,ne=Se,X=we,V=gt,Y=pt,N=_t;return r(),g("div",ts,[o("div",null,[o("h3",ss,a(n.$t("d.streams.detail.consumerGroups.title")),1),o("p",as,a(n.$t("d.streams.detail.consumerGroups.subtitle")),1)]),t(T)&&t(j).length===0?(r(),p(i,{key:0,class:"shadow-sm"},{default:s(()=>[e(z,{class:"grid gap-3 p-4"},{default:s(()=>[(r(),g(ee,null,le(3,k=>e(O,{key:k,class:"h-12 w-full"})),64))]),_:1})]),_:1})):t(D)&&t(j).length===0?(r(),p(i,{key:1,class:"shadow-sm"},{default:s(()=>[e(z,{class:"flex flex-col items-center gap-3 p-6 text-center"},{default:s(()=>[e(u,{name:"lucide:alert-circle",class:"h-8 w-8 text-destructive"}),o("p",os,a(t(D)),1),e(G,{variant:"outline",size:"sm",onClick:H},{default:s(()=>[c(a(n.$t("common.retry")),1)]),_:1})]),_:1})]),_:1})):t(j).length>0?(r(),g("div",ns,[t(D)?(r(),g("div",rs,[e(u,{name:"lucide:alert-circle",class:"h-4 w-4 shrink-0"}),o("span",ls,a(t(D)),1)])):J("",!0),(r(!0),g(ee,null,le(t(j),k=>(r(),p(N,{key:k.id,class:"w-full","onUpdate:open":U=>f(k.id,U)},{default:s(()=>[e(i,{class:"shadow-sm"},{default:s(()=>[e(me,{"as-child":""},{default:s(()=>[e(ae,{class:"cursor-pointer px-4 py-3"},{default:s(()=>[o("div",is,[o("div",cs,[o("div",ds,[e(u,{name:"lucide:users",class:"h-4 w-4 shrink-0 text-muted-foreground"}),o("h4",{class:"max-w-[36ch] truncate text-sm font-medium text-foreground",title:k.id},a(k.id),9,ms)]),o("div",us,[o("span",null,a(n.$t("d.streams.detail.consumerGroups.groupInfo.state"))+": "+a(k.state||"-"),1),o("span",null,a(n.$t("d.streams.detail.consumerGroups.groupInfo.memberCount"))+": "+a(k.member_count??0),1)])]),o("div",fs,[e(K,{variant:"secondary",class:"text-xs"},{default:s(()=>[c(a(k.protocol||"-"),1)]),_:2},1024),e(u,{name:"lucide:chevron-down",class:"h-4 w-4 text-muted-foreground group-data-[state=open]:rotate-180"})])])]),_:2},1024)]),_:2},1024),e(Y,null,{default:s(()=>[e(z,{class:"border-t px-4 py-4"},{default:s(()=>[h(k.id)?(r(),g("div",ps,[e(O,{class:"h-14 w-full"}),e(O,{class:"h-20 w-full"})])):t(C)[k.id]?(r(),g("div",_s,[o("p",hs,a(t(C)[k.id]),1),e(G,{variant:"outline",size:"sm",onClick:U=>m(k.id,!0)},{default:s(()=>[c(a(n.$t("common.retry")),1)]),_:1},8,["onClick"])])):P(k.id)?(r(),g(ee,{key:2},[o("div",gs,[o("div",vs,[o("span",xs,a(n.$t("d.streams.detail.consumerGroups.groupInfo.generationId")),1),o("span",bs,a(q(k.id).generation_id??"-"),1)]),o("div",ys,[o("span",ws,a(n.$t("d.streams.detail.consumerGroups.groupInfo.leaderMemberId")),1),o("span",{class:"truncate text-sm text-foreground",title:q(k.id

1).leader_member_id||"-"},a(q(k.id).leader_member_id||"-"),9,$s)]),o("div",ks,[o("span",Ts,a(n.$t("d.streams.detail.consumerGroups.groupInfo.protocol")),1),o("span",Ss,a(q(k.id).protocol||"-"),1)])]),M(k.id).length?(r(),g("div",Cs,[e(X,null,{default:s(()=>[e(oe,null,{default:s(()=>[e(ce,null,{default:s(()=>[e(te,{class:"min-w-[220px] px-4 py-3"},{default:s(()=>[c(a(n.$t("d.streams.detail.consumerGroups.members.table.memberId")),1)]),_:1}),e(te,{class:"min-w-[180px] px-4 py-3"},{default:s(()=>[c(a(n.$t("d.streams.detail.consumerGroups.members.table.clientId")),1)]),_:1}),e(te,{class:"min-w-[160px] px-4 py-3"},{default:s(()=>[c(a(n.$t("d.streams.detail.consumerGroups.members.table.host")),1)]),_:1}),e(te,{class:"min-w-[140px] px-4 py-3"},{default:s(()=>[c(a(n.$t("d.streams.detail.consumerGroups.members.table.sessionTimeout")),1)]),_:1}),e(te,{class:"min-w-[180px] px-4 py-3"},{default:s(()=>[c(a(n.$t("d.streams.detail.consumerGroups.members.table.partitions")),1)]),_:1})]),_:1})]),_:1}),e(ne,null,{default:s(()=>[(r(!0),g(ee,null,le(M(k.id),U=>(r(),p(ce,{key:U.id},{default:s(()=>[e(I,{class:"px-4 py-3 font-medium"},{default:s(()=>[o("span",{class:"block max-w-[34ch] truncate",title:U.id||"-"},a(U.id||"-"),9,Ds)]),_:2},1024),e(I,{class:"px-4 py-3"},{default:s(()=>[o("span",{class:"block max-w-[28ch] truncate",title:U.client_id||"-"},a(U.client_id||"-"),9,Fs)]),_:2},1024),e(I,{class:"px-4 py-3"},{default:s(()=>[o("span",{class:"block max-w-[24ch] truncate",title:U.host||"-"},a(U.host||"-"),9,Ps)]),_:2},1024),e(I,{class:"px-4 py-3"},{default:s(()=>[c(a(U.session_timeout_ms?`${U.session_timeout_ms}ms`:"-"),1)]),_:2},1024),e(I,{class:"px-4 py-3"},{default:s(()=>[U.partitions?.length?(r(),g("div",Gs,[(r(!0),g(ee,null,le(U.partitions,ie=>(r(),p(K,{key:`${ie.topic}:${ie.partition_index}`,variant:"outline",class:"text-xs"},{default:s(()=>[c(" P"+a(ie.partition_index)+" ",1),!x.fetchConsumerGroupOffsets&&d(ie)!==void 0?(r(),g("span",Es,"("+a(d(ie))+")",1)):J("",!0)]),_:2},1024))),128))])):(r(),g("span",Ms,a(n.$t("d.streams.detail.consumerGroups.members.empty")),1))]),_:2},1024)]),_:2},1024))),128))]),_:2},1024)]),_:2},1024)])):(r(),g("p",Is,a(n.$t("d.streams.detail.consumerGroups.members.empty")),1))],64)):J("",!0),x.fetchConsumerGroupOffsets?(r(),p(V,{key:`${x.refreshKey}:${x.streamName}`,class:"mt-6","group-id":k.id,topic:x.streamName,"fetch-offsets":x.fetchConsumerGroupOffsets},null,8,["group-id","topic","fetch-offsets"])):J("",!0)]),_:2},1024)]),_:2},1024)]),_:2},1024)]),_:2},1032,["onUpdate:open"]))),128)),t(y)||t(A)?(r(),g("div",Ns,[e(G,{variant:"outline",size:"sm",disabled:t(E)||!t(A),onClick:$[0]||($[0]=k=>Q("previous"))},{default:s(()=>[t(v)?(r(),p(u,{key:1,name:"lucide:loader-2",class:"h-4 w-4 animate-spin"})):(r(),p(u,{key:0,name:"lucide:chevron-left",class:"h-4 w-4"})),c(" "+a(n.$t("common.pagination.previous")),1)]),_:1},8,["disabled"]),e(G,{variant:"outline",size:"sm",disabled:t(E)||!t(y),onClick:$[1]||($[1]=k=>Q("next"))},{default:s(()=>[c(a(n.$t("common.pagination.next"))+" ",1),t(L)?(r(),p(u,{key:1,name:"lucide:loader-2",class:"h-4 w-4 animate-spin"})):(r(),p(u,{key:0,name:"lucide:chevron-right",class:"h-4 w-4"}))]),_:1},8,["disabled"])])):J("",!0)])):(r(),g("div",Bs,[o("p",Os,a(n.$t("d.streams.detail.consumerGroups.noGroups")),1)]))])}}}),zs=Object.assign(As,{__name:"SharedStreamsConsumerGroupsTable"}),ve=100,Ne=1,Be=1e4;function js(x){return Math.min(Be,Math.max(Ne,Math.floor(x)))}const Ls={class:"mt-1 flex min-h-0 flex-1 flex-col gap-5"},Us={key:0,class:"grid gap-3 rounded-lg border border-border/70 bg-muted/40 p-3 text-xs uppercase tracking-wide text-muted-foreground md:grid-cols-4 md:gap-4"},Rs={class:"flex flex-col gap-1"},Vs={class:"text-base font-semibold text-foreground normal-case"},Hs={class:"flex flex-col gap-1"},Ks={class:"text-base font-medium text-foreground normal-case"},Qs={class:"flex flex-col gap-1"},qs={class:"text-base font-medium text-foreground normal-case"},Ys={class:"flex flex-col gap-1"},Zs={class:"text-base font-medium text-foreground normal-case"},Js={class:"grid items-end gap-3 text-sm sm:grid-cols-[minmax(0,1fr)_minmax(0,2fr)_auto_auto]"},Xs={class:"grid gap-1"},Ws={class:"grid gap-1"},ea={class:"flex w-full min-w-0 overflow-hidden rounded-md border border-input bg-background shadow-sm"},ta={class:"min-w-[200px] flex-1"},sa={key:1,class:"relative datetime-input-wrapper"},aa={class:"flex items-end justify-end"},oa={class:"sr-only"},na={class:"flex items-end justify-end"},ra={class:"sr-only"},la={class:"flex-1 overflow-hidden rounded-lg border border-border/70"},ia={key:0,class:"space-y-3 p-6"},ca={key:1,class:"p-6"},da={key:2,class:"p-6 text-sm text-muted-foreground"},ma={key:3,class:"h-full overflow-auto"},ua={class:"font-mono text-sm break-all"},fa={class:"max-w-lg max-h-48 overflow-auto whitespace-pre-wrap wrap-break-word rounded-md bg-muted/60 p-3 text-xs font-mono text-foreground"},pa=fe({__name:"PartitionMessagesDrawer",props:{open:{type:Boolean},streamName:{},partition:{},fetchPartitionMessages:{type:Function}},emits:["update:open"],setup(x,{emit:b}){const _=x,j=b,{t:l}

1=pe(),S=We(_,"open",j),C=w(!1),T=w(!1),D=w(null),E=w([]),L=w(""),v=et({max_messages:ve,start_offset:void 0,start_timestamp:void 0}),y={OFFSET:"start_offset",TIMESTAMP:"start_timestamp"},A=w(y.OFFSET),F=Z(()=>A.value===y.OFFSET),R=Z(()=>!(v.max_messages===ve&&v.start_offset===void 0&&v.start_timestamp===void 0&&L.value===""&&A.value===y.OFFSET)),B=Z(()=>C.value||T.value);function H(d){return d==null||d===""?d:Array.from(d).map(m=>{const f=m.charCodeAt(0),n=f===9||f===10||f===13;return!(f>=0&&f<=31||f===127||f>=128&&f<=159)||n?m:f===0?"\\0":`\\x${f.toString(16).padStart(2,"0")}`}).join("")}function Q(d={}){v.max_messages=ve,v.start_offset=void 0,v.start_timestamp=void 0,L.value="",A.value=y.OFFSET,d.reload&&_.partition&&S.value&&M(d.trigger??"reset")}function h(d,m){if(m===""||m===null){d==="max_messages"?v.max_messages=void 0:d==="start_offset"&&(v.start_offset=void 0);return}const f=Number(m);if(Number.isNaN(f))return;const n=Math.floor(f);d==="max_messages"?v.max_messages=js(n):d==="start_offset"&&(v.start_offset=Math.max(0,n))}function P(d){const m=typeof d=="number"?String(d):d;if(L.value=m,!m){v.start_timestamp=void 0;return}const f=Date.parse(m);if(Number.isNaN(f)){v.start_timestamp=void 0;return}v.start_timestamp=f}function q(){const d=document.getElementById("partition-start-timestamp");if(d){if(typeof d.showPicker=="function"){d.showPicker();return}d.focus(),d.click()}}async function M(d="search"){if(_.partition)try{d==="search"?C.value=!0:T.value=!0,D.value=null;const m=await _.fetchPartitionMessages({streamName:_.streamName,partitionIndex:_.partition.partition_index??0,params:Object.fromEntries(Object.entries({max_messages:v.max_messages,start_offset:v.start_offset,start_timestamp:v.start_timestamp}).filter(([,f])=>f!=null))});E.value=m.messages??[]}catch(m){console.error("Failed to load partition messages:",m),D.value=se(m,l("d.streams.detail.partitions.messagesDrawer.error"))}finally{d==="search"?C.value=!1:T.value=!1}}return de(()=>A.value,(d,m)=>{if(d!==m){if(d===y.OFFSET){L.value="",v.start_timestamp=void 0;return}d===y.TIMESTAMP&&(v.start_offset=void 0)}}),de(()=>[S.value,_.partition?.partition_index],([d,m],[f,n])=>{if(d&&m!==void 0&&m!==null){(!f||n!==m)&&(Q({reload:!0,trigger:"search"}),E.value=[]);return}d||(E.value=[],D.value=null,Q())}),(d,m)=>{const f=xt,n=bt,$=$t,O=wt,z=Tt,i=kt,u=yt,G=he,K=ge,ae=_e,me=Dt,te=Ct,ce=St,oe=Te,I=ke,ne=$e,X=Ce,V=Se,Y=we;return r(),p(t(Pt),{open:t(S),"onUpdate:open":m[5]||(m[5]=N=>ue(S)?S.value=N:null)},{default:s(()=>[e(t(Ft),{side:"right",class:"flex h-full max-h-screen w-full min-h-0 flex-col overflow-hidden sm:max-w-4xl lg:max-w-5xl"},{default:s(()=>[e(t(Gt),null,{default:s(()=>[e(t(Et),null,{default:s(()=>[c(a(t(l)("d.streams.detail.partitions.messagesDrawer.title",{index:x.partition?.partition_index??"-"})),1)]),_:1}),e(t(Mt),null,{default:s(()=>[c(a(t(l)("d.streams.detail.partitions.messagesDrawer.description")),1)]),_:1})]),_:1}),o("div",Ls,[x.partition?(r(),g("div",Us,[o("div",Rs,[o("span",null,a(t(l)("d.streams.detail.partitions.table.partitionIndex")),1),o("span",Vs,a(x.partition.partition_index),1)]),o("div",Hs,[o("span",null,a(t(l)("d.streams.detail.partitions.table.startOffset")),1),o("span",Ks,a(x.partition.start_offset??"-"),1)]),o("div",Qs,[o("span",null,a(t(l)("d.streams.detail.partitions.table.endOffset")),1),o("span",qs,a(x.partition.end_offset??"-"),1)]),o("div",Ys,[o("span",null,a(t(l)("d.streams.detail.partitions.table.estimatedBytes")),1),o("span",Zs,a(("formatBytes"in d?d.formatBytes:t(Ee))(x.partition.estimated_bytes??0)),1)])])):J("",!0),o("div",Js,[o("div",Xs,[e(f,{for:"partition-max-messages"},{default:s(()=>[c(a(t(l)("d.streams.detail.partitions.messagesDrawer.fields.maxMessages")),1)]),_:1}),e(n,{id:"partition-max-messages",type:"number",min:t(Ne),max:t(Be),"model-value":t(v).max_messages,class:"h-10 w-full","onUpdate:modelValue":m[0]||(m[0]=N=>h("max_messages",N))},null,8,["min","max","model-value"])]),o("div",Ws,[e(f,{for:"partition-start-mode"},{default:s(()=>[c(a(t(l)("d.streams.detail.partitions.messagesDrawer.fields.startMode")),1)]),_:1}),e(f,{for:t(F)?"partition-start-offset":"partition-start-timestamp",class:"sr-only"},{default:s(()=>[c(a(t(F)?t(l)("d.streams.detail.partitions.messagesDrawer.fields.startOffset"):t(l)("d.streams.detail.partitions.messagesDrawer.fields.startTimestamp")),1)]),_:1},8,["for"]),o("div",ea,[e(u,{modelValue:t(A),"onUpdate:modelValue":m[1]||(m[1]=N=>

1ue(A)?A.value=N:null)},{default:s(()=>[e(O,{id:"partition-start-mode",class:"h-10 w-36 rounded-none border-0 border-r border-input bg-transparent text-left focus:ring-0 focus-visible:ring-0 focus-visible:ring-offset-0 sm:w-44"},{default:s(()=>[e($,{placeholder:t(l)("d.streams.detail.partitions.messagesDrawer.fields.startModePlaceholder")},null,8,["placeholder"])]),_:1}),e(i,null,{default:s(()=>[e(z,{value:y.OFFSET},{default:s(()=>[c(a(t(l)("d.streams.detail.partitions.messagesDrawer.fields.startOffset")),1)]),_:1},8,["value"]),e(z,{value:y.TIMESTAMP},{default:s(()=>[c(a(t(l)("d.streams.detail.partitions.messagesDrawer.fields.startTimestamp")),1)]),_:1},8,["value"])]),_:1})]),_:1},8,["modelValue"]),o("div",ta,[t(F)?(r(),p(n,{key:0,id:"partition-start-offset",type:"number",min:"0","model-value":t(v).start_offset??"",class:"h-10 w-full rounded-none border-0 bg-transparent px-3 focus-visible:ring-0 focus-visible:ring-offset-0","onUpdate:modelValue":m[2]||(m[2]=N=>h("start_offset",N))},null,8,["model-value"])):(r(),g("div",sa,[e(n,{id:"partition-start-timestamp",type:"datetime-local",step:"1","model-value":t(L),class:"h-10 w-full rounded-none border-0 bg-transparent pl-3 pr-10 datetime-input focus-visible:ring-0 focus-visible:ring-offset-0","onUpdate:modelValue":P},null,8,["model-value"]),o("button",{type:"button",class:"absolute right-3 top-1/2 z-10 -translate-y-1/2 text-muted-foreground transition-colors hover:text-foreground focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-ring focus-visible:ring-offset-2",onClick:q},[e(G,{name:"lucide:calendar",class:"h-4 w-4"})])]))])])]),o("div",aa,[e(K,{type:"button",variant:"outline",size:"icon",class:"sm:h-10 sm:w-10",loading:t(T),disabled:t(T)||t(C)||!t(R),"aria-label":t(l)("common.reset"),onClick:m[3]||(m[3]=N=>Q({reload:!0,trigger:"reset"}))},{default:s(()=>[e(G,{name:"lucide:rotate-ccw",class:"h-4 w-4"}),o("span",oa,a(t(l)("common.reset")),1)]),_:1},8,["loading","disabled","aria-label"])]),o("div",na,[e(K,{size:"icon",class:"sm:h-10 sm:w-10",loading:t(C),disabled:t(C)||t(T),"aria-label":t(l)("common.search"),onClick:m[4]||(m[4]=N=>M("search"))},{default:s(()=>[e(G,{name:"lucide:search",class:"h-4 w-4"}),o("span",ra,a(t(l)("common.search")),1)]),_:1},8,["loading","disabled","aria-label"])])]),o("div",la,[t(B)?(r(),g("div",ia,[e(ae,{class:"h-4 w-1/2"}),e(ae,{class:"h-4 w-3/4"}),e(ae,{class:"h-4 w-2/3"})])):t(D)?(r(),g("div",ca,[e(ce,{variant:"destructive"},{default:s(()=>[e(me,null,{default:s(()=>[c(a(t(l)("common.error")),1)]),_:1}),e(te,null,{default:s(()=>[c(a(t(D)),1)]),_:1})]),_:1})])):t(E).length===0?(r(),g("div",da,a(t(l)("d.streams.detail.partitions.messagesDrawer.empty")),1)):(r(),g("div",ma,[e(Y,null,{default:s(()=>[e(ne,{class:"sticky top-0 z-10 bg-background"},{default:s(()=>[e(I,null,{default:s(()=>[e(oe,{class:"px-6 py-3 text-sm font-medium uppercase tracking-wide"},{default:s(()=>[c(a(t(l)("d.streams.detail.partitions.messagesDrawer.table.offset")),1)]),_:1}),e(oe,{class:"px-4 py-3 text-sm font-medium uppercase tracking-wide whitespace-nowrap min-w-48"},{default:s(()=>[c(a(t(l)("d.streams.detail.partitions.messagesDrawer.table.timestamp")),1)]),_:1}),e(oe,{class:"px-4 py-3 text-sm font-medium uppercase tracking-wide"},{default:s(()=>[c(a(t(l)("d.streams.detail.partitions.messagesDrawer.table.key")),1)]),_:1}),e(oe,{class:"px-4 py-3 text-xs uppercase tracking-wide"},{default:s(()=>[c(a(t(l)("d.streams.detail.partitions.messagesDrawer.table.payload")),1)]),_:1})]),_:1})]),_:1}),e(V,null,{default:s(()=>[(r(!0),g(ee,null,le(t(E),(N,k)=>(r(),p(I,{key:N.offset??k},{default:s(()=>[e(X,{class:"px-6 py-3 text-sm font-medium tabular-nums text-foreground"},{default:s(()=>[c(a(N.offset??"-"),1)]),_:2},1024),e(X,{class:"px-4 py-3 text-sm whitespace-nowrap align-middle min-w-48"},{default:s(()=>[c(a(N.timestamp?("formatDateTime"in d?d.formatDateTime:t(Ie))(N.timestamp,"-",{precision:"second"}):"-"),1)]),_:2},1024),e(X,{class:"px-4 py-3 text-sm"},{default:s(()=>[o("span",ua,a(N.key??"-"),1)]),_:2},1024),e(X,{class:"px-4 py-3 align-top"},{default:s(()=>[o("pre",fa,a(H(N.value)),1)]),_:2},1024)]),_:2},1024))),128))]),_:1})]),_:1})]))])])]),_:1})]),_:1},8,["open"])}}}),_a=Object.assign(It(pa,[["__scopeId","data-v-c9f520d9"]]),{__name:"SharedStream

1sPartitionMessagesDrawer"}),ha={class:"flex flex-col gap-6"},ga={class:"grid grid-cols-1 gap-4 md:grid-cols-2 lg:grid-cols-3"},va={class:"md:col-span-2 lg:col-span-2"},xa={class:"flex flex-wrap gap-1"},ba={class:"max-w-xl break-words text-sm font-medium text-foreground"},ya={key:2,class:"space-y-6"},wa={class:"flex flex-col gap-4 sm:flex-row sm:items-start sm:justify-between"},$a={class:"min-w-0"},ka={class:"text-xl font-semibold text-foreground"},Ta={class:"text-sm text-muted-foreground mt-2"},Sa={class:"flex flex-wrap items-center gap-2 sm:justify-end"},Ca={class:"grid grid-cols-1 md:grid-cols-2 xl:grid-cols-3"},Da={class:"min-w-0 space-y-2 border-b p-4 md:border-r md:border-b xl:border-b"},Fa={class:"flex items-center gap-2 text-muted-foreground"},Pa={class:"text-sm font-medium"},Ga={class:"flex min-w-0 items-center gap-2 pl-6"},Ea=["title"],Ma={class:"sr-only"},Ia={class:"space-y-2 border-b p-4 md:border-b xl:border-r xl:border-b"},Na={class:"flex items-center gap-2 text-muted-foreground"},Ba={class:"text-sm font-medium"},Oa={class:"pl-6 text-sm font-semibold text-foreground"},Aa={class:"space-y-2 border-b p-4 md:border-r md:border-b xl:border-r-0 xl:border-b"},za={class:"flex items-center gap-2 text-muted-foreground"},ja={class:"text-sm font-medium"},La={class:"pl-6 text-sm font-semibold text-foreground"},Ua={class:"space-y-2 border-b p-4 md:border-r md:border-b xl:border-r xl:border-b-0"},Ra={class:"flex items-center gap-2 text-muted-foreground"},Va={class:"text-sm font-medium"},Ha={class:"pl-6 text-sm font-semibold text-foreground"},Ka={class:"space-y-2 p-4 md:border-r xl:border-r"},Qa={class:"flex items-center gap-2 text-muted-foreground"},qa={class:"text-sm font-medium"},Ya={class:"pl-6 text-sm font-semibold text-foreground"},Za={class:"space-y-3 border-t px-4 py-4"},Ja={class:"flex items-center gap-2"},Xa={class:"text-sm font-medium text-muted-foreground"},Wa={class:"flex gap-2"},eo={key:1,class:"flex flex-wrap gap-2"},to=["title"],so={key:2,class:"text-sm text-muted-foreground"},ao={class:"text-base font-medium text-foreground"},oo={class:"text-sm text-muted-foreground"},no={class:"flex justify-end gap-3 pt-6"},ro=fe({__name:"StreamDetail",props:{streamName:{},listHref:{},fetchStreamDetails:{},fetchStreamPartitions:{},fetchStreamConsumerGroups:{},fetchConsumerGroup:{},fetchConsumerGroupOffsets:{},fetchPartitionMessages:{},deleteStream:{type:Function,default:void 0},updateTopicFilters:{type:Function,default:void 0},canDeleteStreams:{type:Boolean,default:!0},canUpdateStreams:{type:Boolean,default:!0},onDeleted:{type:Function,default:void 0}},setup(x){const b=x,{t:_}=pe(),{copy:j}=jt(),l=w(null),S=w(!1),C=w(!1),T=w(null),D=w(0),E=w(!1),L=w(!1),v=w("partitions"),y=w(!1),A=w(null),F=w(!1),R=w(!1),B=w([]),H=Z(()=>!!b.deleteStream&&b.canDeleteStreams),Q=Z(()=>!!b.updateTopicFilters&&b.canUpdateStreams),h=Z(()=>{const i=l.value,u=rt(i?.retention_ms);return u.kind==="forever"?_("d.streams.detail.streamInfo.retentionForever"):u.value});function P(i){A.value=i,y.value=!0}function q(){return[...l.value?.topic_filters||[]]}async function M(i=!1){try{i||(S.value=!0),T.value=null;const u=await b.fetchStreamDetails();l.value=u,F.value||(B.value=q())}catch(u){console.error("Failed to fetch stream details:",u),T.value=se(u,_("d.streams.messages.loadError"))}finally{i||(S.value=!1)}}async function d(){try{C.value=!0,await M(!0),D.value+=1}finally{C.value=!1}}async function m(){if(!(!b.deleteStream||!H.value))try{L.value=!0,await b.deleteStream(),re.success(_("d.streams.messages.deleteSuccess",{name:b.streamName})),E.value=!1,b.onDeleted?.()}catch(i){console.error("Delete stream error:",i),re.error(se(i,_("d.streams.messages.deleteError"))),E.value=!1}finally{L.value=!1}}function f(){Q.value&&(B.value=q(),F.value=!0)}function n(){B.value=q(),F.value=!1}function $(i=[]){B.value=i.filter(u=>typeof u=="string")}async function O(){if(!b.updateTopicFilters||!Q.value)return;const i=lt(B.value);if(i.some(K=>K.length===0)){re.error(_("d.streams.createDialog.validation.topicFilterRequired"));return}if(i.some(K=>it(K))){re.error(_("d.streams.createDialog.validation.topicFilterReserved"));return}try{R.value=!0,B.value=i,await b.updateTopicFilters(i),re.success(_("d.streams.messages.updateTopicFiltersSuccess")),F.value=!1,await M(!0)}catch(K){console.error("Update topic filters error:",K),re.error(se(K,_("d.streams.messages.updateTopicFiltersError")))}finally{R.value=!1}}async function z(){const i=l.value?.name;if(i)try{await j(i),re.success(_("d.streams.messages.copySuccess"))}catch(u){console.error("Failed to copy stream name:",u),re.error(_("d.streams.messages.copyError"))}}return de(y,i=>{i||(A.value=null)}),ye(()=>{M()}),de(()=>b.streamName,()=>{l.value=null,B.value=[],F.value=!1,R.value=!1,y.value=!1,E.value=!1,D.value+=1,M()}),(i,u)=>

1{const G=Ke,K=Ye,ae=qe,me=Ze,te=Je,ce=Qe,oe=Xe,I=_e,ne=xe,X=be,V=he,Y=ge,N=nt,k=Ge,U=dt,ie=ct,Oe=Wt,De=ut,Ae=zs,ze=mt,je=_a,Le=Ot,Ue=At,Re=Bt,Ve=Nt,He=zt;return r(),g("div",ha,[e(oe,null,{default:s(()=>[e(ce,null,{default:s(()=>[e(ae,null,{default:s(()=>[e(K,{"as-child":""},{default:s(()=>[e(G,{url:x.listHref},{default:s(()=>[c(a(i.$t("d.streams.title")),1)]),_:1},8,["url"])]),_:1})]),_:1}),e(me),e(ae,null,{default:s(()=>[e(te,{class:"inline-block max-w-[32ch] truncate align-bottom",title:x.streamName},{default:s(()=>[c(a(x.streamName),1)]),_:1},8,["title"])]),_:1})]),_:1})]),_:1}),t(S)?(r(),p(X,{key:0,class:"shadow-sm"},{default:s(()=>[e(ne,{class:"p-4"},{default:s(()=>[o("div",ga,[o("div",null,[e(I,{class:"h-4 w-20 mb-2"}),e(I,{class:"h-4 w-24"})]),o("div",null,[e(I,{class:"h-4 w-16 mb-2"}),e(I,{class:"h-4 w-8"})]),o("div",null,[e(I,{class:"h-4 w-24 mb-2"}),e(I,{class:"h-4 w-32"})]),o("div",null,[e(I,{class:"h-4 w-20 mb-2"}),e(I,{class:"h-4 w-16"})]),o("div",va,[e(I,{class:"h-4 w-20 mb-2"}),o("div",xa,[e(I,{class:"h-6 w-16"}),e(I,{class:"h-6 w-20"})])])])]),_:1})]),_:1})):t(T)?(r(),p(X,{key:1,class:"shadow-sm"},{default:s(()=>[e(ne,{class:"flex flex-col items-center justify-center gap-4 p-8 text-center"},{default:s(()=>[e(V,{name:"lucide:alert-circle",class:"h-10 w-10 text-destructive"}),o("h3",ba,a(t(T)),1),e(Y,{variant:"outline",size:"sm",onClick:M},{default:s(()=>[c(a(i.$t("common.retry")),1)]),_:1})]),_:1})]),_:1})):t(l)?(r(),g("div",ya,[o("div",wa,[o("div",$a,[o("h2",ka,a(i.$t("d.streams.detail.streamInfo.title")),1),o("p",Ta,a(i.$t("d.streams.detail.streamInfo.subtitle")),1)]),o("div",Sa,[e(Y,{variant:"outline",size:"sm",disabled:t(C)||t(S),onClick:d},{default:s(()=>[e(V,{name:"lucide:refresh-cw",class:tt(t(C)?"w-4 h-4 animate-spin":"w-4 h-4")},null,8,["class"]),c(" "+a(i.$t("common.refresh")),1)]),_:1},8,["disabled"]),t(H)?(r(),p(Y,{key:0,variant:"destructive",size:"sm",onClick:u[0]||(u[0]=W=>E.value=!0)},{default:s(()=>[e(V,{name:"lucide:trash",class:"w-4 h-4"}),c(" "+a(i.$t("d.streams.actions.deleteStream")),1)]),_:1})):J("",!0)])]),e(X,{class:"overflow-hidden shadow-sm"},{default:s(()=>[e(ne,{class:"p-0"},{default:s(()=>[o("div",Ca,[o("div",Da,[o("div",Fa,[e(V,{name:"lucide:align-center",class:"w-4 h-4"}),o("label",Pa,a(i.$t("d.streams.table.name")),1)]),o("div",Ga,[o("p",{class:"max-w-[32ch] truncate text-sm font-semibold text-foreground",title:t(l).name||"-"},a(t(l).name||"-"),9,Ea),t(l).name?(r(),p(Y,{key:0,variant:"ghost",size:"icon",class:"h-8 w-8 shrink-0",onClick:z},{default:s(()=>[e(V,{name:"lucide:copy",class:"w-4 h-4"}),o("span",Ma,a(i.$t("common.copy")),1)]),_:1})):J("",!0)])]),o("div",Ia,[o("div",Na,[e(V,{name:"lucide:layers",class:"w-4 h-4"}),o("label",Ba,a(i.$t("d.streams.table.partitions")),1)]),o("p",Oa,a(t(l).partitions||"-"),1)]),o("div",Aa,[o("div",za,[e(V,{name:"lucide:calendar",class:"w-4 h-4"}),o("label",ja,a(i.$t("d.streams.table.createdTime")),1)]),o("p",La,a(t(l).created_at?("formatDateTime"in i?i.formatDateTime:t(Ie))(t(l).created_at):"-"),1)]),o("div",Ua,[o("div",Ra,[e(V,{name:"lucide:trash-2",class:"w-4 h-4"}),o("label",Va,a(i.$t("d.streams.detail.streamInfo.cleanupPolicy")),1)]),o("p",Ha,a(t(l).cleanup_policy||"-"),1)]),o("div",Ka,[o("div",Qa,[e(V,{name:"lucide:clock-3",class:"w-4 h-4"}),o("label",qa,a(i.$t("d.streams.detail.streamInfo.retentionTime")),1)]),o("p",Ya,a(t(h)),1)]),u[5]||(u[5]=o("div",{class:"hidden p-4 md:block"},null,-1))]),o("div",Za,[o("div",Ja,[e(V,{name:"lucide:filter",class:"w-4 h-4 text-muted-foreground"}),o("label",Xa,a(i.$t("d.streams.table.topicFilters")),1),t(Q)&&!t(F)?(r(),p(Y,{key:0,type:"button",variant:"outline",size:"sm",class:"ml-auto h-8 px-3",disabled:t(R),onClick:f},{default:s(()=>[e(V,{name:"lucide:pencil",class:"w-3.5 h-3.5"}),c(" "+a(i.$t("d.streams.detail.topicFilters.edit")),1)]),_:1},8,["disabled"])):J("",!0)]),t(F)?(r(),g(ee,{key:0},[e(N,{"model-value":t(B),disabled:t(R),placeholder:i.$t("d.streams.createDialog.form.topicFiltersItemPlaceholder"),"onUpdate:modelValue":$},null,8,["model-value","disabled","placeholder"]),o("div",Wa,[e(Y,{type:"button",size:"sm",loading:t(R),onClick:O},{default:s(()=>[c(a(i.$t("d.streams.detail.topicFilters.save")),1)]),_:1},8,["loading"]),e(Y,{type:"button",variant:"outline",size:"sm",disabled:t(R),onClick:n},{default:s(()=>[c(a(i.$t("d.streams.detail.topicFilters.cancel")),1)]),_:1},8,["disabled"])])],64)):t(l).topic_filters&&t(l).topic_filters.length>0?(r(),g("div",eo,[(r(!0),g(ee,null,le(t(l).topic_filters,W=>(r(),p(k,{key:W,variant:"secondary",class:"text-xs max-w-[32ch] min-w-0"},{default:s(()=>[o("span",{class:"block max-w-full truncate",title:W},a(W),9,to)]),_:2},1024))),128))])):(r(),g("span",so,"-"))])]),_:1})]),_:1}),e(ze,{modelValue:t(v),"onUpdate:modelValue":u[1]||(u[1]=W=>ue(v)?v.value=W:null)},{default:s(()=>[e(ie,{class:"grid w-full max-w-[360px] grid-cols-2 rounded-lg border border-border/70 bg-muted/40 p-1"},{default:s(()=>[e(U,{value:"partitions"},{default:s(()=>[c(a(i.$t("d.streams.detail.partitions.title")),1)]),_:1}),e(U,{value:"consumer-groups"},{default:s(()=>[c(a(i.$t("d.streams.detail.consumerGroups.title")),1)]),_:1})]),_:1}),e(De,{value:"partitions",class:"mt-4"},{default:s(()=>[e(Oe,{"fetch-partitions":b.fetchStreamPartitions,"refresh-key":t(D),onBrowse:P},null,8,["fetch-partitions","refresh-key"])]),_:1}),e(De,{value:"consumer-groups",class:"mt-4"},{default:s(()=>[e(Ae,{"stream-name":x.streamName,"fetch-consumer-groups":b.fetchStreamConsumerGroups,"fetch-consumer-group":b.fetchConsumerGroup,"fetch-consumer-group-offsets":b.fetchConsumerGroupOffsets,"refresh-key":t(D)},null,8,["stream-name","fetch-consumer-groups","fetch-consumer-group","fetch-consumer-group-offsets","refresh-key"])]),_:1})]),_:1},8,["modelValue"])])):(r(),p(X,{key:3,class:"shadow-sm"},{default:s(()=>[e(ne,{class:"flex flex-col items-center justify-center gap-4 p-8 text-center"},{default:s(()=>[e(V,{name:"lucide:info",class:"h-10 w-10 text-muted-foreground"}),o("h3",ao,a(i.$t("d.streams.detail.noData")),1),o("p",oo,a(i.$t("d.streams.detail.noDataDescription")),1)]),_:1})]),_:1})),e(je,{open:t(y),"onUpdate:open":u[2]||(u[2]=W=>ue(y)?y.value=W:null),"stream-name":x.streamName,partition:t(A),"fetch-partition-messages":b.fetchPartitionMessages},null,8,["open","stream-name","partition","fetch-partition-messages"]),t(H)?(r(),p(He,{key:4,open:t(E),"onUpdate:open":u[4]||(u[4]=W=>ue(E)?E.value=W:null)},{default:s(()=>[e(Ve,null,{default:s(()=>[e(Re,null,{default:s(()=>[e(Le,null,{default:s(()=>[c(a(i.$t("d.streams.deleteDialog.title")),1)]),_:1}),e(Ue,{class:"wrap-anywhere"},{default:s(()=>[c(a(i.$t("d.streams.deleteDialog.description",{name:x.streamName})),1)]),_:1})]),_:1}),o("div",no,[e(Y,{type:"button",variant:"outline",size:"sm",disabled:t(L),onClick:u[3]||(u[3]=W=>E.value=!1)},{default:s(()=>[c(a(i.$t("common.cancel")),1)]),_:1},8,["disabled"]),e(Y,{variant:"destructive",size:"sm",loading:t(L),onClick:m},{default:s(()=>[c(a(i.$t("common.delete")),1)]),_:1},8,["loading"])])]),_:1})]),_:1},8,["open"])):J("",!0)])}}}

1),lo=Object.assign(ro,{__name:"SharedStreamsStreamDetail"}),io={class:"mx-auto my-6 flex w-full max-w-[1440px] flex-col gap-6 px-4 lg:px-6 xl:px-12 2xl:px-20 3xl:px-24"},bn=fe({__name:"index",setup(x){const{t:b}=pe(),_=st(),{getStreamDetails:j,getStreamPartitions:l,getStreamConsumerGroups:S,deleteStream:C,getStreamMessages:T,updateStreamTopicFilters:D}=Ut(),{getConsumerGroup:E}=vt(),{can:L}=Rt();at({title:b("d.streams.detail.title")});const v=Z(()=>_.params.orgId),y=Z(()=>_.params.id),A=Z(()=>_.params.name),F=Z(()=>decodeURIComponent(A.value)),R=Z(()=>`/dashboard/organizations/${v.value}/projects/${y.value}/streams`),B=Z(()=>L("delete","Project")),H=Z(()=>L("update","Project")),Q=()=>j(y.value,F.value),h=n=>l(y.value,F.value,n),P=n=>S(y.value,F.value,n),q=n=>E(y.value,n),M=()=>C(y.value,F.value);function d(n){return D(y.value,F.value,n)}function m(n){return T(y.value,n.streamName,n.partitionIndex,n.params??{})}const f=()=>ot(R.value);return(n,$)=>{const O=lo,z=Lt;return r(),p(z,null,{default:s(()=>[o("div",io,[e(O,{"stream-name":t(F),"list-href":t(R),"fetch-stream-details":Q,"fetch-stream-partitions":h,"fetch-stream-consumer-groups":P,"fetch-consumer-group":q,"delete-stream":t(B)?M:void 0,"can-delete-streams":t(B),"update-topic-filters":t(H)?d:void 0,"can-update-streams":t(H),"fetch-partition-messages":m,"on-deleted":f},null,8,["stream-name","list-href","delete-stream","can-delete-streams","update-topic-filters","can-update-streams"])])]),_:1})}}});

1export{bn as default};