30379780849

Committed 28 Jul 2026 04:45PM UTC coverage: 53.191% (-27.1%) from 80.307%

Build # 30379780849

Build Type

Pull #1269

github

Committed by

web-flow

Commit Message

Merge 2846843fa into 20927735c

Pull Request Pull Request #1269: fix: update pool reliably upon config changes

Coverage Stats

3671 of 7490 branches covered (49.01%)

Branch coverage included in aggregate %.

42 of 47 new or added lines in 4 files covered. (89.36%)

3545 existing lines in 156 files now uncovered.

7065 of 12694 relevant lines covered (55.66%)

71.05 hits per line

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

43.75

/src/http/routes/object/createObject.ts

import fastifyMultipart from '@fastify/multipart'
import { FastifyInstance, RequestGenericInterface } from 'fastify'
import { FromSchema } from 'json-schema-to-ts'
import { createDefaultSchema } from '../../routes-helper'
import { ROUTE_OPERATIONS } from '../operations'

const createObjectParamsSchema = {
  type: 'object',
  properties: {
    bucketName: { type: 'string', examples: ['avatars'] },
    '*': { type: 'string', examples: ['folder/cat.png'] },
  },
  required: ['bucketName', '*'],
} as const
const successResponseSchema = {
  type: 'object',
  properties: {
    Id: {
      type: 'string',
    },
    Key: {
      type: 'string',
      examples: ['avatars/folder/cat.png'],
    },
  },
  required: ['Key'],
}
interface createObjectRequestInterface extends RequestGenericInterface {
  Params: FromSchema<typeof createObjectParamsSchema>
  Headers: {
    authorization: string
    'content-type': string
    'cache-control'?: string
    'x-upsert'?: string
    'x-robots-tag'?: string
  }
}

export default async function routes(fastify: FastifyInstance) {
  const summary = 'Upload a new object'

  const schema = createDefaultSchema(successResponseSchema, {
    params: createObjectParamsSchema,
    summary,
    tags: ['object'],
  })

  fastify.register(fastifyMultipart, {
    limits: {
      fields: 10,
      files: 1,
    },
    throwFileSizeLimit: false,
  })

  fastify.addContentTypeParser(
    ['application/json', 'text/plain'],
    function (request, payload, done) {
      done(null)
    }
  )

  fastify.post<createObjectRequestInterface>(
    '/:bucketName/*',
    {
      schema,
      config: {
        operation: ROUTE_OPERATIONS.CREATE_OBJECT,
      },
    },
    async (request, response) => {
      const { bucketName } = request.params
      const objectName = request.params['*']

      const isUpsert = request.headers['x-upsert'] === 'true'
      const owner = request.owner

      const { objectMetadata, path, id } = await request.storage
        .from(bucketName)
        .uploadFromRequest(request, {
          objectName,
          signal: request.signals.body.signal,
          owner,
          isUpsert,
        })

      return response.status(objectMetadata?.httpStatusCode ?? 200).send({
        Id: id,
        Key: path,
      })
    }
  )
}

1	import fastifyMultipart from '@fastify/multipart'
2	import { FastifyInstance, RequestGenericInterface } from 'fastify'
3	import { FromSchema } from 'json-schema-to-ts'
4	import { createDefaultSchema } from '../../routes-helper'
5	import { ROUTE_OPERATIONS } from '../operations'
6
7	const createObjectParamsSchema = {	8✔
8	type: 'object',
9	properties: {
10	bucketName: { type: 'string', examples: ['avatars'] },
11	'*': { type: 'string', examples: ['folder/cat.png'] },
12	},
13	required: ['bucketName', '*'],
14	} as const
15	const successResponseSchema = {	8✔
16	type: 'object',
17	properties: {
18	Id: {
19	type: 'string',
20	},
21	Key: {
22	type: 'string',
23	examples: ['avatars/folder/cat.png'],
24	},
25	},
26	required: ['Key'],
27	}
28	interface createObjectRequestInterface extends RequestGenericInterface {
29	Params: FromSchema<typeof createObjectParamsSchema>
30	Headers: {
31	authorization: string
32	'content-type': string
33	'cache-control'?: string
34	'x-upsert'?: string
35	'x-robots-tag'?: string
36	}
37	}
38
39	export default async function routes(fastify: FastifyInstance) {
40	const summary = 'Upload a new object'	2✔
41
42	const schema = createDefaultSchema(successResponseSchema, {	2✔
43	params: createObjectParamsSchema,
44	summary,
45	tags: ['object'],
46	})
47
48	fastify.register(fastifyMultipart, {	2✔
49	limits: {
50	fields: 10,
51	files: 1,
52	},
53	throwFileSizeLimit: false,
54	})
55
56	fastify.addContentTypeParser(	2✔
57	['application/json', 'text/plain'],
58	function (request, payload, done) {
UNCOV 59	done(null)	×
60	}
61	)
62
63	fastify.post<createObjectRequestInterface>(	2✔
64	'/:bucketName/*',
65	{
66	schema,
67	config: {
68	operation: ROUTE_OPERATIONS.CREATE_OBJECT,
69	},
70	},
71	async (request, response) => {
UNCOV 72	const { bucketName } = request.params	×
UNCOV 73	const objectName = request.params['*']	×
74
UNCOV 75	const isUpsert = request.headers['x-upsert'] === 'true'	×
UNCOV 76	const owner = request.owner	×
77
UNCOV 78	const { objectMetadata, path, id } = await request.storage	×
79	.from(bucketName)
80	.uploadFromRequest(request, {
81	objectName,
82	signal: request.signals.body.signal,
83	owner,
84	isUpsert,
85	})
86
UNCOV 87	return response.status(objectMetadata?.httpStatusCode ?? 200).send({	×
88	Id: id,
89	Key: path,
90	})
91	}
92	)
93	}

supabase / storage / 30379780849

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