/**
 * Minified by jsDelivr using Terser v5.39.0.
 * Original file: /npm/@instill-ai/typescript-sdk@0.0.12/dist/index.js
 *
 * Do NOT use SRI with dynamically generated files! More information: https://www.jsdelivr.com/using-sri-with-dynamic-files
 */
"use strict";var __create=Object.create,__defProp=Object.defineProperty,__getOwnPropDesc=Object.getOwnPropertyDescriptor,__getOwnPropNames=Object.getOwnPropertyNames,__getProtoOf=Object.getPrototypeOf,__hasOwnProp=Object.prototype.hasOwnProperty,__export=(e,t)=>{for(var n in t)__defProp(e,n,{get:t[n],enumerable:!0})},__copyProps=(e,t,n,a)=>{if(t&&"object"==typeof t||"function"==typeof t)for(let r of __getOwnPropNames(t))__hasOwnProp.call(e,r)||r===n||__defProp(e,r,{get:()=>t[r],enumerable:!(a=__getOwnPropDesc(t,r))||a.enumerable});return e},__toESM=(e,t,n)=>(n=null!=e?__create(__getProtoOf(e)):{},__copyProps(!t&&e&&e.__esModule?n:__defProp(n,"default",{value:e,enumerable:!0}),e)),__toCommonJS=e=>__copyProps(__defProp({},"__esModule",{value:!0}),e),src_exports={};__export(src_exports,{createClient:()=>createClient,default:()=>src_default,env:()=>env,getInstillApiErrorMessage:()=>getInstillApiErrorMessage,getQueryString:()=>getQueryString}),module.exports=__toCommonJS(src_exports);var import_axios3=__toESM(require("axios")),import_axios=__toESM(require("axios")),isBrowser=()=>Boolean("undefined"!=typeof window);function env(e=""){if(!e.length)throw new Error("No env key provided");return isBrowser()&&window.__env?"''"===window.__env[e]?"":parseString(window.__env[e]):"''"===process.env[e]?"":parseString(process.env[e])}var parseString=e=>"true"===e||"false"!==e&&(/^\d+$/.test(e)?parseInt(e):e);function createClient(e,t,n){let a={};if(n?a=n:e&&(a={Authorization:`Bearer ${e}`,"CF-Access-Client-Id":env("CF_ACCESS_CLIENT_ID")?env("CF_ACCESS_CLIENT_ID"):void 0,"CF-Access-Client-Secret":env("CF_ACCESS_CLIENT_SECRET")?env("CF_ACCESS_CLIENT_SECRET"):void 0}),!process.env.API_GATEWAY_URL&&!env("API_GATEWAY_URL"))throw new Error("API_GATEWAY_URL or API_GATEWAY_URL is not defined");let r=`${process.env.API_GATEWAY_URL??env("API_GATEWAY_URL")}/${t}/${env("API_VERSION")}`;return import_axios.default.create({baseURL:r,headers:a})}var getQueryString=({baseURL:e,pageSize:t,nextPageToken:n,filter:a})=>{let r=e;return(t||n||a)&&(e.includes("?")?r+="&":r+="?"),t&&(r+=`page_size=${t}&`),n&&(r+=`page_token=${n}&`),a&&(r+=`filter=${a}&`),r.endsWith("&")&&(r=r.slice(0,-1)),r};function getInstillApiErrorMessage(e){return e.response&&(e.response.data.details||e.response.data.message)?0===e.response.data.details.length?e.response.data.message:JSON.stringify(e.response?.data.details,null,"\t"):null}var import_axios2=__toESM(require("axios"));async function listConnectorResourcesQuery({axiosInstance:e,pageSize:t,nextPageToken:n,filter:a}){try{const r=[],s=getQueryString({baseURL:"/connector-resources?view=VIEW_FULL",pageSize:t,nextPageToken:n,filter:a}),{data:i}=await e.get(s);return r.push(...i.connector_resources),i.next_page_token&&r.push(...await listConnectorResourcesQuery({axiosInstance:e,pageSize:t,nextPageToken:i.next_page_token,filter:a})),Promise.resolve(r)}catch(e){return Promise.reject(e)}}async function listUserConnectorResourcesQuery({axiosInstance:e,userName:t,pageSize:n,nextPageToken:a,filter:r}){try{const s=[],i=getQueryString({baseURL:`${t}/connector-resources?view=VIEW_FULL`,pageSize:n,nextPageToken:a,filter:r}),{data:o}=await e.get(i);return s.push(...o.connector_resources),o.next_page_token&&s.push(...await listUserConnectorResourcesQuery({axiosInstance:e,userName:t,pageSize:n,nextPageToken:o.next_page_token,filter:r})),Promise.resolve(s)}catch(e){return Promise.reject(e)}}async function listConnectorDefinitionsQuery({axiosInstance:e,pageSize:t,nextPageToken:n,filter:a}){try{const r=[],s=getQueryString({baseURL:"/connector-definitions?view=VIEW_FULL",pageSize:t,nextPageToken:n,filter:a}),{data:i}=await e.get(s);return r.push(...i.connector_definitions),i.next_page_token&&r.push(...await listConnectorDefinitionsQuery({axiosInstance:e,pageSize:t,nextPageToken:i.next_page_token,filter:a})),Promise.resolve(r)}catch(e){return Promise.reject(e)}}async function getConnectorDefinitionQuery({axiosInstance:e,connectorDefinitionName:t}){try{const{data:n}=await e.get(`/${t}?view=VIEW_FULL`);return Promise.resolve(n.connector_definition)}catch(e){return Promise.reject(e)}}async function getUserConnectorResourceQuery({axiosInstance:e,connectorResourceName:t}){try{const{data:n}=await e.get(`/${t}?view=VIEW_FULL`);return Promise.resolve(n.connector_resource)}catch(e){return Promise.reject(e)}}async function watchUserConnectorResource({axiosInstance:e,connectorResourceName:t}){try{const{data:n}=await e.get(`/${t}/watch`);return Promise.resolve(n)}catch(e){return Promise.reject(e)}}async function createUserConnectorResourceMutation({axiosInstance:e,userName:t,payload:n}){try{const a=await e.post(`${t}/connector-resources`,n);return Promise.resolve(a.data.connector_resource)}catch(e){return Promise.reject(e)}}async function deleteUserConnectorResourceMutation({axiosInstance:e,connectorResourceName:t}){try{await e.delete(`/${t}`)}catch(e){return Promise.reject(e)}}async function updateUserConnectorResourceMutation({axiosInstance:e,payload:t}){try{const n=await e.patch(`/${t.connectorResourceName}`,{...t,connectorResourceName:void 0});return Promise.resolve(n.data.connector_resource)}catch(e){return Promise.reject(e)}}async function renameUserConnectorResource({axiosInstance:e,payload:t}){try{const{data:n}=await e.post(`/${t.name}/rename`,t);return Promise.resolve(n.connector_resource)}catch(e){return Promise.reject(e)}}async function testUserConnectorResourceConnectionAction({axiosInstance:e,connectorResourceName:t}){try{const{data:n}=await e.post(`/${t}/testConnection`);return Promise.resolve(n.state)}catch(e){return Promise.reject(e)}}async function connectUserConnectorResourceAction({axiosInstance:e,connectorResourceName:t}){try{const{data:n}=await e.post(`/${t}/connect`);return Promise.resolve(n.connector_resource)}catch(e){return Promise.reject(e)}}async function disconnectUserConnectorResourceAction({axiosInstance:e,connectorResourceName:t}){try{const{data:n}=await e.post(`/${t}/disconnect`);return Promise.resolve(n.connector_resource)}catch(e){return Promise.reject(e)}}var ConnectorClient=class{axiosInstance;constructor(e,t,n){let a=`${e}/vdp/${t}`;this.axiosInstance=import_axios3.default.create({baseURL:a,headers:{Authorization:`Bearer ${n}`}})}async listConnectorResourcesQuery({pageSize:e,nextPageToken:t,filter:n}){return listConnectorResourcesQuery({axiosInstance:this.axiosInstance,pageSize:e,nextPageToken:t,filter:n})}async listUserConnectorResourcesQuery({userName:e,pageSize:t,nextPageToken:n,filter:a}){return listUserConnectorResourcesQuery({axiosInstance:this.axiosInstance,userName:e,pageSize:t,nextPageToken:n,filter:a})}async listConnectorDefinitionsQuery({pageSize:e,nextPageToken:t,filter:n}){return listConnectorDefinitionsQuery({axiosInstance:this.axiosInstance,pageSize:e,nextPageToken:t,filter:n})}async getConnectorDefinitionQuery({connectorDefinitionName:e}){return getConnectorDefinitionQuery({axiosInstance:this.axiosInstance,connectorDefinitionName:e})}async getUserConnectorResourceQuery({connectorResourceName:e}){return getUserConnectorResourceQuery({axiosInstance:this.axiosInstance,connectorResourceName:e})}async watchUserConnectorResource({connectorResourceName:e}){return watchUserConnectorResource({axiosInstance:this.axiosInstance,connectorResourceName:e})}async createUserConnectorResourceMutation({userName:e,payload:t}){return createUserConnectorResourceMutation({axiosInstance:this.axiosInstance,userName:e,payload:t})}async deleteUserConnectorResourceMutation({connectorResourceName:e}){return deleteUserConnectorResourceMutation({axiosInstance:this.axiosInstance,connectorResourceName:e})}async updateUserConnectorResourceMutation({payload:e}){return updateUserConnectorResourceMutation({axiosInstance:this.axiosInstance,payload:e})}async renameUserConnectorResource({payload:e}){return renameUserConnectorResource({axiosInstance:this.axiosInstance,payload:e})}async testUserConnectorResourceConnectionAction({connectorResourceName:e}){return testUserConnectorResourceConnectionAction({axiosInstance:this.axiosInstance,connectorResourceName:e})}async connectUserConnectorResourceAction({connectorResourceName:e}){return connectUserConnectorResourceAction({axiosInstance:this.axiosInstance,connectorResourceName:e})}async disconnectUserConnectorResourceAction({connectorResourceName:e}){return disconnectUserConnectorResourceAction({axiosInstance:this.axiosInstance,connectorResourceName:e})}},ConnectorClient_default=ConnectorClient,import_axios4=__toESM(require("axios"));async function listPipelineTriggerRecordsQuery({axiosInstance:e,pageSize:t,nextPageToken:n,filter:a}){try{const r=[],s=getQueryString({baseURL:"/metrics/vdp/pipeline/triggers",pageSize:t,nextPageToken:n,filter:a}),{data:i}=await e.get(s);return r.push(...i.pipeline_trigger_records),i.next_page_token&&r.push(...await listPipelineTriggerRecordsQuery({axiosInstance:e,pageSize:t,nextPageToken:i.next_page_token,filter:a})),Promise.resolve(r)}catch(e){return Promise.reject(e)}}async function listTriggeredPipelineQuery({axiosInstance:e,pageSize:t,nextPageToken:n,filter:a}){try{const r=[],s=getQueryString({baseURL:"/metrics/vdp/pipeline/tables",pageSize:t,nextPageToken:n,filter:a}),{data:i}=await e.get(s);return r.push(...i.pipeline_trigger_table_records),i.next_page_token&&r.push(...await listTriggeredPipelineQuery({axiosInstance:e,pageSize:t,nextPageToken:i.next_page_token,filter:a})),Promise.resolve(r)}catch(e){return Promise.reject(e)}}async function listTriggeredPipelineChartQuery({axiosInstance:e,pageSize:t,nextPageToken:n,filter:a}){try{const r=[],s=getQueryString({baseURL:"/metrics/vdp/pipeline/charts",pageSize:t,nextPageToken:n,filter:a}),{data:i}=await e.get(s);return r.push(...i.pipeline_trigger_chart_records),Promise.resolve(r)}catch(e){return Promise.reject(e)}}var MetricClient=class{axiosInstance;constructor(e,t,n){let a=`${e}/core/${t}`;this.axiosInstance=import_axios4.default.create({baseURL:a,headers:{Authorization:`Bearer ${n}`}})}async listPipelineTriggerRecordsQuery({pageSize:e,nextPageToken:t,filter:n}){return listPipelineTriggerRecordsQuery({axiosInstance:this.axiosInstance,pageSize:e,nextPageToken:t,filter:n})}async listTriggeredPipelineQuery({pageSize:e,nextPageToken:t,filter:n}){return listTriggeredPipelineQuery({axiosInstance:this.axiosInstance,pageSize:e,nextPageToken:t,filter:n})}async listTriggeredPipelineChartQuery({pageSize:e,nextPageToken:t,filter:n}){return listTriggeredPipelineChartQuery({axiosInstance:this.axiosInstance,pageSize:e,nextPageToken:t,filter:n})}},MetricClient_default=MetricClient,import_axios5=__toESM(require("axios"));async function getUserQuery(e){try{const{data:t}=await e.get("/users/me");return Promise.resolve(t.user)}catch(e){return Promise.reject(e)}}async function checkUserIdExist({axiosInstance:e,id:t}){try{const{data:n}=await e.get(`/users/${t}/exist`);return Promise.resolve(n.exists)}catch(e){return Promise.reject(e)}}async function getApiTokenQuery({axiosInstance:e,tokenName:t}){try{const{data:n}=await e.get(`/${t}`);return Promise.resolve(n.token)}catch(e){return Promise.reject(e)}}async function listApiTokensQuery({axiosInstance:e,pageSize:t,nextPageToken:n}){try{const a=[],r=getQueryString({baseURL:"/tokens",pageSize:t,nextPageToken:n,filter:null}),{data:s}=await e.get(r);return a.push(...s.tokens),s.next_page_token&&a.push(...await listApiTokensQuery({axiosInstance:e,pageSize:t,nextPageToken:s.next_page_token})),Promise.resolve(a)}catch(e){return Promise.reject(e)}}async function updateUserMutation({axiosInstance:e,payload:t}){try{const{data:n}=await e.patch("/users/me",t);return Promise.resolve(n.user)}catch(e){return Promise.reject(e)}}async function createApiTokenMutation({axiosInstance:e,payload:t}){try{const{data:n}=await e.post("/tokens",t);return Promise.resolve(n.token)}catch(e){return Promise.reject(e)}}async function deleteApiTokenMutation({axiosInstance:e,tokenName:t}){try{await e.delete(`/${t}`)}catch(e){return Promise.reject(e)}}async function changePasswordMutation({axiosInstance:e,payload:t}){try{await e.post("/auth/change_password",t)}catch(e){return Promise.reject(e)}}async function authLogoutAction(e){try{await e.post("/auth/logout")}catch(e){return Promise.reject(e)}}async function authLoginAction({axiosInstance:e,payload:t}){try{const{data:n}=await e.post("/auth/login",t);return Promise.resolve(n.access_token)}catch(e){return Promise.reject(e)}}async function authValidateTokenAction(e){try{await e.post("/auth/validate_access_token")}catch(e){return Promise.reject(e)}}var AuthClient=class{axiosInstance;constructor(e,t,n){let a=`${e}/core/${t}`;this.axiosInstance=import_axios5.default.create({baseURL:a,headers:{Authorization:`Bearer ${n}`}})}async getUserQuery(){return getUserQuery(this.axiosInstance)}async checkUserIdExist({id:e}){return checkUserIdExist({axiosInstance:this.axiosInstance,id:e})}async getApiTokenQuery({tokenName:e}){return getApiTokenQuery({axiosInstance:this.axiosInstance,tokenName:e})}async listApiTokensQuery({pageSize:e,nextPageToken:t}){return listApiTokensQuery({axiosInstance:this.axiosInstance,pageSize:e,nextPageToken:t})}async updateUserMutation({payload:e}){return updateUserMutation({axiosInstance:this.axiosInstance,payload:e})}async createApiTokenMutation({payload:e}){return createApiTokenMutation({axiosInstance:this.axiosInstance,payload:e})}async deleteApiTokenMutation({tokenName:e}){return deleteApiTokenMutation({axiosInstance:this.axiosInstance,tokenName:e})}async changePasswordMutation({payload:e}){return changePasswordMutation({axiosInstance:this.axiosInstance,payload:e})}async authLogoutAction(){return authLogoutAction(this.axiosInstance)}async authLoginAction({payload:e}){return authLoginAction({axiosInstance:this.axiosInstance,payload:e})}async authValidateTokenAction(){return authValidateTokenAction(this.axiosInstance)}},AuthClient_default=AuthClient,import_axios6=__toESM(require("axios"));async function getModelDefinitionQuery({axiosInstance:e,modelDefinitionName:t}){try{const{data:n}=await e.get(`/${t}`);return Promise.resolve(n.model_definition)}catch(e){return Promise.reject(e)}}async function listModelDefinitionsQuery({axiosInstance:e,pageSize:t,nextPageToken:n}){try{const a=[],r=getQueryString({baseURL:"/model-definitions",pageSize:t,nextPageToken:n,filter:null}),{data:s}=await e.get(r);return a.push(...s.model_definitions),s.next_page_token&&a.push(...await listModelDefinitionsQuery({axiosInstance:e,pageSize:t,nextPageToken:s.next_page_token})),Promise.resolve(a)}catch(e){return Promise.reject(e)}}async function getUserModelQuery({axiosInstance:e,modelName:t}){try{const{data:n}=await e.get(`/${t}?view=VIEW_FULL`);return Promise.resolve(n.model)}catch(e){return Promise.reject(e)}}async function listModelsQuery({axiosInstance:e,pageSize:t,nextPageToken:n}){try{const a=[],r=getQueryString({baseURL:"/models?view=VIEW_FULL",pageSize:t,nextPageToken:n,filter:null}),{data:s}=await e.get(r);return a.push(...s.models),s.next_page_token&&a.push(...await listModelsQuery({axiosInstance:e,pageSize:t,nextPageToken:s.next_page_token})),Promise.resolve(a)}catch(e){return Promise.reject(e)}}async function listUserModelsQuery({axiosInstance:e,userName:t,pageSize:n,nextPageToken:a}){try{const r=[],s=getQueryString({baseURL:`/${t}/models?view=VIEW_FULL`,pageSize:n,nextPageToken:a,filter:null}),{data:i}=await e.get(s);return r.push(...i.models),i.next_page_token&&r.push(...await listUserModelsQuery({axiosInstance:e,userName:t,pageSize:n,nextPageToken:i.next_page_token})),Promise.resolve(r)}catch(e){return Promise.reject(e)}}async function getUserModelReadmeQuery({axiosInstance:e,modelName:t}){try{const{data:n}=await e.get(`/${t}/readme`);return Promise.resolve(n.readme)}catch(e){return Promise.reject(e)}}async function watchUserModel({axiosInstance:e,modelName:t}){try{const{data:n}=await e.get(`/${t}/watch`);return Promise.resolve(n)}catch(e){return Promise.reject(e)}}async function createUserModelMutation({axiosInstance:e,userName:t,payload:n}){if("Local"===n.type)try{const t=new FormData;t.append("id",n.id),t.append("model_definition",n.model_definition),t.append("content",n.configuration.content),n.description&&t.append("description",n.description);const{data:a}=await e.post("/models/multipart",t,{headers:{"Content-Type":"multipart/form-data"}});return Promise.resolve(a.operation)}catch(e){return Promise.reject(e)}else{let a={};a="GitHub"===n.type?{id:n.id,model_definition:n.model_definition,description:n.description,configuration:{repository:n.configuration.repository,tag:n.configuration.tag}}:"ArtiVC"===n.type?{id:n.id,model_definition:n.model_definition,description:n.description,configuration:{url:n.configuration.url,credential:n.configuration.credential?JSON.parse(n.configuration.credential):void 0,tag:n.configuration.tag}}:{id:n.id,model_definition:n.model_definition,description:n.description,configuration:{repo_id:n.configuration.repo_id}};try{const{data:n}=await e.post(`${t}/models`,a);return Promise.resolve(n.operation)}catch(e){return Promise.reject(e)}}}async function updateModelMutation({axiosInstance:e,payload:t}){try{const{data:n}=await e.patch(`/${t.name}`,t);return Promise.resolve(n.model)}catch(e){return Promise.reject(e)}}async function deleteUserModelMutation({axiosInstance:e,modelName:t}){try{await e.delete(`/${t}`)}catch(e){return Promise.reject(e)}}async function deployUserModelAction({axiosInstance:e,modelName:t}){try{const{data:n}=await e.post(`/${t}/deploy`);return Promise.resolve(n.model_id)}catch(e){return Promise.reject(e)}}async function undeployUserModelAction({axiosInstance:e,modelName:t}){try{const{data:n}=await e.post(`/${t}/undeploy`);return Promise.resolve(n.model_id)}catch(e){return Promise.reject(e)}}var ModelClient=class{axiosInstance;constructor(e,t,n){let a=`${e}/model/${t}`;this.axiosInstance=import_axios6.default.create({baseURL:a,headers:{Authorization:`Bearer ${n}`}})}async getModelDefinitionQuery({modelDefinitionName:e}){return getModelDefinitionQuery({axiosInstance:this.axiosInstance,modelDefinitionName:e})}async listModelDefinitionsQuery({pageSize:e,nextPageToken:t}){return listModelDefinitionsQuery({axiosInstance:this.axiosInstance,pageSize:e,nextPageToken:t})}async getUserModelQuery({modelName:e}){return getUserModelQuery({axiosInstance:this.axiosInstance,modelName:e})}async listModelsQuery({pageSize:e,nextPageToken:t}){return listModelsQuery({axiosInstance:this.axiosInstance,pageSize:e,nextPageToken:t})}async listUserModelsQuery({userName:e,pageSize:t,nextPageToken:n}){return listUserModelsQuery({axiosInstance:this.axiosInstance,userName:e,pageSize:t,nextPageToken:n})}async getUserModelReadmeQuery({modelName:e}){return getUserModelReadmeQuery({axiosInstance:this.axiosInstance,modelName:e})}async watchUserModel({modelName:e}){return watchUserModel({axiosInstance:this.axiosInstance,modelName:e})}async createUserModelMutation({userName:e,payload:t}){return createUserModelMutation({axiosInstance:this.axiosInstance,userName:e,payload:t})}async updateModelMutation({payload:e}){return updateModelMutation({axiosInstance:this.axiosInstance,payload:e})}async deleteUserModelMutation({modelName:e}){return deleteUserModelMutation({axiosInstance:this.axiosInstance,modelName:e})}async deployUserModelAction({modelName:e}){return deployUserModelAction({axiosInstance:this.axiosInstance,modelName:e})}async undeployUserModelAction({modelName:e}){return undeployUserModelAction({axiosInstance:this.axiosInstance,modelName:e})}},ModelClient_default=ModelClient,import_axios7=__toESM(require("axios"));async function getOperationQuery({axiosInstance:e,operationName:t}){try{const{data:n}=await e.get(`/${t}`);return Promise.resolve(n.operation)}catch(e){return Promise.reject(e)}}async function checkUntilOperationIsDone({axiosInstance:e,operationName:t}){try{if((await getOperationQuery({axiosInstance:e,operationName:t})).done)return Promise.resolve(!0);{await new Promise((e=>setTimeout(e,1e3)));const n=await checkUntilOperationIsDone({axiosInstance:e,operationName:t});return Promise.resolve(n)}}catch(e){return Promise.reject(e)}}var OperationClient=class{axiosInstance;constructor(e,t,n){let a=`${e}/model/${t}`;this.axiosInstance=import_axios7.default.create({baseURL:a,headers:{Authorization:`Bearer ${n}`}})}async getOperationQuery({operationName:e}){return getOperationQuery({axiosInstance:this.axiosInstance,operationName:e})}async checkUntilOperationIsDone({operationName:e}){return checkUntilOperationIsDone({axiosInstance:this.axiosInstance,operationName:e})}},OperationClient_default=OperationClient,import_axios8=__toESM(require("axios"));async function listPipelinesQuery({axiosInstance:e,pageSize:t,nextPageToken:n}){try{const a=[],r=getQueryString({baseURL:"/pipelines?view=VIEW_FULL",pageSize:t,nextPageToken:n,filter:null}),{data:s}=await e.get(r);return a.push(...s.pipelines),s.next_page_token&&a.push(...await listPipelinesQuery({axiosInstance:e,pageSize:t,nextPageToken:s.next_page_token})),Promise.resolve(a)}catch(e){return Promise.reject(e)}}async function listUserPipelinesQuery({axiosInstance:e,pageSize:t,nextPageToken:n,userName:a}){try{const r=[],s=getQueryString({baseURL:`${a}/pipelines?view=VIEW_FULL`,pageSize:t,nextPageToken:n,filter:null}),{data:i}=await e.get(s);return r.push(...i.pipelines),i.next_page_token&&r.push(...await listUserPipelinesQuery({axiosInstance:e,pageSize:t,nextPageToken:i.next_page_token,userName:a})),Promise.resolve(r)}catch(e){return Promise.reject(e)}}async function getUserPipelineQuery({axiosInstance:e,pipelineName:t}){try{const{data:n}=await e.get(`/${t}?view=VIEW_FULL`);return Promise.resolve(n.pipeline)}catch(e){return Promise.reject(e)}}async function listUserPipelineReleasesQuery({axiosInstance:e,pipelineName:t,pageSize:n,nextPageToken:a}){try{const r=[],s=getQueryString({baseURL:`/${t}/releases?view=VIEW_FULL`,pageSize:n,nextPageToken:a,filter:null}),{data:i}=await e.get(s);return r.push(...i.releases),i.next_page_token&&r.push(...await listUserPipelineReleasesQuery({axiosInstance:e,pipelineName:t,pageSize:n,nextPageToken:i.next_page_token})),Promise.resolve(r)}catch(e){return Promise.reject(e)}}async function getUserPipelineReleaseQuery({axiosInstance:e,pipelineReleaseName:t}){try{const{data:n}=await e.get(`/${t}?view=VIEW_FULL`);return Promise.resolve(n.release)}catch(e){return Promise.reject(e)}}async function watchUserPipelineReleaseQuery({axiosInstance:e,pipelineReleaseName:t}){try{const{data:n}=await e.get(`/${t}/watch`);return Promise.resolve(n.state)}catch(e){return Promise.reject(e)}}async function createUserPipelineMutation({axiosInstance:e,userName:t,payload:n}){try{const{data:a}=await e.post(`${t}/pipelines`,n);return Promise.resolve(a.pipeline)}catch(e){return Promise.reject(e)}}async function updateUserPipelineMutation({axiosInstance:e,payload:t}){try{const{data:n}=await e.patch(`/${t.name}`,t);return Promise.resolve(n.pipeline)}catch(e){return Promise.reject(e)}}async function deleteUserPipelineMutation({axiosInstance:e,pipelineName:t}){try{await e.delete(`/${t}`)}catch(e){return Promise.reject(e)}}async function renameUserPipelineMutation({axiosInstance:e,payload:t}){try{const{data:n}=await e.post(`/${t.name}/rename`,t);return Promise.resolve(n.pipeline)}catch(e){return Promise.reject(e)}}async function createUserPipelineReleaseMutation({axiosInstance:e,pipelineName:t,payload:n}){try{const{data:a}=await e.post(`${t}/releases`,n);return Promise.resolve(a.release)}catch(e){return Promise.reject(e)}}async function updateUserPipelineReleaseMutation({axiosInstance:e,payload:t,pipelineReleaseName:n}){try{const{data:a}=await e.patch(`/${n}`,t);return Promise.resolve(a.release)}catch(e){return Promise.reject(e)}}async function deleteUserPipelineReleaseMutation({axiosInstance:e,pipelineReleaseName:t}){try{await e.delete(`/${t}`)}catch(e){return Promise.reject(e)}}async function triggerUserPipelineAction({axiosInstance:e,pipelineName:t,payload:n,returnTraces:a}){try{const{data:r}=await e.post(`/${t}/trigger`,n,{headers:{"instill-return-traces":a?"true":"false","Access-Control-Allow-Headers":"instill-return-traces","Content-Type":"application/json"}});return Promise.resolve(r)}catch(e){return Promise.reject(e)}}async function triggerAsyncUserPipelineAction({axiosInstance:e,pipelineName:t,payload:n,returnTraces:a}){try{const{data:r}=await e.post(`/${t}/triggerAsync`,n,{headers:{"instill-return-traces":a?"true":"false","Access-Control-Allow-Headers":"instill-return-traces","Content-Type":"application/json"}});return Promise.resolve(r.operation)}catch(e){return Promise.reject(e)}}async function setDefaultUserPipelineReleaseMutation({axiosInstance:e,pipelineReleaseName:t}){try{const{data:n}=await e.post(`/${t}/setDefault`);return Promise.resolve(n.release)}catch(e){return Promise.reject(e)}}async function restoreUserPipelineReleaseMutation({axiosInstance:e,pipelineReleaseName:t}){try{const{data:n}=await e.post(`/${t}/restore`);return Promise.resolve(n.release)}catch(e){return Promise.reject(e)}}async function triggerUserPipelineReleaseAction({axiosInstance:e,pipelineReleaseName:t,payload:n,returnTraces:a}){try{const{data:r}=await e.post(`/${t}/trigger`,n,{headers:{"instill-return-traces":a?"true":"false","Access-Control-Allow-Headers":"instill-return-traces","Content-Type":"application/json"}});return Promise.resolve(r)}catch(e){return Promise.reject(e)}}async function triggerAsyncUserPipelineReleaseAction({axiosInstance:e,pipelineReleaseName:t,payload:n,returnTraces:a}){try{const{data:r}=await e.post(`/${t}/triggerAsync`,n,{headers:{"instill-return-traces":a?"true":"false","Access-Control-Allow-Headers":"instill-return-traces","Content-Type":"application.json"}});return Promise.resolve(r.operation)}catch(e){return Promise.reject(e)}}var PipelineClient=class{axiosInstance;constructor(e,t,n){let a=`${e}/vdp/${t}`;this.axiosInstance=import_axios8.default.create({baseURL:a,headers:{Authorization:`Bearer ${n}`}})}async listPipelinesQuery({pageSize:e,nextPageToken:t}){return listPipelinesQuery({axiosInstance:this.axiosInstance,pageSize:e,nextPageToken:t})}async listUserPipelinesQuery({pageSize:e,nextPageToken:t,userName:n}){return listUserPipelinesQuery({axiosInstance:this.axiosInstance,pageSize:e,nextPageToken:t,userName:n})}async getUserPipelineQuery({pipelineName:e}){return getUserPipelineQuery({axiosInstance:this.axiosInstance,pipelineName:e})}async listUserPipelineReleasesQuery({pipelineName:e,pageSize:t,nextPageToken:n}){return listUserPipelineReleasesQuery({axiosInstance:this.axiosInstance,pipelineName:e,pageSize:t,nextPageToken:n})}async getUserPipelineReleaseQuery({pipelineReleaseName:e}){return getUserPipelineReleaseQuery({axiosInstance:this.axiosInstance,pipelineReleaseName:e})}async watchUserPipelineReleaseQuery({pipelineReleaseName:e}){return watchUserPipelineReleaseQuery({axiosInstance:this.axiosInstance,pipelineReleaseName:e})}async createUserPipelineMutation({userName:e,payload:t}){return createUserPipelineMutation({axiosInstance:this.axiosInstance,userName:e,payload:t})}async updateUserPipelineMutation({payload:e}){return updateUserPipelineMutation({axiosInstance:this.axiosInstance,payload:e})}async deleteUserPipelineMutation({pipelineName:e}){return deleteUserPipelineMutation({axiosInstance:this.axiosInstance,pipelineName:e})}async renameUserPipelineMutation({payload:e}){return renameUserPipelineMutation({axiosInstance:this.axiosInstance,payload:e})}async createUserPipelineReleaseMutation({pipelineName:e,payload:t}){return createUserPipelineReleaseMutation({axiosInstance:this.axiosInstance,pipelineName:e,payload:t})}async updateUserPipelineReleaseMutation({payload:e,pipelineReleaseName:t}){return updateUserPipelineReleaseMutation({axiosInstance:this.axiosInstance,payload:e,pipelineReleaseName:t})}async deleteUserPipelineReleaseMutation({pipelineReleaseName:e}){return deleteUserPipelineReleaseMutation({axiosInstance:this.axiosInstance,pipelineReleaseName:e})}async triggerUserPipelineAction({pipelineName:e,payload:t,returnTraces:n}){return triggerUserPipelineAction({axiosInstance:this.axiosInstance,pipelineName:e,payload:t,returnTraces:n})}async triggerAsyncUserPipelineAction({pipelineName:e,payload:t,returnTraces:n}){return triggerAsyncUserPipelineAction({axiosInstance:this.axiosInstance,pipelineName:e,payload:t,returnTraces:n})}async setDefaultUserPipelineReleaseMutation({pipelineReleaseName:e}){return setDefaultUserPipelineReleaseMutation({axiosInstance:this.axiosInstance,pipelineReleaseName:e})}async restoreUserPipelineReleaseMutation({pipelineReleaseName:e}){return restoreUserPipelineReleaseMutation({axiosInstance:this.axiosInstance,pipelineReleaseName:e})}async triggerUserPipelineReleaseAction({pipelineReleaseName:e,payload:t,returnTraces:n}){return triggerUserPipelineReleaseAction({axiosInstance:this.axiosInstance,pipelineReleaseName:e,payload:t,returnTraces:n})}async triggerAsyncUserPipelineReleaseAction({pipelineReleaseName:e,payload:t,returnTraces:n}){return triggerAsyncUserPipelineReleaseAction({axiosInstance:this.axiosInstance,pipelineReleaseName:e,payload:t,returnTraces:n})}},PipelineClient_default=PipelineClient,InstillClient=class{Pipeline;Auth;Connector;Metric;Model;Operation;constructor(e,t,n){this.Pipeline=new PipelineClient_default(e,t,n),this.Auth=new AuthClient_default(e,t,n),this.Connector=new ConnectorClient_default(e,t,n),this.Metric=new MetricClient_default(e,t,n),this.Model=new ModelClient_default(e,t,n),this.Operation=new OperationClient_default(e,t,n)}},src_default=InstillClient;
//# sourceMappingURL=/sm/43c1b9e22c446587cac0311bf8597f5144b052608a41ce4c16a35612b2f8c307.map