refactor(admin-v2): Consolidate compliance/DSGVO pages into SDK pipeline

Remove duplicate compliance and DSGVO admin pages that have been superseded
by the unified SDK pipeline. Update navigation, sidebar, roles, and module
registry to reflect the new structure. Add DSFA corpus API proxy and
source-policy components.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

admin-v2/app/api/dsfa-corpus/route.ts

@@ -0,0 +1,100 @@
+/**
+ * DSFA Corpus API Proxy
+ *
+ * Proxies requests to klausur-service for DSFA RAG operations.
+ * Endpoints: /api/v1/dsfa-rag/stats, /api/v1/dsfa-rag/sources
+ */
+
+import { NextRequest, NextResponse } from 'next/server'
+
+const KLAUSUR_SERVICE_URL = process.env.KLAUSUR_SERVICE_URL || 'http://klausur-service:8086'
+
+export async function GET(request: NextRequest) {
+  const { searchParams } = new URL(request.url)
+  const action = searchParams.get('action')
+
+  try {
+    let url = `${KLAUSUR_SERVICE_URL}/api/v1/dsfa-rag`
+
+    switch (action) {
+      case 'status':
+        url += '/stats'
+        break
+      case 'sources':
+        url += '/sources'
+        break
+      case 'source-detail': {
+        const code = searchParams.get('code')
+        if (!code) {
+          return NextResponse.json({ error: 'Missing code parameter' }, { status: 400 })
+        }
+        url += `/sources/${encodeURIComponent(code)}`
+        break
+      }
+      default:
+        return NextResponse.json({ error: 'Unknown action' }, { status: 400 })
+    }
+
+    const res = await fetch(url, {
+      headers: {
+        'Content-Type': 'application/json',
+      },
+      cache: 'no-store',
+    })
+
+    const data = await res.json()
+    return NextResponse.json(data, { status: res.status })
+  } catch (error) {
+    console.error('DSFA corpus proxy error:', error)
+    return NextResponse.json(
+      { error: 'Failed to connect to klausur-service' },
+      { status: 503 }
+    )
+  }
+}
+
+export async function POST(request: NextRequest) {
+  const { searchParams } = new URL(request.url)
+  const action = searchParams.get('action')
+
+  try {
+    let url = `${KLAUSUR_SERVICE_URL}/api/v1/dsfa-rag`
+
+    switch (action) {
+      case 'init': {
+        url += '/init'
+        const res = await fetch(url, {
+          method: 'POST',
+          headers: { 'Content-Type': 'application/json' },
+        })
+        const data = await res.json()
+        return NextResponse.json(data, { status: res.status })
+      }
+
+      case 'ingest': {
+        const body = await request.json()
+        const sourceCode = body.source_code
+        if (!sourceCode) {
+          return NextResponse.json({ error: 'Missing source_code' }, { status: 400 })
+        }
+        url += `/sources/${encodeURIComponent(sourceCode)}/ingest`
+        const res = await fetch(url, {
+          method: 'POST',
+          headers: { 'Content-Type': 'application/json' },
+          body: JSON.stringify(body),
+        })
+        const data = await res.json()
+        return NextResponse.json(data, { status: res.status })
+      }
+
+      default:
+        return NextResponse.json({ error: 'Unknown action' }, { status: 400 })
+    }
+  } catch (error) {
+    console.error('DSFA corpus proxy error:', error)
+    return NextResponse.json(
+      { error: 'Failed to connect to klausur-service' },
+      { status: 503 }
+    )
+  }
+}

admin-v2/app/api/legal-corpus/route.ts

@@ -8,6 +8,7 @@
 import { NextRequest, NextResponse } from 'next/server'
 
 const KLAUSUR_SERVICE_URL = process.env.KLAUSUR_SERVICE_URL || 'http://klausur-service:8086'
+const QDRANT_URL = process.env.QDRANT_URL || 'http://qdrant:6333'
 
 export async function GET(request: NextRequest) {
   const { searchParams } = new URL(request.url)
@@ -17,9 +18,24 @@ export async function GET(request: NextRequest) {
     let url = `${KLAUSUR_SERVICE_URL}/api/v1/admin/legal-corpus`
 
     switch (action) {
-      case 'status':
-        url += '/status'
-        break
+      case 'status': {
+        // Query Qdrant directly for collection stats
+        const qdrantRes = await fetch(`${QDRANT_URL}/collections/bp_legal_corpus`, {
+          cache: 'no-store',
+        })
+        if (!qdrantRes.ok) {
+          return NextResponse.json({ error: 'Qdrant not available' }, { status: 503 })
+        }
+        const qdrantData = await qdrantRes.json()
+        const result = qdrantData.result || {}
+        return NextResponse.json({
+          collection: 'bp_legal_corpus',
+          totalPoints: result.points_count || 0,
+          vectorSize: result.config?.params?.vectors?.size || 0,
+          status: result.status || 'unknown',
+          regulations: {},
+        })
+      }
       case 'search':
         const query = searchParams.get('query')
         const topK = searchParams.get('top_k') || '5'

admin-v2/app/api/sdk/compliance-advisor/chat/route.ts

@@ -159,7 +159,7 @@ export async function POST(request: NextRequest) {
         stream: true,
         options: {
           temperature: 0.3,
-          num_predict: 2048,
+          num_predict: 8192,
         },
       }),
       signal: AbortSignal.timeout(120000),