@algolia/ingestion - npm Package Compare versions

Comparing version 1.7.0 to 1.8.0

dist/builds/browser.min.js

@@ -1,2 +0,2 @@
-function _(a){let o,d=`algolia-client-js-${a.key}`;function m(){return o===void 0&&(o=a.localStorage||window.localStorage),o}function h(){return JSON.parse(m().getItem(d)||"{}")}function T(n){m().setItem(d,JSON.stringify(n))}function w(){let n=a.timeToLive?a.timeToLive*1e3:null,e=h(),r=Object.fromEntries(Object.entries(e).filter(([,i])=>i.timestamp!==void 0));if(T(r),!n)return;let s=Object.fromEntries(Object.entries(r).filter(([,i])=>{let u=new Date().getTime();return!(i.timestamp+n<u)}));T(s)}return{get(n,e,r={miss:()=>Promise.resolve()}){return Promise.resolve().then(()=>(w(),h()[JSON.stringify(n)])).then(s=>Promise.all([s?s.value:e(),s!==void 0])).then(([s,i])=>Promise.all([s,i||r.miss(s)])).then(([s])=>s)},set(n,e){return Promise.resolve().then(()=>{let r=h();return r[JSON.stringify(n)]={timestamp:new Date().getTime(),value:e},m().setItem(d,JSON.stringify(r)),e})},delete(n){return Promise.resolve().then(()=>{let e=h();delete e[JSON.stringify(n)],m().setItem(d,JSON.stringify(e))})},clear(){return Promise.resolve().then(()=>{m().removeItem(d)})}}}function ee(){return{get(a,o,d={miss:()=>Promise.resolve()}){return o().then(h=>Promise.all([h,d.miss(h)])).then(([h])=>h)},set(a,o){return Promise.resolve(o)},delete(a){return Promise.resolve()},clear(){return Promise.resolve()}}}function S(a){let o=[...a.caches],d=o.shift();return d===void 0?ee():{get(m,h,T={miss:()=>Promise.resolve()}){return d.get(m,h,T).catch(()=>S({caches:o}).get(m,h,T))},set(m,h){return d.set(m,h).catch(()=>S({caches:o}).set(m,h))},delete(m){return d.delete(m).catch(()=>S({caches:o}).delete(m))},clear(){return d.clear().catch(()=>S({caches:o}).clear())}}}function k(a={serializable:!0}){let o={};return{get(d,m,h={miss:()=>Promise.resolve()}){let T=JSON.stringify(d);if(T in o)return Promise.resolve(a.serializable?JSON.parse(o[T]):o[T]);let w=m();return w.then(n=>h.miss(n)).then(()=>w)},set(d,m){return o[JSON.stringify(d)]=a.serializable?JSON.stringify(m):m,Promise.resolve(m)},delete(d){return delete o[JSON.stringify(d)],Promise.resolve()},clear(){return o={},Promise.resolve()}}}var N=1e3,W=2e3,B=3e4;function re(a){let o={value:`Algolia for JavaScript (${a})`,add(d){let m=`; ${d.segment}${d.version!==void 0?` (${d.version})`:""}`;return o.value.indexOf(m)===-1&&(o.value=`${o.value}${m}`),o}};return o}function $(a,o,d="WithinHeaders"){let m={"x-algolia-api-key":o,"x-algolia-application-id":a};return{headers(){return d==="WithinHeaders"?m:{}},queryParameters(){return d==="WithinQueryParameters"?m:{}}}}function j({algoliaAgents:a,client:o,version:d}){let m=re(d).add({segment:o,version:d});return a.forEach(h=>m.add(h)),m}function J(){return{debug(a,o){return Promise.resolve()},info(a,o){return Promise.resolve()},error(a,o){return Promise.resolve()}}}var V=2*60*1e3;function G(a,o="up"){let d=Date.now();function m(){return o==="up"||Date.now()-d>V}function h(){return o==="timed out"&&Date.now()-d<=V}return{...a,status:o,lastUpdate:d,isUp:m,isTimedOut:h}}var M=class extends Error{name="AlgoliaError";constructor(a,o){super(a),o&&(this.name=o)}},z=class extends M{stackTrace;constructor(a,o,d){super(a,d),this.stackTrace=o}},te=class extends z{constructor(a){super("Unreachable hosts - your application id may be incorrect. If the error persists, please reach out to the Algolia Support team: https://alg.li/support.",a,"RetryError")}},U=class extends z{status;constructor(a,o,d,m="ApiError"){super(a,d,m),this.status=o}},se=class extends M{response;constructor(a,o){super(a,"DeserializationError"),this.response=o}},oe=class extends U{error;constructor(a,o,d,m){super(a,o,m,"DetailedApiError"),this.error=d}};function ae(a,o,d){let m=ne(d),h=`${a.protocol}://${a.url}${a.port?`:${a.port}`:""}/${o.charAt(0)==="/"?o.substring(1):o}`;return m.length&&(h+=`?${m}`),h}function ne(a){return Object.keys(a).filter(o=>a[o]!==void 0).sort().map(o=>`${o}=${encodeURIComponent(Object.prototype.toString.call(a[o])==="[object Array]"?a[o].join(","):a[o]).replaceAll("+","%20")}`).join("&")}function ie(a,o){if(a.method==="GET"||a.data===void 0&&o.data===void 0)return;let d=Array.isArray(a.data)?a.data:{...a.data,...o.data};return JSON.stringify(d)}function ue(a,o,d){let m={Accept:"application/json",...a,...o,...d},h={};return Object.keys(m).forEach(T=>{let w=m[T];h[T.toLowerCase()]=w}),h}function me(a){try{return JSON.parse(a.content)}catch(o){throw new se(o.message,a)}}function ce({content:a,status:o},d){try{let m=JSON.parse(a);return"error"in m?new oe(m.message,o,m.error,d):new U(m.message,o,d)}catch{}return new U(a,o,d)}function de({isTimedOut:a,status:o}){return!a&&~~o===0}function pe({isTimedOut:a,status:o}){return a||de({isTimedOut:a,status:o})||~~(o/100)!==2&&~~(o/100)!==4}function he({status:a}){return~~(a/100)===2}function fe(a){return a.map(o=>F(o))}function F(a){let o=a.request.headers["x-algolia-api-key"]?{"x-algolia-api-key":"*****"}:{};return{...a,request:{...a.request,headers:{...a.request.headers,...o}}}}function X({hosts:a,hostsCache:o,baseHeaders:d,logger:m,baseQueryParameters:h,algoliaAgent:T,timeouts:w,requester:n,requestsCache:e,responsesCache:r}){async function s(t){let c=await Promise.all(t.map(g=>o.get(g,()=>Promise.resolve(G(g))))),f=c.filter(g=>g.isUp()),P=c.filter(g=>g.isTimedOut()),l=[...f,...P];return{hosts:l.length>0?l:t,getTimeout(g,p){return(P.length===0&&g===0?1:P.length+3+g)*p}}}async function i(t,c,f=!0){let P=[],l=ie(t,c),q=ue(d,t.headers,c.headers),g=t.method==="GET"?{...t.data,...c.data}:{},p={...h,...t.queryParameters,...g};if(T.value&&(p["x-algolia-agent"]=T.value),c&&c.queryParameters)for(let y of Object.keys(c.queryParameters))!c.queryParameters[y]||Object.prototype.toString.call(c.queryParameters[y])==="[object Object]"?p[y]=c.queryParameters[y]:p[y]=c.queryParameters[y].toString();let R=0,v=async(y,I)=>{let D=y.pop();if(D===void 0)throw new te(fe(P));let O={...w,...c.timeouts},b={data:l,headers:q,method:t.method,url:ae(D,t.path,p),connectTimeout:I(R,O.connect),responseTimeout:I(R,f?O.read:O.write)},Q=C=>{let L={request:b,response:C,host:D,triesLeft:y.length};return P.push(L),L},E=await n.send(b);if(pe(E)){let C=Q(E);return E.isTimedOut&&R++,m.info("Retryable failure",F(C)),await o.set(D,G(D,E.isTimedOut?"timed out":"down")),v(y,I)}if(he(E))return me(E);throw Q(E),ce(E,P)},Z=a.filter(y=>y.accept==="readWrite"||(f?y.accept==="read":y.accept==="write")),H=await s(Z);return v([...H.hosts].reverse(),H.getTimeout)}function u(t,c={}){let f=t.useReadTransporter||t.method==="GET";if(!f)return i(t,c,f);let P=()=>i(t,c);if((c.cacheable||t.cacheable)!==!0)return P();let q={request:t,requestOptions:c,transporter:{queryParameters:h,headers:d}};return r.get(q,()=>e.get(q,()=>e.set(q,P()).then(g=>Promise.all([e.delete(q),g]),g=>Promise.all([e.delete(q),Promise.reject(g)])).then(([g,p])=>p)),{miss:g=>r.set(q,g)})}return{hostsCache:o,requester:n,timeouts:w,logger:m,algoliaAgent:T,baseHeaders:d,baseQueryParameters:h,hosts:a,request:u,requestsCache:e,responsesCache:r}}function K(){function a(o){return new Promise(d=>{let m=new XMLHttpRequest;m.open(o.method,o.url,!0),Object.keys(o.headers).forEach(n=>m.setRequestHeader(n,o.headers[n]));let h=(n,e)=>setTimeout(()=>{m.abort(),d({status:0,content:e,isTimedOut:!0})},n),T=h(o.connectTimeout,"Connection timeout"),w;m.onreadystatechange=()=>{m.readyState>m.OPENED&&w===void 0&&(clearTimeout(T),w=h(o.responseTimeout,"Socket timeout"))},m.onerror=()=>{m.status===0&&(clearTimeout(T),clearTimeout(w),d({content:m.responseText||"Network request failed",status:m.status,isTimedOut:!1}))},m.onload=()=>{clearTimeout(T),clearTimeout(w),d({content:m.responseText,status:m.status,isTimedOut:!1})},m.send(o.data)})}return{send:a}}var x="1.7.0",A=["eu","us"];function le(a){return[{url:"data.{region}.algolia.com".replace("{region}",a),accept:"readWrite",protocol:"https"}]}function Pe(a){return a.type==="onDemand"}function qe(a){return a.type==="schedule"}function ge(a){return a.type==="subscription"}function Y({appId:a,apiKey:o,authMode:d,algoliaAgents:m,region:h,...T}){let w=$(a,o,d),n=X({hosts:le(h),...T,algoliaAgent:j({algoliaAgents:m,client:"Ingestion",version:x}),baseHeaders:{"content-type":"text/plain",...w.headers(),...T.baseHeaders},baseQueryParameters:{...w.queryParameters(),...T.baseQueryParameters}});return{transporter:n,appId:a,clearCache(){return Promise.all([n.requestsCache.clear(),n.responsesCache.clear()]).then(()=>{})},get _ua(){return n.algoliaAgent.value},addAlgoliaAgent(e,r){n.algoliaAgent.add({segment:e,version:r})},setClientApiKey({apiKey:e}){!d||d==="WithinHeaders"?n.baseHeaders["x-algolia-api-key"]=e:n.baseQueryParameters["x-algolia-api-key"]=e},createAuthentication(e,r){if(!e)throw new Error("Parameter `authenticationCreate` is required when calling `createAuthentication`.");if(!e.type)throw new Error("Parameter `authenticationCreate.type` is required when calling `createAuthentication`.");if(!e.name)throw new Error("Parameter `authenticationCreate.name` is required when calling `createAuthentication`.");if(!e.input)throw new Error("Parameter `authenticationCreate.input` is required when calling `createAuthentication`.");let t={method:"POST",path:"/1/authentications",queryParameters:{},headers:{},data:e};return n.request(t,r)},createDestination(e,r){if(!e)throw new Error("Parameter `destinationCreate` is required when calling `createDestination`.");if(!e.type)throw new Error("Parameter `destinationCreate.type` is required when calling `createDestination`.");if(!e.name)throw new Error("Parameter `destinationCreate.name` is required when calling `createDestination`.");if(!e.input)throw new Error("Parameter `destinationCreate.input` is required when calling `createDestination`.");let t={method:"POST",path:"/1/destinations",queryParameters:{},headers:{},data:e};return n.request(t,r)},createSource(e,r){if(!e)throw new Error("Parameter `sourceCreate` is required when calling `createSource`.");if(!e.type)throw new Error("Parameter `sourceCreate.type` is required when calling `createSource`.");if(!e.name)throw new Error("Parameter `sourceCreate.name` is required when calling `createSource`.");let t={method:"POST",path:"/1/sources",queryParameters:{},headers:{},data:e};return n.request(t,r)},createTask(e,r){if(!e)throw new Error("Parameter `taskCreate` is required when calling `createTask`.");if(!e.sourceID)throw new Error("Parameter `taskCreate.sourceID` is required when calling `createTask`.");if(!e.destinationID)throw new Error("Parameter `taskCreate.destinationID` is required when calling `createTask`.");if(!e.action)throw new Error("Parameter `taskCreate.action` is required when calling `createTask`.");let t={method:"POST",path:"/2/tasks",queryParameters:{},headers:{},data:e};return n.request(t,r)},createTaskV1(e,r){if(!e)throw new Error("Parameter `taskCreate` is required when calling `createTaskV1`.");if(!e.sourceID)throw new Error("Parameter `taskCreate.sourceID` is required when calling `createTaskV1`.");if(!e.destinationID)throw new Error("Parameter `taskCreate.destinationID` is required when calling `createTaskV1`.");if(!e.trigger)throw new Error("Parameter `taskCreate.trigger` is required when calling `createTaskV1`.");if(!e.action)throw new Error("Parameter `taskCreate.action` is required when calling `createTaskV1`.");let t={method:"POST",path:"/1/tasks",queryParameters:{},headers:{},data:e};return n.request(t,r)},createTransformation(e,r){if(!e)throw new Error("Parameter `transformationCreate` is required when calling `createTransformation`.");if(!e.code)throw new Error("Parameter `transformationCreate.code` is required when calling `createTransformation`.");if(!e.name)throw new Error("Parameter `transformationCreate.name` is required when calling `createTransformation`.");let t={method:"POST",path:"/1/transformations",queryParameters:{},headers:{},data:e};return n.request(t,r)},customDelete({path:e,parameters:r},s){if(!e)throw new Error("Parameter `path` is required when calling `customDelete`.");let c={method:"DELETE",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{}};return n.request(c,s)},customGet({path:e,parameters:r},s){if(!e)throw new Error("Parameter `path` is required when calling `customGet`.");let c={method:"GET",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{}};return n.request(c,s)},customPost({path:e,parameters:r,body:s},i){if(!e)throw new Error("Parameter `path` is required when calling `customPost`.");let f={method:"POST",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{},data:s||{}};return n.request(f,i)},customPut({path:e,parameters:r,body:s},i){if(!e)throw new Error("Parameter `path` is required when calling `customPut`.");let f={method:"PUT",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{},data:s||{}};return n.request(f,i)},deleteAuthentication({authenticationID:e},r){if(!e)throw new Error("Parameter `authenticationID` is required when calling `deleteAuthentication`.");let t={method:"DELETE",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteDestination({destinationID:e},r){if(!e)throw new Error("Parameter `destinationID` is required when calling `deleteDestination`.");let t={method:"DELETE",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteSource({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `deleteSource`.");let t={method:"DELETE",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `deleteTask`.");let t={method:"DELETE",path:"/2/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `deleteTaskV1`.");let t={method:"DELETE",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteTransformation({transformationID:e},r){if(!e)throw new Error("Parameter `transformationID` is required when calling `deleteTransformation`.");let t={method:"DELETE",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},disableTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `disableTask`.");let t={method:"PUT",path:"/2/tasks/{taskID}/disable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},disableTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `disableTaskV1`.");let t={method:"PUT",path:"/1/tasks/{taskID}/disable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},enableTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `enableTask`.");let t={method:"PUT",path:"/2/tasks/{taskID}/enable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},enableTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `enableTaskV1`.");let t={method:"PUT",path:"/1/tasks/{taskID}/enable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getAuthentication({authenticationID:e},r){if(!e)throw new Error("Parameter `authenticationID` is required when calling `getAuthentication`.");let t={method:"GET",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getDestination({destinationID:e},r){if(!e)throw new Error("Parameter `destinationID` is required when calling `getDestination`.");let t={method:"GET",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getEvent({runID:e,eventID:r},s){if(!e)throw new Error("Parameter `runID` is required when calling `getEvent`.");if(!r)throw new Error("Parameter `eventID` is required when calling `getEvent`.");let c={method:"GET",path:"/1/runs/{runID}/events/{eventID}".replace("{runID}",encodeURIComponent(e)).replace("{eventID}",encodeURIComponent(r)),queryParameters:{},headers:{}};return n.request(c,s)},getRun({runID:e},r){if(!e)throw new Error("Parameter `runID` is required when calling `getRun`.");let t={method:"GET",path:"/1/runs/{runID}".replace("{runID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getSource({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `getSource`.");let t={method:"GET",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `getTask`.");let t={method:"GET",path:"/2/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `getTaskV1`.");let t={method:"GET",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getTransformation({transformationID:e},r){if(!e)throw new Error("Parameter `transformationID` is required when calling `getTransformation`.");let t={method:"GET",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},listAuthentications({itemsPerPage:e,page:r,type:s,platform:i,sort:u,order:t}={},c=void 0){let f="/1/authentications",P={},l={};e!==void 0&&(l.itemsPerPage=e.toString()),r!==void 0&&(l.page=r.toString()),s!==void 0&&(l.type=s.toString()),i!==void 0&&(l.platform=i.toString()),u!==void 0&&(l.sort=u.toString()),t!==void 0&&(l.order=t.toString());let q={method:"GET",path:f,queryParameters:l,headers:P};return n.request(q,c)},listDestinations({itemsPerPage:e,page:r,type:s,authenticationID:i,transformationID:u,sort:t,order:c}={},f=void 0){let P="/1/destinations",l={},q={};e!==void 0&&(q.itemsPerPage=e.toString()),r!==void 0&&(q.page=r.toString()),s!==void 0&&(q.type=s.toString()),i!==void 0&&(q.authenticationID=i.toString()),u!==void 0&&(q.transformationID=u.toString()),t!==void 0&&(q.sort=t.toString()),c!==void 0&&(q.order=c.toString());let g={method:"GET",path:P,queryParameters:q,headers:l};return n.request(g,f)},listEvents({runID:e,itemsPerPage:r,page:s,status:i,type:u,sort:t,order:c,startDate:f,endDate:P},l){if(!e)throw new Error("Parameter `runID` is required when calling `listEvents`.");let q="/1/runs/{runID}/events".replace("{runID}",encodeURIComponent(e)),g={},p={};r!==void 0&&(p.itemsPerPage=r.toString()),s!==void 0&&(p.page=s.toString()),i!==void 0&&(p.status=i.toString()),u!==void 0&&(p.type=u.toString()),t!==void 0&&(p.sort=t.toString()),c!==void 0&&(p.order=c.toString()),f!==void 0&&(p.startDate=f.toString()),P!==void 0&&(p.endDate=P.toString());let R={method:"GET",path:q,queryParameters:p,headers:g};return n.request(R,l)},listRuns({itemsPerPage:e,page:r,status:s,type:i,taskID:u,sort:t,order:c,startDate:f,endDate:P}={},l=void 0){let q="/1/runs",g={},p={};e!==void 0&&(p.itemsPerPage=e.toString()),r!==void 0&&(p.page=r.toString()),s!==void 0&&(p.status=s.toString()),i!==void 0&&(p.type=i.toString()),u!==void 0&&(p.taskID=u.toString()),t!==void 0&&(p.sort=t.toString()),c!==void 0&&(p.order=c.toString()),f!==void 0&&(p.startDate=f.toString()),P!==void 0&&(p.endDate=P.toString());let R={method:"GET",path:q,queryParameters:p,headers:g};return n.request(R,l)},listSources({itemsPerPage:e,page:r,type:s,authenticationID:i,sort:u,order:t}={},c=void 0){let f="/1/sources",P={},l={};e!==void 0&&(l.itemsPerPage=e.toString()),r!==void 0&&(l.page=r.toString()),s!==void 0&&(l.type=s.toString()),i!==void 0&&(l.authenticationID=i.toString()),u!==void 0&&(l.sort=u.toString()),t!==void 0&&(l.order=t.toString());let q={method:"GET",path:f,queryParameters:l,headers:P};return n.request(q,c)},listTasks({itemsPerPage:e,page:r,action:s,enabled:i,sourceID:u,destinationID:t,triggerType:c,sort:f,order:P}={},l=void 0){let q="/2/tasks",g={},p={};e!==void 0&&(p.itemsPerPage=e.toString()),r!==void 0&&(p.page=r.toString()),s!==void 0&&(p.action=s.toString()),i!==void 0&&(p.enabled=i.toString()),u!==void 0&&(p.sourceID=u.toString()),t!==void 0&&(p.destinationID=t.toString()),c!==void 0&&(p.triggerType=c.toString()),f!==void 0&&(p.sort=f.toString()),P!==void 0&&(p.order=P.toString());let R={method:"GET",path:q,queryParameters:p,headers:g};return n.request(R,l)},listTasksV1({itemsPerPage:e,page:r,action:s,enabled:i,sourceID:u,destinationID:t,triggerType:c,sort:f,order:P}={},l=void 0){let q="/1/tasks",g={},p={};e!==void 0&&(p.itemsPerPage=e.toString()),r!==void 0&&(p.page=r.toString()),s!==void 0&&(p.action=s.toString()),i!==void 0&&(p.enabled=i.toString()),u!==void 0&&(p.sourceID=u.toString()),t!==void 0&&(p.destinationID=t.toString()),c!==void 0&&(p.triggerType=c.toString()),f!==void 0&&(p.sort=f.toString()),P!==void 0&&(p.order=P.toString());let R={method:"GET",path:q,queryParameters:p,headers:g};return n.request(R,l)},listTransformations({itemsPerPage:e,page:r,sort:s,order:i}={},u=void 0){let t="/1/transformations",c={},f={};e!==void 0&&(f.itemsPerPage=e.toString()),r!==void 0&&(f.page=r.toString()),s!==void 0&&(f.sort=s.toString()),i!==void 0&&(f.order=i.toString());let P={method:"GET",path:t,queryParameters:f,headers:c};return n.request(P,u)},pushTask({taskID:e,pushTaskPayload:r},s){if(!e)throw new Error("Parameter `taskID` is required when calling `pushTask`.");if(!r)throw new Error("Parameter `pushTaskPayload` is required when calling `pushTask`.");if(!r.action)throw new Error("Parameter `pushTaskPayload.action` is required when calling `pushTask`.");if(!r.records)throw new Error("Parameter `pushTaskPayload.records` is required when calling `pushTask`.");let c={method:"POST",path:"/2/tasks/{taskID}/push".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},runSource({sourceID:e,runSourcePayload:r},s){if(!e)throw new Error("Parameter `sourceID` is required when calling `runSource`.");let c={method:"POST",path:"/1/sources/{sourceID}/run".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r||{}};return n.request(c,s)},runTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `runTask`.");let t={method:"POST",path:"/2/tasks/{taskID}/run".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},runTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `runTaskV1`.");let t={method:"POST",path:"/1/tasks/{taskID}/run".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},searchAuthentications(e,r){if(!e)throw new Error("Parameter `authenticationSearch` is required when calling `searchAuthentications`.");if(!e.authenticationIDs)throw new Error("Parameter `authenticationSearch.authenticationIDs` is required when calling `searchAuthentications`.");let t={method:"POST",path:"/1/authentications/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchDestinations(e,r){if(!e)throw new Error("Parameter `destinationSearch` is required when calling `searchDestinations`.");if(!e.destinationIDs)throw new Error("Parameter `destinationSearch.destinationIDs` is required when calling `searchDestinations`.");let t={method:"POST",path:"/1/destinations/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchSources(e,r){if(!e)throw new Error("Parameter `sourceSearch` is required when calling `searchSources`.");if(!e.sourceIDs)throw new Error("Parameter `sourceSearch.sourceIDs` is required when calling `searchSources`.");let t={method:"POST",path:"/1/sources/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchTasks(e,r){if(!e)throw new Error("Parameter `taskSearch` is required when calling `searchTasks`.");if(!e.taskIDs)throw new Error("Parameter `taskSearch.taskIDs` is required when calling `searchTasks`.");let t={method:"POST",path:"/2/tasks/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchTasksV1(e,r){if(!e)throw new Error("Parameter `taskSearch` is required when calling `searchTasksV1`.");if(!e.taskIDs)throw new Error("Parameter `taskSearch.taskIDs` is required when calling `searchTasksV1`.");let t={method:"POST",path:"/1/tasks/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchTransformations(e,r){if(!e)throw new Error("Parameter `transformationSearch` is required when calling `searchTransformations`.");if(!e.transformationIDs)throw new Error("Parameter `transformationSearch.transformationIDs` is required when calling `searchTransformations`.");let t={method:"POST",path:"/1/transformations/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},triggerDockerSourceDiscover({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `triggerDockerSourceDiscover`.");let t={method:"POST",path:"/1/sources/{sourceID}/discover".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},tryTransformation(e,r){if(!e)throw new Error("Parameter `transformationTry` is required when calling `tryTransformation`.");if(!e.code)throw new Error("Parameter `transformationTry.code` is required when calling `tryTransformation`.");if(!e.sampleRecord)throw new Error("Parameter `transformationTry.sampleRecord` is required when calling `tryTransformation`.");let t={method:"POST",path:"/1/transformations/try",queryParameters:{},headers:{},data:e};return n.request(t,r)},tryTransformationBeforeUpdate({transformationID:e,transformationTry:r},s){if(!e)throw new Error("Parameter `transformationID` is required when calling `tryTransformationBeforeUpdate`.");if(!r)throw new Error("Parameter `transformationTry` is required when calling `tryTransformationBeforeUpdate`.");if(!r.code)throw new Error("Parameter `transformationTry.code` is required when calling `tryTransformationBeforeUpdate`.");if(!r.sampleRecord)throw new Error("Parameter `transformationTry.sampleRecord` is required when calling `tryTransformationBeforeUpdate`.");let c={method:"POST",path:"/1/transformations/{transformationID}/try".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateAuthentication({authenticationID:e,authenticationUpdate:r},s){if(!e)throw new Error("Parameter `authenticationID` is required when calling `updateAuthentication`.");if(!r)throw new Error("Parameter `authenticationUpdate` is required when calling `updateAuthentication`.");let c={method:"PATCH",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateDestination({destinationID:e,destinationUpdate:r},s){if(!e)throw new Error("Parameter `destinationID` is required when calling `updateDestination`.");if(!r)throw new Error("Parameter `destinationUpdate` is required when calling `updateDestination`.");let c={method:"PATCH",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateSource({sourceID:e,sourceUpdate:r},s){if(!e)throw new Error("Parameter `sourceID` is required when calling `updateSource`.");if(!r)throw new Error("Parameter `sourceUpdate` is required when calling `updateSource`.");let c={method:"PATCH",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateTask({taskID:e,taskUpdate:r},s){if(!e)throw new Error("Parameter `taskID` is required when calling `updateTask`.");if(!r)throw new Error("Parameter `taskUpdate` is required when calling `updateTask`.");let c={method:"PATCH",path:"/2/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateTaskV1({taskID:e,taskUpdate:r},s){if(!e)throw new Error("Parameter `taskID` is required when calling `updateTaskV1`.");if(!r)throw new Error("Parameter `taskUpdate` is required when calling `updateTaskV1`.");let c={method:"PATCH",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateTransformation({transformationID:e,transformationCreate:r},s){if(!e)throw new Error("Parameter `transformationID` is required when calling `updateTransformation`.");if(!r)throw new Error("Parameter `transformationCreate` is required when calling `updateTransformation`.");if(!r.code)throw new Error("Parameter `transformationCreate.code` is required when calling `updateTransformation`.");if(!r.name)throw new Error("Parameter `transformationCreate.name` is required when calling `updateTransformation`.");let c={method:"PUT",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},validateSource(e,r=void 0){let t={method:"POST",path:"/1/sources/validate",queryParameters:{},headers:{},data:e||{}};return n.request(t,r)},validateSourceBeforeUpdate({sourceID:e,sourceUpdate:r},s){if(!e)throw new Error("Parameter `sourceID` is required when calling `validateSourceBeforeUpdate`.");if(!r)throw new Error("Parameter `sourceUpdate` is required when calling `validateSourceBeforeUpdate`.");let c={method:"POST",path:"/1/sources/{sourceID}/validate".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)}}}function ls(a,o,d,m){if(!a||typeof a!="string")throw new Error("`appId` is missing.");if(!o||typeof o!="string")throw new Error("`apiKey` is missing.");if(!d||d&&(typeof d!="string"||!A.includes(d)))throw new Error(`\`region\` is required and must be one of the following: ${A.join(", ")}`);return Y({appId:a,apiKey:o,region:d,timeouts:{connect:N,read:W,write:B},logger:J(),requester:K(),algoliaAgents:[{segment:"Browser"}],authMode:"WithinQueryParameters",responsesCache:k(),requestsCache:k({serializable:!1}),hostsCache:S({caches:[_({key:`${x}-${a}`}),k()]}),...m})}export{x as apiClientVersion,ls as ingestionClient,Pe as isOnDemandTrigger,qe as isScheduleTrigger,ge as isSubscriptionTrigger};
+function V(){function a(o){return new Promise(d=>{let m=new XMLHttpRequest;m.open(o.method,o.url,!0),Object.keys(o.headers).forEach(n=>m.setRequestHeader(n,o.headers[n]));let h=(n,e)=>setTimeout(()=>{m.abort(),d({status:0,content:e,isTimedOut:!0})},n),T=h(o.connectTimeout,"Connection timeout"),y;m.onreadystatechange=()=>{m.readyState>m.OPENED&&y===void 0&&(clearTimeout(T),y=h(o.responseTimeout,"Socket timeout"))},m.onerror=()=>{m.status===0&&(clearTimeout(T),clearTimeout(y),d({content:m.responseText||"Network request failed",status:m.status,isTimedOut:!1}))},m.onload=()=>{clearTimeout(T),clearTimeout(y),d({content:m.responseText,status:m.status,isTimedOut:!1})},m.send(o.data)})}return{send:a}}function N(a){let o,d=`algolia-client-js-${a.key}`;function m(){return o===void 0&&(o=a.localStorage||window.localStorage),o}function h(){return JSON.parse(m().getItem(d)||"{}")}function T(n){m().setItem(d,JSON.stringify(n))}function y(){let n=a.timeToLive?a.timeToLive*1e3:null,e=h(),r=Object.fromEntries(Object.entries(e).filter(([,i])=>i.timestamp!==void 0));if(T(r),!n)return;let s=Object.fromEntries(Object.entries(r).filter(([,i])=>{let u=new Date().getTime();return!(i.timestamp+n<u)}));T(s)}return{get(n,e,r={miss:()=>Promise.resolve()}){return Promise.resolve().then(()=>(y(),h()[JSON.stringify(n)])).then(s=>Promise.all([s?s.value:e(),s!==void 0])).then(([s,i])=>Promise.all([s,i||r.miss(s)])).then(([s])=>s)},set(n,e){return Promise.resolve().then(()=>{let r=h();return r[JSON.stringify(n)]={timestamp:new Date().getTime(),value:e},m().setItem(d,JSON.stringify(r)),e})},delete(n){return Promise.resolve().then(()=>{let e=h();delete e[JSON.stringify(n)],m().setItem(d,JSON.stringify(e))})},clear(){return Promise.resolve().then(()=>{m().removeItem(d)})}}}function ee(){return{get(a,o,d={miss:()=>Promise.resolve()}){return o().then(h=>Promise.all([h,d.miss(h)])).then(([h])=>h)},set(a,o){return Promise.resolve(o)},delete(a){return Promise.resolve()},clear(){return Promise.resolve()}}}function S(a){let o=[...a.caches],d=o.shift();return d===void 0?ee():{get(m,h,T={miss:()=>Promise.resolve()}){return d.get(m,h,T).catch(()=>S({caches:o}).get(m,h,T))},set(m,h){return d.set(m,h).catch(()=>S({caches:o}).set(m,h))},delete(m){return d.delete(m).catch(()=>S({caches:o}).delete(m))},clear(){return d.clear().catch(()=>S({caches:o}).clear())}}}function k(a={serializable:!0}){let o={};return{get(d,m,h={miss:()=>Promise.resolve()}){let T=JSON.stringify(d);if(T in o)return Promise.resolve(a.serializable?JSON.parse(o[T]):o[T]);let y=m();return y.then(n=>h.miss(n)).then(()=>y)},set(d,m){return o[JSON.stringify(d)]=a.serializable?JSON.stringify(m):m,Promise.resolve(m)},delete(d){return delete o[JSON.stringify(d)],Promise.resolve()},clear(){return o={},Promise.resolve()}}}var W=1e3,B=2e3,$=3e4;function re(a){let o={value:`Algolia for JavaScript (${a})`,add(d){let m=`; ${d.segment}${d.version!==void 0?` (${d.version})`:""}`;return o.value.indexOf(m)===-1&&(o.value=`${o.value}${m}`),o}};return o}function j(a,o,d="WithinHeaders"){let m={"x-algolia-api-key":o,"x-algolia-application-id":a};return{headers(){return d==="WithinHeaders"?m:{}},queryParameters(){return d==="WithinQueryParameters"?m:{}}}}function J({algoliaAgents:a,client:o,version:d}){let m=re(d).add({segment:o,version:d});return a.forEach(h=>m.add(h)),m}function M(){return{debug(a,o){return Promise.resolve()},info(a,o){return Promise.resolve()},error(a,o){return Promise.resolve()}}}var G=2*60*1e3;function _(a,o="up"){let d=Date.now();function m(){return o==="up"||Date.now()-d>G}function h(){return o==="timed out"&&Date.now()-d<=G}return{...a,status:o,lastUpdate:d,isUp:m,isTimedOut:h}}var z=class extends Error{name="AlgoliaError";constructor(a,o){super(a),o&&(this.name=o)}},F=class extends z{stackTrace;constructor(a,o,d){super(a,d),this.stackTrace=o}},te=class extends F{constructor(a){super("Unreachable hosts - your application id may be incorrect. If the error persists, please reach out to the Algolia Support team: https://alg.li/support.",a,"RetryError")}},U=class extends F{status;constructor(a,o,d,m="ApiError"){super(a,d,m),this.status=o}},se=class extends z{response;constructor(a,o){super(a,"DeserializationError"),this.response=o}},oe=class extends U{error;constructor(a,o,d,m){super(a,o,m,"DetailedApiError"),this.error=d}};function ae(a,o,d){let m=ne(d),h=`${a.protocol}://${a.url}${a.port?`:${a.port}`:""}/${o.charAt(0)==="/"?o.substring(1):o}`;return m.length&&(h+=`?${m}`),h}function ne(a){return Object.keys(a).filter(o=>a[o]!==void 0).sort().map(o=>`${o}=${encodeURIComponent(Object.prototype.toString.call(a[o])==="[object Array]"?a[o].join(","):a[o]).replace(/\+/g,"%20")}`).join("&")}function ie(a,o){if(a.method==="GET"||a.data===void 0&&o.data===void 0)return;let d=Array.isArray(a.data)?a.data:{...a.data,...o.data};return JSON.stringify(d)}function ue(a,o,d){let m={Accept:"application/json",...a,...o,...d},h={};return Object.keys(m).forEach(T=>{let y=m[T];h[T.toLowerCase()]=y}),h}function me(a){try{return JSON.parse(a.content)}catch(o){throw new se(o.message,a)}}function ce({content:a,status:o},d){try{let m=JSON.parse(a);return"error"in m?new oe(m.message,o,m.error,d):new U(m.message,o,d)}catch{}return new U(a,o,d)}function de({isTimedOut:a,status:o}){return!a&&~~o===0}function pe({isTimedOut:a,status:o}){return a||de({isTimedOut:a,status:o})||~~(o/100)!==2&&~~(o/100)!==4}function he({status:a}){return~~(a/100)===2}function fe(a){return a.map(o=>X(o))}function X(a){let o=a.request.headers["x-algolia-api-key"]?{"x-algolia-api-key":"*****"}:{};return{...a,request:{...a.request,headers:{...a.request.headers,...o}}}}function K({hosts:a,hostsCache:o,baseHeaders:d,logger:m,baseQueryParameters:h,algoliaAgent:T,timeouts:y,requester:n,requestsCache:e,responsesCache:r}){async function s(t){let c=await Promise.all(t.map(g=>o.get(g,()=>Promise.resolve(_(g))))),f=c.filter(g=>g.isUp()),P=c.filter(g=>g.isTimedOut()),l=[...f,...P];return{hosts:l.length>0?l:t,getTimeout(g,p){return(P.length===0&&g===0?1:P.length+3+g)*p}}}async function i(t,c,f=!0){let P=[],l=ie(t,c),q=ue(d,t.headers,c.headers),g=t.method==="GET"?{...t.data,...c.data}:{},p={...h,...t.queryParameters,...g};if(T.value&&(p["x-algolia-agent"]=T.value),c&&c.queryParameters)for(let w of Object.keys(c.queryParameters))!c.queryParameters[w]||Object.prototype.toString.call(c.queryParameters[w])==="[object Object]"?p[w]=c.queryParameters[w]:p[w]=c.queryParameters[w].toString();let R=0,v=async(w,I)=>{let D=w.pop();if(D===void 0)throw new te(fe(P));let O={...y,...c.timeouts},b={data:l,headers:q,method:t.method,url:ae(D,t.path,p),connectTimeout:I(R,O.connect),responseTimeout:I(R,f?O.read:O.write)},Q=C=>{let L={request:b,response:C,host:D,triesLeft:w.length};return P.push(L),L},E=await n.send(b);if(pe(E)){let C=Q(E);return E.isTimedOut&&R++,m.info("Retryable failure",X(C)),await o.set(D,_(D,E.isTimedOut?"timed out":"down")),v(w,I)}if(he(E))return me(E);throw Q(E),ce(E,P)},Z=a.filter(w=>w.accept==="readWrite"||(f?w.accept==="read":w.accept==="write")),H=await s(Z);return v([...H.hosts].reverse(),H.getTimeout)}function u(t,c={}){let f=t.useReadTransporter||t.method==="GET";if(!f)return i(t,c,f);let P=()=>i(t,c);if((c.cacheable||t.cacheable)!==!0)return P();let q={request:t,requestOptions:c,transporter:{queryParameters:h,headers:d}};return r.get(q,()=>e.get(q,()=>e.set(q,P()).then(g=>Promise.all([e.delete(q),g]),g=>Promise.all([e.delete(q),Promise.reject(g)])).then(([g,p])=>p)),{miss:g=>r.set(q,g)})}return{hostsCache:o,requester:n,timeouts:y,logger:m,algoliaAgent:T,baseHeaders:d,baseQueryParameters:h,hosts:a,request:u,requestsCache:e,responsesCache:r}}var x="1.8.0",A=["eu","us"];function le(a){return[{url:"data.{region}.algolia.com".replace("{region}",a),accept:"readWrite",protocol:"https"}]}function Pe(a){return a.type==="onDemand"}function qe(a){return a.type==="schedule"}function ge(a){return a.type==="subscription"}function Y({appId:a,apiKey:o,authMode:d,algoliaAgents:m,region:h,...T}){let y=j(a,o,d),n=K({hosts:le(h),...T,algoliaAgent:J({algoliaAgents:m,client:"Ingestion",version:x}),baseHeaders:{"content-type":"text/plain",...y.headers(),...T.baseHeaders},baseQueryParameters:{...y.queryParameters(),...T.baseQueryParameters}});return{transporter:n,appId:a,clearCache(){return Promise.all([n.requestsCache.clear(),n.responsesCache.clear()]).then(()=>{})},get _ua(){return n.algoliaAgent.value},addAlgoliaAgent(e,r){n.algoliaAgent.add({segment:e,version:r})},setClientApiKey({apiKey:e}){!d||d==="WithinHeaders"?n.baseHeaders["x-algolia-api-key"]=e:n.baseQueryParameters["x-algolia-api-key"]=e},createAuthentication(e,r){if(!e)throw new Error("Parameter `authenticationCreate` is required when calling `createAuthentication`.");if(!e.type)throw new Error("Parameter `authenticationCreate.type` is required when calling `createAuthentication`.");if(!e.name)throw new Error("Parameter `authenticationCreate.name` is required when calling `createAuthentication`.");if(!e.input)throw new Error("Parameter `authenticationCreate.input` is required when calling `createAuthentication`.");let t={method:"POST",path:"/1/authentications",queryParameters:{},headers:{},data:e};return n.request(t,r)},createDestination(e,r){if(!e)throw new Error("Parameter `destinationCreate` is required when calling `createDestination`.");if(!e.type)throw new Error("Parameter `destinationCreate.type` is required when calling `createDestination`.");if(!e.name)throw new Error("Parameter `destinationCreate.name` is required when calling `createDestination`.");if(!e.input)throw new Error("Parameter `destinationCreate.input` is required when calling `createDestination`.");let t={method:"POST",path:"/1/destinations",queryParameters:{},headers:{},data:e};return n.request(t,r)},createSource(e,r){if(!e)throw new Error("Parameter `sourceCreate` is required when calling `createSource`.");if(!e.type)throw new Error("Parameter `sourceCreate.type` is required when calling `createSource`.");if(!e.name)throw new Error("Parameter `sourceCreate.name` is required when calling `createSource`.");let t={method:"POST",path:"/1/sources",queryParameters:{},headers:{},data:e};return n.request(t,r)},createTask(e,r){if(!e)throw new Error("Parameter `taskCreate` is required when calling `createTask`.");if(!e.sourceID)throw new Error("Parameter `taskCreate.sourceID` is required when calling `createTask`.");if(!e.destinationID)throw new Error("Parameter `taskCreate.destinationID` is required when calling `createTask`.");if(!e.action)throw new Error("Parameter `taskCreate.action` is required when calling `createTask`.");let t={method:"POST",path:"/2/tasks",queryParameters:{},headers:{},data:e};return n.request(t,r)},createTaskV1(e,r){if(!e)throw new Error("Parameter `taskCreate` is required when calling `createTaskV1`.");if(!e.sourceID)throw new Error("Parameter `taskCreate.sourceID` is required when calling `createTaskV1`.");if(!e.destinationID)throw new Error("Parameter `taskCreate.destinationID` is required when calling `createTaskV1`.");if(!e.trigger)throw new Error("Parameter `taskCreate.trigger` is required when calling `createTaskV1`.");if(!e.action)throw new Error("Parameter `taskCreate.action` is required when calling `createTaskV1`.");let t={method:"POST",path:"/1/tasks",queryParameters:{},headers:{},data:e};return n.request(t,r)},createTransformation(e,r){if(!e)throw new Error("Parameter `transformationCreate` is required when calling `createTransformation`.");if(!e.code)throw new Error("Parameter `transformationCreate.code` is required when calling `createTransformation`.");if(!e.name)throw new Error("Parameter `transformationCreate.name` is required when calling `createTransformation`.");let t={method:"POST",path:"/1/transformations",queryParameters:{},headers:{},data:e};return n.request(t,r)},customDelete({path:e,parameters:r},s){if(!e)throw new Error("Parameter `path` is required when calling `customDelete`.");let c={method:"DELETE",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{}};return n.request(c,s)},customGet({path:e,parameters:r},s){if(!e)throw new Error("Parameter `path` is required when calling `customGet`.");let c={method:"GET",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{}};return n.request(c,s)},customPost({path:e,parameters:r,body:s},i){if(!e)throw new Error("Parameter `path` is required when calling `customPost`.");let f={method:"POST",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{},data:s||{}};return n.request(f,i)},customPut({path:e,parameters:r,body:s},i){if(!e)throw new Error("Parameter `path` is required when calling `customPut`.");let f={method:"PUT",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{},data:s||{}};return n.request(f,i)},deleteAuthentication({authenticationID:e},r){if(!e)throw new Error("Parameter `authenticationID` is required when calling `deleteAuthentication`.");let t={method:"DELETE",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteDestination({destinationID:e},r){if(!e)throw new Error("Parameter `destinationID` is required when calling `deleteDestination`.");let t={method:"DELETE",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteSource({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `deleteSource`.");let t={method:"DELETE",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `deleteTask`.");let t={method:"DELETE",path:"/2/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `deleteTaskV1`.");let t={method:"DELETE",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteTransformation({transformationID:e},r){if(!e)throw new Error("Parameter `transformationID` is required when calling `deleteTransformation`.");let t={method:"DELETE",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},disableTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `disableTask`.");let t={method:"PUT",path:"/2/tasks/{taskID}/disable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},disableTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `disableTaskV1`.");let t={method:"PUT",path:"/1/tasks/{taskID}/disable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},enableTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `enableTask`.");let t={method:"PUT",path:"/2/tasks/{taskID}/enable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},enableTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `enableTaskV1`.");let t={method:"PUT",path:"/1/tasks/{taskID}/enable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getAuthentication({authenticationID:e},r){if(!e)throw new Error("Parameter `authenticationID` is required when calling `getAuthentication`.");let t={method:"GET",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getDestination({destinationID:e},r){if(!e)throw new Error("Parameter `destinationID` is required when calling `getDestination`.");let t={method:"GET",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getEvent({runID:e,eventID:r},s){if(!e)throw new Error("Parameter `runID` is required when calling `getEvent`.");if(!r)throw new Error("Parameter `eventID` is required when calling `getEvent`.");let c={method:"GET",path:"/1/runs/{runID}/events/{eventID}".replace("{runID}",encodeURIComponent(e)).replace("{eventID}",encodeURIComponent(r)),queryParameters:{},headers:{}};return n.request(c,s)},getRun({runID:e},r){if(!e)throw new Error("Parameter `runID` is required when calling `getRun`.");let t={method:"GET",path:"/1/runs/{runID}".replace("{runID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getSource({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `getSource`.");let t={method:"GET",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `getTask`.");let t={method:"GET",path:"/2/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `getTaskV1`.");let t={method:"GET",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getTransformation({transformationID:e},r){if(!e)throw new Error("Parameter `transformationID` is required when calling `getTransformation`.");let t={method:"GET",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},listAuthentications({itemsPerPage:e,page:r,type:s,platform:i,sort:u,order:t}={},c=void 0){let f="/1/authentications",P={},l={};e!==void 0&&(l.itemsPerPage=e.toString()),r!==void 0&&(l.page=r.toString()),s!==void 0&&(l.type=s.toString()),i!==void 0&&(l.platform=i.toString()),u!==void 0&&(l.sort=u.toString()),t!==void 0&&(l.order=t.toString());let q={method:"GET",path:f,queryParameters:l,headers:P};return n.request(q,c)},listDestinations({itemsPerPage:e,page:r,type:s,authenticationID:i,transformationID:u,sort:t,order:c}={},f=void 0){let P="/1/destinations",l={},q={};e!==void 0&&(q.itemsPerPage=e.toString()),r!==void 0&&(q.page=r.toString()),s!==void 0&&(q.type=s.toString()),i!==void 0&&(q.authenticationID=i.toString()),u!==void 0&&(q.transformationID=u.toString()),t!==void 0&&(q.sort=t.toString()),c!==void 0&&(q.order=c.toString());let g={method:"GET",path:P,queryParameters:q,headers:l};return n.request(g,f)},listEvents({runID:e,itemsPerPage:r,page:s,status:i,type:u,sort:t,order:c,startDate:f,endDate:P},l){if(!e)throw new Error("Parameter `runID` is required when calling `listEvents`.");let q="/1/runs/{runID}/events".replace("{runID}",encodeURIComponent(e)),g={},p={};r!==void 0&&(p.itemsPerPage=r.toString()),s!==void 0&&(p.page=s.toString()),i!==void 0&&(p.status=i.toString()),u!==void 0&&(p.type=u.toString()),t!==void 0&&(p.sort=t.toString()),c!==void 0&&(p.order=c.toString()),f!==void 0&&(p.startDate=f.toString()),P!==void 0&&(p.endDate=P.toString());let R={method:"GET",path:q,queryParameters:p,headers:g};return n.request(R,l)},listRuns({itemsPerPage:e,page:r,status:s,type:i,taskID:u,sort:t,order:c,startDate:f,endDate:P}={},l=void 0){let q="/1/runs",g={},p={};e!==void 0&&(p.itemsPerPage=e.toString()),r!==void 0&&(p.page=r.toString()),s!==void 0&&(p.status=s.toString()),i!==void 0&&(p.type=i.toString()),u!==void 0&&(p.taskID=u.toString()),t!==void 0&&(p.sort=t.toString()),c!==void 0&&(p.order=c.toString()),f!==void 0&&(p.startDate=f.toString()),P!==void 0&&(p.endDate=P.toString());let R={method:"GET",path:q,queryParameters:p,headers:g};return n.request(R,l)},listSources({itemsPerPage:e,page:r,type:s,authenticationID:i,sort:u,order:t}={},c=void 0){let f="/1/sources",P={},l={};e!==void 0&&(l.itemsPerPage=e.toString()),r!==void 0&&(l.page=r.toString()),s!==void 0&&(l.type=s.toString()),i!==void 0&&(l.authenticationID=i.toString()),u!==void 0&&(l.sort=u.toString()),t!==void 0&&(l.order=t.toString());let q={method:"GET",path:f,queryParameters:l,headers:P};return n.request(q,c)},listTasks({itemsPerPage:e,page:r,action:s,enabled:i,sourceID:u,destinationID:t,triggerType:c,sort:f,order:P}={},l=void 0){let q="/2/tasks",g={},p={};e!==void 0&&(p.itemsPerPage=e.toString()),r!==void 0&&(p.page=r.toString()),s!==void 0&&(p.action=s.toString()),i!==void 0&&(p.enabled=i.toString()),u!==void 0&&(p.sourceID=u.toString()),t!==void 0&&(p.destinationID=t.toString()),c!==void 0&&(p.triggerType=c.toString()),f!==void 0&&(p.sort=f.toString()),P!==void 0&&(p.order=P.toString());let R={method:"GET",path:q,queryParameters:p,headers:g};return n.request(R,l)},listTasksV1({itemsPerPage:e,page:r,action:s,enabled:i,sourceID:u,destinationID:t,triggerType:c,sort:f,order:P}={},l=void 0){let q="/1/tasks",g={},p={};e!==void 0&&(p.itemsPerPage=e.toString()),r!==void 0&&(p.page=r.toString()),s!==void 0&&(p.action=s.toString()),i!==void 0&&(p.enabled=i.toString()),u!==void 0&&(p.sourceID=u.toString()),t!==void 0&&(p.destinationID=t.toString()),c!==void 0&&(p.triggerType=c.toString()),f!==void 0&&(p.sort=f.toString()),P!==void 0&&(p.order=P.toString());let R={method:"GET",path:q,queryParameters:p,headers:g};return n.request(R,l)},listTransformations({itemsPerPage:e,page:r,sort:s,order:i}={},u=void 0){let t="/1/transformations",c={},f={};e!==void 0&&(f.itemsPerPage=e.toString()),r!==void 0&&(f.page=r.toString()),s!==void 0&&(f.sort=s.toString()),i!==void 0&&(f.order=i.toString());let P={method:"GET",path:t,queryParameters:f,headers:c};return n.request(P,u)},pushTask({taskID:e,pushTaskPayload:r},s){if(!e)throw new Error("Parameter `taskID` is required when calling `pushTask`.");if(!r)throw new Error("Parameter `pushTaskPayload` is required when calling `pushTask`.");if(!r.action)throw new Error("Parameter `pushTaskPayload.action` is required when calling `pushTask`.");if(!r.records)throw new Error("Parameter `pushTaskPayload.records` is required when calling `pushTask`.");let c={method:"POST",path:"/2/tasks/{taskID}/push".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},runSource({sourceID:e,runSourcePayload:r},s){if(!e)throw new Error("Parameter `sourceID` is required when calling `runSource`.");let c={method:"POST",path:"/1/sources/{sourceID}/run".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r||{}};return n.request(c,s)},runTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `runTask`.");let t={method:"POST",path:"/2/tasks/{taskID}/run".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},runTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `runTaskV1`.");let t={method:"POST",path:"/1/tasks/{taskID}/run".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},searchAuthentications(e,r){if(!e)throw new Error("Parameter `authenticationSearch` is required when calling `searchAuthentications`.");if(!e.authenticationIDs)throw new Error("Parameter `authenticationSearch.authenticationIDs` is required when calling `searchAuthentications`.");let t={method:"POST",path:"/1/authentications/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchDestinations(e,r){if(!e)throw new Error("Parameter `destinationSearch` is required when calling `searchDestinations`.");if(!e.destinationIDs)throw new Error("Parameter `destinationSearch.destinationIDs` is required when calling `searchDestinations`.");let t={method:"POST",path:"/1/destinations/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchSources(e,r){if(!e)throw new Error("Parameter `sourceSearch` is required when calling `searchSources`.");if(!e.sourceIDs)throw new Error("Parameter `sourceSearch.sourceIDs` is required when calling `searchSources`.");let t={method:"POST",path:"/1/sources/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchTasks(e,r){if(!e)throw new Error("Parameter `taskSearch` is required when calling `searchTasks`.");if(!e.taskIDs)throw new Error("Parameter `taskSearch.taskIDs` is required when calling `searchTasks`.");let t={method:"POST",path:"/2/tasks/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchTasksV1(e,r){if(!e)throw new Error("Parameter `taskSearch` is required when calling `searchTasksV1`.");if(!e.taskIDs)throw new Error("Parameter `taskSearch.taskIDs` is required when calling `searchTasksV1`.");let t={method:"POST",path:"/1/tasks/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchTransformations(e,r){if(!e)throw new Error("Parameter `transformationSearch` is required when calling `searchTransformations`.");if(!e.transformationIDs)throw new Error("Parameter `transformationSearch.transformationIDs` is required when calling `searchTransformations`.");let t={method:"POST",path:"/1/transformations/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},triggerDockerSourceDiscover({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `triggerDockerSourceDiscover`.");let t={method:"POST",path:"/1/sources/{sourceID}/discover".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},tryTransformation(e,r){if(!e)throw new Error("Parameter `transformationTry` is required when calling `tryTransformation`.");if(!e.code)throw new Error("Parameter `transformationTry.code` is required when calling `tryTransformation`.");if(!e.sampleRecord)throw new Error("Parameter `transformationTry.sampleRecord` is required when calling `tryTransformation`.");let t={method:"POST",path:"/1/transformations/try",queryParameters:{},headers:{},data:e};return n.request(t,r)},tryTransformationBeforeUpdate({transformationID:e,transformationTry:r},s){if(!e)throw new Error("Parameter `transformationID` is required when calling `tryTransformationBeforeUpdate`.");if(!r)throw new Error("Parameter `transformationTry` is required when calling `tryTransformationBeforeUpdate`.");if(!r.code)throw new Error("Parameter `transformationTry.code` is required when calling `tryTransformationBeforeUpdate`.");if(!r.sampleRecord)throw new Error("Parameter `transformationTry.sampleRecord` is required when calling `tryTransformationBeforeUpdate`.");let c={method:"POST",path:"/1/transformations/{transformationID}/try".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateAuthentication({authenticationID:e,authenticationUpdate:r},s){if(!e)throw new Error("Parameter `authenticationID` is required when calling `updateAuthentication`.");if(!r)throw new Error("Parameter `authenticationUpdate` is required when calling `updateAuthentication`.");let c={method:"PATCH",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateDestination({destinationID:e,destinationUpdate:r},s){if(!e)throw new Error("Parameter `destinationID` is required when calling `updateDestination`.");if(!r)throw new Error("Parameter `destinationUpdate` is required when calling `updateDestination`.");let c={method:"PATCH",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateSource({sourceID:e,sourceUpdate:r},s){if(!e)throw new Error("Parameter `sourceID` is required when calling `updateSource`.");if(!r)throw new Error("Parameter `sourceUpdate` is required when calling `updateSource`.");let c={method:"PATCH",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateTask({taskID:e,taskUpdate:r},s){if(!e)throw new Error("Parameter `taskID` is required when calling `updateTask`.");if(!r)throw new Error("Parameter `taskUpdate` is required when calling `updateTask`.");let c={method:"PATCH",path:"/2/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateTaskV1({taskID:e,taskUpdate:r},s){if(!e)throw new Error("Parameter `taskID` is required when calling `updateTaskV1`.");if(!r)throw new Error("Parameter `taskUpdate` is required when calling `updateTaskV1`.");let c={method:"PATCH",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateTransformation({transformationID:e,transformationCreate:r},s){if(!e)throw new Error("Parameter `transformationID` is required when calling `updateTransformation`.");if(!r)throw new Error("Parameter `transformationCreate` is required when calling `updateTransformation`.");if(!r.code)throw new Error("Parameter `transformationCreate.code` is required when calling `updateTransformation`.");if(!r.name)throw new Error("Parameter `transformationCreate.name` is required when calling `updateTransformation`.");let c={method:"PUT",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},validateSource(e,r=void 0){let t={method:"POST",path:"/1/sources/validate",queryParameters:{},headers:{},data:e||{}};return n.request(t,r)},validateSourceBeforeUpdate({sourceID:e,sourceUpdate:r},s){if(!e)throw new Error("Parameter `sourceID` is required when calling `validateSourceBeforeUpdate`.");if(!r)throw new Error("Parameter `sourceUpdate` is required when calling `validateSourceBeforeUpdate`.");let c={method:"POST",path:"/1/sources/{sourceID}/validate".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)}}}function gs(a,o,d,m){if(!a||typeof a!="string")throw new Error("`appId` is missing.");if(!o||typeof o!="string")throw new Error("`apiKey` is missing.");if(!d||d&&(typeof d!="string"||!A.includes(d)))throw new Error(`\`region\` is required and must be one of the following: ${A.join(", ")}`);return Y({appId:a,apiKey:o,region:d,timeouts:{connect:W,read:B,write:$},logger:M(),requester:V(),algoliaAgents:[{segment:"Browser"}],authMode:"WithinQueryParameters",responsesCache:k(),requestsCache:k({serializable:!1}),hostsCache:S({caches:[N({key:`${x}-${a}`}),k()]}),...m})}export{x as apiClientVersion,gs as ingestionClient,Pe as isOnDemandTrigger,qe as isScheduleTrigger,ge as isSubscriptionTrigger};
 //# sourceMappingURL=browser.min.js.map

dist/builds/browser.umd.js

@@ -7,6 +7,6 @@ (function (global, factory) {
 
-	function _(a){let o,d=`algolia-client-js-${a.key}`;function m(){return o===void 0&&(o=a.localStorage||window.localStorage),o}function h(){return JSON.parse(m().getItem(d)||"{}")}function T(n){m().setItem(d,JSON.stringify(n));}function w(){let n=a.timeToLive?a.timeToLive*1e3:null,e=h(),r=Object.fromEntries(Object.entries(e).filter(([,i])=>i.timestamp!==void 0));if(T(r),!n)return;let s=Object.fromEntries(Object.entries(r).filter(([,i])=>{let u=new Date().getTime();return !(i.timestamp+n<u)}));T(s);}return {get(n,e,r={miss:()=>Promise.resolve()}){return Promise.resolve().then(()=>(w(),h()[JSON.stringify(n)])).then(s=>Promise.all([s?s.value:e(),s!==void 0])).then(([s,i])=>Promise.all([s,i||r.miss(s)])).then(([s])=>s)},set(n,e){return Promise.resolve().then(()=>{let r=h();return r[JSON.stringify(n)]={timestamp:new Date().getTime(),value:e},m().setItem(d,JSON.stringify(r)),e})},delete(n){return Promise.resolve().then(()=>{let e=h();delete e[JSON.stringify(n)],m().setItem(d,JSON.stringify(e));})},clear(){return Promise.resolve().then(()=>{m().removeItem(d);})}}}function ee(){return {get(a,o,d={miss:()=>Promise.resolve()}){return o().then(h=>Promise.all([h,d.miss(h)])).then(([h])=>h)},set(a,o){return Promise.resolve(o)},delete(a){return Promise.resolve()},clear(){return Promise.resolve()}}}function S(a){let o=[...a.caches],d=o.shift();return d===void 0?ee():{get(m,h,T={miss:()=>Promise.resolve()}){return d.get(m,h,T).catch(()=>S({caches:o}).get(m,h,T))},set(m,h){return d.set(m,h).catch(()=>S({caches:o}).set(m,h))},delete(m){return d.delete(m).catch(()=>S({caches:o}).delete(m))},clear(){return d.clear().catch(()=>S({caches:o}).clear())}}}function k(a={serializable:!0}){let o={};return {get(d,m,h={miss:()=>Promise.resolve()}){let T=JSON.stringify(d);if(T in o)return Promise.resolve(a.serializable?JSON.parse(o[T]):o[T]);let w=m();return w.then(n=>h.miss(n)).then(()=>w)},set(d,m){return o[JSON.stringify(d)]=a.serializable?JSON.stringify(m):m,Promise.resolve(m)},delete(d){return delete o[JSON.stringify(d)],Promise.resolve()},clear(){return o={},Promise.resolve()}}}var N=1e3,W=2e3,B=3e4;function re(a){let o={value:`Algolia for JavaScript (${a})`,add(d){let m=`; ${d.segment}${d.version!==void 0?` (${d.version})`:""}`;return o.value.indexOf(m)===-1&&(o.value=`${o.value}${m}`),o}};return o}function $(a,o,d="WithinHeaders"){let m={"x-algolia-api-key":o,"x-algolia-application-id":a};return {headers(){return d==="WithinHeaders"?m:{}},queryParameters(){return d==="WithinQueryParameters"?m:{}}}}function j({algoliaAgents:a,client:o,version:d}){let m=re(d).add({segment:o,version:d});return a.forEach(h=>m.add(h)),m}function J(){return {debug(a,o){return Promise.resolve()},info(a,o){return Promise.resolve()},error(a,o){return Promise.resolve()}}}var V=2*60*1e3;function G(a,o="up"){let d=Date.now();function m(){return o==="up"||Date.now()-d>V}function h(){return o==="timed out"&&Date.now()-d<=V}return {...a,status:o,lastUpdate:d,isUp:m,isTimedOut:h}}var M=class extends Error{name="AlgoliaError";constructor(a,o){super(a),o&&(this.name=o);}},z=class extends M{stackTrace;constructor(a,o,d){super(a,d),this.stackTrace=o;}},te=class extends z{constructor(a){super("Unreachable hosts - your application id may be incorrect. If the error persists, please reach out to the Algolia Support team: https://alg.li/support.",a,"RetryError");}},U=class extends z{status;constructor(a,o,d,m="ApiError"){super(a,d,m),this.status=o;}},se=class extends M{response;constructor(a,o){super(a,"DeserializationError"),this.response=o;}},oe=class extends U{error;constructor(a,o,d,m){super(a,o,m,"DetailedApiError"),this.error=d;}};function ae(a,o,d){let m=ne(d),h=`${a.protocol}://${a.url}${a.port?`:${a.port}`:""}/${o.charAt(0)==="/"?o.substring(1):o}`;return m.length&&(h+=`?${m}`),h}function ne(a){return Object.keys(a).filter(o=>a[o]!==void 0).sort().map(o=>`${o}=${encodeURIComponent(Object.prototype.toString.call(a[o])==="[object Array]"?a[o].join(","):a[o]).replaceAll("+","%20")}`).join("&")}function ie(a,o){if(a.method==="GET"||a.data===void 0&&o.data===void 0)return;let d=Array.isArray(a.data)?a.data:{...a.data,...o.data};return JSON.stringify(d)}function ue(a,o,d){let m={Accept:"application/json",...a,...o,...d},h={};return Object.keys(m).forEach(T=>{let w=m[T];h[T.toLowerCase()]=w;}),h}function me(a){try{return JSON.parse(a.content)}catch(o){throw new se(o.message,a)}}function ce({content:a,status:o},d){try{let m=JSON.parse(a);return "error"in m?new oe(m.message,o,m.error,d):new U(m.message,o,d)}catch{}return new U(a,o,d)}function de({isTimedOut:a,status:o}){return !a&&~~o===0}function pe({isTimedOut:a,status:o}){return a||de({isTimedOut:a,status:o})||~~(o/100)!==2&&~~(o/100)!==4}function he({status:a}){return ~~(a/100)===2}function fe(a){return a.map(o=>F(o))}function F(a){let o=a.request.headers["x-algolia-api-key"]?{"x-algolia-api-key":"*****"}:{};return {...a,request:{...a.request,headers:{...a.request.headers,...o}}}}function X({hosts:a,hostsCache:o,baseHeaders:d,logger:m,baseQueryParameters:h,algoliaAgent:T,timeouts:w,requester:n,requestsCache:e,responsesCache:r}){async function s(t){let c=await Promise.all(t.map(g=>o.get(g,()=>Promise.resolve(G(g))))),f=c.filter(g=>g.isUp()),P=c.filter(g=>g.isTimedOut()),l=[...f,...P];return {hosts:l.length>0?l:t,getTimeout(g,p){return (P.length===0&&g===0?1:P.length+3+g)*p}}}async function i(t,c,f=!0){let P=[],l=ie(t,c),q=ue(d,t.headers,c.headers),g=t.method==="GET"?{...t.data,...c.data}:{},p={...h,...t.queryParameters,...g};if(T.value&&(p["x-algolia-agent"]=T.value),c&&c.queryParameters)for(let y of Object.keys(c.queryParameters))!c.queryParameters[y]||Object.prototype.toString.call(c.queryParameters[y])==="[object Object]"?p[y]=c.queryParameters[y]:p[y]=c.queryParameters[y].toString();let R=0,v=async(y,I)=>{let D=y.pop();if(D===void 0)throw new te(fe(P));let O={...w,...c.timeouts},b={data:l,headers:q,method:t.method,url:ae(D,t.path,p),connectTimeout:I(R,O.connect),responseTimeout:I(R,f?O.read:O.write)},Q=C=>{let L={request:b,response:C,host:D,triesLeft:y.length};return P.push(L),L},E=await n.send(b);if(pe(E)){let C=Q(E);return E.isTimedOut&&R++,m.info("Retryable failure",F(C)),await o.set(D,G(D,E.isTimedOut?"timed out":"down")),v(y,I)}if(he(E))return me(E);throw Q(E),ce(E,P)},Z=a.filter(y=>y.accept==="readWrite"||(f?y.accept==="read":y.accept==="write")),H=await s(Z);return v([...H.hosts].reverse(),H.getTimeout)}function u(t,c={}){let f=t.useReadTransporter||t.method==="GET";if(!f)return i(t,c,f);let P=()=>i(t,c);if((c.cacheable||t.cacheable)!==!0)return P();let q={request:t,requestOptions:c,transporter:{queryParameters:h,headers:d}};return r.get(q,()=>e.get(q,()=>e.set(q,P()).then(g=>Promise.all([e.delete(q),g]),g=>Promise.all([e.delete(q),Promise.reject(g)])).then(([g,p])=>p)),{miss:g=>r.set(q,g)})}return {hostsCache:o,requester:n,timeouts:w,logger:m,algoliaAgent:T,baseHeaders:d,baseQueryParameters:h,hosts:a,request:u,requestsCache:e,responsesCache:r}}function K(){function a(o){return new Promise(d=>{let m=new XMLHttpRequest;m.open(o.method,o.url,!0),Object.keys(o.headers).forEach(n=>m.setRequestHeader(n,o.headers[n]));let h=(n,e)=>setTimeout(()=>{m.abort(),d({status:0,content:e,isTimedOut:!0});},n),T=h(o.connectTimeout,"Connection timeout"),w;m.onreadystatechange=()=>{m.readyState>m.OPENED&&w===void 0&&(clearTimeout(T),w=h(o.responseTimeout,"Socket timeout"));},m.onerror=()=>{m.status===0&&(clearTimeout(T),clearTimeout(w),d({content:m.responseText||"Network request failed",status:m.status,isTimedOut:!1}));},m.onload=()=>{clearTimeout(T),clearTimeout(w),d({content:m.responseText,status:m.status,isTimedOut:!1});},m.send(o.data);})}return {send:a}}var x="1.7.0",A=["eu","us"];function le(a){return [{url:"data.{region}.algolia.com".replace("{region}",a),accept:"readWrite",protocol:"https"}]}function Pe(a){return a.type==="onDemand"}function qe(a){return a.type==="schedule"}function ge(a){return a.type==="subscription"}function Y({appId:a,apiKey:o,authMode:d,algoliaAgents:m,region:h,...T}){let w=$(a,o,d),n=X({hosts:le(h),...T,algoliaAgent:j({algoliaAgents:m,client:"Ingestion",version:x}),baseHeaders:{"content-type":"text/plain",...w.headers(),...T.baseHeaders},baseQueryParameters:{...w.queryParameters(),...T.baseQueryParameters}});return {transporter:n,appId:a,clearCache(){return Promise.all([n.requestsCache.clear(),n.responsesCache.clear()]).then(()=>{})},get _ua(){return n.algoliaAgent.value},addAlgoliaAgent(e,r){n.algoliaAgent.add({segment:e,version:r});},setClientApiKey({apiKey:e}){!d||d==="WithinHeaders"?n.baseHeaders["x-algolia-api-key"]=e:n.baseQueryParameters["x-algolia-api-key"]=e;},createAuthentication(e,r){if(!e)throw new Error("Parameter `authenticationCreate` is required when calling `createAuthentication`.");if(!e.type)throw new Error("Parameter `authenticationCreate.type` is required when calling `createAuthentication`.");if(!e.name)throw new Error("Parameter `authenticationCreate.name` is required when calling `createAuthentication`.");if(!e.input)throw new Error("Parameter `authenticationCreate.input` is required when calling `createAuthentication`.");let t={method:"POST",path:"/1/authentications",queryParameters:{},headers:{},data:e};return n.request(t,r)},createDestination(e,r){if(!e)throw new Error("Parameter `destinationCreate` is required when calling `createDestination`.");if(!e.type)throw new Error("Parameter `destinationCreate.type` is required when calling `createDestination`.");if(!e.name)throw new Error("Parameter `destinationCreate.name` is required when calling `createDestination`.");if(!e.input)throw new Error("Parameter `destinationCreate.input` is required when calling `createDestination`.");let t={method:"POST",path:"/1/destinations",queryParameters:{},headers:{},data:e};return n.request(t,r)},createSource(e,r){if(!e)throw new Error("Parameter `sourceCreate` is required when calling `createSource`.");if(!e.type)throw new Error("Parameter `sourceCreate.type` is required when calling `createSource`.");if(!e.name)throw new Error("Parameter `sourceCreate.name` is required when calling `createSource`.");let t={method:"POST",path:"/1/sources",queryParameters:{},headers:{},data:e};return n.request(t,r)},createTask(e,r){if(!e)throw new Error("Parameter `taskCreate` is required when calling `createTask`.");if(!e.sourceID)throw new Error("Parameter `taskCreate.sourceID` is required when calling `createTask`.");if(!e.destinationID)throw new Error("Parameter `taskCreate.destinationID` is required when calling `createTask`.");if(!e.action)throw new Error("Parameter `taskCreate.action` is required when calling `createTask`.");let t={method:"POST",path:"/2/tasks",queryParameters:{},headers:{},data:e};return n.request(t,r)},createTaskV1(e,r){if(!e)throw new Error("Parameter `taskCreate` is required when calling `createTaskV1`.");if(!e.sourceID)throw new Error("Parameter `taskCreate.sourceID` is required when calling `createTaskV1`.");if(!e.destinationID)throw new Error("Parameter `taskCreate.destinationID` is required when calling `createTaskV1`.");if(!e.trigger)throw new Error("Parameter `taskCreate.trigger` is required when calling `createTaskV1`.");if(!e.action)throw new Error("Parameter `taskCreate.action` is required when calling `createTaskV1`.");let t={method:"POST",path:"/1/tasks",queryParameters:{},headers:{},data:e};return n.request(t,r)},createTransformation(e,r){if(!e)throw new Error("Parameter `transformationCreate` is required when calling `createTransformation`.");if(!e.code)throw new Error("Parameter `transformationCreate.code` is required when calling `createTransformation`.");if(!e.name)throw new Error("Parameter `transformationCreate.name` is required when calling `createTransformation`.");let t={method:"POST",path:"/1/transformations",queryParameters:{},headers:{},data:e};return n.request(t,r)},customDelete({path:e,parameters:r},s){if(!e)throw new Error("Parameter `path` is required when calling `customDelete`.");let c={method:"DELETE",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{}};return n.request(c,s)},customGet({path:e,parameters:r},s){if(!e)throw new Error("Parameter `path` is required when calling `customGet`.");let c={method:"GET",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{}};return n.request(c,s)},customPost({path:e,parameters:r,body:s},i){if(!e)throw new Error("Parameter `path` is required when calling `customPost`.");let f={method:"POST",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{},data:s||{}};return n.request(f,i)},customPut({path:e,parameters:r,body:s},i){if(!e)throw new Error("Parameter `path` is required when calling `customPut`.");let f={method:"PUT",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{},data:s||{}};return n.request(f,i)},deleteAuthentication({authenticationID:e},r){if(!e)throw new Error("Parameter `authenticationID` is required when calling `deleteAuthentication`.");let t={method:"DELETE",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteDestination({destinationID:e},r){if(!e)throw new Error("Parameter `destinationID` is required when calling `deleteDestination`.");let t={method:"DELETE",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteSource({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `deleteSource`.");let t={method:"DELETE",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `deleteTask`.");let t={method:"DELETE",path:"/2/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `deleteTaskV1`.");let t={method:"DELETE",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteTransformation({transformationID:e},r){if(!e)throw new Error("Parameter `transformationID` is required when calling `deleteTransformation`.");let t={method:"DELETE",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},disableTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `disableTask`.");let t={method:"PUT",path:"/2/tasks/{taskID}/disable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},disableTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `disableTaskV1`.");let t={method:"PUT",path:"/1/tasks/{taskID}/disable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},enableTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `enableTask`.");let t={method:"PUT",path:"/2/tasks/{taskID}/enable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},enableTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `enableTaskV1`.");let t={method:"PUT",path:"/1/tasks/{taskID}/enable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getAuthentication({authenticationID:e},r){if(!e)throw new Error("Parameter `authenticationID` is required when calling `getAuthentication`.");let t={method:"GET",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getDestination({destinationID:e},r){if(!e)throw new Error("Parameter `destinationID` is required when calling `getDestination`.");let t={method:"GET",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getEvent({runID:e,eventID:r},s){if(!e)throw new Error("Parameter `runID` is required when calling `getEvent`.");if(!r)throw new Error("Parameter `eventID` is required when calling `getEvent`.");let c={method:"GET",path:"/1/runs/{runID}/events/{eventID}".replace("{runID}",encodeURIComponent(e)).replace("{eventID}",encodeURIComponent(r)),queryParameters:{},headers:{}};return n.request(c,s)},getRun({runID:e},r){if(!e)throw new Error("Parameter `runID` is required when calling `getRun`.");let t={method:"GET",path:"/1/runs/{runID}".replace("{runID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getSource({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `getSource`.");let t={method:"GET",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `getTask`.");let t={method:"GET",path:"/2/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `getTaskV1`.");let t={method:"GET",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getTransformation({transformationID:e},r){if(!e)throw new Error("Parameter `transformationID` is required when calling `getTransformation`.");let t={method:"GET",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},listAuthentications({itemsPerPage:e,page:r,type:s,platform:i,sort:u,order:t}={},c=void 0){let f="/1/authentications",P={},l={};e!==void 0&&(l.itemsPerPage=e.toString()),r!==void 0&&(l.page=r.toString()),s!==void 0&&(l.type=s.toString()),i!==void 0&&(l.platform=i.toString()),u!==void 0&&(l.sort=u.toString()),t!==void 0&&(l.order=t.toString());let q={method:"GET",path:f,queryParameters:l,headers:P};return n.request(q,c)},listDestinations({itemsPerPage:e,page:r,type:s,authenticationID:i,transformationID:u,sort:t,order:c}={},f=void 0){let P="/1/destinations",l={},q={};e!==void 0&&(q.itemsPerPage=e.toString()),r!==void 0&&(q.page=r.toString()),s!==void 0&&(q.type=s.toString()),i!==void 0&&(q.authenticationID=i.toString()),u!==void 0&&(q.transformationID=u.toString()),t!==void 0&&(q.sort=t.toString()),c!==void 0&&(q.order=c.toString());let g={method:"GET",path:P,queryParameters:q,headers:l};return n.request(g,f)},listEvents({runID:e,itemsPerPage:r,page:s,status:i,type:u,sort:t,order:c,startDate:f,endDate:P},l){if(!e)throw new Error("Parameter `runID` is required when calling `listEvents`.");let q="/1/runs/{runID}/events".replace("{runID}",encodeURIComponent(e)),g={},p={};r!==void 0&&(p.itemsPerPage=r.toString()),s!==void 0&&(p.page=s.toString()),i!==void 0&&(p.status=i.toString()),u!==void 0&&(p.type=u.toString()),t!==void 0&&(p.sort=t.toString()),c!==void 0&&(p.order=c.toString()),f!==void 0&&(p.startDate=f.toString()),P!==void 0&&(p.endDate=P.toString());let R={method:"GET",path:q,queryParameters:p,headers:g};return n.request(R,l)},listRuns({itemsPerPage:e,page:r,status:s,type:i,taskID:u,sort:t,order:c,startDate:f,endDate:P}={},l=void 0){let q="/1/runs",g={},p={};e!==void 0&&(p.itemsPerPage=e.toString()),r!==void 0&&(p.page=r.toString()),s!==void 0&&(p.status=s.toString()),i!==void 0&&(p.type=i.toString()),u!==void 0&&(p.taskID=u.toString()),t!==void 0&&(p.sort=t.toString()),c!==void 0&&(p.order=c.toString()),f!==void 0&&(p.startDate=f.toString()),P!==void 0&&(p.endDate=P.toString());let R={method:"GET",path:q,queryParameters:p,headers:g};return n.request(R,l)},listSources({itemsPerPage:e,page:r,type:s,authenticationID:i,sort:u,order:t}={},c=void 0){let f="/1/sources",P={},l={};e!==void 0&&(l.itemsPerPage=e.toString()),r!==void 0&&(l.page=r.toString()),s!==void 0&&(l.type=s.toString()),i!==void 0&&(l.authenticationID=i.toString()),u!==void 0&&(l.sort=u.toString()),t!==void 0&&(l.order=t.toString());let q={method:"GET",path:f,queryParameters:l,headers:P};return n.request(q,c)},listTasks({itemsPerPage:e,page:r,action:s,enabled:i,sourceID:u,destinationID:t,triggerType:c,sort:f,order:P}={},l=void 0){let q="/2/tasks",g={},p={};e!==void 0&&(p.itemsPerPage=e.toString()),r!==void 0&&(p.page=r.toString()),s!==void 0&&(p.action=s.toString()),i!==void 0&&(p.enabled=i.toString()),u!==void 0&&(p.sourceID=u.toString()),t!==void 0&&(p.destinationID=t.toString()),c!==void 0&&(p.triggerType=c.toString()),f!==void 0&&(p.sort=f.toString()),P!==void 0&&(p.order=P.toString());let R={method:"GET",path:q,queryParameters:p,headers:g};return n.request(R,l)},listTasksV1({itemsPerPage:e,page:r,action:s,enabled:i,sourceID:u,destinationID:t,triggerType:c,sort:f,order:P}={},l=void 0){let q="/1/tasks",g={},p={};e!==void 0&&(p.itemsPerPage=e.toString()),r!==void 0&&(p.page=r.toString()),s!==void 0&&(p.action=s.toString()),i!==void 0&&(p.enabled=i.toString()),u!==void 0&&(p.sourceID=u.toString()),t!==void 0&&(p.destinationID=t.toString()),c!==void 0&&(p.triggerType=c.toString()),f!==void 0&&(p.sort=f.toString()),P!==void 0&&(p.order=P.toString());let R={method:"GET",path:q,queryParameters:p,headers:g};return n.request(R,l)},listTransformations({itemsPerPage:e,page:r,sort:s,order:i}={},u=void 0){let t="/1/transformations",c={},f={};e!==void 0&&(f.itemsPerPage=e.toString()),r!==void 0&&(f.page=r.toString()),s!==void 0&&(f.sort=s.toString()),i!==void 0&&(f.order=i.toString());let P={method:"GET",path:t,queryParameters:f,headers:c};return n.request(P,u)},pushTask({taskID:e,pushTaskPayload:r},s){if(!e)throw new Error("Parameter `taskID` is required when calling `pushTask`.");if(!r)throw new Error("Parameter `pushTaskPayload` is required when calling `pushTask`.");if(!r.action)throw new Error("Parameter `pushTaskPayload.action` is required when calling `pushTask`.");if(!r.records)throw new Error("Parameter `pushTaskPayload.records` is required when calling `pushTask`.");let c={method:"POST",path:"/2/tasks/{taskID}/push".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},runSource({sourceID:e,runSourcePayload:r},s){if(!e)throw new Error("Parameter `sourceID` is required when calling `runSource`.");let c={method:"POST",path:"/1/sources/{sourceID}/run".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r||{}};return n.request(c,s)},runTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `runTask`.");let t={method:"POST",path:"/2/tasks/{taskID}/run".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},runTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `runTaskV1`.");let t={method:"POST",path:"/1/tasks/{taskID}/run".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},searchAuthentications(e,r){if(!e)throw new Error("Parameter `authenticationSearch` is required when calling `searchAuthentications`.");if(!e.authenticationIDs)throw new Error("Parameter `authenticationSearch.authenticationIDs` is required when calling `searchAuthentications`.");let t={method:"POST",path:"/1/authentications/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchDestinations(e,r){if(!e)throw new Error("Parameter `destinationSearch` is required when calling `searchDestinations`.");if(!e.destinationIDs)throw new Error("Parameter `destinationSearch.destinationIDs` is required when calling `searchDestinations`.");let t={method:"POST",path:"/1/destinations/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchSources(e,r){if(!e)throw new Error("Parameter `sourceSearch` is required when calling `searchSources`.");if(!e.sourceIDs)throw new Error("Parameter `sourceSearch.sourceIDs` is required when calling `searchSources`.");let t={method:"POST",path:"/1/sources/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchTasks(e,r){if(!e)throw new Error("Parameter `taskSearch` is required when calling `searchTasks`.");if(!e.taskIDs)throw new Error("Parameter `taskSearch.taskIDs` is required when calling `searchTasks`.");let t={method:"POST",path:"/2/tasks/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchTasksV1(e,r){if(!e)throw new Error("Parameter `taskSearch` is required when calling `searchTasksV1`.");if(!e.taskIDs)throw new Error("Parameter `taskSearch.taskIDs` is required when calling `searchTasksV1`.");let t={method:"POST",path:"/1/tasks/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchTransformations(e,r){if(!e)throw new Error("Parameter `transformationSearch` is required when calling `searchTransformations`.");if(!e.transformationIDs)throw new Error("Parameter `transformationSearch.transformationIDs` is required when calling `searchTransformations`.");let t={method:"POST",path:"/1/transformations/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},triggerDockerSourceDiscover({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `triggerDockerSourceDiscover`.");let t={method:"POST",path:"/1/sources/{sourceID}/discover".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},tryTransformation(e,r){if(!e)throw new Error("Parameter `transformationTry` is required when calling `tryTransformation`.");if(!e.code)throw new Error("Parameter `transformationTry.code` is required when calling `tryTransformation`.");if(!e.sampleRecord)throw new Error("Parameter `transformationTry.sampleRecord` is required when calling `tryTransformation`.");let t={method:"POST",path:"/1/transformations/try",queryParameters:{},headers:{},data:e};return n.request(t,r)},tryTransformationBeforeUpdate({transformationID:e,transformationTry:r},s){if(!e)throw new Error("Parameter `transformationID` is required when calling `tryTransformationBeforeUpdate`.");if(!r)throw new Error("Parameter `transformationTry` is required when calling `tryTransformationBeforeUpdate`.");if(!r.code)throw new Error("Parameter `transformationTry.code` is required when calling `tryTransformationBeforeUpdate`.");if(!r.sampleRecord)throw new Error("Parameter `transformationTry.sampleRecord` is required when calling `tryTransformationBeforeUpdate`.");let c={method:"POST",path:"/1/transformations/{transformationID}/try".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateAuthentication({authenticationID:e,authenticationUpdate:r},s){if(!e)throw new Error("Parameter `authenticationID` is required when calling `updateAuthentication`.");if(!r)throw new Error("Parameter `authenticationUpdate` is required when calling `updateAuthentication`.");let c={method:"PATCH",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateDestination({destinationID:e,destinationUpdate:r},s){if(!e)throw new Error("Parameter `destinationID` is required when calling `updateDestination`.");if(!r)throw new Error("Parameter `destinationUpdate` is required when calling `updateDestination`.");let c={method:"PATCH",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateSource({sourceID:e,sourceUpdate:r},s){if(!e)throw new Error("Parameter `sourceID` is required when calling `updateSource`.");if(!r)throw new Error("Parameter `sourceUpdate` is required when calling `updateSource`.");let c={method:"PATCH",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateTask({taskID:e,taskUpdate:r},s){if(!e)throw new Error("Parameter `taskID` is required when calling `updateTask`.");if(!r)throw new Error("Parameter `taskUpdate` is required when calling `updateTask`.");let c={method:"PATCH",path:"/2/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateTaskV1({taskID:e,taskUpdate:r},s){if(!e)throw new Error("Parameter `taskID` is required when calling `updateTaskV1`.");if(!r)throw new Error("Parameter `taskUpdate` is required when calling `updateTaskV1`.");let c={method:"PATCH",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateTransformation({transformationID:e,transformationCreate:r},s){if(!e)throw new Error("Parameter `transformationID` is required when calling `updateTransformation`.");if(!r)throw new Error("Parameter `transformationCreate` is required when calling `updateTransformation`.");if(!r.code)throw new Error("Parameter `transformationCreate.code` is required when calling `updateTransformation`.");if(!r.name)throw new Error("Parameter `transformationCreate.name` is required when calling `updateTransformation`.");let c={method:"PUT",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},validateSource(e,r=void 0){let t={method:"POST",path:"/1/sources/validate",queryParameters:{},headers:{},data:e||{}};return n.request(t,r)},validateSourceBeforeUpdate({sourceID:e,sourceUpdate:r},s){if(!e)throw new Error("Parameter `sourceID` is required when calling `validateSourceBeforeUpdate`.");if(!r)throw new Error("Parameter `sourceUpdate` is required when calling `validateSourceBeforeUpdate`.");let c={method:"POST",path:"/1/sources/{sourceID}/validate".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)}}}function ls(a,o,d,m){if(!a||typeof a!="string")throw new Error("`appId` is missing.");if(!o||typeof o!="string")throw new Error("`apiKey` is missing.");if(!d||d&&(typeof d!="string"||!A.includes(d)))throw new Error(`\`region\` is required and must be one of the following: ${A.join(", ")}`);return Y({appId:a,apiKey:o,region:d,timeouts:{connect:N,read:W,write:B},logger:J(),requester:K(),algoliaAgents:[{segment:"Browser"}],authMode:"WithinQueryParameters",responsesCache:k(),requestsCache:k({serializable:!1}),hostsCache:S({caches:[_({key:`${x}-${a}`}),k()]}),...m})}
+	function V(){function a(o){return new Promise(d=>{let m=new XMLHttpRequest;m.open(o.method,o.url,!0),Object.keys(o.headers).forEach(n=>m.setRequestHeader(n,o.headers[n]));let h=(n,e)=>setTimeout(()=>{m.abort(),d({status:0,content:e,isTimedOut:!0});},n),T=h(o.connectTimeout,"Connection timeout"),y;m.onreadystatechange=()=>{m.readyState>m.OPENED&&y===void 0&&(clearTimeout(T),y=h(o.responseTimeout,"Socket timeout"));},m.onerror=()=>{m.status===0&&(clearTimeout(T),clearTimeout(y),d({content:m.responseText||"Network request failed",status:m.status,isTimedOut:!1}));},m.onload=()=>{clearTimeout(T),clearTimeout(y),d({content:m.responseText,status:m.status,isTimedOut:!1});},m.send(o.data);})}return {send:a}}function N(a){let o,d=`algolia-client-js-${a.key}`;function m(){return o===void 0&&(o=a.localStorage||window.localStorage),o}function h(){return JSON.parse(m().getItem(d)||"{}")}function T(n){m().setItem(d,JSON.stringify(n));}function y(){let n=a.timeToLive?a.timeToLive*1e3:null,e=h(),r=Object.fromEntries(Object.entries(e).filter(([,i])=>i.timestamp!==void 0));if(T(r),!n)return;let s=Object.fromEntries(Object.entries(r).filter(([,i])=>{let u=new Date().getTime();return !(i.timestamp+n<u)}));T(s);}return {get(n,e,r={miss:()=>Promise.resolve()}){return Promise.resolve().then(()=>(y(),h()[JSON.stringify(n)])).then(s=>Promise.all([s?s.value:e(),s!==void 0])).then(([s,i])=>Promise.all([s,i||r.miss(s)])).then(([s])=>s)},set(n,e){return Promise.resolve().then(()=>{let r=h();return r[JSON.stringify(n)]={timestamp:new Date().getTime(),value:e},m().setItem(d,JSON.stringify(r)),e})},delete(n){return Promise.resolve().then(()=>{let e=h();delete e[JSON.stringify(n)],m().setItem(d,JSON.stringify(e));})},clear(){return Promise.resolve().then(()=>{m().removeItem(d);})}}}function ee(){return {get(a,o,d={miss:()=>Promise.resolve()}){return o().then(h=>Promise.all([h,d.miss(h)])).then(([h])=>h)},set(a,o){return Promise.resolve(o)},delete(a){return Promise.resolve()},clear(){return Promise.resolve()}}}function S(a){let o=[...a.caches],d=o.shift();return d===void 0?ee():{get(m,h,T={miss:()=>Promise.resolve()}){return d.get(m,h,T).catch(()=>S({caches:o}).get(m,h,T))},set(m,h){return d.set(m,h).catch(()=>S({caches:o}).set(m,h))},delete(m){return d.delete(m).catch(()=>S({caches:o}).delete(m))},clear(){return d.clear().catch(()=>S({caches:o}).clear())}}}function k(a={serializable:!0}){let o={};return {get(d,m,h={miss:()=>Promise.resolve()}){let T=JSON.stringify(d);if(T in o)return Promise.resolve(a.serializable?JSON.parse(o[T]):o[T]);let y=m();return y.then(n=>h.miss(n)).then(()=>y)},set(d,m){return o[JSON.stringify(d)]=a.serializable?JSON.stringify(m):m,Promise.resolve(m)},delete(d){return delete o[JSON.stringify(d)],Promise.resolve()},clear(){return o={},Promise.resolve()}}}var W=1e3,B=2e3,$=3e4;function re(a){let o={value:`Algolia for JavaScript (${a})`,add(d){let m=`; ${d.segment}${d.version!==void 0?` (${d.version})`:""}`;return o.value.indexOf(m)===-1&&(o.value=`${o.value}${m}`),o}};return o}function j(a,o,d="WithinHeaders"){let m={"x-algolia-api-key":o,"x-algolia-application-id":a};return {headers(){return d==="WithinHeaders"?m:{}},queryParameters(){return d==="WithinQueryParameters"?m:{}}}}function J({algoliaAgents:a,client:o,version:d}){let m=re(d).add({segment:o,version:d});return a.forEach(h=>m.add(h)),m}function M(){return {debug(a,o){return Promise.resolve()},info(a,o){return Promise.resolve()},error(a,o){return Promise.resolve()}}}var G=2*60*1e3;function _(a,o="up"){let d=Date.now();function m(){return o==="up"||Date.now()-d>G}function h(){return o==="timed out"&&Date.now()-d<=G}return {...a,status:o,lastUpdate:d,isUp:m,isTimedOut:h}}var z=class extends Error{name="AlgoliaError";constructor(a,o){super(a),o&&(this.name=o);}},F=class extends z{stackTrace;constructor(a,o,d){super(a,d),this.stackTrace=o;}},te=class extends F{constructor(a){super("Unreachable hosts - your application id may be incorrect. If the error persists, please reach out to the Algolia Support team: https://alg.li/support.",a,"RetryError");}},U=class extends F{status;constructor(a,o,d,m="ApiError"){super(a,d,m),this.status=o;}},se=class extends z{response;constructor(a,o){super(a,"DeserializationError"),this.response=o;}},oe=class extends U{error;constructor(a,o,d,m){super(a,o,m,"DetailedApiError"),this.error=d;}};function ae(a,o,d){let m=ne(d),h=`${a.protocol}://${a.url}${a.port?`:${a.port}`:""}/${o.charAt(0)==="/"?o.substring(1):o}`;return m.length&&(h+=`?${m}`),h}function ne(a){return Object.keys(a).filter(o=>a[o]!==void 0).sort().map(o=>`${o}=${encodeURIComponent(Object.prototype.toString.call(a[o])==="[object Array]"?a[o].join(","):a[o]).replace(/\+/g,"%20")}`).join("&")}function ie(a,o){if(a.method==="GET"||a.data===void 0&&o.data===void 0)return;let d=Array.isArray(a.data)?a.data:{...a.data,...o.data};return JSON.stringify(d)}function ue(a,o,d){let m={Accept:"application/json",...a,...o,...d},h={};return Object.keys(m).forEach(T=>{let y=m[T];h[T.toLowerCase()]=y;}),h}function me(a){try{return JSON.parse(a.content)}catch(o){throw new se(o.message,a)}}function ce({content:a,status:o},d){try{let m=JSON.parse(a);return "error"in m?new oe(m.message,o,m.error,d):new U(m.message,o,d)}catch{}return new U(a,o,d)}function de({isTimedOut:a,status:o}){return !a&&~~o===0}function pe({isTimedOut:a,status:o}){return a||de({isTimedOut:a,status:o})||~~(o/100)!==2&&~~(o/100)!==4}function he({status:a}){return ~~(a/100)===2}function fe(a){return a.map(o=>X(o))}function X(a){let o=a.request.headers["x-algolia-api-key"]?{"x-algolia-api-key":"*****"}:{};return {...a,request:{...a.request,headers:{...a.request.headers,...o}}}}function K({hosts:a,hostsCache:o,baseHeaders:d,logger:m,baseQueryParameters:h,algoliaAgent:T,timeouts:y,requester:n,requestsCache:e,responsesCache:r}){async function s(t){let c=await Promise.all(t.map(g=>o.get(g,()=>Promise.resolve(_(g))))),f=c.filter(g=>g.isUp()),P=c.filter(g=>g.isTimedOut()),l=[...f,...P];return {hosts:l.length>0?l:t,getTimeout(g,p){return (P.length===0&&g===0?1:P.length+3+g)*p}}}async function i(t,c,f=!0){let P=[],l=ie(t,c),q=ue(d,t.headers,c.headers),g=t.method==="GET"?{...t.data,...c.data}:{},p={...h,...t.queryParameters,...g};if(T.value&&(p["x-algolia-agent"]=T.value),c&&c.queryParameters)for(let w of Object.keys(c.queryParameters))!c.queryParameters[w]||Object.prototype.toString.call(c.queryParameters[w])==="[object Object]"?p[w]=c.queryParameters[w]:p[w]=c.queryParameters[w].toString();let R=0,v=async(w,I)=>{let D=w.pop();if(D===void 0)throw new te(fe(P));let O={...y,...c.timeouts},b={data:l,headers:q,method:t.method,url:ae(D,t.path,p),connectTimeout:I(R,O.connect),responseTimeout:I(R,f?O.read:O.write)},Q=C=>{let L={request:b,response:C,host:D,triesLeft:w.length};return P.push(L),L},E=await n.send(b);if(pe(E)){let C=Q(E);return E.isTimedOut&&R++,m.info("Retryable failure",X(C)),await o.set(D,_(D,E.isTimedOut?"timed out":"down")),v(w,I)}if(he(E))return me(E);throw Q(E),ce(E,P)},Z=a.filter(w=>w.accept==="readWrite"||(f?w.accept==="read":w.accept==="write")),H=await s(Z);return v([...H.hosts].reverse(),H.getTimeout)}function u(t,c={}){let f=t.useReadTransporter||t.method==="GET";if(!f)return i(t,c,f);let P=()=>i(t,c);if((c.cacheable||t.cacheable)!==!0)return P();let q={request:t,requestOptions:c,transporter:{queryParameters:h,headers:d}};return r.get(q,()=>e.get(q,()=>e.set(q,P()).then(g=>Promise.all([e.delete(q),g]),g=>Promise.all([e.delete(q),Promise.reject(g)])).then(([g,p])=>p)),{miss:g=>r.set(q,g)})}return {hostsCache:o,requester:n,timeouts:y,logger:m,algoliaAgent:T,baseHeaders:d,baseQueryParameters:h,hosts:a,request:u,requestsCache:e,responsesCache:r}}var x="1.8.0",A=["eu","us"];function le(a){return [{url:"data.{region}.algolia.com".replace("{region}",a),accept:"readWrite",protocol:"https"}]}function Pe(a){return a.type==="onDemand"}function qe(a){return a.type==="schedule"}function ge(a){return a.type==="subscription"}function Y({appId:a,apiKey:o,authMode:d,algoliaAgents:m,region:h,...T}){let y=j(a,o,d),n=K({hosts:le(h),...T,algoliaAgent:J({algoliaAgents:m,client:"Ingestion",version:x}),baseHeaders:{"content-type":"text/plain",...y.headers(),...T.baseHeaders},baseQueryParameters:{...y.queryParameters(),...T.baseQueryParameters}});return {transporter:n,appId:a,clearCache(){return Promise.all([n.requestsCache.clear(),n.responsesCache.clear()]).then(()=>{})},get _ua(){return n.algoliaAgent.value},addAlgoliaAgent(e,r){n.algoliaAgent.add({segment:e,version:r});},setClientApiKey({apiKey:e}){!d||d==="WithinHeaders"?n.baseHeaders["x-algolia-api-key"]=e:n.baseQueryParameters["x-algolia-api-key"]=e;},createAuthentication(e,r){if(!e)throw new Error("Parameter `authenticationCreate` is required when calling `createAuthentication`.");if(!e.type)throw new Error("Parameter `authenticationCreate.type` is required when calling `createAuthentication`.");if(!e.name)throw new Error("Parameter `authenticationCreate.name` is required when calling `createAuthentication`.");if(!e.input)throw new Error("Parameter `authenticationCreate.input` is required when calling `createAuthentication`.");let t={method:"POST",path:"/1/authentications",queryParameters:{},headers:{},data:e};return n.request(t,r)},createDestination(e,r){if(!e)throw new Error("Parameter `destinationCreate` is required when calling `createDestination`.");if(!e.type)throw new Error("Parameter `destinationCreate.type` is required when calling `createDestination`.");if(!e.name)throw new Error("Parameter `destinationCreate.name` is required when calling `createDestination`.");if(!e.input)throw new Error("Parameter `destinationCreate.input` is required when calling `createDestination`.");let t={method:"POST",path:"/1/destinations",queryParameters:{},headers:{},data:e};return n.request(t,r)},createSource(e,r){if(!e)throw new Error("Parameter `sourceCreate` is required when calling `createSource`.");if(!e.type)throw new Error("Parameter `sourceCreate.type` is required when calling `createSource`.");if(!e.name)throw new Error("Parameter `sourceCreate.name` is required when calling `createSource`.");let t={method:"POST",path:"/1/sources",queryParameters:{},headers:{},data:e};return n.request(t,r)},createTask(e,r){if(!e)throw new Error("Parameter `taskCreate` is required when calling `createTask`.");if(!e.sourceID)throw new Error("Parameter `taskCreate.sourceID` is required when calling `createTask`.");if(!e.destinationID)throw new Error("Parameter `taskCreate.destinationID` is required when calling `createTask`.");if(!e.action)throw new Error("Parameter `taskCreate.action` is required when calling `createTask`.");let t={method:"POST",path:"/2/tasks",queryParameters:{},headers:{},data:e};return n.request(t,r)},createTaskV1(e,r){if(!e)throw new Error("Parameter `taskCreate` is required when calling `createTaskV1`.");if(!e.sourceID)throw new Error("Parameter `taskCreate.sourceID` is required when calling `createTaskV1`.");if(!e.destinationID)throw new Error("Parameter `taskCreate.destinationID` is required when calling `createTaskV1`.");if(!e.trigger)throw new Error("Parameter `taskCreate.trigger` is required when calling `createTaskV1`.");if(!e.action)throw new Error("Parameter `taskCreate.action` is required when calling `createTaskV1`.");let t={method:"POST",path:"/1/tasks",queryParameters:{},headers:{},data:e};return n.request(t,r)},createTransformation(e,r){if(!e)throw new Error("Parameter `transformationCreate` is required when calling `createTransformation`.");if(!e.code)throw new Error("Parameter `transformationCreate.code` is required when calling `createTransformation`.");if(!e.name)throw new Error("Parameter `transformationCreate.name` is required when calling `createTransformation`.");let t={method:"POST",path:"/1/transformations",queryParameters:{},headers:{},data:e};return n.request(t,r)},customDelete({path:e,parameters:r},s){if(!e)throw new Error("Parameter `path` is required when calling `customDelete`.");let c={method:"DELETE",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{}};return n.request(c,s)},customGet({path:e,parameters:r},s){if(!e)throw new Error("Parameter `path` is required when calling `customGet`.");let c={method:"GET",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{}};return n.request(c,s)},customPost({path:e,parameters:r,body:s},i){if(!e)throw new Error("Parameter `path` is required when calling `customPost`.");let f={method:"POST",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{},data:s||{}};return n.request(f,i)},customPut({path:e,parameters:r,body:s},i){if(!e)throw new Error("Parameter `path` is required when calling `customPut`.");let f={method:"PUT",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{},data:s||{}};return n.request(f,i)},deleteAuthentication({authenticationID:e},r){if(!e)throw new Error("Parameter `authenticationID` is required when calling `deleteAuthentication`.");let t={method:"DELETE",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteDestination({destinationID:e},r){if(!e)throw new Error("Parameter `destinationID` is required when calling `deleteDestination`.");let t={method:"DELETE",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteSource({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `deleteSource`.");let t={method:"DELETE",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `deleteTask`.");let t={method:"DELETE",path:"/2/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `deleteTaskV1`.");let t={method:"DELETE",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},deleteTransformation({transformationID:e},r){if(!e)throw new Error("Parameter `transformationID` is required when calling `deleteTransformation`.");let t={method:"DELETE",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},disableTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `disableTask`.");let t={method:"PUT",path:"/2/tasks/{taskID}/disable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},disableTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `disableTaskV1`.");let t={method:"PUT",path:"/1/tasks/{taskID}/disable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},enableTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `enableTask`.");let t={method:"PUT",path:"/2/tasks/{taskID}/enable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},enableTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `enableTaskV1`.");let t={method:"PUT",path:"/1/tasks/{taskID}/enable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getAuthentication({authenticationID:e},r){if(!e)throw new Error("Parameter `authenticationID` is required when calling `getAuthentication`.");let t={method:"GET",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getDestination({destinationID:e},r){if(!e)throw new Error("Parameter `destinationID` is required when calling `getDestination`.");let t={method:"GET",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getEvent({runID:e,eventID:r},s){if(!e)throw new Error("Parameter `runID` is required when calling `getEvent`.");if(!r)throw new Error("Parameter `eventID` is required when calling `getEvent`.");let c={method:"GET",path:"/1/runs/{runID}/events/{eventID}".replace("{runID}",encodeURIComponent(e)).replace("{eventID}",encodeURIComponent(r)),queryParameters:{},headers:{}};return n.request(c,s)},getRun({runID:e},r){if(!e)throw new Error("Parameter `runID` is required when calling `getRun`.");let t={method:"GET",path:"/1/runs/{runID}".replace("{runID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getSource({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `getSource`.");let t={method:"GET",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `getTask`.");let t={method:"GET",path:"/2/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `getTaskV1`.");let t={method:"GET",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},getTransformation({transformationID:e},r){if(!e)throw new Error("Parameter `transformationID` is required when calling `getTransformation`.");let t={method:"GET",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},listAuthentications({itemsPerPage:e,page:r,type:s,platform:i,sort:u,order:t}={},c=void 0){let f="/1/authentications",P={},l={};e!==void 0&&(l.itemsPerPage=e.toString()),r!==void 0&&(l.page=r.toString()),s!==void 0&&(l.type=s.toString()),i!==void 0&&(l.platform=i.toString()),u!==void 0&&(l.sort=u.toString()),t!==void 0&&(l.order=t.toString());let q={method:"GET",path:f,queryParameters:l,headers:P};return n.request(q,c)},listDestinations({itemsPerPage:e,page:r,type:s,authenticationID:i,transformationID:u,sort:t,order:c}={},f=void 0){let P="/1/destinations",l={},q={};e!==void 0&&(q.itemsPerPage=e.toString()),r!==void 0&&(q.page=r.toString()),s!==void 0&&(q.type=s.toString()),i!==void 0&&(q.authenticationID=i.toString()),u!==void 0&&(q.transformationID=u.toString()),t!==void 0&&(q.sort=t.toString()),c!==void 0&&(q.order=c.toString());let g={method:"GET",path:P,queryParameters:q,headers:l};return n.request(g,f)},listEvents({runID:e,itemsPerPage:r,page:s,status:i,type:u,sort:t,order:c,startDate:f,endDate:P},l){if(!e)throw new Error("Parameter `runID` is required when calling `listEvents`.");let q="/1/runs/{runID}/events".replace("{runID}",encodeURIComponent(e)),g={},p={};r!==void 0&&(p.itemsPerPage=r.toString()),s!==void 0&&(p.page=s.toString()),i!==void 0&&(p.status=i.toString()),u!==void 0&&(p.type=u.toString()),t!==void 0&&(p.sort=t.toString()),c!==void 0&&(p.order=c.toString()),f!==void 0&&(p.startDate=f.toString()),P!==void 0&&(p.endDate=P.toString());let R={method:"GET",path:q,queryParameters:p,headers:g};return n.request(R,l)},listRuns({itemsPerPage:e,page:r,status:s,type:i,taskID:u,sort:t,order:c,startDate:f,endDate:P}={},l=void 0){let q="/1/runs",g={},p={};e!==void 0&&(p.itemsPerPage=e.toString()),r!==void 0&&(p.page=r.toString()),s!==void 0&&(p.status=s.toString()),i!==void 0&&(p.type=i.toString()),u!==void 0&&(p.taskID=u.toString()),t!==void 0&&(p.sort=t.toString()),c!==void 0&&(p.order=c.toString()),f!==void 0&&(p.startDate=f.toString()),P!==void 0&&(p.endDate=P.toString());let R={method:"GET",path:q,queryParameters:p,headers:g};return n.request(R,l)},listSources({itemsPerPage:e,page:r,type:s,authenticationID:i,sort:u,order:t}={},c=void 0){let f="/1/sources",P={},l={};e!==void 0&&(l.itemsPerPage=e.toString()),r!==void 0&&(l.page=r.toString()),s!==void 0&&(l.type=s.toString()),i!==void 0&&(l.authenticationID=i.toString()),u!==void 0&&(l.sort=u.toString()),t!==void 0&&(l.order=t.toString());let q={method:"GET",path:f,queryParameters:l,headers:P};return n.request(q,c)},listTasks({itemsPerPage:e,page:r,action:s,enabled:i,sourceID:u,destinationID:t,triggerType:c,sort:f,order:P}={},l=void 0){let q="/2/tasks",g={},p={};e!==void 0&&(p.itemsPerPage=e.toString()),r!==void 0&&(p.page=r.toString()),s!==void 0&&(p.action=s.toString()),i!==void 0&&(p.enabled=i.toString()),u!==void 0&&(p.sourceID=u.toString()),t!==void 0&&(p.destinationID=t.toString()),c!==void 0&&(p.triggerType=c.toString()),f!==void 0&&(p.sort=f.toString()),P!==void 0&&(p.order=P.toString());let R={method:"GET",path:q,queryParameters:p,headers:g};return n.request(R,l)},listTasksV1({itemsPerPage:e,page:r,action:s,enabled:i,sourceID:u,destinationID:t,triggerType:c,sort:f,order:P}={},l=void 0){let q="/1/tasks",g={},p={};e!==void 0&&(p.itemsPerPage=e.toString()),r!==void 0&&(p.page=r.toString()),s!==void 0&&(p.action=s.toString()),i!==void 0&&(p.enabled=i.toString()),u!==void 0&&(p.sourceID=u.toString()),t!==void 0&&(p.destinationID=t.toString()),c!==void 0&&(p.triggerType=c.toString()),f!==void 0&&(p.sort=f.toString()),P!==void 0&&(p.order=P.toString());let R={method:"GET",path:q,queryParameters:p,headers:g};return n.request(R,l)},listTransformations({itemsPerPage:e,page:r,sort:s,order:i}={},u=void 0){let t="/1/transformations",c={},f={};e!==void 0&&(f.itemsPerPage=e.toString()),r!==void 0&&(f.page=r.toString()),s!==void 0&&(f.sort=s.toString()),i!==void 0&&(f.order=i.toString());let P={method:"GET",path:t,queryParameters:f,headers:c};return n.request(P,u)},pushTask({taskID:e,pushTaskPayload:r},s){if(!e)throw new Error("Parameter `taskID` is required when calling `pushTask`.");if(!r)throw new Error("Parameter `pushTaskPayload` is required when calling `pushTask`.");if(!r.action)throw new Error("Parameter `pushTaskPayload.action` is required when calling `pushTask`.");if(!r.records)throw new Error("Parameter `pushTaskPayload.records` is required when calling `pushTask`.");let c={method:"POST",path:"/2/tasks/{taskID}/push".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},runSource({sourceID:e,runSourcePayload:r},s){if(!e)throw new Error("Parameter `sourceID` is required when calling `runSource`.");let c={method:"POST",path:"/1/sources/{sourceID}/run".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r||{}};return n.request(c,s)},runTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `runTask`.");let t={method:"POST",path:"/2/tasks/{taskID}/run".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},runTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `runTaskV1`.");let t={method:"POST",path:"/1/tasks/{taskID}/run".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},searchAuthentications(e,r){if(!e)throw new Error("Parameter `authenticationSearch` is required when calling `searchAuthentications`.");if(!e.authenticationIDs)throw new Error("Parameter `authenticationSearch.authenticationIDs` is required when calling `searchAuthentications`.");let t={method:"POST",path:"/1/authentications/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchDestinations(e,r){if(!e)throw new Error("Parameter `destinationSearch` is required when calling `searchDestinations`.");if(!e.destinationIDs)throw new Error("Parameter `destinationSearch.destinationIDs` is required when calling `searchDestinations`.");let t={method:"POST",path:"/1/destinations/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchSources(e,r){if(!e)throw new Error("Parameter `sourceSearch` is required when calling `searchSources`.");if(!e.sourceIDs)throw new Error("Parameter `sourceSearch.sourceIDs` is required when calling `searchSources`.");let t={method:"POST",path:"/1/sources/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchTasks(e,r){if(!e)throw new Error("Parameter `taskSearch` is required when calling `searchTasks`.");if(!e.taskIDs)throw new Error("Parameter `taskSearch.taskIDs` is required when calling `searchTasks`.");let t={method:"POST",path:"/2/tasks/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchTasksV1(e,r){if(!e)throw new Error("Parameter `taskSearch` is required when calling `searchTasksV1`.");if(!e.taskIDs)throw new Error("Parameter `taskSearch.taskIDs` is required when calling `searchTasksV1`.");let t={method:"POST",path:"/1/tasks/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},searchTransformations(e,r){if(!e)throw new Error("Parameter `transformationSearch` is required when calling `searchTransformations`.");if(!e.transformationIDs)throw new Error("Parameter `transformationSearch.transformationIDs` is required when calling `searchTransformations`.");let t={method:"POST",path:"/1/transformations/search",queryParameters:{},headers:{},data:e};return n.request(t,r)},triggerDockerSourceDiscover({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `triggerDockerSourceDiscover`.");let t={method:"POST",path:"/1/sources/{sourceID}/discover".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return n.request(t,r)},tryTransformation(e,r){if(!e)throw new Error("Parameter `transformationTry` is required when calling `tryTransformation`.");if(!e.code)throw new Error("Parameter `transformationTry.code` is required when calling `tryTransformation`.");if(!e.sampleRecord)throw new Error("Parameter `transformationTry.sampleRecord` is required when calling `tryTransformation`.");let t={method:"POST",path:"/1/transformations/try",queryParameters:{},headers:{},data:e};return n.request(t,r)},tryTransformationBeforeUpdate({transformationID:e,transformationTry:r},s){if(!e)throw new Error("Parameter `transformationID` is required when calling `tryTransformationBeforeUpdate`.");if(!r)throw new Error("Parameter `transformationTry` is required when calling `tryTransformationBeforeUpdate`.");if(!r.code)throw new Error("Parameter `transformationTry.code` is required when calling `tryTransformationBeforeUpdate`.");if(!r.sampleRecord)throw new Error("Parameter `transformationTry.sampleRecord` is required when calling `tryTransformationBeforeUpdate`.");let c={method:"POST",path:"/1/transformations/{transformationID}/try".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateAuthentication({authenticationID:e,authenticationUpdate:r},s){if(!e)throw new Error("Parameter `authenticationID` is required when calling `updateAuthentication`.");if(!r)throw new Error("Parameter `authenticationUpdate` is required when calling `updateAuthentication`.");let c={method:"PATCH",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateDestination({destinationID:e,destinationUpdate:r},s){if(!e)throw new Error("Parameter `destinationID` is required when calling `updateDestination`.");if(!r)throw new Error("Parameter `destinationUpdate` is required when calling `updateDestination`.");let c={method:"PATCH",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateSource({sourceID:e,sourceUpdate:r},s){if(!e)throw new Error("Parameter `sourceID` is required when calling `updateSource`.");if(!r)throw new Error("Parameter `sourceUpdate` is required when calling `updateSource`.");let c={method:"PATCH",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateTask({taskID:e,taskUpdate:r},s){if(!e)throw new Error("Parameter `taskID` is required when calling `updateTask`.");if(!r)throw new Error("Parameter `taskUpdate` is required when calling `updateTask`.");let c={method:"PATCH",path:"/2/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateTaskV1({taskID:e,taskUpdate:r},s){if(!e)throw new Error("Parameter `taskID` is required when calling `updateTaskV1`.");if(!r)throw new Error("Parameter `taskUpdate` is required when calling `updateTaskV1`.");let c={method:"PATCH",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},updateTransformation({transformationID:e,transformationCreate:r},s){if(!e)throw new Error("Parameter `transformationID` is required when calling `updateTransformation`.");if(!r)throw new Error("Parameter `transformationCreate` is required when calling `updateTransformation`.");if(!r.code)throw new Error("Parameter `transformationCreate.code` is required when calling `updateTransformation`.");if(!r.name)throw new Error("Parameter `transformationCreate.name` is required when calling `updateTransformation`.");let c={method:"PUT",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)},validateSource(e,r=void 0){let t={method:"POST",path:"/1/sources/validate",queryParameters:{},headers:{},data:e||{}};return n.request(t,r)},validateSourceBeforeUpdate({sourceID:e,sourceUpdate:r},s){if(!e)throw new Error("Parameter `sourceID` is required when calling `validateSourceBeforeUpdate`.");if(!r)throw new Error("Parameter `sourceUpdate` is required when calling `validateSourceBeforeUpdate`.");let c={method:"POST",path:"/1/sources/{sourceID}/validate".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return n.request(c,s)}}}function gs(a,o,d,m){if(!a||typeof a!="string")throw new Error("`appId` is missing.");if(!o||typeof o!="string")throw new Error("`apiKey` is missing.");if(!d||d&&(typeof d!="string"||!A.includes(d)))throw new Error(`\`region\` is required and must be one of the following: ${A.join(", ")}`);return Y({appId:a,apiKey:o,region:d,timeouts:{connect:W,read:B,write:$},logger:M(),requester:V(),algoliaAgents:[{segment:"Browser"}],authMode:"WithinQueryParameters",responsesCache:k(),requestsCache:k({serializable:!1}),hostsCache:S({caches:[N({key:`${x}-${a}`}),k()]}),...m})}
 
 	exports.apiClientVersion = x;
-	exports.ingestionClient = ls;
+	exports.ingestionClient = gs;
 	exports.isOnDemandTrigger = Pe;
@@ -13,0 +13,0 @@ exports.isScheduleTrigger = qe;

index.js

 // eslint-disable-next-line import/no-commonjs,import/extensions
-module.exports = require('./dist/builds/node.cjs');
+module.exports = require('./dist/builds/node.cjs');

model/action.ts

@@ -8,7 +8,7 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
   | 'addObject'
-  | 'clear'
-  | 'delete'
-  | 'deleteObject'
+  | 'updateObject'
   | 'partialUpdateObject'
   | 'partialUpdateObjectNoCreate'
-  | 'updateObject';
+  | 'deleteObject'
+  | 'delete'
+  | 'clear';

model/actionType.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type ActionType = 'append' | 'partial' | 'replace' | 'save';
+export type ActionType = 'replace' | 'save' | 'partial' | 'append';

model/authenticationSearch.ts

@@ -7,3 +7,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type AuthenticationSearch = {
-  authenticationIDs: string[];
+  authenticationIDs: Array<string>;
 };

model/authenticationSortKeys.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type AuthenticationSortKeys = 'createdAt' | 'name' | 'platform' | 'type' | 'updatedAt';
+export type AuthenticationSortKeys = 'name' | 'type' | 'platform' | 'updatedAt' | 'createdAt';

model/authenticationType.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type AuthenticationType = 'algolia' | 'algoliaInsights' | 'apiKey' | 'basic' | 'googleServiceAccount' | 'oauth';
+export type AuthenticationType = 'googleServiceAccount' | 'basic' | 'apiKey' | 'oauth' | 'algolia' | 'algoliaInsights';

model/authInput.ts

@@ -11,7 +11,7 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type AuthInput =
+  | AuthGoogleServiceAccount
+  | AuthBasic
+  | AuthAPIKey
+  | AuthOAuth
   | AuthAlgolia
-  | AuthAlgoliaInsights
-  | AuthAPIKey
-  | AuthBasic
-  | AuthGoogleServiceAccount
-  | AuthOAuth;
+  | AuthAlgoliaInsights;

model/authInputPartial.ts

@@ -11,7 +11,7 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type AuthInputPartial =
-  | AuthAlgoliaInsightsPartial
+  | AuthGoogleServiceAccountPartial
+  | AuthBasicPartial
+  | AuthAPIKeyPartial
+  | AuthOAuthPartial
   | AuthAlgoliaPartial
-  | AuthAPIKeyPartial
-  | AuthBasicPartial
-  | AuthGoogleServiceAccountPartial
-  | AuthOAuthPartial;
+  | AuthAlgoliaInsightsPartial;

model/bigCommerceChannel.ts

@@ -12,3 +12,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
    */
-  currencies?: string[];
+  currencies?: Array<string>;
 };

model/clientMethodProps.ts

 // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
-import type { ActionType } from './actionType';
-import type { AuthenticationSortKeys } from './authenticationSortKeys';
-import type { AuthenticationType } from './authenticationType';
-import type { AuthenticationUpdate } from './authenticationUpdate';
-import type { DestinationSortKeys } from './destinationSortKeys';
-import type { DestinationType } from './destinationType';
-import type { DestinationUpdate } from './destinationUpdate';
-import type { EventSortKeys } from './eventSortKeys';
-import type { EventStatus } from './eventStatus';
-import type { EventType } from './eventType';
-import type { OrderKeys } from './orderKeys';
-import type { PlatformWithNone } from './platformWithNone';
-import type { PushTaskPayload } from './pushTaskPayload';
-import type { RunSortKeys } from './runSortKeys';
-import type { RunSourcePayload } from './runSourcePayload';
-import type { RunStatus } from './runStatus';
-import type { RunType } from './runType';
-import type { SourceSortKeys } from './sourceSortKeys';
-import type { SourceType } from './sourceType';
-import type { SourceUpdate } from './sourceUpdate';
-import type { TaskSortKeys } from './taskSortKeys';
-import type { TaskUpdate } from './taskUpdate';
-import type { TaskUpdateV1 } from './taskUpdateV1';
-import type { TransformationCreate } from './transformationCreate';
-import type { TransformationSortKeys } from './transformationSortKeys';
-import type { TransformationTry } from './transformationTry';
-import type { TriggerType } from './triggerType';
+import { ActionType } from '../model/actionType';
 
+import { AuthenticationSortKeys } from '../model/authenticationSortKeys';
+import { AuthenticationType } from '../model/authenticationType';
+import { AuthenticationUpdate } from '../model/authenticationUpdate';
+
+import { DestinationSortKeys } from '../model/destinationSortKeys';
+import { DestinationType } from '../model/destinationType';
+import { DestinationUpdate } from '../model/destinationUpdate';
+
+import { EventSortKeys } from '../model/eventSortKeys';
+import { EventStatus } from '../model/eventStatus';
+import { EventType } from '../model/eventType';
+
+import { OrderKeys } from '../model/orderKeys';
+import { PlatformWithNone } from '../model/platformWithNone';
+import { PushTaskPayload } from '../model/pushTaskPayload';
+
+import { RunSortKeys } from '../model/runSortKeys';
+import { RunSourcePayload } from '../model/runSourcePayload';
+
+import { RunStatus } from '../model/runStatus';
+import { RunType } from '../model/runType';
+
+import { SourceSortKeys } from '../model/sourceSortKeys';
+import { SourceType } from '../model/sourceType';
+import { SourceUpdate } from '../model/sourceUpdate';
+
+import { TaskSortKeys } from '../model/taskSortKeys';
+import { TaskUpdate } from '../model/taskUpdate';
+
+import { TaskUpdateV1 } from '../model/taskUpdateV1';
+
+import { TransformationCreate } from '../model/transformationCreate';
+
+import { TransformationSortKeys } from '../model/transformationSortKeys';
+import { TransformationTry } from '../model/transformationTry';
+
+import { TriggerType } from '../model/triggerType';
+
 /**
@@ -42,3 +54,3 @@ * Properties for the `customDelete` method.
    */
-  parameters?: Record<string, any>;
+  parameters?: { [key: string]: any };
 };
@@ -57,3 +69,3 @@
    */
-  parameters?: Record<string, any>;
+  parameters?: { [key: string]: any };
 };
@@ -72,3 +84,3 @@
    */
-  parameters?: Record<string, any>;
+  parameters?: { [key: string]: any };
   /**
@@ -91,3 +103,3 @@ * Parameters to send with the custom request.
    */
-  parameters?: Record<string, any>;
+  parameters?: { [key: string]: any };
   /**
@@ -298,7 +310,7 @@ * Parameters to send with the custom request.
    */
-  type?: AuthenticationType[];
+  type?: Array<AuthenticationType>;
   /**
    * Ecommerce platform for which to retrieve authentications.
    */
-  platform?: PlatformWithNone[];
+  platform?: Array<PlatformWithNone>;
   /**
@@ -329,7 +341,7 @@ * Property by which to sort the list of authentications.
    */
-  type?: DestinationType[];
+  type?: Array<DestinationType>;
   /**
    * Authentication ID used by destinations.
    */
-  authenticationID?: string[];
+  authenticationID?: Array<string>;
   /**
@@ -368,7 +380,7 @@ * Get the list of destinations used by a transformation.
    */
-  status?: EventStatus[];
+  status?: Array<EventStatus>;
   /**
    * Event type for filtering the list of task runs.
    */
-  type?: EventType[];
+  type?: Array<EventType>;
   /**
@@ -407,7 +419,7 @@ * Property by which to sort the list of task run events.
    */
-  status?: RunStatus[];
+  status?: Array<RunStatus>;
   /**
    * Run type for filtering the list of task runs.
    */
-  type?: RunType[];
+  type?: Array<RunType>;
   /**
@@ -450,7 +462,7 @@ * Task ID for filtering the list of task runs.
    */
-  type?: SourceType[];
+  type?: Array<SourceType>;
   /**
    * Authentication IDs of the sources to retrieve. \'none\' returns sources that doesn\'t have an authentication.
    */
-  authenticationID?: string[];
+  authenticationID?: Array<string>;
   /**
@@ -481,3 +493,3 @@ * Property by which to sort the list of sources.
    */
-  action?: ActionType[];
+  action?: Array<ActionType>;
   /**
@@ -490,11 +502,11 @@ * Whether to filter the list of tasks by the `enabled` status.
    */
-  sourceID?: string[];
+  sourceID?: Array<string>;
   /**
    * Destination IDs for filtering the list of tasks.
    */
-  destinationID?: string[];
+  destinationID?: Array<string>;
   /**
    * Type of task trigger for filtering the list of tasks.
    */
-  triggerType?: TriggerType[];
+  triggerType?: Array<TriggerType>;
   /**
@@ -525,3 +537,3 @@ * Property by which to sort the list of tasks.
    */
-  action?: ActionType[];
+  action?: Array<ActionType>;
   /**
@@ -534,11 +546,11 @@ * Whether to filter the list of tasks by the `enabled` status.
    */
-  sourceID?: string[];
+  sourceID?: Array<string>;
   /**
    * Destination IDs for filtering the list of tasks.
    */
-  destinationID?: string[];
+  destinationID?: Array<string>;
   /**
    * Type of task trigger for filtering the list of tasks.
    */
-  triggerType?: TriggerType[];
+  triggerType?: Array<TriggerType>;
   /**
@@ -545,0 +557,0 @@ * Property by which to sort the list of tasks.

model/commercetoolsCustomFields.ts

@@ -10,3 +10,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
    */
-  inventory?: string[] | null;
+  inventory?: Array<string> | null;
 
@@ -16,3 +16,3 @@ /**
    */
-  price?: string[] | null;
+  price?: Array<string> | null;
 
@@ -22,3 +22,3 @@ /**
    */
-  category?: string[] | null;
+  category?: Array<string> | null;
 };

model/destination.ts

@@ -39,3 +39,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
-  transformationIDs?: string[];
+  transformationIDs?: Array<string>;
 };

model/destinationCreate.ts

@@ -24,3 +24,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
-  transformationIDs?: string[];
+  transformationIDs?: Array<string>;
 };

model/destinationIndexName.ts

@@ -16,3 +16,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
    */
-  attributesToExclude?: string[];
+  attributesToExclude?: Array<string>;
 };

model/destinationSearch.ts

@@ -7,3 +7,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type DestinationSearch = {
-  destinationIDs: string[];
+  destinationIDs: Array<string>;
 };

model/destinationSortKeys.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type DestinationSortKeys = 'createdAt' | 'name' | 'type' | 'updatedAt';
+export type DestinationSortKeys = 'name' | 'type' | 'updatedAt' | 'createdAt';

model/destinationType.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type DestinationType = 'insights' | 'search';
+export type DestinationType = 'search' | 'insights';

model/destinationUpdate.ts

@@ -24,3 +24,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
-  transformationIDs?: string[];
+  transformationIDs?: Array<string>;
 };

model/dockerImageType.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type DockerImageType = 'airbyte' | 'custom' | 'singer';
+export type DockerImageType = 'singer' | 'custom' | 'airbyte';

model/dockerStreams.ts

@@ -7,3 +7,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
   /**
-   * The name of the stream to fetch the data from (e.g. Table name).
+   * The name of the stream to fetch the data from (e.g. table name).
    */
@@ -13,7 +13,7 @@ name: string;
   /**
-   * The properties of the stream to select (e.g. Column).
+   * The properties of the stream to select (e.g. column).
    */
-  properties?: string[];
+  properties?: Array<string>;
 
   syncMode: DockerStreamsSyncMode;
 };

model/dockerStreamsInput.ts

@@ -9,3 +9,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type DockerStreamsInput = {
-  streams: DockerStreams[];
+  streams: Array<DockerStreams>;
 };

model/dockerStreamsSyncMode.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type DockerStreamsSyncMode = 'fullTable' | 'incremental';
+export type DockerStreamsSyncMode = 'incremental' | 'fullTable';

model/entityType.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type EntityType = 'collection' | 'product';
+export type EntityType = 'product' | 'collection';

model/event.ts

@@ -34,3 +34,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
-  data?: Record<string, any>;
+  data?: { [key: string]: any };
 
@@ -37,0 +37,0 @@ /**

model/eventSortKeys.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type EventSortKeys = 'publishedAt' | 'status' | 'type';
+export type EventSortKeys = 'status' | 'type' | 'publishedAt';

model/eventStatus.ts

 // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
-export type EventStatus = 'created' | 'critical' | 'failed' | 'retried' | 'started' | 'succeeded';
+export type EventStatus = 'created' | 'started' | 'retried' | 'failed' | 'succeeded' | 'critical';

model/eventType.ts

 // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
-export type EventType = 'fetch' | 'log' | 'record' | 'transform';
+export type EventType = 'fetch' | 'record' | 'log' | 'transform';

model/index.ts

@@ -5,4 +5,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export * from './actionType';
-export * from './authAPIKey';
-export * from './authAPIKeyPartial';
 export * from './authAlgolia';
@@ -12,10 +10,6 @@ export * from './authAlgoliaInsights';
 export * from './authAlgoliaPartial';
+export * from './authAPIKey';
+export * from './authAPIKeyPartial';
 export * from './authBasic';
 export * from './authBasicPartial';
-export * from './authGoogleServiceAccount';
-export * from './authGoogleServiceAccountPartial';
-export * from './authInput';
-export * from './authInputPartial';
-export * from './authOAuth';
-export * from './authOAuthPartial';
 export * from './authentication';
@@ -29,5 +23,12 @@ export * from './authenticationCreate';
 export * from './authenticationUpdateResponse';
+export * from './authGoogleServiceAccount';
+export * from './authGoogleServiceAccountPartial';
+export * from './authInput';
+export * from './authInputPartial';
+export * from './authOAuth';
+export * from './authOAuthPartial';
 export * from './bigCommerceChannel';
 export * from './bigCommerceMetafield';
 export * from './bigQueryDataType';
+export * from './clientMethodProps';
 export * from './commercetoolsCustomFields';
@@ -100,6 +101,6 @@ export * from './deleteResponse';
 export * from './sourceBigQuery';
-export * from './sourceCSV';
 export * from './sourceCommercetools';
 export * from './sourceCreate';
 export * from './sourceCreateResponse';
+export * from './sourceCSV';
 export * from './sourceDocker';
@@ -151,2 +152,1 @@ export * from './sourceGA4BigQueryExport';
 export * from './window';
-export * from './clientMethodProps';

model/listAuthenticationsResponse.ts

@@ -7,5 +7,5 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type ListAuthenticationsResponse = {
-  authentications: Authentication[];
+  authentications: Array<Authentication>;
 
   pagination: Pagination;
 };

model/listDestinationsResponse.ts

@@ -7,5 +7,5 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type ListDestinationsResponse = {
-  destinations: Destination[];
+  destinations: Array<Destination>;
 
   pagination: Pagination;
 };

model/listEventsResponse.ts

@@ -8,3 +8,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type ListEventsResponse = {
-  events: Event[];
+  events: Array<Event>;
 
@@ -11,0 +11,0 @@ pagination: Pagination;

model/listSourcesResponse.ts

@@ -7,5 +7,5 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type ListSourcesResponse = {
-  sources: Source[];
+  sources: Array<Source>;
 
   pagination: Pagination;
 };

model/listTasksResponse.ts

@@ -10,5 +10,5 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type ListTasksResponse = {
-  tasks: Task[];
+  tasks: Array<Task>;
 
   pagination: Pagination;
 };

model/listTasksResponseV1.ts

@@ -10,5 +10,5 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type ListTasksResponseV1 = {
-  tasks: TaskV1[];
+  tasks: Array<TaskV1>;
 
   pagination: Pagination;
 };

model/listTransformationsResponse.ts

@@ -10,5 +10,5 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type ListTransformationsResponse = {
-  transformations: Transformation[];
+  transformations: Array<Transformation>;
 
   pagination: Pagination;
 };

model/mappingFieldDirective.ts

@@ -15,3 +15,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
    */
-  value: Record<string, any>;
+  value: { [key: string]: any };
 };

model/mappingInput.ts

@@ -12,3 +12,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
-  actions: MappingKitAction[];
+  actions: Array<MappingKitAction>;
 };

model/mappingKitAction.ts

@@ -24,3 +24,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
-  fieldDirectives: MappingFieldDirective[];
+  fieldDirectives: Array<MappingFieldDirective>;
 };

model/mappingTypeCSV.ts

 // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
-export type MappingTypeCSV = 'boolean' | 'float' | 'integer' | 'json' | 'string';
+export type MappingTypeCSV = 'string' | 'integer' | 'float' | 'boolean' | 'json';

model/pushTaskPayload.ts

@@ -9,3 +9,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
-  records: PushTaskRecords[];
+  records: Array<PushTaskRecords>;
 };

model/runListResponse.ts

@@ -8,3 +8,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type RunListResponse = {
-  runs: Run[];
+  runs: Array<Run>;
 
@@ -11,0 +11,0 @@ pagination: Pagination;

model/runOutcome.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type RunOutcome = 'failure' | 'processing' | 'success';
+export type RunOutcome = 'success' | 'failure' | 'processing';

model/runReasonCode.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type RunReasonCode = 'blocking' | 'critical' | 'discarded' | 'internal' | 'no_events' | 'ok' | 'too_many_errors';
+export type RunReasonCode = 'internal' | 'critical' | 'no_events' | 'too_many_errors' | 'ok' | 'discarded' | 'blocking';

model/runSortKeys.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type RunSortKeys = 'createdAt' | 'status' | 'updatedAt';
+export type RunSortKeys = 'status' | 'updatedAt' | 'createdAt';

model/runSourcePayload.ts

@@ -9,3 +9,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
    */
-  indexToInclude?: string[];
+  indexToInclude?: Array<string>;
 
@@ -15,3 +15,3 @@ /**
    */
-  indexToExclude?: string[];
+  indexToExclude?: Array<string>;
 
@@ -21,5 +21,5 @@ /**
    */
-  entityIDs?: string[];
+  entityIDs?: Array<string>;
 
   entityType?: EntityType;
 };

model/runSourceResponse.ts

@@ -7,3 +7,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
    */
-  taskWithRunID: Record<string, string>;
+  taskWithRunID: { [key: string]: string };
 
@@ -10,0 +10,0 @@ /**

model/runStatus.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type RunStatus = 'created' | 'finished' | 'idled' | 'skipped' | 'started';
+export type RunStatus = 'created' | 'started' | 'idled' | 'finished' | 'skipped';

model/runType.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type RunType = 'discover' | 'push' | 'reindex' | 'update' | 'validate';
+export type RunType = 'reindex' | 'update' | 'discover' | 'validate' | 'push';

model/shopifyInput.ts

@@ -10,5 +10,5 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type ShopifyInput = {
-  metafields: ShopifyMetafield[];
+  metafields: Array<ShopifyMetafield>;
 
   market: ShopifyMarket;
 };

model/shopifyMarket.ts

@@ -7,7 +7,7 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type ShopifyMarket = {
-  countries: string[];
+  countries: Array<string>;
 
-  currencies: string[];
+  currencies: Array<string>;
 
-  locales: string[];
+  locales: Array<string>;
 };

model/sourceBigCommerce.ts

@@ -14,7 +14,7 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
-  customFields?: string[];
+  customFields?: Array<string>;
 
-  productMetafields?: BigCommerceMetafield[];
+  productMetafields?: Array<BigCommerceMetafield>;
 
-  variantMetafields?: BigCommerceMetafield[];
+  variantMetafields?: Array<BigCommerceMetafield>;
 };

model/sourceCommercetools.ts

@@ -6,3 +6,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type SourceCommercetools = {
-  storeKeys?: string[];
+  storeKeys?: Array<string>;
 
@@ -12,3 +12,3 @@ /**
    */
-  locales?: string[];
+  locales?: Array<string>;
 
@@ -15,0 +15,0 @@ url: string;

model/sourceCSV.ts

@@ -20,3 +20,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
    */
-  mapping?: Record<string, MappingTypeCSV>;
+  mapping?: { [key: string]: MappingTypeCSV };
 
@@ -23,0 +23,0 @@ method?: MethodType;

model/sourceInput.ts

@@ -13,9 +13,9 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type SourceInput =
+  | SourceCommercetools
   | SourceBigCommerce
+  | SourceJSON
+  | SourceCSV
   | SourceBigQuery
-  | SourceCommercetools
-  | SourceCSV
+  | SourceGA4BigQueryExport
   | SourceDocker
-  | SourceGA4BigQueryExport
-  | SourceJSON
   | SourceShopify;

model/sourceSearch.ts

 // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
 export type SourceSearch = {
-  sourceIDs: string[];
+  sourceIDs: Array<string>;
 };

model/sourceShopify.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
-export type SourceShopify = SourceShopifyBase & SourceUpdateShopify;
+export type SourceShopify = SourceUpdateShopify & SourceShopifyBase;

model/sourceSortKeys.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type SourceSortKeys = 'createdAt' | 'name' | 'type' | 'updatedAt';
+export type SourceSortKeys = 'name' | 'type' | 'updatedAt' | 'createdAt';

model/sourceType.ts

@@ -11,4 +11,4 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
   | 'json'
-  | 'push'
+  | 'shopify'
   | 'sfcc'
-  | 'shopify';
+  | 'push';

model/sourceUpdateCommercetools.ts

@@ -6,3 +6,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type SourceUpdateCommercetools = {
-  storeKeys?: string[];
+  storeKeys?: Array<string>;
 
@@ -12,3 +12,3 @@ /**
    */
-  locales?: string[];
+  locales?: Array<string>;
 
@@ -15,0 +15,0 @@ url?: string;

model/sourceUpdateInput.ts

@@ -12,8 +12,8 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 export type SourceUpdateInput =
+  | SourceUpdateCommercetools
+  | SourceJSON
+  | SourceCSV
   | SourceBigQuery
-  | SourceCSV
   | SourceGA4BigQueryExport
-  | SourceJSON
-  | SourceUpdateCommercetools
   | SourceUpdateDocker
   | SourceUpdateShopify;

model/sourceUpdateShopify.ts

@@ -7,3 +7,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
    */
-  featureFlags?: Record<string, any>;
+  featureFlags?: { [key: string]: any };
 };

model/sourceWatchResponse.ts

@@ -12,3 +12,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
   /**
-   * Depending on the source type, the validation returns sampling data of your source (JSON, CSV, BigQuery).
+   * depending on the source type, the validation returns sampling data of your source (JSON, CSV, BigQuery).
    */
@@ -18,10 +18,10 @@ data?: Array<Record<string, unknown>>;
   /**
-   * In case of error, observability events will be added to the response, if any.
+   * in case of error, observability events will be added to the response, if any.
    */
-  events?: Event[];
+  events?: Array<Event>;
 
   /**
-   * A message describing the outcome of a validate run.
+   * a message describing the outcome of a validate run.
    */
   message: string;
 };

model/taskCreateTrigger.ts

@@ -6,4 +6,5 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 import type { StreamingTrigger } from './streamingTrigger';
+
 import type { SubscriptionTrigger } from './subscriptionTrigger';
 
-export type TaskCreateTrigger = OnDemandTriggerInput | ScheduleTriggerInput | StreamingTrigger | SubscriptionTrigger;
+export type TaskCreateTrigger = OnDemandTriggerInput | ScheduleTriggerInput | SubscriptionTrigger | StreamingTrigger;

model/taskInput.ts

 // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
 import type { DockerStreamsInput } from './dockerStreamsInput';
+
 import type { ShopifyInput } from './shopifyInput';
+
 import type { StreamingInput } from './streamingInput';
@@ -10,2 +12,2 @@
  */
-export type TaskInput = DockerStreamsInput | ShopifyInput | StreamingInput;
+export type TaskInput = StreamingInput | DockerStreamsInput | ShopifyInput;

model/taskSearch.ts

 // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
 export type TaskSearch = {
-  taskIDs: string[];
+  taskIDs: Array<string>;
 };

model/taskSortKeys.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type TaskSortKeys = 'action' | 'createdAt' | 'enabled' | 'triggerType' | 'updatedAt';
+export type TaskSortKeys = 'enabled' | 'triggerType' | 'action' | 'updatedAt' | 'createdAt';

model/transformation.ts

@@ -12,3 +12,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
    */
-  authenticationIDs?: string[];
+  authenticationIDs?: Array<string>;
 
@@ -15,0 +15,0 @@ /**

model/transformationCreate.ts

@@ -25,3 +25,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
    */
-  authenticationIDs?: string[];
+  authenticationIDs?: Array<string>;
 };

model/transformationSearch.ts

 // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
 export type TransformationSearch = {
-  transformationIDs: string[];
+  transformationIDs: Array<string>;
 };

model/transformationSortKeys.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type TransformationSortKeys = 'createdAt' | 'name' | 'updatedAt';
+export type TransformationSortKeys = 'name' | 'updatedAt' | 'createdAt';

model/transformationTry.ts

@@ -16,3 +16,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 
-  authentications?: AuthenticationCreate[];
+  authentications?: Array<AuthenticationCreate>;
 };

model/trigger.ts

@@ -6,2 +6,3 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
 import type { StreamingTrigger } from './streamingTrigger';
+
 import type { SubscriptionTrigger } from './subscriptionTrigger';
@@ -12,2 +13,2 @@
  */
-export type Trigger = OnDemandTrigger | ScheduleTrigger | StreamingTrigger | SubscriptionTrigger;
+export type Trigger = OnDemandTrigger | ScheduleTrigger | SubscriptionTrigger | StreamingTrigger;

model/triggerType.ts

@@ -6,2 +6,2 @@ // Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
  */
-export type TriggerType = 'onDemand' | 'schedule' | 'streaming' | 'subscription';
+export type TriggerType = 'onDemand' | 'schedule' | 'subscription' | 'streaming';

package.json

 {
-  "version": "1.7.0",
+  "version": "1.8.0",
   "repository": {
@@ -52,6 +52,6 @@ "type": "git",
   "dependencies": {
-    "@algolia/client-common": "5.7.0",
-    "@algolia/requester-browser-xhr": "5.7.0",
-    "@algolia/requester-fetch": "5.7.0",
-    "@algolia/requester-node-http": "5.7.0"
+    "@algolia/client-common": "5.8.0",
+    "@algolia/requester-browser-xhr": "5.8.0",
+    "@algolia/requester-fetch": "5.8.0",
+    "@algolia/requester-node-http": "5.8.0"
   },
@@ -62,3 +62,3 @@ "devDependencies": {
     "publint": "0.2.11",
-    "rollup": "4.22.5",
+    "rollup": "4.24.0",
     "tsup": "8.3.0",
@@ -65,0 +65,0 @@ "typescript": "5.6.2"

README.md

@@ -35,3 +35,2 @@ <p align="center">
 
-
 To get started, you first need to install @algolia/ingestion (or any other available API client package).
@@ -42,9 +41,8 @@ All of our clients comes with type definition, and are available for both browser and node environments.
 
-
 ```bash
-yarn add @algolia/ingestion@1.7.0
+yarn add @algolia/ingestion@1.8.0
 # or
-npm install @algolia/ingestion@1.7.0
+npm install @algolia/ingestion@1.8.0
 # or
-pnpm add @algolia/ingestion@1.7.0
+pnpm add @algolia/ingestion@1.8.0
 ```
@@ -57,3 +55,3 @@
 ```html
-<script src="https://cdn.jsdelivr.net/npm/@algolia/ingestion@1.7.0/dist/builds/browser.umd.js"></script>
+<script src="https://cdn.jsdelivr.net/npm/@algolia/ingestion@1.8.0/dist/builds/browser.umd.js"></script>
 ```
@@ -79,2 +77,2 @@
 
-The Algolia JavaScript API Client is an open-sourced software licensed under the [MIT license](LICENSE).
+The Algolia JavaScript API Client is an open-sourced software licensed under the [MIT license](LICENSE).

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

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

1865788

increased by0.01%

Worsened metrics

Lines of code

23077

decreased by-1.95%

Number of lines in readme file

75

decreased by-1.32%

Dependency changes

• + Added@algolia/client-common@5.8.0(transitive)

• + Added@algolia/requester-browser-xhr@5.8.0(transitive)

• + Added@algolia/requester-fetch@5.8.0(transitive)

• + Added@algolia/requester-node-http@5.8.0(transitive)

• - Removed@algolia/client-common@5.7.0(transitive)

• - Removed@algolia/requester-browser-xhr@5.7.0(transitive)

• - Removed@algolia/requester-fetch@5.7.0(transitive)

• - Removed@algolia/requester-node-http@5.7.0(transitive)

• Updated@algolia/client-common@5.8.0

• Updated@algolia/requester-browser-xhr@5.8.0

• Updated@algolia/requester-fetch@5.8.0

• Updated@algolia/requester-node-http@5.8.0