https://exode.me/client/en-US/chunk-35AIQB7E.js

1import{c as P}from"./chunk-Q6I3NOHV.js";import{d as L}from"./chunk-V3JZPFOE.js";import{Af as h,B as c,Pf as O,Q as A,S as b,Xg as w,Y as f,aa as S,d as C,f as E,gh as y,j as R,lh as U,md as l,n as u,pd as x,v as g,x as m}from"./chunk-HVCWS4IF.js";import{a as d,g as j,j as p}from"./chunk-KJ7W2O2B.js";var V=j(w());var v=(0,V.default)("peertube:subscriptions:UserSubscriptionService"),s=class s{authHttp=S(x);restExtractor=S(y);videoService=S(P);restService=S(U);existsSubject=new E(1);existsObservable;myAccountSubscriptionCache={};myAccountSubscriptionCacheObservable={};myAccountSubscriptionCacheSubject=new C;constructor(){this.existsObservable=g(O({time:200,notifierObservable:this.existsSubject,bulkGet:this.doSubscriptionsExist.bind(this)}).pipe(u(t=>t.response)),this.myAccountSubscriptionCacheSubject)}listFollowers(t){let{pagination:e,nameWithHost:i,search:o,channel:a}=t,r=new l;r=this.restService.addRestGetParams(r,this.restService.componentToRestPagination(e),"-createdAt"),o&&(r=r.append("search",o));let n=a?`${s.BASE_VIDEO_CHANNELS_URL}/${a}/followers`:`${s.BASE_ACCOUNTS_URL}/${i}/followers`;return this.authHttp.get(n,{params:r}).pipe(c(I=>this.restExtractor.handleError(I)))}getUserSubscriptionVideos(t){let{videoPagination:e,sort:i,skipCount:o}=t,a=this.restService.componentToRestPagination(e),r=new l;return r=this.restService.addRestGetParams(r,a,i),o&&(r=r.set("skipCount",o+"")),this.authHttp.get(s.BASE_USER_SUBSCRIPTIONS_URL+"/videos",{params:r}).pipe(A(n=>this.videoService.extractVideos(n)),c(n=>this.restExtractor.handleError(n)))}deleteSubscription(t){let e=s.BASE_USER_SUBSCRIPTIONS_URL+"/"+t;return this.authHttp.delete(e).pipe(b(()=>{this.myAccountSubscriptionCache[t]=!1,this.myAccountSubscriptionCacheSubject.next(this.myAccountSubscriptionCache)}),c(i=>this.restExtractor.handleError(i)))}addSubscription(t){let e=s.BASE_USER_SUBSCRIPTIONS_URL,i={uri:t};return this.authHttp.post(e,i).pipe(b(()=>{this.myAccountSubscriptionCache[t]=!0,this.myAccountSubscriptionCacheSubject.next(this.myAccountSubscriptionCache)}),c(o=>this.restExtractor.handleError(o)))}listSubscriptions(t){let{pagination:e,search:i}=t,o=s.BASE_USER_SUBSCRIPTIONS_URL,a=this.restService.componentToRestPagination(e),r=new l;return r=this.restService.addRestGetParams(r,a),i&&(r=r.append("search",i)),this.authHttp.get(o,{params:r}).pipe(u(n=>L.extractVideoChannels(n)),c(n=>this.restExtractor.handleError(n)))}listenToMyAccountSubscriptionCacheSubject(){return this.myAccountSubscriptionCacheSubject.asObservable()}listenToSubscriptionCacheChange(t){if(t in this.myAccountSubscriptionCacheObservable)return this.myAccountSubscriptionCacheObservable[t];let e=this.existsObservable.pipe(m(i=>i[t]!==void 0),u(i=>i[t]));return this.myAccountSubscriptionCacheObservable[t]=e,e}doesSubscriptionExist(t){return v("Running subscription check for "+t),t in this.myAccountSubscriptionCache?(v("Found cache for "+t),R(this.myAccountSubscriptionCache[t])):(this.existsSubject.next(t),v("Fetching from network for "+t),this.existsObservable.pipe(m(e=>e[t]!==void 0),u(e=>e[t]),b(e=>this.myAccountSubscriptionCache[t]=e)))}doSubscriptionsExist(t){let e=s.BASE_USER_SUBSCRIPTIONS_URL+"/exist",i=new l;return i=this.restService.addObjectParams(i,{uris:t}),this.authHttp.get(e,{params:i}).pipe(b(o=>{this.myAccountSubscriptionCache=d(d({},this.myAccountSubscriptionCache),o)}),c(o=>this.restExtractor.handleError(o)))}};p(s,"BASE_USER_SUBSCRIPTIONS_URL",h.apiUrl+"/api/v1/users/me/subscriptions"),p(s,"BASE_VIDEO_CHANNELS_URL",h.apiUrl+"/api/v1/video-channels"),p(s,"BASE_ACCOUNTS_URL",h.apiUrl+"/api/v1/accounts"),p(s,"\u0275fac",function(e){return new(e||s)}),p(s,"\u0275prov",f({token:s,factory:s.\u0275fac}));var B=s;export{B as a};
2/**i18n:347eeb695970c32bc275618edc2e751c67145d9fc3012e70543c114a99b9e016*/