@harnessio/ff-javascript-client-sdk - npm Package Compare versions

Comparing version 1.26.0 to 1.26.1

dist/sdk.cjs.js

@@ -1,1 +0,2 @@
-var Se=Object.create;var F=Object.defineProperty,Ce=Object.defineProperties,Oe=Object.getOwnPropertyDescriptor,Te=Object.getOwnPropertyDescriptors,we=Object.getOwnPropertyNames,ne=Object.getOwnPropertySymbols,De=Object.getPrototypeOf,re=Object.prototype.hasOwnProperty,Ae=Object.prototype.propertyIsEnumerable;var ae=(n,e,a)=>e in n?F(n,e,{enumerable:!0,configurable:!0,writable:!0,value:a}):n[e]=a,O=(n,e)=>{for(var a in e||(e={}))re.call(e,a)&&ae(n,a,e[a]);if(ne)for(var a of ne(e))Ae.call(e,a)&&ae(n,a,e[a]);return n},j=(n,e)=>Ce(n,Te(e));var Pe=(n,e)=>{for(var a in e)F(n,a,{get:e[a],enumerable:!0})},oe=(n,e,a,o)=>{if(e&&typeof e=="object"||typeof e=="function")for(let r of we(e))!re.call(n,r)&&r!==a&&F(n,r,{get:()=>e[r],enumerable:!(o=Oe(e,r))||o.enumerable});return n};var se=(n,e,a)=>(a=n!=null?Se(De(n)):{},oe(e||!n||!n.__esModule?F(a,"default",{value:n,enumerable:!0}):a,n)),Fe=n=>oe(F({},"__esModule",{value:!0}),n);var f=(n,e,a)=>new Promise((o,r)=>{var l=b=>{try{y(a.next(b))}catch(g){r(g)}},h=b=>{try{y(a.throw(b))}catch(g){r(g)}},y=b=>b.done?o(b.value):Promise.resolve(b.value).then(l,h);y((a=a.apply(n,e)).next())});var Be={};Pe(Be,{Event:()=>M,initialize:()=>$e});module.exports=Fe(Be);var fe=se(require("jwt-decode")),he=se(require("mitt"));var M=(v=>(v.READY="ready",v.CONNECTED="connected",v.DISCONNECTED="disconnected",v.STOPPED="stopped",v.POLLING="polling",v.POLLING_STOPPED="polling stopped",v.FLAGS_LOADED="flags loaded",v.CACHE_LOADED="cache loaded",v.CHANGED="changed",v.ERROR="error",v.ERROR_CACHE="cache error",v.ERROR_METRICS="metrics error",v.ERROR_AUTH="auth error",v.ERROR_FETCH_FLAGS="fetch flags error",v.ERROR_FETCH_FLAG="fetch flag error",v.ERROR_STREAM="stream error",v))(M||{});var Me={debug:!1,baseUrl:"https://config.ff.harness.io/api/1.0",eventUrl:"https://events.ff.harness.io/api/1.0",eventsSyncInterval:6e4,pollingInterval:6e4,streamEnabled:!0,cache:!1},le=n=>{let e=O(O({},Me),n);return e.pollingEnabled===void 0&&(e.pollingEnabled=e.streamEnabled),e.eventsSyncInterval<6e4&&(e.eventsSyncInterval=6e4),e.pollingInterval<6e4&&(e.pollingInterval=6e4),(!e.logger||!e.logger.debug||!e.logger.error||!e.logger.info||!e.logger.warn)&&(e.logger=console),e},U=(n,e=!0)=>{e?setTimeout(n,0):n()},V=(n,e)=>Math.round(Math.random()*(e-n)+n);function q(n){return function(...a){let[o,r]=n(a);return fetch(o,r)}}var ce=3e4,_=class{constructor(e,a,o,r,l,h,y,b,g){this.eventBus=e;this.configurations=a;this.url=o;this.apiKey=r;this.standardHeaders=l;this.fallbackPoller=h;this.logDebug=y;this.logError=b;this.eventCallback=g;this.closed=!1;this.connectionOpened=!1;this.disconnectEventEmitted=!1}start(){let e=g=>{g.toString().split(/\r?\n/).forEach(a)},a=g=>{if(g.startsWith("data:")){let S=JSON.parse(g.substring(5));this.logDebugMessage("Received event from stream: ",S),this.eventCallback(S)}},o=()=>{this.logDebugMessage("Stream connected"),this.eventBus.emit("connected")},r=()=>{clearInterval(this.readTimeoutCheckerId);let g=V(1e3,1e4);this.logDebugMessage("Stream disconnected, will reconnect in "+g+"ms"),this.disconnectEventEmitted||(this.eventBus.emit("disconnected"),this.disconnectEventEmitted=!0),setTimeout(()=>this.start(),g)},l=g=>{g&&this.logErrorMessage("Stream has issue",g),this.fallBackToPolling(),this.eventBus.emit("stream error",g),this.eventBus.emit("error",g),r()},h=O({"Cache-Control":"no-cache",Accept:"text/event-stream","API-Key":this.apiKey},this.standardHeaders);this.logDebugMessage("SSE HTTP start request",this.url),this.xhr=new XMLHttpRequest,this.xhr.open("GET",this.url);for(let[g,S]of Object.entries(h))this.xhr.setRequestHeader(g,S);this.xhr.timeout=24*60*60*1e3,this.xhr.onerror=()=>{this.connectionOpened=!1,l("XMLHttpRequest error on SSE stream")},this.xhr.onabort=()=>{this.connectionOpened=!1,this.logDebugMessage("SSE aborted"),this.closed||l(null)},this.xhr.ontimeout=()=>{this.connectionOpened=!1,l("SSE timeout")},this.xhr.onload=()=>{if(this.xhr.status>=400&&this.xhr.status<=599){l(`HTTP code ${this.xhr.status}`);return}this.connectionOpened||(o(),this.connectionOpened=!0,this.disconnectEventEmitted=!1)};let y=0,b=Date.now();this.xhr.onprogress=()=>{this.connectionOpened||(o(),this.connectionOpened=!0,this.disconnectEventEmitted=!1),this.stopFallBackPolling(),b=Date.now();let g=this.xhr.responseText.slice(y);y+=g.length,this.logDebugMessage("SSE GOT: "+g),e(g)},this.readTimeoutCheckerId=setInterval(()=>{b<Date.now()-ce&&(this.logErrorMessage("SSE read timeout"),this.xhr.abort())},ce),this.xhr.send()}close(){this.connectionOpened=!1,this.closed=!0,this.xhr&&this.xhr.abort(),clearInterval(this.readTimeoutCheckerId),this.eventBus.emit("stopped"),this.stopFallBackPolling()}fallBackToPolling(){!this.fallbackPoller.isPolling()&&this.configurations.pollingEnabled&&(this.logDebugMessage("Falling back to polling mode while stream recovers"),this.fallbackPoller.start())}stopFallBackPolling(){this.fallbackPoller.isPolling()&&(this.logDebugMessage("Stopping fallback polling mode"),this.fallbackPoller.stop())}logDebugMessage(e,...a){this.configurations.debug&&this.logDebug(`Streaming:  ${e}`,...a)}logErrorMessage(e,...a){this.logError(`Streaming:  ${e}`,...a)}};function ge(n,e,a,o,r){let l=n in a,h=l?a[n]:e;return l&&o(n,h),r?{value:h,isDefaultValue:!l}:h}var x=class{constructor(e,a,o,r,l){this.fetchFlagsFn=e;this.configurations=a;this.eventBus=o;this.logDebug=r;this.logError=l;this.maxAttempts=5}start(){if(this.isPolling()){this.logDebugMessage("Already polling.");return}this.isRunning=!0,this.eventBus.emit("polling"),this.logDebugMessage(`Starting poller, first poll will be in ${this.configurations.pollingInterval}ms`),this.timeoutId=setTimeout(()=>this.poll(),this.configurations.pollingInterval)}poll(){this.attemptFetch().finally(()=>{this.timeoutId=setTimeout(()=>this.poll(),this.configurations.pollingInterval)})}attemptFetch(){return f(this,null,function*(){for(let e=1;e<=this.maxAttempts;e++){let a=yield this.fetchFlagsFn();if(a.type==="success"){this.logDebugMessage(`Successfully polled for flag updates, next poll in ${this.configurations.pollingInterval}ms. `);return}if(this.logErrorMessage("Error when polling for flag updates",a.error),e>=this.maxAttempts){this.logDebugMessage(`Maximum attempts reached for polling for flags. Next poll in ${this.configurations.pollingInterval}ms.`);return}this.logDebugMessage(`Polling for flags attempt #${e} failed. Remaining attempts: ${this.maxAttempts-e}`,a.error);let o=V(1e3,1e4);yield new Promise(r=>setTimeout(r,o))}})}stop(){this.timeoutId&&(clearTimeout(this.timeoutId),this.timeoutId=void 0,this.isRunning=!1,this.eventBus.emit("polling stopped"),this.logDebugMessage("Polling stopped"))}isPolling(){return this.isRunning}logDebugMessage(e,...a){this.configurations.debug&&this.logDebug(`Poller: ${e}`,...a)}logErrorMessage(e,...a){this.logError(`Poller: ${e}`,...a)}};function de(a){return f(this,arguments,function*(n,e={}){let o=yield Ve(n),r=_e(e);return{loadFromCache:()=>W(o,r,e),saveToCache:l=>J(o,r,l),updateCachedEvaluation:l=>Ne(o,r,l),removeCachedEvaluation:l=>ke(o,r,l)}})}function W(o,r){return f(this,arguments,function*(n,e,a={}){let l=parseInt(yield e.getItem(n+".ts"));if(a!=null&&a.ttl&&!isNaN(l)&&l+a.ttl<Date.now())return yield xe(n,e),[];let h=yield e.getItem(n);if(h)try{return JSON.parse(h)}catch(y){}return[]})}function xe(n,e){return f(this,null,function*(){yield e.removeItem(n),yield e.removeItem(n+".ts")})}function J(n,e,a){return f(this,null,function*(){yield e.setItem(n,JSON.stringify(a)),yield e.setItem(n+".ts",Date.now().toString())})}function Ne(n,e,a){return f(this,null,function*(){let o=yield W(n,e),r=o.find(({flag:l})=>l===a.flag);r?Object.assign(r,a):o.push(a),yield J(n,e,o)})}function ke(n,e,a){return f(this,null,function*(){let o=yield W(n,e),r=o.findIndex(({flag:l})=>l===a);r>-1&&(o.splice(r,1),yield J(n,e,o))})}function Ve(n){return f(this,null,function*(){var a,o;let e=n;if(globalThis!=null&&globalThis.TextEncoder&&((o=(a=globalThis==null?void 0:globalThis.crypto)==null?void 0:a.subtle)!=null&&o.digest)){let l=new TextEncoder().encode(n),h=yield crypto.subtle.digest("SHA-256",l);e=Array.from(new Uint8Array(h)).map(b=>b.toString(16).padStart(2,"0")).join("")}else globalThis.btoa&&(e=btoa(n));return"HARNESS_FF_CACHE_"+e})}function _e(n){let e;return!n.storage||typeof n.storage!="object"||!("getItem"in n.storage)||!("setItem"in n.storage)||!("removeItem"in n.storage)?globalThis.localStorage?e=globalThis.localStorage:globalThis.sessionStorage?e=globalThis.sessionStorage:e=Le:e=n.storage,{getItem(o){return f(this,null,function*(){let r=e.getItem(o);return r instanceof Promise?yield r:r})},setItem(o,r){return f(this,null,function*(){let l=e.setItem(o,r);l instanceof Promise&&(yield l)})},removeItem(o){return f(this,null,function*(){let r=e.removeItem(o);r instanceof Promise&&(yield r)})}}}var Le={getItem:()=>null,setItem:()=>{},removeItem:()=>{}};var ve="1.25.0",ue=`Javascript ${ve} Client`,He=500,Ge=globalThis.fetch,Y=!!globalThis.Proxy,$e=(n,e,a)=>{let o=!1,r,l,h,y,b,g,S=!0,D={},N=q(t=>t),z=0,X=!1,L=()=>{S=!1},v=()=>{S=!0},C=[],d=(0,he.default)(),m=le(a),p=(t,...i)=>{m.debug&&m.logger.debug(`[FF-SDK] ${t}`,...i)},T=(t,...i)=>{m.logger.error(`[FF-SDK] ${t}`,...i)},H=t=>{let{value:i}=t;try{switch(t.kind.toLowerCase()){case"int":case"number":i=Number(i);break;case"boolean":i=i.toString().toLowerCase()==="true";break;case"json":i=JSON.parse(i);break}}catch(c){T(c)}return i},G=t=>{if(S){let i=Date.now();i-t.lastAccessed>He&&(t.count++,t.lastAccessed=i)}},me=()=>f(void 0,null,function*(){if(m.cache){p("initializing cache");try{let t=!0,i=yield de(e.identifier+n,typeof m.cache=="boolean"?{}:m.cache),c=yield i.loadFromCache();c!=null&&c.length&&U(()=>{p("loading from cache",c),te(c,!1),d.emit("cache loaded",c)}),K("flags loaded",u=>f(void 0,null,function*(){yield i.saveToCache(u),t=!1})),K("changed",u=>f(void 0,null,function*(){t||(u.deleted?yield i.removeCachedEvaluation(u.flag):yield i.updateCachedEvaluation(u))}))}catch(t){T("Cache error: ",t),d.emit("cache error",t),d.emit("error",t)}}}),pe=(t,i)=>f(void 0,null,function*(){return(yield(yield Ge(`${i.baseUrl}/client/auth`,{method:"POST",headers:{"Content-Type":"application/json","Harness-SDK-Info":ue},body:JSON.stringify({apiKey:t,target:j(O({},e),{identifier:String(e.identifier)})})})).json()).authToken}),$=0,B=()=>{if(C.length){p("Sending metrics...",{metrics:C,evaluations:I});let t={metricsData:C.map(i=>({timestamp:Date.now(),count:i.count,metricsType:"FFMETRICS",attributes:[{key:"featureIdentifier",value:i.featureIdentifier},{key:"featureName",value:i.featureIdentifier},{key:"variationIdentifier",value:i.variationIdentifier},{key:"target",value:e.identifier},{key:"SDK_NAME",value:"JavaScript"},{key:"SDK_LANGUAGE",value:"JavaScript"},{key:"SDK_TYPE",value:"client"},{key:"SDK_VERSION",value:ve}]}))};N(`${m.eventUrl}/metrics/${r}?cluster=${l}`,{method:"POST",headers:O({"Content-Type":"application/json"},D),body:JSON.stringify(t)}).then(()=>{C=[],$=0}).catch(i=>{$++&&(C=[],$=0),p(i),d.emit("metrics error",i)}).finally(()=>{g=window.setTimeout(B,m.eventsSyncInterval)})}else g=window.setTimeout(B,m.eventsSyncInterval)},I={},Ee=t=>{p("Sending event for",t.flag),Y?d.emit("changed",new Proxy(t,{get(i,c){var u;if(S&&i.hasOwnProperty(c)&&c==="value"){let E=i.flag,s=t.value,R=C.find(P=>P.featureIdentifier===E&&P.featureValue===s);R?(G(R),R.variationIdentifier=((u=I[E])==null?void 0:u.identifier)||""):C.push({featureIdentifier:E,featureValue:String(s),variationIdentifier:I[E].identifier||"",count:1,lastAccessed:Date.now()}),p("Metrics event: Flag",c,"has been read with value via stream update",s)}return c==="value"?H(t):t[c]}})):d.emit("changed",{deleted:t.deleted,flag:t.flag,value:H(t)})},Q=function(){return Y?new Proxy({},{get(t,i){var u,E,s;let c=t[i];if(S&&t.hasOwnProperty(i)){let R=t[i],P=C.find(ie=>ie.featureIdentifier===i&&R===ie.featureValue);P?(P.variationIdentifier=((u=I[i])==null?void 0:u.identifier)||"",G(P)):C.push({featureIdentifier:i,featureValue:R,variationIdentifier:((E=I[i])==null?void 0:E.identifier)||"",count:1,lastAccessed:Date.now()}),p("Metrics event: Flag:",i,"has been read with value:",R,"variationIdentifier:",(s=I[i])==null?void 0:s.identifier)}return c}}):{}},w=Q();me().then(()=>pe(n,m).then(t=>f(void 0,null,function*(){if(o)return;b=t;let i=(0,fe.default)(t);if(D={Authorization:`Bearer ${b}`,"Harness-AccountID":i.accountID,"Harness-EnvironmentID":i.environmentIdentifier,"Harness-SDK-Info":ue},globalThis.btoa){let E=globalThis.btoa(JSON.stringify(e));E.length<262144&&(D["Harness-Target"]=E)}p("Authenticated",i),g=window.setTimeout(B,m.eventsSyncInterval),r=i.environment,l=i.clusterIdentifier;let c=!!Object.keys(I).length;if((yield k()).type==="success"&&p("Fetch all flags ok",w),!o){if(m.streamEnabled?(p("Streaming mode enabled"),Re()):m.pollingEnabled?(p("Polling mode enabled"),be()):p("Streaming and polling mode disabled"),!c){L();let E=O({},w);v(),d.emit("ready",E)}X=!0}})).catch(t=>{T("Authentication error: ",t),d.emit("auth error",t),d.emit("error",t)}));let k=()=>f(void 0,null,function*(){try{let t=yield N(`${m.baseUrl}/client/env/${r}/target/${e.identifier}/evaluations?cluster=${l}`,{headers:D});if(t.ok){let i=yield t.json();return i.forEach(A),d.emit("flags loaded",i),{type:"success",data:i}}else return T("Features fetch operation error: ",t),d.emit("fetch flags error",t),d.emit("error",t),{type:"error",error:t}}catch(t){return T("Features fetch operation error: ",t),d.emit("fetch flags error",t),d.emit("error",t),{type:"error",error:t}}}),Z=t=>f(void 0,null,function*(){try{let i=yield N(`${m.baseUrl}/client/env/${r}/target/${e.identifier}/evaluations/${t}?cluster=${l}`,{headers:D});if(i.ok){let c=yield i.json();A(c)}else T("Feature fetch operation error: ",i),d.emit("fetch flag error",i),d.emit("error",i)}catch(i){T("Feature fetch operation error: ",i),d.emit("fetch flag error",i),d.emit("error",i)}}),A=t=>{L();let i=H(t);i!==w[t.flag]&&(p("Flag variation has changed for ",t.identifier),w[t.flag]=i,I[t.flag]=j(O({},t),{value:i}),Ee(t)),v()};y=new x(k,m,d,p,T);let Re=()=>{let t=s=>{switch(s.event){case"create":c(s.evaluations)?s.evaluations.forEach(R=>{A(R)}):setTimeout(()=>Z(s.identifier),1e3);break;case"patch":c(s.evaluations)?s.evaluations.forEach(R=>{A(R)}):Z(s.identifier);break;case"delete":delete w[s.identifier],d.emit("changed",{flag:s.identifier,value:void 0,deleted:!0}),p("Evaluation deleted",{message:s,storage:w});break}},i=s=>!(!s||!s.flag||!s.identifier||!s.kind||!s.value),c=s=>!(!s||s.length==0||!s.every(R=>i(R))),u=s=>{s.event==="patch"&&(c(s.evaluations)?s.evaluations.forEach(R=>{A(R)}):k())},E=`${m.baseUrl}/stream?cluster=${l}`;h=new _(d,m,E,n,D,y,p,T,s=>{s.domain==="flag"?t(s):s.domain==="target-segment"&&u(s)}),h.start()},be=()=>{y.start()},K=(t,i)=>d.on(t,i),ye=(t,i)=>{t?d.off(t,i):ee()},Ie=(t,i)=>{var s;if(!S||Y||i===void 0)return;let c=i,u=t,E=C.find(R=>R.featureIdentifier===u&&R.featureValue===c);E?(G(E),E.variationIdentifier=((s=I[u])==null?void 0:s.identifier)||""):C.push({featureIdentifier:u,featureValue:c,count:1,variationIdentifier:I[u].identifier||"",lastAccessed:Date.now()})},ee=()=>{o=!0,m.streamEnabled&&(p("Closing event stream"),typeof(h==null?void 0:h.close)=="function"&&h.close(),d.all.clear()),m.pollingEnabled&&y.isPolling()&&(p("Closing Poller"),y.stop()),w=Q(),I={},clearTimeout(g)},te=(t,i=!0)=>{t.length&&U(()=>{let c=!!Object.keys(I).length;if(t.forEach(A),!c){L();let u=O({},w);v(),d.emit("ready",u)}},i)};return{on:K,off:ye,close:ee,setEvaluations:te,registerAPIRequestMiddleware:t=>{N=q(t)},refreshEvaluations:()=>{X&&!o&&Date.now()-z>=6e4&&(k(),z=Date.now())},variation:(t,i,c=!1)=>ge(t,i,w,Ie,c)}};0&&(module.exports={Event,initialize});
+var Ce=Object.create;var F=Object.defineProperty,Te=Object.defineProperties,Ae=Object.getOwnPropertyDescriptor,Oe=Object.getOwnPropertyDescriptors,we=Object.getOwnPropertyNames,ne=Object.getOwnPropertySymbols,De=Object.getPrototypeOf,re=Object.prototype.hasOwnProperty,Pe=Object.prototype.propertyIsEnumerable;var ae=(i,e,a)=>e in i?F(i,e,{enumerable:!0,configurable:!0,writable:!0,value:a}):i[e]=a,T=(i,e)=>{for(var a in e||(e={}))re.call(e,a)&&ae(i,a,e[a]);if(ne)for(var a of ne(e))Pe.call(e,a)&&ae(i,a,e[a]);return i},j=(i,e)=>Te(i,Oe(e));var Fe=(i,e)=>{for(var a in e)F(i,a,{get:e[a],enumerable:!0})},oe=(i,e,a,o)=>{if(e&&typeof e=="object"||typeof e=="function")for(let r of we(e))!re.call(i,r)&&r!==a&&F(i,r,{get:()=>e[r],enumerable:!(o=Ae(e,r))||o.enumerable});return i};var se=(i,e,a)=>(a=i!=null?Ce(De(i)):{},oe(e||!i||!i.__esModule?F(a,"default",{value:i,enumerable:!0}):a,i)),Me=i=>oe(F({},"__esModule",{value:!0}),i);var h=(i,e,a)=>new Promise((o,r)=>{var l=E=>{try{p(a.next(E))}catch(g){r(g)}},u=E=>{try{p(a.throw(E))}catch(g){r(g)}},p=E=>E.done?o(E.value):Promise.resolve(E.value).then(l,u);p((a=a.apply(i,e)).next())});var je={};Fe(je,{Event:()=>M,initialize:()=>Ke});module.exports=Me(je);var he=se(require("jwt-decode")),me=se(require("mitt"));var M=(m=>(m.READY="ready",m.CONNECTED="connected",m.DISCONNECTED="disconnected",m.STOPPED="stopped",m.POLLING="polling",m.POLLING_STOPPED="polling stopped",m.FLAGS_LOADED="flags loaded",m.CACHE_LOADED="cache loaded",m.CHANGED="changed",m.ERROR="error",m.ERROR_CACHE="cache error",m.ERROR_METRICS="metrics error",m.ERROR_AUTH="auth error",m.ERROR_FETCH_FLAGS="fetch flags error",m.ERROR_FETCH_FLAG="fetch flag error",m.ERROR_STREAM="stream error",m))(M||{});var Ne={debug:!1,baseUrl:"https://config.ff.harness.io/api/1.0",eventUrl:"https://events.ff.harness.io/api/1.0",eventsSyncInterval:6e4,pollingInterval:6e4,streamEnabled:!0,cache:!1},le=i=>{let e=T(T({},Ne),i);return e.pollingEnabled===void 0&&(e.pollingEnabled=e.streamEnabled),e.eventsSyncInterval<6e4&&(e.eventsSyncInterval=6e4),e.pollingInterval<6e4&&(e.pollingInterval=6e4),(!e.logger||!e.logger.debug||!e.logger.error||!e.logger.info||!e.logger.warn)&&(e.logger=console),e},U=(i,e=!0)=>{e?setTimeout(i,0):i()},V=(i,e)=>Math.round(Math.random()*(e-i)+i),ce=i=>{let e="ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=",a="",o=0,r=xe(JSON.stringify(i));for(;o<r.length;){let l=r.charCodeAt(o++),u=r.charCodeAt(o++),p=r.charCodeAt(o++),E=l>>2,g=(l&3)<<4|u>>4,b=(u&15)<<2|p>>6,A=p&63;isNaN(u)?b=A=64:isNaN(p)&&(A=64),a+=e.charAt(E)+e.charAt(g)+e.charAt(b)+e.charAt(A)}return a},xe=i=>i.replace(/\r\n/g,`
+`).split("").map(e=>{let a=e.charCodeAt(0);return a<128?String.fromCharCode(a):a>127&&a<2048?String.fromCharCode(a>>6|192)+String.fromCharCode(a&63|128):String.fromCharCode(a>>12|224)+String.fromCharCode(a>>6&63|128)+String.fromCharCode(a&63|128)}).join("");function q(i){return function(...a){let[o,r]=i(a);return fetch(o,r)}}var ge=3e4,_=class{constructor(e,a,o,r,l,u,p,E,g){this.eventBus=e;this.configurations=a;this.url=o;this.apiKey=r;this.standardHeaders=l;this.fallbackPoller=u;this.logDebug=p;this.logError=E;this.eventCallback=g;this.closed=!1;this.connectionOpened=!1;this.disconnectEventEmitted=!1}start(){let e=g=>{g.toString().split(/\r?\n/).forEach(a)},a=g=>{if(g.startsWith("data:")){let b=JSON.parse(g.substring(5));this.logDebugMessage("Received event from stream: ",b),this.eventCallback(b)}},o=()=>{this.logDebugMessage("Stream connected"),this.eventBus.emit("connected")},r=()=>{clearInterval(this.readTimeoutCheckerId);let g=V(1e3,1e4);this.logDebugMessage("Stream disconnected, will reconnect in "+g+"ms"),this.disconnectEventEmitted||(this.eventBus.emit("disconnected"),this.disconnectEventEmitted=!0),setTimeout(()=>this.start(),g)},l=g=>{g&&this.logErrorMessage("Stream has issue",g),this.fallBackToPolling(),this.eventBus.emit("stream error",g),this.eventBus.emit("error",g),r()},u=T({"Cache-Control":"no-cache",Accept:"text/event-stream","API-Key":this.apiKey},this.standardHeaders);this.logDebugMessage("SSE HTTP start request",this.url),this.xhr=new XMLHttpRequest,this.xhr.open("GET",this.url);for(let[g,b]of Object.entries(u))this.xhr.setRequestHeader(g,b);this.xhr.timeout=24*60*60*1e3,this.xhr.onerror=()=>{this.connectionOpened=!1,l("XMLHttpRequest error on SSE stream")},this.xhr.onabort=()=>{this.connectionOpened=!1,this.logDebugMessage("SSE aborted"),this.closed||l(null)},this.xhr.ontimeout=()=>{this.connectionOpened=!1,l("SSE timeout")},this.xhr.onload=()=>{if(this.xhr.status>=400&&this.xhr.status<=599){l(`HTTP code ${this.xhr.status}`);return}this.connectionOpened||(o(),this.connectionOpened=!0,this.disconnectEventEmitted=!1)};let p=0,E=Date.now();this.xhr.onprogress=()=>{this.connectionOpened||(o(),this.connectionOpened=!0,this.disconnectEventEmitted=!1),this.stopFallBackPolling(),E=Date.now();let g=this.xhr.responseText.slice(p);p+=g.length,this.logDebugMessage("SSE GOT: "+g),e(g)},this.readTimeoutCheckerId=setInterval(()=>{E<Date.now()-ge&&(this.logErrorMessage("SSE read timeout"),this.xhr.abort())},ge),this.xhr.send()}close(){this.connectionOpened=!1,this.closed=!0,this.xhr&&this.xhr.abort(),clearInterval(this.readTimeoutCheckerId),this.eventBus.emit("stopped"),this.stopFallBackPolling()}fallBackToPolling(){!this.fallbackPoller.isPolling()&&this.configurations.pollingEnabled&&(this.logDebugMessage("Falling back to polling mode while stream recovers"),this.fallbackPoller.start())}stopFallBackPolling(){this.fallbackPoller.isPolling()&&(this.logDebugMessage("Stopping fallback polling mode"),this.fallbackPoller.stop())}logDebugMessage(e,...a){this.configurations.debug&&this.logDebug(`Streaming:  ${e}`,...a)}logErrorMessage(e,...a){this.logError(`Streaming:  ${e}`,...a)}};function de(i,e,a,o,r){let l=i in a,u=l?a[i]:e;return l&&o(i,u),r?{value:u,isDefaultValue:!l}:u}var N=class{constructor(e,a,o,r,l){this.fetchFlagsFn=e;this.configurations=a;this.eventBus=o;this.logDebug=r;this.logError=l;this.maxAttempts=5}start(){if(this.isPolling()){this.logDebugMessage("Already polling.");return}this.isRunning=!0,this.eventBus.emit("polling"),this.logDebugMessage(`Starting poller, first poll will be in ${this.configurations.pollingInterval}ms`),this.timeoutId=setTimeout(()=>this.poll(),this.configurations.pollingInterval)}poll(){this.attemptFetch().finally(()=>{this.timeoutId=setTimeout(()=>this.poll(),this.configurations.pollingInterval)})}attemptFetch(){return h(this,null,function*(){for(let e=1;e<=this.maxAttempts;e++){let a=yield this.fetchFlagsFn();if(a.type==="success"){this.logDebugMessage(`Successfully polled for flag updates, next poll in ${this.configurations.pollingInterval}ms. `);return}if(this.logErrorMessage("Error when polling for flag updates",a.error),e>=this.maxAttempts){this.logDebugMessage(`Maximum attempts reached for polling for flags. Next poll in ${this.configurations.pollingInterval}ms.`);return}this.logDebugMessage(`Polling for flags attempt #${e} failed. Remaining attempts: ${this.maxAttempts-e}`,a.error);let o=V(1e3,1e4);yield new Promise(r=>setTimeout(r,o))}})}stop(){this.timeoutId&&(clearTimeout(this.timeoutId),this.timeoutId=void 0,this.isRunning=!1,this.eventBus.emit("polling stopped"),this.logDebugMessage("Polling stopped"))}isPolling(){return this.isRunning}logDebugMessage(e,...a){this.configurations.debug&&this.logDebug(`Poller: ${e}`,...a)}logErrorMessage(e,...a){this.logError(`Poller: ${e}`,...a)}};function ue(a){return h(this,arguments,function*(i,e={}){let o=yield Le(i),r=He(e);return{loadFromCache:()=>W(o,r,e),saveToCache:l=>J(o,r,l),updateCachedEvaluation:l=>Ve(o,r,l),removeCachedEvaluation:l=>_e(o,r,l)}})}function W(o,r){return h(this,arguments,function*(i,e,a={}){let l=parseInt(yield e.getItem(i+".ts"));if(a!=null&&a.ttl&&!isNaN(l)&&l+a.ttl<Date.now())return yield ke(i,e),[];let u=yield e.getItem(i);if(u)try{return JSON.parse(u)}catch(p){}return[]})}function ke(i,e){return h(this,null,function*(){yield e.removeItem(i),yield e.removeItem(i+".ts")})}function J(i,e,a){return h(this,null,function*(){yield e.setItem(i,JSON.stringify(a)),yield e.setItem(i+".ts",Date.now().toString())})}function Ve(i,e,a){return h(this,null,function*(){let o=yield W(i,e),r=o.find(({flag:l})=>l===a.flag);r?Object.assign(r,a):o.push(a),yield J(i,e,o)})}function _e(i,e,a){return h(this,null,function*(){let o=yield W(i,e),r=o.findIndex(({flag:l})=>l===a);r>-1&&(o.splice(r,1),yield J(i,e,o))})}function Le(i){return h(this,null,function*(){var a,o;let e=i;if(globalThis!=null&&globalThis.TextEncoder&&((o=(a=globalThis==null?void 0:globalThis.crypto)==null?void 0:a.subtle)!=null&&o.digest)){let l=new TextEncoder().encode(i),u=yield crypto.subtle.digest("SHA-256",l);e=Array.from(new Uint8Array(u)).map(E=>E.toString(16).padStart(2,"0")).join("")}else globalThis.btoa&&(e=btoa(i));return"HARNESS_FF_CACHE_"+e})}function He(i){let e;return!i.storage||typeof i.storage!="object"||!("getItem"in i.storage)||!("setItem"in i.storage)||!("removeItem"in i.storage)?globalThis.localStorage?e=globalThis.localStorage:globalThis.sessionStorage?e=globalThis.sessionStorage:e=Ge:e=i.storage,{getItem(o){return h(this,null,function*(){let r=e.getItem(o);return r instanceof Promise?yield r:r})},setItem(o,r){return h(this,null,function*(){let l=e.setItem(o,r);l instanceof Promise&&(yield l)})},removeItem(o){return h(this,null,function*(){let r=e.removeItem(o);r instanceof Promise&&(yield r)})}}}var Ge={getItem:()=>null,setItem:()=>{},removeItem:()=>{}};var ve="1.26.1",fe=`Javascript ${ve} Client`,$e=500,Be=globalThis.fetch,Y=!!globalThis.Proxy,Ke=(i,e,a)=>{let o=!1,r,l,u,p,E,g,b=!0,A={},x=q(t=>t),z=0,X=!1,L=()=>{b=!1},m=()=>{b=!0},C=[],d=(0,me.default)(),v=le(a),R=(t,...n)=>{v.debug&&v.logger.debug(`[FF-SDK] ${t}`,...n)},O=(t,...n)=>{v.logger.error(`[FF-SDK] ${t}`,...n)},H=t=>{let{value:n}=t;try{switch(t.kind.toLowerCase()){case"int":case"number":n=Number(n);break;case"boolean":n=n.toString().toLowerCase()==="true";break;case"json":n=JSON.parse(n);break}}catch(c){O(c)}return n},G=t=>{if(b){let n=Date.now();n-t.lastAccessed>$e&&(t.count++,t.lastAccessed=n)}},pe=()=>h(void 0,null,function*(){if(v.cache){R("initializing cache");try{let t=!0,n=yield ue(e.identifier+i,typeof v.cache=="boolean"?{}:v.cache),c=yield n.loadFromCache();c!=null&&c.length&&U(()=>{R("loading from cache",c),te(c,!1),d.emit("cache loaded",c)}),K("flags loaded",f=>h(void 0,null,function*(){yield n.saveToCache(f),t=!1})),K("changed",f=>h(void 0,null,function*(){t||(f.deleted?yield n.removeCachedEvaluation(f.flag):yield n.updateCachedEvaluation(f))}))}catch(t){O("Cache error: ",t),d.emit("cache error",t),d.emit("error",t)}}}),Ee=(t,n)=>h(void 0,null,function*(){return(yield(yield Be(`${n.baseUrl}/client/auth`,{method:"POST",headers:{"Content-Type":"application/json","Harness-SDK-Info":fe},body:JSON.stringify({apiKey:t,target:j(T({},e),{identifier:String(e.identifier)})})})).json()).authToken}),$=0,B=()=>{if(C.length){R("Sending metrics...",{metrics:C,evaluations:I});let t={metricsData:C.map(n=>({timestamp:Date.now(),count:n.count,metricsType:"FFMETRICS",attributes:[{key:"featureIdentifier",value:n.featureIdentifier},{key:"featureName",value:n.featureIdentifier},{key:"variationIdentifier",value:n.variationIdentifier},{key:"target",value:e.identifier},{key:"SDK_NAME",value:"JavaScript"},{key:"SDK_LANGUAGE",value:"JavaScript"},{key:"SDK_TYPE",value:"client"},{key:"SDK_VERSION",value:ve}]}))};x(`${v.eventUrl}/metrics/${r}?cluster=${l}`,{method:"POST",headers:T({"Content-Type":"application/json"},A),body:JSON.stringify(t)}).then(()=>{C=[],$=0}).catch(n=>{$++&&(C=[],$=0),R(n),d.emit("metrics error",n)}).finally(()=>{g=window.setTimeout(B,v.eventsSyncInterval)})}else g=window.setTimeout(B,v.eventsSyncInterval)},I={},Re=t=>{R("Sending event for",t.flag),Y?d.emit("changed",new Proxy(t,{get(n,c){var f;if(b&&n.hasOwnProperty(c)&&c==="value"){let S=n.flag,s=t.value,y=C.find(P=>P.featureIdentifier===S&&P.featureValue===s);y?(G(y),y.variationIdentifier=((f=I[S])==null?void 0:f.identifier)||""):C.push({featureIdentifier:S,featureValue:String(s),variationIdentifier:I[S].identifier||"",count:1,lastAccessed:Date.now()}),R("Metrics event: Flag",c,"has been read with value via stream update",s)}return c==="value"?H(t):t[c]}})):d.emit("changed",{deleted:t.deleted,flag:t.flag,value:H(t)})},Q=function(){return Y?new Proxy({},{get(t,n){var f,S,s;let c=t[n];if(b&&t.hasOwnProperty(n)){let y=t[n],P=C.find(ie=>ie.featureIdentifier===n&&y===ie.featureValue);P?(P.variationIdentifier=((f=I[n])==null?void 0:f.identifier)||"",G(P)):C.push({featureIdentifier:n,featureValue:y,variationIdentifier:((S=I[n])==null?void 0:S.identifier)||"",count:1,lastAccessed:Date.now()}),R("Metrics event: Flag:",n,"has been read with value:",y,"variationIdentifier:",(s=I[n])==null?void 0:s.identifier)}return c}}):{}},w=Q();pe().then(()=>Ee(i,v).then(t=>h(void 0,null,function*(){if(o)return;E=t;let n=(0,he.default)(t);A={Authorization:`Bearer ${E}`,"Harness-AccountID":n.accountID,"Harness-EnvironmentID":n.environmentIdentifier,"Harness-SDK-Info":fe};let c=ce(e);c.length<262144&&(A["Harness-Target"]=c),R("Authenticated",n),g=window.setTimeout(B,v.eventsSyncInterval),r=n.environment,l=n.clusterIdentifier;let f=!!Object.keys(I).length;if((yield k()).type==="success"&&R("Fetch all flags ok",w),!o){if(v.streamEnabled?(R("Streaming mode enabled"),ye()):v.pollingEnabled?(R("Polling mode enabled"),be()):R("Streaming and polling mode disabled"),!f){L();let s=T({},w);m(),d.emit("ready",s)}X=!0}})).catch(t=>{O("Authentication error: ",t),d.emit("auth error",t),d.emit("error",t)}));let k=()=>h(void 0,null,function*(){try{let t=yield x(`${v.baseUrl}/client/env/${r}/target/${e.identifier}/evaluations?cluster=${l}`,{headers:A});if(t.ok){let n=yield t.json();return n.forEach(D),d.emit("flags loaded",n),{type:"success",data:n}}else return O("Features fetch operation error: ",t),d.emit("fetch flags error",t),d.emit("error",t),{type:"error",error:t}}catch(t){return O("Features fetch operation error: ",t),d.emit("fetch flags error",t),d.emit("error",t),{type:"error",error:t}}}),Z=t=>h(void 0,null,function*(){try{let n=yield x(`${v.baseUrl}/client/env/${r}/target/${e.identifier}/evaluations/${t}?cluster=${l}`,{headers:A});if(n.ok){let c=yield n.json();D(c)}else O("Feature fetch operation error: ",n),d.emit("fetch flag error",n),d.emit("error",n)}catch(n){O("Feature fetch operation error: ",n),d.emit("fetch flag error",n),d.emit("error",n)}}),D=t=>{L();let n=H(t);n!==w[t.flag]&&(R("Flag variation has changed for ",t.identifier),w[t.flag]=n,I[t.flag]=j(T({},t),{value:n}),Re(t)),m()};p=new N(k,v,d,R,O);let ye=()=>{let t=s=>{switch(s.event){case"create":c(s.evaluations)?s.evaluations.forEach(y=>{D(y)}):setTimeout(()=>Z(s.identifier),1e3);break;case"patch":c(s.evaluations)?s.evaluations.forEach(y=>{D(y)}):Z(s.identifier);break;case"delete":delete w[s.identifier],d.emit("changed",{flag:s.identifier,value:void 0,deleted:!0}),R("Evaluation deleted",{message:s,storage:w});break}},n=s=>!(!s||!s.flag||!s.identifier||!s.kind||!s.value),c=s=>!(!s||s.length==0||!s.every(y=>n(y))),f=s=>{s.event==="patch"&&(c(s.evaluations)?s.evaluations.forEach(y=>{D(y)}):k())},S=`${v.baseUrl}/stream?cluster=${l}`;u=new _(d,v,S,i,A,p,R,O,s=>{s.domain==="flag"?t(s):s.domain==="target-segment"&&f(s)}),u.start()},be=()=>{p.start()},K=(t,n)=>d.on(t,n),Se=(t,n)=>{t?d.off(t,n):ee()},Ie=(t,n)=>{var s;if(!b||Y||n===void 0)return;let c=n,f=t,S=C.find(y=>y.featureIdentifier===f&&y.featureValue===c);S?(G(S),S.variationIdentifier=((s=I[f])==null?void 0:s.identifier)||""):C.push({featureIdentifier:f,featureValue:c,count:1,variationIdentifier:I[f].identifier||"",lastAccessed:Date.now()})},ee=()=>{o=!0,v.streamEnabled&&(R("Closing event stream"),typeof(u==null?void 0:u.close)=="function"&&u.close(),d.all.clear()),v.pollingEnabled&&p.isPolling()&&(R("Closing Poller"),p.stop()),w=Q(),I={},clearTimeout(g)},te=(t,n=!0)=>{t.length&&U(()=>{let c=!!Object.keys(I).length;if(t.forEach(D),!c){L();let f=T({},w);m(),d.emit("ready",f)}},n)};return{on:K,off:Se,close:ee,setEvaluations:te,registerAPIRequestMiddleware:t=>{x=q(t)},refreshEvaluations:()=>{X&&!o&&Date.now()-z>=6e4&&(k(),z=Date.now())},variation:(t,n,c=!1)=>de(t,n,w,Ie,c)}};0&&(module.exports={Event,initialize});

dist/sdk.client-iife.js

@@ -1,1 +0,2 @@
-var HarnessFFSDK=(()=>{var N=Object.defineProperty,we=Object.defineProperties,Ce=Object.getOwnPropertyDescriptor,Oe=Object.getOwnPropertyDescriptors,Te=Object.getOwnPropertyNames,re=Object.getOwnPropertySymbols;var se=Object.prototype.hasOwnProperty,Ae=Object.prototype.propertyIsEnumerable;var oe=(t,e,a)=>e in t?N(t,e,{enumerable:!0,configurable:!0,writable:!0,value:a}):t[e]=a,C=(t,e)=>{for(var a in e||(e={}))se.call(e,a)&&oe(t,a,e[a]);if(re)for(var a of re(e))Ae.call(e,a)&&oe(t,a,e[a]);return t},j=(t,e)=>we(t,Oe(e));var De=(t,e)=>{for(var a in e)N(t,a,{get:e[a],enumerable:!0})},Pe=(t,e,a,r)=>{if(e&&typeof e=="object"||typeof e=="function")for(let o of Te(e))!se.call(t,o)&&o!==a&&N(t,o,{get:()=>e[o],enumerable:!(r=Ce(e,o))||r.enumerable});return t};var Fe=t=>Pe(N({},"__esModule",{value:!0}),t);var h=(t,e,a)=>new Promise((r,o)=>{var s=y=>{try{R(a.next(y))}catch(d){o(d)}},u=y=>{try{R(a.throw(y))}catch(d){o(d)}},R=y=>y.done?r(y.value):Promise.resolve(y.value).then(s,u);R((a=a.apply(t,e)).next())});var Ue={};De(Ue,{Event:()=>F,initialize:()=>Ke});function q(t){this.message=t}q.prototype=new Error,q.prototype.name="InvalidCharacterError";var le=typeof window!="undefined"&&window.atob&&window.atob.bind(window)||function(t){var e=String(t).replace(/=+$/,"");if(e.length%4==1)throw new q("'atob' failed: The string to be decoded is not correctly encoded.");for(var a,r,o=0,s=0,u="";r=e.charAt(s++);~r&&(a=o%4?64*a+r:r,o++%4)?u+=String.fromCharCode(255&a>>(-2*o&6)):0)r="ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=".indexOf(r);return u};function xe(t){var e=t.replace(/-/g,"+").replace(/_/g,"/");switch(e.length%4){case 0:break;case 2:e+="==";break;case 3:e+="=";break;default:throw"Illegal base64url string!"}try{return function(a){return decodeURIComponent(le(a).replace(/(.)/g,function(r,o){var s=o.charCodeAt(0).toString(16).toUpperCase();return s.length<2&&(s="0"+s),"%"+s}))}(e)}catch(a){return le(e)}}function V(t){this.message=t}function ke(t,e){if(typeof t!="string")throw new V("Invalid token specified");var a=(e=e||{}).header===!0?0:1;try{return JSON.parse(xe(t.split(".")[a]))}catch(r){throw new V("Invalid token specified: "+r.message)}}V.prototype=new Error,V.prototype.name="InvalidTokenError";var ce=ke;function de(t){return{all:t=t||new Map,on:function(e,a){var r=t.get(e);r&&r.push(a)||t.set(e,[a])},off:function(e,a){var r=t.get(e);r&&r.splice(r.indexOf(a)>>>0,1)},emit:function(e,a){(t.get(e)||[]).slice().map(function(r){r(a)}),(t.get("*")||[]).slice().map(function(r){r(e,a)})}}}var F=(v=>(v.READY="ready",v.CONNECTED="connected",v.DISCONNECTED="disconnected",v.STOPPED="stopped",v.POLLING="polling",v.POLLING_STOPPED="polling stopped",v.FLAGS_LOADED="flags loaded",v.CACHE_LOADED="cache loaded",v.CHANGED="changed",v.ERROR="error",v.ERROR_CACHE="cache error",v.ERROR_METRICS="metrics error",v.ERROR_AUTH="auth error",v.ERROR_FETCH_FLAGS="fetch flags error",v.ERROR_FETCH_FLAG="fetch flag error",v.ERROR_STREAM="stream error",v))(F||{});var Me={debug:!1,baseUrl:"https://config.ff.harness.io/api/1.0",eventUrl:"https://events.ff.harness.io/api/1.0",eventsSyncInterval:6e4,pollingInterval:6e4,streamEnabled:!0,cache:!1},ge=t=>{let e=C(C({},Me),t);return e.pollingEnabled===void 0&&(e.pollingEnabled=e.streamEnabled),e.eventsSyncInterval<6e4&&(e.eventsSyncInterval=6e4),e.pollingInterval<6e4&&(e.pollingInterval=6e4),(!e.logger||!e.logger.debug||!e.logger.error||!e.logger.info||!e.logger.warn)&&(e.logger=console),e},J=(t,e=!0)=>{e?setTimeout(t,0):t()},_=(t,e)=>Math.round(Math.random()*(e-t)+t);function W(t){return function(...a){let[r,o]=t(a);return fetch(r,o)}}var ue=3e4,L=class{constructor(e,a,r,o,s,u,R,y,d){this.eventBus=e;this.configurations=a;this.url=r;this.apiKey=o;this.standardHeaders=s;this.fallbackPoller=u;this.logDebug=R;this.logError=y;this.eventCallback=d;this.closed=!1;this.connectionOpened=!1;this.disconnectEventEmitted=!1}start(){let e=d=>{d.toString().split(/\r?\n/).forEach(a)},a=d=>{if(d.startsWith("data:")){let S=JSON.parse(d.substring(5));this.logDebugMessage("Received event from stream: ",S),this.eventCallback(S)}},r=()=>{this.logDebugMessage("Stream connected"),this.eventBus.emit("connected")},o=()=>{clearInterval(this.readTimeoutCheckerId);let d=_(1e3,1e4);this.logDebugMessage("Stream disconnected, will reconnect in "+d+"ms"),this.disconnectEventEmitted||(this.eventBus.emit("disconnected"),this.disconnectEventEmitted=!0),setTimeout(()=>this.start(),d)},s=d=>{d&&this.logErrorMessage("Stream has issue",d),this.fallBackToPolling(),this.eventBus.emit("stream error",d),this.eventBus.emit("error",d),o()},u=C({"Cache-Control":"no-cache",Accept:"text/event-stream","API-Key":this.apiKey},this.standardHeaders);this.logDebugMessage("SSE HTTP start request",this.url),this.xhr=new XMLHttpRequest,this.xhr.open("GET",this.url);for(let[d,S]of Object.entries(u))this.xhr.setRequestHeader(d,S);this.xhr.timeout=24*60*60*1e3,this.xhr.onerror=()=>{this.connectionOpened=!1,s("XMLHttpRequest error on SSE stream")},this.xhr.onabort=()=>{this.connectionOpened=!1,this.logDebugMessage("SSE aborted"),this.closed||s(null)},this.xhr.ontimeout=()=>{this.connectionOpened=!1,s("SSE timeout")},this.xhr.onload=()=>{if(this.xhr.status>=400&&this.xhr.status<=599){s(`HTTP code ${this.xhr.status}`);return}this.connectionOpened||(r(),this.connectionOpened=!0,this.disconnectEventEmitted=!1)};let R=0,y=Date.now();this.xhr.onprogress=()=>{this.connectionOpened||(r(),this.connectionOpened=!0,this.disconnectEventEmitted=!1),this.stopFallBackPolling(),y=Date.now();let d=this.xhr.responseText.slice(R);R+=d.length,this.logDebugMessage("SSE GOT: "+d),e(d)},this.readTimeoutCheckerId=setInterval(()=>{y<Date.now()-ue&&(this.logErrorMessage("SSE read timeout"),this.xhr.abort())},ue),this.xhr.send()}close(){this.connectionOpened=!1,this.closed=!0,this.xhr&&this.xhr.abort(),clearInterval(this.readTimeoutCheckerId),this.eventBus.emit("stopped"),this.stopFallBackPolling()}fallBackToPolling(){!this.fallbackPoller.isPolling()&&this.configurations.pollingEnabled&&(this.logDebugMessage("Falling back to polling mode while stream recovers"),this.fallbackPoller.start())}stopFallBackPolling(){this.fallbackPoller.isPolling()&&(this.logDebugMessage("Stopping fallback polling mode"),this.fallbackPoller.stop())}logDebugMessage(e,...a){this.configurations.debug&&this.logDebug(`Streaming:  ${e}`,...a)}logErrorMessage(e,...a){this.logError(`Streaming:  ${e}`,...a)}};function fe(t,e,a,r,o){let s=t in a,u=s?a[t]:e;return s&&r(t,u),o?{value:u,isDefaultValue:!s}:u}var x=class{constructor(e,a,r,o,s){this.fetchFlagsFn=e;this.configurations=a;this.eventBus=r;this.logDebug=o;this.logError=s;this.maxAttempts=5}start(){if(this.isPolling()){this.logDebugMessage("Already polling.");return}this.isRunning=!0,this.eventBus.emit("polling"),this.logDebugMessage(`Starting poller, first poll will be in ${this.configurations.pollingInterval}ms`),this.timeoutId=setTimeout(()=>this.poll(),this.configurations.pollingInterval)}poll(){this.attemptFetch().finally(()=>{this.timeoutId=setTimeout(()=>this.poll(),this.configurations.pollingInterval)})}attemptFetch(){return h(this,null,function*(){for(let e=1;e<=this.maxAttempts;e++){let a=yield this.fetchFlagsFn();if(a.type==="success"){this.logDebugMessage(`Successfully polled for flag updates, next poll in ${this.configurations.pollingInterval}ms. `);return}if(this.logErrorMessage("Error when polling for flag updates",a.error),e>=this.maxAttempts){this.logDebugMessage(`Maximum attempts reached for polling for flags. Next poll in ${this.configurations.pollingInterval}ms.`);return}this.logDebugMessage(`Polling for flags attempt #${e} failed. Remaining attempts: ${this.maxAttempts-e}`,a.error);let r=_(1e3,1e4);yield new Promise(o=>setTimeout(o,r))}})}stop(){this.timeoutId&&(clearTimeout(this.timeoutId),this.timeoutId=void 0,this.isRunning=!1,this.eventBus.emit("polling stopped"),this.logDebugMessage("Polling stopped"))}isPolling(){return this.isRunning}logDebugMessage(e,...a){this.configurations.debug&&this.logDebug(`Poller: ${e}`,...a)}logErrorMessage(e,...a){this.logError(`Poller: ${e}`,...a)}};function he(a){return h(this,arguments,function*(t,e={}){let r=yield Le(t),o=He(e);return{loadFromCache:()=>Y(r,o,e),saveToCache:s=>z(r,o,s),updateCachedEvaluation:s=>Ve(r,o,s),removeCachedEvaluation:s=>_e(r,o,s)}})}function Y(r,o){return h(this,arguments,function*(t,e,a={}){let s=parseInt(yield e.getItem(t+".ts"));if(a!=null&&a.ttl&&!isNaN(s)&&s+a.ttl<Date.now())return yield Ne(t,e),[];let u=yield e.getItem(t);if(u)try{return JSON.parse(u)}catch(R){}return[]})}function Ne(t,e){return h(this,null,function*(){yield e.removeItem(t),yield e.removeItem(t+".ts")})}function z(t,e,a){return h(this,null,function*(){yield e.setItem(t,JSON.stringify(a)),yield e.setItem(t+".ts",Date.now().toString())})}function Ve(t,e,a){return h(this,null,function*(){let r=yield Y(t,e),o=r.find(({flag:s})=>s===a.flag);o?Object.assign(o,a):r.push(a),yield z(t,e,r)})}function _e(t,e,a){return h(this,null,function*(){let r=yield Y(t,e),o=r.findIndex(({flag:s})=>s===a);o>-1&&(r.splice(o,1),yield z(t,e,r))})}function Le(t){return h(this,null,function*(){var a,r;let e=t;if(globalThis!=null&&globalThis.TextEncoder&&((r=(a=globalThis==null?void 0:globalThis.crypto)==null?void 0:a.subtle)!=null&&r.digest)){let s=new TextEncoder().encode(t),u=yield crypto.subtle.digest("SHA-256",s);e=Array.from(new Uint8Array(u)).map(y=>y.toString(16).padStart(2,"0")).join("")}else globalThis.btoa&&(e=btoa(t));return"HARNESS_FF_CACHE_"+e})}function He(t){let e;return!t.storage||typeof t.storage!="object"||!("getItem"in t.storage)||!("setItem"in t.storage)||!("removeItem"in t.storage)?globalThis.localStorage?e=globalThis.localStorage:globalThis.sessionStorage?e=globalThis.sessionStorage:e=Ge:e=t.storage,{getItem(r){return h(this,null,function*(){let o=e.getItem(r);return o instanceof Promise?yield o:o})},setItem(r,o){return h(this,null,function*(){let s=e.setItem(r,o);s instanceof Promise&&(yield s)})},removeItem(r){return h(this,null,function*(){let o=e.removeItem(r);o instanceof Promise&&(yield o)})}}}var Ge={getItem:()=>null,setItem:()=>{},removeItem:()=>{}};var me="1.25.0",ve=`Javascript ${me} Client`,$e=500,Be=globalThis.fetch,X=!!globalThis.Proxy,Ke=(t,e,a)=>{let r=!1,o,s,u,R,y,d,S=!0,A={},k=W(i=>i),Q=0,Z=!1,H=()=>{S=!1},v=()=>{S=!0},w=[],g=de(),m=ge(a),p=(i,...n)=>{m.debug&&m.logger.debug(`[FF-SDK] ${i}`,...n)},O=(i,...n)=>{m.logger.error(`[FF-SDK] ${i}`,...n)},G=i=>{let{value:n}=i;try{switch(i.kind.toLowerCase()){case"int":case"number":n=Number(n);break;case"boolean":n=n.toString().toLowerCase()==="true";break;case"json":n=JSON.parse(n);break}}catch(c){O(c)}return n},$=i=>{if(S){let n=Date.now();n-i.lastAccessed>$e&&(i.count++,i.lastAccessed=n)}},pe=()=>h(void 0,null,function*(){if(m.cache){p("initializing cache");try{let i=!0,n=yield he(e.identifier+t,typeof m.cache=="boolean"?{}:m.cache),c=yield n.loadFromCache();c!=null&&c.length&&J(()=>{p("loading from cache",c),ne(c,!1),g.emit("cache loaded",c)}),U("flags loaded",f=>h(void 0,null,function*(){yield n.saveToCache(f),i=!1})),U("changed",f=>h(void 0,null,function*(){i||(f.deleted?yield n.removeCachedEvaluation(f.flag):yield n.updateCachedEvaluation(f))}))}catch(i){O("Cache error: ",i),g.emit("cache error",i),g.emit("error",i)}}}),Ee=(i,n)=>h(void 0,null,function*(){return(yield(yield Be(`${n.baseUrl}/client/auth`,{method:"POST",headers:{"Content-Type":"application/json","Harness-SDK-Info":ve},body:JSON.stringify({apiKey:i,target:j(C({},e),{identifier:String(e.identifier)})})})).json()).authToken}),B=0,K=()=>{if(w.length){p("Sending metrics...",{metrics:w,evaluations:I});let i={metricsData:w.map(n=>({timestamp:Date.now(),count:n.count,metricsType:"FFMETRICS",attributes:[{key:"featureIdentifier",value:n.featureIdentifier},{key:"featureName",value:n.featureIdentifier},{key:"variationIdentifier",value:n.variationIdentifier},{key:"target",value:e.identifier},{key:"SDK_NAME",value:"JavaScript"},{key:"SDK_LANGUAGE",value:"JavaScript"},{key:"SDK_TYPE",value:"client"},{key:"SDK_VERSION",value:me}]}))};k(`${m.eventUrl}/metrics/${o}?cluster=${s}`,{method:"POST",headers:C({"Content-Type":"application/json"},A),body:JSON.stringify(i)}).then(()=>{w=[],B=0}).catch(n=>{B++&&(w=[],B=0),p(n),g.emit("metrics error",n)}).finally(()=>{d=window.setTimeout(K,m.eventsSyncInterval)})}else d=window.setTimeout(K,m.eventsSyncInterval)},I={},be=i=>{p("Sending event for",i.flag),X?g.emit("changed",new Proxy(i,{get(n,c){var f;if(S&&n.hasOwnProperty(c)&&c==="value"){let E=n.flag,l=i.value,b=w.find(P=>P.featureIdentifier===E&&P.featureValue===l);b?($(b),b.variationIdentifier=((f=I[E])==null?void 0:f.identifier)||""):w.push({featureIdentifier:E,featureValue:String(l),variationIdentifier:I[E].identifier||"",count:1,lastAccessed:Date.now()}),p("Metrics event: Flag",c,"has been read with value via stream update",l)}return c==="value"?G(i):i[c]}})):g.emit("changed",{deleted:i.deleted,flag:i.flag,value:G(i)})},ee=function(){return X?new Proxy({},{get(i,n){var f,E,l;let c=i[n];if(S&&i.hasOwnProperty(n)){let b=i[n],P=w.find(ae=>ae.featureIdentifier===n&&b===ae.featureValue);P?(P.variationIdentifier=((f=I[n])==null?void 0:f.identifier)||"",$(P)):w.push({featureIdentifier:n,featureValue:b,variationIdentifier:((E=I[n])==null?void 0:E.identifier)||"",count:1,lastAccessed:Date.now()}),p("Metrics event: Flag:",n,"has been read with value:",b,"variationIdentifier:",(l=I[n])==null?void 0:l.identifier)}return c}}):{}},T=ee();pe().then(()=>Ee(t,m).then(i=>h(void 0,null,function*(){if(r)return;y=i;let n=ce(i);if(A={Authorization:`Bearer ${y}`,"Harness-AccountID":n.accountID,"Harness-EnvironmentID":n.environmentIdentifier,"Harness-SDK-Info":ve},globalThis.btoa){let E=globalThis.btoa(JSON.stringify(e));E.length<262144&&(A["Harness-Target"]=E)}p("Authenticated",n),d=window.setTimeout(K,m.eventsSyncInterval),o=n.environment,s=n.clusterIdentifier;let c=!!Object.keys(I).length;if((yield M()).type==="success"&&p("Fetch all flags ok",T),!r){if(m.streamEnabled?(p("Streaming mode enabled"),ye()):m.pollingEnabled?(p("Polling mode enabled"),Re()):p("Streaming and polling mode disabled"),!c){H();let E=C({},T);v(),g.emit("ready",E)}Z=!0}})).catch(i=>{O("Authentication error: ",i),g.emit("auth error",i),g.emit("error",i)}));let M=()=>h(void 0,null,function*(){try{let i=yield k(`${m.baseUrl}/client/env/${o}/target/${e.identifier}/evaluations?cluster=${s}`,{headers:A});if(i.ok){let n=yield i.json();return n.forEach(D),g.emit("flags loaded",n),{type:"success",data:n}}else return O("Features fetch operation error: ",i),g.emit("fetch flags error",i),g.emit("error",i),{type:"error",error:i}}catch(i){return O("Features fetch operation error: ",i),g.emit("fetch flags error",i),g.emit("error",i),{type:"error",error:i}}}),te=i=>h(void 0,null,function*(){try{let n=yield k(`${m.baseUrl}/client/env/${o}/target/${e.identifier}/evaluations/${i}?cluster=${s}`,{headers:A});if(n.ok){let c=yield n.json();D(c)}else O("Feature fetch operation error: ",n),g.emit("fetch flag error",n),g.emit("error",n)}catch(n){O("Feature fetch operation error: ",n),g.emit("fetch flag error",n),g.emit("error",n)}}),D=i=>{H();let n=G(i);n!==T[i.flag]&&(p("Flag variation has changed for ",i.identifier),T[i.flag]=n,I[i.flag]=j(C({},i),{value:n}),be(i)),v()};R=new x(M,m,g,p,O);let ye=()=>{let i=l=>{switch(l.event){case"create":c(l.evaluations)?l.evaluations.forEach(b=>{D(b)}):setTimeout(()=>te(l.identifier),1e3);break;case"patch":c(l.evaluations)?l.evaluations.forEach(b=>{D(b)}):te(l.identifier);break;case"delete":delete T[l.identifier],g.emit("changed",{flag:l.identifier,value:void 0,deleted:!0}),p("Evaluation deleted",{message:l,storage:T});break}},n=l=>!(!l||!l.flag||!l.identifier||!l.kind||!l.value),c=l=>!(!l||l.length==0||!l.every(b=>n(b))),f=l=>{l.event==="patch"&&(c(l.evaluations)?l.evaluations.forEach(b=>{D(b)}):M())},E=`${m.baseUrl}/stream?cluster=${s}`;u=new L(g,m,E,t,A,R,p,O,l=>{l.domain==="flag"?i(l):l.domain==="target-segment"&&f(l)}),u.start()},Re=()=>{R.start()},U=(i,n)=>g.on(i,n),Ie=(i,n)=>{i?g.off(i,n):ie()},Se=(i,n)=>{var l;if(!S||X||n===void 0)return;let c=n,f=i,E=w.find(b=>b.featureIdentifier===f&&b.featureValue===c);E?($(E),E.variationIdentifier=((l=I[f])==null?void 0:l.identifier)||""):w.push({featureIdentifier:f,featureValue:c,count:1,variationIdentifier:I[f].identifier||"",lastAccessed:Date.now()})},ie=()=>{r=!0,m.streamEnabled&&(p("Closing event stream"),typeof(u==null?void 0:u.close)=="function"&&u.close(),g.all.clear()),m.pollingEnabled&&R.isPolling()&&(p("Closing Poller"),R.stop()),T=ee(),I={},clearTimeout(d)},ne=(i,n=!0)=>{i.length&&J(()=>{let c=!!Object.keys(I).length;if(i.forEach(D),!c){H();let f=C({},T);v(),g.emit("ready",f)}},n)};return{on:U,off:Ie,close:ie,setEvaluations:ne,registerAPIRequestMiddleware:i=>{k=W(i)},refreshEvaluations:()=>{Z&&!r&&Date.now()-Q>=6e4&&(M(),Q=Date.now())},variation:(i,n,c=!1)=>fe(i,n,T,Se,c)}};return Fe(Ue);})();
+var HarnessFFSDK=(()=>{var N=Object.defineProperty,we=Object.defineProperties,Te=Object.getOwnPropertyDescriptor,Ae=Object.getOwnPropertyDescriptors,Oe=Object.getOwnPropertyNames,ae=Object.getOwnPropertySymbols;var se=Object.prototype.hasOwnProperty,De=Object.prototype.propertyIsEnumerable;var oe=(t,e,i)=>e in t?N(t,e,{enumerable:!0,configurable:!0,writable:!0,value:i}):t[e]=i,w=(t,e)=>{for(var i in e||(e={}))se.call(e,i)&&oe(t,i,e[i]);if(ae)for(var i of ae(e))De.call(e,i)&&oe(t,i,e[i]);return t},j=(t,e)=>we(t,Ae(e));var Pe=(t,e)=>{for(var i in e)N(t,i,{get:e[i],enumerable:!0})},Fe=(t,e,i,a)=>{if(e&&typeof e=="object"||typeof e=="function")for(let o of Oe(e))!se.call(t,o)&&o!==i&&N(t,o,{get:()=>e[o],enumerable:!(a=Te(e,o))||a.enumerable});return t};var xe=t=>Fe(N({},"__esModule",{value:!0}),t);var h=(t,e,i)=>new Promise((a,o)=>{var s=E=>{try{p(i.next(E))}catch(d){o(d)}},g=E=>{try{p(i.throw(E))}catch(d){o(d)}},p=E=>E.done?a(E.value):Promise.resolve(E.value).then(s,g);p((i=i.apply(t,e)).next())});var qe={};Pe(qe,{Event:()=>F,initialize:()=>je});function q(t){this.message=t}q.prototype=new Error,q.prototype.name="InvalidCharacterError";var le=typeof window!="undefined"&&window.atob&&window.atob.bind(window)||function(t){var e=String(t).replace(/=+$/,"");if(e.length%4==1)throw new q("'atob' failed: The string to be decoded is not correctly encoded.");for(var i,a,o=0,s=0,g="";a=e.charAt(s++);~a&&(i=o%4?64*i+a:a,o++%4)?g+=String.fromCharCode(255&i>>(-2*o&6)):0)a="ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=".indexOf(a);return g};function ke(t){var e=t.replace(/-/g,"+").replace(/_/g,"/");switch(e.length%4){case 0:break;case 2:e+="==";break;case 3:e+="=";break;default:throw"Illegal base64url string!"}try{return function(i){return decodeURIComponent(le(i).replace(/(.)/g,function(a,o){var s=o.charCodeAt(0).toString(16).toUpperCase();return s.length<2&&(s="0"+s),"%"+s}))}(e)}catch(i){return le(e)}}function V(t){this.message=t}function Me(t,e){if(typeof t!="string")throw new V("Invalid token specified");var i=(e=e||{}).header===!0?0:1;try{return JSON.parse(ke(t.split(".")[i]))}catch(a){throw new V("Invalid token specified: "+a.message)}}V.prototype=new Error,V.prototype.name="InvalidTokenError";var ce=Me;function de(t){return{all:t=t||new Map,on:function(e,i){var a=t.get(e);a&&a.push(i)||t.set(e,[i])},off:function(e,i){var a=t.get(e);a&&a.splice(a.indexOf(i)>>>0,1)},emit:function(e,i){(t.get(e)||[]).slice().map(function(a){a(i)}),(t.get("*")||[]).slice().map(function(a){a(e,i)})}}}var F=(m=>(m.READY="ready",m.CONNECTED="connected",m.DISCONNECTED="disconnected",m.STOPPED="stopped",m.POLLING="polling",m.POLLING_STOPPED="polling stopped",m.FLAGS_LOADED="flags loaded",m.CACHE_LOADED="cache loaded",m.CHANGED="changed",m.ERROR="error",m.ERROR_CACHE="cache error",m.ERROR_METRICS="metrics error",m.ERROR_AUTH="auth error",m.ERROR_FETCH_FLAGS="fetch flags error",m.ERROR_FETCH_FLAG="fetch flag error",m.ERROR_STREAM="stream error",m))(F||{});var Ne={debug:!1,baseUrl:"https://config.ff.harness.io/api/1.0",eventUrl:"https://events.ff.harness.io/api/1.0",eventsSyncInterval:6e4,pollingInterval:6e4,streamEnabled:!0,cache:!1},ge=t=>{let e=w(w({},Ne),t);return e.pollingEnabled===void 0&&(e.pollingEnabled=e.streamEnabled),e.eventsSyncInterval<6e4&&(e.eventsSyncInterval=6e4),e.pollingInterval<6e4&&(e.pollingInterval=6e4),(!e.logger||!e.logger.debug||!e.logger.error||!e.logger.info||!e.logger.warn)&&(e.logger=console),e},J=(t,e=!0)=>{e?setTimeout(t,0):t()},_=(t,e)=>Math.round(Math.random()*(e-t)+t),ue=t=>{let e="ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=",i="",a=0,o=Ve(JSON.stringify(t));for(;a<o.length;){let s=o.charCodeAt(a++),g=o.charCodeAt(a++),p=o.charCodeAt(a++),E=s>>2,d=(s&3)<<4|g>>4,R=(g&15)<<2|p>>6,T=p&63;isNaN(g)?R=T=64:isNaN(p)&&(T=64),i+=e.charAt(E)+e.charAt(d)+e.charAt(R)+e.charAt(T)}return i},Ve=t=>t.replace(/\r\n/g,`
+`).split("").map(e=>{let i=e.charCodeAt(0);return i<128?String.fromCharCode(i):i>127&&i<2048?String.fromCharCode(i>>6|192)+String.fromCharCode(i&63|128):String.fromCharCode(i>>12|224)+String.fromCharCode(i>>6&63|128)+String.fromCharCode(i&63|128)}).join("");function W(t){return function(...i){let[a,o]=t(i);return fetch(a,o)}}var fe=3e4,L=class{constructor(e,i,a,o,s,g,p,E,d){this.eventBus=e;this.configurations=i;this.url=a;this.apiKey=o;this.standardHeaders=s;this.fallbackPoller=g;this.logDebug=p;this.logError=E;this.eventCallback=d;this.closed=!1;this.connectionOpened=!1;this.disconnectEventEmitted=!1}start(){let e=d=>{d.toString().split(/\r?\n/).forEach(i)},i=d=>{if(d.startsWith("data:")){let R=JSON.parse(d.substring(5));this.logDebugMessage("Received event from stream: ",R),this.eventCallback(R)}},a=()=>{this.logDebugMessage("Stream connected"),this.eventBus.emit("connected")},o=()=>{clearInterval(this.readTimeoutCheckerId);let d=_(1e3,1e4);this.logDebugMessage("Stream disconnected, will reconnect in "+d+"ms"),this.disconnectEventEmitted||(this.eventBus.emit("disconnected"),this.disconnectEventEmitted=!0),setTimeout(()=>this.start(),d)},s=d=>{d&&this.logErrorMessage("Stream has issue",d),this.fallBackToPolling(),this.eventBus.emit("stream error",d),this.eventBus.emit("error",d),o()},g=w({"Cache-Control":"no-cache",Accept:"text/event-stream","API-Key":this.apiKey},this.standardHeaders);this.logDebugMessage("SSE HTTP start request",this.url),this.xhr=new XMLHttpRequest,this.xhr.open("GET",this.url);for(let[d,R]of Object.entries(g))this.xhr.setRequestHeader(d,R);this.xhr.timeout=24*60*60*1e3,this.xhr.onerror=()=>{this.connectionOpened=!1,s("XMLHttpRequest error on SSE stream")},this.xhr.onabort=()=>{this.connectionOpened=!1,this.logDebugMessage("SSE aborted"),this.closed||s(null)},this.xhr.ontimeout=()=>{this.connectionOpened=!1,s("SSE timeout")},this.xhr.onload=()=>{if(this.xhr.status>=400&&this.xhr.status<=599){s(`HTTP code ${this.xhr.status}`);return}this.connectionOpened||(a(),this.connectionOpened=!0,this.disconnectEventEmitted=!1)};let p=0,E=Date.now();this.xhr.onprogress=()=>{this.connectionOpened||(a(),this.connectionOpened=!0,this.disconnectEventEmitted=!1),this.stopFallBackPolling(),E=Date.now();let d=this.xhr.responseText.slice(p);p+=d.length,this.logDebugMessage("SSE GOT: "+d),e(d)},this.readTimeoutCheckerId=setInterval(()=>{E<Date.now()-fe&&(this.logErrorMessage("SSE read timeout"),this.xhr.abort())},fe),this.xhr.send()}close(){this.connectionOpened=!1,this.closed=!0,this.xhr&&this.xhr.abort(),clearInterval(this.readTimeoutCheckerId),this.eventBus.emit("stopped"),this.stopFallBackPolling()}fallBackToPolling(){!this.fallbackPoller.isPolling()&&this.configurations.pollingEnabled&&(this.logDebugMessage("Falling back to polling mode while stream recovers"),this.fallbackPoller.start())}stopFallBackPolling(){this.fallbackPoller.isPolling()&&(this.logDebugMessage("Stopping fallback polling mode"),this.fallbackPoller.stop())}logDebugMessage(e,...i){this.configurations.debug&&this.logDebug(`Streaming:  ${e}`,...i)}logErrorMessage(e,...i){this.logError(`Streaming:  ${e}`,...i)}};function he(t,e,i,a,o){let s=t in i,g=s?i[t]:e;return s&&a(t,g),o?{value:g,isDefaultValue:!s}:g}var x=class{constructor(e,i,a,o,s){this.fetchFlagsFn=e;this.configurations=i;this.eventBus=a;this.logDebug=o;this.logError=s;this.maxAttempts=5}start(){if(this.isPolling()){this.logDebugMessage("Already polling.");return}this.isRunning=!0,this.eventBus.emit("polling"),this.logDebugMessage(`Starting poller, first poll will be in ${this.configurations.pollingInterval}ms`),this.timeoutId=setTimeout(()=>this.poll(),this.configurations.pollingInterval)}poll(){this.attemptFetch().finally(()=>{this.timeoutId=setTimeout(()=>this.poll(),this.configurations.pollingInterval)})}attemptFetch(){return h(this,null,function*(){for(let e=1;e<=this.maxAttempts;e++){let i=yield this.fetchFlagsFn();if(i.type==="success"){this.logDebugMessage(`Successfully polled for flag updates, next poll in ${this.configurations.pollingInterval}ms. `);return}if(this.logErrorMessage("Error when polling for flag updates",i.error),e>=this.maxAttempts){this.logDebugMessage(`Maximum attempts reached for polling for flags. Next poll in ${this.configurations.pollingInterval}ms.`);return}this.logDebugMessage(`Polling for flags attempt #${e} failed. Remaining attempts: ${this.maxAttempts-e}`,i.error);let a=_(1e3,1e4);yield new Promise(o=>setTimeout(o,a))}})}stop(){this.timeoutId&&(clearTimeout(this.timeoutId),this.timeoutId=void 0,this.isRunning=!1,this.eventBus.emit("polling stopped"),this.logDebugMessage("Polling stopped"))}isPolling(){return this.isRunning}logDebugMessage(e,...i){this.configurations.debug&&this.logDebug(`Poller: ${e}`,...i)}logErrorMessage(e,...i){this.logError(`Poller: ${e}`,...i)}};function me(i){return h(this,arguments,function*(t,e={}){let a=yield Ge(t),o=$e(e);return{loadFromCache:()=>Y(a,o,e),saveToCache:s=>z(a,o,s),updateCachedEvaluation:s=>Le(a,o,s),removeCachedEvaluation:s=>He(a,o,s)}})}function Y(a,o){return h(this,arguments,function*(t,e,i={}){let s=parseInt(yield e.getItem(t+".ts"));if(i!=null&&i.ttl&&!isNaN(s)&&s+i.ttl<Date.now())return yield _e(t,e),[];let g=yield e.getItem(t);if(g)try{return JSON.parse(g)}catch(p){}return[]})}function _e(t,e){return h(this,null,function*(){yield e.removeItem(t),yield e.removeItem(t+".ts")})}function z(t,e,i){return h(this,null,function*(){yield e.setItem(t,JSON.stringify(i)),yield e.setItem(t+".ts",Date.now().toString())})}function Le(t,e,i){return h(this,null,function*(){let a=yield Y(t,e),o=a.find(({flag:s})=>s===i.flag);o?Object.assign(o,i):a.push(i),yield z(t,e,a)})}function He(t,e,i){return h(this,null,function*(){let a=yield Y(t,e),o=a.findIndex(({flag:s})=>s===i);o>-1&&(a.splice(o,1),yield z(t,e,a))})}function Ge(t){return h(this,null,function*(){var i,a;let e=t;if(globalThis!=null&&globalThis.TextEncoder&&((a=(i=globalThis==null?void 0:globalThis.crypto)==null?void 0:i.subtle)!=null&&a.digest)){let s=new TextEncoder().encode(t),g=yield crypto.subtle.digest("SHA-256",s);e=Array.from(new Uint8Array(g)).map(E=>E.toString(16).padStart(2,"0")).join("")}else globalThis.btoa&&(e=btoa(t));return"HARNESS_FF_CACHE_"+e})}function $e(t){let e;return!t.storage||typeof t.storage!="object"||!("getItem"in t.storage)||!("setItem"in t.storage)||!("removeItem"in t.storage)?globalThis.localStorage?e=globalThis.localStorage:globalThis.sessionStorage?e=globalThis.sessionStorage:e=Be:e=t.storage,{getItem(a){return h(this,null,function*(){let o=e.getItem(a);return o instanceof Promise?yield o:o})},setItem(a,o){return h(this,null,function*(){let s=e.setItem(a,o);s instanceof Promise&&(yield s)})},removeItem(a){return h(this,null,function*(){let o=e.removeItem(a);o instanceof Promise&&(yield o)})}}}var Be={getItem:()=>null,setItem:()=>{},removeItem:()=>{}};var pe="1.26.1",ve=`Javascript ${pe} Client`,Ke=500,Ue=globalThis.fetch,X=!!globalThis.Proxy,je=(t,e,i)=>{let a=!1,o,s,g,p,E,d,R=!0,T={},k=W(n=>n),Q=0,Z=!1,H=()=>{R=!1},m=()=>{R=!0},C=[],u=de(),v=ge(i),y=(n,...r)=>{v.debug&&v.logger.debug(`[FF-SDK] ${n}`,...r)},A=(n,...r)=>{v.logger.error(`[FF-SDK] ${n}`,...r)},G=n=>{let{value:r}=n;try{switch(n.kind.toLowerCase()){case"int":case"number":r=Number(r);break;case"boolean":r=r.toString().toLowerCase()==="true";break;case"json":r=JSON.parse(r);break}}catch(c){A(c)}return r},$=n=>{if(R){let r=Date.now();r-n.lastAccessed>Ke&&(n.count++,n.lastAccessed=r)}},Ee=()=>h(void 0,null,function*(){if(v.cache){y("initializing cache");try{let n=!0,r=yield me(e.identifier+t,typeof v.cache=="boolean"?{}:v.cache),c=yield r.loadFromCache();c!=null&&c.length&&J(()=>{y("loading from cache",c),ne(c,!1),u.emit("cache loaded",c)}),U("flags loaded",f=>h(void 0,null,function*(){yield r.saveToCache(f),n=!1})),U("changed",f=>h(void 0,null,function*(){n||(f.deleted?yield r.removeCachedEvaluation(f.flag):yield r.updateCachedEvaluation(f))}))}catch(n){A("Cache error: ",n),u.emit("cache error",n),u.emit("error",n)}}}),ye=(n,r)=>h(void 0,null,function*(){return(yield(yield Ue(`${r.baseUrl}/client/auth`,{method:"POST",headers:{"Content-Type":"application/json","Harness-SDK-Info":ve},body:JSON.stringify({apiKey:n,target:j(w({},e),{identifier:String(e.identifier)})})})).json()).authToken}),B=0,K=()=>{if(C.length){y("Sending metrics...",{metrics:C,evaluations:I});let n={metricsData:C.map(r=>({timestamp:Date.now(),count:r.count,metricsType:"FFMETRICS",attributes:[{key:"featureIdentifier",value:r.featureIdentifier},{key:"featureName",value:r.featureIdentifier},{key:"variationIdentifier",value:r.variationIdentifier},{key:"target",value:e.identifier},{key:"SDK_NAME",value:"JavaScript"},{key:"SDK_LANGUAGE",value:"JavaScript"},{key:"SDK_TYPE",value:"client"},{key:"SDK_VERSION",value:pe}]}))};k(`${v.eventUrl}/metrics/${o}?cluster=${s}`,{method:"POST",headers:w({"Content-Type":"application/json"},T),body:JSON.stringify(n)}).then(()=>{C=[],B=0}).catch(r=>{B++&&(C=[],B=0),y(r),u.emit("metrics error",r)}).finally(()=>{d=window.setTimeout(K,v.eventsSyncInterval)})}else d=window.setTimeout(K,v.eventsSyncInterval)},I={},be=n=>{y("Sending event for",n.flag),X?u.emit("changed",new Proxy(n,{get(r,c){var f;if(R&&r.hasOwnProperty(c)&&c==="value"){let S=r.flag,l=n.value,b=C.find(P=>P.featureIdentifier===S&&P.featureValue===l);b?($(b),b.variationIdentifier=((f=I[S])==null?void 0:f.identifier)||""):C.push({featureIdentifier:S,featureValue:String(l),variationIdentifier:I[S].identifier||"",count:1,lastAccessed:Date.now()}),y("Metrics event: Flag",c,"has been read with value via stream update",l)}return c==="value"?G(n):n[c]}})):u.emit("changed",{deleted:n.deleted,flag:n.flag,value:G(n)})},ee=function(){return X?new Proxy({},{get(n,r){var f,S,l;let c=n[r];if(R&&n.hasOwnProperty(r)){let b=n[r],P=C.find(re=>re.featureIdentifier===r&&b===re.featureValue);P?(P.variationIdentifier=((f=I[r])==null?void 0:f.identifier)||"",$(P)):C.push({featureIdentifier:r,featureValue:b,variationIdentifier:((S=I[r])==null?void 0:S.identifier)||"",count:1,lastAccessed:Date.now()}),y("Metrics event: Flag:",r,"has been read with value:",b,"variationIdentifier:",(l=I[r])==null?void 0:l.identifier)}return c}}):{}},O=ee();Ee().then(()=>ye(t,v).then(n=>h(void 0,null,function*(){if(a)return;E=n;let r=ce(n);T={Authorization:`Bearer ${E}`,"Harness-AccountID":r.accountID,"Harness-EnvironmentID":r.environmentIdentifier,"Harness-SDK-Info":ve};let c=ue(e);c.length<262144&&(T["Harness-Target"]=c),y("Authenticated",r),d=window.setTimeout(K,v.eventsSyncInterval),o=r.environment,s=r.clusterIdentifier;let f=!!Object.keys(I).length;if((yield M()).type==="success"&&y("Fetch all flags ok",O),!a){if(v.streamEnabled?(y("Streaming mode enabled"),Re()):v.pollingEnabled?(y("Polling mode enabled"),Se()):y("Streaming and polling mode disabled"),!f){H();let l=w({},O);m(),u.emit("ready",l)}Z=!0}})).catch(n=>{A("Authentication error: ",n),u.emit("auth error",n),u.emit("error",n)}));let M=()=>h(void 0,null,function*(){try{let n=yield k(`${v.baseUrl}/client/env/${o}/target/${e.identifier}/evaluations?cluster=${s}`,{headers:T});if(n.ok){let r=yield n.json();return r.forEach(D),u.emit("flags loaded",r),{type:"success",data:r}}else return A("Features fetch operation error: ",n),u.emit("fetch flags error",n),u.emit("error",n),{type:"error",error:n}}catch(n){return A("Features fetch operation error: ",n),u.emit("fetch flags error",n),u.emit("error",n),{type:"error",error:n}}}),te=n=>h(void 0,null,function*(){try{let r=yield k(`${v.baseUrl}/client/env/${o}/target/${e.identifier}/evaluations/${n}?cluster=${s}`,{headers:T});if(r.ok){let c=yield r.json();D(c)}else A("Feature fetch operation error: ",r),u.emit("fetch flag error",r),u.emit("error",r)}catch(r){A("Feature fetch operation error: ",r),u.emit("fetch flag error",r),u.emit("error",r)}}),D=n=>{H();let r=G(n);r!==O[n.flag]&&(y("Flag variation has changed for ",n.identifier),O[n.flag]=r,I[n.flag]=j(w({},n),{value:r}),be(n)),m()};p=new x(M,v,u,y,A);let Re=()=>{let n=l=>{switch(l.event){case"create":c(l.evaluations)?l.evaluations.forEach(b=>{D(b)}):setTimeout(()=>te(l.identifier),1e3);break;case"patch":c(l.evaluations)?l.evaluations.forEach(b=>{D(b)}):te(l.identifier);break;case"delete":delete O[l.identifier],u.emit("changed",{flag:l.identifier,value:void 0,deleted:!0}),y("Evaluation deleted",{message:l,storage:O});break}},r=l=>!(!l||!l.flag||!l.identifier||!l.kind||!l.value),c=l=>!(!l||l.length==0||!l.every(b=>r(b))),f=l=>{l.event==="patch"&&(c(l.evaluations)?l.evaluations.forEach(b=>{D(b)}):M())},S=`${v.baseUrl}/stream?cluster=${s}`;g=new L(u,v,S,t,T,p,y,A,l=>{l.domain==="flag"?n(l):l.domain==="target-segment"&&f(l)}),g.start()},Se=()=>{p.start()},U=(n,r)=>u.on(n,r),Ie=(n,r)=>{n?u.off(n,r):ie()},Ce=(n,r)=>{var l;if(!R||X||r===void 0)return;let c=r,f=n,S=C.find(b=>b.featureIdentifier===f&&b.featureValue===c);S?($(S),S.variationIdentifier=((l=I[f])==null?void 0:l.identifier)||""):C.push({featureIdentifier:f,featureValue:c,count:1,variationIdentifier:I[f].identifier||"",lastAccessed:Date.now()})},ie=()=>{a=!0,v.streamEnabled&&(y("Closing event stream"),typeof(g==null?void 0:g.close)=="function"&&g.close(),u.all.clear()),v.pollingEnabled&&p.isPolling()&&(y("Closing Poller"),p.stop()),O=ee(),I={},clearTimeout(d)},ne=(n,r=!0)=>{n.length&&J(()=>{let c=!!Object.keys(I).length;if(n.forEach(D),!c){H();let f=w({},O);m(),u.emit("ready",f)}},r)};return{on:U,off:Ie,close:ie,setEvaluations:ne,registerAPIRequestMiddleware:n=>{k=W(n)},refreshEvaluations:()=>{Z&&!a&&Date.now()-Q>=6e4&&(M(),Q=Date.now())},variation:(n,r,c=!1)=>he(n,r,O,Ce,c)}};return xe(qe);})();

dist/sdk.client.js

@@ -1,1 +0,2 @@
-var Ie=Object.defineProperty,Se=Object.defineProperties;var we=Object.getOwnPropertyDescriptors;var ae=Object.getOwnPropertySymbols;var Ce=Object.prototype.hasOwnProperty,Oe=Object.prototype.propertyIsEnumerable;var re=(i,e,a)=>e in i?Ie(i,e,{enumerable:!0,configurable:!0,writable:!0,value:a}):i[e]=a,C=(i,e)=>{for(var a in e||(e={}))Ce.call(e,a)&&re(i,a,e[a]);if(ae)for(var a of ae(e))Oe.call(e,a)&&re(i,a,e[a]);return i},U=(i,e)=>Se(i,we(e));var h=(i,e,a)=>new Promise((r,o)=>{var s=y=>{try{R(a.next(y))}catch(d){o(d)}},u=y=>{try{R(a.throw(y))}catch(d){o(d)}},R=y=>y.done?r(y.value):Promise.resolve(y.value).then(s,u);R((a=a.apply(i,e)).next())});function j(i){this.message=i}j.prototype=new Error,j.prototype.name="InvalidCharacterError";var oe=typeof window!="undefined"&&window.atob&&window.atob.bind(window)||function(i){var e=String(i).replace(/=+$/,"");if(e.length%4==1)throw new j("'atob' failed: The string to be decoded is not correctly encoded.");for(var a,r,o=0,s=0,u="";r=e.charAt(s++);~r&&(a=o%4?64*a+r:r,o++%4)?u+=String.fromCharCode(255&a>>(-2*o&6)):0)r="ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=".indexOf(r);return u};function Te(i){var e=i.replace(/-/g,"+").replace(/_/g,"/");switch(e.length%4){case 0:break;case 2:e+="==";break;case 3:e+="=";break;default:throw"Illegal base64url string!"}try{return function(a){return decodeURIComponent(oe(a).replace(/(.)/g,function(r,o){var s=o.charCodeAt(0).toString(16).toUpperCase();return s.length<2&&(s="0"+s),"%"+s}))}(e)}catch(a){return oe(e)}}function M(i){this.message=i}function Ae(i,e){if(typeof i!="string")throw new M("Invalid token specified");var a=(e=e||{}).header===!0?0:1;try{return JSON.parse(Te(i.split(".")[a]))}catch(r){throw new M("Invalid token specified: "+r.message)}}M.prototype=new Error,M.prototype.name="InvalidTokenError";var se=Ae;function le(i){return{all:i=i||new Map,on:function(e,a){var r=i.get(e);r&&r.push(a)||i.set(e,[a])},off:function(e,a){var r=i.get(e);r&&r.splice(r.indexOf(a)>>>0,1)},emit:function(e,a){(i.get(e)||[]).slice().map(function(r){r(a)}),(i.get("*")||[]).slice().map(function(r){r(e,a)})}}}var N=(v=>(v.READY="ready",v.CONNECTED="connected",v.DISCONNECTED="disconnected",v.STOPPED="stopped",v.POLLING="polling",v.POLLING_STOPPED="polling stopped",v.FLAGS_LOADED="flags loaded",v.CACHE_LOADED="cache loaded",v.CHANGED="changed",v.ERROR="error",v.ERROR_CACHE="cache error",v.ERROR_METRICS="metrics error",v.ERROR_AUTH="auth error",v.ERROR_FETCH_FLAGS="fetch flags error",v.ERROR_FETCH_FLAG="fetch flag error",v.ERROR_STREAM="stream error",v))(N||{});var De={debug:!1,baseUrl:"https://config.ff.harness.io/api/1.0",eventUrl:"https://events.ff.harness.io/api/1.0",eventsSyncInterval:6e4,pollingInterval:6e4,streamEnabled:!0,cache:!1},ce=i=>{let e=C(C({},De),i);return e.pollingEnabled===void 0&&(e.pollingEnabled=e.streamEnabled),e.eventsSyncInterval<6e4&&(e.eventsSyncInterval=6e4),e.pollingInterval<6e4&&(e.pollingInterval=6e4),(!e.logger||!e.logger.debug||!e.logger.error||!e.logger.info||!e.logger.warn)&&(e.logger=console),e},q=(i,e=!0)=>{e?setTimeout(i,0):i()},V=(i,e)=>Math.round(Math.random()*(e-i)+i);function J(i){return function(...a){let[r,o]=i(a);return fetch(r,o)}}var de=3e4,_=class{constructor(e,a,r,o,s,u,R,y,d){this.eventBus=e;this.configurations=a;this.url=r;this.apiKey=o;this.standardHeaders=s;this.fallbackPoller=u;this.logDebug=R;this.logError=y;this.eventCallback=d;this.closed=!1;this.connectionOpened=!1;this.disconnectEventEmitted=!1}start(){let e=d=>{d.toString().split(/\r?\n/).forEach(a)},a=d=>{if(d.startsWith("data:")){let S=JSON.parse(d.substring(5));this.logDebugMessage("Received event from stream: ",S),this.eventCallback(S)}},r=()=>{this.logDebugMessage("Stream connected"),this.eventBus.emit("connected")},o=()=>{clearInterval(this.readTimeoutCheckerId);let d=V(1e3,1e4);this.logDebugMessage("Stream disconnected, will reconnect in "+d+"ms"),this.disconnectEventEmitted||(this.eventBus.emit("disconnected"),this.disconnectEventEmitted=!0),setTimeout(()=>this.start(),d)},s=d=>{d&&this.logErrorMessage("Stream has issue",d),this.fallBackToPolling(),this.eventBus.emit("stream error",d),this.eventBus.emit("error",d),o()},u=C({"Cache-Control":"no-cache",Accept:"text/event-stream","API-Key":this.apiKey},this.standardHeaders);this.logDebugMessage("SSE HTTP start request",this.url),this.xhr=new XMLHttpRequest,this.xhr.open("GET",this.url);for(let[d,S]of Object.entries(u))this.xhr.setRequestHeader(d,S);this.xhr.timeout=24*60*60*1e3,this.xhr.onerror=()=>{this.connectionOpened=!1,s("XMLHttpRequest error on SSE stream")},this.xhr.onabort=()=>{this.connectionOpened=!1,this.logDebugMessage("SSE aborted"),this.closed||s(null)},this.xhr.ontimeout=()=>{this.connectionOpened=!1,s("SSE timeout")},this.xhr.onload=()=>{if(this.xhr.status>=400&&this.xhr.status<=599){s(`HTTP code ${this.xhr.status}`);return}this.connectionOpened||(r(),this.connectionOpened=!0,this.disconnectEventEmitted=!1)};let R=0,y=Date.now();this.xhr.onprogress=()=>{this.connectionOpened||(r(),this.connectionOpened=!0,this.disconnectEventEmitted=!1),this.stopFallBackPolling(),y=Date.now();let d=this.xhr.responseText.slice(R);R+=d.length,this.logDebugMessage("SSE GOT: "+d),e(d)},this.readTimeoutCheckerId=setInterval(()=>{y<Date.now()-de&&(this.logErrorMessage("SSE read timeout"),this.xhr.abort())},de),this.xhr.send()}close(){this.connectionOpened=!1,this.closed=!0,this.xhr&&this.xhr.abort(),clearInterval(this.readTimeoutCheckerId),this.eventBus.emit("stopped"),this.stopFallBackPolling()}fallBackToPolling(){!this.fallbackPoller.isPolling()&&this.configurations.pollingEnabled&&(this.logDebugMessage("Falling back to polling mode while stream recovers"),this.fallbackPoller.start())}stopFallBackPolling(){this.fallbackPoller.isPolling()&&(this.logDebugMessage("Stopping fallback polling mode"),this.fallbackPoller.stop())}logDebugMessage(e,...a){this.configurations.debug&&this.logDebug(`Streaming:  ${e}`,...a)}logErrorMessage(e,...a){this.logError(`Streaming:  ${e}`,...a)}};function ge(i,e,a,r,o){let s=i in a,u=s?a[i]:e;return s&&r(i,u),o?{value:u,isDefaultValue:!s}:u}var F=class{constructor(e,a,r,o,s){this.fetchFlagsFn=e;this.configurations=a;this.eventBus=r;this.logDebug=o;this.logError=s;this.maxAttempts=5}start(){if(this.isPolling()){this.logDebugMessage("Already polling.");return}this.isRunning=!0,this.eventBus.emit("polling"),this.logDebugMessage(`Starting poller, first poll will be in ${this.configurations.pollingInterval}ms`),this.timeoutId=setTimeout(()=>this.poll(),this.configurations.pollingInterval)}poll(){this.attemptFetch().finally(()=>{this.timeoutId=setTimeout(()=>this.poll(),this.configurations.pollingInterval)})}attemptFetch(){return h(this,null,function*(){for(let e=1;e<=this.maxAttempts;e++){let a=yield this.fetchFlagsFn();if(a.type==="success"){this.logDebugMessage(`Successfully polled for flag updates, next poll in ${this.configurations.pollingInterval}ms. `);return}if(this.logErrorMessage("Error when polling for flag updates",a.error),e>=this.maxAttempts){this.logDebugMessage(`Maximum attempts reached for polling for flags. Next poll in ${this.configurations.pollingInterval}ms.`);return}this.logDebugMessage(`Polling for flags attempt #${e} failed. Remaining attempts: ${this.maxAttempts-e}`,a.error);let r=V(1e3,1e4);yield new Promise(o=>setTimeout(o,r))}})}stop(){this.timeoutId&&(clearTimeout(this.timeoutId),this.timeoutId=void 0,this.isRunning=!1,this.eventBus.emit("polling stopped"),this.logDebugMessage("Polling stopped"))}isPolling(){return this.isRunning}logDebugMessage(e,...a){this.configurations.debug&&this.logDebug(`Poller: ${e}`,...a)}logErrorMessage(e,...a){this.logError(`Poller: ${e}`,...a)}};function ue(a){return h(this,arguments,function*(i,e={}){let r=yield ke(i),o=Me(e);return{loadFromCache:()=>W(r,o,e),saveToCache:s=>Y(r,o,s),updateCachedEvaluation:s=>Fe(r,o,s),removeCachedEvaluation:s=>xe(r,o,s)}})}function W(r,o){return h(this,arguments,function*(i,e,a={}){let s=parseInt(yield e.getItem(i+".ts"));if(a!=null&&a.ttl&&!isNaN(s)&&s+a.ttl<Date.now())return yield Pe(i,e),[];let u=yield e.getItem(i);if(u)try{return JSON.parse(u)}catch(R){}return[]})}function Pe(i,e){return h(this,null,function*(){yield e.removeItem(i),yield e.removeItem(i+".ts")})}function Y(i,e,a){return h(this,null,function*(){yield e.setItem(i,JSON.stringify(a)),yield e.setItem(i+".ts",Date.now().toString())})}function Fe(i,e,a){return h(this,null,function*(){let r=yield W(i,e),o=r.find(({flag:s})=>s===a.flag);o?Object.assign(o,a):r.push(a),yield Y(i,e,r)})}function xe(i,e,a){return h(this,null,function*(){let r=yield W(i,e),o=r.findIndex(({flag:s})=>s===a);o>-1&&(r.splice(o,1),yield Y(i,e,r))})}function ke(i){return h(this,null,function*(){var a,r;let e=i;if(globalThis!=null&&globalThis.TextEncoder&&((r=(a=globalThis==null?void 0:globalThis.crypto)==null?void 0:a.subtle)!=null&&r.digest)){let s=new TextEncoder().encode(i),u=yield crypto.subtle.digest("SHA-256",s);e=Array.from(new Uint8Array(u)).map(y=>y.toString(16).padStart(2,"0")).join("")}else globalThis.btoa&&(e=btoa(i));return"HARNESS_FF_CACHE_"+e})}function Me(i){let e;return!i.storage||typeof i.storage!="object"||!("getItem"in i.storage)||!("setItem"in i.storage)||!("removeItem"in i.storage)?globalThis.localStorage?e=globalThis.localStorage:globalThis.sessionStorage?e=globalThis.sessionStorage:e=Ne:e=i.storage,{getItem(r){return h(this,null,function*(){let o=e.getItem(r);return o instanceof Promise?yield o:o})},setItem(r,o){return h(this,null,function*(){let s=e.setItem(r,o);s instanceof Promise&&(yield s)})},removeItem(r){return h(this,null,function*(){let o=e.removeItem(r);o instanceof Promise&&(yield o)})}}}var Ne={getItem:()=>null,setItem:()=>{},removeItem:()=>{}};var he="1.25.0",fe=`Javascript ${he} Client`,Ve=500,_e=globalThis.fetch,z=!!globalThis.Proxy,Et=(i,e,a)=>{let r=!1,o,s,u,R,y,d,S=!0,A={},x=J(t=>t),X=0,Q=!1,L=()=>{S=!1},v=()=>{S=!0},w=[],g=le(),m=ce(a),p=(t,...n)=>{m.debug&&m.logger.debug(`[FF-SDK] ${t}`,...n)},O=(t,...n)=>{m.logger.error(`[FF-SDK] ${t}`,...n)},H=t=>{let{value:n}=t;try{switch(t.kind.toLowerCase()){case"int":case"number":n=Number(n);break;case"boolean":n=n.toString().toLowerCase()==="true";break;case"json":n=JSON.parse(n);break}}catch(c){O(c)}return n},G=t=>{if(S){let n=Date.now();n-t.lastAccessed>Ve&&(t.count++,t.lastAccessed=n)}},ve=()=>h(void 0,null,function*(){if(m.cache){p("initializing cache");try{let t=!0,n=yield ue(e.identifier+i,typeof m.cache=="boolean"?{}:m.cache),c=yield n.loadFromCache();c!=null&&c.length&&q(()=>{p("loading from cache",c),ie(c,!1),g.emit("cache loaded",c)}),K("flags loaded",f=>h(void 0,null,function*(){yield n.saveToCache(f),t=!1})),K("changed",f=>h(void 0,null,function*(){t||(f.deleted?yield n.removeCachedEvaluation(f.flag):yield n.updateCachedEvaluation(f))}))}catch(t){O("Cache error: ",t),g.emit("cache error",t),g.emit("error",t)}}}),me=(t,n)=>h(void 0,null,function*(){return(yield(yield _e(`${n.baseUrl}/client/auth`,{method:"POST",headers:{"Content-Type":"application/json","Harness-SDK-Info":fe},body:JSON.stringify({apiKey:t,target:U(C({},e),{identifier:String(e.identifier)})})})).json()).authToken}),$=0,B=()=>{if(w.length){p("Sending metrics...",{metrics:w,evaluations:I});let t={metricsData:w.map(n=>({timestamp:Date.now(),count:n.count,metricsType:"FFMETRICS",attributes:[{key:"featureIdentifier",value:n.featureIdentifier},{key:"featureName",value:n.featureIdentifier},{key:"variationIdentifier",value:n.variationIdentifier},{key:"target",value:e.identifier},{key:"SDK_NAME",value:"JavaScript"},{key:"SDK_LANGUAGE",value:"JavaScript"},{key:"SDK_TYPE",value:"client"},{key:"SDK_VERSION",value:he}]}))};x(`${m.eventUrl}/metrics/${o}?cluster=${s}`,{method:"POST",headers:C({"Content-Type":"application/json"},A),body:JSON.stringify(t)}).then(()=>{w=[],$=0}).catch(n=>{$++&&(w=[],$=0),p(n),g.emit("metrics error",n)}).finally(()=>{d=window.setTimeout(B,m.eventsSyncInterval)})}else d=window.setTimeout(B,m.eventsSyncInterval)},I={},pe=t=>{p("Sending event for",t.flag),z?g.emit("changed",new Proxy(t,{get(n,c){var f;if(S&&n.hasOwnProperty(c)&&c==="value"){let E=n.flag,l=t.value,b=w.find(P=>P.featureIdentifier===E&&P.featureValue===l);b?(G(b),b.variationIdentifier=((f=I[E])==null?void 0:f.identifier)||""):w.push({featureIdentifier:E,featureValue:String(l),variationIdentifier:I[E].identifier||"",count:1,lastAccessed:Date.now()}),p("Metrics event: Flag",c,"has been read with value via stream update",l)}return c==="value"?H(t):t[c]}})):g.emit("changed",{deleted:t.deleted,flag:t.flag,value:H(t)})},Z=function(){return z?new Proxy({},{get(t,n){var f,E,l;let c=t[n];if(S&&t.hasOwnProperty(n)){let b=t[n],P=w.find(ne=>ne.featureIdentifier===n&&b===ne.featureValue);P?(P.variationIdentifier=((f=I[n])==null?void 0:f.identifier)||"",G(P)):w.push({featureIdentifier:n,featureValue:b,variationIdentifier:((E=I[n])==null?void 0:E.identifier)||"",count:1,lastAccessed:Date.now()}),p("Metrics event: Flag:",n,"has been read with value:",b,"variationIdentifier:",(l=I[n])==null?void 0:l.identifier)}return c}}):{}},T=Z();ve().then(()=>me(i,m).then(t=>h(void 0,null,function*(){if(r)return;y=t;let n=se(t);if(A={Authorization:`Bearer ${y}`,"Harness-AccountID":n.accountID,"Harness-EnvironmentID":n.environmentIdentifier,"Harness-SDK-Info":fe},globalThis.btoa){let E=globalThis.btoa(JSON.stringify(e));E.length<262144&&(A["Harness-Target"]=E)}p("Authenticated",n),d=window.setTimeout(B,m.eventsSyncInterval),o=n.environment,s=n.clusterIdentifier;let c=!!Object.keys(I).length;if((yield k()).type==="success"&&p("Fetch all flags ok",T),!r){if(m.streamEnabled?(p("Streaming mode enabled"),Ee()):m.pollingEnabled?(p("Polling mode enabled"),be()):p("Streaming and polling mode disabled"),!c){L();let E=C({},T);v(),g.emit("ready",E)}Q=!0}})).catch(t=>{O("Authentication error: ",t),g.emit("auth error",t),g.emit("error",t)}));let k=()=>h(void 0,null,function*(){try{let t=yield x(`${m.baseUrl}/client/env/${o}/target/${e.identifier}/evaluations?cluster=${s}`,{headers:A});if(t.ok){let n=yield t.json();return n.forEach(D),g.emit("flags loaded",n),{type:"success",data:n}}else return O("Features fetch operation error: ",t),g.emit("fetch flags error",t),g.emit("error",t),{type:"error",error:t}}catch(t){return O("Features fetch operation error: ",t),g.emit("fetch flags error",t),g.emit("error",t),{type:"error",error:t}}}),ee=t=>h(void 0,null,function*(){try{let n=yield x(`${m.baseUrl}/client/env/${o}/target/${e.identifier}/evaluations/${t}?cluster=${s}`,{headers:A});if(n.ok){let c=yield n.json();D(c)}else O("Feature fetch operation error: ",n),g.emit("fetch flag error",n),g.emit("error",n)}catch(n){O("Feature fetch operation error: ",n),g.emit("fetch flag error",n),g.emit("error",n)}}),D=t=>{L();let n=H(t);n!==T[t.flag]&&(p("Flag variation has changed for ",t.identifier),T[t.flag]=n,I[t.flag]=U(C({},t),{value:n}),pe(t)),v()};R=new F(k,m,g,p,O);let Ee=()=>{let t=l=>{switch(l.event){case"create":c(l.evaluations)?l.evaluations.forEach(b=>{D(b)}):setTimeout(()=>ee(l.identifier),1e3);break;case"patch":c(l.evaluations)?l.evaluations.forEach(b=>{D(b)}):ee(l.identifier);break;case"delete":delete T[l.identifier],g.emit("changed",{flag:l.identifier,value:void 0,deleted:!0}),p("Evaluation deleted",{message:l,storage:T});break}},n=l=>!(!l||!l.flag||!l.identifier||!l.kind||!l.value),c=l=>!(!l||l.length==0||!l.every(b=>n(b))),f=l=>{l.event==="patch"&&(c(l.evaluations)?l.evaluations.forEach(b=>{D(b)}):k())},E=`${m.baseUrl}/stream?cluster=${s}`;u=new _(g,m,E,i,A,R,p,O,l=>{l.domain==="flag"?t(l):l.domain==="target-segment"&&f(l)}),u.start()},be=()=>{R.start()},K=(t,n)=>g.on(t,n),ye=(t,n)=>{t?g.off(t,n):te()},Re=(t,n)=>{var l;if(!S||z||n===void 0)return;let c=n,f=t,E=w.find(b=>b.featureIdentifier===f&&b.featureValue===c);E?(G(E),E.variationIdentifier=((l=I[f])==null?void 0:l.identifier)||""):w.push({featureIdentifier:f,featureValue:c,count:1,variationIdentifier:I[f].identifier||"",lastAccessed:Date.now()})},te=()=>{r=!0,m.streamEnabled&&(p("Closing event stream"),typeof(u==null?void 0:u.close)=="function"&&u.close(),g.all.clear()),m.pollingEnabled&&R.isPolling()&&(p("Closing Poller"),R.stop()),T=Z(),I={},clearTimeout(d)},ie=(t,n=!0)=>{t.length&&q(()=>{let c=!!Object.keys(I).length;if(t.forEach(D),!c){L();let f=C({},T);v(),g.emit("ready",f)}},n)};return{on:K,off:ye,close:te,setEvaluations:ie,registerAPIRequestMiddleware:t=>{x=J(t)},refreshEvaluations:()=>{Q&&!r&&Date.now()-X>=6e4&&(k(),X=Date.now())},variation:(t,n,c=!1)=>ge(t,n,T,Re,c)}};export{N as Event,Et as initialize};
+var Ie=Object.defineProperty,Ce=Object.defineProperties;var we=Object.getOwnPropertyDescriptors;var re=Object.getOwnPropertySymbols;var Te=Object.prototype.hasOwnProperty,Ae=Object.prototype.propertyIsEnumerable;var ae=(i,e,t)=>e in i?Ie(i,e,{enumerable:!0,configurable:!0,writable:!0,value:t}):i[e]=t,w=(i,e)=>{for(var t in e||(e={}))Te.call(e,t)&&ae(i,t,e[t]);if(re)for(var t of re(e))Ae.call(e,t)&&ae(i,t,e[t]);return i},U=(i,e)=>Ce(i,we(e));var h=(i,e,t)=>new Promise((a,o)=>{var s=E=>{try{p(t.next(E))}catch(d){o(d)}},g=E=>{try{p(t.throw(E))}catch(d){o(d)}},p=E=>E.done?a(E.value):Promise.resolve(E.value).then(s,g);p((t=t.apply(i,e)).next())});function j(i){this.message=i}j.prototype=new Error,j.prototype.name="InvalidCharacterError";var oe=typeof window!="undefined"&&window.atob&&window.atob.bind(window)||function(i){var e=String(i).replace(/=+$/,"");if(e.length%4==1)throw new j("'atob' failed: The string to be decoded is not correctly encoded.");for(var t,a,o=0,s=0,g="";a=e.charAt(s++);~a&&(t=o%4?64*t+a:a,o++%4)?g+=String.fromCharCode(255&t>>(-2*o&6)):0)a="ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=".indexOf(a);return g};function Oe(i){var e=i.replace(/-/g,"+").replace(/_/g,"/");switch(e.length%4){case 0:break;case 2:e+="==";break;case 3:e+="=";break;default:throw"Illegal base64url string!"}try{return function(t){return decodeURIComponent(oe(t).replace(/(.)/g,function(a,o){var s=o.charCodeAt(0).toString(16).toUpperCase();return s.length<2&&(s="0"+s),"%"+s}))}(e)}catch(t){return oe(e)}}function M(i){this.message=i}function De(i,e){if(typeof i!="string")throw new M("Invalid token specified");var t=(e=e||{}).header===!0?0:1;try{return JSON.parse(Oe(i.split(".")[t]))}catch(a){throw new M("Invalid token specified: "+a.message)}}M.prototype=new Error,M.prototype.name="InvalidTokenError";var se=De;function le(i){return{all:i=i||new Map,on:function(e,t){var a=i.get(e);a&&a.push(t)||i.set(e,[t])},off:function(e,t){var a=i.get(e);a&&a.splice(a.indexOf(t)>>>0,1)},emit:function(e,t){(i.get(e)||[]).slice().map(function(a){a(t)}),(i.get("*")||[]).slice().map(function(a){a(e,t)})}}}var N=(m=>(m.READY="ready",m.CONNECTED="connected",m.DISCONNECTED="disconnected",m.STOPPED="stopped",m.POLLING="polling",m.POLLING_STOPPED="polling stopped",m.FLAGS_LOADED="flags loaded",m.CACHE_LOADED="cache loaded",m.CHANGED="changed",m.ERROR="error",m.ERROR_CACHE="cache error",m.ERROR_METRICS="metrics error",m.ERROR_AUTH="auth error",m.ERROR_FETCH_FLAGS="fetch flags error",m.ERROR_FETCH_FLAG="fetch flag error",m.ERROR_STREAM="stream error",m))(N||{});var Pe={debug:!1,baseUrl:"https://config.ff.harness.io/api/1.0",eventUrl:"https://events.ff.harness.io/api/1.0",eventsSyncInterval:6e4,pollingInterval:6e4,streamEnabled:!0,cache:!1},ce=i=>{let e=w(w({},Pe),i);return e.pollingEnabled===void 0&&(e.pollingEnabled=e.streamEnabled),e.eventsSyncInterval<6e4&&(e.eventsSyncInterval=6e4),e.pollingInterval<6e4&&(e.pollingInterval=6e4),(!e.logger||!e.logger.debug||!e.logger.error||!e.logger.info||!e.logger.warn)&&(e.logger=console),e},q=(i,e=!0)=>{e?setTimeout(i,0):i()},V=(i,e)=>Math.round(Math.random()*(e-i)+i),de=i=>{let e="ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=",t="",a=0,o=Fe(JSON.stringify(i));for(;a<o.length;){let s=o.charCodeAt(a++),g=o.charCodeAt(a++),p=o.charCodeAt(a++),E=s>>2,d=(s&3)<<4|g>>4,R=(g&15)<<2|p>>6,T=p&63;isNaN(g)?R=T=64:isNaN(p)&&(T=64),t+=e.charAt(E)+e.charAt(d)+e.charAt(R)+e.charAt(T)}return t},Fe=i=>i.replace(/\r\n/g,`
+`).split("").map(e=>{let t=e.charCodeAt(0);return t<128?String.fromCharCode(t):t>127&&t<2048?String.fromCharCode(t>>6|192)+String.fromCharCode(t&63|128):String.fromCharCode(t>>12|224)+String.fromCharCode(t>>6&63|128)+String.fromCharCode(t&63|128)}).join("");function J(i){return function(...t){let[a,o]=i(t);return fetch(a,o)}}var ge=3e4,_=class{constructor(e,t,a,o,s,g,p,E,d){this.eventBus=e;this.configurations=t;this.url=a;this.apiKey=o;this.standardHeaders=s;this.fallbackPoller=g;this.logDebug=p;this.logError=E;this.eventCallback=d;this.closed=!1;this.connectionOpened=!1;this.disconnectEventEmitted=!1}start(){let e=d=>{d.toString().split(/\r?\n/).forEach(t)},t=d=>{if(d.startsWith("data:")){let R=JSON.parse(d.substring(5));this.logDebugMessage("Received event from stream: ",R),this.eventCallback(R)}},a=()=>{this.logDebugMessage("Stream connected"),this.eventBus.emit("connected")},o=()=>{clearInterval(this.readTimeoutCheckerId);let d=V(1e3,1e4);this.logDebugMessage("Stream disconnected, will reconnect in "+d+"ms"),this.disconnectEventEmitted||(this.eventBus.emit("disconnected"),this.disconnectEventEmitted=!0),setTimeout(()=>this.start(),d)},s=d=>{d&&this.logErrorMessage("Stream has issue",d),this.fallBackToPolling(),this.eventBus.emit("stream error",d),this.eventBus.emit("error",d),o()},g=w({"Cache-Control":"no-cache",Accept:"text/event-stream","API-Key":this.apiKey},this.standardHeaders);this.logDebugMessage("SSE HTTP start request",this.url),this.xhr=new XMLHttpRequest,this.xhr.open("GET",this.url);for(let[d,R]of Object.entries(g))this.xhr.setRequestHeader(d,R);this.xhr.timeout=24*60*60*1e3,this.xhr.onerror=()=>{this.connectionOpened=!1,s("XMLHttpRequest error on SSE stream")},this.xhr.onabort=()=>{this.connectionOpened=!1,this.logDebugMessage("SSE aborted"),this.closed||s(null)},this.xhr.ontimeout=()=>{this.connectionOpened=!1,s("SSE timeout")},this.xhr.onload=()=>{if(this.xhr.status>=400&&this.xhr.status<=599){s(`HTTP code ${this.xhr.status}`);return}this.connectionOpened||(a(),this.connectionOpened=!0,this.disconnectEventEmitted=!1)};let p=0,E=Date.now();this.xhr.onprogress=()=>{this.connectionOpened||(a(),this.connectionOpened=!0,this.disconnectEventEmitted=!1),this.stopFallBackPolling(),E=Date.now();let d=this.xhr.responseText.slice(p);p+=d.length,this.logDebugMessage("SSE GOT: "+d),e(d)},this.readTimeoutCheckerId=setInterval(()=>{E<Date.now()-ge&&(this.logErrorMessage("SSE read timeout"),this.xhr.abort())},ge),this.xhr.send()}close(){this.connectionOpened=!1,this.closed=!0,this.xhr&&this.xhr.abort(),clearInterval(this.readTimeoutCheckerId),this.eventBus.emit("stopped"),this.stopFallBackPolling()}fallBackToPolling(){!this.fallbackPoller.isPolling()&&this.configurations.pollingEnabled&&(this.logDebugMessage("Falling back to polling mode while stream recovers"),this.fallbackPoller.start())}stopFallBackPolling(){this.fallbackPoller.isPolling()&&(this.logDebugMessage("Stopping fallback polling mode"),this.fallbackPoller.stop())}logDebugMessage(e,...t){this.configurations.debug&&this.logDebug(`Streaming:  ${e}`,...t)}logErrorMessage(e,...t){this.logError(`Streaming:  ${e}`,...t)}};function ue(i,e,t,a,o){let s=i in t,g=s?t[i]:e;return s&&a(i,g),o?{value:g,isDefaultValue:!s}:g}var F=class{constructor(e,t,a,o,s){this.fetchFlagsFn=e;this.configurations=t;this.eventBus=a;this.logDebug=o;this.logError=s;this.maxAttempts=5}start(){if(this.isPolling()){this.logDebugMessage("Already polling.");return}this.isRunning=!0,this.eventBus.emit("polling"),this.logDebugMessage(`Starting poller, first poll will be in ${this.configurations.pollingInterval}ms`),this.timeoutId=setTimeout(()=>this.poll(),this.configurations.pollingInterval)}poll(){this.attemptFetch().finally(()=>{this.timeoutId=setTimeout(()=>this.poll(),this.configurations.pollingInterval)})}attemptFetch(){return h(this,null,function*(){for(let e=1;e<=this.maxAttempts;e++){let t=yield this.fetchFlagsFn();if(t.type==="success"){this.logDebugMessage(`Successfully polled for flag updates, next poll in ${this.configurations.pollingInterval}ms. `);return}if(this.logErrorMessage("Error when polling for flag updates",t.error),e>=this.maxAttempts){this.logDebugMessage(`Maximum attempts reached for polling for flags. Next poll in ${this.configurations.pollingInterval}ms.`);return}this.logDebugMessage(`Polling for flags attempt #${e} failed. Remaining attempts: ${this.maxAttempts-e}`,t.error);let a=V(1e3,1e4);yield new Promise(o=>setTimeout(o,a))}})}stop(){this.timeoutId&&(clearTimeout(this.timeoutId),this.timeoutId=void 0,this.isRunning=!1,this.eventBus.emit("polling stopped"),this.logDebugMessage("Polling stopped"))}isPolling(){return this.isRunning}logDebugMessage(e,...t){this.configurations.debug&&this.logDebug(`Poller: ${e}`,...t)}logErrorMessage(e,...t){this.logError(`Poller: ${e}`,...t)}};function fe(t){return h(this,arguments,function*(i,e={}){let a=yield Ne(i),o=Ve(e);return{loadFromCache:()=>W(a,o,e),saveToCache:s=>Y(a,o,s),updateCachedEvaluation:s=>ke(a,o,s),removeCachedEvaluation:s=>Me(a,o,s)}})}function W(a,o){return h(this,arguments,function*(i,e,t={}){let s=parseInt(yield e.getItem(i+".ts"));if(t!=null&&t.ttl&&!isNaN(s)&&s+t.ttl<Date.now())return yield xe(i,e),[];let g=yield e.getItem(i);if(g)try{return JSON.parse(g)}catch(p){}return[]})}function xe(i,e){return h(this,null,function*(){yield e.removeItem(i),yield e.removeItem(i+".ts")})}function Y(i,e,t){return h(this,null,function*(){yield e.setItem(i,JSON.stringify(t)),yield e.setItem(i+".ts",Date.now().toString())})}function ke(i,e,t){return h(this,null,function*(){let a=yield W(i,e),o=a.find(({flag:s})=>s===t.flag);o?Object.assign(o,t):a.push(t),yield Y(i,e,a)})}function Me(i,e,t){return h(this,null,function*(){let a=yield W(i,e),o=a.findIndex(({flag:s})=>s===t);o>-1&&(a.splice(o,1),yield Y(i,e,a))})}function Ne(i){return h(this,null,function*(){var t,a;let e=i;if(globalThis!=null&&globalThis.TextEncoder&&((a=(t=globalThis==null?void 0:globalThis.crypto)==null?void 0:t.subtle)!=null&&a.digest)){let s=new TextEncoder().encode(i),g=yield crypto.subtle.digest("SHA-256",s);e=Array.from(new Uint8Array(g)).map(E=>E.toString(16).padStart(2,"0")).join("")}else globalThis.btoa&&(e=btoa(i));return"HARNESS_FF_CACHE_"+e})}function Ve(i){let e;return!i.storage||typeof i.storage!="object"||!("getItem"in i.storage)||!("setItem"in i.storage)||!("removeItem"in i.storage)?globalThis.localStorage?e=globalThis.localStorage:globalThis.sessionStorage?e=globalThis.sessionStorage:e=_e:e=i.storage,{getItem(a){return h(this,null,function*(){let o=e.getItem(a);return o instanceof Promise?yield o:o})},setItem(a,o){return h(this,null,function*(){let s=e.setItem(a,o);s instanceof Promise&&(yield s)})},removeItem(a){return h(this,null,function*(){let o=e.removeItem(a);o instanceof Promise&&(yield o)})}}}var _e={getItem:()=>null,setItem:()=>{},removeItem:()=>{}};var me="1.26.1",he=`Javascript ${me} Client`,Le=500,He=globalThis.fetch,z=!!globalThis.Proxy,bt=(i,e,t)=>{let a=!1,o,s,g,p,E,d,R=!0,T={},x=J(n=>n),X=0,Q=!1,L=()=>{R=!1},m=()=>{R=!0},C=[],u=le(),v=ce(t),y=(n,...r)=>{v.debug&&v.logger.debug(`[FF-SDK] ${n}`,...r)},A=(n,...r)=>{v.logger.error(`[FF-SDK] ${n}`,...r)},H=n=>{let{value:r}=n;try{switch(n.kind.toLowerCase()){case"int":case"number":r=Number(r);break;case"boolean":r=r.toString().toLowerCase()==="true";break;case"json":r=JSON.parse(r);break}}catch(c){A(c)}return r},G=n=>{if(R){let r=Date.now();r-n.lastAccessed>Le&&(n.count++,n.lastAccessed=r)}},ve=()=>h(void 0,null,function*(){if(v.cache){y("initializing cache");try{let n=!0,r=yield fe(e.identifier+i,typeof v.cache=="boolean"?{}:v.cache),c=yield r.loadFromCache();c!=null&&c.length&&q(()=>{y("loading from cache",c),ie(c,!1),u.emit("cache loaded",c)}),K("flags loaded",f=>h(void 0,null,function*(){yield r.saveToCache(f),n=!1})),K("changed",f=>h(void 0,null,function*(){n||(f.deleted?yield r.removeCachedEvaluation(f.flag):yield r.updateCachedEvaluation(f))}))}catch(n){A("Cache error: ",n),u.emit("cache error",n),u.emit("error",n)}}}),pe=(n,r)=>h(void 0,null,function*(){return(yield(yield He(`${r.baseUrl}/client/auth`,{method:"POST",headers:{"Content-Type":"application/json","Harness-SDK-Info":he},body:JSON.stringify({apiKey:n,target:U(w({},e),{identifier:String(e.identifier)})})})).json()).authToken}),$=0,B=()=>{if(C.length){y("Sending metrics...",{metrics:C,evaluations:I});let n={metricsData:C.map(r=>({timestamp:Date.now(),count:r.count,metricsType:"FFMETRICS",attributes:[{key:"featureIdentifier",value:r.featureIdentifier},{key:"featureName",value:r.featureIdentifier},{key:"variationIdentifier",value:r.variationIdentifier},{key:"target",value:e.identifier},{key:"SDK_NAME",value:"JavaScript"},{key:"SDK_LANGUAGE",value:"JavaScript"},{key:"SDK_TYPE",value:"client"},{key:"SDK_VERSION",value:me}]}))};x(`${v.eventUrl}/metrics/${o}?cluster=${s}`,{method:"POST",headers:w({"Content-Type":"application/json"},T),body:JSON.stringify(n)}).then(()=>{C=[],$=0}).catch(r=>{$++&&(C=[],$=0),y(r),u.emit("metrics error",r)}).finally(()=>{d=window.setTimeout(B,v.eventsSyncInterval)})}else d=window.setTimeout(B,v.eventsSyncInterval)},I={},Ee=n=>{y("Sending event for",n.flag),z?u.emit("changed",new Proxy(n,{get(r,c){var f;if(R&&r.hasOwnProperty(c)&&c==="value"){let S=r.flag,l=n.value,b=C.find(P=>P.featureIdentifier===S&&P.featureValue===l);b?(G(b),b.variationIdentifier=((f=I[S])==null?void 0:f.identifier)||""):C.push({featureIdentifier:S,featureValue:String(l),variationIdentifier:I[S].identifier||"",count:1,lastAccessed:Date.now()}),y("Metrics event: Flag",c,"has been read with value via stream update",l)}return c==="value"?H(n):n[c]}})):u.emit("changed",{deleted:n.deleted,flag:n.flag,value:H(n)})},Z=function(){return z?new Proxy({},{get(n,r){var f,S,l;let c=n[r];if(R&&n.hasOwnProperty(r)){let b=n[r],P=C.find(ne=>ne.featureIdentifier===r&&b===ne.featureValue);P?(P.variationIdentifier=((f=I[r])==null?void 0:f.identifier)||"",G(P)):C.push({featureIdentifier:r,featureValue:b,variationIdentifier:((S=I[r])==null?void 0:S.identifier)||"",count:1,lastAccessed:Date.now()}),y("Metrics event: Flag:",r,"has been read with value:",b,"variationIdentifier:",(l=I[r])==null?void 0:l.identifier)}return c}}):{}},O=Z();ve().then(()=>pe(i,v).then(n=>h(void 0,null,function*(){if(a)return;E=n;let r=se(n);T={Authorization:`Bearer ${E}`,"Harness-AccountID":r.accountID,"Harness-EnvironmentID":r.environmentIdentifier,"Harness-SDK-Info":he};let c=de(e);c.length<262144&&(T["Harness-Target"]=c),y("Authenticated",r),d=window.setTimeout(B,v.eventsSyncInterval),o=r.environment,s=r.clusterIdentifier;let f=!!Object.keys(I).length;if((yield k()).type==="success"&&y("Fetch all flags ok",O),!a){if(v.streamEnabled?(y("Streaming mode enabled"),ye()):v.pollingEnabled?(y("Polling mode enabled"),be()):y("Streaming and polling mode disabled"),!f){L();let l=w({},O);m(),u.emit("ready",l)}Q=!0}})).catch(n=>{A("Authentication error: ",n),u.emit("auth error",n),u.emit("error",n)}));let k=()=>h(void 0,null,function*(){try{let n=yield x(`${v.baseUrl}/client/env/${o}/target/${e.identifier}/evaluations?cluster=${s}`,{headers:T});if(n.ok){let r=yield n.json();return r.forEach(D),u.emit("flags loaded",r),{type:"success",data:r}}else return A("Features fetch operation error: ",n),u.emit("fetch flags error",n),u.emit("error",n),{type:"error",error:n}}catch(n){return A("Features fetch operation error: ",n),u.emit("fetch flags error",n),u.emit("error",n),{type:"error",error:n}}}),ee=n=>h(void 0,null,function*(){try{let r=yield x(`${v.baseUrl}/client/env/${o}/target/${e.identifier}/evaluations/${n}?cluster=${s}`,{headers:T});if(r.ok){let c=yield r.json();D(c)}else A("Feature fetch operation error: ",r),u.emit("fetch flag error",r),u.emit("error",r)}catch(r){A("Feature fetch operation error: ",r),u.emit("fetch flag error",r),u.emit("error",r)}}),D=n=>{L();let r=H(n);r!==O[n.flag]&&(y("Flag variation has changed for ",n.identifier),O[n.flag]=r,I[n.flag]=U(w({},n),{value:r}),Ee(n)),m()};p=new F(k,v,u,y,A);let ye=()=>{let n=l=>{switch(l.event){case"create":c(l.evaluations)?l.evaluations.forEach(b=>{D(b)}):setTimeout(()=>ee(l.identifier),1e3);break;case"patch":c(l.evaluations)?l.evaluations.forEach(b=>{D(b)}):ee(l.identifier);break;case"delete":delete O[l.identifier],u.emit("changed",{flag:l.identifier,value:void 0,deleted:!0}),y("Evaluation deleted",{message:l,storage:O});break}},r=l=>!(!l||!l.flag||!l.identifier||!l.kind||!l.value),c=l=>!(!l||l.length==0||!l.every(b=>r(b))),f=l=>{l.event==="patch"&&(c(l.evaluations)?l.evaluations.forEach(b=>{D(b)}):k())},S=`${v.baseUrl}/stream?cluster=${s}`;g=new _(u,v,S,i,T,p,y,A,l=>{l.domain==="flag"?n(l):l.domain==="target-segment"&&f(l)}),g.start()},be=()=>{p.start()},K=(n,r)=>u.on(n,r),Re=(n,r)=>{n?u.off(n,r):te()},Se=(n,r)=>{var l;if(!R||z||r===void 0)return;let c=r,f=n,S=C.find(b=>b.featureIdentifier===f&&b.featureValue===c);S?(G(S),S.variationIdentifier=((l=I[f])==null?void 0:l.identifier)||""):C.push({featureIdentifier:f,featureValue:c,count:1,variationIdentifier:I[f].identifier||"",lastAccessed:Date.now()})},te=()=>{a=!0,v.streamEnabled&&(y("Closing event stream"),typeof(g==null?void 0:g.close)=="function"&&g.close(),u.all.clear()),v.pollingEnabled&&p.isPolling()&&(y("Closing Poller"),p.stop()),O=Z(),I={},clearTimeout(d)},ie=(n,r=!0)=>{n.length&&q(()=>{let c=!!Object.keys(I).length;if(n.forEach(D),!c){L();let f=w({},O);m(),u.emit("ready",f)}},r)};return{on:K,off:Re,close:te,setEvaluations:ie,registerAPIRequestMiddleware:n=>{x=J(n)},refreshEvaluations:()=>{Q&&!a&&Date.now()-X>=6e4&&(k(),X=Date.now())},variation:(n,r,c=!1)=>ue(n,r,O,Se,c)}};export{N as Event,bt as initialize};

dist/sdk.esm.js

@@ -1,1 +0,2 @@
-var pe=Object.defineProperty,Ee=Object.defineProperties;var Re=Object.getOwnPropertyDescriptors;var ie=Object.getOwnPropertySymbols;var be=Object.prototype.hasOwnProperty,ye=Object.prototype.propertyIsEnumerable;var ne=(n,e,a)=>e in n?pe(n,e,{enumerable:!0,configurable:!0,writable:!0,value:a}):n[e]=a,O=(n,e)=>{for(var a in e||(e={}))be.call(e,a)&&ne(n,a,e[a]);if(ie)for(var a of ie(e))ye.call(e,a)&&ne(n,a,e[a]);return n},K=(n,e)=>Ee(n,Re(e));var f=(n,e,a)=>new Promise((r,s)=>{var l=b=>{try{y(a.next(b))}catch(g){s(g)}},h=b=>{try{y(a.throw(b))}catch(g){s(g)}},y=b=>b.done?r(b.value):Promise.resolve(b.value).then(l,h);y((a=a.apply(n,e)).next())});import Ae from"jwt-decode";import Pe from"mitt";var N=(v=>(v.READY="ready",v.CONNECTED="connected",v.DISCONNECTED="disconnected",v.STOPPED="stopped",v.POLLING="polling",v.POLLING_STOPPED="polling stopped",v.FLAGS_LOADED="flags loaded",v.CACHE_LOADED="cache loaded",v.CHANGED="changed",v.ERROR="error",v.ERROR_CACHE="cache error",v.ERROR_METRICS="metrics error",v.ERROR_AUTH="auth error",v.ERROR_FETCH_FLAGS="fetch flags error",v.ERROR_FETCH_FLAG="fetch flag error",v.ERROR_STREAM="stream error",v))(N||{});var Ie={debug:!1,baseUrl:"https://config.ff.harness.io/api/1.0",eventUrl:"https://events.ff.harness.io/api/1.0",eventsSyncInterval:6e4,pollingInterval:6e4,streamEnabled:!0,cache:!1},ae=n=>{let e=O(O({},Ie),n);return e.pollingEnabled===void 0&&(e.pollingEnabled=e.streamEnabled),e.eventsSyncInterval<6e4&&(e.eventsSyncInterval=6e4),e.pollingInterval<6e4&&(e.pollingInterval=6e4),(!e.logger||!e.logger.debug||!e.logger.error||!e.logger.info||!e.logger.warn)&&(e.logger=console),e},j=(n,e=!0)=>{e?setTimeout(n,0):n()},k=(n,e)=>Math.round(Math.random()*(e-n)+n);function U(n){return function(...a){let[r,s]=n(a);return fetch(r,s)}}var re=3e4,V=class{constructor(e,a,r,s,l,h,y,b,g){this.eventBus=e;this.configurations=a;this.url=r;this.apiKey=s;this.standardHeaders=l;this.fallbackPoller=h;this.logDebug=y;this.logError=b;this.eventCallback=g;this.closed=!1;this.connectionOpened=!1;this.disconnectEventEmitted=!1}start(){let e=g=>{g.toString().split(/\r?\n/).forEach(a)},a=g=>{if(g.startsWith("data:")){let S=JSON.parse(g.substring(5));this.logDebugMessage("Received event from stream: ",S),this.eventCallback(S)}},r=()=>{this.logDebugMessage("Stream connected"),this.eventBus.emit("connected")},s=()=>{clearInterval(this.readTimeoutCheckerId);let g=k(1e3,1e4);this.logDebugMessage("Stream disconnected, will reconnect in "+g+"ms"),this.disconnectEventEmitted||(this.eventBus.emit("disconnected"),this.disconnectEventEmitted=!0),setTimeout(()=>this.start(),g)},l=g=>{g&&this.logErrorMessage("Stream has issue",g),this.fallBackToPolling(),this.eventBus.emit("stream error",g),this.eventBus.emit("error",g),s()},h=O({"Cache-Control":"no-cache",Accept:"text/event-stream","API-Key":this.apiKey},this.standardHeaders);this.logDebugMessage("SSE HTTP start request",this.url),this.xhr=new XMLHttpRequest,this.xhr.open("GET",this.url);for(let[g,S]of Object.entries(h))this.xhr.setRequestHeader(g,S);this.xhr.timeout=24*60*60*1e3,this.xhr.onerror=()=>{this.connectionOpened=!1,l("XMLHttpRequest error on SSE stream")},this.xhr.onabort=()=>{this.connectionOpened=!1,this.logDebugMessage("SSE aborted"),this.closed||l(null)},this.xhr.ontimeout=()=>{this.connectionOpened=!1,l("SSE timeout")},this.xhr.onload=()=>{if(this.xhr.status>=400&&this.xhr.status<=599){l(`HTTP code ${this.xhr.status}`);return}this.connectionOpened||(r(),this.connectionOpened=!0,this.disconnectEventEmitted=!1)};let y=0,b=Date.now();this.xhr.onprogress=()=>{this.connectionOpened||(r(),this.connectionOpened=!0,this.disconnectEventEmitted=!1),this.stopFallBackPolling(),b=Date.now();let g=this.xhr.responseText.slice(y);y+=g.length,this.logDebugMessage("SSE GOT: "+g),e(g)},this.readTimeoutCheckerId=setInterval(()=>{b<Date.now()-re&&(this.logErrorMessage("SSE read timeout"),this.xhr.abort())},re),this.xhr.send()}close(){this.connectionOpened=!1,this.closed=!0,this.xhr&&this.xhr.abort(),clearInterval(this.readTimeoutCheckerId),this.eventBus.emit("stopped"),this.stopFallBackPolling()}fallBackToPolling(){!this.fallbackPoller.isPolling()&&this.configurations.pollingEnabled&&(this.logDebugMessage("Falling back to polling mode while stream recovers"),this.fallbackPoller.start())}stopFallBackPolling(){this.fallbackPoller.isPolling()&&(this.logDebugMessage("Stopping fallback polling mode"),this.fallbackPoller.stop())}logDebugMessage(e,...a){this.configurations.debug&&this.logDebug(`Streaming:  ${e}`,...a)}logErrorMessage(e,...a){this.logError(`Streaming:  ${e}`,...a)}};function oe(n,e,a,r,s){let l=n in a,h=l?a[n]:e;return l&&r(n,h),s?{value:h,isDefaultValue:!l}:h}var F=class{constructor(e,a,r,s,l){this.fetchFlagsFn=e;this.configurations=a;this.eventBus=r;this.logDebug=s;this.logError=l;this.maxAttempts=5}start(){if(this.isPolling()){this.logDebugMessage("Already polling.");return}this.isRunning=!0,this.eventBus.emit("polling"),this.logDebugMessage(`Starting poller, first poll will be in ${this.configurations.pollingInterval}ms`),this.timeoutId=setTimeout(()=>this.poll(),this.configurations.pollingInterval)}poll(){this.attemptFetch().finally(()=>{this.timeoutId=setTimeout(()=>this.poll(),this.configurations.pollingInterval)})}attemptFetch(){return f(this,null,function*(){for(let e=1;e<=this.maxAttempts;e++){let a=yield this.fetchFlagsFn();if(a.type==="success"){this.logDebugMessage(`Successfully polled for flag updates, next poll in ${this.configurations.pollingInterval}ms. `);return}if(this.logErrorMessage("Error when polling for flag updates",a.error),e>=this.maxAttempts){this.logDebugMessage(`Maximum attempts reached for polling for flags. Next poll in ${this.configurations.pollingInterval}ms.`);return}this.logDebugMessage(`Polling for flags attempt #${e} failed. Remaining attempts: ${this.maxAttempts-e}`,a.error);let r=k(1e3,1e4);yield new Promise(s=>setTimeout(s,r))}})}stop(){this.timeoutId&&(clearTimeout(this.timeoutId),this.timeoutId=void 0,this.isRunning=!1,this.eventBus.emit("polling stopped"),this.logDebugMessage("Polling stopped"))}isPolling(){return this.isRunning}logDebugMessage(e,...a){this.configurations.debug&&this.logDebug(`Poller: ${e}`,...a)}logErrorMessage(e,...a){this.logError(`Poller: ${e}`,...a)}};function se(a){return f(this,arguments,function*(n,e={}){let r=yield Te(n),s=we(e);return{loadFromCache:()=>q(r,s,e),saveToCache:l=>W(r,s,l),updateCachedEvaluation:l=>Ce(r,s,l),removeCachedEvaluation:l=>Oe(r,s,l)}})}function q(r,s){return f(this,arguments,function*(n,e,a={}){let l=parseInt(yield e.getItem(n+".ts"));if(a!=null&&a.ttl&&!isNaN(l)&&l+a.ttl<Date.now())return yield Se(n,e),[];let h=yield e.getItem(n);if(h)try{return JSON.parse(h)}catch(y){}return[]})}function Se(n,e){return f(this,null,function*(){yield e.removeItem(n),yield e.removeItem(n+".ts")})}function W(n,e,a){return f(this,null,function*(){yield e.setItem(n,JSON.stringify(a)),yield e.setItem(n+".ts",Date.now().toString())})}function Ce(n,e,a){return f(this,null,function*(){let r=yield q(n,e),s=r.find(({flag:l})=>l===a.flag);s?Object.assign(s,a):r.push(a),yield W(n,e,r)})}function Oe(n,e,a){return f(this,null,function*(){let r=yield q(n,e),s=r.findIndex(({flag:l})=>l===a);s>-1&&(r.splice(s,1),yield W(n,e,r))})}function Te(n){return f(this,null,function*(){var a,r;let e=n;if(globalThis!=null&&globalThis.TextEncoder&&((r=(a=globalThis==null?void 0:globalThis.crypto)==null?void 0:a.subtle)!=null&&r.digest)){let l=new TextEncoder().encode(n),h=yield crypto.subtle.digest("SHA-256",l);e=Array.from(new Uint8Array(h)).map(b=>b.toString(16).padStart(2,"0")).join("")}else globalThis.btoa&&(e=btoa(n));return"HARNESS_FF_CACHE_"+e})}function we(n){let e;return!n.storage||typeof n.storage!="object"||!("getItem"in n.storage)||!("setItem"in n.storage)||!("removeItem"in n.storage)?globalThis.localStorage?e=globalThis.localStorage:globalThis.sessionStorage?e=globalThis.sessionStorage:e=De:e=n.storage,{getItem(r){return f(this,null,function*(){let s=e.getItem(r);return s instanceof Promise?yield s:s})},setItem(r,s){return f(this,null,function*(){let l=e.setItem(r,s);l instanceof Promise&&(yield l)})},removeItem(r){return f(this,null,function*(){let s=e.removeItem(r);s instanceof Promise&&(yield s)})}}}var De={getItem:()=>null,setItem:()=>{},removeItem:()=>{}};var ce="1.25.0",le=`Javascript ${ce} Client`,Fe=500,Me=globalThis.fetch,J=!!globalThis.Proxy,dt=(n,e,a)=>{let r=!1,s,l,h,y,b,g,S=!0,D={},M=U(t=>t),Y=0,z=!1,_=()=>{S=!1},v=()=>{S=!0},C=[],d=Pe(),m=ae(a),p=(t,...i)=>{m.debug&&m.logger.debug(`[FF-SDK] ${t}`,...i)},T=(t,...i)=>{m.logger.error(`[FF-SDK] ${t}`,...i)},L=t=>{let{value:i}=t;try{switch(t.kind.toLowerCase()){case"int":case"number":i=Number(i);break;case"boolean":i=i.toString().toLowerCase()==="true";break;case"json":i=JSON.parse(i);break}}catch(c){T(c)}return i},H=t=>{if(S){let i=Date.now();i-t.lastAccessed>Fe&&(t.count++,t.lastAccessed=i)}},ge=()=>f(void 0,null,function*(){if(m.cache){p("initializing cache");try{let t=!0,i=yield se(e.identifier+n,typeof m.cache=="boolean"?{}:m.cache),c=yield i.loadFromCache();c!=null&&c.length&&j(()=>{p("loading from cache",c),ee(c,!1),d.emit("cache loaded",c)}),B("flags loaded",u=>f(void 0,null,function*(){yield i.saveToCache(u),t=!1})),B("changed",u=>f(void 0,null,function*(){t||(u.deleted?yield i.removeCachedEvaluation(u.flag):yield i.updateCachedEvaluation(u))}))}catch(t){T("Cache error: ",t),d.emit("cache error",t),d.emit("error",t)}}}),de=(t,i)=>f(void 0,null,function*(){return(yield(yield Me(`${i.baseUrl}/client/auth`,{method:"POST",headers:{"Content-Type":"application/json","Harness-SDK-Info":le},body:JSON.stringify({apiKey:t,target:K(O({},e),{identifier:String(e.identifier)})})})).json()).authToken}),G=0,$=()=>{if(C.length){p("Sending metrics...",{metrics:C,evaluations:I});let t={metricsData:C.map(i=>({timestamp:Date.now(),count:i.count,metricsType:"FFMETRICS",attributes:[{key:"featureIdentifier",value:i.featureIdentifier},{key:"featureName",value:i.featureIdentifier},{key:"variationIdentifier",value:i.variationIdentifier},{key:"target",value:e.identifier},{key:"SDK_NAME",value:"JavaScript"},{key:"SDK_LANGUAGE",value:"JavaScript"},{key:"SDK_TYPE",value:"client"},{key:"SDK_VERSION",value:ce}]}))};M(`${m.eventUrl}/metrics/${s}?cluster=${l}`,{method:"POST",headers:O({"Content-Type":"application/json"},D),body:JSON.stringify(t)}).then(()=>{C=[],G=0}).catch(i=>{G++&&(C=[],G=0),p(i),d.emit("metrics error",i)}).finally(()=>{g=window.setTimeout($,m.eventsSyncInterval)})}else g=window.setTimeout($,m.eventsSyncInterval)},I={},ue=t=>{p("Sending event for",t.flag),J?d.emit("changed",new Proxy(t,{get(i,c){var u;if(S&&i.hasOwnProperty(c)&&c==="value"){let E=i.flag,o=t.value,R=C.find(P=>P.featureIdentifier===E&&P.featureValue===o);R?(H(R),R.variationIdentifier=((u=I[E])==null?void 0:u.identifier)||""):C.push({featureIdentifier:E,featureValue:String(o),variationIdentifier:I[E].identifier||"",count:1,lastAccessed:Date.now()}),p("Metrics event: Flag",c,"has been read with value via stream update",o)}return c==="value"?L(t):t[c]}})):d.emit("changed",{deleted:t.deleted,flag:t.flag,value:L(t)})},X=function(){return J?new Proxy({},{get(t,i){var u,E,o;let c=t[i];if(S&&t.hasOwnProperty(i)){let R=t[i],P=C.find(te=>te.featureIdentifier===i&&R===te.featureValue);P?(P.variationIdentifier=((u=I[i])==null?void 0:u.identifier)||"",H(P)):C.push({featureIdentifier:i,featureValue:R,variationIdentifier:((E=I[i])==null?void 0:E.identifier)||"",count:1,lastAccessed:Date.now()}),p("Metrics event: Flag:",i,"has been read with value:",R,"variationIdentifier:",(o=I[i])==null?void 0:o.identifier)}return c}}):{}},w=X();ge().then(()=>de(n,m).then(t=>f(void 0,null,function*(){if(r)return;b=t;let i=Ae(t);if(D={Authorization:`Bearer ${b}`,"Harness-AccountID":i.accountID,"Harness-EnvironmentID":i.environmentIdentifier,"Harness-SDK-Info":le},globalThis.btoa){let E=globalThis.btoa(JSON.stringify(e));E.length<262144&&(D["Harness-Target"]=E)}p("Authenticated",i),g=window.setTimeout($,m.eventsSyncInterval),s=i.environment,l=i.clusterIdentifier;let c=!!Object.keys(I).length;if((yield x()).type==="success"&&p("Fetch all flags ok",w),!r){if(m.streamEnabled?(p("Streaming mode enabled"),fe()):m.pollingEnabled?(p("Polling mode enabled"),he()):p("Streaming and polling mode disabled"),!c){_();let E=O({},w);v(),d.emit("ready",E)}z=!0}})).catch(t=>{T("Authentication error: ",t),d.emit("auth error",t),d.emit("error",t)}));let x=()=>f(void 0,null,function*(){try{let t=yield M(`${m.baseUrl}/client/env/${s}/target/${e.identifier}/evaluations?cluster=${l}`,{headers:D});if(t.ok){let i=yield t.json();return i.forEach(A),d.emit("flags loaded",i),{type:"success",data:i}}else return T("Features fetch operation error: ",t),d.emit("fetch flags error",t),d.emit("error",t),{type:"error",error:t}}catch(t){return T("Features fetch operation error: ",t),d.emit("fetch flags error",t),d.emit("error",t),{type:"error",error:t}}}),Q=t=>f(void 0,null,function*(){try{let i=yield M(`${m.baseUrl}/client/env/${s}/target/${e.identifier}/evaluations/${t}?cluster=${l}`,{headers:D});if(i.ok){let c=yield i.json();A(c)}else T("Feature fetch operation error: ",i),d.emit("fetch flag error",i),d.emit("error",i)}catch(i){T("Feature fetch operation error: ",i),d.emit("fetch flag error",i),d.emit("error",i)}}),A=t=>{_();let i=L(t);i!==w[t.flag]&&(p("Flag variation has changed for ",t.identifier),w[t.flag]=i,I[t.flag]=K(O({},t),{value:i}),ue(t)),v()};y=new F(x,m,d,p,T);let fe=()=>{let t=o=>{switch(o.event){case"create":c(o.evaluations)?o.evaluations.forEach(R=>{A(R)}):setTimeout(()=>Q(o.identifier),1e3);break;case"patch":c(o.evaluations)?o.evaluations.forEach(R=>{A(R)}):Q(o.identifier);break;case"delete":delete w[o.identifier],d.emit("changed",{flag:o.identifier,value:void 0,deleted:!0}),p("Evaluation deleted",{message:o,storage:w});break}},i=o=>!(!o||!o.flag||!o.identifier||!o.kind||!o.value),c=o=>!(!o||o.length==0||!o.every(R=>i(R))),u=o=>{o.event==="patch"&&(c(o.evaluations)?o.evaluations.forEach(R=>{A(R)}):x())},E=`${m.baseUrl}/stream?cluster=${l}`;h=new V(d,m,E,n,D,y,p,T,o=>{o.domain==="flag"?t(o):o.domain==="target-segment"&&u(o)}),h.start()},he=()=>{y.start()},B=(t,i)=>d.on(t,i),ve=(t,i)=>{t?d.off(t,i):Z()},me=(t,i)=>{var o;if(!S||J||i===void 0)return;let c=i,u=t,E=C.find(R=>R.featureIdentifier===u&&R.featureValue===c);E?(H(E),E.variationIdentifier=((o=I[u])==null?void 0:o.identifier)||""):C.push({featureIdentifier:u,featureValue:c,count:1,variationIdentifier:I[u].identifier||"",lastAccessed:Date.now()})},Z=()=>{r=!0,m.streamEnabled&&(p("Closing event stream"),typeof(h==null?void 0:h.close)=="function"&&h.close(),d.all.clear()),m.pollingEnabled&&y.isPolling()&&(p("Closing Poller"),y.stop()),w=X(),I={},clearTimeout(g)},ee=(t,i=!0)=>{t.length&&j(()=>{let c=!!Object.keys(I).length;if(t.forEach(A),!c){_();let u=O({},w);v(),d.emit("ready",u)}},i)};return{on:B,off:ve,close:Z,setEvaluations:ee,registerAPIRequestMiddleware:t=>{M=U(t)},refreshEvaluations:()=>{z&&!r&&Date.now()-Y>=6e4&&(x(),Y=Date.now())},variation:(t,i,c=!1)=>oe(t,i,w,me,c)}};export{N as Event,dt as initialize};
+var Ee=Object.defineProperty,Re=Object.defineProperties;var ye=Object.getOwnPropertyDescriptors;var ie=Object.getOwnPropertySymbols;var be=Object.prototype.hasOwnProperty,Se=Object.prototype.propertyIsEnumerable;var ne=(a,e,n)=>e in a?Ee(a,e,{enumerable:!0,configurable:!0,writable:!0,value:n}):a[e]=n,T=(a,e)=>{for(var n in e||(e={}))be.call(e,n)&&ne(a,n,e[n]);if(ie)for(var n of ie(e))Se.call(e,n)&&ne(a,n,e[n]);return a},K=(a,e)=>Re(a,ye(e));var h=(a,e,n)=>new Promise((r,o)=>{var l=E=>{try{p(n.next(E))}catch(g){o(g)}},u=E=>{try{p(n.throw(E))}catch(g){o(g)}},p=E=>E.done?r(E.value):Promise.resolve(E.value).then(l,u);p((n=n.apply(a,e)).next())});import Fe from"jwt-decode";import Me from"mitt";var x=(m=>(m.READY="ready",m.CONNECTED="connected",m.DISCONNECTED="disconnected",m.STOPPED="stopped",m.POLLING="polling",m.POLLING_STOPPED="polling stopped",m.FLAGS_LOADED="flags loaded",m.CACHE_LOADED="cache loaded",m.CHANGED="changed",m.ERROR="error",m.ERROR_CACHE="cache error",m.ERROR_METRICS="metrics error",m.ERROR_AUTH="auth error",m.ERROR_FETCH_FLAGS="fetch flags error",m.ERROR_FETCH_FLAG="fetch flag error",m.ERROR_STREAM="stream error",m))(x||{});var Ie={debug:!1,baseUrl:"https://config.ff.harness.io/api/1.0",eventUrl:"https://events.ff.harness.io/api/1.0",eventsSyncInterval:6e4,pollingInterval:6e4,streamEnabled:!0,cache:!1},ae=a=>{let e=T(T({},Ie),a);return e.pollingEnabled===void 0&&(e.pollingEnabled=e.streamEnabled),e.eventsSyncInterval<6e4&&(e.eventsSyncInterval=6e4),e.pollingInterval<6e4&&(e.pollingInterval=6e4),(!e.logger||!e.logger.debug||!e.logger.error||!e.logger.info||!e.logger.warn)&&(e.logger=console),e},j=(a,e=!0)=>{e?setTimeout(a,0):a()},k=(a,e)=>Math.round(Math.random()*(e-a)+a),re=a=>{let e="ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=",n="",r=0,o=Ce(JSON.stringify(a));for(;r<o.length;){let l=o.charCodeAt(r++),u=o.charCodeAt(r++),p=o.charCodeAt(r++),E=l>>2,g=(l&3)<<4|u>>4,b=(u&15)<<2|p>>6,A=p&63;isNaN(u)?b=A=64:isNaN(p)&&(A=64),n+=e.charAt(E)+e.charAt(g)+e.charAt(b)+e.charAt(A)}return n},Ce=a=>a.replace(/\r\n/g,`
+`).split("").map(e=>{let n=e.charCodeAt(0);return n<128?String.fromCharCode(n):n>127&&n<2048?String.fromCharCode(n>>6|192)+String.fromCharCode(n&63|128):String.fromCharCode(n>>12|224)+String.fromCharCode(n>>6&63|128)+String.fromCharCode(n&63|128)}).join("");function U(a){return function(...n){let[r,o]=a(n);return fetch(r,o)}}var oe=3e4,V=class{constructor(e,n,r,o,l,u,p,E,g){this.eventBus=e;this.configurations=n;this.url=r;this.apiKey=o;this.standardHeaders=l;this.fallbackPoller=u;this.logDebug=p;this.logError=E;this.eventCallback=g;this.closed=!1;this.connectionOpened=!1;this.disconnectEventEmitted=!1}start(){let e=g=>{g.toString().split(/\r?\n/).forEach(n)},n=g=>{if(g.startsWith("data:")){let b=JSON.parse(g.substring(5));this.logDebugMessage("Received event from stream: ",b),this.eventCallback(b)}},r=()=>{this.logDebugMessage("Stream connected"),this.eventBus.emit("connected")},o=()=>{clearInterval(this.readTimeoutCheckerId);let g=k(1e3,1e4);this.logDebugMessage("Stream disconnected, will reconnect in "+g+"ms"),this.disconnectEventEmitted||(this.eventBus.emit("disconnected"),this.disconnectEventEmitted=!0),setTimeout(()=>this.start(),g)},l=g=>{g&&this.logErrorMessage("Stream has issue",g),this.fallBackToPolling(),this.eventBus.emit("stream error",g),this.eventBus.emit("error",g),o()},u=T({"Cache-Control":"no-cache",Accept:"text/event-stream","API-Key":this.apiKey},this.standardHeaders);this.logDebugMessage("SSE HTTP start request",this.url),this.xhr=new XMLHttpRequest,this.xhr.open("GET",this.url);for(let[g,b]of Object.entries(u))this.xhr.setRequestHeader(g,b);this.xhr.timeout=24*60*60*1e3,this.xhr.onerror=()=>{this.connectionOpened=!1,l("XMLHttpRequest error on SSE stream")},this.xhr.onabort=()=>{this.connectionOpened=!1,this.logDebugMessage("SSE aborted"),this.closed||l(null)},this.xhr.ontimeout=()=>{this.connectionOpened=!1,l("SSE timeout")},this.xhr.onload=()=>{if(this.xhr.status>=400&&this.xhr.status<=599){l(`HTTP code ${this.xhr.status}`);return}this.connectionOpened||(r(),this.connectionOpened=!0,this.disconnectEventEmitted=!1)};let p=0,E=Date.now();this.xhr.onprogress=()=>{this.connectionOpened||(r(),this.connectionOpened=!0,this.disconnectEventEmitted=!1),this.stopFallBackPolling(),E=Date.now();let g=this.xhr.responseText.slice(p);p+=g.length,this.logDebugMessage("SSE GOT: "+g),e(g)},this.readTimeoutCheckerId=setInterval(()=>{E<Date.now()-oe&&(this.logErrorMessage("SSE read timeout"),this.xhr.abort())},oe),this.xhr.send()}close(){this.connectionOpened=!1,this.closed=!0,this.xhr&&this.xhr.abort(),clearInterval(this.readTimeoutCheckerId),this.eventBus.emit("stopped"),this.stopFallBackPolling()}fallBackToPolling(){!this.fallbackPoller.isPolling()&&this.configurations.pollingEnabled&&(this.logDebugMessage("Falling back to polling mode while stream recovers"),this.fallbackPoller.start())}stopFallBackPolling(){this.fallbackPoller.isPolling()&&(this.logDebugMessage("Stopping fallback polling mode"),this.fallbackPoller.stop())}logDebugMessage(e,...n){this.configurations.debug&&this.logDebug(`Streaming:  ${e}`,...n)}logErrorMessage(e,...n){this.logError(`Streaming:  ${e}`,...n)}};function se(a,e,n,r,o){let l=a in n,u=l?n[a]:e;return l&&r(a,u),o?{value:u,isDefaultValue:!l}:u}var F=class{constructor(e,n,r,o,l){this.fetchFlagsFn=e;this.configurations=n;this.eventBus=r;this.logDebug=o;this.logError=l;this.maxAttempts=5}start(){if(this.isPolling()){this.logDebugMessage("Already polling.");return}this.isRunning=!0,this.eventBus.emit("polling"),this.logDebugMessage(`Starting poller, first poll will be in ${this.configurations.pollingInterval}ms`),this.timeoutId=setTimeout(()=>this.poll(),this.configurations.pollingInterval)}poll(){this.attemptFetch().finally(()=>{this.timeoutId=setTimeout(()=>this.poll(),this.configurations.pollingInterval)})}attemptFetch(){return h(this,null,function*(){for(let e=1;e<=this.maxAttempts;e++){let n=yield this.fetchFlagsFn();if(n.type==="success"){this.logDebugMessage(`Successfully polled for flag updates, next poll in ${this.configurations.pollingInterval}ms. `);return}if(this.logErrorMessage("Error when polling for flag updates",n.error),e>=this.maxAttempts){this.logDebugMessage(`Maximum attempts reached for polling for flags. Next poll in ${this.configurations.pollingInterval}ms.`);return}this.logDebugMessage(`Polling for flags attempt #${e} failed. Remaining attempts: ${this.maxAttempts-e}`,n.error);let r=k(1e3,1e4);yield new Promise(o=>setTimeout(o,r))}})}stop(){this.timeoutId&&(clearTimeout(this.timeoutId),this.timeoutId=void 0,this.isRunning=!1,this.eventBus.emit("polling stopped"),this.logDebugMessage("Polling stopped"))}isPolling(){return this.isRunning}logDebugMessage(e,...n){this.configurations.debug&&this.logDebug(`Poller: ${e}`,...n)}logErrorMessage(e,...n){this.logError(`Poller: ${e}`,...n)}};function le(n){return h(this,arguments,function*(a,e={}){let r=yield we(a),o=De(e);return{loadFromCache:()=>q(r,o,e),saveToCache:l=>W(r,o,l),updateCachedEvaluation:l=>Ae(r,o,l),removeCachedEvaluation:l=>Oe(r,o,l)}})}function q(r,o){return h(this,arguments,function*(a,e,n={}){let l=parseInt(yield e.getItem(a+".ts"));if(n!=null&&n.ttl&&!isNaN(l)&&l+n.ttl<Date.now())return yield Te(a,e),[];let u=yield e.getItem(a);if(u)try{return JSON.parse(u)}catch(p){}return[]})}function Te(a,e){return h(this,null,function*(){yield e.removeItem(a),yield e.removeItem(a+".ts")})}function W(a,e,n){return h(this,null,function*(){yield e.setItem(a,JSON.stringify(n)),yield e.setItem(a+".ts",Date.now().toString())})}function Ae(a,e,n){return h(this,null,function*(){let r=yield q(a,e),o=r.find(({flag:l})=>l===n.flag);o?Object.assign(o,n):r.push(n),yield W(a,e,r)})}function Oe(a,e,n){return h(this,null,function*(){let r=yield q(a,e),o=r.findIndex(({flag:l})=>l===n);o>-1&&(r.splice(o,1),yield W(a,e,r))})}function we(a){return h(this,null,function*(){var n,r;let e=a;if(globalThis!=null&&globalThis.TextEncoder&&((r=(n=globalThis==null?void 0:globalThis.crypto)==null?void 0:n.subtle)!=null&&r.digest)){let l=new TextEncoder().encode(a),u=yield crypto.subtle.digest("SHA-256",l);e=Array.from(new Uint8Array(u)).map(E=>E.toString(16).padStart(2,"0")).join("")}else globalThis.btoa&&(e=btoa(a));return"HARNESS_FF_CACHE_"+e})}function De(a){let e;return!a.storage||typeof a.storage!="object"||!("getItem"in a.storage)||!("setItem"in a.storage)||!("removeItem"in a.storage)?globalThis.localStorage?e=globalThis.localStorage:globalThis.sessionStorage?e=globalThis.sessionStorage:e=Pe:e=a.storage,{getItem(r){return h(this,null,function*(){let o=e.getItem(r);return o instanceof Promise?yield o:o})},setItem(r,o){return h(this,null,function*(){let l=e.setItem(r,o);l instanceof Promise&&(yield l)})},removeItem(r){return h(this,null,function*(){let o=e.removeItem(r);o instanceof Promise&&(yield o)})}}}var Pe={getItem:()=>null,setItem:()=>{},removeItem:()=>{}};var ge="1.26.1",ce=`Javascript ${ge} Client`,Ne=500,xe=globalThis.fetch,J=!!globalThis.Proxy,ft=(a,e,n)=>{let r=!1,o,l,u,p,E,g,b=!0,A={},M=U(t=>t),Y=0,z=!1,_=()=>{b=!1},m=()=>{b=!0},C=[],d=Me(),v=ae(n),R=(t,...i)=>{v.debug&&v.logger.debug(`[FF-SDK] ${t}`,...i)},O=(t,...i)=>{v.logger.error(`[FF-SDK] ${t}`,...i)},L=t=>{let{value:i}=t;try{switch(t.kind.toLowerCase()){case"int":case"number":i=Number(i);break;case"boolean":i=i.toString().toLowerCase()==="true";break;case"json":i=JSON.parse(i);break}}catch(c){O(c)}return i},H=t=>{if(b){let i=Date.now();i-t.lastAccessed>Ne&&(t.count++,t.lastAccessed=i)}},de=()=>h(void 0,null,function*(){if(v.cache){R("initializing cache");try{let t=!0,i=yield le(e.identifier+a,typeof v.cache=="boolean"?{}:v.cache),c=yield i.loadFromCache();c!=null&&c.length&&j(()=>{R("loading from cache",c),ee(c,!1),d.emit("cache loaded",c)}),B("flags loaded",f=>h(void 0,null,function*(){yield i.saveToCache(f),t=!1})),B("changed",f=>h(void 0,null,function*(){t||(f.deleted?yield i.removeCachedEvaluation(f.flag):yield i.updateCachedEvaluation(f))}))}catch(t){O("Cache error: ",t),d.emit("cache error",t),d.emit("error",t)}}}),ue=(t,i)=>h(void 0,null,function*(){return(yield(yield xe(`${i.baseUrl}/client/auth`,{method:"POST",headers:{"Content-Type":"application/json","Harness-SDK-Info":ce},body:JSON.stringify({apiKey:t,target:K(T({},e),{identifier:String(e.identifier)})})})).json()).authToken}),G=0,$=()=>{if(C.length){R("Sending metrics...",{metrics:C,evaluations:I});let t={metricsData:C.map(i=>({timestamp:Date.now(),count:i.count,metricsType:"FFMETRICS",attributes:[{key:"featureIdentifier",value:i.featureIdentifier},{key:"featureName",value:i.featureIdentifier},{key:"variationIdentifier",value:i.variationIdentifier},{key:"target",value:e.identifier},{key:"SDK_NAME",value:"JavaScript"},{key:"SDK_LANGUAGE",value:"JavaScript"},{key:"SDK_TYPE",value:"client"},{key:"SDK_VERSION",value:ge}]}))};M(`${v.eventUrl}/metrics/${o}?cluster=${l}`,{method:"POST",headers:T({"Content-Type":"application/json"},A),body:JSON.stringify(t)}).then(()=>{C=[],G=0}).catch(i=>{G++&&(C=[],G=0),R(i),d.emit("metrics error",i)}).finally(()=>{g=window.setTimeout($,v.eventsSyncInterval)})}else g=window.setTimeout($,v.eventsSyncInterval)},I={},fe=t=>{R("Sending event for",t.flag),J?d.emit("changed",new Proxy(t,{get(i,c){var f;if(b&&i.hasOwnProperty(c)&&c==="value"){let S=i.flag,s=t.value,y=C.find(P=>P.featureIdentifier===S&&P.featureValue===s);y?(H(y),y.variationIdentifier=((f=I[S])==null?void 0:f.identifier)||""):C.push({featureIdentifier:S,featureValue:String(s),variationIdentifier:I[S].identifier||"",count:1,lastAccessed:Date.now()}),R("Metrics event: Flag",c,"has been read with value via stream update",s)}return c==="value"?L(t):t[c]}})):d.emit("changed",{deleted:t.deleted,flag:t.flag,value:L(t)})},X=function(){return J?new Proxy({},{get(t,i){var f,S,s;let c=t[i];if(b&&t.hasOwnProperty(i)){let y=t[i],P=C.find(te=>te.featureIdentifier===i&&y===te.featureValue);P?(P.variationIdentifier=((f=I[i])==null?void 0:f.identifier)||"",H(P)):C.push({featureIdentifier:i,featureValue:y,variationIdentifier:((S=I[i])==null?void 0:S.identifier)||"",count:1,lastAccessed:Date.now()}),R("Metrics event: Flag:",i,"has been read with value:",y,"variationIdentifier:",(s=I[i])==null?void 0:s.identifier)}return c}}):{}},w=X();de().then(()=>ue(a,v).then(t=>h(void 0,null,function*(){if(r)return;E=t;let i=Fe(t);A={Authorization:`Bearer ${E}`,"Harness-AccountID":i.accountID,"Harness-EnvironmentID":i.environmentIdentifier,"Harness-SDK-Info":ce};let c=re(e);c.length<262144&&(A["Harness-Target"]=c),R("Authenticated",i),g=window.setTimeout($,v.eventsSyncInterval),o=i.environment,l=i.clusterIdentifier;let f=!!Object.keys(I).length;if((yield N()).type==="success"&&R("Fetch all flags ok",w),!r){if(v.streamEnabled?(R("Streaming mode enabled"),he()):v.pollingEnabled?(R("Polling mode enabled"),me()):R("Streaming and polling mode disabled"),!f){_();let s=T({},w);m(),d.emit("ready",s)}z=!0}})).catch(t=>{O("Authentication error: ",t),d.emit("auth error",t),d.emit("error",t)}));let N=()=>h(void 0,null,function*(){try{let t=yield M(`${v.baseUrl}/client/env/${o}/target/${e.identifier}/evaluations?cluster=${l}`,{headers:A});if(t.ok){let i=yield t.json();return i.forEach(D),d.emit("flags loaded",i),{type:"success",data:i}}else return O("Features fetch operation error: ",t),d.emit("fetch flags error",t),d.emit("error",t),{type:"error",error:t}}catch(t){return O("Features fetch operation error: ",t),d.emit("fetch flags error",t),d.emit("error",t),{type:"error",error:t}}}),Q=t=>h(void 0,null,function*(){try{let i=yield M(`${v.baseUrl}/client/env/${o}/target/${e.identifier}/evaluations/${t}?cluster=${l}`,{headers:A});if(i.ok){let c=yield i.json();D(c)}else O("Feature fetch operation error: ",i),d.emit("fetch flag error",i),d.emit("error",i)}catch(i){O("Feature fetch operation error: ",i),d.emit("fetch flag error",i),d.emit("error",i)}}),D=t=>{_();let i=L(t);i!==w[t.flag]&&(R("Flag variation has changed for ",t.identifier),w[t.flag]=i,I[t.flag]=K(T({},t),{value:i}),fe(t)),m()};p=new F(N,v,d,R,O);let he=()=>{let t=s=>{switch(s.event){case"create":c(s.evaluations)?s.evaluations.forEach(y=>{D(y)}):setTimeout(()=>Q(s.identifier),1e3);break;case"patch":c(s.evaluations)?s.evaluations.forEach(y=>{D(y)}):Q(s.identifier);break;case"delete":delete w[s.identifier],d.emit("changed",{flag:s.identifier,value:void 0,deleted:!0}),R("Evaluation deleted",{message:s,storage:w});break}},i=s=>!(!s||!s.flag||!s.identifier||!s.kind||!s.value),c=s=>!(!s||s.length==0||!s.every(y=>i(y))),f=s=>{s.event==="patch"&&(c(s.evaluations)?s.evaluations.forEach(y=>{D(y)}):N())},S=`${v.baseUrl}/stream?cluster=${l}`;u=new V(d,v,S,a,A,p,R,O,s=>{s.domain==="flag"?t(s):s.domain==="target-segment"&&f(s)}),u.start()},me=()=>{p.start()},B=(t,i)=>d.on(t,i),ve=(t,i)=>{t?d.off(t,i):Z()},pe=(t,i)=>{var s;if(!b||J||i===void 0)return;let c=i,f=t,S=C.find(y=>y.featureIdentifier===f&&y.featureValue===c);S?(H(S),S.variationIdentifier=((s=I[f])==null?void 0:s.identifier)||""):C.push({featureIdentifier:f,featureValue:c,count:1,variationIdentifier:I[f].identifier||"",lastAccessed:Date.now()})},Z=()=>{r=!0,v.streamEnabled&&(R("Closing event stream"),typeof(u==null?void 0:u.close)=="function"&&u.close(),d.all.clear()),v.pollingEnabled&&p.isPolling()&&(R("Closing Poller"),p.stop()),w=X(),I={},clearTimeout(g)},ee=(t,i=!0)=>{t.length&&j(()=>{let c=!!Object.keys(I).length;if(t.forEach(D),!c){_();let f=T({},w);m(),d.emit("ready",f)}},i)};return{on:B,off:ve,close:Z,setEvaluations:ee,registerAPIRequestMiddleware:t=>{M=U(t)},refreshEvaluations:()=>{z&&!r&&Date.now()-Y>=6e4&&(N(),Y=Date.now())},variation:(t,i,c=!1)=>se(t,i,w,pe,c)}};export{x as Event,ft as initialize};

dist/utils.d.ts

@@ -1,2 +0,2 @@
-import type { Options } from './types';
+import type { Options, Target } from './types';
 export declare const MIN_EVENTS_SYNC_INTERVAL = 60000;
@@ -8,1 +8,2 @@ export declare const MIN_POLLING_INTERVAL = 60000;
 export declare const getRandom: (min: number, max: number) => number;
+export declare const encodeTarget: (target: Target) => string;

package.json

 {
   "name": "@harnessio/ff-javascript-client-sdk",
-  "version": "1.26.0",
+  "version": "1.26.1",
   "author": "Harness",
@@ -5,0 +5,0 @@ "license": "Apache-2.0",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

100658

increased by2.4%

Lines of code

501

increased by2.24%

Worsened metrics

Number of medium supply chain risk alerts

5

increased by25%

No dependency changes