15387080396

Committed 02 Jun 2025 08:04AM UTC coverage: 77.893% (-0.3%) from 78.159%

Build # 15387080396

Build Type

Pull #696

github

Committed by

web-flow

Commit Message

Merge f3f847646 into d82ebecc1

Pull Request Pull Request #696: feat: pgboss v10

Coverage Stats

1536 of 2137 branches covered (71.88%)

Branch coverage included in aggregate %.

166 of 436 new or added lines in 28 files covered. (38.07%)

60 existing lines in 4 files now uncovered.

17374 of 22140 relevant lines covered (78.47%)

110.28 hits per line

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

66.67

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

import { FastifyInstance } from 'fastify'
import apiKey from '../../plugins/apikey'
import { getConfig } from '../../../config'
import { UpgradePgBossV10 } from '@storage/events'

const { pgQueueEnable } = getConfig()

export default async function routes(fastify: FastifyInstance) {
  fastify.register(apiKey)

  fastify.post('/migrate/pgboss-v10', async (req, reply) => {
    if (!pgQueueEnable) {
      return reply.status(400).send({ message: 'Queue is not enabled' })
    }

    await UpgradePgBossV10.send({})

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

1	import { FastifyInstance } from 'fastify'	1✔
2	import apiKey from '../../plugins/apikey'	1✔
3	import { getConfig } from '../../../config'	1✔
4	import { UpgradePgBossV10 } from '@storage/events'	1✔
5		1✔
6	const { pgQueueEnable } = getConfig()	1✔
7		1✔
8	export default async function routes(fastify: FastifyInstance) {	1✔
9	fastify.register(apiKey)	1✔
10		1✔
11	fastify.post('/migrate/pgboss-v10', async (req, reply) => {	1✔
NEW 12	if (!pgQueueEnable) {	×
NEW 13	return reply.status(400).send({ message: 'Queue is not enabled' })	×
NEW 14	}	×
NEW 15		×
NEW 16	await UpgradePgBossV10.send({})	×
NEW 17		×
NEW 18	return reply.send({ message: 'Migration scheduled' })	×
19	})	1✔
20	}	1✔

supabase / storage / 15387080396

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