@algolia/ingestion - npm Package Compare versions

Comparing version 1.0.0-beta.11 to 1.0.0-beta.12

dist/builds/browser.d.ts

@@ -19,2 +19,3 @@ import type { ClientOptions } from '@algolia/client-common';
     createTask(taskCreate: import("../model").TaskCreate, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskCreateResponse>;
+    createTaskV1(taskCreate: import("../model").TaskCreateV1, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskCreateResponse>;
     createTransformation(transformationCreate: import("../model").TransformationCreate, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TransformationCreateResponse>;
@@ -29,20 +30,27 @@ customDelete({ path, parameters }: import("../model").CustomDeleteProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<Record<string, any>>;
     deleteTask({ taskID }: import("../model").DeleteTaskProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").DeleteResponse>;
+    deleteTaskV1({ taskID }: import("../model").DeleteTaskV1Props, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").DeleteResponse>;
     deleteTransformation({ transformationID }: import("../model").DeleteTransformationProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").DeleteResponse>;
     disableTask({ taskID }: import("../model").DisableTaskProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskUpdateResponse>;
+    disableTaskV1({ taskID }: import("../model").DisableTaskV1Props, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskUpdateResponse>;
     enableTask({ taskID }: import("../model").EnableTaskProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskUpdateResponse>;
+    enableTaskV1({ taskID }: import("../model").EnableTaskV1Props, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskUpdateResponse>;
     getAuthentication({ authenticationID }: import("../model").GetAuthenticationProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Authentication>;
-    getAuthentications({ itemsPerPage, page, type, platform, sort, order, }?: import("../model").GetAuthenticationsProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListAuthenticationsResponse>;
     getDestination({ destinationID }: import("../model").GetDestinationProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Destination>;
-    getDestinations({ itemsPerPage, page, type, authenticationID, sort, order, }?: import("../model").GetDestinationsProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListDestinationsResponse>;
     getEvent({ runID, eventID }: import("../model").GetEventProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Event>;
-    getEvents({ runID, itemsPerPage, page, status, type, sort, order, startDate, endDate, }: import("../model").GetEventsProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").ListEventsResponse>;
     getRun({ runID }: import("../model").GetRunProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Run>;
-    getRuns({ itemsPerPage, page, status, taskID, sort, order, startDate, endDate, }?: import("../model").GetRunsProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").RunListResponse>;
     getSource({ sourceID }: import("../model").GetSourceProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Source>;
-    getSources({ itemsPerPage, page, type, authenticationID, sort, order, }?: import("../model").GetSourcesProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListSourcesResponse>;
     getTask({ taskID }: import("../model").GetTaskProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Task>;
-    getTasks({ itemsPerPage, page, action, enabled, sourceID, destinationID, triggerType, sort, order, }?: import("../model").GetTasksProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListTasksResponse>;
+    getTaskV1({ taskID }: import("../model").GetTaskV1Props, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskV1>;
     getTransformation({ transformationID }: import("../model").GetTransformationProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Transformation>;
-    getTransformations({ sort, order }?: import("../model").GetTransformationsProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListTransformationsResponse>;
+    listAuthentications({ itemsPerPage, page, type, platform, sort, order, }?: import("../model").ListAuthenticationsProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListAuthenticationsResponse>;
+    listDestinations({ itemsPerPage, page, type, authenticationID, sort, order, }?: import("../model").ListDestinationsProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListDestinationsResponse>;
+    listEvents({ runID, itemsPerPage, page, status, type, sort, order, startDate, endDate, }: import("../model").ListEventsProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").ListEventsResponse>;
+    listRuns({ itemsPerPage, page, status, taskID, sort, order, startDate, endDate, }?: import("../model").ListRunsProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").RunListResponse>;
+    listSources({ itemsPerPage, page, type, authenticationID, sort, order, }?: import("../model").ListSourcesProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListSourcesResponse>;
+    listTasks({ itemsPerPage, page, action, enabled, sourceID, destinationID, triggerType, sort, order, }?: import("../model").ListTasksProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListTasksResponse>;
+    listTasksV1({ itemsPerPage, page, action, enabled, sourceID, destinationID, triggerType, sort, order, }?: import("../model").ListTasksV1Props, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListTasksResponseV1>;
+    listTransformations({ sort, order }?: import("../model").ListTransformationsProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListTransformationsResponse>;
+    pushTask({ taskID, batchWriteParams }: import("../model").PushTaskProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").RunResponse>;
     runTask({ taskID }: import("../model").RunTaskProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").RunResponse>;
+    runTaskV1({ taskID }: import("../model").RunTaskV1Props, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").RunResponse>;
     searchAuthentications(authenticationSearch: import("../model").AuthenticationSearch, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Authentication[]>;
@@ -52,2 +60,3 @@ searchDestinations(destinationSearch: import("../model").DestinationSearch, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Destination[]>;
     searchTasks(taskSearch: import("../model").TaskSearch, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Task[]>;
+    searchTasksV1(taskSearch: import("../model").TaskSearch, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskV1[]>;
     searchTransformations(transformationSearch: import("../model").TransformationSearch, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Transformation[]>;
@@ -60,2 +69,3 @@ triggerDockerSourceDiscover({ sourceID }: import("../model").TriggerDockerSourceDiscoverProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").SourceWatchResponse>;
     updateTask({ taskID, taskUpdate }: import("../model").UpdateTaskProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskUpdateResponse>;
+    updateTaskV1({ taskID, taskUpdate }: import("../model").UpdateTaskV1Props, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskUpdateResponse>;
     updateTransformation({ transformationID, transformationCreate }: import("../model").UpdateTransformationProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TransformationUpdateResponse>;
@@ -62,0 +72,0 @@ validateSource(sourceCreate: import("../model").SourceCreate, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").SourceWatchResponse>;

dist/builds/node.d.ts

@@ -19,2 +19,3 @@ import type { ClientOptions } from '@algolia/client-common';
     createTask(taskCreate: import("../model").TaskCreate, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskCreateResponse>;
+    createTaskV1(taskCreate: import("../model").TaskCreateV1, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskCreateResponse>;
     createTransformation(transformationCreate: import("../model").TransformationCreate, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TransformationCreateResponse>;
@@ -29,20 +30,27 @@ customDelete({ path, parameters }: import("../model").CustomDeleteProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<Record<string, any>>;
     deleteTask({ taskID }: import("../model").DeleteTaskProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").DeleteResponse>;
+    deleteTaskV1({ taskID }: import("../model").DeleteTaskV1Props, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").DeleteResponse>;
     deleteTransformation({ transformationID }: import("../model").DeleteTransformationProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").DeleteResponse>;
     disableTask({ taskID }: import("../model").DisableTaskProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskUpdateResponse>;
+    disableTaskV1({ taskID }: import("../model").DisableTaskV1Props, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskUpdateResponse>;
     enableTask({ taskID }: import("../model").EnableTaskProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskUpdateResponse>;
+    enableTaskV1({ taskID }: import("../model").EnableTaskV1Props, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskUpdateResponse>;
     getAuthentication({ authenticationID }: import("../model").GetAuthenticationProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Authentication>;
-    getAuthentications({ itemsPerPage, page, type, platform, sort, order, }?: import("../model").GetAuthenticationsProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListAuthenticationsResponse>;
     getDestination({ destinationID }: import("../model").GetDestinationProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Destination>;
-    getDestinations({ itemsPerPage, page, type, authenticationID, sort, order, }?: import("../model").GetDestinationsProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListDestinationsResponse>;
     getEvent({ runID, eventID }: import("../model").GetEventProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Event>;
-    getEvents({ runID, itemsPerPage, page, status, type, sort, order, startDate, endDate, }: import("../model").GetEventsProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").ListEventsResponse>;
     getRun({ runID }: import("../model").GetRunProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Run>;
-    getRuns({ itemsPerPage, page, status, taskID, sort, order, startDate, endDate, }?: import("../model").GetRunsProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").RunListResponse>;
     getSource({ sourceID }: import("../model").GetSourceProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Source>;
-    getSources({ itemsPerPage, page, type, authenticationID, sort, order, }?: import("../model").GetSourcesProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListSourcesResponse>;
     getTask({ taskID }: import("../model").GetTaskProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Task>;
-    getTasks({ itemsPerPage, page, action, enabled, sourceID, destinationID, triggerType, sort, order, }?: import("../model").GetTasksProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListTasksResponse>;
+    getTaskV1({ taskID }: import("../model").GetTaskV1Props, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskV1>;
     getTransformation({ transformationID }: import("../model").GetTransformationProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Transformation>;
-    getTransformations({ sort, order }?: import("../model").GetTransformationsProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListTransformationsResponse>;
+    listAuthentications({ itemsPerPage, page, type, platform, sort, order, }?: import("../model").ListAuthenticationsProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListAuthenticationsResponse>;
+    listDestinations({ itemsPerPage, page, type, authenticationID, sort, order, }?: import("../model").ListDestinationsProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListDestinationsResponse>;
+    listEvents({ runID, itemsPerPage, page, status, type, sort, order, startDate, endDate, }: import("../model").ListEventsProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").ListEventsResponse>;
+    listRuns({ itemsPerPage, page, status, taskID, sort, order, startDate, endDate, }?: import("../model").ListRunsProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").RunListResponse>;
+    listSources({ itemsPerPage, page, type, authenticationID, sort, order, }?: import("../model").ListSourcesProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListSourcesResponse>;
+    listTasks({ itemsPerPage, page, action, enabled, sourceID, destinationID, triggerType, sort, order, }?: import("../model").ListTasksProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListTasksResponse>;
+    listTasksV1({ itemsPerPage, page, action, enabled, sourceID, destinationID, triggerType, sort, order, }?: import("../model").ListTasksV1Props, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListTasksResponseV1>;
+    listTransformations({ sort, order }?: import("../model").ListTransformationsProps, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").ListTransformationsResponse>;
+    pushTask({ taskID, batchWriteParams }: import("../model").PushTaskProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").RunResponse>;
     runTask({ taskID }: import("../model").RunTaskProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").RunResponse>;
+    runTaskV1({ taskID }: import("../model").RunTaskV1Props, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").RunResponse>;
     searchAuthentications(authenticationSearch: import("../model").AuthenticationSearch, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Authentication[]>;
@@ -52,2 +60,3 @@ searchDestinations(destinationSearch: import("../model").DestinationSearch, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Destination[]>;
     searchTasks(taskSearch: import("../model").TaskSearch, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Task[]>;
+    searchTasksV1(taskSearch: import("../model").TaskSearch, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskV1[]>;
     searchTransformations(transformationSearch: import("../model").TransformationSearch, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").Transformation[]>;
@@ -60,2 +69,3 @@ triggerDockerSourceDiscover({ sourceID }: import("../model").TriggerDockerSourceDiscoverProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").SourceWatchResponse>;
     updateTask({ taskID, taskUpdate }: import("../model").UpdateTaskProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskUpdateResponse>;
+    updateTaskV1({ taskID, taskUpdate }: import("../model").UpdateTaskV1Props, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TaskUpdateResponse>;
     updateTransformation({ transformationID, transformationCreate }: import("../model").UpdateTransformationProps, requestOptions?: import("@algolia/client-common").RequestOptions): Promise<import("../model").TransformationUpdateResponse>;
@@ -62,0 +72,0 @@ validateSource(sourceCreate: import("../model").SourceCreate, requestOptions?: import("@algolia/client-common").RequestOptions | undefined): Promise<import("../model").SourceWatchResponse>;

dist/ingestion.umd.js

@@ -1,2 +0,2 @@
-/*! ingestion.umd.js | 1.0.0-beta.11 | © Algolia, inc. | https://github.com/algolia/algoliasearch-client-javascript */
-!function(e,r){"object"==typeof exports&&"undefined"!=typeof module?r(exports):"function"==typeof define&&define.amd?define(["exports"],r):r((e="undefined"!=typeof globalThis?globalThis:e||self)["@algolia/ingestion"]={})}(this,(function(e){"use strict";function r(e){let r;const t=`algolia-client-js-${e.key}`;function a(){return void 0===r&&(r=e.localStorage||window.localStorage),r}function n(){return JSON.parse(a().getItem(t)||"{}")}function o(e){a().setItem(t,JSON.stringify(e))}return{get:(r,t,a={miss:()=>Promise.resolve()})=>Promise.resolve().then((()=>(function(){const r=e.timeToLive?1e3*e.timeToLive:null,t=n(),a=Object.fromEntries(Object.entries(t).filter((([,e])=>void 0!==e.timestamp)));if(o(a),!r)return;o(Object.fromEntries(Object.entries(a).filter((([,e])=>{const t=(new Date).getTime();return!(e.timestamp+r<t)}))))}(),n()[JSON.stringify(r)]))).then((e=>Promise.all([e?e.value:t(),void 0!==e]))).then((([e,r])=>Promise.all([e,r||a.miss(e)]))).then((([e])=>e)),set:(e,r)=>Promise.resolve().then((()=>{const o=n();return o[JSON.stringify(e)]={timestamp:(new Date).getTime(),value:r},a().setItem(t,JSON.stringify(o)),r})),delete:e=>Promise.resolve().then((()=>{const r=n();delete r[JSON.stringify(e)],a().setItem(t,JSON.stringify(r))})),clear:()=>Promise.resolve().then((()=>{a().removeItem(t)}))}}function t(e){const r=[...e.caches],a=r.shift();return void 0===a?{get:(e,r,t={miss:()=>Promise.resolve()})=>r().then((e=>Promise.all([e,t.miss(e)]))).then((([e])=>e)),set:(e,r)=>Promise.resolve(r),delete:e=>Promise.resolve(),clear:()=>Promise.resolve()}:{get:(e,n,o={miss:()=>Promise.resolve()})=>a.get(e,n,o).catch((()=>t({caches:r}).get(e,n,o))),set:(e,n)=>a.set(e,n).catch((()=>t({caches:r}).set(e,n))),delete:e=>a.delete(e).catch((()=>t({caches:r}).delete(e))),clear:()=>a.clear().catch((()=>t({caches:r}).clear()))}}function a(e={serializable:!0}){let r={};return{get(t,a,n={miss:()=>Promise.resolve()}){const o=JSON.stringify(t);if(o in r)return Promise.resolve(e.serializable?JSON.parse(r[o]):r[o]);const s=a();return s.then((e=>n.miss(e))).then((()=>s))},set:(t,a)=>(r[JSON.stringify(t)]=e.serializable?JSON.stringify(a):a,Promise.resolve(a)),delete:e=>(delete r[JSON.stringify(e)],Promise.resolve()),clear:()=>(r={},Promise.resolve())}}const n=12e4;function o(e,r="up"){const t=Date.now();return{...e,status:r,lastUpdate:t,isUp:function(){return"up"===r||Date.now()-t>n},isTimedOut:function(){return"timed out"===r&&Date.now()-t<=n}}}function s(e,r,t){return(r=function(e){var r=function(e,r){if("object"!=typeof e||!e)return e;var t=e[Symbol.toPrimitive];if(void 0!==t){var a=t.call(e,r||"default");if("object"!=typeof a)return a;throw new TypeError("@@toPrimitive must return a primitive value.")}return("string"===r?String:Number)(e)}(e,"string");return"symbol"==typeof r?r:r+""}(r))in e?Object.defineProperty(e,r,{value:t,enumerable:!0,configurable:!0,writable:!0}):e[r]=t,e}class i extends Error{constructor(e,r){super(e),s(this,"name","AlgoliaError"),r&&(this.name=r)}}class u extends i{constructor(e,r,t){super(e,t),s(this,"stackTrace",void 0),this.stackTrace=r}}class c extends u{constructor(e){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.",e,"RetryError")}}class d extends u{constructor(e,r,t,a="ApiError"){super(e,t,a),s(this,"status",void 0),this.status=r}}class h extends i{constructor(e,r){super(e,"DeserializationError"),s(this,"response",void 0),this.response=r}}class m extends d{constructor(e,r,t,a){super(e,r,a,"DetailedApiError"),s(this,"error",void 0),this.error=t}}function l(e,r,t){const a=(n=t,Object.keys(n).filter((e=>void 0!==n[e])).sort().map((e=>`${e}=${encodeURIComponent("[object Array]"===Object.prototype.toString.call(n[e])?n[e].join(","):n[e]).replaceAll("+","%20")}`)).join("&"));var n;let o=`${e.protocol}://${e.url}${e.port?`:${e.port}`:""}/${"/"===r.charAt(0)?r.substring(1):r}`;return a.length&&(o+=`?${a}`),o}function p(e){const r=e.request.headers["x-algolia-api-key"]?{"x-algolia-api-key":"*****"}:{};return{...e,request:{...e.request,headers:{...e.request.headers,...r}}}}function g({hosts:e,hostsCache:r,baseHeaders:t,baseQueryParameters:a,algoliaAgent:n,timeouts:s,requester:i,requestsCache:u,responsesCache:g}){async function w(u,g,w=!0){const f=[],P=function(e,r){if("GET"===e.method||void 0===e.data&&void 0===r.data)return;const t=Array.isArray(e.data)?e.data:{...e.data,...r.data};return JSON.stringify(t)}(u,g),q=function(e,r,t){const a={Accept:"application/json",...e,...r,...t},n={};return Object.keys(a).forEach((e=>{const r=a[e];n[e.toLowerCase()]=r})),n}(t,u.headers,g.headers),D="GET"===u.method?{...u.data,...g.data}:{},I={...a,...u.queryParameters,...D};if(n.value&&(I["x-algolia-agent"]=n.value),g&&g.queryParameters)for(const e of Object.keys(g.queryParameters))g.queryParameters[e]&&"[object Object]"!==Object.prototype.toString.call(g.queryParameters[e])?I[e]=g.queryParameters[e].toString():I[e]=g.queryParameters[e];let y=0;const T=async(e,t)=>{const a=e.pop();if(void 0===a)throw new c(function(e){return e.map((e=>p(e)))}(f));let n=w?g.timeouts?.read||s.read:g.timeouts?.write||s.write;const D={data:P,headers:q,method:u.method,url:l(a,u.path,I),connectTimeout:t(y,g.timeouts?.connect||s.connect),responseTimeout:t(y,n)},v=r=>{const t={request:D,response:r,host:a,triesLeft:e.length};return f.push(t),t},E=await i.send(D);if(function({isTimedOut:e,status:r}){return e||function({isTimedOut:e,status:r}){return!e&&!~~r}({isTimedOut:e,status:r})||2!=~~(r/100)&&4!=~~(r/100)}(E)){const n=v(E);return E.isTimedOut&&y++,console.log("Retryable failure",p(n)),await r.set(a,o(a,E.isTimedOut?"timed out":"down")),T(e,t)}if(function({status:e}){return 2==~~(e/100)}(E))return function(e){try{return JSON.parse(e.content)}catch(r){throw new h(r.message,e)}}(E);throw v(E),function({content:e,status:r},t){try{const a=JSON.parse(e);return"error"in a?new m(a.message,r,a.error,t):new d(a.message,r,t)}catch(e){}return new d(e,r,t)}(E,f)},v=e.filter((e=>"readWrite"===e.accept||(w?"read"===e.accept:"write"===e.accept))),E=await async function(e){const t=await Promise.all(e.map((e=>r.get(e,(()=>Promise.resolve(o(e))))))),a=t.filter((e=>e.isUp())),n=t.filter((e=>e.isTimedOut())),s=[...a,...n];return{hosts:s.length>0?s:e,getTimeout:(e,r)=>(0===n.length&&0===e?1:n.length+3+e)*r}}(v);return T([...E.hosts].reverse(),E.getTimeout)}return{hostsCache:r,requester:i,timeouts:s,algoliaAgent:n,baseHeaders:t,baseQueryParameters:a,hosts:e,request:function(e,r={}){const n=e.useReadTransporter||"GET"===e.method;if(!n)return w(e,r,n);const o=()=>w(e,r);if(!0!==(r.cacheable||e.cacheable))return o();const s={request:e,requestOptions:r,transporter:{queryParameters:a,headers:t}};return g.get(s,(()=>u.get(s,(()=>u.set(s,o()).then((e=>Promise.all([u.delete(s),e])),(e=>Promise.all([u.delete(s),Promise.reject(e)]))).then((([e,r])=>r))))),{miss:e=>g.set(s,e)})},requestsCache:u,responsesCache:g}}function w({algoliaAgents:e,client:r,version:t}){const a=function(e){const r={value:`Algolia for JavaScript (${e})`,add(e){const t=`; ${e.segment}${void 0!==e.version?` (${e.version})`:""}`;return-1===r.value.indexOf(t)&&(r.value=`${r.value}${t}`),r}};return r}(t).add({segment:r,version:t});return e.forEach((e=>a.add(e))),a}const f="1.0.0-beta.11",P=["eu","us"];e.apiClientVersion=f,e.ingestionClient=function(e,n,o,s){if(!e||"string"!=typeof e)throw new Error("`appId` is missing.");if(!n||"string"!=typeof n)throw new Error("`apiKey` is missing.");if(!o||o&&("string"!=typeof o||!P.includes(o)))throw new Error(`\`region\` is required and must be one of the following: ${P.join(", ")}`);return function({appId:e,apiKey:r,authMode:t,algoliaAgents:a,region:n,...o}){const s=function(e,r,t="WithinHeaders"){const a={"x-algolia-api-key":r,"x-algolia-application-id":e};return{headers:()=>"WithinHeaders"===t?a:{},queryParameters:()=>"WithinQueryParameters"===t?a:{}}}(e,r,t),i=g({hosts:(u=n,[{url:"data.{region}.algolia.com".replace("{region}",u),accept:"readWrite",protocol:"https"}]),...o,algoliaAgent:w({algoliaAgents:a,client:"Ingestion",version:f}),baseHeaders:{"content-type":"text/plain",...s.headers(),...o.baseHeaders},baseQueryParameters:{...s.queryParameters(),...o.baseQueryParameters}});var u;return{transporter:i,appId:e,clearCache:()=>Promise.all([i.requestsCache.clear(),i.responsesCache.clear()]).then((()=>{})),get _ua(){return i.algoliaAgent.value},addAlgoliaAgent(e,r){i.algoliaAgent.add({segment:e,version:r})},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`.");const t={method:"POST",path:"/1/authentications",queryParameters:{},headers:{},data:e};return i.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`.");const t={method:"POST",path:"/1/destinations",queryParameters:{},headers:{},data:e};return i.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`.");if(!e.input)throw new Error("Parameter `sourceCreate.input` is required when calling `createSource`.");const t={method:"POST",path:"/1/sources",queryParameters:{},headers:{},data:e};return i.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.trigger)throw new Error("Parameter `taskCreate.trigger` is required when calling `createTask`.");if(!e.action)throw new Error("Parameter `taskCreate.action` is required when calling `createTask`.");const t={method:"POST",path:"/1/tasks",queryParameters:{},headers:{},data:e};return i.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`.");const t={method:"POST",path:"/1/transformations",queryParameters:{},headers:{},data:e};return i.request(t,r)},customDelete({path:e,parameters:r},t){if(!e)throw new Error("Parameter `path` is required when calling `customDelete`.");const a={method:"DELETE",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{}};return i.request(a,t)},customGet({path:e,parameters:r},t){if(!e)throw new Error("Parameter `path` is required when calling `customGet`.");const a={method:"GET",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{}};return i.request(a,t)},customPost({path:e,parameters:r,body:t},a){if(!e)throw new Error("Parameter `path` is required when calling `customPost`.");const n={method:"POST",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{},data:t||{}};return i.request(n,a)},customPut({path:e,parameters:r,body:t},a){if(!e)throw new Error("Parameter `path` is required when calling `customPut`.");const n={method:"PUT",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{},data:t||{}};return i.request(n,a)},deleteAuthentication({authenticationID:e},r){if(!e)throw new Error("Parameter `authenticationID` is required when calling `deleteAuthentication`.");const t={method:"DELETE",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},deleteDestination({destinationID:e},r){if(!e)throw new Error("Parameter `destinationID` is required when calling `deleteDestination`.");const t={method:"DELETE",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},deleteSource({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `deleteSource`.");const t={method:"DELETE",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},deleteTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `deleteTask`.");const t={method:"DELETE",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},deleteTransformation({transformationID:e},r){if(!e)throw new Error("Parameter `transformationID` is required when calling `deleteTransformation`.");const t={method:"DELETE",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},disableTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `disableTask`.");const t={method:"PUT",path:"/1/tasks/{taskID}/disable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},enableTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `enableTask`.");const t={method:"PUT",path:"/1/tasks/{taskID}/enable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},getAuthentication({authenticationID:e},r){if(!e)throw new Error("Parameter `authenticationID` is required when calling `getAuthentication`.");const t={method:"GET",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},getAuthentications({itemsPerPage:e,page:r,type:t,platform:a,sort:n,order:o}={},s=void 0){const u={};void 0!==e&&(u.itemsPerPage=e.toString()),void 0!==r&&(u.page=r.toString()),void 0!==t&&(u.type=t.toString()),void 0!==a&&(u.platform=a.toString()),void 0!==n&&(u.sort=n.toString()),void 0!==o&&(u.order=o.toString());const c={method:"GET",path:"/1/authentications",queryParameters:u,headers:{}};return i.request(c,s)},getDestination({destinationID:e},r){if(!e)throw new Error("Parameter `destinationID` is required when calling `getDestination`.");const t={method:"GET",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},getDestinations({itemsPerPage:e,page:r,type:t,authenticationID:a,sort:n,order:o}={},s=void 0){const u={};void 0!==e&&(u.itemsPerPage=e.toString()),void 0!==r&&(u.page=r.toString()),void 0!==t&&(u.type=t.toString()),void 0!==a&&(u.authenticationID=a.toString()),void 0!==n&&(u.sort=n.toString()),void 0!==o&&(u.order=o.toString());const c={method:"GET",path:"/1/destinations",queryParameters:u,headers:{}};return i.request(c,s)},getEvent({runID:e,eventID:r},t){if(!e)throw new Error("Parameter `runID` is required when calling `getEvent`.");if(!r)throw new Error("Parameter `eventID` is required when calling `getEvent`.");const a={method:"GET",path:"/1/runs/{runID}/events/{eventID}".replace("{runID}",encodeURIComponent(e)).replace("{eventID}",encodeURIComponent(r)),queryParameters:{},headers:{}};return i.request(a,t)},getEvents({runID:e,itemsPerPage:r,page:t,status:a,type:n,sort:o,order:s,startDate:u,endDate:c},d){if(!e)throw new Error("Parameter `runID` is required when calling `getEvents`.");const h="/1/runs/{runID}/events".replace("{runID}",encodeURIComponent(e)),m={};void 0!==r&&(m.itemsPerPage=r.toString()),void 0!==t&&(m.page=t.toString()),void 0!==a&&(m.status=a.toString()),void 0!==n&&(m.type=n.toString()),void 0!==o&&(m.sort=o.toString()),void 0!==s&&(m.order=s.toString()),void 0!==u&&(m.startDate=u.toString()),void 0!==c&&(m.endDate=c.toString());const l={method:"GET",path:h,queryParameters:m,headers:{}};return i.request(l,d)},getRun({runID:e},r){if(!e)throw new Error("Parameter `runID` is required when calling `getRun`.");const t={method:"GET",path:"/1/runs/{runID}".replace("{runID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},getRuns({itemsPerPage:e,page:r,status:t,taskID:a,sort:n,order:o,startDate:s,endDate:u}={},c=void 0){const d={};void 0!==e&&(d.itemsPerPage=e.toString()),void 0!==r&&(d.page=r.toString()),void 0!==t&&(d.status=t.toString()),void 0!==a&&(d.taskID=a.toString()),void 0!==n&&(d.sort=n.toString()),void 0!==o&&(d.order=o.toString()),void 0!==s&&(d.startDate=s.toString()),void 0!==u&&(d.endDate=u.toString());const h={method:"GET",path:"/1/runs",queryParameters:d,headers:{}};return i.request(h,c)},getSource({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `getSource`.");const t={method:"GET",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},getSources({itemsPerPage:e,page:r,type:t,authenticationID:a,sort:n,order:o}={},s=void 0){const u={};void 0!==e&&(u.itemsPerPage=e.toString()),void 0!==r&&(u.page=r.toString()),void 0!==t&&(u.type=t.toString()),void 0!==a&&(u.authenticationID=a.toString()),void 0!==n&&(u.sort=n.toString()),void 0!==o&&(u.order=o.toString());const c={method:"GET",path:"/1/sources",queryParameters:u,headers:{}};return i.request(c,s)},getTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `getTask`.");const t={method:"GET",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},getTasks({itemsPerPage:e,page:r,action:t,enabled:a,sourceID:n,destinationID:o,triggerType:s,sort:u,order:c}={},d=void 0){const h={};void 0!==e&&(h.itemsPerPage=e.toString()),void 0!==r&&(h.page=r.toString()),void 0!==t&&(h.action=t.toString()),void 0!==a&&(h.enabled=a.toString()),void 0!==n&&(h.sourceID=n.toString()),void 0!==o&&(h.destinationID=o.toString()),void 0!==s&&(h.triggerType=s.toString()),void 0!==u&&(h.sort=u.toString()),void 0!==c&&(h.order=c.toString());const m={method:"GET",path:"/1/tasks",queryParameters:h,headers:{}};return i.request(m,d)},getTransformation({transformationID:e},r){if(!e)throw new Error("Parameter `transformationID` is required when calling `getTransformation`.");const t={method:"GET",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},getTransformations({sort:e,order:r}={},t=void 0){const a={};void 0!==e&&(a.sort=e.toString()),void 0!==r&&(a.order=r.toString());const n={method:"GET",path:"/1/transformations",queryParameters:a,headers:{}};return i.request(n,t)},runTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `runTask`.");const t={method:"POST",path:"/1/tasks/{taskID}/run".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.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`.");const t={method:"POST",path:"/1/authentications/search",queryParameters:{},headers:{},data:e};return i.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`.");const t={method:"POST",path:"/1/destinations/search",queryParameters:{},headers:{},data:e};return i.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`.");const t={method:"POST",path:"/1/sources/search",queryParameters:{},headers:{},data:e};return i.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`.");const t={method:"POST",path:"/1/tasks/search",queryParameters:{},headers:{},data:e};return i.request(t,r)},searchTransformations(e,r){if(!e)throw new Error("Parameter `transformationSearch` is required when calling `searchTransformations`.");if(!e.transformationsIDs)throw new Error("Parameter `transformationSearch.transformationsIDs` is required when calling `searchTransformations`.");const t={method:"POST",path:"/1/transformations/search",queryParameters:{},headers:{},data:e};return i.request(t,r)},triggerDockerSourceDiscover({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `triggerDockerSourceDiscover`.");const t={method:"POST",path:"/1/sources/{sourceID}/discover".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},tryTransformations(e,r){if(!e)throw new Error("Parameter `transformationTry` is required when calling `tryTransformations`.");if(!e.code)throw new Error("Parameter `transformationTry.code` is required when calling `tryTransformations`.");if(!e.sampleRecord)throw new Error("Parameter `transformationTry.sampleRecord` is required when calling `tryTransformations`.");const t={method:"POST",path:"/1/transformations/try",queryParameters:{},headers:{},data:e};return i.request(t,r)},updateAuthentication({authenticationID:e,authenticationUpdate:r},t){if(!e)throw new Error("Parameter `authenticationID` is required when calling `updateAuthentication`.");if(!r)throw new Error("Parameter `authenticationUpdate` is required when calling `updateAuthentication`.");const a={method:"PATCH",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return i.request(a,t)},updateDestination({destinationID:e,destinationUpdate:r},t){if(!e)throw new Error("Parameter `destinationID` is required when calling `updateDestination`.");if(!r)throw new Error("Parameter `destinationUpdate` is required when calling `updateDestination`.");const a={method:"PATCH",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return i.request(a,t)},updateSource({sourceID:e,sourceUpdate:r},t){if(!e)throw new Error("Parameter `sourceID` is required when calling `updateSource`.");if(!r)throw new Error("Parameter `sourceUpdate` is required when calling `updateSource`.");const a={method:"PATCH",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return i.request(a,t)},updateTask({taskID:e,taskUpdate:r},t){if(!e)throw new Error("Parameter `taskID` is required when calling `updateTask`.");if(!r)throw new Error("Parameter `taskUpdate` is required when calling `updateTask`.");const a={method:"PATCH",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return i.request(a,t)},updateTransformation({transformationID:e,transformationCreate:r},t){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`.");const a={method:"PUT",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return i.request(a,t)},validateSource(e,r=void 0){const t={method:"POST",path:"/1/sources/validate",queryParameters:{},headers:{},data:e||{}};return i.request(t,r)},validateSourceBeforeUpdate({sourceID:e,sourceUpdate:r},t){if(!e)throw new Error("Parameter `sourceID` is required when calling `validateSourceBeforeUpdate`.");if(!r)throw new Error("Parameter `sourceUpdate` is required when calling `validateSourceBeforeUpdate`.");const a={method:"POST",path:"/1/sources/{sourceID}/validate".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return i.request(a,t)}}}({appId:e,apiKey:n,region:o,timeouts:{connect:1e3,read:2e3,write:3e4},requester:{send:function(e){return new Promise((r=>{const t=new XMLHttpRequest;t.open(e.method,e.url,!0),Object.keys(e.headers).forEach((r=>t.setRequestHeader(r,e.headers[r])));const a=(e,a)=>setTimeout((()=>{t.abort(),r({status:0,content:a,isTimedOut:!0})}),e),n=a(e.connectTimeout,"Connection timeout");let o;t.onreadystatechange=()=>{t.readyState>t.OPENED&&void 0===o&&(clearTimeout(n),o=a(e.responseTimeout,"Socket timeout"))},t.onerror=()=>{0===t.status&&(clearTimeout(n),clearTimeout(o),r({content:t.responseText||"Network request failed",status:t.status,isTimedOut:!1}))},t.onload=()=>{clearTimeout(n),clearTimeout(o),r({content:t.responseText,status:t.status,isTimedOut:!1})},t.send(e.data)}))}},algoliaAgents:[{segment:"Browser"}],authMode:"WithinQueryParameters",responsesCache:a(),requestsCache:a({serializable:!1}),hostsCache:t({caches:[r({key:`${f}-${e}`}),a()]}),...s})},e.isOnDemandTrigger=function(e){return"onDemand"===e.type},e.isScheduleTrigger=function(e){return"schedule"===e.type},e.isSubscriptionTrigger=function(e){return"subscription"===e.type}}));
+/*! ingestion.umd.js | 1.0.0-beta.12 | © Algolia, inc. | https://github.com/algolia/algoliasearch-client-javascript */
+!function(e,r){"object"==typeof exports&&"undefined"!=typeof module?r(exports):"function"==typeof define&&define.amd?define(["exports"],r):r((e="undefined"!=typeof globalThis?globalThis:e||self)["@algolia/ingestion"]={})}(this,(function(e){"use strict";function r(e){let r;const t=`algolia-client-js-${e.key}`;function a(){return void 0===r&&(r=e.localStorage||window.localStorage),r}function n(){return JSON.parse(a().getItem(t)||"{}")}function s(e){a().setItem(t,JSON.stringify(e))}return{get:(r,t,a={miss:()=>Promise.resolve()})=>Promise.resolve().then((()=>(function(){const r=e.timeToLive?1e3*e.timeToLive:null,t=n(),a=Object.fromEntries(Object.entries(t).filter((([,e])=>void 0!==e.timestamp)));if(s(a),!r)return;s(Object.fromEntries(Object.entries(a).filter((([,e])=>{const t=(new Date).getTime();return!(e.timestamp+r<t)}))))}(),n()[JSON.stringify(r)]))).then((e=>Promise.all([e?e.value:t(),void 0!==e]))).then((([e,r])=>Promise.all([e,r||a.miss(e)]))).then((([e])=>e)),set:(e,r)=>Promise.resolve().then((()=>{const s=n();return s[JSON.stringify(e)]={timestamp:(new Date).getTime(),value:r},a().setItem(t,JSON.stringify(s)),r})),delete:e=>Promise.resolve().then((()=>{const r=n();delete r[JSON.stringify(e)],a().setItem(t,JSON.stringify(r))})),clear:()=>Promise.resolve().then((()=>{a().removeItem(t)}))}}function t(e){const r=[...e.caches],a=r.shift();return void 0===a?{get:(e,r,t={miss:()=>Promise.resolve()})=>r().then((e=>Promise.all([e,t.miss(e)]))).then((([e])=>e)),set:(e,r)=>Promise.resolve(r),delete:e=>Promise.resolve(),clear:()=>Promise.resolve()}:{get:(e,n,s={miss:()=>Promise.resolve()})=>a.get(e,n,s).catch((()=>t({caches:r}).get(e,n,s))),set:(e,n)=>a.set(e,n).catch((()=>t({caches:r}).set(e,n))),delete:e=>a.delete(e).catch((()=>t({caches:r}).delete(e))),clear:()=>a.clear().catch((()=>t({caches:r}).clear()))}}function a(e={serializable:!0}){let r={};return{get(t,a,n={miss:()=>Promise.resolve()}){const s=JSON.stringify(t);if(s in r)return Promise.resolve(e.serializable?JSON.parse(r[s]):r[s]);const o=a();return o.then((e=>n.miss(e))).then((()=>o))},set:(t,a)=>(r[JSON.stringify(t)]=e.serializable?JSON.stringify(a):a,Promise.resolve(a)),delete:e=>(delete r[JSON.stringify(e)],Promise.resolve()),clear:()=>(r={},Promise.resolve())}}const n=12e4;function s(e,r="up"){const t=Date.now();return{...e,status:r,lastUpdate:t,isUp:function(){return"up"===r||Date.now()-t>n},isTimedOut:function(){return"timed out"===r&&Date.now()-t<=n}}}function o(e,r,t){return(r=function(e){var r=function(e,r){if("object"!=typeof e||!e)return e;var t=e[Symbol.toPrimitive];if(void 0!==t){var a=t.call(e,r||"default");if("object"!=typeof a)return a;throw new TypeError("@@toPrimitive must return a primitive value.")}return("string"===r?String:Number)(e)}(e,"string");return"symbol"==typeof r?r:r+""}(r))in e?Object.defineProperty(e,r,{value:t,enumerable:!0,configurable:!0,writable:!0}):e[r]=t,e}class i extends Error{constructor(e,r){super(e),o(this,"name","AlgoliaError"),r&&(this.name=r)}}class u extends i{constructor(e,r,t){super(e,t),o(this,"stackTrace",void 0),this.stackTrace=r}}class c extends u{constructor(e){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.",e,"RetryError")}}class d extends u{constructor(e,r,t,a="ApiError"){super(e,t,a),o(this,"status",void 0),this.status=r}}class h extends i{constructor(e,r){super(e,"DeserializationError"),o(this,"response",void 0),this.response=r}}class m extends d{constructor(e,r,t,a){super(e,r,a,"DetailedApiError"),o(this,"error",void 0),this.error=t}}function l(e,r,t){const a=(n=t,Object.keys(n).filter((e=>void 0!==n[e])).sort().map((e=>`${e}=${encodeURIComponent("[object Array]"===Object.prototype.toString.call(n[e])?n[e].join(","):n[e]).replaceAll("+","%20")}`)).join("&"));var n;let s=`${e.protocol}://${e.url}${e.port?`:${e.port}`:""}/${"/"===r.charAt(0)?r.substring(1):r}`;return a.length&&(s+=`?${a}`),s}function p(e){const r=e.request.headers["x-algolia-api-key"]?{"x-algolia-api-key":"*****"}:{};return{...e,request:{...e.request,headers:{...e.request.headers,...r}}}}function g({hosts:e,hostsCache:r,baseHeaders:t,baseQueryParameters:a,algoliaAgent:n,timeouts:o,requester:i,requestsCache:u,responsesCache:g}){async function w(u,g,w=!0){const P=[],f=function(e,r){if("GET"===e.method||void 0===e.data&&void 0===r.data)return;const t=Array.isArray(e.data)?e.data:{...e.data,...r.data};return JSON.stringify(t)}(u,g),q=function(e,r,t){const a={Accept:"application/json",...e,...r,...t},n={};return Object.keys(a).forEach((e=>{const r=a[e];n[e.toLowerCase()]=r})),n}(t,u.headers,g.headers),D="GET"===u.method?{...u.data,...g.data}:{},I={...a,...u.queryParameters,...D};if(n.value&&(I["x-algolia-agent"]=n.value),g&&g.queryParameters)for(const e of Object.keys(g.queryParameters))g.queryParameters[e]&&"[object Object]"!==Object.prototype.toString.call(g.queryParameters[e])?I[e]=g.queryParameters[e].toString():I[e]=g.queryParameters[e];let T=0;const k=async(e,t)=>{const a=e.pop();if(void 0===a)throw new c(function(e){return e.map((e=>p(e)))}(P));let n=w?g.timeouts?.read||o.read:g.timeouts?.write||o.write;const D={data:f,headers:q,method:u.method,url:l(a,u.path,I),connectTimeout:t(T,g.timeouts?.connect||o.connect),responseTimeout:t(T,n)},y=r=>{const t={request:D,response:r,host:a,triesLeft:e.length};return P.push(t),t},E=await i.send(D);if(function({isTimedOut:e,status:r}){return e||function({isTimedOut:e,status:r}){return!e&&!~~r}({isTimedOut:e,status:r})||2!=~~(r/100)&&4!=~~(r/100)}(E)){const n=y(E);return E.isTimedOut&&T++,console.log("Retryable failure",p(n)),await r.set(a,s(a,E.isTimedOut?"timed out":"down")),k(e,t)}if(function({status:e}){return 2==~~(e/100)}(E))return function(e){try{return JSON.parse(e.content)}catch(r){throw new h(r.message,e)}}(E);throw y(E),function({content:e,status:r},t){try{const a=JSON.parse(e);return"error"in a?new m(a.message,r,a.error,t):new d(a.message,r,t)}catch(e){}return new d(e,r,t)}(E,P)},y=e.filter((e=>"readWrite"===e.accept||(w?"read"===e.accept:"write"===e.accept))),E=await async function(e){const t=await Promise.all(e.map((e=>r.get(e,(()=>Promise.resolve(s(e))))))),a=t.filter((e=>e.isUp())),n=t.filter((e=>e.isTimedOut())),o=[...a,...n];return{hosts:o.length>0?o:e,getTimeout:(e,r)=>(0===n.length&&0===e?1:n.length+3+e)*r}}(y);return k([...E.hosts].reverse(),E.getTimeout)}return{hostsCache:r,requester:i,timeouts:o,algoliaAgent:n,baseHeaders:t,baseQueryParameters:a,hosts:e,request:function(e,r={}){const n=e.useReadTransporter||"GET"===e.method;if(!n)return w(e,r,n);const s=()=>w(e,r);if(!0!==(r.cacheable||e.cacheable))return s();const o={request:e,requestOptions:r,transporter:{queryParameters:a,headers:t}};return g.get(o,(()=>u.get(o,(()=>u.set(o,s()).then((e=>Promise.all([u.delete(o),e])),(e=>Promise.all([u.delete(o),Promise.reject(e)]))).then((([e,r])=>r))))),{miss:e=>g.set(o,e)})},requestsCache:u,responsesCache:g}}function w({algoliaAgents:e,client:r,version:t}){const a=function(e){const r={value:`Algolia for JavaScript (${e})`,add(e){const t=`; ${e.segment}${void 0!==e.version?` (${e.version})`:""}`;return-1===r.value.indexOf(t)&&(r.value=`${r.value}${t}`),r}};return r}(t).add({segment:r,version:t});return e.forEach((e=>a.add(e))),a}const P="1.0.0-beta.12",f=["eu","us"];e.apiClientVersion=P,e.ingestionClient=function(e,n,s,o){if(!e||"string"!=typeof e)throw new Error("`appId` is missing.");if(!n||"string"!=typeof n)throw new Error("`apiKey` is missing.");if(!s||s&&("string"!=typeof s||!f.includes(s)))throw new Error(`\`region\` is required and must be one of the following: ${f.join(", ")}`);return function({appId:e,apiKey:r,authMode:t,algoliaAgents:a,region:n,...s}){const o=function(e,r,t="WithinHeaders"){const a={"x-algolia-api-key":r,"x-algolia-application-id":e};return{headers:()=>"WithinHeaders"===t?a:{},queryParameters:()=>"WithinQueryParameters"===t?a:{}}}(e,r,t),i=g({hosts:(u=n,[{url:"data.{region}.algolia.com".replace("{region}",u),accept:"readWrite",protocol:"https"}]),...s,algoliaAgent:w({algoliaAgents:a,client:"Ingestion",version:P}),baseHeaders:{"content-type":"text/plain",...o.headers(),...s.baseHeaders},baseQueryParameters:{...o.queryParameters(),...s.baseQueryParameters}});var u;return{transporter:i,appId:e,clearCache:()=>Promise.all([i.requestsCache.clear(),i.responsesCache.clear()]).then((()=>{})),get _ua(){return i.algoliaAgent.value},addAlgoliaAgent(e,r){i.algoliaAgent.add({segment:e,version:r})},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`.");const t={method:"POST",path:"/1/authentications",queryParameters:{},headers:{},data:e};return i.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`.");const t={method:"POST",path:"/1/destinations",queryParameters:{},headers:{},data:e};return i.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`.");if(!e.input)throw new Error("Parameter `sourceCreate.input` is required when calling `createSource`.");const t={method:"POST",path:"/1/sources",queryParameters:{},headers:{},data:e};return i.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`.");const t={method:"POST",path:"/2/tasks",queryParameters:{},headers:{},data:e};return i.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`.");const t={method:"POST",path:"/1/tasks",queryParameters:{},headers:{},data:e};return i.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`.");const t={method:"POST",path:"/1/transformations",queryParameters:{},headers:{},data:e};return i.request(t,r)},customDelete({path:e,parameters:r},t){if(!e)throw new Error("Parameter `path` is required when calling `customDelete`.");const a={method:"DELETE",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{}};return i.request(a,t)},customGet({path:e,parameters:r},t){if(!e)throw new Error("Parameter `path` is required when calling `customGet`.");const a={method:"GET",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{}};return i.request(a,t)},customPost({path:e,parameters:r,body:t},a){if(!e)throw new Error("Parameter `path` is required when calling `customPost`.");const n={method:"POST",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{},data:t||{}};return i.request(n,a)},customPut({path:e,parameters:r,body:t},a){if(!e)throw new Error("Parameter `path` is required when calling `customPut`.");const n={method:"PUT",path:"/{path}".replace("{path}",e),queryParameters:r||{},headers:{},data:t||{}};return i.request(n,a)},deleteAuthentication({authenticationID:e},r){if(!e)throw new Error("Parameter `authenticationID` is required when calling `deleteAuthentication`.");const t={method:"DELETE",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},deleteDestination({destinationID:e},r){if(!e)throw new Error("Parameter `destinationID` is required when calling `deleteDestination`.");const t={method:"DELETE",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},deleteSource({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `deleteSource`.");const t={method:"DELETE",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},deleteTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `deleteTask`.");const t={method:"DELETE",path:"/2/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},deleteTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `deleteTaskV1`.");const t={method:"DELETE",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},deleteTransformation({transformationID:e},r){if(!e)throw new Error("Parameter `transformationID` is required when calling `deleteTransformation`.");const t={method:"DELETE",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},disableTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `disableTask`.");const t={method:"PUT",path:"/2/tasks/{taskID}/disable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},disableTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `disableTaskV1`.");const t={method:"PUT",path:"/1/tasks/{taskID}/disable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},enableTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `enableTask`.");const t={method:"PUT",path:"/2/tasks/{taskID}/enable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},enableTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `enableTaskV1`.");const t={method:"PUT",path:"/1/tasks/{taskID}/enable".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},getAuthentication({authenticationID:e},r){if(!e)throw new Error("Parameter `authenticationID` is required when calling `getAuthentication`.");const t={method:"GET",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},getDestination({destinationID:e},r){if(!e)throw new Error("Parameter `destinationID` is required when calling `getDestination`.");const t={method:"GET",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},getEvent({runID:e,eventID:r},t){if(!e)throw new Error("Parameter `runID` is required when calling `getEvent`.");if(!r)throw new Error("Parameter `eventID` is required when calling `getEvent`.");const a={method:"GET",path:"/1/runs/{runID}/events/{eventID}".replace("{runID}",encodeURIComponent(e)).replace("{eventID}",encodeURIComponent(r)),queryParameters:{},headers:{}};return i.request(a,t)},getRun({runID:e},r){if(!e)throw new Error("Parameter `runID` is required when calling `getRun`.");const t={method:"GET",path:"/1/runs/{runID}".replace("{runID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},getSource({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `getSource`.");const t={method:"GET",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},getTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `getTask`.");const t={method:"GET",path:"/2/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},getTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `getTaskV1`.");const t={method:"GET",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},getTransformation({transformationID:e},r){if(!e)throw new Error("Parameter `transformationID` is required when calling `getTransformation`.");const t={method:"GET",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},listAuthentications({itemsPerPage:e,page:r,type:t,platform:a,sort:n,order:s}={},o=void 0){const u={};void 0!==e&&(u.itemsPerPage=e.toString()),void 0!==r&&(u.page=r.toString()),void 0!==t&&(u.type=t.toString()),void 0!==a&&(u.platform=a.toString()),void 0!==n&&(u.sort=n.toString()),void 0!==s&&(u.order=s.toString());const c={method:"GET",path:"/1/authentications",queryParameters:u,headers:{}};return i.request(c,o)},listDestinations({itemsPerPage:e,page:r,type:t,authenticationID:a,sort:n,order:s}={},o=void 0){const u={};void 0!==e&&(u.itemsPerPage=e.toString()),void 0!==r&&(u.page=r.toString()),void 0!==t&&(u.type=t.toString()),void 0!==a&&(u.authenticationID=a.toString()),void 0!==n&&(u.sort=n.toString()),void 0!==s&&(u.order=s.toString());const c={method:"GET",path:"/1/destinations",queryParameters:u,headers:{}};return i.request(c,o)},listEvents({runID:e,itemsPerPage:r,page:t,status:a,type:n,sort:s,order:o,startDate:u,endDate:c},d){if(!e)throw new Error("Parameter `runID` is required when calling `listEvents`.");const h="/1/runs/{runID}/events".replace("{runID}",encodeURIComponent(e)),m={};void 0!==r&&(m.itemsPerPage=r.toString()),void 0!==t&&(m.page=t.toString()),void 0!==a&&(m.status=a.toString()),void 0!==n&&(m.type=n.toString()),void 0!==s&&(m.sort=s.toString()),void 0!==o&&(m.order=o.toString()),void 0!==u&&(m.startDate=u.toString()),void 0!==c&&(m.endDate=c.toString());const l={method:"GET",path:h,queryParameters:m,headers:{}};return i.request(l,d)},listRuns({itemsPerPage:e,page:r,status:t,taskID:a,sort:n,order:s,startDate:o,endDate:u}={},c=void 0){const d={};void 0!==e&&(d.itemsPerPage=e.toString()),void 0!==r&&(d.page=r.toString()),void 0!==t&&(d.status=t.toString()),void 0!==a&&(d.taskID=a.toString()),void 0!==n&&(d.sort=n.toString()),void 0!==s&&(d.order=s.toString()),void 0!==o&&(d.startDate=o.toString()),void 0!==u&&(d.endDate=u.toString());const h={method:"GET",path:"/1/runs",queryParameters:d,headers:{}};return i.request(h,c)},listSources({itemsPerPage:e,page:r,type:t,authenticationID:a,sort:n,order:s}={},o=void 0){const u={};void 0!==e&&(u.itemsPerPage=e.toString()),void 0!==r&&(u.page=r.toString()),void 0!==t&&(u.type=t.toString()),void 0!==a&&(u.authenticationID=a.toString()),void 0!==n&&(u.sort=n.toString()),void 0!==s&&(u.order=s.toString());const c={method:"GET",path:"/1/sources",queryParameters:u,headers:{}};return i.request(c,o)},listTasks({itemsPerPage:e,page:r,action:t,enabled:a,sourceID:n,destinationID:s,triggerType:o,sort:u,order:c}={},d=void 0){const h={};void 0!==e&&(h.itemsPerPage=e.toString()),void 0!==r&&(h.page=r.toString()),void 0!==t&&(h.action=t.toString()),void 0!==a&&(h.enabled=a.toString()),void 0!==n&&(h.sourceID=n.toString()),void 0!==s&&(h.destinationID=s.toString()),void 0!==o&&(h.triggerType=o.toString()),void 0!==u&&(h.sort=u.toString()),void 0!==c&&(h.order=c.toString());const m={method:"GET",path:"/2/tasks",queryParameters:h,headers:{}};return i.request(m,d)},listTasksV1({itemsPerPage:e,page:r,action:t,enabled:a,sourceID:n,destinationID:s,triggerType:o,sort:u,order:c}={},d=void 0){const h={};void 0!==e&&(h.itemsPerPage=e.toString()),void 0!==r&&(h.page=r.toString()),void 0!==t&&(h.action=t.toString()),void 0!==a&&(h.enabled=a.toString()),void 0!==n&&(h.sourceID=n.toString()),void 0!==s&&(h.destinationID=s.toString()),void 0!==o&&(h.triggerType=o.toString()),void 0!==u&&(h.sort=u.toString()),void 0!==c&&(h.order=c.toString());const m={method:"GET",path:"/1/tasks",queryParameters:h,headers:{}};return i.request(m,d)},listTransformations({sort:e,order:r}={},t=void 0){const a={};void 0!==e&&(a.sort=e.toString()),void 0!==r&&(a.order=r.toString());const n={method:"GET",path:"/1/transformations",queryParameters:a,headers:{}};return i.request(n,t)},pushTask({taskID:e,batchWriteParams:r},t){if(!e)throw new Error("Parameter `taskID` is required when calling `pushTask`.");if(!r)throw new Error("Parameter `batchWriteParams` is required when calling `pushTask`.");if(!r.requests)throw new Error("Parameter `batchWriteParams.requests` is required when calling `pushTask`.");const a={method:"POST",path:"/2/tasks/{taskID}/push".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return i.request(a,t)},runTask({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `runTask`.");const t={method:"POST",path:"/2/tasks/{taskID}/run".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},runTaskV1({taskID:e},r){if(!e)throw new Error("Parameter `taskID` is required when calling `runTaskV1`.");const t={method:"POST",path:"/1/tasks/{taskID}/run".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.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`.");const t={method:"POST",path:"/1/authentications/search",queryParameters:{},headers:{},data:e};return i.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`.");const t={method:"POST",path:"/1/destinations/search",queryParameters:{},headers:{},data:e};return i.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`.");const t={method:"POST",path:"/1/sources/search",queryParameters:{},headers:{},data:e};return i.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`.");const t={method:"POST",path:"/2/tasks/search",queryParameters:{},headers:{},data:e};return i.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`.");const t={method:"POST",path:"/1/tasks/search",queryParameters:{},headers:{},data:e};return i.request(t,r)},searchTransformations(e,r){if(!e)throw new Error("Parameter `transformationSearch` is required when calling `searchTransformations`.");if(!e.transformationsIDs)throw new Error("Parameter `transformationSearch.transformationsIDs` is required when calling `searchTransformations`.");const t={method:"POST",path:"/1/transformations/search",queryParameters:{},headers:{},data:e};return i.request(t,r)},triggerDockerSourceDiscover({sourceID:e},r){if(!e)throw new Error("Parameter `sourceID` is required when calling `triggerDockerSourceDiscover`.");const t={method:"POST",path:"/1/sources/{sourceID}/discover".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{}};return i.request(t,r)},tryTransformations(e,r){if(!e)throw new Error("Parameter `transformationTry` is required when calling `tryTransformations`.");if(!e.code)throw new Error("Parameter `transformationTry.code` is required when calling `tryTransformations`.");if(!e.sampleRecord)throw new Error("Parameter `transformationTry.sampleRecord` is required when calling `tryTransformations`.");const t={method:"POST",path:"/1/transformations/try",queryParameters:{},headers:{},data:e};return i.request(t,r)},updateAuthentication({authenticationID:e,authenticationUpdate:r},t){if(!e)throw new Error("Parameter `authenticationID` is required when calling `updateAuthentication`.");if(!r)throw new Error("Parameter `authenticationUpdate` is required when calling `updateAuthentication`.");const a={method:"PATCH",path:"/1/authentications/{authenticationID}".replace("{authenticationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return i.request(a,t)},updateDestination({destinationID:e,destinationUpdate:r},t){if(!e)throw new Error("Parameter `destinationID` is required when calling `updateDestination`.");if(!r)throw new Error("Parameter `destinationUpdate` is required when calling `updateDestination`.");const a={method:"PATCH",path:"/1/destinations/{destinationID}".replace("{destinationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return i.request(a,t)},updateSource({sourceID:e,sourceUpdate:r},t){if(!e)throw new Error("Parameter `sourceID` is required when calling `updateSource`.");if(!r)throw new Error("Parameter `sourceUpdate` is required when calling `updateSource`.");const a={method:"PATCH",path:"/1/sources/{sourceID}".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return i.request(a,t)},updateTask({taskID:e,taskUpdate:r},t){if(!e)throw new Error("Parameter `taskID` is required when calling `updateTask`.");if(!r)throw new Error("Parameter `taskUpdate` is required when calling `updateTask`.");const a={method:"PATCH",path:"/2/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return i.request(a,t)},updateTaskV1({taskID:e,taskUpdate:r},t){if(!e)throw new Error("Parameter `taskID` is required when calling `updateTaskV1`.");if(!r)throw new Error("Parameter `taskUpdate` is required when calling `updateTaskV1`.");const a={method:"PATCH",path:"/1/tasks/{taskID}".replace("{taskID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return i.request(a,t)},updateTransformation({transformationID:e,transformationCreate:r},t){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`.");const a={method:"PUT",path:"/1/transformations/{transformationID}".replace("{transformationID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return i.request(a,t)},validateSource(e,r=void 0){const t={method:"POST",path:"/1/sources/validate",queryParameters:{},headers:{},data:e||{}};return i.request(t,r)},validateSourceBeforeUpdate({sourceID:e,sourceUpdate:r},t){if(!e)throw new Error("Parameter `sourceID` is required when calling `validateSourceBeforeUpdate`.");if(!r)throw new Error("Parameter `sourceUpdate` is required when calling `validateSourceBeforeUpdate`.");const a={method:"POST",path:"/1/sources/{sourceID}/validate".replace("{sourceID}",encodeURIComponent(e)),queryParameters:{},headers:{},data:r};return i.request(a,t)}}}({appId:e,apiKey:n,region:s,timeouts:{connect:1e3,read:2e3,write:3e4},requester:{send:function(e){return new Promise((r=>{const t=new XMLHttpRequest;t.open(e.method,e.url,!0),Object.keys(e.headers).forEach((r=>t.setRequestHeader(r,e.headers[r])));const a=(e,a)=>setTimeout((()=>{t.abort(),r({status:0,content:a,isTimedOut:!0})}),e),n=a(e.connectTimeout,"Connection timeout");let s;t.onreadystatechange=()=>{t.readyState>t.OPENED&&void 0===s&&(clearTimeout(n),s=a(e.responseTimeout,"Socket timeout"))},t.onerror=()=>{0===t.status&&(clearTimeout(n),clearTimeout(s),r({content:t.responseText||"Network request failed",status:t.status,isTimedOut:!1}))},t.onload=()=>{clearTimeout(n),clearTimeout(s),r({content:t.responseText,status:t.status,isTimedOut:!1})},t.send(e.data)}))}},algoliaAgents:[{segment:"Browser"}],authMode:"WithinQueryParameters",responsesCache:a(),requestsCache:a({serializable:!1}),hostsCache:t({caches:[r({key:`${P}-${e}`}),a()]}),...o})},e.isOnDemandTrigger=function(e){return"onDemand"===e.type},e.isScheduleTrigger=function(e){return"schedule"===e.type},e.isSubscriptionTrigger=function(e){return"subscription"===e.type}}));

dist/model/clientMethodProps.d.ts

@@ -5,2 +5,3 @@ import type { ActionType } from './actionType';
 import type { AuthenticationUpdate } from './authenticationUpdate';
+import type { BatchWriteParams } from './batchWriteParams';
 import type { DestinationSortKeys } from './destinationSortKeys';
@@ -22,2 +23,3 @@ import type { DestinationType } from './destinationType';
 import type { TaskUpdate } from './taskUpdate';
+import type { TaskUpdateV1 } from './taskUpdateV1';
 import type { TransformationCreate } from './transformationCreate';
@@ -122,2 +124,11 @@ import type { TriggerType } from './triggerType';
 /**
+ * Properties for the `deleteTaskV1` method.
+ */
+export type DeleteTaskV1Props = {
+    /**
+     * Unique identifier of a task.
+     */
+    taskID: string;
+};
+/**
  * Properties for the `deleteTransformation` method.
@@ -141,2 +152,11 @@ */
 /**
+ * Properties for the `disableTaskV1` method.
+ */
+export type DisableTaskV1Props = {
+    /**
+     * Unique identifier of a task.
+     */
+    taskID: string;
+};
+/**
  * Properties for the `enableTask` method.
@@ -151,2 +171,11 @@ */
 /**
+ * Properties for the `enableTaskV1` method.
+ */
+export type EnableTaskV1Props = {
+    /**
+     * Unique identifier of a task.
+     */
+    taskID: string;
+};
+/**
  * Properties for the `getAuthentication` method.
@@ -161,6 +190,73 @@ */
 /**
- * Properties for the `getAuthentications` method.
+ * Properties for the `getDestination` method.
  */
-export type GetAuthenticationsProps = {
+export type GetDestinationProps = {
     /**
+     * Unique identifier of a destination.
+     */
+    destinationID: string;
+};
+/**
+ * Properties for the `getEvent` method.
+ */
+export type GetEventProps = {
+    /**
+     * Unique identifier of a task run.
+     */
+    runID: string;
+    /**
+     * Unique identifier of an event.
+     */
+    eventID: string;
+};
+/**
+ * Properties for the `getRun` method.
+ */
+export type GetRunProps = {
+    /**
+     * Unique identifier of a task run.
+     */
+    runID: string;
+};
+/**
+ * Properties for the `getSource` method.
+ */
+export type GetSourceProps = {
+    /**
+     * Unique identifier of a source.
+     */
+    sourceID: string;
+};
+/**
+ * Properties for the `getTask` method.
+ */
+export type GetTaskProps = {
+    /**
+     * Unique identifier of a task.
+     */
+    taskID: string;
+};
+/**
+ * Properties for the `getTaskV1` method.
+ */
+export type GetTaskV1Props = {
+    /**
+     * Unique identifier of a task.
+     */
+    taskID: string;
+};
+/**
+ * Properties for the `getTransformation` method.
+ */
+export type GetTransformationProps = {
+    /**
+     * Unique identifier of a transformation.
+     */
+    transformationID: string;
+};
+/**
+ * Properties for the `listAuthentications` method.
+ */
+export type ListAuthenticationsProps = {
+    /**
      * Number of items per page.
@@ -191,15 +287,6 @@ */
 /**
- * Properties for the `getDestination` method.
+ * Properties for the `listDestinations` method.
  */
-export type GetDestinationProps = {
+export type ListDestinationsProps = {
     /**
-     * Unique identifier of a destination.
-     */
-    destinationID: string;
-};
-/**
- * Properties for the `getDestinations` method.
- */
-export type GetDestinationsProps = {
-    /**
      * Number of items per page.
@@ -230,5 +317,5 @@ */
 /**
- * Properties for the `getEvent` method.
+ * Properties for the `listEvents` method.
  */
-export type GetEventProps = {
+export type ListEventsProps = {
     /**
@@ -239,15 +326,2 @@ * Unique identifier of a task run.
     /**
-     * Unique identifier of an event.
-     */
-    eventID: string;
-};
-/**
- * Properties for the `getEvents` method.
- */
-export type GetEventsProps = {
-    /**
-     * Unique identifier of a task run.
-     */
-    runID: string;
-    /**
      * Number of items per page.
@@ -286,15 +360,6 @@ */
 /**
- * Properties for the `getRun` method.
+ * Properties for the `listRuns` method.
  */
-export type GetRunProps = {
+export type ListRunsProps = {
     /**
-     * Unique identifier of a task run.
-     */
-    runID: string;
-};
-/**
- * Properties for the `getRuns` method.
- */
-export type GetRunsProps = {
-    /**
      * Number of items per page.
@@ -333,15 +398,6 @@ */
 /**
- * Properties for the `getSource` method.
+ * Properties for the `listSources` method.
  */
-export type GetSourceProps = {
+export type ListSourcesProps = {
     /**
-     * Unique identifier of a source.
-     */
-    sourceID: string;
-};
-/**
- * Properties for the `getSources` method.
- */
-export type GetSourcesProps = {
-    /**
      * Number of items per page.
@@ -372,14 +428,46 @@ */
 /**
- * Properties for the `getTask` method.
+ * Properties for the `listTasks` method.
  */
-export type GetTaskProps = {
+export type ListTasksProps = {
     /**
-     * Unique identifier of a task.
+     * Number of items per page.
      */
-    taskID: string;
+    itemsPerPage?: number;
+    /**
+     * Page number of the paginated API response.
+     */
+    page?: number;
+    /**
+     * Actions for filtering the list of tasks.
+     */
+    action?: ActionType[];
+    /**
+     * Whether to filter the list of tasks by the `enabled` status.
+     */
+    enabled?: boolean;
+    /**
+     * Source IDs for filtering the list of tasks.
+     */
+    sourceID?: string[];
+    /**
+     * Destination IDs for filtering the list of tasks.
+     */
+    destinationID?: string[];
+    /**
+     * Type of task trigger for filtering the list of tasks.
+     */
+    triggerType?: TriggerType[];
+    /**
+     * Property by which to sort the list of tasks.
+     */
+    sort?: TaskSortKeys;
+    /**
+     * Sort order of the response, ascending or descending.
+     */
+    order?: OrderKeys;
 };
 /**
- * Properties for the `getTasks` method.
+ * Properties for the `listTasksV1` method.
  */
-export type GetTasksProps = {
+export type ListTasksV1Props = {
     /**
@@ -423,22 +511,26 @@ * Number of items per page.
 /**
- * Properties for the `getTransformation` method.
+ * Properties for the `listTransformations` method.
  */
-export type GetTransformationProps = {
+export type ListTransformationsProps = {
     /**
-     * Unique identifier of a transformation.
+     * Property by which to sort the list.
      */
-    transformationID: string;
+    sort?: SortKeys;
+    /**
+     * Sort order of the response, ascending or descending.
+     */
+    order?: OrderKeys;
 };
 /**
- * Properties for the `getTransformations` method.
+ * Properties for the `pushTask` method.
  */
-export type GetTransformationsProps = {
+export type PushTaskProps = {
     /**
-     * Property by which to sort the list.
+     * Unique identifier of a task.
      */
-    sort?: SortKeys;
+    taskID: string;
     /**
-     * Sort order of the response, ascending or descending.
+     * Request body of a Search API `batch` request that will be pushed in the Connectors pipeline.
      */
-    order?: OrderKeys;
+    batchWriteParams: BatchWriteParams;
 };
@@ -455,2 +547,11 @@ /**
 /**
+ * Properties for the `runTaskV1` method.
+ */
+export type RunTaskV1Props = {
+    /**
+     * Unique identifier of a task.
+     */
+    taskID: string;
+};
+/**
  * Properties for the `triggerDockerSourceDiscover` method.
@@ -505,2 +606,12 @@ */
 /**
+ * Properties for the `updateTaskV1` method.
+ */
+export type UpdateTaskV1Props = {
+    /**
+     * Unique identifier of a task.
+     */
+    taskID: string;
+    taskUpdate: TaskUpdateV1;
+};
+/**
  * Properties for the `updateTransformation` method.
@@ -507,0 +618,0 @@ */

dist/model/index.d.ts

@@ -0,1 +1,2 @@
+export * from './action';
 export * from './actionType';
@@ -24,2 +25,4 @@ export * from './authAPIKey';
 export * from './authenticationUpdateResponse';
+export * from './batchRequest';
+export * from './batchWriteParams';
 export * from './bigCommerceChannel';
@@ -54,2 +57,3 @@ export * from './bigCommerceMetafield';
 export * from './listTasksResponse';
+export * from './listTasksResponseV1';
 export * from './listTransformationsResponse';
@@ -119,2 +123,3 @@ export * from './mappingFieldDirective';
 export * from './taskCreateTrigger';
+export * from './taskCreateV1';
 export * from './taskInput';
@@ -125,2 +130,4 @@ export * from './taskSearch';
 export * from './taskUpdateResponse';
+export * from './taskUpdateV1';
+export * from './taskV1';
 export * from './transformation';
@@ -127,0 +134,0 @@ export * from './transformationCreate';

dist/model/task.d.ts

 import type { ActionType } from './actionType';
 import type { TaskInput } from './taskInput';
-import type { Trigger } from './trigger';
 export type Task = {
@@ -17,3 +16,14 @@ /**
     destinationID: string;
-    trigger: Trigger;
+    /**
+     * Cron expression for the task\'s schedule.
+     */
+    cron?: string;
+    /**
+     * The last time the scheduled task ran in RFC 3339 format.
+     */
+    lastRun?: string;
+    /**
+     * The next scheduled run of the task in RFC 3339 format.
+     */
+    nextRun?: string;
     input?: TaskInput;
@@ -20,0 +30,0 @@ /**

dist/model/taskCreate.d.ts

 import type { ActionType } from './actionType';
-import type { TaskCreateTrigger } from './taskCreateTrigger';
 import type { TaskInput } from './taskInput';
@@ -16,5 +15,8 @@ /**
     destinationID: string;
-    trigger: TaskCreateTrigger;
     action: ActionType;
     /**
+     * Cron expression for the task\'s schedule.
+     */
+    cron?: string;
+    /**
      * Whether the task is enabled.
@@ -21,0 +23,0 @@ */

dist/model/taskUpdate.d.ts

 import type { TaskInput } from './taskInput';
-import type { TriggerUpdateInput } from './triggerUpdateInput';
 /**
@@ -11,3 +10,6 @@ * API request body for updating a task.
     destinationID?: string;
-    trigger?: TriggerUpdateInput;
+    /**
+     * Cron expression for the task\'s schedule.
+     */
+    cron?: string;
     input?: TaskInput;
@@ -14,0 +16,0 @@ /**

dist/src/ingestionClient.d.ts

@@ -7,3 +7,3 @@ import type { CreateClientOptions, RequestOptions } from '@algolia/client-common';
 import type { AuthenticationUpdateResponse } from '../model/authenticationUpdateResponse';
-import type { CustomDeleteProps, CustomGetProps, CustomPostProps, CustomPutProps, DeleteAuthenticationProps, DeleteDestinationProps, DeleteSourceProps, DeleteTaskProps, DeleteTransformationProps, DisableTaskProps, EnableTaskProps, GetAuthenticationProps, GetAuthenticationsProps, GetDestinationProps, GetDestinationsProps, GetEventProps, GetEventsProps, GetRunProps, GetRunsProps, GetSourceProps, GetSourcesProps, GetTaskProps, GetTasksProps, GetTransformationProps, GetTransformationsProps, RunTaskProps, TriggerDockerSourceDiscoverProps, UpdateAuthenticationProps, UpdateDestinationProps, UpdateSourceProps, UpdateTaskProps, UpdateTransformationProps, ValidateSourceBeforeUpdateProps } from '../model/clientMethodProps';
+import type { CustomDeleteProps, CustomGetProps, CustomPostProps, CustomPutProps, DeleteAuthenticationProps, DeleteDestinationProps, DeleteSourceProps, DeleteTaskProps, DeleteTaskV1Props, DeleteTransformationProps, DisableTaskProps, DisableTaskV1Props, EnableTaskProps, EnableTaskV1Props, GetAuthenticationProps, GetDestinationProps, GetEventProps, GetRunProps, GetSourceProps, GetTaskProps, GetTaskV1Props, GetTransformationProps, ListAuthenticationsProps, ListDestinationsProps, ListEventsProps, ListRunsProps, ListSourcesProps, ListTasksProps, ListTasksV1Props, ListTransformationsProps, PushTaskProps, RunTaskProps, RunTaskV1Props, TriggerDockerSourceDiscoverProps, UpdateAuthenticationProps, UpdateDestinationProps, UpdateSourceProps, UpdateTaskProps, UpdateTaskV1Props, UpdateTransformationProps, ValidateSourceBeforeUpdateProps } from '../model/clientMethodProps';
 import type { DeleteResponse } from '../model/deleteResponse';
@@ -21,2 +21,3 @@ import type { Destination } from '../model/destination';
 import type { ListTasksResponse } from '../model/listTasksResponse';
+import type { ListTasksResponseV1 } from '../model/listTasksResponseV1';
 import type { ListTransformationsResponse } from '../model/listTransformationsResponse';
@@ -39,4 +40,6 @@ import type { OnDemandTrigger } from '../model/onDemandTrigger';
 import type { TaskCreateTrigger } from '../model/taskCreateTrigger';
+import type { TaskCreateV1 } from '../model/taskCreateV1';
 import type { TaskSearch } from '../model/taskSearch';
 import type { TaskUpdateResponse } from '../model/taskUpdateResponse';
+import type { TaskV1 } from '../model/taskV1';
 import type { Transformation } from '../model/transformation';
@@ -50,3 +53,3 @@ import type { TransformationCreate } from '../model/transformationCreate';
 import type { Trigger } from '../model/trigger';
-export declare const apiClientVersion = "1.0.0-beta.11";
+export declare const apiClientVersion = "1.0.0-beta.12";
 export declare const REGIONS: readonly ["eu", "us"];
@@ -142,2 +145,9 @@ export type Region = (typeof REGIONS)[number];
     /**
+     * Creates a new task using the v1 endpoint, please use `createTask` instead.
+     *
+     * @param taskCreate - Request body for creating a task.
+     * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
+     */
+    createTaskV1(taskCreate: TaskCreateV1, requestOptions?: RequestOptions): Promise<TaskCreateResponse>;
+    /**
      * Creates a new transformation.
@@ -235,2 +245,10 @@ *
     /**
+     * Deletes a task by its ID using the v1 endpoint, please use `deleteTask` instead.
+     *
+     * @param deleteTaskV1 - The deleteTaskV1 object.
+     * @param deleteTaskV1.taskID - Unique identifier of a task.
+     * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
+     */
+    deleteTaskV1({ taskID }: DeleteTaskV1Props, requestOptions?: RequestOptions): Promise<DeleteResponse>;
+    /**
      * Deletes a transformation by its ID.
@@ -257,2 +275,15 @@ *
     /**
+     * Disables a task using the v1 endpoint, please use `disableTask` instead.
+     *
+     * Required API Key ACLs:
+     * - addObject
+     * - deleteIndex
+     * - editSettings.
+     *
+     * @param disableTaskV1 - The disableTaskV1 object.
+     * @param disableTaskV1.taskID - Unique identifier of a task.
+     * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
+     */
+    disableTaskV1({ taskID }: DisableTaskV1Props, requestOptions?: RequestOptions): Promise<TaskUpdateResponse>;
+    /**
      * Enables a task.
@@ -271,3 +302,3 @@ *
     /**
-     * Retrieves an authentication resource by its ID.
+     * Enables a task using the v1 endpoint, please use `enableTask` instead.
      *
@@ -279,9 +310,9 @@ * Required API Key ACLs:
      *
-     * @param getAuthentication - The getAuthentication object.
-     * @param getAuthentication.authenticationID - Unique identifier of an authentication resource.
+     * @param enableTaskV1 - The enableTaskV1 object.
+     * @param enableTaskV1.taskID - Unique identifier of a task.
      * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
      */
-    getAuthentication({ authenticationID }: GetAuthenticationProps, requestOptions?: RequestOptions): Promise<Authentication>;
+    enableTaskV1({ taskID }: EnableTaskV1Props, requestOptions?: RequestOptions): Promise<TaskUpdateResponse>;
     /**
-     * Retrieves a list of all authentication resources.
+     * Retrieves an authentication resource by its ID.
      *
@@ -293,12 +324,7 @@ * Required API Key ACLs:
      *
-     * @param getAuthentications - The getAuthentications object.
-     * @param getAuthentications.itemsPerPage - Number of items per page.
-     * @param getAuthentications.page - Page number of the paginated API response.
-     * @param getAuthentications.type - Type of authentication resource to retrieve.
-     * @param getAuthentications.platform - Ecommerce platform for which to retrieve authentication resources.
-     * @param getAuthentications.sort - Property by which to sort the list of authentication resources.
-     * @param getAuthentications.order - Sort order of the response, ascending or descending.
+     * @param getAuthentication - The getAuthentication object.
+     * @param getAuthentication.authenticationID - Unique identifier of an authentication resource.
      * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
      */
-    getAuthentications({ itemsPerPage, page, type, platform, sort, order, }?: GetAuthenticationsProps, requestOptions?: RequestOptions | undefined): Promise<ListAuthenticationsResponse>;
+    getAuthentication({ authenticationID }: GetAuthenticationProps, requestOptions?: RequestOptions): Promise<Authentication>;
     /**
@@ -318,3 +344,3 @@ * Retrieves a destination by its ID.
     /**
-     * Retrieves a list of destinations.
+     * Retrieves a single task run event by its ID.
      *
@@ -326,14 +352,10 @@ * Required API Key ACLs:
      *
-     * @param getDestinations - The getDestinations object.
-     * @param getDestinations.itemsPerPage - Number of items per page.
-     * @param getDestinations.page - Page number of the paginated API response.
-     * @param getDestinations.type - Destination type.
-     * @param getDestinations.authenticationID - Authentication ID used by destinations.
-     * @param getDestinations.sort - Property by which to sort the destinations.
-     * @param getDestinations.order - Sort order of the response, ascending or descending.
+     * @param getEvent - The getEvent object.
+     * @param getEvent.runID - Unique identifier of a task run.
+     * @param getEvent.eventID - Unique identifier of an event.
      * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
      */
-    getDestinations({ itemsPerPage, page, type, authenticationID, sort, order, }?: GetDestinationsProps, requestOptions?: RequestOptions | undefined): Promise<ListDestinationsResponse>;
+    getEvent({ runID, eventID }: GetEventProps, requestOptions?: RequestOptions): Promise<Event>;
     /**
-     * Retrieves a single task run event by its ID.
+     * Retrieve a single task run by its ID.
      *
@@ -345,10 +367,9 @@ * Required API Key ACLs:
      *
-     * @param getEvent - The getEvent object.
-     * @param getEvent.runID - Unique identifier of a task run.
-     * @param getEvent.eventID - Unique identifier of an event.
+     * @param getRun - The getRun object.
+     * @param getRun.runID - Unique identifier of a task run.
      * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
      */
-    getEvent({ runID, eventID }: GetEventProps, requestOptions?: RequestOptions): Promise<Event>;
+    getRun({ runID }: GetRunProps, requestOptions?: RequestOptions): Promise<Run>;
     /**
-     * Retrieves a list of events for a task run, identified by it\'s ID.
+     * Retrieve a source by its ID.
      *
@@ -360,17 +381,9 @@ * Required API Key ACLs:
      *
-     * @param getEvents - The getEvents object.
-     * @param getEvents.runID - Unique identifier of a task run.
-     * @param getEvents.itemsPerPage - Number of items per page.
-     * @param getEvents.page - Page number of the paginated API response.
-     * @param getEvents.status - Event status for filtering the list of task runs.
-     * @param getEvents.type - Event type for filtering the list of task runs.
-     * @param getEvents.sort - Property by which to sort the list of task run events.
-     * @param getEvents.order - Sort order of the response, ascending or descending.
-     * @param getEvents.startDate - Date and time in RFC 3339 format for the earliest events to retrieve. By default, the current time minus three hours is used.
-     * @param getEvents.endDate - Date and time in RFC 3339 format for the latest events to retrieve. By default, the current time is used.
+     * @param getSource - The getSource object.
+     * @param getSource.sourceID - Unique identifier of a source.
      * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
      */
-    getEvents({ runID, itemsPerPage, page, status, type, sort, order, startDate, endDate, }: GetEventsProps, requestOptions?: RequestOptions): Promise<ListEventsResponse>;
+    getSource({ sourceID }: GetSourceProps, requestOptions?: RequestOptions): Promise<Source>;
     /**
-     * Retrieve a single task run by its ID.
+     * Retrieves a task by its ID.
      *
@@ -382,9 +395,9 @@ * Required API Key ACLs:
      *
-     * @param getRun - The getRun object.
-     * @param getRun.runID - Unique identifier of a task run.
+     * @param getTask - The getTask object.
+     * @param getTask.taskID - Unique identifier of a task.
      * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
      */
-    getRun({ runID }: GetRunProps, requestOptions?: RequestOptions): Promise<Run>;
+    getTask({ taskID }: GetTaskProps, requestOptions?: RequestOptions): Promise<Task>;
     /**
-     * Retrieve a list of task runs.
+     * Retrieves a task by its ID using the v1 endpoint, please use `getTask` instead.
      *
@@ -396,16 +409,9 @@ * Required API Key ACLs:
      *
-     * @param getRuns - The getRuns object.
-     * @param getRuns.itemsPerPage - Number of items per page.
-     * @param getRuns.page - Page number of the paginated API response.
-     * @param getRuns.status - Run status for filtering the list of task runs.
-     * @param getRuns.taskID - Task ID for filtering the list of task runs.
-     * @param getRuns.sort - Property by which to sort the list of task runs.
-     * @param getRuns.order - Sort order of the response, ascending or descending.
-     * @param getRuns.startDate - Date in RFC 3339 format for the earliest run to retrieve. By default, the current day minus seven days is used.
-     * @param getRuns.endDate - Date in RFC 3339 format for the latest run to retrieve. By default, the current day is used.
+     * @param getTaskV1 - The getTaskV1 object.
+     * @param getTaskV1.taskID - Unique identifier of a task.
      * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
      */
-    getRuns({ itemsPerPage, page, status, taskID, sort, order, startDate, endDate, }?: GetRunsProps, requestOptions?: RequestOptions | undefined): Promise<RunListResponse>;
+    getTaskV1({ taskID }: GetTaskV1Props, requestOptions?: RequestOptions): Promise<TaskV1>;
     /**
-     * Retrieve a source by its ID.
+     * Retrieves a transformation by its ID.
      *
@@ -417,9 +423,9 @@ * Required API Key ACLs:
      *
-     * @param getSource - The getSource object.
-     * @param getSource.sourceID - Unique identifier of a source.
+     * @param getTransformation - The getTransformation object.
+     * @param getTransformation.transformationID - Unique identifier of a transformation.
      * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
      */
-    getSource({ sourceID }: GetSourceProps, requestOptions?: RequestOptions): Promise<Source>;
+    getTransformation({ transformationID }: GetTransformationProps, requestOptions?: RequestOptions): Promise<Transformation>;
     /**
-     * Retrieves a list of sources.
+     * Retrieves a list of all authentication resources.
      *
@@ -431,14 +437,14 @@ * Required API Key ACLs:
      *
-     * @param getSources - The getSources object.
-     * @param getSources.itemsPerPage - Number of items per page.
-     * @param getSources.page - Page number of the paginated API response.
-     * @param getSources.type - Source type. Some sources require authentication.
-     * @param getSources.authenticationID - Authentication IDs of the sources to retrieve. \'none\' returns sources that doesn\'t have an authentication resource.
-     * @param getSources.sort - Property by which to sort the list of sources.
-     * @param getSources.order - Sort order of the response, ascending or descending.
+     * @param listAuthentications - The listAuthentications object.
+     * @param listAuthentications.itemsPerPage - Number of items per page.
+     * @param listAuthentications.page - Page number of the paginated API response.
+     * @param listAuthentications.type - Type of authentication resource to retrieve.
+     * @param listAuthentications.platform - Ecommerce platform for which to retrieve authentication resources.
+     * @param listAuthentications.sort - Property by which to sort the list of authentication resources.
+     * @param listAuthentications.order - Sort order of the response, ascending or descending.
      * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
      */
-    getSources({ itemsPerPage, page, type, authenticationID, sort, order, }?: GetSourcesProps, requestOptions?: RequestOptions | undefined): Promise<ListSourcesResponse>;
+    listAuthentications({ itemsPerPage, page, type, platform, sort, order, }?: ListAuthenticationsProps, requestOptions?: RequestOptions | undefined): Promise<ListAuthenticationsResponse>;
     /**
-     * Retrieves a task by its ID.
+     * Retrieves a list of destinations.
      *
@@ -450,8 +456,72 @@ * Required API Key ACLs:
      *
-     * @param getTask - The getTask object.
-     * @param getTask.taskID - Unique identifier of a task.
+     * @param listDestinations - The listDestinations object.
+     * @param listDestinations.itemsPerPage - Number of items per page.
+     * @param listDestinations.page - Page number of the paginated API response.
+     * @param listDestinations.type - Destination type.
+     * @param listDestinations.authenticationID - Authentication ID used by destinations.
+     * @param listDestinations.sort - Property by which to sort the destinations.
+     * @param listDestinations.order - Sort order of the response, ascending or descending.
      * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
      */
-    getTask({ taskID }: GetTaskProps, requestOptions?: RequestOptions): Promise<Task>;
+    listDestinations({ itemsPerPage, page, type, authenticationID, sort, order, }?: ListDestinationsProps, requestOptions?: RequestOptions | undefined): Promise<ListDestinationsResponse>;
     /**
+     * Retrieves a list of events for a task run, identified by it\'s ID.
+     *
+     * Required API Key ACLs:
+     * - addObject
+     * - deleteIndex
+     * - editSettings.
+     *
+     * @param listEvents - The listEvents object.
+     * @param listEvents.runID - Unique identifier of a task run.
+     * @param listEvents.itemsPerPage - Number of items per page.
+     * @param listEvents.page - Page number of the paginated API response.
+     * @param listEvents.status - Event status for filtering the list of task runs.
+     * @param listEvents.type - Event type for filtering the list of task runs.
+     * @param listEvents.sort - Property by which to sort the list of task run events.
+     * @param listEvents.order - Sort order of the response, ascending or descending.
+     * @param listEvents.startDate - Date and time in RFC 3339 format for the earliest events to retrieve. By default, the current time minus three hours is used.
+     * @param listEvents.endDate - Date and time in RFC 3339 format for the latest events to retrieve. By default, the current time is used.
+     * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
+     */
+    listEvents({ runID, itemsPerPage, page, status, type, sort, order, startDate, endDate, }: ListEventsProps, requestOptions?: RequestOptions): Promise<ListEventsResponse>;
+    /**
+     * Retrieve a list of task runs.
+     *
+     * Required API Key ACLs:
+     * - addObject
+     * - deleteIndex
+     * - editSettings.
+     *
+     * @param listRuns - The listRuns object.
+     * @param listRuns.itemsPerPage - Number of items per page.
+     * @param listRuns.page - Page number of the paginated API response.
+     * @param listRuns.status - Run status for filtering the list of task runs.
+     * @param listRuns.taskID - Task ID for filtering the list of task runs.
+     * @param listRuns.sort - Property by which to sort the list of task runs.
+     * @param listRuns.order - Sort order of the response, ascending or descending.
+     * @param listRuns.startDate - Date in RFC 3339 format for the earliest run to retrieve. By default, the current day minus seven days is used.
+     * @param listRuns.endDate - Date in RFC 3339 format for the latest run to retrieve. By default, the current day is used.
+     * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
+     */
+    listRuns({ itemsPerPage, page, status, taskID, sort, order, startDate, endDate, }?: ListRunsProps, requestOptions?: RequestOptions | undefined): Promise<RunListResponse>;
+    /**
+     * Retrieves a list of sources.
+     *
+     * Required API Key ACLs:
+     * - addObject
+     * - deleteIndex
+     * - editSettings.
+     *
+     * @param listSources - The listSources object.
+     * @param listSources.itemsPerPage - Number of items per page.
+     * @param listSources.page - Page number of the paginated API response.
+     * @param listSources.type - Source type. Some sources require authentication.
+     * @param listSources.authenticationID - Authentication IDs of the sources to retrieve. \'none\' returns sources that doesn\'t have an authentication resource.
+     * @param listSources.sort - Property by which to sort the list of sources.
+     * @param listSources.order - Sort order of the response, ascending or descending.
+     * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
+     */
+    listSources({ itemsPerPage, page, type, authenticationID, sort, order, }?: ListSourcesProps, requestOptions?: RequestOptions | undefined): Promise<ListSourcesResponse>;
+    /**
      * Retrieves a list of tasks.
@@ -464,17 +534,17 @@ *
      *
-     * @param getTasks - The getTasks object.
-     * @param getTasks.itemsPerPage - Number of items per page.
-     * @param getTasks.page - Page number of the paginated API response.
-     * @param getTasks.action - Actions for filtering the list of tasks.
-     * @param getTasks.enabled - Whether to filter the list of tasks by the `enabled` status.
-     * @param getTasks.sourceID - Source IDs for filtering the list of tasks.
-     * @param getTasks.destinationID - Destination IDs for filtering the list of tasks.
-     * @param getTasks.triggerType - Type of task trigger for filtering the list of tasks.
-     * @param getTasks.sort - Property by which to sort the list of tasks.
-     * @param getTasks.order - Sort order of the response, ascending or descending.
+     * @param listTasks - The listTasks object.
+     * @param listTasks.itemsPerPage - Number of items per page.
+     * @param listTasks.page - Page number of the paginated API response.
+     * @param listTasks.action - Actions for filtering the list of tasks.
+     * @param listTasks.enabled - Whether to filter the list of tasks by the `enabled` status.
+     * @param listTasks.sourceID - Source IDs for filtering the list of tasks.
+     * @param listTasks.destinationID - Destination IDs for filtering the list of tasks.
+     * @param listTasks.triggerType - Type of task trigger for filtering the list of tasks.
+     * @param listTasks.sort - Property by which to sort the list of tasks.
+     * @param listTasks.order - Sort order of the response, ascending or descending.
      * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
      */
-    getTasks({ itemsPerPage, page, action, enabled, sourceID, destinationID, triggerType, sort, order, }?: GetTasksProps, requestOptions?: RequestOptions | undefined): Promise<ListTasksResponse>;
+    listTasks({ itemsPerPage, page, action, enabled, sourceID, destinationID, triggerType, sort, order, }?: ListTasksProps, requestOptions?: RequestOptions | undefined): Promise<ListTasksResponse>;
     /**
-     * Retrieves a transformation by its ID.
+     * Retrieves a list of tasks using the v1 endpoint, please use `getTasks` instead.
      *
@@ -486,7 +556,15 @@ * Required API Key ACLs:
      *
-     * @param getTransformation - The getTransformation object.
-     * @param getTransformation.transformationID - Unique identifier of a transformation.
+     * @param listTasksV1 - The listTasksV1 object.
+     * @param listTasksV1.itemsPerPage - Number of items per page.
+     * @param listTasksV1.page - Page number of the paginated API response.
+     * @param listTasksV1.action - Actions for filtering the list of tasks.
+     * @param listTasksV1.enabled - Whether to filter the list of tasks by the `enabled` status.
+     * @param listTasksV1.sourceID - Source IDs for filtering the list of tasks.
+     * @param listTasksV1.destinationID - Destination IDs for filtering the list of tasks.
+     * @param listTasksV1.triggerType - Type of task trigger for filtering the list of tasks.
+     * @param listTasksV1.sort - Property by which to sort the list of tasks.
+     * @param listTasksV1.order - Sort order of the response, ascending or descending.
      * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
      */
-    getTransformation({ transformationID }: GetTransformationProps, requestOptions?: RequestOptions): Promise<Transformation>;
+    listTasksV1({ itemsPerPage, page, action, enabled, sourceID, destinationID, triggerType, sort, order, }?: ListTasksV1Props, requestOptions?: RequestOptions | undefined): Promise<ListTasksResponseV1>;
     /**
@@ -500,9 +578,23 @@ * Retrieves a list of transformations.
      *
-     * @param getTransformations - The getTransformations object.
-     * @param getTransformations.sort - Property by which to sort the list.
-     * @param getTransformations.order - Sort order of the response, ascending or descending.
+     * @param listTransformations - The listTransformations object.
+     * @param listTransformations.sort - Property by which to sort the list.
+     * @param listTransformations.order - Sort order of the response, ascending or descending.
      * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
      */
-    getTransformations({ sort, order }?: GetTransformationsProps, requestOptions?: RequestOptions | undefined): Promise<ListTransformationsResponse>;
+    listTransformations({ sort, order }?: ListTransformationsProps, requestOptions?: RequestOptions | undefined): Promise<ListTransformationsResponse>;
     /**
+     * Push a `batch` request payload through the Pipeline. You can check the status of task pushes with the observability endpoints.
+     *
+     * Required API Key ACLs:
+     * - addObject
+     * - deleteIndex
+     * - editSettings.
+     *
+     * @param pushTask - The pushTask object.
+     * @param pushTask.taskID - Unique identifier of a task.
+     * @param pushTask.batchWriteParams - Request body of a Search API `batch` request that will be pushed in the Connectors pipeline.
+     * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
+     */
+    pushTask({ taskID, batchWriteParams }: PushTaskProps, requestOptions?: RequestOptions): Promise<RunResponse>;
+    /**
      * Runs a task. You can check the status of task runs with the observability endpoints.
@@ -521,2 +613,15 @@ *
     /**
+     * Runs a task using the v1 endpoint, please use `runTask` instead. You can check the status of task runs with the observability endpoints.
+     *
+     * Required API Key ACLs:
+     * - addObject
+     * - deleteIndex
+     * - editSettings.
+     *
+     * @param runTaskV1 - The runTaskV1 object.
+     * @param runTaskV1.taskID - Unique identifier of a task.
+     * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
+     */
+    runTaskV1({ taskID }: RunTaskV1Props, requestOptions?: RequestOptions): Promise<RunResponse>;
+    /**
      * Searches for authentication resources.
@@ -570,2 +675,14 @@ *
     /**
+     * Searches for tasks using the v1 endpoint, please use `searchTasks` instead.
+     *
+     * Required API Key ACLs:
+     * - addObject
+     * - deleteIndex
+     * - editSettings.
+     *
+     * @param taskSearch - The taskSearch object.
+     * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
+     */
+    searchTasksV1(taskSearch: TaskSearch, requestOptions?: RequestOptions): Promise<TaskV1[]>;
+    /**
      * Searches for transformations.
@@ -659,2 +776,11 @@ *
     /**
+     * Updates a task by its ID using the v1 endpoint, please use `updateTask` instead.
+     *
+     * @param updateTaskV1 - The updateTaskV1 object.
+     * @param updateTaskV1.taskID - Unique identifier of a task.
+     * @param updateTaskV1.taskUpdate - The taskUpdate object.
+     * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
+     */
+    updateTaskV1({ taskID, taskUpdate }: UpdateTaskV1Props, requestOptions?: RequestOptions): Promise<TaskUpdateResponse>;
+    /**
      * Updates a transformation by its ID.
@@ -661,0 +787,0 @@ *

model/clientMethodProps.ts

@@ -7,2 +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.
 import type { AuthenticationUpdate } from './authenticationUpdate';
+import type { BatchWriteParams } from './batchWriteParams';
 import type { DestinationSortKeys } from './destinationSortKeys';
@@ -24,2 +25,3 @@ import type { DestinationType } from './destinationType';
 import type { TaskUpdate } from './taskUpdate';
+import type { TaskUpdateV1 } from './taskUpdateV1';
 import type { TransformationCreate } from './transformationCreate';
@@ -133,2 +135,12 @@ import type { TriggerType } from './triggerType';
 /**
+ * Properties for the `deleteTaskV1` method.
+ */
+export type DeleteTaskV1Props = {
+  /**
+   * Unique identifier of a task.
+   */
+  taskID: string;
+};
+
+/**
  * Properties for the `deleteTransformation` method.
@@ -154,2 +166,12 @@ */
 /**
+ * Properties for the `disableTaskV1` method.
+ */
+export type DisableTaskV1Props = {
+  /**
+   * Unique identifier of a task.
+   */
+  taskID: string;
+};
+
+/**
  * Properties for the `enableTask` method.
@@ -165,2 +187,12 @@ */
 /**
+ * Properties for the `enableTaskV1` method.
+ */
+export type EnableTaskV1Props = {
+  /**
+   * Unique identifier of a task.
+   */
+  taskID: string;
+};
+
+/**
  * Properties for the `getAuthentication` method.
@@ -176,6 +208,80 @@ */
 /**
- * Properties for the `getAuthentications` method.
+ * Properties for the `getDestination` method.
  */
-export type GetAuthenticationsProps = {
+export type GetDestinationProps = {
   /**
+   * Unique identifier of a destination.
+   */
+  destinationID: string;
+};
+
+/**
+ * Properties for the `getEvent` method.
+ */
+export type GetEventProps = {
+  /**
+   * Unique identifier of a task run.
+   */
+  runID: string;
+  /**
+   * Unique identifier of an event.
+   */
+  eventID: string;
+};
+
+/**
+ * Properties for the `getRun` method.
+ */
+export type GetRunProps = {
+  /**
+   * Unique identifier of a task run.
+   */
+  runID: string;
+};
+
+/**
+ * Properties for the `getSource` method.
+ */
+export type GetSourceProps = {
+  /**
+   * Unique identifier of a source.
+   */
+  sourceID: string;
+};
+
+/**
+ * Properties for the `getTask` method.
+ */
+export type GetTaskProps = {
+  /**
+   * Unique identifier of a task.
+   */
+  taskID: string;
+};
+
+/**
+ * Properties for the `getTaskV1` method.
+ */
+export type GetTaskV1Props = {
+  /**
+   * Unique identifier of a task.
+   */
+  taskID: string;
+};
+
+/**
+ * Properties for the `getTransformation` method.
+ */
+export type GetTransformationProps = {
+  /**
+   * Unique identifier of a transformation.
+   */
+  transformationID: string;
+};
+
+/**
+ * Properties for the `listAuthentications` method.
+ */
+export type ListAuthenticationsProps = {
+  /**
    * Number of items per page.
@@ -207,16 +313,6 @@ */
 /**
- * Properties for the `getDestination` method.
+ * Properties for the `listDestinations` method.
  */
-export type GetDestinationProps = {
+export type ListDestinationsProps = {
   /**
-   * Unique identifier of a destination.
-   */
-  destinationID: string;
-};
-
-/**
- * Properties for the `getDestinations` method.
- */
-export type GetDestinationsProps = {
-  /**
    * Number of items per page.
@@ -248,5 +344,5 @@ */
 /**
- * Properties for the `getEvent` method.
+ * Properties for the `listEvents` method.
  */
-export type GetEventProps = {
+export type ListEventsProps = {
   /**
@@ -257,16 +353,2 @@ * Unique identifier of a task run.
   /**
-   * Unique identifier of an event.
-   */
-  eventID: string;
-};
-
-/**
- * Properties for the `getEvents` method.
- */
-export type GetEventsProps = {
-  /**
-   * Unique identifier of a task run.
-   */
-  runID: string;
-  /**
    * Number of items per page.
@@ -306,16 +388,6 @@ */
 /**
- * Properties for the `getRun` method.
+ * Properties for the `listRuns` method.
  */
-export type GetRunProps = {
+export type ListRunsProps = {
   /**
-   * Unique identifier of a task run.
-   */
-  runID: string;
-};
-
-/**
- * Properties for the `getRuns` method.
- */
-export type GetRunsProps = {
-  /**
    * Number of items per page.
@@ -355,16 +427,6 @@ */
 /**
- * Properties for the `getSource` method.
+ * Properties for the `listSources` method.
  */
-export type GetSourceProps = {
+export type ListSourcesProps = {
   /**
-   * Unique identifier of a source.
-   */
-  sourceID: string;
-};
-
-/**
- * Properties for the `getSources` method.
- */
-export type GetSourcesProps = {
-  /**
    * Number of items per page.
@@ -396,15 +458,47 @@ */
 /**
- * Properties for the `getTask` method.
+ * Properties for the `listTasks` method.
  */
-export type GetTaskProps = {
+export type ListTasksProps = {
   /**
-   * Unique identifier of a task.
+   * Number of items per page.
    */
-  taskID: string;
+  itemsPerPage?: number;
+  /**
+   * Page number of the paginated API response.
+   */
+  page?: number;
+  /**
+   * Actions for filtering the list of tasks.
+   */
+  action?: ActionType[];
+  /**
+   * Whether to filter the list of tasks by the `enabled` status.
+   */
+  enabled?: boolean;
+  /**
+   * Source IDs for filtering the list of tasks.
+   */
+  sourceID?: string[];
+  /**
+   * Destination IDs for filtering the list of tasks.
+   */
+  destinationID?: string[];
+  /**
+   * Type of task trigger for filtering the list of tasks.
+   */
+  triggerType?: TriggerType[];
+  /**
+   * Property by which to sort the list of tasks.
+   */
+  sort?: TaskSortKeys;
+  /**
+   * Sort order of the response, ascending or descending.
+   */
+  order?: OrderKeys;
 };
 
 /**
- * Properties for the `getTasks` method.
+ * Properties for the `listTasksV1` method.
  */
-export type GetTasksProps = {
+export type ListTasksV1Props = {
   /**
@@ -449,23 +543,27 @@ * Number of items per page.
 /**
- * Properties for the `getTransformation` method.
+ * Properties for the `listTransformations` method.
  */
-export type GetTransformationProps = {
+export type ListTransformationsProps = {
   /**
-   * Unique identifier of a transformation.
+   * Property by which to sort the list.
    */
-  transformationID: string;
+  sort?: SortKeys;
+  /**
+   * Sort order of the response, ascending or descending.
+   */
+  order?: OrderKeys;
 };
 
 /**
- * Properties for the `getTransformations` method.
+ * Properties for the `pushTask` method.
  */
-export type GetTransformationsProps = {
+export type PushTaskProps = {
   /**
-   * Property by which to sort the list.
+   * Unique identifier of a task.
    */
-  sort?: SortKeys;
+  taskID: string;
   /**
-   * Sort order of the response, ascending or descending.
+   * Request body of a Search API `batch` request that will be pushed in the Connectors pipeline.
    */
-  order?: OrderKeys;
+  batchWriteParams: BatchWriteParams;
 };
@@ -484,2 +582,12 @@
 /**
+ * Properties for the `runTaskV1` method.
+ */
+export type RunTaskV1Props = {
+  /**
+   * Unique identifier of a task.
+   */
+  taskID: string;
+};
+
+/**
  * Properties for the `triggerDockerSourceDiscover` method.
@@ -539,2 +647,13 @@ */
 /**
+ * Properties for the `updateTaskV1` method.
+ */
+export type UpdateTaskV1Props = {
+  /**
+   * Unique identifier of a task.
+   */
+  taskID: string;
+  taskUpdate: TaskUpdateV1;
+};
+
+/**
  * Properties for the `updateTransformation` method.
@@ -541,0 +660,0 @@ */

model/index.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 * from './action';
 export * from './actionType';
@@ -26,2 +27,4 @@ export * from './authAPIKey';
 export * from './authenticationUpdateResponse';
+export * from './batchRequest';
+export * from './batchWriteParams';
 export * from './bigCommerceChannel';
@@ -56,2 +59,3 @@ export * from './bigCommerceMetafield';
 export * from './listTasksResponse';
+export * from './listTasksResponseV1';
 export * from './listTransformationsResponse';
@@ -121,2 +125,3 @@ export * from './mappingFieldDirective';
 export * from './taskCreateTrigger';
+export * from './taskCreateV1';
 export * from './taskInput';
@@ -127,2 +132,4 @@ export * from './taskSearch';
 export * from './taskUpdateResponse';
+export * from './taskUpdateV1';
+export * from './taskV1';
 export * from './transformation';
@@ -129,0 +136,0 @@ export * from './transformationCreate';

model/task.ts

@@ -5,3 +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.
 import type { TaskInput } from './taskInput';
-import type { Trigger } from './trigger';
 
@@ -24,4 +23,17 @@ export type Task = {
 
-  trigger: Trigger;
+  /**
+   * Cron expression for the task\'s schedule.
+   */
+  cron?: string;
 
+  /**
+   * The last time the scheduled task ran in RFC 3339 format.
+   */
+  lastRun?: string;
+
+  /**
+   * The next scheduled run of the task in RFC 3339 format.
+   */
+  nextRun?: string;
+
   input?: TaskInput;
@@ -28,0 +40,0 @@

model/taskCreate.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 { TaskCreateTrigger } from './taskCreateTrigger';
 import type { TaskInput } from './taskInput';
@@ -21,7 +20,10 @@
 
-  trigger: TaskCreateTrigger;
-
   action: ActionType;
 
   /**
+   * Cron expression for the task\'s schedule.
+   */
+  cron?: string;
+
+  /**
    * Whether the task is enabled.
@@ -28,0 +30,0 @@ */

model/taskUpdate.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 { TaskInput } from './taskInput';
-import type { TriggerUpdateInput } from './triggerUpdateInput';
 
@@ -15,3 +14,6 @@ /**
 
-  trigger?: TriggerUpdateInput;
+  /**
+   * Cron expression for the task\'s schedule.
+   */
+  cron?: string;
 
@@ -18,0 +20,0 @@ input?: TaskInput;

package.json

 {
   "name": "@algolia/ingestion",
-  "version": "1.0.0-beta.11",
+  "version": "1.0.0-beta.12",
   "description": "JavaScript client for ingestion",
@@ -45,8 +45,8 @@ "repository": {
   "dependencies": {
-    "@algolia/client-common": "5.0.0-beta.12",
-    "@algolia/requester-browser-xhr": "5.0.0-beta.12",
-    "@algolia/requester-node-http": "5.0.0-beta.12"
+    "@algolia/client-common": "5.0.0-beta.13",
+    "@algolia/requester-browser-xhr": "5.0.0-beta.13",
+    "@algolia/requester-node-http": "5.0.0-beta.13"
   },
   "devDependencies": {
-    "@types/node": "20.14.10",
+    "@types/node": "20.14.11",
     "rollup": "4.18.1",
@@ -53,0 +53,0 @@ "typescript": "5.5.3"

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

586531

increased by14.62%

Number of package files

440

increased by5.01%

Lines of code

12185

increased by15.33%

Dependency changes

• + Added@algolia/client-common@5.0.0-beta.13(transitive)

• + Added@algolia/requester-browser-xhr@5.0.0-beta.13(transitive)

• + Added@algolia/requester-node-http@5.0.0-beta.13(transitive)

• - Removed@algolia/client-common@5.0.0-beta.12(transitive)

• - Removed@algolia/requester-browser-xhr@5.0.0-beta.12(transitive)

• - Removed@algolia/requester-node-http@5.0.0-beta.12(transitive)

• Updated@algolia/client-common@5.0.0-beta.13

• Updated@algolia/requester-browser-xhr@5.0.0-beta.13

• Updated@algolia/requester-node-http@5.0.0-beta.13