30381503940

Committed 28 Jul 2026 05:07PM UTC coverage: 59.291% (-21.0%) from 80.307%

Build # 30381503940

Build Type

Pull #1270

github

Committed by

web-flow

Commit Message

Merge fa9a4947b into 20927735c

Pull Request Pull Request #1270: fix(storage): document 200 responses for vector bucket CRUD endpoints

Coverage Stats

3677 of 7083 branches covered (51.91%)

Branch coverage included in aggregate %.

9 of 55 new or added lines in 3 files covered. (16.36%)

2445 existing lines in 105 files now uncovered.

7666 of 12048 relevant lines covered (63.63%)

363.67 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()	29✔
9
10	const moveJobsSchema = {	29✔
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)	12✔
35
36	fastify.post<MoveJobsRequestInterface>(	12✔
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 / 30381503940

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