// ── Global 401 Handler ──

(function() {
  var _origFetch = window.fetch;
  window.fetch = function(url, opts) {
    return _origFetch.apply(this, arguments).then(function(resp) {
      if (resp.status === 401 && typeof url === 'string' && !url.includes('/api/auth/')) {
        if (typeof currentPage !== 'undefined' && currentPage !== 'login') {
          navigateTo('login');
        }
      }
      return resp;
    });
  };
})();

// ── Auth API ──

async function apiLogin(username, password) {
  const resp = await fetch('/api/auth/login', {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({ username, password })
  });
  if (!resp.ok) {
    const err = await resp.json();
    throw new Error(err.error || 'Login failed');
  }
  return resp.json();
}

async function apiLogout() {
  await fetch('/api/auth/logout', { method: 'POST' });
}

async function apiMe() {
  const resp = await fetch('/api/auth/me');
  if (!resp.ok) return null;
  return resp.json();
}

// ── API Calls ──

async function apiChat(messages, sessionId, signal) {
  return fetch('/api/chat', {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({ messages, sessionId }),
    signal
  });
}

// ── Agent API ──

async function apiGetAgents() {
  const resp = await fetch('/api/agents');
  return resp.json();
}

async function apiGetAgent(agentId) {
  const resp = await fetch(`/api/agents/${agentId}`);
  if (!resp.ok) return null;
  return resp.json();
}

async function apiCreateAgent(data) {
  const resp = await fetch('/api/agents', {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify(data)
  });
  return resp.json();
}

async function apiUpdateAgent(agentId, data) {
  const resp = await fetch(`/api/agents/${agentId}`, {
    method: 'PUT',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify(data)
  });
  return resp.json();
}

async function apiDeleteAgent(agentId) {
  return fetch(`/api/agents/${agentId}`, { method: 'DELETE' });
}

async function apiHistory(sessionId, beforeId) {
  let url = `/api/history?sessionId=${sessionId}`;
  if (beforeId) url += `&beforeId=${beforeId}`;
  const resp = await fetch(url);
  return resp.json();
}

async function apiHistoryPoll(sessionId, afterId) {
  const resp = await fetch(`/api/history/poll?sessionId=${sessionId}&afterId=${afterId}`);
  return resp.json();
}

async function apiArchive(sessionId) {
  const resp = await fetch(`/api/archive?sessionId=${sessionId}`, { method: 'POST' });
  if (resp.status === 204) return null;
  return resp.json();
}

async function apiListArchives(sessionId) {
  const resp = await fetch(`/api/archives?sessionId=${sessionId}`);
  return resp.json();
}

async function apiGetArchive(archiveId) {
  const resp = await fetch(`/api/archive/${archiveId}`);
  return resp.json();
}

// ── Session API ──

async function apiGetSessions() {
  const resp = await fetch('/api/sessions');
  return resp.json();
}

async function apiCreateSession(data = {}) {
  const resp = await fetch('/api/sessions', {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify(data)
  });
  return resp.json();
}

async function apiGetSession(sessionId) {
  const resp = await fetch(`/api/sessions/${sessionId}`);
  if (!resp.ok) return null;
  return resp.json();
}

async function apiDeleteSession(sessionId) {
  return fetch(`/api/sessions/${sessionId}`, { method: 'DELETE' });
}

async function apiUpdateSession(sessionId, data) {
  const resp = await fetch(`/api/sessions/${sessionId}`, {
    method: 'PUT',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify(data)
  });
  return resp.json();
}

async function apiExecCommand(sessionId, command, mode = 'background') {
  const resp = await fetch(`/api/sessions/${sessionId}/exec`, {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({ command, mode })
  });
  if (mode === 'foreground') return resp.json();
  return resp;
}

async function apiGetSystemPrompt(sessionId) {
  const resp = await fetch(`/api/sessions/${sessionId}/system-prompt`);
  if (!resp.ok) throw new Error('System-Prompt konnte nicht geladen werden');
  return resp.text();
}

async function apiGetSystemPromptBlocks(sessionId) {
  const resp = await fetch(`/api/sessions/${sessionId}/system-prompt-blocks`);
  if (!resp.ok) throw new Error('System-Prompt konnte nicht geladen werden');
  return resp.json();
}

async function apiIsStreaming(sessionId) {
  const resp = await fetch(`/api/sessions/${sessionId}/streaming`);
  return resp.json();
}

async function apiGetChain(chainId) {
  const resp = await fetch(`/api/chains/${chainId}`);
  if (!resp.ok) return null;
  return resp.json();
}

async function apiToggleMessageMark(messageId) {
  const resp = await fetch(`/api/messages/${messageId}/mark`, { method: 'PUT' });
  return resp.json();
}

async function apiGitStatus(sessionId) {
  const resp = await fetch(`/api/sessions/${sessionId}/git-status`);
  if (!resp.ok) return null;
  return resp.json();
}

// ── Skills API ──

async function apiGetSkills() {
  const resp = await fetch('/api/skills');
  return resp.json();
}

async function apiGetAgentSkills(agentId) {
  const resp = await fetch(`/api/agents/${agentId}/skills`);
  return resp.json();
}

async function apiSetAgentSkills(agentId, skills) {
  const resp = await fetch(`/api/agents/${agentId}/skills`, {
    method: 'PUT',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({ skills })
  });
  return resp.json();
}

async function apiAddAgentSkill(agentId, slug) {
  return fetch(`/api/agents/${agentId}/skills/${slug}`, { method: 'POST' });
}

async function apiRemoveAgentSkill(agentId, slug) {
  return fetch(`/api/agents/${agentId}/skills/${slug}`, { method: 'DELETE' });
}

// ── Profile API ──

async function apiGetProfile() {
  const resp = await fetch('/api/profile');
  if (!resp.ok) return null;
  return resp.json();
}

async function apiUpdateProfile(data) {
  const resp = await fetch('/api/profile', {
    method: 'PUT',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify(data)
  });
  if (!resp.ok) {
    const err = await resp.json();
    throw new Error(err.error || 'Fehler beim Speichern');
  }
  return resp.json();
}

async function apiChangePassword(currentPassword, newPassword) {
  const resp = await fetch('/api/profile/password', {
    method: 'PUT',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({ currentPassword, newPassword })
  });
  if (!resp.ok) {
    const err = await resp.json();
    throw new Error(err.error || 'Fehler beim Ändern');
  }
  return resp.json();
}

async function apiTelegramStatus() {
  const resp = await fetch('/api/telegram/status');
  if (!resp.ok) return { configured: false };
  return resp.json();
}

async function apiTelegramLink(sessionId) {
  const resp = await fetch('/api/telegram/link', {
    method: 'POST',
    credentials: 'include',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({ sessionId })
  });
  if (!resp.ok) {
    const err = await resp.json().catch(() => ({}));
    throw new Error(err.error || 'Telegram-Link fehlgeschlagen');
  }
  return resp.json();
}

async function apiTelegramWebhookInfo() {
  const resp = await fetch('/api/telegram/webhook-info', { credentials: 'include' });
  if (!resp.ok) throw new Error('Webhook-Info fehlgeschlagen');
  return resp.json();
}

async function apiTelegramRegisterWebhook(baseUrl) {
  const resp = await fetch('/api/telegram/register-webhook', {
    method: 'POST',
    credentials: 'include',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({ baseUrl })
  });
  if (!resp.ok) throw new Error('Webhook-Registrierung fehlgeschlagen');
  return resp.json();
}

async function apiTelegramDeleteWebhook() {
  const resp = await fetch('/api/telegram/webhook', { method: 'DELETE', credentials: 'include' });
  if (!resp.ok) throw new Error('Webhook-Löschung fehlgeschlagen');
  return resp.json();
}

async function apiBackupDb() {
  const resp = await fetch('/api/backup', { method: 'POST', credentials: 'include' });
  if (!resp.ok) throw new Error('Backup fehlgeschlagen');
  const blob = await resp.blob();
  const cd = resp.headers.get('content-disposition') || '';
  const filename = cd.match(/filename\*=UTF-8''(.+?)(?:;|$)/i)?.[1]
    || cd.match(/filename="?([^";]+)"?/)?.[1]
    || 'gott-backup.tar.gz';
  const url = URL.createObjectURL(blob);
  const a = document.createElement('a');
  a.href = url;
  a.download = filename;
  document.body.appendChild(a);
  a.click();
  a.remove();
  URL.revokeObjectURL(url);
}