chore: add dvtp example Flow A - Toestemming geven [no ci]

Author: sgort

packages/backend/src/db/mappers.ts

@@ -51,45 +51,42 @@ export function mapDocument(r: DocumentRow): Document {
   };
 }
 
-export function mapRopaRecord(
-  row: RopaRecordRow,
-  fields: RopaPersonalDataField[]
-): RopaRecord {
+export function mapRopaRecord(row: RopaRecordRow, fields: RopaPersonalDataField[]): RopaRecord {
   return {
-    id:                    row.id,
-    bpmnProcessId:         row.bpmn_process_id,
-    processLevel:          row.process_level as RopaRecord['processLevel'],
-    title:                 row.title,
-    controllerName:        row.controller_name,
-    controllerContact:     row.controller_contact,
-    dpoContact:            row.dpo_contact ?? undefined,
-    purpose:               row.purpose,
-    legalBasisUri:         row.legal_basis_uri,
-    legalBasisLabel:       row.legal_basis_label,
-    gdprArticle:           row.gdpr_article,
-    dataSubjects:          row.data_subjects,
-    recipients:            row.recipients,
+    id: row.id,
+    bpmnProcessId: row.bpmn_process_id,
+    processLevel: row.process_level as RopaRecord['processLevel'],
+    title: row.title,
+    controllerName: row.controller_name,
+    controllerContact: row.controller_contact,
+    dpoContact: row.dpo_contact ?? undefined,
+    purpose: row.purpose,
+    legalBasisUri: row.legal_basis_uri,
+    legalBasisLabel: row.legal_basis_label,
+    gdprArticle: row.gdpr_article,
+    dataSubjects: row.data_subjects,
+    recipients: row.recipients,
     thirdCountryTransfers: row.third_country_transfers,
-    thirdCountryDetails:   row.third_country_details ?? undefined,
-    retentionPeriod:       row.retention_period,
-    securityMeasures:      row.security_measures,
-    status:                row.status as RopaRecord['status'],
-    schemaVersion:         row.schema_version,
-    personalDataFields:    fields,
-    createdAt:             row.created_at.toISOString(),
-    updatedAt:             row.updated_at.toISOString(),
+    thirdCountryDetails: row.third_country_details ?? undefined,
+    retentionPeriod: row.retention_period,
+    securityMeasures: row.security_measures,
+    status: row.status as RopaRecord['status'],
+    schemaVersion: row.schema_version,
+    personalDataFields: fields,
+    createdAt: row.created_at.toISOString(),
+    updatedAt: row.updated_at.toISOString(),
   };
 }
 
 export function mapRopaField(row: RopaFieldRow): RopaPersonalDataField {
   return {
-    id:              row.id,
-    ropaRecordId:    row.ropa_record_id,
-    formId:          row.form_id,
-    fieldKey:        row.field_key,
-    fieldLabel:      row.field_label,
-    dataCategory:    row.data_category,
+    id: row.id,
+    ropaRecordId: row.ropa_record_id,
+    formId: row.form_id,
+    fieldKey: row.field_key,
+    fieldLabel: row.field_label,
+    dataCategory: row.data_category,
     specialCategory: row.special_category,
-    sortOrder:       row.sort_order,
+    sortOrder: row.sort_order,
   };
-}
+}

packages/backend/src/db/types.ts

@@ -72,4 +72,4 @@ export type RopaFieldRow = {
   data_category: string;
   special_category: boolean;
   sort_order: number;
-};
+};

packages/backend/src/routes/assets.public.routes.ts

@@ -11,16 +11,16 @@ const router = Router();
 router.use(cors({ origin: '*', methods: ['GET', 'OPTIONS'] }));
 
 router.get('/', async (_req: Request, res: Response) => {
-    try {
-        const data = await listPublicBundles();
-        res.json({ success: true, data });
-    } catch (err) {
-        logger.error('[assets.public] listPublicBundles failed', { error: getErrorMessage(err) });
-        res.status(500).json({
-            success: false,
-            error: { code: 'LIST_FAILED', message: getErrorMessage(err) },
-        });
-    }
+  try {
+    const data = await listPublicBundles();
+    res.json({ success: true, data });
+  } catch (err) {
+    logger.error('[assets.public] listPublicBundles failed', { error: getErrorMessage(err) });
+    res.status(500).json({
+      success: false,
+      error: { code: 'LIST_FAILED', message: getErrorMessage(err) },
+    });
+  }
 });
 
-export default router;
+export default router;

packages/backend/src/routes/assets.routes.ts

@@ -73,7 +73,12 @@ router.delete('/bpmn/:id', async (req: Request, res: Response) => {
 router.patch('/bpmn/:id/deploy', async (req: Request, res: Response) => {
   if (!dbRequired(req, res)) return;
   try {
-    const { deploymentId, operatonUrl, formIds = [], documentIds = [] } = req.body as {
+    const {
+      deploymentId,
+      operatonUrl,
+      formIds = [],
+      documentIds = [],
+    } = req.body as {
       deploymentId: string;
       operatonUrl?: string;
       formIds?: string[];
@@ -83,7 +88,12 @@ router.patch('/bpmn/:id/deploy', async (req: Request, res: Response) => {
     res.json({ success: true });
   } catch (err) {
     logger.error('[assets] markDeployed failed', { error: getErrorMessage(err) });
-    res.status(500).json({ success: false, error: { code: 'DEPLOY_MARK_FAILED', message: getErrorMessage(err) } });
+    res
+      .status(500)
+      .json({
+        success: false,
+        error: { code: 'DEPLOY_MARK_FAILED', message: getErrorMessage(err) },
+      });
   }
 });
 

packages/backend/src/services/assets.service.ts

@@ -185,7 +185,11 @@ export async function listPublicBundles(): Promise<unknown[]> {
     operatonDeploymentId: r.operaton_deployment_id ?? undefined,
     deployedForms: (r as unknown as { forms: { id: string; name: string }[] }).forms,
     deployedDocuments: (r as unknown as { documents: { id: string; name: string }[] }).documents,
-    subprocesses: (r as unknown as { subprocesses: { id: string; name: string; bpmnProcessId: string; status: string }[] }).subprocesses,
+    subprocesses: (
+      r as unknown as {
+        subprocesses: { id: string; name: string; bpmnProcessId: string; status: string }[];
+      }
+    ).subprocesses,
     updatedAt: r.updated_at,
   }));
 }

packages/backend/src/services/ropa.service.ts

@@ -24,7 +24,9 @@ export async function listRopa(): Promise<RopaRecord[]> {
 
 export async function getRopaById(id: string): Promise<RopaRecord | null> {
   if (!pool) return null;
-  const { rows } = await pool.query<RopaRecordRow>(`SELECT * FROM ropa_records WHERE id = $1`, [id]);
+  const { rows } = await pool.query<RopaRecordRow>(`SELECT * FROM ropa_records WHERE id = $1`, [
+    id,
+  ]);
   if (rows.length === 0) return null;
   const { rows: fieldRows } = await pool.query<RopaFieldRow>(
     `SELECT * FROM ropa_personal_data_fields WHERE ropa_record_id = $1 ORDER BY sort_order ASC`,
@@ -158,7 +160,10 @@ export async function listPublicRopa(organisation?: string): Promise<PublicRopaR
     [ids]
   );
   return recordRows.map((r) => {
-    const full = mapRopaRecord(r, fieldRows.filter((f) => f.ropa_record_id === r.id).map(mapRopaField));
+    const full = mapRopaRecord(
+      r,
+      fieldRows.filter((f) => f.ropa_record_id === r.id).map(mapRopaField)
+    );
     // Strip internal fields before exposing publicly
     // eslint-disable-next-line @typescript-eslint/no-unused-vars
     const { schemaVersion, controllerContact, dpoContact, ...pub } = full;