diff --git a/api/korrespond-refine.php b/api/korrespond-refine.php
new file mode 100644
index 0000000..4a3cdc1
--- /dev/null
+++ b/api/korrespond-refine.php
@@ -0,0 +1,120 @@
+ 0) { @ob_end_clean(); }
+ob_implicit_flush(true);
+
+header('Content-Type: application/x-ndjson; charset=utf-8');
+header('Cache-Control: no-store');
+header('X-Accel-Buffering: no');
+
+$startTime = microtime(true);
+$language = 'en';
+
+$emit = function (string $event, array $payload = []) use ($startTime): void {
+ $payload['event'] = $event;
+ $payload['t_ms'] = (int)round((microtime(true) - $startTime) * 1000);
+ echo json_encode($payload, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES) . "\n";
+ @flush();
+};
+
+try {
+ $raw = file_get_contents('php://input');
+ if ($raw === false || strlen($raw) > 200000) {
+ throw new DbnToolsHttpException('Request body unreadable or too large.', 413, 'body_too_large');
+ }
+ $input = json_decode((string)$raw, true);
+ if (!is_array($input)) {
+ throw new DbnToolsHttpException('Request body must be valid JSON.', 400, 'invalid_json');
+ }
+
+ $language = dbnToolsNormalizeLanguage($input['language'] ?? 'en');
+ $jurisdiction = $input['jurisdiction'] ?? 'norwegian';
+ if (!in_array($jurisdiction, ['norwegian', 'echr', 'both'], true)) {
+ throw new DbnToolsHttpException('Invalid jurisdiction.', 422, 'invalid_jurisdiction');
+ }
+ $originalDraftNo = trim((string)($input['original_draft_no'] ?? ''));
+ if ($originalDraftNo === '') {
+ throw new DbnToolsHttpException('original_draft_no is required.', 422, 'missing_original_draft');
+ }
+ if (mb_strlen($originalDraftNo, 'UTF-8') > 12000) {
+ throw new DbnToolsHttpException('original_draft_no is too large.', 413, 'original_too_large');
+ }
+ $classify = is_array($input['classify'] ?? null) ? $input['classify'] : [];
+ $intake = is_array($input['intake'] ?? null) ? $input['intake'] : [];
+
+ // Sanitise intake to expected fields only
+ $allowedBodies = ['barnehage','school_1_10','sfo','nav','bufdir','barnevernet',
+ 'kommune_other','statsforvalter','trygderetten','tingrett','other'];
+ $allowedOutput = ['email','formal','filing','call_prep'];
+ $allowedTone = ['cooperative','neutral','firm','adversarial','warm'];
+
+ $intake = [
+ 'recipient_body' => in_array($intake['recipient_body'] ?? '', $allowedBodies, true) ? $intake['recipient_body'] : 'other',
+ 'output_type' => in_array($intake['output_type'] ?? '', $allowedOutput, true) ? $intake['output_type'] : 'email',
+ 'tone' => in_array($intake['tone'] ?? '', $allowedTone, true) ? $intake['tone'] : 'neutral',
+ 'language' => $language,
+ 'goal' => mb_substr(trim((string)($intake['goal'] ?? '')), 0, 600, 'UTF-8'),
+ ];
+
+ // Credit gate (refine is a paid pass)
+ $ftUid = dbnToolsFreeTierCheck('korrespond_refine');
+ $ftRemaining = dbnToolsFreeTierDeduct($ftUid, 'korrespond_refine');
+ if ($ftRemaining >= 0) {
+ header('X-Credits-Remaining: ' . $ftRemaining);
+ }
+
+ $emit('start', [
+ 'jurisdiction' => $jurisdiction,
+ 'body' => $intake['recipient_body'],
+ 'language' => $language,
+ ]);
+
+ $agent = new DbnKorrespondAgent();
+ $result = $agent->refine($intake, $classify, $originalDraftNo, $jurisdiction, $emit);
+ $result['ok'] = true;
+ $result['latency_ms'] = (int)round((microtime(true) - $startTime) * 1000);
+
+ dbnToolsLogMetadata([
+ 'tool' => 'korrespond_refine',
+ 'language' => $language,
+ 'ok' => true,
+ 'latency_ms' => $result['latency_ms'],
+ 'source_count' => is_array($result['cited_law'] ?? null) ? count($result['cited_law']) : 0,
+ 'deployment' => 'gpt-4o',
+ 'jurisdiction' => $jurisdiction,
+ ]);
+
+ $emit('final', ['result' => $result]);
+
+} catch (DbnToolsHttpException $e) {
+ $latency = (int)round((microtime(true) - $startTime) * 1000);
+ dbnToolsLogMetadata([
+ 'tool' => 'korrespond_refine',
+ 'language' => $language,
+ 'ok' => false,
+ 'latency_ms' => $latency,
+ 'error_code' => $e->errorCode,
+ ]);
+ $emit('error', ['code' => $e->errorCode, 'message' => $e->getMessage(), 'status' => $e->status]);
+} catch (Throwable $e) {
+ error_log('Korrespond refine fatal: ' . $e->getMessage());
+ $latency = (int)round((microtime(true) - $startTime) * 1000);
+ dbnToolsLogMetadata([
+ 'tool' => 'korrespond_refine',
+ 'language' => $language,
+ 'ok' => false,
+ 'latency_ms' => $latency,
+ 'error_code' => 'internal_error',
+ ]);
+ $emit('error', ['code' => 'internal_error', 'message' => 'Korrespond refine could not complete this request.']);
+}
diff --git a/assets/css/tools.css b/assets/css/tools.css
index 4b79216..f2aacd3 100644
--- a/assets/css/tools.css
+++ b/assets/css/tools.css
@@ -7136,3 +7136,44 @@ body.lt-landing {
/* Required hint */
.required-hint { color: var(--dbn-red, #ba0c2f); font-size: 0.78rem; font-weight: 500; }
+/* Korrespond — refine panel */
+.korr-refine-panel {
+ margin-top: 22px;
+ padding: 16px 18px;
+ background: rgba(0, 32, 91, 0.04);
+ border: 1px dashed rgba(0, 32, 91, 0.35);
+ border-radius: 10px;
+}
+.korr-refine-panel h3 {
+ margin: 0 0 6px;
+ font-size: 1rem;
+ color: var(--dbn-blue, #00205b);
+}
+.korr-refine-panel h3 small {
+ font-size: 0.75rem;
+ font-weight: 400;
+ color: rgba(0, 0, 0, 0.55);
+}
+.korr-refine-controls {
+ display: flex;
+ flex-wrap: wrap;
+ align-items: center;
+ gap: 14px;
+ margin: 10px 0 4px;
+}
+.korr-refine-controls label {
+ display: inline-flex;
+ align-items: center;
+ gap: 6px;
+ font-size: 0.88rem;
+ cursor: pointer;
+}
+.korr-refine-controls button {
+ margin-left: auto;
+}
+.korr-refined {
+ margin-top: 18px;
+ padding-top: 18px;
+ border-top: 1px solid rgba(0, 32, 91, 0.18);
+}
+
diff --git a/assets/js/korrespond.js b/assets/js/korrespond.js
index fd638c5..0d99965 100644
--- a/assets/js/korrespond.js
+++ b/assets/js/korrespond.js
@@ -1,6 +1,7 @@
/* korrespond.js — page-scoped UI for /korrespond.php
- Two-pass wizard: Pass 1 may return clarify questions; Pass 2 returns Norwegian
- + working-language drafts side by side with verified law citations.
+ Three-pass flow: Pass 1 may return clarify questions; Pass 2 returns Norwegian
+ + working-language drafts with verified law citations. Pass 3 (opt-in) refines
+ the draft with jurisdiction-scoped formal citations + Rettskilder appendix.
*/
(function () {
'use strict';
@@ -9,6 +10,7 @@
let lang = window.DBN_TOOLS_LANG || localStorage.getItem('dbn-ui-lang') || 'en';
let uploadFiles = [];
let lastClassify = null;
+ let lastFinal = null;
let pendingClarifications = {};
const LANG_LABELS = { en: 'English', no: 'Norsk', uk: 'Українська', pl: 'Polski' };
@@ -295,10 +297,111 @@
}
setStatus(`Done in ${Math.round((finalResult.latency_ms || 0) / 1000)} s · ${(finalResult.cited_law || []).length} cited source(s)`, 'ok');
+ lastFinal = finalResult;
renderFinal(finalResult);
pendingClarifications = {}; // reset for next run
}
+ // ── Pass 3: refine with jurisdiction-scoped formal citations ────────────────
+ async function runRefine(jurisdiction) {
+ if (!lastFinal || !lastClassify) {
+ setStatus('No draft to refine. Run a draft first.', 'error');
+ return;
+ }
+ const refineBtn = document.getElementById('korrRefineBtn');
+ if (refineBtn) { refineBtn.disabled = true; refineBtn.textContent = 'Refining…'; }
+ setStatus(`Refining draft with ${jurisdiction} authorities…`, 'busy');
+
+ const payload = {
+ jurisdiction,
+ language: lang,
+ original_draft_no: lastFinal.draft_no || '',
+ classify: lastClassify,
+ intake: {
+ recipient_body: lastFinal.recipient_body,
+ output_type: lastFinal.output_type,
+ tone: lastFinal.tone,
+ goal: lastFinal.goal,
+ },
+ };
+
+ let response;
+ try {
+ response = await fetch('api/korrespond-refine.php', {
+ method: 'POST', credentials: 'same-origin',
+ headers: { 'Content-Type': 'application/json' },
+ body: JSON.stringify(payload),
+ });
+ } catch (err) {
+ setStatus(`Network error: ${err.message || err}`, 'error');
+ if (refineBtn) { refineBtn.disabled = false; refineBtn.textContent = 'Refine citations'; }
+ return;
+ }
+
+ if (!response.ok || !response.body) {
+ if (response.status === 402 || response.status === 429) {
+ const d = await response.json().catch(() => ({}));
+ if (typeof window.dbnFreeTierError === 'function') window.dbnFreeTierError(response.status, d);
+ } else {
+ setStatus(`Refine failed (${response.status}).`, 'error');
+ }
+ if (refineBtn) { refineBtn.disabled = false; refineBtn.textContent = 'Refine citations'; }
+ return;
+ }
+ const creditsRemaining = response.headers.get('X-Credits-Remaining');
+ if (creditsRemaining !== null && typeof window.dbnUpdateCredits === 'function') {
+ window.dbnUpdateCredits(parseInt(creditsRemaining, 10));
+ }
+
+ const reader = response.body.getReader();
+ const decoder = new TextDecoder('utf-8');
+ let buffer = '';
+ let finalResult = null;
+ let errorEvent = null;
+
+ while (true) {
+ let chunk;
+ try { chunk = await reader.read(); }
+ catch (err) {
+ setStatus(`Stream error: ${err.message || err}`, 'error');
+ if (refineBtn) { refineBtn.disabled = false; refineBtn.textContent = 'Refine citations'; }
+ return;
+ }
+ const { done, value } = chunk;
+ if (value) {
+ buffer += decoder.decode(value, { stream: true });
+ const lines = buffer.split('\n');
+ buffer = lines.pop();
+ for (const line of lines) {
+ const trimmed = line.trim();
+ if (!trimmed) continue;
+ let evt; try { evt = JSON.parse(trimmed); } catch (_) { continue; }
+ if (!evt || !evt.event) continue;
+ if (evt.event === 'progress') { setStatus(evt.detail || 'Refining…', 'busy'); continue; }
+ if (evt.event === 'start') { setStatus(`Refining (${evt.jurisdiction})…`, 'busy'); continue; }
+ if (evt.event === 'retrieval') { setStatus(`Hentet ${evt.sources_count} rettskilder for ${evt.jurisdiction}…`, 'busy'); continue; }
+ if (evt.event === 'final') { finalResult = evt.result; continue; }
+ if (evt.event === 'error') { errorEvent = evt; continue; }
+ }
+ }
+ if (done) break;
+ }
+
+ if (refineBtn) { refineBtn.disabled = false; refineBtn.textContent = 'Refine citations'; }
+
+ if (errorEvent) {
+ setStatus(`${errorEvent.code}: ${errorEvent.message}`, 'error');
+ return;
+ }
+ if (!finalResult) {
+ setStatus('Refine stream ended without a result.', 'error');
+ return;
+ }
+
+ setStatus(`Refined in ${Math.round((finalResult.latency_ms || 0) / 1000)} s · ${(finalResult.cited_law || []).length} cited authority(ies) · ${finalResult.jurisdiction}`, 'ok');
+ renderRefined(finalResult);
+ }
+
// ── Rendering ───────────────────────────────────────────────────────────────
function renderClassifySummary(c) {
if (!c || !c.summary) return;
@@ -386,6 +489,18 @@
` : 'No cited law sources — draft is plain-language (no § references available from corpus).
'}
${data.disclaimer ? `${esc(data.disclaimer)}
` : ''}
+
+
`;
// Wire copy/download
@@ -405,6 +520,105 @@
downloadText(`korrespond-${data.recipient_body}-${suffix}.txt`, target);
});
});
+
+ // Wire refine
+ const refineBtn = document.getElementById('korrRefineBtn');
+ refineBtn?.addEventListener('click', () => {
+ const choice = document.querySelector('input[name="korrJurisdiction"]:checked');
+ runRefine(choice ? choice.value : 'norwegian');
+ });
+ }
+
+ function renderRefined(data) {
+ const slot = document.getElementById('korrRefinedSlot');
+ if (!slot) return;
+ const userLang = data.draft_user_lang || 'en';
+ const userLangLabel = LANG_LABELS[userLang] || userLang.toUpperCase();
+ const flags = data.self_check || {};
+ const cited = data.cited_law || [];
+ const isSameLang = userLang === 'no';
+ const draftNo = data.draft_no || '';
+ const draftUser = data.draft_user || '';
+ const jurLabel = data.jurisdiction === 'echr' ? 'ECHR (EMK + HUDOC)'
+ : data.jurisdiction === 'both' ? 'Norwegian + ECHR'
+ : 'Norwegian law';
+
+ const flagBadge = (key, label) => {
+ const v = flags[key] || 'ok';
+ const cls = v === 'ok' ? 'is-ok' : (v === 'warn' ? 'is-warn' : 'is-error');
+ const icon = v === 'ok' ? '✓' : '!';
+ return `${icon} ${esc(label)}`;
+ };
+
+ slot.innerHTML = `
+
+
+
Refined · ${esc(jurLabel)}
+
+ ${flagBadge('citations_verified', 'Citations verified')}
+ ${flagBadge('deadline_mentioned', 'Deadline')}
+ ${flagBadge('goal_addressed', 'Goal addressed')}
+
+
+
+
+
+
+
Norsk (bokmål) — refined
+
+
+
+
+
+
${esc(draftNo)}
+
+ ${isSameLang ? '' : `
+
+
+
${esc(userLangLabel)} — refined
+
+
+
+
+
+
${esc(draftUser)}
+
`}
+
+
+ ${cited.length ? `
+
+ Cited authorities (${cited.length}) — ${esc(jurLabel)}
+
+ ${cited.map((s) => `
+
+
[${s.n}] ${esc(s.title)}${s.section ? ' — ' + esc(s.section) : ''}${s.authority_type ? ' (' + esc(s.authority_type) + ')' : ''}
+
${esc(s.excerpt || '')}
+ ${s.source_url ? `
View source` : ''}
+
+ `).join('')}
+
` : ''}
+