28793654629

Committed 06 Jul 2026 01:05PM UTC coverage: 48.793% (-30.2%) from 79.041%

Build # 28793654629

Build Type

Pull #1206

github

Committed by

web-flow

Commit Message

Merge 056d0b5f9 into d54b900bf

Pull Request Pull Request #1206: fix: leak of request into pools

Coverage Stats

3210 of 7101 branches covered (45.2%)

Branch coverage included in aggregate %.

2 of 2 new or added lines in 2 files covered. (100.0%)

3858 existing lines in 164 files now uncovered.

6208 of 12201 relevant lines covered (50.88%)

63.5 hits per line

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

50.0

/src/http/plugins/storage.ts

import { createStorageBackend, StorageBackendAdapter } from '@storage/backend'
import { CdnCacheManager } from '@storage/cdn/cdn-cache-manager'
import type { Database } from '@storage/database'
import { StoragePgDB } from '@storage/database'
import { PassThroughLocation, TenantLocation } from '@storage/locator'
import { Storage } from '@storage/storage'
import fastifyPlugin from 'fastify-plugin'
import { getConfig } from '../../config'

declare module 'fastify' {
  interface FastifyRequest {
    storage: Storage
    backend: StorageBackendAdapter
    cdnCache: CdnCacheManager
  }
}

const { storageBackendType, storageS3Bucket } = getConfig()

const storageBackend = createStorageBackend(storageBackendType)

// TenantLocation is immutable so singleton not to allocate per request.
const tenantLocation = new TenantLocation(storageS3Bucket)

export const storage = fastifyPlugin(
  async function storagePlugin(fastify) {
    fastify.decorateRequest('storage')
    fastify.addHook('preHandler', async (request) => {
      const databaseOptions = {
        tenantId: request.tenantId,
        host: request.headers['x-forwarded-host'] as string,
        reqId: request.id,
        sbReqId: request.sbReqId,
        latestMigration: request.latestMigration,
      }

      const database: Database = new StoragePgDB(request.db, databaseOptions)

      const location = request.isIcebergBucket
        ? new PassThroughLocation(request.internalIcebergBucketName!)
        : tenantLocation

      request.backend = storageBackend
      request.storage = new Storage(storageBackend, database, location)
      request.cdnCache = new CdnCacheManager(request.storage)
    })

    fastify.addHook('onClose', async () => {
      storageBackend.close()
    })
  },
  { name: 'storage-init' }
)

1	import { createStorageBackend, StorageBackendAdapter } from '@storage/backend'
2	import { CdnCacheManager } from '@storage/cdn/cdn-cache-manager'
3	import type { Database } from '@storage/database'
4	import { StoragePgDB } from '@storage/database'
5	import { PassThroughLocation, TenantLocation } from '@storage/locator'
6	import { Storage } from '@storage/storage'
7	import fastifyPlugin from 'fastify-plugin'
8	import { getConfig } from '../../config'
9
10	declare module 'fastify' {
11	interface FastifyRequest {
12	storage: Storage
13	backend: StorageBackendAdapter
14	cdnCache: CdnCacheManager
15	}
16	}
17
18	const { storageBackendType, storageS3Bucket } = getConfig()	3✔
19
20	const storageBackend = createStorageBackend(storageBackendType)	3✔
21
22	// TenantLocation is immutable so singleton not to allocate per request.
23	const tenantLocation = new TenantLocation(storageS3Bucket)	3✔
24
25	export const storage = fastifyPlugin(	3✔
26	async function storagePlugin(fastify) {
27	fastify.decorateRequest('storage')	4✔
28	fastify.addHook('preHandler', async (request) => {	4✔
UNCOV 29	const databaseOptions = {	×
30	tenantId: request.tenantId,
31	host: request.headers['x-forwarded-host'] as string,
32	reqId: request.id,
33	sbReqId: request.sbReqId,
34	latestMigration: request.latestMigration,
35	}
36
UNCOV 37	const database: Database = new StoragePgDB(request.db, databaseOptions)	×
38
UNCOV 39	const location = request.isIcebergBucket	×
40	? new PassThroughLocation(request.internalIcebergBucketName!)
41	: tenantLocation
42
UNCOV 43	request.backend = storageBackend	×
UNCOV 44	request.storage = new Storage(storageBackend, database, location)	×
UNCOV 45	request.cdnCache = new CdnCacheManager(request.storage)	×
46	})
47
48	fastify.addHook('onClose', async () => {	4✔
49	storageBackend.close()	4✔
50	})
51	},
52	{ name: 'storage-init' }
53	)

supabase / storage / 28793654629

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