25639316851

Committed 10 May 2026 08:44PM UTC coverage: 74.164% (-0.09%) from 74.255%

Build # 25639316851

Build Type

Pull #1094

github

Committed by

web-flow

Commit Message

Merge db2c619cb into a4d3fb5c3

Pull Request Pull Request #1094: feat: embedded vector store

Coverage Stats

4138 of 6145 branches covered (67.34%)

Branch coverage included in aggregate %.

230 of 301 new or added lines in 7 files covered. (76.41%)

2 existing lines in 1 file now uncovered.

8257 of 10568 relevant lines covered (78.13%)

399.25 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

39.13

/src/storage/protocols/vector/adapter/embedded/error-handler.ts

import { ERRORS } from '@internal/errors'

export type ZVecError = Error & {
  code:
    | 'ZVEC_NOT_FOUND'
    | 'ZVEC_ALREADY_EXISTS'
    | 'ZVEC_INVALID_ARGUMENT'
    | 'ZVEC_PERMISSION_DENIED'
    | 'ZVEC_FAILED_PRECONDITION'
    | 'ZVEC_RESOURCE_EXHAUSTED'
    | 'ZVEC_UNAVAILABLE'
    | 'ZVEC_INTERNAL_ERROR'
    | 'ZVEC_NOT_SUPPORTED'
    | 'ZVEC_UNKNOWN'
    | 'ZVEC_INVALID_STATUS_CODE'
}

function hasZVecCode(error: unknown): error is ZVecError {
  return (
    error instanceof Error &&
    typeof (error as ZVecError).code === 'string' &&
    (error as ZVecError).code.startsWith('ZVEC_')
  )
}

export async function handleZVecError<T>(
  fn: () => Promise<T> | T,
  resource: { type: string; name: string }
): Promise<T> {
  try {
    return await fn()
  } catch (e) {
    if (!hasZVecCode(e)) {
      throw e
    }

    switch (e.code) {
      case 'ZVEC_NOT_FOUND':
        throw ERRORS.S3VectorNotFoundException(resource.type, resource.name)
      case 'ZVEC_ALREADY_EXISTS':
        throw ERRORS.S3VectorConflictException(resource.type, resource.name)
      case 'ZVEC_INVALID_ARGUMENT':
        throw ERRORS.InvalidParameter(`${resource.type}:${resource.name}`, { message: e.message })
      case 'ZVEC_PERMISSION_DENIED':
        throw ERRORS.AccessDenied(e.message, e)
      case 'ZVEC_NOT_SUPPORTED':
        throw ERRORS.S3VectorEmbeddedNotSupported(`${resource.type}:${resource.name}`)
      default:
        throw e
    }
  }
}

1	import { ERRORS } from '@internal/errors'
2
3	export type ZVecError = Error & {
4	code:
5	\| 'ZVEC_NOT_FOUND'
6	\| 'ZVEC_ALREADY_EXISTS'
7	\| 'ZVEC_INVALID_ARGUMENT'
8	\| 'ZVEC_PERMISSION_DENIED'
9	\| 'ZVEC_FAILED_PRECONDITION'
10	\| 'ZVEC_RESOURCE_EXHAUSTED'
11	\| 'ZVEC_UNAVAILABLE'
12	\| 'ZVEC_INTERNAL_ERROR'
13	\| 'ZVEC_NOT_SUPPORTED'
14	\| 'ZVEC_UNKNOWN'
15	\| 'ZVEC_INVALID_STATUS_CODE'
16	}
17
18	function hasZVecCode(error: unknown): error is ZVecError {
19	return (	1✔
20	error instanceof Error &&	3✔
21	typeof (error as ZVecError).code === 'string' &&
22	(error as ZVecError).code.startsWith('ZVEC_')
23	)
24	}
25
26	export async function handleZVecError<T>(
27	fn: () => Promise<T> \| T,
28	resource: { type: string; name: string }
29	): Promise<T> {
30	try {	11✔
31	return await fn()	11✔
32	} catch (e) {
33	if (!hasZVecCode(e)) {	1!
34	throw e	1✔
35	}
36
NEW 37	switch (e.code) {	×
38	case 'ZVEC_NOT_FOUND':
NEW 39	throw ERRORS.S3VectorNotFoundException(resource.type, resource.name)	×
40	case 'ZVEC_ALREADY_EXISTS':
NEW 41	throw ERRORS.S3VectorConflictException(resource.type, resource.name)	×
42	case 'ZVEC_INVALID_ARGUMENT':
NEW 43	throw ERRORS.InvalidParameter(`${resource.type}:${resource.name}`, { message: e.message })	×
44	case 'ZVEC_PERMISSION_DENIED':
NEW 45	throw ERRORS.AccessDenied(e.message, e)	×
46	case 'ZVEC_NOT_SUPPORTED':
NEW 47	throw ERRORS.S3VectorEmbeddedNotSupported(`${resource.type}:${resource.name}`)	×
48	default:
NEW 49	throw e	×
50	}
51	}
52	}

supabase / storage / 25639316851

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous