import { ClassicPreset } from 'rete'; import { BaseWorkflowNode } from './base-node'; import { pdfSocket } from '../sockets'; import type { PDFData, SocketData, MultiPDFData } from '../types'; import { PDFDocument } from 'pdf-lib'; import { loadPyMuPDF } from '../../utils/pymupdf-loader.js'; export class CbzToPdfNode extends BaseWorkflowNode { readonly category = 'Input' as const; readonly icon = 'ph-book-open'; readonly description = 'Upload comic book archives and convert to PDF'; private files: File[] = []; constructor() { super('CBZ Input'); this.addOutput('pdf', new ClassicPreset.Output(pdfSocket, 'PDF')); } async addFiles(fileList: File[]): Promise { for (const file of fileList) { const name = file.name.toLowerCase(); if (name.endsWith('.cbz') || name.endsWith('.cbr')) { this.files.push(file); } } } removeFile(index: number): void { this.files.splice(index, 1); } hasFile(): boolean { return this.files.length > 0; } getFileCount(): number { return this.files.length; } getFilenames(): string[] { return this.files.map((f) => f.name); } getFilename(): string { if (this.files.length === 0) return ''; if (this.files.length === 1) return this.files[0].name; return `${this.files.length} comic archives`; } async data( _inputs: Record ): Promise> { if (this.files.length === 0) throw new Error('No comic archives uploaded in CBZ Input node'); const pymupdf = await loadPyMuPDF(); const results: PDFData[] = []; for (const file of this.files) { const blob = await pymupdf.convertToPdf(file, { filetype: 'cbz' }); const bytes = new Uint8Array(await blob.arrayBuffer()); const document = await PDFDocument.load(bytes); results.push({ type: 'pdf', document, bytes, filename: file.name.replace(/\.(cbz|cbr)$/i, '.pdf'), }); } if (results.length === 1) return { pdf: results[0] }; return { pdf: { type: 'multi-pdf', items: results } as MultiPDFData }; } }