27760253447

Committed 18 Jun 2026 12:43PM UTC coverage: 60.005% (-18.2%) from 78.232%

Build # 27760253447

Build Type

push

github

Committed by

web-flow

Commit Message

fix: limit for delete objects and sign urls (#1160)

Signed-off-by: ferhat elmas <elmas.ferhat@gmail.com>

Coverage Stats

3351 of 6375 branches covered (52.56%)

Branch coverage included in aggregate %.

25 of 31 new or added lines in 4 files covered. (80.65%)

2041 existing lines in 86 files now uncovered.

7151 of 11127 relevant lines covered (64.27%)

354.89 hits per line

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

26.67

/src/http/routes/admin/queue.ts

import { SYSTEM_TENANT } from '@internal/queue/constants'
import { MoveJobs } from '@storage/events'
import { FastifyInstance, RequestGenericInterface } from 'fastify'
import { FromSchema } from 'json-schema-to-ts'
import { getConfig } from '../../../config'
import { registerApiKeyAuth } from '../../plugins/apikey'

const { pgQueueEnable } = getConfig()

const moveJobsSchema = {
  body: {
    type: 'object',
    properties: {
      fromQueue: {
        type: 'string',
      },
      toQueue: {
        type: 'string',
      },
      deleteJobsFromOriginalQueue: {
        type: 'boolean',
        default: false,
      },
    },
    required: ['fromQueue', 'toQueue'],
  },
} as const

interface MoveJobsRequestInterface extends RequestGenericInterface {
  Body: FromSchema<typeof moveJobsSchema.body>
}

export default async function routes(fastify: FastifyInstance) {
  registerApiKeyAuth(fastify)

  fastify.post<MoveJobsRequestInterface>(
    '/move',
    { schema: { ...moveJobsSchema, tags: ['queue'] } },
    async (req, reply) => {
      if (!pgQueueEnable) {
        return reply.status(400).send({ message: 'Queue is not enabled' })
      }

      const fromQueue = req.body.fromQueue
      const toQueue = req.body.toQueue
      const deleteJobsFromOriginalQueue = req.body.deleteJobsFromOriginalQueue || false

      await MoveJobs.send({
        fromQueue,
        toQueue,
        deleteJobsFromOriginalQueue,
        sbReqId: req.sbReqId,
        tenant: SYSTEM_TENANT,
      })

      return reply.send({ message: 'Move jobs scheduled' })
    }
  )
}

1	import { SYSTEM_TENANT } from '@internal/queue/constants'
2	import { MoveJobs } from '@storage/events'
3	import { FastifyInstance, RequestGenericInterface } from 'fastify'
4	import { FromSchema } from 'json-schema-to-ts'
5	import { getConfig } from '../../../config'
6	import { registerApiKeyAuth } from '../../plugins/apikey'
7
8	const { pgQueueEnable } = getConfig()	28✔
9
10	const moveJobsSchema = {	28✔
11	body: {
12	type: 'object',
13	properties: {
14	fromQueue: {
15	type: 'string',
16	},
17	toQueue: {
18	type: 'string',
19	},
20	deleteJobsFromOriginalQueue: {
21	type: 'boolean',
22	default: false,
23	},
24	},
25	required: ['fromQueue', 'toQueue'],
26	},
27	} as const
28
29	interface MoveJobsRequestInterface extends RequestGenericInterface {
30	Body: FromSchema<typeof moveJobsSchema.body>
31	}
32
33	export default async function routes(fastify: FastifyInstance) {
34	registerApiKeyAuth(fastify)	11✔
35
36	fastify.post<MoveJobsRequestInterface>(	11✔
37	'/move',
38	{ schema: { ...moveJobsSchema, tags: ['queue'] } },
39	async (req, reply) => {
UNCOV 40	if (!pgQueueEnable) {	×
41	return reply.status(400).send({ message: 'Queue is not enabled' })	×
42	}
43
UNCOV 44	const fromQueue = req.body.fromQueue	×
UNCOV 45	const toQueue = req.body.toQueue	×
UNCOV 46	const deleteJobsFromOriginalQueue = req.body.deleteJobsFromOriginalQueue \|\| false	×
47
UNCOV 48	await MoveJobs.send({	×
49	fromQueue,
50	toQueue,
51	deleteJobsFromOriginalQueue,
52	sbReqId: req.sbReqId,
53	tenant: SYSTEM_TENANT,
54	})
55
UNCOV 56	return reply.send({ message: 'Move jobs scheduled' })	×
57	}
58	)
59	}

supabase / storage / 27760253447

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