nexarch/web/datev-export/lib/api.ts

// Duenner Client fuer DAT-03 (connect/internal/datevapi) — enthaelt keine
// eigene Geschaeftslogik, nur Datenabruf/-versand. Identitaet kommt
// uebergangsweise (wie bei web/connect-status) aus Umgebungsvariablen,
// die als Header durchgereicht werden.

export class UnauthorizedError extends Error {}
export class ApiError extends Error {}

function apiBase(): string {
  const base = process.env.NEXT_PUBLIC_CONNECT_API_URL;
  if (!base) {
    throw new Error("NEXT_PUBLIC_CONNECT_API_URL ist nicht gesetzt (Umgebungsvariable erforderlich)");
  }
  return base;
}

function identityHeaders(): Record<string, string> {
  const userID = process.env.NEXT_PUBLIC_USER_ID;
  const tenant = process.env.NEXT_PUBLIC_TENANT_SLUG;
  const headers: Record<string, string> = {};
  if (userID) headers["X-User-Id"] = userID;
  if (tenant) headers["X-Tenant-Slug"] = tenant;
  return headers;
}

async function req<T>(path: string, init?: RequestInit): Promise<T> {
  const res = await fetch(`${apiBase()}${path}`, {
    ...init,
    headers: {
      "Content-Type": "application/json",
      ...identityHeaders(),
      ...init?.headers,
    },
  });
  if (res.status === 401) {
    throw new UnauthorizedError("Anmeldung erforderlich, um DATEV-Exporte zu sehen.");
  }
  if (!res.ok) {
    const body = await res.json().catch(() => ({}));
    throw new ApiError(body.error ?? `Anfrage fehlgeschlagen (${res.status})`);
  }
  return res.json().catch(() => undefined as T);
}

export interface ExportEntry {
  Amount: number;
  DebitCredit: "S" | "H";
  Account: string;
  CounterAccount: string;
  Date: string;
  Text: string;
  DocumentRef: string;
}

export interface TriggerExportRequest {
  consultant_number: string;
  client_number: string;
  fiscal_year_start: string;
  account_length: number;
  description: string;
  period_start: string;
  period_end: string;
  entries: ExportEntry[];
}

export interface ExportRun {
  id: string;
  period_start: string;
  period_end: string;
  entry_count: number;
  retention_class: string;
  created_at: string;
  transfer_status?: string;
  transfer_error?: string;
}

export function triggerExport(req_: TriggerExportRequest): Promise<ExportRun> {
  return req("/datev/exports", { method: "POST", body: JSON.stringify(req_) });
}

export function fetchExportRuns(): Promise<ExportRun[]> {
  return req("/datev/exports");
}