29005879037

Committed 09 Jul 2026 08:46AM UTC coverage: 58.99% (-20.3%) from 79.254%

Build # 29005879037

Build Type

Pull #1196

github

Committed by

web-flow

Commit Message

Merge 7e8ebf9b4 into 1bfdcd74e

Pull Request Pull Request #1196: chore(deps-dev): bump resolve-tspaths from 0.8.19 to 0.8.23

Coverage Stats

3509 of 6801 branches covered (51.6%)

Branch coverage included in aggregate %.

7436 of 11753 relevant lines covered (63.27%)

386.03 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) => {
40	if (!pgQueueEnable) {	×
41	return reply.status(400).send({ message: 'Queue is not enabled' })	×
42	}
43
44	const fromQueue = req.body.fromQueue	×
45	const toQueue = req.body.toQueue	×
46	const deleteJobsFromOriginalQueue = req.body.deleteJobsFromOriginalQueue \|\| false	×
47
48	await MoveJobs.send({	×
49	fromQueue,
50	toQueue,
51	deleteJobsFromOriginalQueue,
52	sbReqId: req.sbReqId,
53	tenant: SYSTEM_TENANT,
54	})
55
56	return reply.send({ message: 'Move jobs scheduled' })	×
57	}
58	)
59	}

supabase / storage / 29005879037

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