const API_BASE = "/api";
const AUTH_BASE = "/auth";

async function request(endpoint, options = {}) {
  const response = await fetch(endpoint, {
    credentials: "include",
    headers: {
      "Content-Type": "application/json",
      ...options.headers,
    },
    ...options,
  });

  if (!response.ok) {
    const error = await response.text();
    throw new Error(error || `HTTP ${response.status}`);
  }

  return response.json();
}

export async function getURLMetadata(url) {
  return request(`${API_BASE}/url-metadata?url=${encodeURIComponent(url)}`);
}

export async function getAnnotationFeed(limit = 50, offset = 0) {
  return request(
    `${API_BASE}/annotations/feed?limit=${limit}&offset=${offset}`,
  );
}

export async function getAnnotations({
  source,
  motivation,
  limit = 50,
  offset = 0,
} = {}) {
  let url = `${API_BASE}/annotations?limit=${limit}&offset=${offset}`;
  if (source) url += `&source=${encodeURIComponent(source)}`;
  if (motivation) url += `&motivation=${motivation}`;
  return request(url);
}

export async function getByTarget(source, limit = 50, offset = 0) {
  return request(
    `${API_BASE}/targets?source=${encodeURIComponent(source)}&limit=${limit}&offset=${offset}`,
  );
}

export async function getAnnotation(uri) {
  return request(`${API_BASE}/annotation?uri=${encodeURIComponent(uri)}`);
}

export async function getUserAnnotations(did, limit = 50, offset = 0) {
  return request(
    `${API_BASE}/users/${encodeURIComponent(did)}/annotations?limit=${limit}&offset=${offset}`,
  );
}

export async function getUserHighlights(did, limit = 50, offset = 0) {
  return request(
    `${API_BASE}/users/${encodeURIComponent(did)}/highlights?limit=${limit}&offset=${offset}`,
  );
}

export async function getUserBookmarks(did, limit = 50, offset = 0) {
  return request(
    `${API_BASE}/users/${encodeURIComponent(did)}/bookmarks?limit=${limit}&offset=${offset}`,
  );
}

export async function getHighlights(creatorDid, limit = 50, offset = 0) {
  return request(
    `${API_BASE}/highlights?creator=${encodeURIComponent(creatorDid)}&limit=${limit}&offset=${offset}`,
  );
}

export async function getBookmarks(creatorDid, limit = 50, offset = 0) {
  return request(
    `${API_BASE}/bookmarks?creator=${encodeURIComponent(creatorDid)}&limit=${limit}&offset=${offset}`,
  );
}

export async function getReplies(annotationUri) {
  return request(
    `${API_BASE}/replies?uri=${encodeURIComponent(annotationUri)}`,
  );
}

export async function updateAnnotation(uri, text, tags) {
  return request(`${API_BASE}/annotations?uri=${encodeURIComponent(uri)}`, {
    method: "PUT",
    body: JSON.stringify({ text, tags }),
  });
}

export async function updateHighlight(uri, color, tags) {
  return request(`${API_BASE}/highlights?uri=${encodeURIComponent(uri)}`, {
    method: "PUT",
    body: JSON.stringify({ color, tags }),
  });
}

export async function createBookmark(url, title, description) {
  return request(`${API_BASE}/bookmarks`, {
    method: "POST",
    body: JSON.stringify({ url, title, description }),
  });
}

export async function updateBookmark(uri, title, description, tags) {
  return request(`${API_BASE}/bookmarks?uri=${encodeURIComponent(uri)}`, {
    method: "PUT",
    body: JSON.stringify({ title, description, tags }),
  });
}

export async function getCollections(did) {
  let url = `${API_BASE}/collections`;
  if (did) url += `?author=${encodeURIComponent(did)}`;
  return request(url);
}

export async function getCollectionsContaining(annotationUri) {
  return request(
    `${API_BASE}/collections/containing?uri=${encodeURIComponent(annotationUri)}`,
  );
}

export async function getEditHistory(uri) {
  return request(
    `${API_BASE}/annotations/history?uri=${encodeURIComponent(uri)}`,
  );
}

export async function getNotifications(limit = 50, offset = 0) {
  return request(`${API_BASE}/notifications?limit=${limit}&offset=${offset}`);
}

export async function getUnreadNotificationCount() {
  return request(`${API_BASE}/notifications/count`);
}

export async function markNotificationsRead() {
  return request(`${API_BASE}/notifications/read`, { method: "POST" });
}

export async function updateCollection(uri, name, description, icon) {
  return request(`${API_BASE}/collections?uri=${encodeURIComponent(uri)}`, {
    method: "PUT",
    body: JSON.stringify({ name, description, icon }),
  });
}

export async function createCollection(name, description, icon) {
  return request(`${API_BASE}/collections`, {
    method: "POST",
    body: JSON.stringify({ name, description, icon }),
  });
}

export async function deleteCollection(uri) {
  return request(`${API_BASE}/collections?uri=${encodeURIComponent(uri)}`, {
    method: "DELETE",
  });
}

export async function getCollectionItems(collectionUri) {
  return request(
    `${API_BASE}/collections/${encodeURIComponent(collectionUri)}/items`,
  );
}

export async function addItemToCollection(
  collectionUri,
  annotationUri,
  position = 0,
) {
  return request(
    `${API_BASE}/collections/${encodeURIComponent(collectionUri)}/items`,
    {
      method: "POST",
      body: JSON.stringify({ annotationUri, position }),
    },
  );
}

export async function removeItemFromCollection(itemUri) {
  return request(
    `${API_BASE}/collections/items?uri=${encodeURIComponent(itemUri)}`,
    {
      method: "DELETE",
    },
  );
}

export async function getLikeCount(annotationUri) {
  return request(`${API_BASE}/likes?uri=${encodeURIComponent(annotationUri)}`);
}

export async function deleteHighlight(rkey) {
  return request(`${API_BASE}/highlights?rkey=${encodeURIComponent(rkey)}`, {
    method: "DELETE",
  });
}

export async function deleteBookmark(rkey) {
  return request(`${API_BASE}/bookmarks?rkey=${encodeURIComponent(rkey)}`, {
    method: "DELETE",
  });
}

export async function createAnnotation({ url, text, quote, title, selector }) {
  return request(`${API_BASE}/annotations`, {
    method: "POST",
    body: JSON.stringify({ url, text, quote, title, selector }),
  });
}

export async function deleteAnnotation(rkey, type = "annotation") {
  return request(
    `${API_BASE}/annotations?rkey=${encodeURIComponent(rkey)}&type=${encodeURIComponent(type)}`,
    {
      method: "DELETE",
    },
  );
}

export async function likeAnnotation(subjectUri, subjectCid) {
  return request(`${API_BASE}/annotations/like`, {
    method: "POST",
    headers: {
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      subjectUri,
      subjectCid,
    }),
  });
}

export async function unlikeAnnotation(subjectUri) {
  return request(
    `${API_BASE}/annotations/like?uri=${encodeURIComponent(subjectUri)}`,
    {
      method: "DELETE",
    },
  );
}

export async function createReply({
  parentUri,
  parentCid,
  rootUri,
  rootCid,
  text,
}) {
  return request(`${API_BASE}/annotations/reply`, {
    method: "POST",
    body: JSON.stringify({ parentUri, parentCid, rootUri, rootCid, text }),
  });
}

export async function deleteReply(uri) {
  return request(
    `${API_BASE}/annotations/reply?uri=${encodeURIComponent(uri)}`,
    {
      method: "DELETE",
    },
  );
}

export async function getSession() {
  return request(`${AUTH_BASE}/session`);
}

export async function logout() {
  return request(`${AUTH_BASE}/logout`, { method: "POST" });
}

export function normalizeAnnotation(item) {
  if (!item) return {};

  if (item.type === "Annotation") {
    return {
      uri: item.id,
      author: item.creator,
      url: item.target?.source,
      title: item.target?.title,
      text: item.body?.value,
      selector: item.target?.selector,
      motivation: item.motivation,
      tags: item.tags || [],
      createdAt: item.created,
      cid: item.cid || item.CID,
    };
  }

  if (item.type === "Bookmark") {
    return {
      uri: item.id,
      author: item.creator,
      url: item.source,
      title: item.title,
      description: item.description,
      tags: item.tags || [],
      createdAt: item.created,
      cid: item.cid || item.CID,
    };
  }

  if (item.type === "Highlight") {
    return {
      uri: item.id,
      author: item.creator,
      url: item.target?.source,
      title: item.target?.title,
      selector: item.target?.selector,
      color: item.color,
      tags: item.tags || [],
      createdAt: item.created,
      cid: item.cid || item.CID,
    };
  }

  return {
    uri: item.uri || item.id,
    author: item.author || item.creator,
    url: item.url || item.source || item.target?.source,
    title: item.title || item.target?.title,
    text: item.text || item.body?.value,
    description: item.description,
    selector: item.selector || item.target?.selector,
    color: item.color,
    tags: item.tags || [],
    createdAt: item.createdAt || item.created,
    cid: item.cid || item.CID,
  };
}

export function normalizeHighlight(highlight) {
  return {
    uri: highlight.id,
    author: highlight.creator,
    url: highlight.target?.source,
    title: highlight.target?.title,
    selector: highlight.target?.selector,
    color: highlight.color,
    tags: highlight.tags || [],
    createdAt: highlight.created,
  };
}

export function normalizeBookmark(bookmark) {
  return {
    uri: bookmark.id,
    author: bookmark.creator,
    url: bookmark.source,
    title: bookmark.title,
    description: bookmark.description,
    tags: bookmark.tags || [],
    createdAt: bookmark.created,
  };
}

export async function searchActors(query) {
  const res = await fetch(
    `https://public.api.bsky.app/xrpc/app.bsky.actor.searchActorsTypeahead?q=${encodeURIComponent(query)}&limit=5`,
  );
  if (!res.ok) throw new Error("Search failed");
  return res.json();
}

export async function startLogin(handle, inviteCode) {
  return request(`${AUTH_BASE}/start`, {
    method: "POST",
    body: JSON.stringify({ handle, invite_code: inviteCode }),
  });
}