16 lines
33 KiB
JavaScript
16 lines
33 KiB
JavaScript
|
(function (global, factory) {
|
||
|
|
typeof exports === 'object' && typeof module !== 'undefined' ? factory(exports) :
|
||
|
|
typeof define === 'function' && define.amd ? define(['exports'], factory) :
|
||
|
|
(global = typeof globalThis !== 'undefined' ? globalThis : global || self, factory(global["@algolia/ingestion"] = {}));
|
||
|
|
})(this, (function (exports) { 'use strict';
|
||
|
|
|
||
|
|
function B(a){let o,m=`algolia-client-js-${a.key}`;function c(){return o===void 0&&(o=a.localStorage||window.localStorage),o}function P(){return JSON.parse(c().getItem(m)||"{}")}function g(i){c().setItem(m,JSON.stringify(i));}function R(){let i=a.timeToLive?a.timeToLive*1e3:null,e=P(),r=Object.fromEntries(Object.entries(e).filter(([,n])=>n.timestamp!==void 0));if(g(r),!i)return;let t=Object.fromEntries(Object.entries(r).filter(([,n])=>{let u=new Date().getTime();return !(n.timestamp+i<u)}));g(t);}return {get(i,e,r={miss:()=>Promise.resolve()}){return Promise.resolve().then(()=>(R(),P()[JSON.stringify(i)])).then(t=>Promise.all([t?t.value:e(),t!==void 0])).then(([t,n])=>Promise.all([t,n||r.miss(t)])).then(([t])=>t)},set(i,e){return Promise.resolve().then(()=>{let r=P();return r[JSON.stringify(i)]={timestamp:new Date().getTime(),value:e},c().setItem(m,JSON.stringify(r)),e})},delete(i){return Promise.resolve().then(()=>{let e=P();delete e[JSON.stringify(i)],c().setItem(m,JSON.stringify(e));})},clear(){return Promise.resolve().then(()=>{c().removeItem(m);})}}}function se(){return {get(a,o,m={miss:()=>Promise.resolve()}){return o().then(P=>Promise.all([P,m.miss(P)])).then(([P])=>P)},set(a,o){return Promise.resolve(o)},delete(a){return Promise.resolve()},clear(){return Promise.resolve()}}}function x(a){let o=[...a.caches],m=o.shift();return m===void 0?se():{get(c,P,g={miss:()=>Promise.resolve()}){return m.get(c,P,g).catch(()=>x({caches:o}).get(c,P,g))},set(c,P){return m.set(c,P).catch(()=>x({caches:o}).set(c,P))},delete(c){return m.delete(c).catch(()=>x({caches:o}).delete(c))},clear(){return m.clear().catch(()=>x({caches:o}).clear())}}}function C(a={serializable:true}){let o={};return {get(m,c,P={miss:()=>Promise.resolve()}){let g=JSON.stringify(m);if(g in o)return Promise.resolve(a.serializable?JSON.parse(o[g]):o[g]);let R=c();return R.then(i=>P.miss(i)).then(()=>R)},set(m,c){return o[JSON.stringify(m)]=a.serializable?JSON.stringify(c):c,Promise.resolve(c)},delete(m){return delete o[JSON.stringify(m)],Promise.resolve()},clear(){return o={},Promise.resolve()}}}function oe(a){let o={value:`Algolia for JavaScript (${a})`,add(m){let c=`; ${m.segment}${m.version!==void 0?` (${m.version})`:""}`;return o.value.indexOf(c)===-1&&(o.value=`${o.value}${c}`),o}};return o}function J(a,o,m="WithinHeaders"){let c={"x-algolia-api-key":o,"x-algolia-application-id":a};return {headers(){return m==="WithinHeaders"?c:{}},queryParameters(){return m==="WithinQueryParameters"?c:{}}}}function z({func:a,validate:o,aggregator:m,error:c,timeout:P=()=>0}){let g=R=>new Promise((i,e)=>{a(R).then(async r=>(m&&await m(r),await o(r)?i(r):c&&await c.validate(r)?e(new Error(await c.message(r))):setTimeout(()=>{g(r).then(i).catch(e);},await P()))).catch(r=>{e(r);});});return g()}function M({algoliaAgents:a,client:o,version:m}){let c=oe(m).add({segment:o,version:m});return a.forEach(P=>c.add(P)),c}function F(){return {debug(a,o){return Promise.resolve()},info(a,o){return Promise.resolve()},error(a,o){return Promise.resolve()}}}var ae=750,$=120*1e3;function j(a,o="up"){let m=Date.now();function c(){return o==="up"||Date.now()-m>$}function P(){return o==="timed out"&&Date.now()-m<=$}return {...a,status:o,lastUpdate:m,isUp:c,isTimedOut:P}}var X=class extends Error{name="AlgoliaError";constructor(a,o){super(a),o&&(this.name=o);}};var K=class extends X{stackTrace;constructor(a,o,m){super(a,m),this.stackTrace=o;}},ne=class extends K{constructor(a){super("Unreachable hosts - your application id may be incorrect. If the error persists, please visit our help center https://alg.li/support-unreachable-hosts or reach out to the Algolia Support team: https://alg.li/support",a,"RetryError");}},Q=class extends K{status;constructor(a,o,m,c="ApiError"){super(a,m,c),this.status=o;}},ie=class extends X{response;constructor(a,o){super(a,"DeserializationError"),this.response=o;}},ue=class extends Q{error;constructor(a,o,m,c){super(a,o,c,"DetailedApiError"),this.error=m;}};function ce(a,o,m){let c=me(m),P=`${a.protocol}://${a.url}${a.port?`:${a.port}`:""}/${o.charAt(0)==="/"?o.substr
|
||
|
|
|
||
|
|
exports.apiClientVersion = v;
|
||
|
|
exports.ingestionClient = Is;
|
||
|
|
exports.isOnDemandTrigger = Te;
|
||
|
|
exports.isScheduleTrigger = ye;
|
||
|
|
exports.isSubscriptionTrigger = Re;
|
||
|
|
|
||
|
|
}));
|