-
-
-
-
-
-
-
-
-
- )
+export default async function ReceiptsPage() {
+ // Hard gate: if the invoice-inbox extension isn't loaded, there's no
+ // upload pipeline and nothing would work here.
+ if (!ENABLED_EXTENSION_IDS.has('invoice-inbox')) notFound()
+
+ const supabase = await createClient()
+ const { data: { user } } = await supabase.auth.getUser()
+ if (!user) redirect('/login')
+
+ const companyId = await requireCompanyId(supabase, user.id)
+
+ const { data } = await supabase
+ .from('invoice_inbox_items')
+ .select('*, document:document_attachments!document_id(*)')
+ .eq('company_id', companyId)
+ .eq('document_type', 'receipt')
+ .order('created_at', { ascending: false })
+ .limit(200)
+
+ const rows = (data ?? []) as ReceiptRow[]
+
+ // Batch-sign all document paths so each row renders with a thumbnail.
+ // Supabase exposes createSignedUrls (plural) for exactly this use case.
+ const paths = rows
+ .map((r) => r.document?.storage_path)
+ .filter((p): p is string => Boolean(p))
+
+ const urlByPath = new Map
-
+export type ReceiptRow = InvoiceInboxItem & { document: DocumentAttachment | null }
+export type ReceiptRowWithPreview = ReceiptRow & { preview_url: string | null }
- Kvitton
-- Hantera och granska dina kvitton -
-- Kvittoscanning är inte tillgängligt just nu. -
-
+
+
+
+
+
+ )}
{/* Voucher series — read-only display */}
diff --git a/app/api/ai/backfill/cancel/route.ts b/app/api/ai/backfill/cancel/route.ts
new file mode 100644
index 00000000..8bd09db5
--- /dev/null
+++ b/app/api/ai/backfill/cancel/route.ts
@@ -0,0 +1,38 @@
+import { NextResponse } from 'next/server'
+import { createClient } from '@/lib/supabase/server'
+import { ensureInitialized } from '@/lib/init'
+import { requireCompanyId } from '@/lib/company/context'
+import { requireWritePermission } from '@/lib/auth/require-write'
+import { gateAgentInbox } from '@/lib/ai/feature-flag'
+
+ensureInitialized()
+
+/**
+ * POST /api/ai/backfill/cancel
+ *
+ * Set the kill switch flag on company_settings. The running backfill loop
+ * checks this between items and exits cleanly. Already-generated proposals
+ * stay — the cancel just stops further generation.
+ */
+export async function POST() {
+ const gate = gateAgentInbox()
+ if (gate) return gate
+
+ const supabase = await createClient()
+ const { data: { user } } = await supabase.auth.getUser()
+ if (!user) return NextResponse.json({ error: 'Unauthorized' }, { status: 401 })
+
+ const writeCheck = await requireWritePermission(supabase, user.id)
+ if (!writeCheck.ok) return writeCheck.response
+
+ const companyId = await requireCompanyId(supabase, user.id)
+
+ const { error } = await supabase
+ .from('company_settings')
+ .update({ ai_backfill_cancel_requested: true })
+ .eq('company_id', companyId)
+
+ if (error) return NextResponse.json({ error: error.message }, { status: 500 })
+
+ return NextResponse.json({ data: { cancelled: true } })
+}
diff --git a/app/api/ai/backfill/receipts/route.ts b/app/api/ai/backfill/receipts/route.ts
new file mode 100644
index 00000000..b45a6075
--- /dev/null
+++ b/app/api/ai/backfill/receipts/route.ts
@@ -0,0 +1,222 @@
+import { NextResponse } from 'next/server'
+import { createClient as createServiceClient } from '@supabase/supabase-js'
+import { createClient } from '@/lib/supabase/server'
+import { ensureInitialized } from '@/lib/init'
+import { requireCompanyId } from '@/lib/company/context'
+import { requireWritePermission } from '@/lib/auth/require-write'
+import {
+ generateMatchProposalFor,
+ generateBookingProposalFor,
+} from '@/lib/ai/orchestrator'
+import { gateAgentInbox } from '@/lib/ai/feature-flag'
+import type {
+ InvoiceInboxItem,
+ Transaction,
+ CategorizationTemplate,
+} from '@/types'
+import type { SupabaseClient } from '@supabase/supabase-js'
+
+ensureInitialized()
+
+/**
+ * POST /api/ai/backfill/receipts
+ *
+ * Generate AI proposals for the existing receipt backlog:
+ * - inbox items with document_type='receipt' and status='ready' that
+ * have no pending match proposal → generate match
+ * - items with matched_transaction_id and no booked journal entry but
+ * no pending booking proposal → generate booking
+ *
+ * Fire-and-forget: returns immediately with `{ queued }`. The loop
+ * iterates in the background, checking `company_settings.ai_backfill_cancel_requested`
+ * between items so the user can stop it. Idempotent via the partial
+ * unique index on (subject, step) WHERE pending — re-clicking does no harm.
+ *
+ * NOTE: relies on long-lived Node/Vercel worker to complete the loop. For
+ * v1 dev-only this is acceptable; a proper job queue is a follow-up.
+ */
+export async function POST() {
+ const gate = gateAgentInbox()
+ if (gate) return gate
+
+ const supabase = await createClient()
+ const { data: { user } } = await supabase.auth.getUser()
+ if (!user) return NextResponse.json({ error: 'Unauthorized' }, { status: 401 })
+
+ const writeCheck = await requireWritePermission(supabase, user.id)
+ if (!writeCheck.ok) return writeCheck.response
+
+ const companyId = await requireCompanyId(supabase, user.id)
+
+ // Gate on the per-company flag.
+ const { data: settings } = await supabase
+ .from('company_settings')
+ .select('ai_flow_enabled, ai_backfill_cancel_requested')
+ .eq('company_id', companyId)
+ .maybeSingle()
+
+ if (!settings?.ai_flow_enabled) {
+ return NextResponse.json(
+ { error: 'AI-agenten är inte aktiverad.' },
+ { status: 400 }
+ )
+ }
+
+ // Reset the cancel flag so a previous cancel doesn't kill this run.
+ await supabase
+ .from('company_settings')
+ .update({ ai_backfill_cancel_requested: false })
+ .eq('company_id', companyId)
+
+ // Count eligible items up front for the response.
+ const { data: eligibleMatch } = await supabase
+ .from('invoice_inbox_items')
+ .select('id')
+ .eq('company_id', companyId)
+ .eq('document_type', 'receipt')
+ .eq('status', 'ready')
+ .is('matched_transaction_id', null)
+
+ const { data: eligibleBooking } = await supabase
+ .from('invoice_inbox_items')
+ .select('id')
+ .eq('company_id', companyId)
+ .eq('document_type', 'receipt')
+ .eq('status', 'ready')
+ .not('matched_transaction_id', 'is', null)
+
+ const matchCount = eligibleMatch?.length ?? 0
+ const bookingCount = eligibleBooking?.length ?? 0
+
+ // Kick off the background loop. Intentionally NOT awaited.
+ runBackfill(companyId, user.id).catch((err) => {
+ console.error('[ai/backfill/receipts] loop failed:', err)
+ })
+
+ return NextResponse.json({
+ data: {
+ queued_match: matchCount,
+ queued_booking: bookingCount,
+ },
+ })
+}
+
+/**
+ * Run the backfill loop using a service-role client so the orchestrator's
+ * inserts bypass RLS (mirrors how orchestrator writes from event handlers).
+ */
+async function runBackfill(companyId: string, userId: string): Promise
+
+
+
+
+
+
+ + När aktiv: varje ny banktransaktion blir ett AI-förslag du granskar i + agent-inkorgen. + Den automatiska bokföringen (≥80% regelmatchning) stängs av — inget bokförs + utan din bekräftelse. +
+Source documents required for receipt and transaction mapping
++ ${senderName ? `${senderName} ` : ''}behöver ett kvittounderlag för ${companyName} innan en transaktion kan bokföras. +
++ ${summaryLine || 'Kvitto utan extraherade uppgifter'} +
+Öppna agent-inkorgen och ladda upp en tydlig bild eller PDF av kvittot:
+ ++ Send in receipts. Utan källunderlag kan bokföringen inte slutföras enligt BFL 5 kap 7§. +
+` +} + +function buildText({ companyName, summaryLine, deepLink, senderName }: TemplateArgs): string { + return [ + 'Source documents required for receipt and transaction mapping.', + '', + `${senderName ? `${senderName} ` : ''}behöver ett kvittounderlag för ${companyName} innan en transaktion kan bokföras.`, + '', + summaryLine || 'Kvitto utan extraherade uppgifter', + '', + 'Öppna agent-inkorgen och ladda upp en tydlig bild eller PDF av kvittot:', + deepLink, + '', + 'Send in receipts. Utan källunderlag kan bokföringen inte slutföras enligt BFL 5 kap 7§.', + ].join('\n') +} diff --git a/app/api/ai/learning/remember/route.ts b/app/api/ai/learning/remember/route.ts new file mode 100644 index 00000000..b6051611 --- /dev/null +++ b/app/api/ai/learning/remember/route.ts @@ -0,0 +1,127 @@ +import { NextResponse } from 'next/server' +import { createClient } from '@/lib/supabase/server' +import { ensureInitialized } from '@/lib/init' +import { validateBody } from '@/lib/api/validate' +import { RememberLearningSchema } from '@/lib/api/schemas' +import { requireCompanyId } from '@/lib/company/context' +import { requireWritePermission } from '@/lib/auth/require-write' +import { calculateConfidence } from '@/lib/bookkeeping/counterparty-templates' +import { gateAgentInbox } from '@/lib/ai/feature-flag' +import type { AIProposal } from '@/types' + +ensureInitialized() + +/** + * POST /api/ai/learning/remember + * + * Called from the UI's learning-prompt dialog after a user edited and + * accepted an AI booking proposal. Upserts a categorization_templates row + * with source='ai_corrected' so next time's proposal for the same + * counterparty starts from the user's preference. + * + * This is the ONLY path that creates an ai_corrected template — the + * "silent learning" rule means every template with this source represents + * an explicit user choice. + */ +export async function POST(request: Request) { + const gate = gateAgentInbox() + if (gate) return gate + + const supabase = await createClient() + const { data: { user } } = await supabase.auth.getUser() + if (!user) return NextResponse.json({ error: 'Unauthorized' }, { status: 401 }) + + const writeCheck = await requireWritePermission(supabase, user.id) + if (!writeCheck.ok) return writeCheck.response + + const companyId = await requireCompanyId(supabase, user.id) + + const validation = await validateBody(request, RememberLearningSchema) + if (!validation.success) return validation.response + const { + proposal_id, + counterparty_name, + debit_account, + credit_account, + vat_treatment, + category, + } = validation.data + + // Verify the proposal is accepted + belongs to this company. + const { data: proposal } = await supabase + .from('ai_proposals') + .select('*') + .eq('id', proposal_id) + .eq('company_id', companyId) + .maybeSingle() + + if (!proposal) return NextResponse.json({ error: 'Not found' }, { status: 404 }) + const typed = proposal as AIProposal + if (typed.status !== 'accepted') { + return NextResponse.json( + { error: 'Endast accepterade förslag kan lagras som mall.' }, + { status: 400 } + ) + } + if (typed.step_type !== 'booking') { + return NextResponse.json( + { error: 'Endast bokföringssteget kan lagras som mall.' }, + { status: 400 } + ) + } + + // Upsert the template. Existing row for the same (user_id, counterparty_name) + // gets its source bumped up and occurrence incremented. + const { data: existing } = await supabase + .from('categorization_templates') + .select('*') + .eq('user_id', user.id) + .eq('counterparty_name', counterparty_name) + .maybeSingle() + + const today = new Date().toISOString().slice(0, 10) + + if (existing) { + const newOccurrence = existing.occurrence_count + 1 + await supabase + .from('categorization_templates') + .update({ + debit_account, + credit_account, + vat_treatment, + category, + source: 'ai_corrected', + occurrence_count: newOccurrence, + confidence: calculateConfidence(newOccurrence), + last_seen_date: today, + is_active: true, + }) + .eq('id', existing.id) + + return NextResponse.json({ data: { template_id: existing.id, updated: true } }) + } + + const { data: created, error: insertError } = await supabase + .from('categorization_templates') + .insert({ + user_id: user.id, + company_id: companyId, + counterparty_name, + counterparty_aliases: [counterparty_name], + debit_account, + credit_account, + vat_treatment, + category, + source: 'ai_corrected', + occurrence_count: 1, + confidence: calculateConfidence(1), + last_seen_date: today, + is_active: true, + }) + .select() + .single() + + if (insertError) return NextResponse.json({ error: insertError.message }, { status: 500 }) + + return NextResponse.json({ data: { template_id: created.id, updated: false } }) +} diff --git a/app/api/ai/proposals/[id]/accept/route.ts b/app/api/ai/proposals/[id]/accept/route.ts new file mode 100644 index 00000000..01d0c20e --- /dev/null +++ b/app/api/ai/proposals/[id]/accept/route.ts @@ -0,0 +1,248 @@ +import { NextResponse } from 'next/server' +import { createClient } from '@/lib/supabase/server' +import { eventBus } from '@/lib/events/bus' +import { ensureInitialized } from '@/lib/init' +import { validateBody } from '@/lib/api/validate' +import { AcceptProposalSchema } from '@/lib/api/schemas' +import { requireCompanyId } from '@/lib/company/context' +import { requireWritePermission } from '@/lib/auth/require-write' +import { reValidateProposal } from '@/lib/ai/proposals/re-validate' +import { applyProposal } from '@/lib/ai/proposals/apply' +import { bookkeepingErrorResponse } from '@/lib/bookkeeping/errors' +import { appendProcessingHistory } from '@/lib/processing-history/append' +import { gateAgentInbox } from '@/lib/ai/feature-flag' +import type { + AIProposal, + BookingProposalPayload, + InvoiceInboxItem, + MatchProposalPayload, +} from '@/types' + +ensureInitialized() + +/** + * POST /api/ai/proposals/[id]/accept + * + * Accept a pending proposal: + * 1. Optimistic lock on version to catch concurrent clicks. + * 2. Re-validate (period open, transaction still unbooked, accounts active). + * 3. Apply via lib/ai/proposals/apply.ts (engine call happens there). + * 4. Mark status='accepted', set applied_entry_id, bump version. + * 5. If `edits` provided and differ from proposal_json, record edit_diff + * and return a `learning_prompt` hint so the UI can ask + * "remember this booking for
+
+ {!backfillRunning ? (
+
+ ) : (
+
+ )}
+
+ }
+ />
+
+ {backfillProgress && (
+
+
+ Inga väntande förslag
++ När nya kvitton klassas i inkorgen kommer AI-förslagen att visas här. +
+
+
+ {selectedIds.size > 0 && (
+
+ )}
+
+ )}
+
+
+ {filteredItems.length === 0 && (
+
+
+ Inga kort i denna vy.
+
+
+ )}
+ {filteredItems.map((item) => {
+ if (item.proposal) {
+ return (
+ toggleSelect(item.proposal!.id)}
+ onAccept={() => handleAccept(item.proposal!)}
+ onReject={() => handleReject(item.proposal!)}
+ onEdit={() => setEditProposal(item.proposal!)}
+ onChangeMatch={() => setChangeMatchItem(item)}
+ />
+ )
+ }
+ if (item.request) {
+ return (
+ removeItem(null, item.request!.id)}
+ />
+ )
+ }
+ return null
+ })}
+
+
+ {selectedIds.size > 0 && (
+
+ {selectedIds.size} valda
+
+
+ )}
+
+ )}
+
+ {editProposal && (
+
+
+
+
+
+
+
+ {capped} av {progress.target}
+
+
+
+ + AI-agenten skapar förslag ett kvitto i taget. Nya kort dyker upp här automatiskt. +
+
+
+
+
+
+
+
+
+ {isMatch ? 'Match' : 'Bokföring'}
+
+ {confidenceLabel(proposal.confidence)}
+
+ {isUserEdited && (
+
+ Ändrad av användare
+
+ )}
+ {inbox.document && (
+
+ {inbox.document.file_name}
+
+ )}
+
+
+ {isMatch && matchPayload && (
+ + + Kvittobild saknas — ladda upp i kvittodialogen innan du kan godkänna. +
+ )} + +
+
+ {isMatch && onChangeMatch && (
+
+ )}
+ {!isMatch && (
+
+ )}
+
+
+
+
+ )
+}
+
+function ReasoningDisclosure({
+ reasoning,
+ alternatives,
+}: {
+ reasoning: string | null
+ alternatives?: MatchProposalPayload['alternatives']
+}) {
+ const [open, setOpen] = useState(false)
+ const hasReasoning = Boolean(reasoning)
+ const hasAlternatives = alternatives && alternatives.length > 0
+ if (!hasReasoning && !hasAlternatives) return null
+
+ return (
+
+
+
+ Föreslagen transaktion: {payload.matched_transaction_id}
+
+ )}
+
+
+ {open && (
+
+ )
+}
+
+function ReceiptBox({
+ inbox,
+}: {
+ inbox: AgentInboxItemView['inbox_item']
+}) {
+ const [open, setOpen] = useState(false)
+ const data = (inbox.extracted_data as {
+ merchant?: { name?: string | null }
+ receipt?: { date?: string | null; currency?: string | null }
+ totals?: { total?: number | null }
+ } | null) ?? {}
+ const merchant = data.merchant?.name ?? inbox.document?.file_name ?? 'Okänt kvitto'
+ const total = data.totals?.total ?? null
+ const currency = data.receipt?.currency ?? 'SEK'
+ const date = data.receipt?.date ?? null
+ const quality = assessReceiptQuality(inbox)
+ const hasFile = Boolean(inbox.document_id)
+ const needsAttention = !hasFile || !quality.ok
+
+ return (
+ <>
+
+
+ {reasoning && (
+
+ )}
+ “{reasoning}”
+ )} + {hasAlternatives && ( +-
+ {alternatives!.map((alt) => (
+
- + {Math.round(alt.confidence * 100)}% — {alt.reasoning} + + ))} +
+
+ )
+}
diff --git a/components/agent-inbox/ReceiptDetailDialog.tsx b/components/agent-inbox/ReceiptDetailDialog.tsx
new file mode 100644
index 00000000..d34672ec
--- /dev/null
+++ b/components/agent-inbox/ReceiptDetailDialog.tsx
@@ -0,0 +1,408 @@
+'use client'
+
+import { useEffect, useRef, useState } from 'react'
+import { useRouter } from 'next/navigation'
+import {
+ Dialog,
+ DialogContent,
+ DialogDescription,
+ DialogHeader,
+ DialogTitle,
+} from '@/components/ui/dialog'
+import { Badge } from '@/components/ui/badge'
+import { Button } from '@/components/ui/button'
+import { useToast } from '@/components/ui/use-toast'
+import { Loader2, ExternalLink, FileText, Upload, ImagePlus, MailPlus } from 'lucide-react'
+import { formatCurrency, formatDate } from '@/lib/utils'
+import type { AgentInboxItemView } from '@/app/(dashboard)/agent-inbox/page'
+import { assessReceiptQuality } from './receipt-quality'
+
+// Mirrors ReceiptExtractionResult, kept local + forgiving since legacy rows
+// may be sparse.
+interface ExtractedReceipt {
+ merchant?: {
+ name?: string | null
+ orgNumber?: string | null
+ vatNumber?: string | null
+ isForeign?: boolean
+ } | null
+ receipt?: {
+ date?: string | null
+ time?: string | null
+ currency?: string | null
+ } | null
+ totals?: {
+ subtotal?: number | null
+ vatAmount?: number | null
+ total?: number | null
+ } | null
+ lineItems?: Array<{
+ description?: string
+ quantity?: number
+ unitPrice?: number | null
+ lineTotal?: number
+ vatRate?: number | null
+ }> | null
+ flags?: {
+ isRestaurant?: boolean
+ isSystembolaget?: boolean
+ isForeignMerchant?: boolean
+ } | null
+}
+
+interface Props {
+ open: boolean
+ onOpenChange: (open: boolean) => void
+ inbox: AgentInboxItemView['inbox_item']
+}
+
+export default function ReceiptDetailDialog({ open, onOpenChange, inbox }: Props) {
+ const data = (inbox.extracted_data as ExtractedReceipt | null) ?? {}
+ const merchant = data.merchant?.name ?? inbox.document?.file_name ?? 'Okänt kvitto'
+ const currency = data.receipt?.currency ?? 'SEK'
+ const lineItems = data.lineItems ?? []
+ const flags = data.flags ?? {}
+
+ // Lazily fetch a signed download URL so we can preview the file.
+ const [downloadUrl, setDownloadUrl] = useState
+
+
+
+
+ | Konto | +Debet | +Kredit | +
|---|---|---|
| + {line.account_number}{' '} + {line.description} + | ++ {line.debit_amount > 0 ? line.debit_amount.toFixed(2) : ''} + | ++ {line.credit_amount > 0 ? line.credit_amount.toFixed(2) : ''} + | +
| + {payload.vat_treatment && Moms: {payload.vat_treatment}} + {payload.default_private && Privat uttag} + | +{totalDebit.toFixed(2)} | +{totalDebit.toFixed(2)} | +
+
+
+
+
+ {REQUEST_LABEL[req.request_type]}
+ {item.inbox_item.document && (
+
+ {item.inbox_item.document.file_name}
+
+ )}
+
+ {req.message}
+
+ {action}
+
+
+
+
+ )
+ }
+ if (isImage && row.preview_url) {
+ // eslint-disable-next-line @next/next/no-img-element
+ return (
+
+
+ )
+}
+
+// Optimistic card shown while the upload request is in flight. Replaced by
+// the persisted row on router.refresh(). Keeps the page from looking empty
+// during the 5-10 s classify call.
+function PendingUploadCard({ upload }: { upload: PendingUpload }) {
+ return (
+
+
+
+
+
+
+
+ {upload.file_name}
+
+
+
+
+
+ Det här brukar ta 5–10 sekunder.
+
+
+ + AI läste {v.claude_total != null ? formatCurrency(v.claude_total, currency) : '—'}, OCR läste{' '} + {v.ocr_total != null ? formatCurrency(v.ocr_total, currency) : '—'}. Granska bilden innan du godkänner. +
+ ) +} + +// Optimistic placeholder shown in the list while a manual upload is in +// flight. The upload handler is synchronous (classify + store + insert +// happen before the response returns), so a 5-10 s gap otherwise leaves the +// user staring at nothing. We insert a fake row here so the UI shows a real +// card immediately and router.refresh() replaces it with the persisted row. +interface PendingUpload { + key: string + file_name: string + size_bytes: number + mime_type: string +} + +export default function ReceiptsList({ initialItems }: { initialItems: ReceiptRowWithPreview[] }) { + const [items, setItems] = useState(initialItems) + const [uploading, setUploading] = useState(false) + const [pendingUploads, setPendingUploads] = useState
+
+ {rescanCount > 0 && (
+
+ )}
+
+
+
+ }
+ />
+
+ {items.length === 0 && pendingUploads.length === 0 ? (
+
+
+ Inga kvitton än
++ Ladda upp ett kvitto (PDF, JPG, PNG, HEIC eller WebP) så tar AI hand om resten. +
+
+ {pendingUploads.map((upload) => (
+
+
+
+
+ )
+ })}
+
+ )}
+
+
+
+ {manualRow && (
+
+
+
+
+
+ {s.merchant}
+ {s.total != null && (
+
+ {formatCurrency(s.total, s.currency)}
+
+ )}
+
+
+
+ {(statusKey === 'processing' || statusKey === 'pending') && (
+
+
+ {row.error_message && (
+ {row.error_message}
+ )} +
+
+
+ )}
+ {!needsImage && canRescan && (
+
+
+
+
+ )}
+