* feat: add pushed_at field to ClaudeJob schema Nullable DateTime column to record when the agent's feature branch was pushed to origin. Enables the UI to show a 'pushed' state independently of DONE status. Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> * feat: GitHub-link op DONE-card + pushed_at doorvoer - lib/job-status-url.ts: getBranchUrl(repoUrl, branch) → GitHub tree URL - JobState + ClaudeJobEvent: pushed_at? veld toegevoegd - realtime/solo/route.ts: pushed_at in Prisma-select, JobPayload en mapping - SoloBoardProps + TaskDetailDialog: repoUrl prop doorgevoerd - task-detail-dialog: "Open op GitHub"-link als done + pushed_at + branch + repoUrl - 3 unit-tests voor getBranchUrl; totaal 261 tests groen Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> * feat: add VerifyResult enum, verify_only on Task, verify_result on ClaudeJob Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> * feat: add verify_result+pushed_at to JobState, VerifyResultApi type, SSE payload Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> * feat: verify_only field on SoloTask, PATCH route saves verify_only Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> * feat: TaskDetailDialog — verify_result display + verify_only checkbox Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> * test: verify_only PATCH + verify_result dialog render + store fix Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> * docs: document VerifyResult enum, verify_only task field, pushed_at in architecture Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> * feat(M13): cron /api/cron/cleanup-agent-artifacts — hard-delete FAILED/CANCELLED jobs >7 days * feat(M13): add auto_pr field to Product schema + migration * feat(M13): auto_pr toggle in product settings — server action + UI component + tests * feat(M13): add pr_url to ClaudeJob schema + migration * feat(M13): UI — 'Open PR' link on DONE-card; pr_url in JobState + SSE + task-dialog * feat(M13): add retry_count migration + regen erd - Migration ALTER TABLE claude_jobs ADD COLUMN retry_count INT DEFAULT 0 (schema.prisma was reeds bijgewerkt in eerdere commits) - docs/erd.svg geregenereerd voor de complete M13-schema-wijzigingen (verify_result, verify_only, pushed_at, pr_url, auto_pr, retry_count) Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com> --------- Co-authored-by: Claude Sonnet 4.6 <noreply@anthropic.com>
268 lines
9.4 KiB
TypeScript
268 lines
9.4 KiB
TypeScript
'use server'
|
|
|
|
import { revalidatePath } from 'next/cache'
|
|
import { redirect } from 'next/navigation'
|
|
import { cookies } from 'next/headers'
|
|
import { getIronSession } from 'iron-session'
|
|
import { z } from 'zod'
|
|
import { prisma } from '@/lib/prisma'
|
|
import { SessionData, sessionOptions } from '@/lib/session'
|
|
import { Role } from '@prisma/client'
|
|
import { isValidCode, MAX_CODE_LENGTH, normalizeCode } from '@/lib/code'
|
|
|
|
const productSchema = z.object({
|
|
name: z.string().min(1, 'Naam is verplicht').max(100, 'Naam mag maximaal 100 tekens bevatten'),
|
|
code: z
|
|
.string()
|
|
.max(MAX_CODE_LENGTH, `Code mag maximaal ${MAX_CODE_LENGTH} tekens bevatten`)
|
|
.optional(),
|
|
description: z.string().max(1000, 'Beschrijving mag maximaal 1000 tekens bevatten').optional(),
|
|
repo_url: z
|
|
.string()
|
|
.url('Voer een geldige URL in (inclusief https://)')
|
|
.optional()
|
|
.or(z.literal('')),
|
|
definition_of_done: z
|
|
.string()
|
|
.min(1, 'Definition of Done is verplicht')
|
|
.max(500, 'Definition of Done mag maximaal 500 tekens bevatten'),
|
|
})
|
|
|
|
async function getSession() {
|
|
return getIronSession<SessionData>(await cookies(), sessionOptions)
|
|
}
|
|
|
|
export async function createProductAction(_prevState: unknown, formData: FormData) {
|
|
const session = await getSession()
|
|
if (!session.userId) return { error: 'Niet ingelogd' }
|
|
if (session.isDemo) return { error: 'Niet beschikbaar in demo-modus' }
|
|
|
|
const parsed = productSchema.safeParse({
|
|
name: formData.get('name'),
|
|
code: (formData.get('code') as string) || undefined,
|
|
description: formData.get('description') || undefined,
|
|
repo_url: formData.get('repo_url') || undefined,
|
|
definition_of_done: formData.get('definition_of_done'),
|
|
})
|
|
|
|
if (!parsed.success) {
|
|
return { error: parsed.error.flatten().fieldErrors }
|
|
}
|
|
|
|
const code = normalizeCode(parsed.data.code)
|
|
if (code !== null && !isValidCode(code)) {
|
|
return { error: { code: ['Code mag alleen letters, cijfers, punten, koppeltekens of underscores bevatten'] } }
|
|
}
|
|
|
|
const existing = await prisma.product.findFirst({
|
|
where: { user_id: session.userId, name: parsed.data.name },
|
|
})
|
|
if (existing) return { error: { name: ['Een product met deze naam bestaat al'] } }
|
|
|
|
if (code) {
|
|
const dup = await prisma.product.findFirst({ where: { user_id: session.userId, code } })
|
|
if (dup) return { error: { code: ['Deze code is al in gebruik'] } }
|
|
}
|
|
|
|
const product = await prisma.product.create({
|
|
data: {
|
|
user_id: session.userId,
|
|
name: parsed.data.name,
|
|
code,
|
|
description: parsed.data.description ?? null,
|
|
repo_url: parsed.data.repo_url || null,
|
|
definition_of_done: parsed.data.definition_of_done,
|
|
},
|
|
})
|
|
|
|
redirect(`/products/${product.id}`)
|
|
}
|
|
|
|
export async function updateProductAction(_prevState: unknown, formData: FormData) {
|
|
const session = await getSession()
|
|
if (!session.userId) return { error: 'Niet ingelogd' }
|
|
if (session.isDemo) return { error: 'Niet beschikbaar in demo-modus' }
|
|
|
|
const id = formData.get('id') as string
|
|
if (!id) return { error: 'Product niet gevonden' }
|
|
|
|
const parsed = productSchema.safeParse({
|
|
name: formData.get('name'),
|
|
code: (formData.get('code') as string) || undefined,
|
|
description: formData.get('description') || undefined,
|
|
repo_url: formData.get('repo_url') || undefined,
|
|
definition_of_done: formData.get('definition_of_done'),
|
|
})
|
|
|
|
if (!parsed.success) {
|
|
return { error: parsed.error.flatten().fieldErrors }
|
|
}
|
|
|
|
const code = normalizeCode(parsed.data.code)
|
|
if (code !== null && !isValidCode(code)) {
|
|
return { error: { code: ['Code mag alleen letters, cijfers, punten, koppeltekens of underscores bevatten'] } }
|
|
}
|
|
|
|
// Verify ownership
|
|
const product = await prisma.product.findFirst({
|
|
where: { id, user_id: session.userId },
|
|
})
|
|
if (!product) return { error: 'Product niet gevonden' }
|
|
|
|
// Check unique name (excluding self)
|
|
const duplicate = await prisma.product.findFirst({
|
|
where: { user_id: session.userId, name: parsed.data.name, NOT: { id } },
|
|
})
|
|
if (duplicate) return { error: { name: ['Een product met deze naam bestaat al'] } }
|
|
|
|
if (code) {
|
|
const dupCode = await prisma.product.findFirst({
|
|
where: { user_id: session.userId, code, NOT: { id } },
|
|
})
|
|
if (dupCode) return { error: { code: ['Deze code is al in gebruik'] } }
|
|
}
|
|
|
|
await prisma.product.update({
|
|
where: { id },
|
|
data: {
|
|
name: parsed.data.name,
|
|
code,
|
|
description: parsed.data.description ?? null,
|
|
repo_url: parsed.data.repo_url || null,
|
|
definition_of_done: parsed.data.definition_of_done,
|
|
},
|
|
})
|
|
|
|
revalidatePath(`/products/${id}`)
|
|
revalidatePath('/dashboard')
|
|
return { success: true }
|
|
}
|
|
|
|
export async function archiveProductAction(id: string) {
|
|
const session = await getSession()
|
|
if (!session.userId) return { error: 'Niet ingelogd' }
|
|
if (session.isDemo) return { error: 'Niet beschikbaar in demo-modus' }
|
|
|
|
const product = await prisma.product.findFirst({
|
|
where: { id, user_id: session.userId },
|
|
})
|
|
if (!product) return { error: 'Product niet gevonden' }
|
|
|
|
await prisma.$transaction([
|
|
// Clear active_product_id for all users who had this product active
|
|
prisma.user.updateMany({
|
|
where: { active_product_id: id },
|
|
data: { active_product_id: null },
|
|
}),
|
|
prisma.product.update({ where: { id }, data: { archived: true } }),
|
|
])
|
|
|
|
revalidatePath('/', 'layout')
|
|
redirect('/dashboard')
|
|
}
|
|
|
|
export async function restoreProductAction(id: string) {
|
|
const session = await getSession()
|
|
if (!session.userId) return { error: 'Niet ingelogd' }
|
|
if (session.isDemo) return { error: 'Niet beschikbaar in demo-modus' }
|
|
|
|
const product = await prisma.product.findFirst({
|
|
where: { id, user_id: session.userId },
|
|
})
|
|
if (!product) return { error: 'Product niet gevonden' }
|
|
|
|
await prisma.product.update({ where: { id }, data: { archived: false } })
|
|
|
|
revalidatePath('/dashboard')
|
|
return { success: true }
|
|
}
|
|
|
|
export async function addProductMemberAction(_prevState: unknown, formData: FormData) {
|
|
const session = await getSession()
|
|
if (!session.userId) return { error: 'Niet ingelogd' }
|
|
if (session.isDemo) return { error: 'Niet beschikbaar in demo-modus' }
|
|
|
|
const productId = formData.get('productId') as string
|
|
const username = (formData.get('username') as string)?.trim().toLowerCase()
|
|
|
|
if (!username) return { error: 'Gebruikersnaam is verplicht' }
|
|
|
|
const product = await prisma.product.findFirst({ where: { id: productId, user_id: session.userId } })
|
|
if (!product) return { error: 'Product niet gevonden of geen eigenaar' }
|
|
|
|
const targetUser = await prisma.user.findUnique({
|
|
where: { username },
|
|
include: { roles: true },
|
|
})
|
|
if (!targetUser) return { error: 'Gebruiker niet gevonden' }
|
|
if (targetUser.is_demo) return { error: 'Demo-gebruiker kan niet worden toegevoegd' }
|
|
if (targetUser.id === session.userId) return { error: 'Je bent al eigenaar van dit product' }
|
|
|
|
const hasDeveloperRole = targetUser.roles.some(r => r.role === Role.DEVELOPER)
|
|
if (!hasDeveloperRole) return { error: `Gebruiker "${username}" heeft geen Developer-rol` }
|
|
|
|
const existing = await prisma.productMember.findUnique({
|
|
where: { product_id_user_id: { product_id: productId, user_id: targetUser.id } },
|
|
})
|
|
if (existing) return { error: 'Gebruiker is al lid van dit product' }
|
|
|
|
await prisma.productMember.create({
|
|
data: { product_id: productId, user_id: targetUser.id },
|
|
})
|
|
|
|
revalidatePath(`/products/${productId}/settings`)
|
|
return { success: true }
|
|
}
|
|
|
|
export async function removeProductMemberAction(productId: string, memberId: string) {
|
|
const session = await getSession()
|
|
if (!session.userId) return { error: 'Niet ingelogd' }
|
|
if (session.isDemo) return { error: 'Niet beschikbaar in demo-modus' }
|
|
|
|
const product = await prisma.product.findFirst({ where: { id: productId, user_id: session.userId } })
|
|
if (!product) return { error: 'Product niet gevonden of geen eigenaar' }
|
|
|
|
await prisma.$transaction([
|
|
prisma.user.updateMany({
|
|
where: { id: memberId, active_product_id: productId },
|
|
data: { active_product_id: null },
|
|
}),
|
|
prisma.productMember.deleteMany({ where: { product_id: productId, user_id: memberId } }),
|
|
])
|
|
|
|
revalidatePath(`/products/${productId}/settings`)
|
|
return { success: true }
|
|
}
|
|
|
|
export async function leaveProductAction(productId: string) {
|
|
const session = await getSession()
|
|
if (!session.userId) return { error: 'Niet ingelogd' }
|
|
|
|
await prisma.$transaction([
|
|
prisma.user.updateMany({
|
|
where: { id: session.userId, active_product_id: productId },
|
|
data: { active_product_id: null },
|
|
}),
|
|
prisma.productMember.deleteMany({ where: { product_id: productId, user_id: session.userId } }),
|
|
])
|
|
|
|
revalidatePath('/', 'layout')
|
|
revalidatePath('/settings')
|
|
return { success: true }
|
|
}
|
|
|
|
export async function updateAutoPrAction(id: string, auto_pr: boolean) {
|
|
const session = await getSession()
|
|
if (!session.userId) return { error: 'Niet ingelogd' }
|
|
if (session.isDemo) return { error: 'Niet beschikbaar in demo-modus' }
|
|
|
|
const parsed = z.object({ auto_pr: z.boolean() }).safeParse({ auto_pr })
|
|
if (!parsed.success) return { error: 'Ongeldige waarde voor auto_pr' }
|
|
|
|
const product = await prisma.product.findFirst({ where: { id, user_id: session.userId } })
|
|
if (!product) return { error: 'Product niet gevonden' }
|
|
|
|
await prisma.product.update({ where: { id }, data: { auto_pr: parsed.data.auto_pr } })
|
|
revalidatePath(`/products/${id}/settings`)
|
|
return { success: true }
|
|
}
|