\n \n \n\n",[],[260,262],"f9fc947e-9111-438d-bba5-734775151edb","Login.tsx","01a001de-e00b-7376-9430-657618f20e05","01a001de-e00b-7376-9430-69e64d25a08e",["D",1786737778590],"/** @jsxImportSource https://esm.sh/react */\nimport React, { useState } from \"https://esm.sh/react\";\nexport function Login() {\n const [loading, setLoading] = useState(false);\n const [error, setError] = useState(null);\n const [handle, setHandle] = useState(\"\");\n\n const handleSubmit = (e: React.FormEvent) => {\n e.preventDefault();\n setLoading(true);\n setError(null);\n\n if (!handle.trim()) {\n setError(\"Please enter your Bluesky handle\");\n setLoading(false);\n return;\n }\n\n try {\n // Direct redirect to OAuth package's login endpoint with handle parameter\n globalThis.location.href = `/login?handle=${\n encodeURIComponent(handle.trim())\n }`;\n } catch (error) {\n console.error(\"Login failed:\", error);\n setError(\"Failed to start login process\");\n setLoading(false);\n }\n };\n\n return (\n

\n Login to Book Explorer\n

\n\n

\n {error && (\n

\n {error}\n

\n )}\n\n

\n \n Bluesky Handle\n \n {\n const target = e.target as HTMLInputElement;\n setHandle(target.value);\n }}\n placeholder=\"your-handle.bsky.social\"\n className=\"w-full px-3 py-2 border border-gray-300 rounded-lg focus:outline-none focus:ring-2 focus:ring-blue-500 focus:border-transparent\"\n disabled={loading}\n required\n />\n

\n Enter your Bluesky handle (with or without .bsky.social)\n

\n\n \n {loading ? \"Authenticating...\" : \"Login with Bluesky\"}\n \n \n\n

\n 📚 Book Explorer - Manage your Bluesky book collection\n

\n Uses OAuth for secure authentication. Only you can access and modify\n your book records.\n

\n );\n}\n",[],[260,276,269],"components","683d25f3-5f9f-43dc-a8d4-d84311070549","App.tsx","01a001de-e00b-7376-9430-632b012af108",["D",1786737778590],"/** @jsxImportSource https://esm.sh/react */\nimport React, { useEffect, useState } from \"https://esm.sh/react\";\nimport type {\n AtProtoRecord,\n BookStatus,\n OAuthSession,\n} from \"../../shared/types.ts\";\nimport { STATUS_LABELS } from \"../../shared/types.ts\";\nimport { APP_CONFIG as _APP_CONFIG } from \"../../shared/config.ts\";\nimport { Login } from \"./Login.tsx\";\n\ninterface Toast {\n id: string;\n type: \"success\" | \"error\" | \"info\";\n message: string;\n timestamp: number;\n}\n\nexport function App() {\n const [books, setBooks] = useState([]);\n const [loading, setLoading] = useState(false);\n const [error, setError] = useState(null);\n const [session, setSession] = useState(null);\n const [selectedBooks, setSelectedBooks] = useState>(new Set());\n const [currentPage, setCurrentPage] = useState(0);\n const [showBulkActions, setShowBulkActions] = useState(false);\n const [toasts, setToasts] = useState([]);\n const [statusFilter, setStatusFilter] = useState(null);\n const [currentView, setCurrentView] = useState<\"books\" | \"tools\">(\"books\");\n const [showUserDropdown, setShowUserDropdown] = useState(false);\n\n const BOOKS_PER_PAGE = 50;\n\n const showToast = (type: Toast[\"type\"], message: string) => {\n const id = Date.now().toString();\n const toast: Toast = { id, type, message, timestamp: Date.now() };\n setToasts((prev) => [...prev, toast]);\n\n // Auto-remove after 5 seconds\n setTimeout(() => {\n setToasts((prev) => prev.filter((t) => t.id !== id));\n }, 5000);\n };\n\n const removeToast = (id: string) => {\n setToasts((prev) => prev.filter((t) => t.id !== id));\n };\n\n const logRequest = (method: string, url: string, data?: any) => {\n console.group(`🔄 API ${method} ${url}`);\n console.log(\"Timestamp:\", new Date().toISOString());\n if (data) console.log(\"Request body:\", data);\n };\n\n const logResponse = (\n _method: string,\n _url: string,\n response: Response,\n data?: any,\n ) => {\n console.log(`📥 Response: ${response.status} ${response.statusText}`);\n if (data) console.log(\"Response data:\", data);\n console.groupEnd();\n };\n\n const logError = (method: string, url: string, error: any) => {\n console.error(`❌ Request failed: ${method} ${url}`, error);\n console.groupEnd();\n };\n\n // Check authentication status on mount\n useEffect(() => {\n const checkAuth = async () => {\n try {\n const response = await fetch(\"/api/auth/session\");\n const data = await response.json();\n if (data.valid && data.did) {\n setSession({\n did: data.did,\n handle: data.handle || \"\",\n accessToken: \"\", // Not needed for cookie-based auth\n refreshToken: \"\", // Not needed for cookie-based auth\n pdsUrl: data.pdsUrl || \"\",\n });\n } else {\n setSession(null);\n }\n } catch (error) {\n console.error(\"Failed to check auth status:\", error);\n setSession(null);\n }\n };\n\n checkAuth();\n }, []);\n\n // No need to manage localStorage with cookie-based auth\n\n const handleLogout = () => {\n setSession(null);\n setBooks([]);\n setError(null);\n };\n\n const fetchBooks = async () => {\n if (!session) return;\n\n setLoading(true);\n setError(null);\n\n const url = `/api/books`;\n logRequest(\"GET\", url);\n\n try {\n // With cookie-based auth, no need for custom headers\n const response = await fetch(url, {\n credentials: \"include\", // Include cookies for authentication\n });\n const data = await response.json();\n\n logResponse(\"GET\", url, response, data);\n\n if (response.ok) {\n setBooks(data.books);\n showToast(\n \"success\",\n `Found ${data.books.length} books in your collection`,\n );\n } else {\n const errorMsg = data.error || \"Failed to fetch books\";\n setError(errorMsg);\n showToast(\"error\", errorMsg);\n }\n } catch (err) {\n const errorMsg = \"Network error occurred\";\n logError(\"GET\", url, err);\n setError(errorMsg);\n showToast(\"error\", errorMsg);\n } finally {\n setLoading(false);\n }\n };\n\n const updateBookStatus = async (uri: string, newStatus: BookStatus) => {\n if (!session) {\n showToast(\"error\", \"Please login to update book status\");\n return;\n }\n\n const url = `/api/books/${encodeURIComponent(uri)}/status`;\n const requestData = { status: newStatus };\n logRequest(\"PUT\", url, requestData);\n\n try {\n const response = await fetch(url, {\n method: \"PUT\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n credentials: \"include\", // Include cookies for authentication\n body: JSON.stringify(requestData),\n });\n\n const result = await response.json();\n logResponse(\"PUT\", url, response, result);\n\n if (response.ok) {\n // Update the local state\n setBooks((prevBooks) =>\n prevBooks.map((book) =>\n book.uri === uri\n ? { ...book, value: { ...book.value, status: newStatus } }\n : book\n )\n );\n\n // Find book title for better feedback\n const book = books.find((b) => b.uri === uri);\n const bookTitle = book?.value.title || \"Book\";\n showToast(\n \"success\",\n `Updated \"${bookTitle}\" to ${STATUS_LABELS[newStatus]}`,\n );\n } else {\n if (response.status === 401) {\n showToast(\"error\", \"Session expired. Please login again.\");\n handleLogout();\n } else {\n showToast(\n \"error\",\n `Failed to update status: ${result.error || \"Unknown error\"}`,\n );\n }\n }\n } catch (err) {\n logError(\"PUT\", url, err);\n showToast(\"error\", \"Failed to update book status - network error\");\n }\n };\n\n const updateBulkStatus = async (newStatus: BookStatus) => {\n if (!session || selectedBooks.size === 0) return;\n\n const count = selectedBooks.size;\n showToast(\"info\", `Updating ${count} book${count === 1 ? \"\" : \"s\"}...`);\n\n const uris = Array.from(selectedBooks);\n const results = await Promise.allSettled(\n uris.map((uri) => updateBookStatus(uri, newStatus)),\n );\n\n const successful = results.filter((r) => r.status === \"fulfilled\").length;\n const failed = results.filter((r) => r.status === \"rejected\").length;\n\n if (failed === 0) {\n showToast(\n \"success\",\n `Successfully updated ${successful} book${\n successful === 1 ? \"\" : \"s\"\n } to ${STATUS_LABELS[newStatus]}`,\n );\n } else if (successful === 0) {\n showToast(\n \"error\",\n `Failed to update all ${count} book${count === 1 ? \"\" : \"s\"}`,\n );\n } else {\n showToast(\n \"error\",\n `Updated ${successful} book${\n successful === 1 ? \"\" : \"s\"\n }, but ${failed} failed`,\n );\n }\n\n setSelectedBooks(new Set());\n setShowBulkActions(false);\n };\n\n const toggleBookSelection = (uri: string) => {\n const newSelected = new Set(selectedBooks);\n if (newSelected.has(uri)) {\n newSelected.delete(uri);\n } else {\n newSelected.add(uri);\n }\n setSelectedBooks(newSelected);\n setShowBulkActions(newSelected.size > 0);\n };\n\n const selectAllBooks = () => {\n const allUris = paginatedBooks.map((book) => book.uri);\n setSelectedBooks(new Set(allUris));\n setShowBulkActions(true);\n };\n\n const clearSelection = () => {\n setSelectedBooks(new Set());\n setShowBulkActions(false);\n };\n\n // Filter books based on status\n const filteredBooks = statusFilter\n ? books.filter((book) => book.value.status === statusFilter)\n : books;\n\n // Pagination logic\n const totalPages = Math.ceil(filteredBooks.length / BOOKS_PER_PAGE);\n const startIndex = currentPage * BOOKS_PER_PAGE;\n const paginatedBooks = filteredBooks.slice(\n startIndex,\n startIndex + BOOKS_PER_PAGE,\n );\n\n const goToPage = (page: number) => {\n setCurrentPage(Math.max(0, Math.min(page, totalPages - 1)));\n clearSelection(); // Clear selection when changing pages\n };\n\n const handleStatusFilterChange = (newStatusFilter: BookStatus | null) => {\n setStatusFilter(newStatusFilter);\n setCurrentPage(0); // Reset to first page when filter changes\n clearSelection(); // Clear selection when filter changes\n };\n\n // Auto-load books when session is available\n useEffect(() => {\n if (session) {\n fetchBooks();\n }\n }, [session]);\n\n // Show login screen if not authenticated\n if (!session) {\n return ;\n }\n\n return (\n

\n 📚 Book Explorer\n

\n setShowUserDropdown(!showUserDropdown)}\n className=\"flex items-center gap-2 px-4 py-2 text-sm text-gray-700 hover:bg-gray-100 rounded-lg transition-colors\"\n >\n Logged in as: {session.handle}\n \n \n \n \n {showUserDropdown && (\n

\n {\n setCurrentView(\"books\");\n setShowUserDropdown(false);\n }}\n className={`w-full text-left px-4 py-2 text-sm hover:bg-gray-100 ${\n currentView === \"books\" ? \"bg-gray-50 font-medium\" : \"\"\n }`}\n >\n 📚 My Books\n \n {\n setCurrentView(\"tools\");\n setShowUserDropdown(false);\n }}\n className={`w-full text-left px-4 py-2 text-sm hover:bg-gray-100 ${\n currentView === \"tools\" ? \"bg-gray-50 font-medium\" : \"\"\n }`}\n >\n 🔧 Tools\n \n

\n {\n handleLogout();\n setShowUserDropdown(false);\n }}\n className=\"w-full text-left px-4 py-2 text-sm text-red-600 hover:bg-red-50\"\n >\n Logout\n \n

\n )}\n

\n\n {currentView === \"tools\" ? : (\n <>\n {error && (\n

\n {error}\n

\n )}\n\n {books.length > 0 && (\n

\n My Books ({statusFilter\n ? `${filteredBooks.length} of ${books.length}`\n : books.length})\n

\n Page {currentPage + 1} of {totalPages} • Showing{\" \"}\n {paginatedBooks.length} books\n {statusFilter &&\n ` (filtered by ${STATUS_LABELS[statusFilter]})`}\n

\n\n \n\n {showBulkActions && (\n \n )}\n\n \n\n {totalPages > 1 && (\n \n )}\n

\n )}\n\n {!loading && books.length === 0 && (\n

📚

\n No books found\n

\n Your book collection will appear here once you add some books\n to your Bluesky profile.\n

\n )}\n \n )}\n

\n\n {/* Toast Container */}\n \n

\n );\n}\n\nconst statusOptions: BookStatus[] = [\n \"buzz.bookhive.defs#wantToRead\",\n \"buzz.bookhive.defs#reading\",\n \"buzz.bookhive.defs#finished\",\n \"buzz.bookhive.defs#abandoned\",\n \"buzz.bookhive.defs#owned\",\n];\n\nconst getStatusColor = (status: BookStatus) => {\n switch (status) {\n case \"buzz.bookhive.defs#finished\":\n return \"bg-green-100 text-green-800\";\n case \"buzz.bookhive.defs#reading\":\n return \"bg-blue-100 text-blue-800\";\n case \"buzz.bookhive.defs#wantToRead\":\n return \"bg-yellow-100 text-yellow-800\";\n case \"buzz.bookhive.defs#abandoned\":\n return \"bg-red-100 text-red-800\";\n case \"buzz.bookhive.defs#owned\":\n return \"bg-gray-100 text-gray-800\";\n default:\n return \"bg-gray-100 text-gray-800\";\n }\n};\n\ninterface BooksTableProps {\n books: AtProtoRecord[];\n selectedBooks: Set;\n onToggleSelection: (uri: string) => void;\n onSelectAll: () => void;\n onClearSelection: () => void;\n onStatusUpdate: (uri: string, status: BookStatus) => void;\n}\n\nfunction BooksTable({\n books,\n selectedBooks,\n onToggleSelection,\n onSelectAll,\n onClearSelection,\n onStatusUpdate,\n}: BooksTableProps) {\n const allSelected = books.length > 0 &&\n books.every((book) => selectedBooks.has(book.uri));\n const someSelected = selectedBooks.size > 0 && !allSelected;\n\n const handleSelectAll = () => {\n if (allSelected) {\n onClearSelection();\n } else {\n onSelectAll();\n }\n };\n\n return (\n

\n \n \n \n \n \n \n \n \n \n \n \n \n \n {books.map((record) => (\n \n ))}\n \n

\n {\n if (input) (input as any).indeterminate = someSelected;\n }}\n onChange={handleSelectAll}\n className=\"rounded border-gray-300 text-blue-600 focus:ring-blue-500\"\n />\n	\n Title\n	\n Author\n	\n Status\n	\n Added\n	\n Technical\n	\n Actions\n

\n );\n}\n\ninterface BookRowProps {\n record: AtProtoRecord;\n isSelected: boolean;\n onToggleSelection: (uri: string) => void;\n onStatusUpdate: (uri: string, status: BookStatus) => void;\n}\n\nfunction BookRow({\n record,\n isSelected,\n onToggleSelection,\n onStatusUpdate,\n}: BookRowProps) {\n const book = record.value;\n const currentStatus = book.status as BookStatus;\n const [showTechnical, setShowTechnical] = useState(false);\n\n return (\n \n \n onToggleSelection(record.uri)}\n className=\"rounded border-gray-300 text-blue-600 focus:ring-blue-500\"\n />\n \n \n \n {book.title}\n \n {book.stars && (\n

\n {\"★\".repeat(book.stars)} ({book.stars}/10)\n

\n )}\n \n \n \n {book.authors}\n \n \n \n \n {STATUS_LABELS[currentStatus] || currentStatus}\n \n \n \n

\n {new Date(book.createdAt).toLocaleDateString()}\n

\n {book.startedAt && (\n

\n Started: {new Date(book.startedAt).toLocaleDateString()}\n

\n )}\n {book.finishedAt && (\n

\n Finished: {new Date(book.finishedAt).toLocaleDateString()}\n

\n )}\n \n \n setShowTechnical(!showTechnical)}\n className=\"text-xs text-blue-600 hover:text-blue-800\"\n >\n {showTechnical ? \"Hide\" : \"Show\"}\n \n {showTechnical && (\n

URI: {record.uri.slice(-20)}...

CID: {record.cid.slice(-20)}...

Hive: {book.hiveId}

\n )}\n \n \n

\n {\n const target = e.target as HTMLSelectElement;\n onStatusUpdate(record.uri, target.value as BookStatus);\n }}\n className=\"text-xs border border-gray-300 rounded px-2 py-1 focus:outline-none focus:ring-1 focus:ring-blue-500\"\n >\n {statusOptions.map((status) => (\n \n ))}\n \n \n \n \n \n \n

\n \n \n );\n}\n\ninterface BulkActionsProps {\n selectedCount: number;\n onStatusUpdate: (status: BookStatus) => void;\n onClearSelection: () => void;\n}\n\nfunction BulkActions(\n { selectedCount, onStatusUpdate, onClearSelection }: BulkActionsProps,\n) {\n return (\n

\n {selectedCount} book{selectedCount === 1 ? \"\" : \"s\"} selected\n

\n Change status to:\n {statusOptions.map((status) => (\n onStatusUpdate(status)}\n className={`px-2 py-1 rounded text-xs ${\n getStatusColor(status)\n } hover:opacity-80`}\n >\n {STATUS_LABELS[status]}\n \n ))}\n \n Clear\n \n

\n );\n}\n\ninterface PaginationProps {\n currentPage: number;\n totalPages: number;\n onPageChange: (page: number) => void;\n}\n\nfunction Pagination(\n { currentPage, totalPages, onPageChange }: PaginationProps,\n) {\n const pages = [];\n const showPages = 5;\n let startPage = Math.max(0, currentPage - Math.floor(showPages / 2));\n const endPage = Math.min(totalPages - 1, startPage + showPages - 1);\n\n if (endPage - startPage < showPages - 1) {\n startPage = Math.max(0, endPage - showPages + 1);\n }\n\n for (let i = startPage; i <= endPage; i++) {\n pages.push(i);\n }\n\n return (\n

\n onPageChange(currentPage - 1)}\n disabled={currentPage === 0}\n className=\"px-3 py-1 border border-gray-300 rounded disabled:opacity-50 disabled:cursor-not-allowed hover:bg-gray-50\"\n >\n ← Prev\n \n\n {startPage > 0 && (\n <>\n onPageChange(0)}\n className=\"px-3 py-1 border border-gray-300 rounded hover:bg-gray-50\"\n >\n 1\n \n {startPage > 1 && ...}\n \n )}\n\n {pages.map((page) => (\n onPageChange(page)}\n className={`px-3 py-1 border rounded ${\n page === currentPage\n ? \"bg-blue-600 text-white border-blue-600\"\n : \"border-gray-300 hover:bg-gray-50\"\n }`}\n >\n {page + 1}\n \n ))}\n\n {endPage < totalPages - 1 && (\n <>\n {endPage < totalPages - 2 && (\n ...\n )}\n onPageChange(totalPages - 1)}\n className=\"px-3 py-1 border border-gray-300 rounded hover:bg-gray-50\"\n >\n {totalPages}\n \n \n )}\n\n onPageChange(currentPage + 1)}\n disabled={currentPage === totalPages - 1}\n className=\"px-3 py-1 border border-gray-300 rounded disabled:opacity-50 disabled:cursor-not-allowed hover:bg-gray-50\"\n >\n Next →\n \n

\n );\n}\n\ninterface ToastContainerProps {\n toasts: Toast[];\n onRemoveToast: (id: string) => void;\n}\n\nfunction ToastContainer({ toasts, onRemoveToast }: ToastContainerProps) {\n if (toasts.length === 0) return null;\n\n return (\n

\n {toasts.map((toast) => (\n \n ))}\n

\n );\n}\n\ninterface ToastMessageProps {\n toast: Toast;\n onRemove: (id: string) => void;\n}\n\nfunction ToastMessage({ toast, onRemove }: ToastMessageProps) {\n const getToastStyles = (type: Toast[\"type\"]) => {\n switch (type) {\n case \"success\":\n return \"bg-green-500 text-white\";\n case \"error\":\n return \"bg-red-500 text-white\";\n case \"info\":\n return \"bg-blue-500 text-white\";\n default:\n return \"bg-gray-500 text-white\";\n }\n };\n\n const getIcon = (type: Toast[\"type\"]) => {\n switch (type) {\n case \"success\":\n return \"✅\";\n case \"error\":\n return \"❌\";\n case \"info\":\n return \"ℹ️\";\n default:\n return \"📝\";\n }\n };\n\n return (\n \n

\n {getIcon(toast.type)}\n

{toast.message}

\n onRemove(toast.id)}\n className=\"text-white/80 hover:text-white ml-2 shrink-0\"\n >\n ✕\n \n \n );\n}\n\ninterface BookFilterProps {\n currentFilter: BookStatus | null;\n onFilterChange: (filter: BookStatus | null) => void;\n}\n\nfunction BookFilter({ currentFilter, onFilterChange }: BookFilterProps) {\n return (\n

\n \n Filter by status:\n \n {\n const target = e.target as HTMLSelectElement;\n onFilterChange(target.value as BookStatus || null);\n }}\n className=\"border border-gray-300 rounded-md px-3 py-1 text-sm focus:outline-none focus:ring-2 focus:ring-blue-500 focus:border-transparent\"\n >\n \n {statusOptions.map((status) => (\n \n ))}\n \n

\n\n {currentFilter && (\n onFilterChange(null)}\n className=\"px-3 py-1 text-sm bg-gray-100 text-gray-700 rounded-md hover:bg-gray-200 self-start sm:self-auto\"\n >\n Clear Filter\n \n )}\n\n {currentFilter && (\n

\n Showing books with status:{\" \"}\n \n {STATUS_LABELS[currentFilter]}\n \n

\n )}\n

\n );\n}\n\ninterface ToolsViewProps {\n showToast: (type: Toast[\"type\"], message: string) => void;\n}\n\nfunction ToolsView({ showToast }: ToolsViewProps) {\n const [csvFile, setCsvFile] = useState(null);\n const [processing, setProcessing] = useState(false);\n const [processingStatus, setProcessingStatus] = useState(\"\");\n const [results, setResults] = useState<\n {\n total: number;\n updated: number;\n failed: number;\n books: Array<{ title: string; status: string; success: boolean }>;\n } | null\n >(null);\n\n const handleFileChange = (e: React.ChangeEvent) => {\n const target = e.target as HTMLInputElement;\n if (target.files && target.files[0]) {\n setCsvFile(target.files[0]);\n setResults(null);\n }\n };\n\n const parseCsvFile = async (file: File): Promise => {\n const text = await file.text();\n const lines = text.split(\"\\n\");\n const headers = lines[0].split(\",\").map((h) => h.trim().replace(/\"/g, \"\"));\n\n const records = [];\n for (let i = 1; i < lines.length; i++) {\n if (!lines[i].trim()) continue;\n\n // Parse CSV line handling quoted values\n const values: string[] = [];\n let current = \"\";\n let inQuotes = false;\n\n for (let j = 0; j < lines[i].length; j++) {\n const char = lines[i][j];\n if (char === '\"') {\n inQuotes = !inQuotes;\n } else if (char === \",\" && !inQuotes) {\n values.push(current.trim());\n current = \"\";\n } else {\n current += char;\n }\n }\n values.push(current.trim());\n\n const record: any = {};\n headers.forEach((header, index) => {\n record[header] = values[index] || \"\";\n });\n records.push(record);\n }\n\n return records;\n };\n\n const processImport = async () => {\n if (!csvFile) {\n showToast(\"error\", \"Please select a CSV file first\");\n return;\n }\n\n setProcessing(true);\n setProcessingStatus(\"Parsing CSV file...\");\n\n try {\n // Parse CSV\n const csvRecords = await parseCsvFile(csvFile);\n\n // Filter for books with \"to-read\" status\n const toReadBooks = csvRecords.filter(\n (record) => record[\"Read Status\"] === \"to-read\",\n );\n\n if (toReadBooks.length === 0) {\n showToast(\"info\", \"No books with 'to-read' status found in the CSV\");\n setProcessing(false);\n return;\n }\n\n setProcessingStatus(\n `Found ${toReadBooks.length} books to update. Fetching your AT Protocol books...`,\n );\n\n // Fetch current books from AT Protocol\n const response = await fetch(\"/api/books\", {\n credentials: \"include\", // Include cookies for authentication\n });\n\n if (!response.ok) {\n throw new Error(\"Failed to fetch your books\");\n }\n\n const { books } = await response.json();\n\n // Match books by title and find those with \"wantToRead\" status\n const booksToUpdate = [];\n for (const csvBook of toReadBooks) {\n const csvTitle = csvBook.Title.toLowerCase().trim();\n const atProtoBook = books.find((b: AtProtoRecord) => {\n const bookTitle = b.value.title.toLowerCase().trim();\n return (\n bookTitle === csvTitle &&\n b.value.status === \"buzz.bookhive.defs#wantToRead\"\n );\n });\n\n if (atProtoBook) {\n booksToUpdate.push({\n uri: atProtoBook.uri,\n title: atProtoBook.value.title,\n csvTitle: csvBook.Title,\n });\n }\n }\n\n if (booksToUpdate.length === 0) {\n showToast(\n \"info\",\n \"No matching books found with 'Want to Read' status in your AT Protocol records\",\n );\n setProcessing(false);\n return;\n }\n\n setProcessingStatus(\n `Updating ${booksToUpdate.length} books to 'Finished' status...`,\n );\n\n // Update each book\n const updateResults = [];\n let successCount = 0;\n let failCount = 0;\n\n for (const book of booksToUpdate) {\n try {\n const updateResponse = await fetch(\n `/api/books/${encodeURIComponent(book.uri)}/status`,\n {\n method: \"PUT\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n credentials: \"include\", // Include cookies for authentication\n body: JSON.stringify({ status: \"buzz.bookhive.defs#finished\" }),\n },\n );\n\n if (updateResponse.ok) {\n successCount++;\n updateResults.push({\n title: book.title,\n status: \"Updated to Finished\",\n success: true,\n });\n } else {\n failCount++;\n updateResults.push({\n title: book.title,\n status: \"Failed to update\",\n success: false,\n });\n }\n } catch {\n failCount++;\n updateResults.push({\n title: book.title,\n status: \"Network error\",\n success: false,\n });\n }\n\n setProcessingStatus(\n `Processing: ${successCount + failCount} of ${booksToUpdate.length}`,\n );\n }\n\n setResults({\n total: booksToUpdate.length,\n updated: successCount,\n failed: failCount,\n books: updateResults,\n });\n\n if (successCount > 0) {\n showToast(\n \"success\",\n `Successfully updated ${successCount} book${\n successCount === 1 ? \"\" : \"s\"\n } to Finished status`,\n );\n }\n\n if (failCount > 0) {\n showToast(\n \"error\",\n `Failed to update ${failCount} book${failCount === 1 ? \"\" : \"s\"}`,\n );\n }\n } catch (error) {\n showToast(\n \"error\",\n `Import failed: ${\n error instanceof Error ? error.message : \"Unknown error\"\n }`,\n );\n } finally {\n setProcessing(false);\n setProcessingStatus(\"\");\n }\n };\n\n return (\n

\n 📚 StoryGraph Import Tool\n

\n This tool allows you to sync your StoryGraph reading status with\n your AT Protocol book records. It will:\n

Parse your StoryGraph export CSV file
Find books with \"to-read\" status in the CSV
\n Match them with books in your AT Protocol records that have \"Want\n to Read\" status\n
Update those matched books to \"Finished\" status

\n This is useful if you've been tracking your reading in StoryGraph\n and want to update your Bluesky/AT Protocol book statuses\n accordingly.\n

\n\n

\n \n Upload StoryGraph Export CSV\n \n \n {csvFile && (\n

\n Selected: {csvFile.name}\n

\n )}\n

\n\n \n {processing ? \"Processing...\" : \"Import and Update Books\"}\n \n\n {processingStatus && (\n

\n {processingStatus}\n

\n )}\n

\n\n {results && (\n

\n Import Results\n

\n {results.total}\n

Total Books

\n {results.updated}\n

Updated

\n {results.failed}\n

Failed

\n\n {results.books.length > 0 && (\n

\n Processed Books:\n

\n \n \n \n \n \n \n \n \n {results.books.map((book, index) => (\n \n \n \n \n ))}\n \n

\n Title\n	\n Status\n
\n {book.title}\n	\n \n {book.status}\n \n

\n )}\n

\n );\n}\n",[],[260,276,278],"0d198f15-b4d1-4583-b692-fa0b87feabe8",["D",1786737778590],[189,190],[260,276],"5dc70f47-d6b9-4be0-9d07-82e1d8b8097e",["D",1786737778590],[188,191,192],[260],"62fd22a0-3d11-4fee-8660-741c3e47895b","index.ts","01a001de-e00b-7376-9430-5eed517d205c",["D",1786737778590],"http","import { Hono } from \"https://esm.sh/hono\";\nimport { serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport { createATProtoOAuth } from \"jsr:@tijs/atproto-oauth-hono@^0.2.6\";\nimport type { BookStatus } from \"../shared/types.ts\";\nimport { APP_CONFIG } from \"../shared/config.ts\";\nimport { initializeTables } from \"./database/db.ts\";\nimport { storage } from \"./oauth/storage-adapter.ts\";\n\nconst app = new Hono();\n\n// Initialize database on startup\nawait initializeTables();\n\n// Create OAuth instance using the package\nconst oauth = createATProtoOAuth({\n baseUrl: APP_CONFIG.BASE_URL,\n cookieSecret: APP_CONFIG.COOKIE_SECRET || \"book-explorer-secret\",\n appName: APP_CONFIG.APP_NAME,\n sessionTtl: 60 * 60 * 24, // 24 hours for session validity\n storage,\n});\n\n// OAuth client metadata endpoint\napp.get(\"/client-metadata.json\", (c) => {\n const metadata = {\n \"client_id\": APP_CONFIG.CLIENT_ID,\n \"client_name\": APP_CONFIG.APP_NAME,\n \"client_uri\": APP_CONFIG.BASE_URL,\n \"redirect_uris\": [APP_CONFIG.REDIRECT_URI],\n \"scope\": \"atproto transition:generic\",\n \"grant_types\": [\"authorization_code\", \"refresh_token\"],\n \"response_types\": [\"code\"],\n \"application_type\": \"web\",\n \"token_endpoint_auth_method\": \"none\",\n \"dpop_bound_access_tokens\": true,\n };\n return c.json(metadata);\n});\n\n// Mount OAuth routes - workaround for type instantiation issue\ntry {\n // @ts-ignore - Type instantiation too deep but works at runtime\n app.route(\"/\", oauth.routes);\n console.log(\"✅ OAuth routes mounted successfully\");\n} catch (error) {\n console.error(\"❌ Failed to mount OAuth routes:\", error);\n console.error(\"Error details:\", error.message, error.stack);\n throw error; // Re-throw so we know about OAuth setup issues\n}\n\n// Serve frontend files\napp.get(\"/frontend/*\", (c) => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", (c) => serveFile(c.req.path, import.meta.url));\n\n// Test endpoint to verify server is working\napp.get(\"/api/health\", (c) => {\n return c.json({\n status: \"ok\",\n timestamp: new Date().toISOString(),\n oauth: !!oauth,\n routes: !!oauth.routes,\n });\n});\n\n// Serve the main HTML file for the root path\napp.get(\"/\", async (_c) => {\n const html = await serveFile(\"/frontend/index.html\", import.meta.url);\n return html;\n});\n\n// Helper function to get authenticated user DID from session\nasync function getAuthenticatedUserDid(\n c: any,\n): Promise<{ did: string; oauthSession: any } | null> {\n try {\n const { getIronSession, unsealData } = await import(\n \"npm:iron-session@8.0.4\"\n );\n\n const COOKIE_SECRET = APP_CONFIG.COOKIE_SECRET;\n let userDid: string | null = null;\n\n // Try Bearer token first (mobile)\n const authHeader = c.req.header(\"Authorization\");\n if (authHeader?.startsWith(\"Bearer \")) {\n try {\n const sealedToken = authHeader.slice(7);\n const sessionData = await unsealData(sealedToken, {\n password: COOKIE_SECRET,\n }) as { did: string };\n userDid = sessionData.did;\n } catch (err) {\n console.log(\"Bearer token authentication failed:\", err);\n }\n }\n\n // Fallback to cookie authentication (web)\n if (!userDid) {\n try {\n interface Session {\n did: string;\n }\n const session = await getIronSession(c.req.raw, c.res, {\n cookieName: \"sid\",\n password: COOKIE_SECRET,\n });\n userDid = session.did;\n\n // Extend session TTL if valid (sliding expiration)\n if (userDid) {\n await session.save();\n }\n } catch (err) {\n console.log(\"Cookie authentication failed:\", err);\n }\n }\n\n if (!userDid) {\n return null;\n }\n\n // Get OAuth session data using the sessions API\n const oauthSession = await oauth.sessions.getOAuthSession(userDid);\n if (!oauthSession) {\n return null;\n }\n\n return { did: userDid, oauthSession };\n } catch (error) {\n console.error(\"Failed to get authenticated user:\", error);\n return null;\n }\n}\n\n// API endpoint to fetch book records for the authorized user\napp.get(\"/api/books\", async (c) => {\n try {\n // Get the authenticated user's DID and OAuth session\n const authResult = await getAuthenticatedUserDid(c);\n\n if (!authResult) {\n return c.json({ error: \"Authentication required\" }, 401);\n }\n\n const { did: userDid, oauthSession } = authResult;\n\n // Fetch all book records using cursor pagination\n const allRecords = [];\n let cursor = undefined;\n\n do {\n const url = new URL(\n `${oauthSession.pdsUrl}/xrpc/com.atproto.repo.listRecords`,\n );\n url.searchParams.set(\"repo\", userDid);\n url.searchParams.set(\"collection\", \"buzz.bookhive.book\");\n url.searchParams.set(\"limit\", \"100\");\n if (cursor) {\n url.searchParams.set(\"cursor\", cursor);\n }\n\n // Use the OAuth session to make authenticated requests\n const response = await oauthSession.makeRequest(\"GET\", url.toString());\n\n if (!response.ok) {\n console.error(\"Failed to fetch book records:\", {\n status: response.status,\n statusText: response.statusText,\n url: url.toString(),\n });\n const errorText = await response.text();\n console.error(\"Error response body:\", errorText);\n break;\n }\n\n const data = await response.json();\n console.log(\"Fetched records batch:\", {\n count: data.records?.length || 0,\n cursor: data.cursor,\n });\n allRecords.push(...(data.records || []));\n cursor = data.cursor;\n\n if (!cursor || (data.records?.length || 0) === 0) {\n break;\n }\n } while (cursor);\n\n console.log(\"Total records found:\", allRecords.length);\n return c.json({ books: allRecords });\n } catch (error) {\n console.error(\"Failed to fetch books:\", error);\n return c.json({ error: \"Failed to fetch books\" }, 500);\n }\n});\n\n// API endpoint to update book status using OAuth authentication\napp.put(\"/api/books/:uri/status\", async (c) => {\n const uri = decodeURIComponent(c.req.param(\"uri\"));\n const { status }: { status: BookStatus } = await c.req.json();\n\n try {\n // Get the authenticated user's DID and OAuth session\n const authResult = await getAuthenticatedUserDid(c);\n\n if (!authResult) {\n return c.json({ error: \"Authentication required\" }, 401);\n }\n\n const { did: userDid, oauthSession } = authResult;\n\n // Parse the AT URI to get repo, collection, and rkey\n const uriMatch = uri.match(/at:\\/\\/([^\\/]+)\\/([^\\/]+)\\/(.+)/);\n if (!uriMatch) {\n return c.json({ error: \"Invalid AT URI format\" }, 400);\n }\n\n const [, repo, collection, rkey] = uriMatch;\n\n // Verify that the repo matches the authenticated user's DID\n if (repo !== userDid) {\n return c.json({\n error: \"Access denied\",\n message: \"You can only modify your own records\",\n }, 403);\n }\n\n console.log(\n `Updating record ${rkey} in collection ${collection} for ${repo}`,\n );\n\n try {\n // Get the current record\n const getUrl =\n `${oauthSession.pdsUrl}/xrpc/com.atproto.repo.getRecord?repo=${repo}&collection=${collection}&rkey=${rkey}`;\n\n const getResponse = await oauthSession.makeRequest(\"GET\", getUrl);\n\n if (!getResponse.ok) {\n const errorText = await getResponse.text();\n console.error(\"Failed to get current record:\", {\n status: getResponse.status,\n statusText: getResponse.statusText,\n error: errorText,\n });\n return c.json(\n { error: \"Failed to fetch current record\" },\n getResponse.status as 400 | 401 | 403 | 404 | 500,\n );\n }\n\n const currentRecord = await getResponse.json();\n\n // Update the record with new status\n const updatedValue = {\n ...currentRecord.value,\n status: status,\n };\n\n // Update the record using authenticated fetch\n const updateResponse = await oauthSession.makeRequest(\n \"POST\",\n `${oauthSession.pdsUrl}/xrpc/com.atproto.repo.putRecord`,\n {\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n repo,\n collection,\n rkey,\n record: updatedValue,\n swapRecord: currentRecord.cid,\n }),\n },\n );\n\n if (!updateResponse.ok) {\n const errorText = await updateResponse.text();\n console.error(\"Update failed:\", {\n status: updateResponse.status,\n statusText: updateResponse.statusText,\n error: errorText,\n });\n\n // Handle specific OAuth errors\n if (updateResponse.status === 401) {\n return c.json({\n error: \"Authentication failed\",\n message: \"OAuth session expired. Please login again.\",\n }, 401);\n }\n\n return c.json({\n error: \"Failed to update record\",\n message: errorText,\n }, updateResponse.status as 400 | 401 | 403 | 404 | 500);\n }\n\n const result = await updateResponse.json();\n console.log(`Successfully updated record ${rkey} to status ${status}`);\n\n return c.json({\n success: true,\n message: `Status updated to ${status}`,\n uri: result.uri,\n cid: result.cid,\n newStatus: status,\n });\n } catch (repoError: any) {\n console.error(\"Repository operation failed:\", {\n error: repoError,\n repo,\n collection,\n rkey,\n });\n\n // Handle specific ATProto errors\n if (repoError.message?.includes(\"RecordNotFound\")) {\n return c.json({ error: \"Record not found\" }, 404);\n }\n\n if (repoError.message?.includes(\"InvalidSwap\")) {\n return c.json({\n error: \"Record was modified by another process\",\n message: \"Please refresh and try again\",\n }, 409);\n }\n\n // Check if it's an authentication error\n if (\n repoError.status === 401 || repoError.message?.includes(\"Unauthorized\")\n ) {\n return c.json({\n error: \"Authentication failed\",\n message: \"OAuth session expired. Please login again.\",\n }, 401);\n }\n\n return c.json({\n error: \"Failed to update record\",\n message: repoError.message || \"Unknown repository error\",\n }, 500);\n }\n } catch (error) {\n console.error(\"Update error:\", error);\n\n if (error instanceof Error) {\n return c.json({\n error: \"Failed to update book status\",\n message: error.message,\n }, 500);\n }\n\n return c.json({ error: \"Failed to update book status\" }, 500);\n }\n});\n\napp.onError((err, _c) => {\n console.error(\"Error:\", err);\n throw err;\n});\n\nexport default app.fetch;\n","puf-bookhive",[],[165,293],["D",1786737778590],[],[165,166,67],"2428ed7e-1021-4771-b190-5c761072a844",["D",1786737778590],[185],[165,166],"286cb47a-6de9-4c18-bd5b-286ceb83f3fd","schema.ts","01a001de-e00b-7376-9430-48660d88eb16","01a001de-e00b-7376-9430-4f95c845f58e",["D",1786737778590],"// Drizzle schema definitions for Book Explorer\nimport {\n integer,\n sqliteTable,\n text,\n} from \"https://esm.sh/drizzle-orm@0.44.5/sqlite-core\";\n\n// User sessions table for OAuth data\nexport const userSessionsTable = sqliteTable(\"user_sessions\", {\n did: text(\"did\").primaryKey(),\n handle: text(\"handle\").notNull(),\n accessToken: text(\"access_token\").notNull(),\n refreshToken: text(\"refresh_token\").notNull(),\n pdsUrl: text(\"pds_url\"),\n createdAt: integer(\"created_at\").notNull(),\n});\n\n// Iron Session storage for encrypted session cookies (required by atproto-oauth-hono)\nexport const ironSessionStorageTable = sqliteTable(\"iron_session_storage\", {\n key: text(\"key\").primaryKey(),\n value: text(\"value\").notNull(),\n expiresAt: integer(\"expires_at\"),\n createdAt: integer(\"created_at\").notNull(),\n updatedAt: integer(\"updated_at\").notNull(),\n});\n\n// Export types\nexport type UserSessionInsert = typeof userSessionsTable.$inferInsert;\nexport type UserSessionSelect = typeof userSessionsTable.$inferSelect;\nexport type IronSessionInsert = typeof ironSessionStorageTable.$inferInsert;\nexport type IronSessionSelect = typeof ironSessionStorageTable.$inferSelect;\n",[],[165,316,309],"database","d5b8b43c-615c-4767-af09-520e0e44d02f","migrations.ts","01a001de-e00b-7376-9430-44b41f8a3c27",["D",1786737778590],"// Database migrations for Book Explorer\nimport { rawDb } from \"./db.ts\";\n\nexport async function runMigrations() {\n try {\n // Create user_sessions table\n await rawDb.execute({\n sql: `\n CREATE TABLE IF NOT EXISTS user_sessions (\n did TEXT PRIMARY KEY,\n handle TEXT NOT NULL,\n access_token TEXT NOT NULL,\n refresh_token TEXT NOT NULL,\n pds_url TEXT,\n created_at INTEGER NOT NULL\n )\n `,\n args: [],\n });\n\n // Create iron_session_storage table (required by atproto-oauth-hono)\n await rawDb.execute({\n sql: `\n CREATE TABLE IF NOT EXISTS iron_session_storage (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL,\n expires_at INTEGER,\n created_at INTEGER NOT NULL,\n updated_at INTEGER NOT NULL\n )\n `,\n args: [],\n });\n\n console.log(\"Database migrations completed successfully\");\n } catch (error) {\n console.error(\"Migration failed:\", error);\n throw error;\n }\n}\n",[],[165,316,318],"07d94cef-1648-4599-8089-767e38f5b0bc","db.ts","01a001de-e00b-7376-9430-416b33e2ebd3",["D",1786737778590],"// Drizzle ORM database module using Val Town's sqlite2\nimport { drizzle } from \"https://esm.sh/drizzle-orm@0.44.5/sqlite-proxy\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite2\";\nimport * as schema from \"./schema.ts\";\n\n// Create Drizzle database instance with schema using sqlite-proxy adapter\nexport const db = drizzle(\n async (sql, params) => {\n const result = await sqlite.execute({ sql, args: params || [] });\n return { rows: result.rows };\n },\n { schema },\n);\n\n// Export raw sqlite for migrations and schema operations\nexport const rawDb = sqlite;\n\n// Initialize all tables using Drizzle migrations\nexport async function initializeTables() {\n // Run proper Drizzle-based migrations\n const { runMigrations } = await import(\"./migrations.ts\");\n await runMigrations();\n}\n",[],[165,316,325],"728b0489-e130-49bb-97b4-fc7ee772f5af",["D",1786737778590],[181,182,183],[165,316],"4423fbb7-c1e3-4fcf-9240-9a6bd0d6df4c",["D",1786737778590],[180,184,186],[165],"fd74d727-ca13-4940-adc5-bc1d26ca9d48","settings.local.json","01a001de-e00b-7376-9430-3864f8682872","01a001de-e00b-7376-9430-3e47b7ffc11e",["D",1786737778590],"{\n \"permissions\": {\n \"allow\": [\n \"mcp__sequential-thinking__process_thought\",\n \"WebFetch(domain:jsr.io)\",\n \"WebFetch(domain:github.com)\",\n \"Bash(deno check:*)\",\n \"Bash(deno task:*)\",\n \"Read(/Users/tijs/projects/Anchor/location-feed-generator/**)\",\n \"Read(/Users/tijs/projects/Anchor/location-feed-generator/**)\",\n \"Read(/Users/tijs/projects/Anchor/location-feed-generator/backend/oauth/**)\",\n \"WebSearch\",\n \"Bash(deno repl:*)\",\n \"Read(//Users/tijs/projects/atproto/atproto-oauth-hono/**)\",\n \"Bash(find:*)\",\n \"Read(//Users/tijs/projects/atproto/**)\"\n ],\n \"deny\": [],\n \"ask\": []\n }\n}\n",[],[347,340],".claude","bc6c40ab-d752-45a3-8ea9-9e1510252a17",["D",1786737778590],[178],[347],["D",1786737778590],{"_11":12,"_125":73},{"_11":12,"_121":12,"_72":73,"_30":71,"_122":123,"_124":24},{"_38":110,"_13":16,"_32":35,"_111":75,"_112":62,"_113":63,"_114":79,"_115":116,"_117":118,"_119":14,"_120":12},"ctx",{"_51":-5,"_146":389,"_390":391,"_392":393,"_394":24,"_395":24,"_396":24,"_397":87,"_398":-5,"_399":-7,"_400":-7,"_401":26,"_402":24,"_403":24,"_404":-5,"_405":24,"_406":24,"_407":24,"_408":-5},"ENV",{"_360":361,"_362":363,"_364":16,"_365":366,"_367":368,"_369":370,"_371":372,"_373":374,"_375":376,"_377":378,"_379":380,"_381":382,"_383":384,"_385":386,"_387":388},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e8c4b7030cb7600e4eb0736b15f422c8b8bd130f","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

History · storage-adapter.ts