Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 | 4x 4x 4x 4x 2x 2x 2x 2x 2x 2x 5x 2x 2x 2x 74x 8x 48x 8x 22x 18x 4x 4x 4x 4x 2x 2x 2x 2x 2x | import { http, HttpResponse } from 'msw'
import { mockPipelines, mockRepositories } from '@/msw/mock-data'
import { createMockPipeline } from '@/msw/data'
import { laneLint } from '@/features/pipelines/laneLint'
import type { components } from '@/types/api'
import type { LintIssue } from '@/layers/interfaces'
type SkillRepoRef = components['schemas']['SkillRepoRef']
// Mirrors the API's validateJSONObject + writeLaneLintErrors
/I/ (pipeline_handler.go): a non-object config answers 422; a config whose
/I/ vikunja.lanes section has error-severity lint issues answers 422 with the
// first error message plus the full error-issue list (warnings are
// non-blocking and never serialized).
function configLaneValidationError(
config: unknown,
): { error: string; errors?: LintIssue[] } | null {
if (config === null || config === undefined) return null
if (typeof config !== 'object' || Array.isArray(config)) {
const kind = Array.isArray(config) ? 'array' : typeof config
return { error: `config must be a JSON object, not ${kind}` }
}
const result = laneLint(config, '')
if (result.errors.length > 0) {
return { error: result.errors[0].message, errors: result.errors }
}
return null
}
I
// Joins submitted ordered repository ids against the repositories mock data,
// mirroring the API's pipeline_skill_repos join: response refs carry the
//I repository name and url, and the array order is the submitted priority.
function resolveSkillRepoRefs(ids: unknown): SkillRepoRef[] {
Iif (!Array.isArray(ids)) return []
const refs: SkillRepoRef[] = []
for (const id of ids) {
if (typeof id !== 'string') continue
const repo = mockRepositories.find((r) => r.id === id)
if (!repo) continue
refs.push({ repository_id: repo.id, name: repo.name, url: repo.url })
}
return refs
}
export const pipelineHandlers = [
http.get('/api/v1/projects/:projectId/pipelines', ({ params }) => {
const projectId = params.projectId as string
const pipelines = mockPipelines.filter((p) => p.project_id === projectId)
return HttpResponse.json({
data: pipelines.length > 0 ? pipelines : [createMockPipeline({ project_id: projectId })],
meta: { limit: 50, returned: Math.max(pipelines.length, 1), has_more: false },
})
}),
http.get('/api/v1/pipelines/:id', ({ params }) => {
const pipeline = mockPipelines.find((p) => p.id === params.id)
return HttpResponse.json(pipeline ?? createMockPipeline({ id: params.id as string }))
}),
http.post('/api/v1/projects/:projectId/pipelines', async ({ params, request }) => {
const body = (await request.json()) as Record<string, unknown>
const configError = configLaneValidationError(body.config)
if (configError) {
return HttpResponse.json(configError, { status: 422 })
}
const pipeline = createMockPipeline({
project_id: params.projectId as string,
config: (body.config as Record<string, unknown> | null | undefined) ?? null,
skill_repos: resolveSkillRepoRefs(body.skill_repos),
})
mockPipelines.push(pipeline)
return HttpResponse.json(pipeline, { status: 201 })
}),
http.put('/api/v1/pipelines/:id', async ({ params, request }) => {
const existing = mockPipelines.find((p) => p.id === params.id)
const body = (await request.json()) as Record<string, unknown>
const configError = configLaneValidationError(body.config)
if (configError) {
return HttpResponse.json(configError, { status: 422 })
E }
if (existing) {
if (Array.isArray(body.skill_repos)) {
// Ordered id array → joined refs (order = priority); [] clears.
ObEject.assign(existing, body, { skill_repos: resolveSkillRepoRefs(body.skill_repos) })
} else {
// null = unchanged and absent = untouched: never write skill_repos.
const { skill_repos: _ignored, ...rest } = body
Object.assign(existing, rest)
}
return HttpResponse.json(existing)
}
return HttpResponse.json(createMockPipeline({ id: params.id as string, ...body }))
}),
http.delete('/api/v1/pipelines/:id', () => new HttpResponse(null, { status: 204 })),
]
|