@qdrant/js-client-rest - npm Package Compare versions

Comparing version 1.1.5 to 1.1.6

dist/browser/index.min.js

@@ -1,1 +0,1 @@
-var t={isNone:function(){return!0},orElse:function(t){return t},orCall:function(t){return t()},orNull:function(){return null},orThrow:function(t){throw void 0===t&&(t="Unexpected null value"),new TypeError(t)},map:function(){return t},get:function(){return t}},e=function(){function t(t){this.value=t}return t.prototype.isNone=function(){return!1},t.prototype.orElse=function(){return this.value},t.prototype.orCall=function(){return this.value},t.prototype.orNull=function(){return this.value},t.prototype.orThrow=function(){return this.value},t.prototype.map=function(t){return o(t(this.value))},t.prototype.get=function(t){return this.map((function(e){return e[t]}))},t}();function o(o){return function(o){return o===t||o instanceof e}(o)?o:null==o?t:function(t){if(null==t)throw new TypeError("some() does not accept null or undefined");return new e(t)}(o)}function n(t){return{clusterStatus:t.path("/cluster").method("get").create(),collectionClusterInfo:t.path("/collections/{collection_name}/cluster").method("get").create(),recoverCurrentPeer:t.path("/cluster/recover").method("post").create(),removePeer:t.path("/cluster/peer/{peer_id}").method("delete").create({force:!0}),updateCollectionCluster:t.path("/collections/{collection_name}/cluster").method("post").create({timeout:!0})}}function r(t){return{collectionClusterInfo:t.path("/collections/{collection_name}/cluster").method("get").create(),createCollection:t.path("/collections/{collection_name}").method("put").create({timeout:!0}),createFieldIndex:t.path("/collections/{collection_name}/index").method("put").create({ordering:!0,wait:!0}),createSnapshot:t.path("/collections/{collection_name}/snapshots").method("post").create({wait:!0}),deleteCollection:t.path("/collections/{collection_name}").method("delete").create({timeout:!0}),deleteFieldIndex:t.path("/collections/{collection_name}/index/{field_name}").method("delete").create({ordering:!0,wait:!0}),deleteSnapshots:t.path("/collections/{collection_name}/snapshots/{snapshot_name}").method("delete").create({wait:!0}),getCollection:t.path("/collections/{collection_name}").method("get").create(),getCollectionAliases:t.path("/collections/{collection_name}/aliases").method("get").create(),getCollections:t.path("/collections").method("get").create(),getCollectionsAliases:t.path("/aliases").method("get").create(),getSnapshot:t.path("/collections/{collection_name}/snapshots/{snapshot_name}").method("get").create(),listSnapshots:t.path("/collections/{collection_name}/snapshots").method("get").create(),recoverFromSnapshot:t.path("/collections/{collection_name}/snapshots/recover").method("put").create({wait:!0}),updateAliases:t.path("/collections/aliases").method("post").create({timeout:!0}),updateCollection:t.path("/collections/{collection_name}").method("patch").create({timeout:!0}),updateCollectionCluster:t.path("/collections/{collection_name}/cluster").method("post").create({timeout:!0})}}function s(t){return{clearPayload:t.path("/collections/{collection_name}/points/payload/clear").method("post").create({ordering:!0,wait:!0}),countPoints:t.path("/collections/{collection_name}/points/count").method("post").create(),deletePayload:t.path("/collections/{collection_name}/points/payload/delete").method("post").create({wait:!0,ordering:!0}),deletePoints:t.path("/collections/{collection_name}/points/delete").method("post").create({wait:!0,ordering:!0}),getPoint:t.path("/collections/{collection_name}/points/{id}").method("get").create(),getPoints:t.path("/collections/{collection_name}/points").method("post").create({consistency:!0}),overwritePayload:t.path("/collections/{collection_name}/points/payload").method("put").create({wait:!0,ordering:!0}),recommendBatchPoints:t.path("/collections/{collection_name}/points/recommend/batch").method("post").create({consistency:!0}),recommendPoints:t.path("/collections/{collection_name}/points/recommend").method("post").create({consistency:!0}),scrollPoints:t.path("/collections/{collection_name}/points/scroll").method("post").create({consistency:!0}),searchBatchPoints:t.path("/collections/{collection_name}/points/search/batch").method("post").create({consistency:!0}),searchPoints:t.path("/collections/{collection_name}/points/search").method("post").create({consistency:!0}),setPayload:t.path("/collections/{collection_name}/points/payload").method("post").create({wait:!0,ordering:!0}),upsertPoints:t.path("/collections/{collection_name}/points").method("put").create({wait:!0,ordering:!0})}}function a(t){return{getLocks:t.path("/locks").method("get").create(),metrics:t.path("/metrics").method("get").create(),postLocks:t.path("/locks").method("post").create(),telemetry:t.path("/telemetry").method("get").create()}}function i(t){return{createFullSnapshot:t.path("/snapshots").method("post").create({wait:!0}),createSnapshot:t.path("/collections/{collection_name}/snapshots").method("post").create({wait:!0}),deleteFullSnapshot:t.path("/snapshots/{snapshot_name}").method("delete").create({wait:!0}),deleteSnapshot:t.path("/collections/{collection_name}/snapshots/{snapshot_name}").method("delete").create({wait:!0}),getFullSnapshot:t.path("/snapshots/{snapshot_name}").method("get").create(),getSnapshot:t.path("/collections/{collection_name}/snapshots/{snapshot_name}").method("get").create(),listFullSnapshots:t.path("/snapshots").method("get").create(),listSnapshots:t.path("/collections/{collection_name}/snapshots").method("get").create(),recoverFromSnapshot:t.path("/collections/{collection_name}/snapshots/recover").method("put").create({wait:!0})}}class c extends Error{constructor(t){super(t),this.name=this.constructor.name,Object.setPrototypeOf(this,new.target.prototype)}}class l extends c{static forResponse(t){const e=`${`${t.status}`} ${t.statusText?`(${t.statusText})`:"(Unrecognized Status Code)"}`.trim(),o=t.data?JSON.stringify(t.data,null,2):null;let n="";o&&(n=o.length<=200?o:o.slice(0,-4)+" ...");return new l(`Unexpected Response: ${e}\n${`Raw response content:\n${n}`}`)}}class p extends c{}class h extends c{}class u extends c{}class d extends Error{constructor(t){super(t.statusText),Object.setPrototypeOf(this,new.target.prototype),this.headers=t.headers,this.url=t.url,this.status=t.status,this.statusText=t.statusText,this.data=t.data}}const m=t=>"post"===t||"put"===t||"patch"===t||"delete"===t;function _(t,e,o){let n={};return m(t)?o.forEach((t=>{n[t]=e[t],delete e[t]})):n={...e},function(t){const e=[],o=(t,e)=>`${encodeURIComponent(t)}=${encodeURIComponent(String(e))}`;return Object.keys(t).forEach((n=>{const r=t[n];null!=r&&(Array.isArray(r)?r.forEach((t=>e.push(o(n,t)))):e.push(o(n,r)))})),e.length>0?`?${e.join("&")}`:""}(n)}function y(t,e){const o=new Headers(null==t?void 0:t.headers),n=new Headers(null==e?void 0:e.headers);for(const t of n.keys()){const e=n.get(t);null!=e&&o.set(t,e)}return{...t,...e,headers:o}}function w(t){var e;const o=Object.assign(Array.isArray(t.payload)?[]:{},t.payload),n=function(t,e){return t.replace(/\{([^}]+)\}/g,((t,o)=>{const n=encodeURIComponent(e[o]);return delete e[o],n}))}(t.path,o),r=_(t.method,o,t.queryParams),s=function(t,e){const o=m(t)?JSON.stringify(e):void 0;return"delete"===t&&"{}"===o?void 0:o}(t.method,o),a=function(t,e){const o=new Headers(e);return void 0===t||o.has("Content-Type")||o.append("Content-Type","application/json"),o.has("Accept")||o.append("Accept","application/json"),o}(s,null===(e=t.init)||void 0===e?void 0:e.headers);return{url:t.baseUrl+n+r,init:{...t.init,method:t.method.toUpperCase(),headers:a,body:s}}}async function f(t,e){const o=await fetch(t,e),n=await async function(t){const e=t.headers.get("content-type");if(204===t.status)return;if(e&&-1!==e.indexOf("application/json"))return await t.json();const o=await t.text();try{return JSON.parse(o)}catch(t){return o}}(o),r={headers:o.headers,url:o.url,ok:o.ok,status:o.status,statusText:o.statusText,data:n};if(r.ok)return r;throw new d(r)}function g(){let t="",e={};const o=[],n=function(t,e){const o=async(n,r,s)=>{if(null==t||n===t.length)return e(r,s);const a=t[n];return await a(r,s,((t,e)=>o(n+1,t,e)))};return(t,e)=>o(0,t,e)}(o,f);return{configure:n=>{t=n.baseUrl||"",e=n.init||{},o.splice(0),o.push(...n.use||[])},use:t=>o.push(t),path:o=>({method:r=>({create:s=>function(t){const e=async(o,n)=>{try{return await t(o,n)}catch(t){if(t instanceof d)throw new e.Error(t);throw t}};return e.Error=class extends d{constructor(t){super(t),Object.setPrototypeOf(this,new.target.prototype)}getActualType(){return{status:this.status,data:this.data}}},e}(((a,i)=>async function(t){const{url:e,init:o}=w(t);return await t.fetch(e,o)}({baseUrl:t||"",path:o,method:r,queryParams:Object.keys(s||{}),payload:a,init:y(e,i),fetch:n})))})})}}const C={for:()=>g()};function A(t,e){const o=function(t,{headers:e,timeout:o}){const n=[];Number.isFinite(o)&&n.push((async(t,e,n)=>{const r=new AbortController,s=setTimeout((()=>r.abort()),o);try{return await n(t,{...e,signal:r.signal})}catch(t){if(t instanceof Error&&"AbortError"===t.name)throw new h(t.message);throw t}finally{clearTimeout(s)}}));n.push((async(t,e,o)=>{const n=await o(t,e);if(200===n.status||201===n.status)return n;throw l.forResponse(n)}));const r=C.for();return r.configure({baseUrl:t,init:{headers:e},use:n}),r}(t,e);return{cluster:n(o),collections:r(o),points:s(o),service:a(o),snapshots:i(o)}}class v{constructor({url:t,host:e,apiKey:o,https:n,prefix:r,port:s=6333,timeout:a=3e5,...i}={}){if(this._https=n??"string"==typeof o,this._scheme=this._https?"https":"http",this._prefix=r??"",this._prefix.length>0&&!this._prefix.startsWith("/")&&(this._prefix=`/${this._prefix}`),t&&e)throw new p(`Only one of \`url\`, \`host\` params can be set. Url is ${t}, host is ${e}`);if(e&&(e.startsWith("http://")||e.startsWith("https://")||/:\d+$/.test(e)))throw new p("The `host` param is not expected to contain neither protocol (http:// or https://) nor port (:6333).\nTry to use the `url` parameter instead.");if(t){if(!t.startsWith("http://")&&!t.startsWith("https://"))throw new p("The `url` param expected to contain a valid URL starting with a protocol (http:// or https://).");const e=new URL(t);if(this._host=e.hostname,this._port=e.port?Number(e.port):s,this._scheme=e.protocol.replace(":",""),this._prefix.length>0&&"/"!==e.pathname)throw new p(`Prefix can be set either in \`url\` or in \`prefix\`.\nurl is ${t}, prefix is ${e.pathname}`)}else this._port=s,this._host=e??"127.0.0.1";const c=new Headers,l=i.headers??{};Object.keys(l).forEach((t=>{l[t]&&c.set(t,String(l[t]))})),"string"==typeof o&&("http"===this._scheme&&console.warn("Api key is used with unsecure connection."),c.set("api-key",o));const h=this._port?`${this._host}:${this._port}`:this._host;this._restUri=`${this._scheme}://${h}${this._prefix}`;const u={headers:c,timeout:a};this._openApiClient=A(this._restUri,u)}api(t){return this._openApiClient[t]}async searchBatch(t,{searches:e,consistency:n}){return o((await this._openApiClient.points.searchBatchPoints({collection_name:t,consistency:n,searches:e})).data.result).orThrow("Search batch returned empty")}async search(t,{vector:e,limit:n=10,offset:r=0,filter:s,params:a,with_payload:i=!0,with_vector:c=!1,score_threshold:l,consistency:p}){return o((await this._openApiClient.points.searchPoints({collection_name:t,consistency:p,vector:e,limit:n,offset:r,filter:s,params:a,with_payload:i,with_vector:c,score_threshold:l})).data.result).orThrow("Search returned empty")}async recommend_batch(t,{searches:e,consistency:n}){return o((await this._openApiClient.points.recommendBatchPoints({collection_name:t,searches:e,consistency:n})).data.result).orElse([])}async recommend(t,{positive:e,negative:n,filter:r,params:s,limit:a=10,offset:i=0,with_payload:c=!0,with_vector:l=!1,score_threshold:p,using:h,lookup_from:u,consistency:d}){return o((await this._openApiClient.points.recommendPoints({collection_name:t,limit:a,positive:e,negative:n,filter:r,params:s,offset:i,with_payload:c,with_vector:l,score_threshold:p,using:h,lookup_from:u,consistency:d})).data.result).orThrow("Recommend points API returned empty")}async scroll(t,{filter:e,consistency:n,limit:r=10,offset:s,with_payload:a=!0,with_vector:i=!1}={}){return o((await this._openApiClient.points.scrollPoints({collection_name:t,limit:r,offset:s,filter:e,with_payload:a,with_vector:i,consistency:n})).data.result).orThrow("Scroll points API returned empty")}async count(t,{filter:e,exact:n=!0}={}){return o((await this._openApiClient.points.countPoints({collection_name:t,filter:e,exact:n})).data.result).orThrow("Count points returned empty")}async upsert(t,{wait:e=!0,ordering:n,...r}){return o((await this._openApiClient.points.upsertPoints({collection_name:t,wait:e,ordering:n,...r})).data.result).orThrow("Upsert returned empty")}async retrieve(t,{ids:e,with_payload:n=!0,with_vector:r,consistency:s}){return o((await this._openApiClient.points.getPoints({collection_name:t,ids:e,with_payload:n,with_vector:r,consistency:s})).data.result).orThrow("Retrieve API returned empty")}async delete(t,{wait:e,ordering:n,...r}){return o((await this._openApiClient.points.deletePoints({collection_name:t,wait:e,ordering:n,...r})).data.result).orThrow("Delete points returned empty")}async setPayload(t,{payload:e,points:n,filter:r,ordering:s,wait:a=!0}){return o((await this._openApiClient.points.setPayload({collection_name:t,payload:e,points:n,filter:r,wait:a,ordering:s})).data.result).orThrow("Set payload returned empty")}async overwritePayload(t,{ordering:e,payload:n,points:r,filter:s,wait:a=!0}){return o((await this._openApiClient.points.overwritePayload({collection_name:t,payload:n,points:r,filter:s,wait:a,ordering:e})).data.result).orThrow("Overwrite payload returned empty")}async deletePayload(t,{ordering:e,keys:n,points:r,filter:s,wait:a=!0}){return o((await this._openApiClient.points.deletePayload({collection_name:t,keys:n,points:r,filter:s,wait:a,ordering:e})).data.result).orThrow("Delete payload returned empty")}async clearPayload(t,{ordering:e,wait:n=!0,...r}){return o((await this._openApiClient.points.clearPayload({collection_name:t,wait:n,ordering:e,...r})).data.result).orThrow("Clear payload returned empty")}async updateCollectionAliases({actions:t,timeout:e}){return o((await this._openApiClient.collections.updateAliases({actions:t,timeout:e})).data.result).orThrow("Update aliases returned empty")}async getCollectionAliases(t){return o((await this._openApiClient.collections.getCollectionAliases({collection_name:t})).data.result).orThrow("Get collection aliases returned empty")}async getAliases(){return o((await this._openApiClient.collections.getCollectionsAliases({})).data.result).orThrow("Get aliases returned empty")}async getCollections(){return o((await this._openApiClient.collections.getCollections({})).data.result).orThrow("Get collections returned empty")}async getCollection(t){return o((await this._openApiClient.collections.getCollection({collection_name:t})).data.result).orThrow("Get collection returned empty")}async updateCollection(t,e){return o((await this._openApiClient.collections.updateCollection({collection_name:t,...e})).data.result).orThrow("Update collection returned empty")}async deleteCollection(t,e){return o((await this._openApiClient.collections.deleteCollection({collection_name:t,...e})).data.result).orThrow("Delete collection returned empty")}async createCollection(t,{timeout:e,vectors:n,hnsw_config:r,init_from:s,on_disk_payload:a,optimizers_config:i,quantization_config:c,replication_factor:l,shard_number:p,wal_config:h,write_consistency_factor:u}){return o((await this._openApiClient.collections.createCollection({collection_name:t,timeout:e,vectors:n,hnsw_config:r,init_from:s,on_disk_payload:a,optimizers_config:i,quantization_config:c,replication_factor:l,shard_number:p,wal_config:h,write_consistency_factor:u})).data.result).orThrow("Create collection returned empty")}async recreateCollection(t,{timeout:e,vectors:n,hnsw_config:r,init_from:s,on_disk_payload:a,optimizers_config:i,quantization_config:c,replication_factor:l,shard_number:p,wal_config:h,write_consistency_factor:u}){o(await this._openApiClient.collections.deleteCollection({collection_name:t,timeout:e})).get("ok").orThrow("Delete collection returned failed");return o(await this._openApiClient.collections.createCollection({collection_name:t,timeout:e,vectors:n,hnsw_config:r,init_from:s,on_disk_payload:a,optimizers_config:i,quantization_config:c,replication_factor:l,shard_number:p,wal_config:h,write_consistency_factor:u})).orThrow("Create collection returned empty")}async uploadRecords(){return Promise.reject(new u("uploadRecords()"))}async uploadCollection(){return Promise.reject(new u("uploadCollection()"))}async createPayloadIndex(t,{wait:e,ordering:n,field_name:r,field_schema:s}){return o((await this._openApiClient.collections.createFieldIndex({collection_name:t,field_name:r,field_schema:s,wait:e,ordering:n})).data.result).orThrow("Create field index returned empty")}async deletePayloadIndex(t,e,{wait:n=!0,ordering:r}={}){return o((await this._openApiClient.collections.deleteFieldIndex({collection_name:t,field_name:e,wait:n,ordering:r})).data.result).orThrow("Delete field index returned empty")}async listSnapshots(t){return o((await this._openApiClient.snapshots.listSnapshots({collection_name:t})).data.result).orThrow("List snapshots API returned empty")}async createSnapshot(t,e){return o((await this._openApiClient.snapshots.createSnapshot({collection_name:t,...e})).data.result).orNull()}async deleteSnapshot(t,e,n){return o((await this._openApiClient.snapshots.deleteSnapshot({collection_name:t,snapshot_name:e,...n})).data.result).orThrow("Delete snapshot API returned empty")}async listFullSnapshots(){return o((await this._openApiClient.snapshots.listFullSnapshots({})).data.result).orThrow("List full snapshots API returned empty")}async createFullSnapshot(t){return o((await this._openApiClient.snapshots.createFullSnapshot({...t})).data.result).orThrow("Create full snapshot API returned empty")}async deleteFullSnapshot(t,e){return o((await this._openApiClient.snapshots.deleteFullSnapshot({snapshot_name:t,...e})).data.result).orThrow("Delete full snapshot API returned empty")}async recoverSnapshot(t,{location:e,priority:n}){return o((await this._openApiClient.snapshots.recoverFromSnapshot({collection_name:t,location:e,priority:n})).data.result).orThrow("Recover from snapshot API returned empty")}async lockStorage(t){return o((await this._openApiClient.service.postLocks({write:!0,error_message:t})).data.result).orThrow("Lock storage returned empty")}async unlockStorage(){return o((await this._openApiClient.service.postLocks({write:!1})).data.result).orThrow("Post locks returned empty")}async getLocks(){return o((await this._openApiClient.service.getLocks({})).data.result).orThrow("Get locks returned empty")}}export{v as QdrantClient};
+var t={isNone:function(){return!0},orElse:function(t){return t},orCall:function(t){return t()},orNull:function(){return null},orThrow:function(t){throw void 0===t&&(t="Unexpected null value"),new TypeError(t)},map:function(){return t},get:function(){return t}},e=function(){function t(t){this.value=t}return t.prototype.isNone=function(){return!1},t.prototype.orElse=function(){return this.value},t.prototype.orCall=function(){return this.value},t.prototype.orNull=function(){return this.value},t.prototype.orThrow=function(){return this.value},t.prototype.map=function(t){return o(t(this.value))},t.prototype.get=function(t){return this.map((function(e){return e[t]}))},t}();function o(o){return function(o){return o===t||o instanceof e}(o)?o:null==o?t:function(t){if(null==t)throw new TypeError("some() does not accept null or undefined");return new e(t)}(o)}function n(t){return{clusterStatus:t.path("/cluster").method("get").create(),collectionClusterInfo:t.path("/collections/{collection_name}/cluster").method("get").create(),recoverCurrentPeer:t.path("/cluster/recover").method("post").create(),removePeer:t.path("/cluster/peer/{peer_id}").method("delete").create({force:!0}),updateCollectionCluster:t.path("/collections/{collection_name}/cluster").method("post").create({timeout:!0})}}function r(t){return{collectionClusterInfo:t.path("/collections/{collection_name}/cluster").method("get").create(),createCollection:t.path("/collections/{collection_name}").method("put").create({timeout:!0}),createFieldIndex:t.path("/collections/{collection_name}/index").method("put").create({ordering:!0,wait:!0}),createSnapshot:t.path("/collections/{collection_name}/snapshots").method("post").create({wait:!0}),deleteCollection:t.path("/collections/{collection_name}").method("delete").create({timeout:!0}),deleteFieldIndex:t.path("/collections/{collection_name}/index/{field_name}").method("delete").create({ordering:!0,wait:!0}),deleteSnapshots:t.path("/collections/{collection_name}/snapshots/{snapshot_name}").method("delete").create({wait:!0}),getCollection:t.path("/collections/{collection_name}").method("get").create(),getCollectionAliases:t.path("/collections/{collection_name}/aliases").method("get").create(),getCollections:t.path("/collections").method("get").create(),getCollectionsAliases:t.path("/aliases").method("get").create(),getSnapshot:t.path("/collections/{collection_name}/snapshots/{snapshot_name}").method("get").create(),listSnapshots:t.path("/collections/{collection_name}/snapshots").method("get").create(),recoverFromSnapshot:t.path("/collections/{collection_name}/snapshots/recover").method("put").create({wait:!0}),updateAliases:t.path("/collections/aliases").method("post").create({timeout:!0}),updateCollection:t.path("/collections/{collection_name}").method("patch").create({timeout:!0}),updateCollectionCluster:t.path("/collections/{collection_name}/cluster").method("post").create({timeout:!0})}}function s(t){return{clearPayload:t.path("/collections/{collection_name}/points/payload/clear").method("post").create({ordering:!0,wait:!0}),countPoints:t.path("/collections/{collection_name}/points/count").method("post").create(),deletePayload:t.path("/collections/{collection_name}/points/payload/delete").method("post").create({wait:!0,ordering:!0}),deletePoints:t.path("/collections/{collection_name}/points/delete").method("post").create({wait:!0,ordering:!0}),getPoint:t.path("/collections/{collection_name}/points/{id}").method("get").create(),getPoints:t.path("/collections/{collection_name}/points").method("post").create({consistency:!0}),overwritePayload:t.path("/collections/{collection_name}/points/payload").method("put").create({wait:!0,ordering:!0}),recommendBatchPoints:t.path("/collections/{collection_name}/points/recommend/batch").method("post").create({consistency:!0}),recommendPoints:t.path("/collections/{collection_name}/points/recommend").method("post").create({consistency:!0}),scrollPoints:t.path("/collections/{collection_name}/points/scroll").method("post").create({consistency:!0}),searchBatchPoints:t.path("/collections/{collection_name}/points/search/batch").method("post").create({consistency:!0}),searchPoints:t.path("/collections/{collection_name}/points/search").method("post").create({consistency:!0}),setPayload:t.path("/collections/{collection_name}/points/payload").method("post").create({wait:!0,ordering:!0}),upsertPoints:t.path("/collections/{collection_name}/points").method("put").create({wait:!0,ordering:!0})}}function a(t){return{getLocks:t.path("/locks").method("get").create(),metrics:t.path("/metrics").method("get").create(),postLocks:t.path("/locks").method("post").create(),telemetry:t.path("/telemetry").method("get").create()}}function i(t){return{createFullSnapshot:t.path("/snapshots").method("post").create({wait:!0}),createSnapshot:t.path("/collections/{collection_name}/snapshots").method("post").create({wait:!0}),deleteFullSnapshot:t.path("/snapshots/{snapshot_name}").method("delete").create({wait:!0}),deleteSnapshot:t.path("/collections/{collection_name}/snapshots/{snapshot_name}").method("delete").create({wait:!0}),getFullSnapshot:t.path("/snapshots/{snapshot_name}").method("get").create(),getSnapshot:t.path("/collections/{collection_name}/snapshots/{snapshot_name}").method("get").create(),listFullSnapshots:t.path("/snapshots").method("get").create(),listSnapshots:t.path("/collections/{collection_name}/snapshots").method("get").create(),recoverFromSnapshot:t.path("/collections/{collection_name}/snapshots/recover").method("put").create({wait:!0})}}class c extends Error{constructor(t){super(t),this.name=this.constructor.name,Object.setPrototypeOf(this,new.target.prototype)}}class l extends c{static forResponse(t){const e=`${`${t.status}`} ${t.statusText?`(${t.statusText})`:"(Unrecognized Status Code)"}`.trim(),o=t.data?JSON.stringify(t.data,null,2):null;let n="";o&&(n=o.length<=200?o:o.slice(0,-4)+" ...");return new l(`Unexpected Response: ${e}\n${`Raw response content:\n${n}`}`)}}class p extends c{}class h extends c{}class u extends c{}class d extends Error{constructor(t){super(t.statusText),Object.setPrototypeOf(this,new.target.prototype),this.headers=t.headers,this.url=t.url,this.status=t.status,this.statusText=t.statusText,this.data=t.data}}const m=t=>"post"===t||"put"===t||"patch"===t||"delete"===t;function _(t,e,o){let n={};return m(t)?o.forEach((t=>{n[t]=e[t],delete e[t]})):n={...e},function(t){const e=[],o=(t,e)=>`${encodeURIComponent(t)}=${encodeURIComponent(String(e))}`;return Object.keys(t).forEach((n=>{const r=t[n];null!=r&&(Array.isArray(r)?r.forEach((t=>e.push(o(n,t)))):e.push(o(n,r)))})),e.length>0?`?${e.join("&")}`:""}(n)}function y(t,e){const o=new Headers(null==t?void 0:t.headers),n=new Headers(null==e?void 0:e.headers);for(const t of n.keys()){const e=n.get(t);null!=e&&o.set(t,e)}return{...t,...e,headers:o}}function w(t){var e,o;const n=Object.assign(Array.isArray(t.payload)?[]:{},t.payload),r=function(t,e){return t.replace(/\{([^}]+)\}/g,((t,o)=>{const n=encodeURIComponent(e[o]);return delete e[o],n}))}(t.path,n),s=_(t.method,n,t.queryParams),a=function(t,e){if(!m(t))return;const o=e instanceof FormData?e:JSON.stringify(e);return"delete"===t&&"{}"===o?void 0:o}(t.method,n),i=m(t.method)?function(t,e){const o=new Headers(e);return void 0===t||t instanceof FormData||o.has("Content-Type")||o.append("Content-Type","application/json"),o.has("Accept")||o.append("Accept","application/json"),o}(a,null===(e=t.init)||void 0===e?void 0:e.headers):new Headers(null===(o=t.init)||void 0===o?void 0:o.headers);return{url:t.baseUrl+r+s,init:{...t.init,method:t.method.toUpperCase(),headers:i,body:a}}}async function f(t,e){const o=await fetch(t,e),n=await async function(t){const e=t.headers.get("content-type");if(204===t.status)return;if(e&&-1!==e.indexOf("application/json"))return await t.json();const o=await t.text();try{return JSON.parse(o)}catch(t){return o}}(o),r={headers:o.headers,url:o.url,ok:o.ok,status:o.status,statusText:o.statusText,data:n};if(r.ok)return r;throw new d(r)}function g(){let t="",e={};const o=[],n=function(t,e){const o=async(n,r,s)=>{if(null==t||n===t.length)return e(r,s);const a=t[n];return await a(r,s,((t,e)=>o(n+1,t,e)))};return(t,e)=>o(0,t,e)}(o,f);return{configure:n=>{t=n.baseUrl||"",e=n.init||{},o.splice(0),o.push(...n.use||[])},use:t=>o.push(t),path:o=>({method:r=>({create:s=>function(t){const e=async(o,n)=>{try{return await t(o,n)}catch(t){if(t instanceof d)throw new e.Error(t);throw t}};return e.Error=class extends d{constructor(t){super(t),Object.setPrototypeOf(this,new.target.prototype)}getActualType(){return{status:this.status,data:this.data}}},e}(((a,i)=>async function(t){const{url:e,init:o}=w(t);return await t.fetch(e,o)}({baseUrl:t||"",path:o,method:r,queryParams:Object.keys(s||{}),payload:a,init:y(e,i),fetch:n})))})})}}const C={for:()=>g()};function A(t,e){const o=function(t,{headers:e,timeout:o}){const n=[];Number.isFinite(o)&&n.push((async(t,e,n)=>{const r=new AbortController,s=setTimeout((()=>r.abort()),o);try{return await n(t,{...e,signal:r.signal})}catch(t){if(t instanceof Error&&"AbortError"===t.name)throw new h(t.message);throw t}finally{clearTimeout(s)}}));n.push((async(t,e,o)=>{const n=await o(t,e);if(200===n.status||201===n.status)return n;throw l.forResponse(n)}));const r=C.for();return r.configure({baseUrl:t,init:{headers:e},use:n}),r}(t,e);return{cluster:n(o),collections:r(o),points:s(o),service:a(o),snapshots:i(o)}}class v{constructor({url:t,host:e,apiKey:o,https:n,prefix:r,port:s=6333,timeout:a=3e5,...i}={}){if(this._https=n??"string"==typeof o,this._scheme=this._https?"https":"http",this._prefix=r??"",this._prefix.length>0&&!this._prefix.startsWith("/")&&(this._prefix=`/${this._prefix}`),t&&e)throw new p(`Only one of \`url\`, \`host\` params can be set. Url is ${t}, host is ${e}`);if(e&&(e.startsWith("http://")||e.startsWith("https://")||/:\d+$/.test(e)))throw new p("The `host` param is not expected to contain neither protocol (http:// or https://) nor port (:6333).\nTry to use the `url` parameter instead.");if(t){if(!t.startsWith("http://")&&!t.startsWith("https://"))throw new p("The `url` param expected to contain a valid URL starting with a protocol (http:// or https://).");const e=new URL(t);if(this._host=e.hostname,this._port=e.port?Number(e.port):s,this._scheme=e.protocol.replace(":",""),this._prefix.length>0&&"/"!==e.pathname)throw new p(`Prefix can be set either in \`url\` or in \`prefix\`.\nurl is ${t}, prefix is ${e.pathname}`)}else this._port=s,this._host=e??"127.0.0.1";const c=new Headers,l=i.headers??{};Object.keys(l).forEach((t=>{l[t]&&c.set(t,String(l[t]))})),"string"==typeof o&&("http"===this._scheme&&console.warn("Api key is used with unsecure connection."),c.set("api-key",o));const h=this._port?`${this._host}:${this._port}`:this._host;this._restUri=`${this._scheme}://${h}${this._prefix}`;const u={headers:c,timeout:a};this._openApiClient=A(this._restUri,u)}api(t){return this._openApiClient[t]}async searchBatch(t,{searches:e,consistency:n}){return o((await this._openApiClient.points.searchBatchPoints({collection_name:t,consistency:n,searches:e})).data.result).orThrow("Search batch returned empty")}async search(t,{vector:e,limit:n=10,offset:r=0,filter:s,params:a,with_payload:i=!0,with_vector:c=!1,score_threshold:l,consistency:p}){return o((await this._openApiClient.points.searchPoints({collection_name:t,consistency:p,vector:e,limit:n,offset:r,filter:s,params:a,with_payload:i,with_vector:c,score_threshold:l})).data.result).orThrow("Search returned empty")}async recommend_batch(t,{searches:e,consistency:n}){return o((await this._openApiClient.points.recommendBatchPoints({collection_name:t,searches:e,consistency:n})).data.result).orElse([])}async recommend(t,{positive:e,negative:n,filter:r,params:s,limit:a=10,offset:i=0,with_payload:c=!0,with_vector:l=!1,score_threshold:p,using:h,lookup_from:u,consistency:d}){return o((await this._openApiClient.points.recommendPoints({collection_name:t,limit:a,positive:e,negative:n,filter:r,params:s,offset:i,with_payload:c,with_vector:l,score_threshold:p,using:h,lookup_from:u,consistency:d})).data.result).orThrow("Recommend points API returned empty")}async scroll(t,{filter:e,consistency:n,limit:r=10,offset:s,with_payload:a=!0,with_vector:i=!1}={}){return o((await this._openApiClient.points.scrollPoints({collection_name:t,limit:r,offset:s,filter:e,with_payload:a,with_vector:i,consistency:n})).data.result).orThrow("Scroll points API returned empty")}async count(t,{filter:e,exact:n=!0}={}){return o((await this._openApiClient.points.countPoints({collection_name:t,filter:e,exact:n})).data.result).orThrow("Count points returned empty")}async upsert(t,{wait:e=!0,ordering:n,...r}){return o((await this._openApiClient.points.upsertPoints({collection_name:t,wait:e,ordering:n,...r})).data.result).orThrow("Upsert returned empty")}async retrieve(t,{ids:e,with_payload:n=!0,with_vector:r,consistency:s}){return o((await this._openApiClient.points.getPoints({collection_name:t,ids:e,with_payload:n,with_vector:r,consistency:s})).data.result).orThrow("Retrieve API returned empty")}async delete(t,{wait:e,ordering:n,...r}){return o((await this._openApiClient.points.deletePoints({collection_name:t,wait:e,ordering:n,...r})).data.result).orThrow("Delete points returned empty")}async setPayload(t,{payload:e,points:n,filter:r,ordering:s,wait:a=!0}){return o((await this._openApiClient.points.setPayload({collection_name:t,payload:e,points:n,filter:r,wait:a,ordering:s})).data.result).orThrow("Set payload returned empty")}async overwritePayload(t,{ordering:e,payload:n,points:r,filter:s,wait:a=!0}){return o((await this._openApiClient.points.overwritePayload({collection_name:t,payload:n,points:r,filter:s,wait:a,ordering:e})).data.result).orThrow("Overwrite payload returned empty")}async deletePayload(t,{ordering:e,keys:n,points:r,filter:s,wait:a=!0}){return o((await this._openApiClient.points.deletePayload({collection_name:t,keys:n,points:r,filter:s,wait:a,ordering:e})).data.result).orThrow("Delete payload returned empty")}async clearPayload(t,{ordering:e,wait:n=!0,...r}){return o((await this._openApiClient.points.clearPayload({collection_name:t,wait:n,ordering:e,...r})).data.result).orThrow("Clear payload returned empty")}async updateCollectionAliases({actions:t,timeout:e}){return o((await this._openApiClient.collections.updateAliases({actions:t,timeout:e})).data.result).orThrow("Update aliases returned empty")}async getCollectionAliases(t){return o((await this._openApiClient.collections.getCollectionAliases({collection_name:t})).data.result).orThrow("Get collection aliases returned empty")}async getAliases(){return o((await this._openApiClient.collections.getCollectionsAliases({})).data.result).orThrow("Get aliases returned empty")}async getCollections(){return o((await this._openApiClient.collections.getCollections({})).data.result).orThrow("Get collections returned empty")}async getCollection(t){return o((await this._openApiClient.collections.getCollection({collection_name:t})).data.result).orThrow("Get collection returned empty")}async updateCollection(t,e){return o((await this._openApiClient.collections.updateCollection({collection_name:t,...e})).data.result).orThrow("Update collection returned empty")}async deleteCollection(t,e){return o((await this._openApiClient.collections.deleteCollection({collection_name:t,...e})).data.result).orThrow("Delete collection returned empty")}async createCollection(t,{timeout:e,vectors:n,hnsw_config:r,init_from:s,on_disk_payload:a,optimizers_config:i,quantization_config:c,replication_factor:l,shard_number:p,wal_config:h,write_consistency_factor:u}){return o((await this._openApiClient.collections.createCollection({collection_name:t,timeout:e,vectors:n,hnsw_config:r,init_from:s,on_disk_payload:a,optimizers_config:i,quantization_config:c,replication_factor:l,shard_number:p,wal_config:h,write_consistency_factor:u})).data.result).orThrow("Create collection returned empty")}async recreateCollection(t,{timeout:e,vectors:n,hnsw_config:r,init_from:s,on_disk_payload:a,optimizers_config:i,quantization_config:c,replication_factor:l,shard_number:p,wal_config:h,write_consistency_factor:u}){o(await this._openApiClient.collections.deleteCollection({collection_name:t,timeout:e})).get("ok").orThrow("Delete collection returned failed");return o(await this._openApiClient.collections.createCollection({collection_name:t,timeout:e,vectors:n,hnsw_config:r,init_from:s,on_disk_payload:a,optimizers_config:i,quantization_config:c,replication_factor:l,shard_number:p,wal_config:h,write_consistency_factor:u})).orThrow("Create collection returned empty")}async uploadRecords(){return Promise.reject(new u("uploadRecords()"))}async uploadCollection(){return Promise.reject(new u("uploadCollection()"))}async createPayloadIndex(t,{wait:e,ordering:n,field_name:r,field_schema:s}){return o((await this._openApiClient.collections.createFieldIndex({collection_name:t,field_name:r,field_schema:s,wait:e,ordering:n})).data.result).orThrow("Create field index returned empty")}async deletePayloadIndex(t,e,{wait:n=!0,ordering:r}={}){return o((await this._openApiClient.collections.deleteFieldIndex({collection_name:t,field_name:e,wait:n,ordering:r})).data.result).orThrow("Delete field index returned empty")}async listSnapshots(t){return o((await this._openApiClient.snapshots.listSnapshots({collection_name:t})).data.result).orThrow("List snapshots API returned empty")}async createSnapshot(t,e){return o((await this._openApiClient.snapshots.createSnapshot({collection_name:t,...e})).data.result).orNull()}async deleteSnapshot(t,e,n){return o((await this._openApiClient.snapshots.deleteSnapshot({collection_name:t,snapshot_name:e,...n})).data.result).orThrow("Delete snapshot API returned empty")}async listFullSnapshots(){return o((await this._openApiClient.snapshots.listFullSnapshots({})).data.result).orThrow("List full snapshots API returned empty")}async createFullSnapshot(t){return o((await this._openApiClient.snapshots.createFullSnapshot({...t})).data.result).orThrow("Create full snapshot API returned empty")}async deleteFullSnapshot(t,e){return o((await this._openApiClient.snapshots.deleteFullSnapshot({snapshot_name:t,...e})).data.result).orThrow("Delete full snapshot API returned empty")}async recoverSnapshot(t,{location:e,priority:n}){return o((await this._openApiClient.snapshots.recoverFromSnapshot({collection_name:t,location:e,priority:n})).data.result).orThrow("Recover from snapshot API returned empty")}async lockStorage(t){return o((await this._openApiClient.service.postLocks({write:!0,error_message:t})).data.result).orThrow("Lock storage returned empty")}async unlockStorage(){return o((await this._openApiClient.service.postLocks({write:!1})).data.result).orThrow("Post locks returned empty")}async getLocks(){return o((await this._openApiClient.service.getLocks({})).data.result).orThrow("Get locks returned empty")}}export{v as QdrantClient};

dist/cjs/api-client.js

@@ -10,3 +10,3 @@ "use strict";
 const errors_js_1 = require("./errors.js");
-const openapi_typescript_fetch_1 = require("openapi-typescript-fetch");
+const openapi_typescript_fetch_1 = require("@qdrant/openapi-typescript-fetch");
 function createApis(baseUrl, args) {
@@ -13,0 +13,0 @@ const client = createClient(baseUrl, args);

dist/esm/api-client.js

@@ -7,3 +7,3 @@ import { createClusterApi } from './api/cluster-api.js';
 import { QdrantClientTimeoutError, QdrantClientUnexpectedResponseError } from './errors.js';
-import { Fetcher } from 'openapi-typescript-fetch';
+import { Fetcher } from '@qdrant/openapi-typescript-fetch';
 export function createApis(baseUrl, args) {
@@ -10,0 +10,0 @@ const client = createClient(baseUrl, args);

dist/types/api/cluster-api.d.ts

@@ -6,3 +6,3 @@ import { Client } from '../api-client.js';
      */
-    readonly clusterStatus: import("openapi-typescript-fetch").TypedFetch<{
+    readonly clusterStatus: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         responses: {
@@ -90,3 +90,3 @@ 200: {
      */
-    readonly collectionClusterInfo: import("openapi-typescript-fetch").TypedFetch<{
+    readonly collectionClusterInfo: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -150,3 +150,3 @@ path: {
     }>;
-    readonly recoverCurrentPeer: import("openapi-typescript-fetch").TypedFetch<{
+    readonly recoverCurrentPeer: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         responses: {
@@ -189,3 +189,3 @@ 200: {
      */
-    readonly removePeer: import("openapi-typescript-fetch").TypedFetch<{
+    readonly removePeer: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -233,3 +233,3 @@ query: {
     }>;
-    readonly updateCollectionCluster: import("openapi-typescript-fetch").TypedFetch<{
+    readonly updateCollectionCluster: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -236,0 +236,0 @@ query: {

dist/types/api/collections-api.d.ts

@@ -6,3 +6,3 @@ import { Client } from '../api-client.js';
      */
-    readonly collectionClusterInfo: import("openapi-typescript-fetch").TypedFetch<{
+    readonly collectionClusterInfo: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -69,3 +69,3 @@ path: {
      */
-    readonly createCollection: import("openapi-typescript-fetch").TypedFetch<{
+    readonly createCollection: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -197,3 +197,3 @@ query: {
      */
-    readonly createFieldIndex: import("openapi-typescript-fetch").TypedFetch<{
+    readonly createFieldIndex: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -262,3 +262,3 @@ query: {
      */
-    readonly createSnapshot: import("openapi-typescript-fetch").TypedFetch<{
+    readonly createSnapshot: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -321,3 +321,3 @@ query: {
      */
-    readonly deleteCollection: import("openapi-typescript-fetch").TypedFetch<{
+    readonly deleteCollection: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -368,3 +368,3 @@ query: {
      */
-    readonly deleteFieldIndex: import("openapi-typescript-fetch").TypedFetch<{
+    readonly deleteFieldIndex: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -420,3 +420,3 @@ query: {
      */
-    readonly deleteSnapshots: import("openapi-typescript-fetch").TypedFetch<{
+    readonly deleteSnapshots: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -476,3 +476,3 @@ query: {
      */
-    readonly getCollection: import("openapi-typescript-fetch").TypedFetch<{
+    readonly getCollection: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -618,3 +618,3 @@ path: {
      */
-    readonly getCollectionAliases: import("openapi-typescript-fetch").TypedFetch<{
+    readonly getCollectionAliases: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -667,3 +667,3 @@ path: {
      */
-    readonly getCollections: import("openapi-typescript-fetch").TypedFetch<{
+    readonly getCollections: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         responses: {
@@ -710,3 +710,3 @@ 200: {
      */
-    readonly getCollectionsAliases: import("openapi-typescript-fetch").TypedFetch<{
+    readonly getCollectionsAliases: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         responses: {
@@ -755,3 +755,3 @@ 200: {
      */
-    readonly getSnapshot: import("openapi-typescript-fetch").TypedFetch<{
+    readonly getSnapshot: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -796,3 +796,3 @@ path: {
      */
-    readonly listSnapshots: import("openapi-typescript-fetch").TypedFetch<{
+    readonly listSnapshots: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -844,3 +844,3 @@ path: {
      */
-    readonly recoverFromSnapshot: import("openapi-typescript-fetch").TypedFetch<{
+    readonly recoverFromSnapshot: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -904,3 +904,3 @@ query: {
     }>;
-    readonly updateAliases: import("openapi-typescript-fetch").TypedFetch<{
+    readonly updateAliases: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -969,3 +969,3 @@ query: {
      */
-    readonly updateCollection: import("openapi-typescript-fetch").TypedFetch<{
+    readonly updateCollection: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -1033,3 +1033,3 @@ query: {
     }>;
-    readonly updateCollectionCluster: import("openapi-typescript-fetch").TypedFetch<{
+    readonly updateCollectionCluster: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -1036,0 +1036,0 @@ query: {

dist/types/api/service-api.d.ts

@@ -6,3 +6,3 @@ import { Client } from '../api-client.js';
      */
-    readonly getLocks: import("openapi-typescript-fetch").TypedFetch<{
+    readonly getLocks: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         responses: {
@@ -48,3 +48,3 @@ 200: {
      */
-    readonly metrics: import("openapi-typescript-fetch").TypedFetch<{
+    readonly metrics: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -67,3 +67,3 @@ query: {
      */
-    readonly postLocks: import("openapi-typescript-fetch").TypedFetch<{
+    readonly postLocks: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         requestBody?: {
@@ -117,3 +117,3 @@ content: {
      */
-    readonly telemetry: import("openapi-typescript-fetch").TypedFetch<{
+    readonly telemetry: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -120,0 +120,0 @@ query: {

dist/types/api/snapshots-api.d.ts

@@ -6,3 +6,3 @@ import { Client } from '../api-client.js';
      */
-    readonly createFullSnapshot: import("openapi-typescript-fetch").TypedFetch<{
+    readonly createFullSnapshot: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -62,3 +62,3 @@ query: {
      */
-    readonly createSnapshot: import("openapi-typescript-fetch").TypedFetch<{
+    readonly createSnapshot: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -121,3 +121,3 @@ query: {
      */
-    readonly deleteFullSnapshot: import("openapi-typescript-fetch").TypedFetch<{
+    readonly deleteFullSnapshot: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -176,3 +176,3 @@ query: {
      */
-    readonly deleteSnapshot: import("openapi-typescript-fetch").TypedFetch<{
+    readonly deleteSnapshot: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -233,3 +233,3 @@ query: {
      */
-    readonly getFullSnapshot: import("openapi-typescript-fetch").TypedFetch<{
+    readonly getFullSnapshot: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -274,3 +274,3 @@ path: {
      */
-    readonly getSnapshot: import("openapi-typescript-fetch").TypedFetch<{
+    readonly getSnapshot: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -315,3 +315,3 @@ path: {
      */
-    readonly listFullSnapshots: import("openapi-typescript-fetch").TypedFetch<{
+    readonly listFullSnapshots: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         responses: {
@@ -358,3 +358,3 @@ 200: {
      */
-    readonly listSnapshots: import("openapi-typescript-fetch").TypedFetch<{
+    readonly listSnapshots: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -406,3 +406,3 @@ path: {
      */
-    readonly recoverFromSnapshot: import("openapi-typescript-fetch").TypedFetch<{
+    readonly recoverFromSnapshot: import("@qdrant/openapi-typescript-fetch").TypedFetch<{
         parameters: {
@@ -409,0 +409,0 @@ query: {

dist/types/errors.d.ts

@@ -1,2 +0,2 @@
-import { ApiResponse } from 'openapi-typescript-fetch';
+import { ApiResponse } from '@qdrant/openapi-typescript-fetch';
 declare class CustomError extends Error {
@@ -3,0 +3,0 @@ constructor(message: string);

dist/types/qdrant-client.d.ts

@@ -784,3 +784,3 @@ import { OpenApiClient } from './api-client.js';
         timeout?: number;
-    } & SchemaFor<'CreateCollection'>): Promise<import("openapi-typescript-fetch").ApiResponse<{
+    } & SchemaFor<'CreateCollection'>): Promise<import("@qdrant/openapi-typescript-fetch").ApiResponse<{
         time?: number | undefined;
@@ -787,0 +787,0 @@ status?: "ok" | undefined;

package.json

 {
   "name": "@qdrant/js-client-rest",
-  "version": "1.1.5",
+  "version": "1.1.6",
   "engines": {
@@ -47,4 +47,4 @@ "node": ">=18.0.0",
   "dependencies": {
-    "@sevinf/maybe": "0.5.0",
-    "openapi-typescript-fetch": "Rendez/openapi-typescript-fetch#c114c381602b9b3891f0ec45dbc5409816743dad"
+    "@sevinf/maybe": "^0.5.0",
+    "@qdrant/openapi-typescript-fetch": "^1.2.0"
   },
@@ -51,0 +51,0 @@ "devDependencies": {

Fixed alerts

GitHub dependency

Supply chain risk

Contains a dependency which resolves to a GitHub URL. Dependencies fetched from GitHub specifiers are not immutable can be used to inject untrusted code or reduce the likelihood of a reproducible install.

Found 1 instance in 1 package

Manifest confusion

Supply chain risk

This package has inconsistent metadata. This could be malicious or caused by an error when publishing the package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

1033839

increased by0.17%

Lines of code

21969

increased by0.1%

Number of high supply chain risk alerts

0

decreased by-100%

Number of medium supply chain risk alerts

14

decreased by-6.67%

Dependency changes

• + Added@qdrant/openapi-typescript-fetch@^1.2.0

• + Added@qdrant/openapi-typescript-fetch@1.2.6(transitive)

• - Removedopenapi-typescript-fetch@Rendez/openapi-typescript-fetch#c114c381602b9b3891f0ec45dbc5409816743dad

• Updated@sevinf/maybe@^0.5.0