24797900078

Committed 22 Apr 2026 07:19PM UTC coverage: 32.333% (-37.6%) from 69.944%

Build # 24797900078

Build Type

Pull #1041

github

Committed by

web-flow

Commit Message

Merge f50d51401 into 8e937109d

Pull Request Pull Request #1041: feat: add sb-request-id logging

Coverage Stats

1525 of 5395 branches covered (28.27%)

Branch coverage included in aggregate %.

47 of 57 new or added lines in 22 files covered. (82.46%)

3864 existing lines in 165 files now uncovered.

3312 of 9565 relevant lines covered (34.63%)

10.26 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 { StorageKnexDB } 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)

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

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

      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 { StorageKnexDB } from '@storage/database'
4	import { PassThroughLocation, TenantLocation } from '@storage/locator'
5	import { Storage } from '@storage/storage'
6	import fastifyPlugin from 'fastify-plugin'
7	import { getConfig } from '../../config'
8
9	declare module 'fastify' {
10	interface FastifyRequest {
11	storage: Storage
12	backend: StorageBackendAdapter
13	cdnCache: CdnCacheManager
14	}
15	}
16
17	const { storageBackendType, storageS3Bucket } = getConfig()	3✔
18
19	const storageBackend = createStorageBackend(storageBackendType)	3✔
20
21	export const storage = fastifyPlugin(	3✔
22	async function storagePlugin(fastify) {
23	fastify.decorateRequest('storage')	4✔
24	fastify.addHook('preHandler', async (request) => {	4✔
UNCOV 25	const database = new StorageKnexDB(request.db, {	×
26	tenantId: request.tenantId,
27	host: request.headers['x-forwarded-host'] as string,
28	reqId: request.id,
29	sbReqId: request.sbReqId,
30	latestMigration: request.latestMigration,
31	})
32
UNCOV 33	const location = request.isIcebergBucket	×
34	? new PassThroughLocation(request.internalIcebergBucketName!)
35	: new TenantLocation(storageS3Bucket)
36
UNCOV 37	request.backend = storageBackend	×
UNCOV 38	request.storage = new Storage(storageBackend, database, location)	×
UNCOV 39	request.cdnCache = new CdnCacheManager(request.storage)	×
40	})
41
42	fastify.addHook('onClose', async () => {	4✔
43	storageBackend.close()	4✔
44	})
45	},
46	{ name: 'storage-init' }
47	)

supabase / storage / 24797900078

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