25794757887

Committed 13 May 2026 10:57AM UTC coverage: 39.675% (-35.2%) from 74.849%

Build # 25794757887

Build Type

Pull #1105

github

Committed by

web-flow

Commit Message

Merge d11e8cc92 into 7e995c511

Pull Request Pull Request #1105: fix: drop head after complete in multipart uploads

Coverage Stats

2119 of 5915 branches covered (35.82%)

Branch coverage included in aggregate %.

12 of 15 new or added lines in 1 file covered. (80.0%)

3731 existing lines in 165 files now uncovered.

4252 of 10143 relevant lines covered (41.92%)

35.36 hits per line

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

10.34

/src/http/plugins/vector.ts

import { getTenantConfig, multitenantKnex } from '@internal/database'
import { ERRORS } from '@internal/errors'
import { KnexShardStoreFactory, ShardCatalog, SingleShard } from '@internal/sharding'
import {
  createS3VectorClient,
  KnexVectorMetadataDB,
  S3Vector,
  VectorStoreManager,
} from '@storage/protocols/vector'
import { FastifyInstance } from 'fastify'
import fastifyPlugin from 'fastify-plugin'
import { getConfig } from '../../config'

declare module 'fastify' {
  interface FastifyRequest {
    s3Vector: VectorStoreManager
  }
}

const s3VectorClient = createS3VectorClient()
const s3VectorAdapter = new S3Vector(s3VectorClient)

export const s3vector = fastifyPlugin(async function (fastify: FastifyInstance) {
  fastify.addHook('preHandler', async (req) => {
    const { isMultitenant, vectorS3Buckets, vectorMaxBucketsCount, vectorMaxIndexesCount } =
      getConfig()

    if (!vectorS3Buckets || vectorS3Buckets.length === 0) {
      throw ERRORS.FeatureNotEnabled('vector', 'Vector service not configured')
    }

    let maxBucketCount = vectorMaxBucketsCount
    let maxIndexCount = vectorMaxIndexesCount

    if (isMultitenant) {
      const { features } = await getTenantConfig(req.tenantId)
      maxBucketCount = features?.vectorBuckets?.maxBuckets || vectorMaxBucketsCount
      maxIndexCount = features?.vectorBuckets?.maxIndexes || vectorMaxIndexesCount
    }

    const db = req.db.pool.acquire()
    const store = new KnexVectorMetadataDB(db)
    const shard = isMultitenant
      ? new ShardCatalog(new KnexShardStoreFactory(multitenantKnex))
      : new SingleShard({
          shardKey: vectorS3Buckets[0],
          capacity: 10000,
        })

    req.s3Vector = new VectorStoreManager(s3VectorAdapter, store, shard, {
      tenantId: req.tenantId,
      maxBucketCount,
      maxIndexCount,
    })
  })
})

1	import { getTenantConfig, multitenantKnex } from '@internal/database'
2	import { ERRORS } from '@internal/errors'
3	import { KnexShardStoreFactory, ShardCatalog, SingleShard } from '@internal/sharding'
4	import {
5	createS3VectorClient,
6	KnexVectorMetadataDB,
7	S3Vector,
8	VectorStoreManager,
9	} from '@storage/protocols/vector'
10	import { FastifyInstance } from 'fastify'
11	import fastifyPlugin from 'fastify-plugin'
12	import { getConfig } from '../../config'
13
14	declare module 'fastify' {
15	interface FastifyRequest {
16	s3Vector: VectorStoreManager
17	}
18	}
19
20	const s3VectorClient = createS3VectorClient()	3✔
21	const s3VectorAdapter = new S3Vector(s3VectorClient)	3✔
22
23	export const s3vector = fastifyPlugin(async function (fastify: FastifyInstance) {	3✔
UNCOV 24	fastify.addHook('preHandler', async (req) => {	×
UNCOV 25	const { isMultitenant, vectorS3Buckets, vectorMaxBucketsCount, vectorMaxIndexesCount } =	×
26	getConfig()
27
UNCOV 28	if (!vectorS3Buckets \|\| vectorS3Buckets.length === 0) {	×
UNCOV 29	throw ERRORS.FeatureNotEnabled('vector', 'Vector service not configured')	×
30	}
31
UNCOV 32	let maxBucketCount = vectorMaxBucketsCount	×
UNCOV 33	let maxIndexCount = vectorMaxIndexesCount	×
34
UNCOV 35	if (isMultitenant) {	×
36	const { features } = await getTenantConfig(req.tenantId)	×
37	maxBucketCount = features?.vectorBuckets?.maxBuckets \|\| vectorMaxBucketsCount	×
38	maxIndexCount = features?.vectorBuckets?.maxIndexes \|\| vectorMaxIndexesCount	×
39	}
40
UNCOV 41	const db = req.db.pool.acquire()	×
UNCOV 42	const store = new KnexVectorMetadataDB(db)	×
UNCOV 43	const shard = isMultitenant	×
44	? new ShardCatalog(new KnexShardStoreFactory(multitenantKnex))
45	: new SingleShard({
46	shardKey: vectorS3Buckets[0],
47	capacity: 10000,
48	})
49
UNCOV 50	req.s3Vector = new VectorStoreManager(s3VectorAdapter, store, shard, {	×
51	tenantId: req.tenantId,
52	maxBucketCount,
53	maxIndexCount,
54	})
55	})
56	})

supabase / storage / 25794757887

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