vectors - lance path from vector bucket

Signed-off-by: Amit Prinz Setter <alphaprinz@gmail.com>

Author: alphaprinz

src/endpoint/vector/ops/vector_bucket_create.js

@@ -8,10 +8,21 @@ const dbg = require('../../../util/debug_module')(__filename);
  */
 async function post_vector_bucket(req, res) {
 
-    dbg.log0("post_vector_bucket body =", req.body);
+    dbg.log0("post_vector_bucket body =", req.body, ", headers =", req.headers);
+
+    const ns_name = req.headers['x-noobaa-custom-ns'];
+    const subpath = req.headers['x-noobaa-custom-subpath'];
+
+    const namespace_resource = {
+        resource: ns_name,
+        path: subpath //not to be confused with nsr path
+    };
 
     const vector_bucket_name = req.body.vectorBucketName;
-    await req.vector_sdk.create_vector_bucket({ vector_bucket_name });
+    await req.vector_sdk.create_vector_bucket({
+        vector_bucket_name,
+        namespace_resource,
+    });
 }
 
 exports.handler = post_vector_bucket;

src/endpoint/vector/vector_rest.js

@@ -188,8 +188,11 @@ async function handle_request(req, res) {
 
     //init vector_sdk here to avoid creating this object for s3 reqs that don't need it
     //TODO - find a better place to get BS?
-    req.vector_sdk = new VectorSDK({bucketspace: req.object_sdk._get_bucketspace()});
-    await req.vector_sdk.load_vector_bucket_and_index(req, op);
+    req.vector_sdk = new VectorSDK({
+        bucketspace: req.object_sdk._get_bucketspace(),
+        req
+    });
+    await req.vector_sdk.load_vector_bucket_and_index(op);
     const reply = await op.handler.handler(req, res);
     dbg.log0("VECTOR reply =", reply);
 

src/sdk/vector_sdk.js

@@ -1,20 +1,13 @@
 /* Copyright (C) 2026 NooBaa */
 'use strict';
 
-const _ = require('lodash');
-
 const vector_utils = require("../util/vectors_util");
 
 class VectorSDK {
 
-
-    /**
-     * @param {{
-     *      bucketspace?: nb.BucketSpace;
-     * }} args
-     */
-    constructor({ bucketspace }) {
+    constructor({ bucketspace, req }) {
         this.bucketspace = bucketspace;
+        this.req = req;
     }
 
     /**
@@ -25,15 +18,15 @@ class VectorSDK {
     }
 
     //load the vector bucket and index (if handling the op requries it)
-    async load_vector_bucket_and_index(req, op) {
+    async load_vector_bucket_and_index(op) {
         if (!op.load_vector_bucket) return;
         const params = {
-            vector_bucket_name: req.body.vectorBucketName
+            vector_bucket_name: this.req.body.vectorBucketName
         };
-        req.vector_bucket = await this.get_vector_bucket(params);
+        this.req.vector_bucket = await this.get_vector_bucket(params);
         if (!op.load_vector_index) return;
-        params.vector_index_name = req.body.indexName;
-        req.vector_index = await this.get_vector_index(params);
+        params.vector_index_name = this.req.body.indexName;
+        this.req.vector_index = await this.get_vector_index(params);
     }
 
     //////////////////////////
@@ -43,7 +36,6 @@ class VectorSDK {
     async create_vector_bucket(params) {
         const bs = this._get_bucketspace();
         await bs.create_vector_bucket(params);
-        await vector_utils.create_vector_bucket(params);
     }
 
     async get_vector_bucket(params) {
@@ -54,7 +46,7 @@ class VectorSDK {
     async delete_vector_bucket(params) {
         const bs = this._get_bucketspace();
         await bs.delete_vector_bucket(params);
-        await vector_utils.delete_vector_bucket(params);
+        vector_utils.delete_vector_bucket(this.req.vector_bucket);
     }
 
     async list_vector_buckets(params) {
@@ -70,7 +62,7 @@ class VectorSDK {
     async create_vector_index(params) {
         const bs = this._get_bucketspace();
         await bs.create_vector_index(params);
-        await vector_utils.create_vector_index(params);
+        await vector_utils.create_vector_index(this.req.vector_bucket, this.req.vector_index, params);
     }
 
     async get_vector_index(params) {
@@ -86,28 +78,27 @@ class VectorSDK {
     async delete_vector_index(params) {
         const bs = this._get_bucketspace();
         await bs.delete_vector_index(params);
-        await vector_utils.delete_vector_index(params);
+        await vector_utils.delete_vector_index(this.req.vector_bucket, this.req.vector_index);
     }
 
     //////////////////////////
     // VECTORS              //
     //////////////////////////
 
     async put_vectors(params) {
-        params.vector_index = await this.get_vector_index(_.pick(params, 'vector_bucket_name', 'vector_index_name'));
-        return await vector_utils.put_vectors(params);
+        return await vector_utils.put_vectors(this.req.vector_bucket, this.req.vector_index, params.vectors);
     }
 
     async list_vectors(params) {
-        return await vector_utils.list_vectors(params);
+        return await vector_utils.list_vectors(this.req.vector_bucket, this.req.vector_index, params);
     }
 
     async delete_vectors(params) {
-        await vector_utils.delete_vectors(params);
+        await vector_utils.delete_vectors(this.req.vector_bucket, this.req.vector_index, params.keys);
     }
 
     async query_vectors(params) {
-        return await vector_utils.query_vectors(params);
+        return await vector_utils.query_vectors(this.req.vector_bucket, this.req.vector_index, params);
     }
 
     //////////////////////////////

src/server/system_services/bucket_server.js

@@ -2361,14 +2361,16 @@ function find_vector_index(req, vector_bucket_name, vector_index_name) {
 }
 
 function get_vector_bucket_info(vector_bucket) {
+    const nsr = pool_server.get_namespace_resource_info(vector_bucket.namespace_resource.resource);
+
     const info = {
         name: vector_bucket.name,
         owner_account: get_owner_account_info(vector_bucket.owner_account),
         creation_time: vector_bucket.creation_time,
         vector_db_type: vector_bucket.vector_db_type,
-        namespace_resource: vector_bucket.namespace_resource && {
+        namespace_resource: {
             ...vector_bucket.namespace_resource,
-            resource: pool_server.get_namespace_resource_info(vector_bucket.namespace_resource.resource).name
+            resource: nsr.name,
         },
         bucket_claim: vector_bucket.bucket_claim,
         tags: vector_bucket.tags,