+
+ Local Books Library
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ Continue Reading
@@ -100,7 +132,7 @@
-
+
diff --git a/docker/src/api/local/local.controller.ts b/docker/src/api/local/local.controller.ts
index 5c66a44..c07c070 100644
--- a/docker/src/api/local/local.controller.ts
+++ b/docker/src/api/local/local.controller.ts
@@ -6,7 +6,8 @@ import fs from "fs";
import { PathLike } from "node:fs";
import path from "path";
import {getAnimeById, searchAnimeLocal} from "../anime/anime.service";
-import {getBookById, searchBooksLocal} from "../books/books.service";
+import {getBookById, searchBooksAniList, searchBooksLocal} from "../books/books.service";
+import AdmZip from 'adm-zip';
type SetConfigBody = {
library?: {
@@ -34,7 +35,7 @@ async function resolveEntryMetadata(entry: any, type: string) {
const results = type === 'anime'
? await searchAnimeLocal(query)
- : await searchBooksLocal(query);
+ : await searchBooksAniList(query);
const first = results?.[0];
@@ -237,11 +238,120 @@ export async function matchEntry(
await run(
`UPDATE local_entries
- SET matched_source = ?, matched_id = ?
- WHERE id = ?`,
+ SET matched_source = ?, matched_id = ?
+ WHERE id = ?`,
[source, matched_id, id],
'local_library'
);
return { status: 'OK', matched: !!matched_id };
}
+
+export async function getUnits(
+ request: FastifyRequest<{ Params: Params }>,
+ reply: FastifyReply
+) {
+ try {
+ const { type, id } = request.params as { type: string, id: string };
+
+ // Buscar la entrada por matched_id
+ const entry = await queryOne(
+ `SELECT id, type, matched_id FROM local_entries WHERE matched_id = ? AND type = ?`,
+ [Number(id), type],
+ 'local_library'
+ );
+
+ if (!entry) {
+ return reply.status(404).send({ error: 'ENTRY_NOT_FOUND' });
+ }
+
+ // Obtener todos los archivos/unidades ordenados
+ const files = await queryAll(
+ `SELECT id, file_path, unit_number FROM local_files
+ WHERE entry_id = ?
+ ORDER BY unit_number ASC`,
+ [entry.id],
+ 'local_library'
+ );
+
+ // Formatear la respuesta según el tipo
+ const units = files.map((file: any) => {
+ const fileName = path.basename(file.file_path);
+ const fileExt = path.extname(file.file_path).toLowerCase();
+
+ // Detectar si es un archivo comprimido (capítulo único) o carpeta
+ const isDirectory = fs.existsSync(file.file_path) &&
+ fs.statSync(file.file_path).isDirectory();
+
+ return {
+ id: file.id,
+ number: file.unit_number,
+ name: fileName,
+ type: type === 'anime' ? 'episode' : 'chapter',
+ format: fileExt === '.cbz' ? 'cbz' : 'file',
+ path: file.file_path
+ };
+ });
+
+ return {
+ entry_id: entry.id,
+ matched_id: entry.matched_id,
+ type: entry.type,
+ total: units.length,
+ units
+ };
+ } catch (err) {
+ console.error('Error getting units:', err);
+ return reply.status(500).send({ error: 'FAILED_TO_GET_UNITS' });
+ }
+}
+
+export async function getCbzPages(request: FastifyRequest, reply: FastifyReply) {
+ const { unitId } = request.params as any;
+
+ const file = await queryOne(
+ `SELECT file_path FROM local_files WHERE id = ?`,
+ [unitId],
+ 'local_library'
+ );
+
+ if (!file || !fs.existsSync(file.file_path)) {
+ return reply.status(404).send({ error: 'FILE_NOT_FOUND' });
+ }
+
+ const zip = new AdmZip(file.file_path);
+
+ const pages = zip.getEntries()
+ .filter(e => !e.isDirectory && /\.(jpg|jpeg|png|webp)$/i.test(e.entryName))
+ .sort((a, b) => a.entryName.localeCompare(b.entryName, undefined, { numeric: true }))
+ .map((_, i) =>
+ `/api/library/manga/cbz/${unitId}/page/${i}`
+ );
+
+ return { pages };
+}
+
+export async function getCbzPage(request: FastifyRequest, reply: FastifyReply) {
+ const { unitId, page } = request.params as any;
+
+ const file = await queryOne(
+ `SELECT file_path FROM local_files WHERE id = ?`,
+ [unitId],
+ 'local_library'
+ );
+
+ if (!file) return reply.status(404).send();
+
+ const zip = new AdmZip(file.file_path);
+
+ const images = zip.getEntries()
+ .filter(e => !e.isDirectory && /\.(jpg|jpeg|png|webp)$/i.test(e.entryName))
+ .sort((a, b) => a.entryName.localeCompare(b.entryName, undefined, { numeric: true }));
+
+ const entry = images[page];
+ if (!entry) return reply.status(404).send();
+
+ reply
+ .header('Content-Type', 'image/jpeg')
+ .send(entry.getData());
+}
diff --git a/docker/src/api/local/local.routes.ts b/docker/src/api/local/local.routes.ts
index 5924812..0127890 100644
--- a/docker/src/api/local/local.routes.ts
+++ b/docker/src/api/local/local.routes.ts
@@ -7,6 +7,9 @@ async function localRoutes(fastify: FastifyInstance) {
fastify.get('/library/:type/:id', controller.getEntry);
fastify.get('/library/stream/:type/:id/:unit', controller.streamUnit);
fastify.post('/library/:type/:id/match', controller.matchEntry);
+ fastify.get('/library/:type/:id/units', controller.getUnits);
+ fastify.get('/library/:type/cbz/:unitId/pages', controller.getCbzPages);
+ fastify.get('/library/:type/cbz/:unitId/page/:page', controller.getCbzPage);
}
export default localRoutes;
\ No newline at end of file
diff --git a/docker/src/scripts/books/book.js b/docker/src/scripts/books/book.js
index 7b39a06..7384528 100644
--- a/docker/src/scripts/books/book.js
+++ b/docker/src/scripts/books/book.js
@@ -7,7 +7,7 @@ let allChapters = [];
let filteredChapters = [];
let availableExtensions = [];
-
+let isLocal = false;
const chapterPagination = Object.create(PaginationManager);
chapterPagination.init(12, () => renderChapterTable());
@@ -16,6 +16,40 @@ document.addEventListener('DOMContentLoaded', () => {
setupModalClickOutside();
});
+async function checkLocalLibraryEntry() {
+ try {
+ const res = await fetch(`/api/library/manga/${bookId}`);
+ if (!res.ok) return;
+
+ const data = await res.json();
+ if (data.matched) {
+ isLocal = true;
+ const pill = document.getElementById('local-pill');
+ if (pill) {
+ pill.textContent = 'Local';
+ pill.style.display = 'inline-flex';
+ pill.style.background = 'rgba(34, 197, 94, 0.2)';
+ pill.style.color = '#22c55e';
+ pill.style.borderColor = 'rgba(34, 197, 94, 0.3)';
+ }
+ }
+ } catch (e) {
+ console.error("Error checking local status:", e);
+ }
+}
+
+function markAsLocal() {
+ isLocal = true;
+ const pill = document.getElementById('local-pill');
+ if (pill) {
+ pill.textContent = 'Local';
+ pill.style.display = 'inline-flex';
+ pill.style.background = 'rgba(34, 197, 94, 0.2)';
+ pill.style.color = '#22c55e';
+ pill.style.borderColor = 'rgba(34, 197, 94, 0.3)';
+ }
+}
+
async function init() {
try {
const urlData = URLUtils.parseEntityPath('book');
@@ -27,7 +61,7 @@ async function init() {
extensionName = urlData.extensionName;
bookId = urlData.entityId;
bookSlug = urlData.slug;
-
+ await checkLocalLibraryEntry();
await loadBookMetadata();
await loadAvailableExtensions();
@@ -71,7 +105,6 @@ async function loadBookMetadata() {
const metadata = MediaMetadataUtils.formatBookData(raw, !!extensionName);
bookData.entry_type =
metadata.format === 'MANGA' ? 'MANGA' : 'NOVEL';
-
updatePageTitle(metadata.title);
updateMetadata(metadata);
updateExtensionPill();
@@ -174,32 +207,46 @@ async function loadChapters(targetProvider = null) {
const tbody = document.getElementById('chapters-body');
if (!tbody) return;
- // Si no se pasa provider, intentamos pillar el del select o el primero disponible
if (!targetProvider) {
const select = document.getElementById('provider-filter');
targetProvider = select ? select.value : (availableExtensions[0] || 'all');
}
- tbody.innerHTML = 'Chapter not found
';
+ return;
+ }
+
+ if (unit.format === 'cbz') {
+ chapterLabel.textContent = unit.name; // ✅
+ document.title = unit.name;
+ const pagesRes = await fetch(
+ `/api/library/manga/cbz/${unit.id}/pages`
+ );
+ const pagesData = await pagesRes.json();
+
+ currentType = 'manga';
+ updateSettingsVisibility();
+ applyStyles();
+
+ currentPages = pagesData.pages.map(url => ({ url }));
+ reader.innerHTML = '';
+ loadManga(currentPages);
+ return;
+ }
+ }
+
if (data.title) {
chapterLabel.textContent = data.title;
@@ -160,8 +193,13 @@ async function loadChapter() {
reader.innerHTML = '';
if (data.type === 'manga') {
- currentPages = data.pages || [];
- loadManga(currentPages);
+ if (provider === 'local' && data.format === 'cbz') {
+ currentPages = data.pages.map(url => ({ url }));
+ loadManga(currentPages);
+ } else {
+ currentPages = data.pages || [];
+ loadManga(currentPages);
+ }
} else if (data.type === 'ln') {
loadLN(data.content);
}
@@ -281,7 +319,9 @@ function createImageElement(page, index) {
img.className = 'page-img';
img.dataset.index = index;
- const url = buildProxyUrl(page.url, page.headers);
+ const url = provider === 'local'
+ ? page.url
+ : buildProxyUrl(page.url, page.headers);
const placeholder = "/public/assets/placeholder.svg";
img.onerror = () => {
diff --git a/docker/src/scripts/local-library-books.js b/docker/src/scripts/local-library-books.js
new file mode 100644
index 0000000..63e3f62
--- /dev/null
+++ b/docker/src/scripts/local-library-books.js
@@ -0,0 +1,89 @@
+let activeFilter = 'all';
+let activeSort = 'az';
+let isLocalMode = false;
+let localEntries = [];
+
+function toggleLibraryMode() {
+ isLocalMode = !isLocalMode;
+ const btn = document.getElementById('library-mode-btn');
+ const onlineContent = document.getElementById('online-content');
+ const localContent = document.getElementById('local-content');
+
+ if (isLocalMode) {
+ btn.classList.add('active');
+ onlineContent.classList.add('hidden');
+ localContent.classList.remove('hidden');
+ loadLocalEntries();
+ } else {
+ btn.classList.remove('active');
+ onlineContent.classList.remove('hidden');
+ localContent.classList.add('hidden');
+ }
+}
+
+async function loadLocalEntries() {
+ const grid = document.getElementById('local-entries-grid');
+ grid.innerHTML = ''.repeat(6);
+
+ try {
+ // Cambiado a endpoint de libros
+ const response = await fetch('/api/library/manga');
+ const entries = await response.json();
+ localEntries = entries;
+
+ if (entries.length === 0) {
+ grid.innerHTML = 'No books found in your local library.
'; + return; + } + renderLocalEntries(entries); + } catch (err) { + grid.innerHTML = 'Error loading local books.
'; + } +} + +function renderLocalEntries(entries) { + const grid = document.getElementById('local-entries-grid'); + grid.innerHTML = entries.map(entry => { + const title = entry.metadata?.title?.romaji || entry.metadata?.title?.english || entry.id; + const cover = entry.metadata?.coverImage?.extraLarge || '/public/assets/placeholder.jpg'; + const chapters = entry.metadata?.chapters || '??'; + + return ` +
+
+ `;
+ }).join('');
+}
+
+async function scanLocalLibrary() {
+ const btnText = document.getElementById('scan-text');
+ btnText.innerText = "Scanning...";
+ try {
+ // Asumiendo que el scan de libros usa este query param
+ const response = await fetch('/api/library/scan?mode=incremental', { method: 'POST' });
+ if (response.ok) {
+ await loadLocalEntries();
+ if (window.NotificationUtils) NotificationUtils.show('Library scanned!', 'success');
+ }
+ } catch (err) {
+ if (window.NotificationUtils) NotificationUtils.show('Scan failed', 'error');
+ } finally {
+ btnText.innerText = "Scan Library";
+ }
+}
+
+function viewLocalEntry(id) {
+ if (id) window.location.href = `/book/${id}`;
+}
\ No newline at end of file
diff --git a/docker/views/books/book.html b/docker/views/books/book.html
index 67cd99f..7140a2b 100644
--- a/docker/views/books/book.html
+++ b/docker/views/books/book.html
@@ -62,6 +62,7 @@
diff --git a/docker/views/books/books.html b/docker/views/books/books.html
index c291843..061dd8a 100644
--- a/docker/views/books/books.html
+++ b/docker/views/books/books.html
@@ -9,6 +9,7 @@
+
@@ -36,9 +37,40 @@
+ 
+
+
+
+ ${title}
+ + ${chapters} Chapters +
+
+ ${entry.matched ? '● Linked' : '○ Unlinked'}
+
+
+
+ Local Books Library
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ Continue Reading
@@ -87,7 +119,7 @@
-
+