feat: add listIds() to vector drivers

src/db/cloudflare.ts

@@ -129,6 +129,10 @@ export async function cloudflare(config: CloudflareConfig): Promise<SearchProvid
       return { count: ids.length }
     },
 
+    // listIds() is not implemented — Cloudflare Vectorize Workers binding
+    // does not expose a list/range method (only available via REST API).
+    // This means remove() with chunking (via createRetriv) is not supported.
+
     async clear() {
       throw new Error('[cloudflare] clear() is not supported - use wrangler CLI instead')
     },

src/db/libsql.ts

@@ -150,6 +150,11 @@ export async function libsql(config: LibsqlConfig): Promise<SearchProvider> {
       return { count: ids.length }
     },
 
+    async listIds() {
+      const result = await client.execute('SELECT id FROM vectors')
+      return (result.rows || []).map((row: any) => row.id as string)
+    },
+
     async clear() {
       await client.execute('DELETE FROM vectors')
     },

src/db/pgvector.ts

@@ -162,6 +162,11 @@ export async function pgvector(config: PgvectorConfig): Promise<SearchProvider>
       return { count: ids.length }
     },
 
+    async listIds() {
+      const result = await pool.query(`SELECT id FROM ${table}`)
+      return result.rows.map((row: any) => row.id as string)
+    },
+
     async clear() {
       await pool.query(`DELETE FROM ${table}`)
     },

src/db/sqlite-vec.ts

@@ -206,6 +206,11 @@ export async function sqliteVec(config: SqliteVecConfig): Promise<SearchProvider
       }
     },
 
+    async listIds() {
+      const rows = db.prepare('SELECT id FROM vector_metadata').all() as { id: string }[]
+      return rows.map(r => r.id)
+    },
+
     async clear() {
       db.exec('DELETE FROM vectors')
       db.exec('DELETE FROM vector_metadata')

src/db/upstash.ts

@@ -110,6 +110,17 @@ export async function upstash(config: UpstashConfig): Promise<SearchProvider> {
       return { count: ids.length }
     },
 
+    async listIds() {
+      const ids: string[] = []
+      let cursor = '0'
+      do {
+        const page = await index.range({ cursor, limit: 1000, includeMetadata: false, includeVectors: false }, { namespace: ns })
+        for (const v of page.vectors) ids.push(v.id as string)
+        cursor = page.nextCursor
+      } while (cursor !== '0')
+      return ids
+    },
+
     async clear() {
       await index.reset({ namespace: ns })
     },

src/retriv.ts

@@ -224,7 +224,7 @@ export async function createRetriv(options: RetrivOptions): Promise<SearchProvid
       if (chunker) {
         const lister = drivers.find(d => d.listIds)
         if (!lister)
-          throw new Error('remove() with chunking requires a driver that implements listIds()')
+          throw new Error('remove() with chunking requires a driver that implements listIds() — cloudflare does not support this')
         const allIds = await lister.listIds!()
         const idSet = new Set(ids)
         removeIds = allIds.filter((id) => {