// gallery-cache.js // 画廊和缓存管理模块 import { getContext } from "../../../../../extensions.js"; import { saveBase64AsFile } from "../../../../../utils.js"; // ═══════════════════════════════════════════════════════════════════════════ // 常量 // ═══════════════════════════════════════════════════════════════════════════ const DB_NAME = 'xb_novel_draw_previews'; const DB_STORE = 'previews'; const DB_SELECTIONS_STORE = 'selections'; const DB_VERSION = 2; // ═══════════════════════════════════════════════════════════════════════════ // 状态 // ═══════════════════════════════════════════════════════════════════════════ let db = null; let dbOpening = null; let galleryOverlayCreated = false; let currentGalleryData = null; let dbInitialized = false; // ═══════════════════════════════════════════════════════════════════════════ // 日志 // ═══════════════════════════════════════════════════════════════════════════ function log(...args) { console.log('[GalleryCache]', ...args); } function logDbState(label) { log(label, { dbExists: !!db, dbOpening: !!dbOpening, dbName: db?.name, dbVersion: db?.version, stores: db ? [...db.objectStoreNames] : null }); } // ═══════════════════════════════════════════════════════════════════════════ // 工具函数 // ═══════════════════════════════════════════════════════════════════════════ function escapeHtml(str) { return String(str || '').replace(/&/g, '&').replace(//g, '>').replace(/"/g, '"'); } function getChatCharacterName() { const ctx = getContext(); if (ctx.groupId) return String(ctx.groups?.[ctx.groupId]?.id ?? 'group'); return String(ctx.characters?.[ctx.characterId]?.name || 'character'); } function showToast(message, type = 'success', duration = 2500) { const colors = { success: 'rgba(62,207,142,0.95)', error: 'rgba(248,113,113,0.95)', info: 'rgba(212,165,116,0.95)' }; const toast = document.createElement('div'); toast.textContent = message; toast.style.cssText = 'position:fixed;top:20px;left:50%;transform:translateX(-50%);background:' + (colors[type] || colors.info) + ';color:#fff;padding:10px 20px;border-radius:8px;font-size:13px;z-index:99999;animation:fadeInOut ' + (duration/1000) + 's ease-in-out;max-width:80vw;text-align:center;word-break:break-all'; document.body.appendChild(toast); setTimeout(function() { toast.remove(); }, duration); } // ═══════════════════════════════════════════════════════════════════════════ // IndexedDB 操作 // ═══════════════════════════════════════════════════════════════════════════ function isDbValid() { if (!db) { log('isDbValid: db is null'); return false; } try { const valid = db.objectStoreNames.length > 0; log('isDbValid:', valid); return valid; } catch (e) { log('isDbValid: error', e.message); return false; } } export async function openDB() { if (!dbInitialized) { dbInitialized = true; log('openDB: first call'); } if (dbOpening) { return dbOpening; } if (isDbValid()) { if (db.objectStoreNames.contains(DB_SELECTIONS_STORE)) { return db; } try { db.close(); } catch (e) {} db = null; } dbOpening = new Promise(function(resolve, reject) { var request = indexedDB.open(DB_NAME, DB_VERSION); request.onerror = function() { dbOpening = null; reject(request.error); }; request.onsuccess = function() { db = request.result; db.onclose = function() { db = null; }; db.onversionchange = function() { db.close(); db = null; }; dbOpening = null; resolve(db); }; request.onupgradeneeded = function(e) { var database = e.target.result; if (!database.objectStoreNames.contains(DB_STORE)) { var store = database.createObjectStore(DB_STORE, { keyPath: 'imgId' }); ['messageId', 'chatId', 'timestamp', 'slotId'].forEach(function(idx) { store.createIndex(idx, idx); }); } if (!database.objectStoreNames.contains(DB_SELECTIONS_STORE)) { database.createObjectStore(DB_SELECTIONS_STORE, { keyPath: 'slotId' }); } }; }); return dbOpening; } // ═══════════════════════════════════════════════════════════════════════════ // 选中状态管理 // ═══════════════════════════════════════════════════════════════════════════ export async function setSlotSelection(slotId, imgId) { log('setSlotSelection:', slotId, imgId); var database = await openDB(); logDbState('setSlotSelection got db'); if (!database.objectStoreNames.contains(DB_SELECTIONS_STORE)) { log('setSlotSelection: no store'); return; } return new Promise(function(resolve, reject) { try { var tx = database.transaction(DB_SELECTIONS_STORE, 'readwrite'); tx.objectStore(DB_SELECTIONS_STORE).put({ slotId: slotId, selectedImgId: imgId, timestamp: Date.now() }); tx.oncomplete = function() { log('setSlotSelection: done'); resolve(); }; tx.onerror = function() { log('setSlotSelection: error', tx.error); reject(tx.error); }; } catch (e) { log('setSlotSelection: tx error', e.message); reject(e); } }); } export async function getSlotSelection(slotId) { log('getSlotSelection:', slotId); var database = await openDB(); if (!database.objectStoreNames.contains(DB_SELECTIONS_STORE)) return null; return new Promise(function(resolve, reject) { try { var tx = database.transaction(DB_SELECTIONS_STORE, 'readonly'); var request = tx.objectStore(DB_SELECTIONS_STORE).get(slotId); request.onsuccess = function() { resolve(request.result?.selectedImgId || null); }; request.onerror = function() { reject(request.error); }; } catch (e) { log('getSlotSelection: tx error', e.message); reject(e); } }); } export async function clearSlotSelection(slotId) { log('clearSlotSelection:', slotId); var database = await openDB(); if (!database.objectStoreNames.contains(DB_SELECTIONS_STORE)) return; return new Promise(function(resolve, reject) { try { var tx = database.transaction(DB_SELECTIONS_STORE, 'readwrite'); tx.objectStore(DB_SELECTIONS_STORE).delete(slotId); tx.oncomplete = resolve; tx.onerror = function() { reject(tx.error); }; } catch (e) { log('clearSlotSelection: tx error', e.message); reject(e); } }); } // ═══════════════════════════════════════════════════════════════════════════ // 预览存储 // ═══════════════════════════════════════════════════════════════════════════ export async function storePreview(opts) { var imgId = opts.imgId; var slotId = opts.slotId; var messageId = opts.messageId; var base64 = opts.base64 || null; var tags = opts.tags; var positive = opts.positive; var savedUrl = opts.savedUrl || null; var status = opts.status || 'success'; var errorType = opts.errorType || null; var errorMessage = opts.errorMessage || null; var characterPrompts = opts.characterPrompts || null; var negativePrompt = opts.negativePrompt || null; log('storePreview:', imgId); var database = await openDB(); logDbState('storePreview got db'); var ctx = getContext(); return new Promise(function(resolve, reject) { try { var tx = database.transaction(DB_STORE, 'readwrite'); tx.objectStore(DB_STORE).put({ imgId: imgId, slotId: slotId || imgId, messageId: messageId, chatId: ctx.chatId || (ctx.characterId || 'unknown'), characterName: getChatCharacterName(), base64: base64, tags: tags, positive: positive, savedUrl: savedUrl, status: status, errorType: errorType, errorMessage: errorMessage, characterPrompts: characterPrompts, negativePrompt: negativePrompt, timestamp: Date.now() }); tx.oncomplete = function() { log('storePreview: done'); resolve(); }; tx.onerror = function() { log('storePreview: error', tx.error); reject(tx.error); }; } catch (e) { log('storePreview: tx error', e.message); reject(e); } }); } export async function storeFailedPlaceholder(opts) { var imgId = 'failed-' + opts.slotId + '-' + Date.now(); return storePreview({ imgId: imgId, slotId: opts.slotId, messageId: opts.messageId, base64: null, tags: opts.tags, positive: opts.positive, status: 'failed', errorType: opts.errorType, errorMessage: opts.errorMessage, characterPrompts: opts.characterPrompts || null, negativePrompt: opts.negativePrompt || null, }); } export async function getPreview(imgId) { log('getPreview:', imgId); var database = await openDB(); logDbState('getPreview got db'); return new Promise(function(resolve, reject) { try { var tx = database.transaction(DB_STORE, 'readonly'); var request = tx.objectStore(DB_STORE).get(imgId); request.onsuccess = function() { log('getPreview: found:', !!request.result); resolve(request.result); }; request.onerror = function() { log('getPreview: error', request.error); reject(request.error); }; } catch (e) { log('getPreview: tx error', e.message); reject(e); } }); } export async function getPreviewsBySlot(slotId) { log('getPreviewsBySlot:', slotId); var database = await openDB(); return new Promise(function(resolve, reject) { try { var tx = database.transaction(DB_STORE, 'readonly'); var store = tx.objectStore(DB_STORE); if (store.indexNames.contains('slotId')) { var index = store.index('slotId'); var request = index.getAll(slotId); request.onsuccess = function() { var results = request.result || []; if (results.length === 0) { var allRequest = store.getAll(); allRequest.onsuccess = function() { var allRecords = allRequest.result || []; results = allRecords.filter(function(r) { return r.slotId === slotId || r.imgId === slotId || (!r.slotId && r.imgId === slotId); }); results.sort(function(a, b) { return b.timestamp - a.timestamp; }); resolve(results); }; allRequest.onerror = function() { reject(allRequest.error); }; } else { results.sort(function(a, b) { return b.timestamp - a.timestamp; }); resolve(results); } }; request.onerror = function() { reject(request.error); }; } else { var request2 = store.getAll(); request2.onsuccess = function() { var allRecords = request2.result || []; var results = allRecords.filter(function(r) { return r.slotId === slotId || r.imgId === slotId; }); results.sort(function(a, b) { return b.timestamp - a.timestamp; }); resolve(results); }; request2.onerror = function() { reject(request2.error); }; } } catch (e) { log('getPreviewsBySlot: tx error', e.message); reject(e); } }); } export async function getDisplayPreviewForSlot(slotId) { var previews = await getPreviewsBySlot(slotId); if (!previews.length) return { preview: null, historyCount: 0, hasData: false, isFailed: false }; var successPreviews = previews.filter(function(p) { return p.status !== 'failed' && p.base64; }); var failedPreviews = previews.filter(function(p) { return p.status === 'failed' || !p.base64; }); if (successPreviews.length === 0) { var latestFailed = failedPreviews[0]; return { preview: latestFailed, historyCount: 0, hasData: false, isFailed: true, failedInfo: { tags: latestFailed?.tags || '', positive: latestFailed?.positive || '', errorType: latestFailed?.errorType, errorMessage: latestFailed?.errorMessage } }; } var selectedImgId = await getSlotSelection(slotId); if (selectedImgId) { var selected = successPreviews.find(function(p) { return p.imgId === selectedImgId; }); if (selected) { return { preview: selected, historyCount: successPreviews.length, hasData: true, isFailed: false }; } } return { preview: successPreviews[0], historyCount: successPreviews.length, hasData: true, isFailed: false }; } export async function getLatestPreviewForSlot(slotId) { var result = await getDisplayPreviewForSlot(slotId); return result.preview; } export async function deletePreview(imgId) { log('deletePreview:', imgId); var database = await openDB(); return new Promise(function(resolve, reject) { try { var tx = database.transaction(DB_STORE, 'readwrite'); tx.objectStore(DB_STORE).delete(imgId); tx.oncomplete = function() { log('deletePreview: done'); resolve(); }; tx.onerror = function() { reject(tx.error); }; } catch (e) { log('deletePreview: tx error', e.message); reject(e); } }); } export async function deleteFailedRecordsForSlot(slotId) { var previews = await getPreviewsBySlot(slotId); var failedRecords = previews.filter(function(p) { return p.status === 'failed' || !p.base64; }); for (var i = 0; i < failedRecords.length; i++) { await deletePreview(failedRecords[i].imgId); } } export async function updatePreviewSavedUrl(imgId, savedUrl) { log('updatePreviewSavedUrl:', imgId, savedUrl); var database = await openDB(); logDbState('updatePreviewSavedUrl got db'); var preview = await getPreview(imgId); if (!preview) { log('updatePreviewSavedUrl: not found'); return; } preview.savedUrl = savedUrl; log('updatePreviewSavedUrl: re-getting db for write...'); database = await openDB(); logDbState('updatePreviewSavedUrl got db again'); return new Promise(function(resolve, reject) { try { var tx = database.transaction(DB_STORE, 'readwrite'); tx.objectStore(DB_STORE).put(preview); tx.oncomplete = function() { log('updatePreviewSavedUrl: done'); resolve(); }; tx.onerror = function() { log('updatePreviewSavedUrl: error', tx.error); reject(tx.error); }; } catch (e) { log('updatePreviewSavedUrl: tx error', e.message); reject(e); } }); } export async function getCacheStats() { log('getCacheStats'); var database = await openDB(); return new Promise(function(resolve) { try { var tx = database.transaction(DB_STORE, 'readonly'); var store = tx.objectStore(DB_STORE); var countReq = store.count(); var totalSize = 0; var successCount = 0; var failedCount = 0; store.openCursor().onsuccess = function(e) { var cursor = e.target.result; if (cursor) { totalSize += (cursor.value.base64?.length || 0) * 0.75; if (cursor.value.status === 'failed' || !cursor.value.base64) { failedCount++; } else { successCount++; } cursor.continue(); } }; tx.oncomplete = function() { resolve({ count: countReq.result || 0, successCount: successCount, failedCount: failedCount, sizeBytes: Math.round(totalSize), sizeMB: (totalSize / 1024 / 1024).toFixed(2) }); }; } catch (e) { log('getCacheStats: error', e.message); resolve({ count: 0, successCount: 0, failedCount: 0, sizeBytes: 0, sizeMB: '0' }); } }); } export async function clearExpiredCache(cacheDays) { cacheDays = cacheDays || 3; log('clearExpiredCache:', cacheDays, 'days'); var cutoff = Date.now() - cacheDays * 24 * 60 * 60 * 1000; var database = await openDB(); var deleted = 0; return new Promise(function(resolve) { try { var tx = database.transaction(DB_STORE, 'readwrite'); var store = tx.objectStore(DB_STORE); store.openCursor().onsuccess = function(e) { var cursor = e.target.result; if (cursor) { var record = cursor.value; var isExpiredUnsaved = record.timestamp < cutoff && !record.savedUrl; var isFailed = record.status === 'failed' || !record.base64; if (isExpiredUnsaved || (isFailed && record.timestamp < cutoff)) { cursor.delete(); deleted++; } cursor.continue(); } }; tx.oncomplete = function() { log('clearExpiredCache: deleted', deleted); resolve(deleted); }; } catch (e) { log('clearExpiredCache: error', e.message); resolve(0); } }); } export async function clearAllCache() { log('clearAllCache'); var database = await openDB(); return new Promise(function(resolve, reject) { try { var stores = [DB_STORE]; if (database.objectStoreNames.contains(DB_SELECTIONS_STORE)) { stores.push(DB_SELECTIONS_STORE); } var tx = database.transaction(stores, 'readwrite'); tx.objectStore(DB_STORE).clear(); if (stores.length > 1) { tx.objectStore(DB_SELECTIONS_STORE).clear(); } tx.oncomplete = function() { log('clearAllCache: done'); resolve(); }; tx.onerror = function() { reject(tx.error); }; } catch (e) { log('clearAllCache: error', e.message); reject(e); } }); } export async function getGallerySummary() { log('getGallerySummary'); var database = await openDB(); return new Promise(function(resolve) { try { var tx = database.transaction(DB_STORE, 'readonly'); var store = tx.objectStore(DB_STORE); var request = store.getAll(); request.onsuccess = function() { var results = request.result || []; var summary = {}; for (var i = 0; i < results.length; i++) { var item = results[i]; if (item.status === 'failed' || !item.base64) continue; var charName = item.characterName || 'Unknown'; if (!summary[charName]) { summary[charName] = { count: 0, totalSize: 0, slots: {}, latestTimestamp: 0 }; } var slotId = item.slotId || item.imgId; if (!summary[charName].slots[slotId]) { summary[charName].slots[slotId] = { count: 0, hasSaved: false, latestTimestamp: 0, latestImgId: null, }; } var slot = summary[charName].slots[slotId]; slot.count++; if (item.savedUrl) slot.hasSaved = true; if (item.timestamp > slot.latestTimestamp) { slot.latestTimestamp = item.timestamp; slot.latestImgId = item.imgId; } summary[charName].count++; summary[charName].totalSize += (item.base64?.length || 0) * 0.75; if (item.timestamp > summary[charName].latestTimestamp) { summary[charName].latestTimestamp = item.timestamp; } } resolve(summary); }; request.onerror = function() { resolve({}); }; } catch (e) { log('getGallerySummary: error', e.message); resolve({}); } }); } export async function getCharacterPreviews(charName) { log('getCharacterPreviews:', charName); var database = await openDB(); return new Promise(function(resolve) { try { var tx = database.transaction(DB_STORE, 'readonly'); var store = tx.objectStore(DB_STORE); var request = store.getAll(); request.onsuccess = function() { var results = request.result || []; var slots = {}; for (var i = 0; i < results.length; i++) { var item = results[i]; if ((item.characterName || 'Unknown') !== charName) continue; if (item.status === 'failed' || !item.base64) continue; var slotId = item.slotId || item.imgId; if (!slots[slotId]) slots[slotId] = []; slots[slotId].push(item); } for (var sid in slots) { slots[sid].sort(function(a, b) { return b.timestamp - a.timestamp; }); } resolve(slots); }; request.onerror = function() { resolve({}); }; } catch (e) { log('getCharacterPreviews: error', e.message); resolve({}); } }); } // ═══════════════════════════════════════════════════════════════════════════ // 小画廊 UI // ═══════════════════════════════════════════════════════════════════════════ function ensureGalleryStyles() { if (document.getElementById('nd-gallery-styles')) return; var style = document.createElement('style'); style.id = 'nd-gallery-styles'; style.textContent = '#nd-gallery-overlay{position:fixed;top:0;left:0;width:100vw;height:100vh;z-index:100000;display:none;background:rgba(0,0,0,0.85);backdrop-filter:blur(8px)}#nd-gallery-overlay.visible{display:flex;flex-direction:column;align-items:center;justify-content:center}.nd-gallery-close{position:absolute;top:16px;right:16px;width:40px;height:40px;border:none;background:rgba(255,255,255,0.1);border-radius:50%;color:#fff;font-size:20px;cursor:pointer;z-index:10}.nd-gallery-close:hover{background:rgba(255,255,255,0.2)}.nd-gallery-main{display:flex;align-items:center;gap:16px;max-width:90vw;max-height:70vh}.nd-gallery-nav{width:48px;height:48px;border:none;background:rgba(255,255,255,0.1);border-radius:50%;color:#fff;font-size:24px;cursor:pointer;flex-shrink:0}.nd-gallery-nav:hover{background:rgba(255,255,255,0.2)}.nd-gallery-nav:disabled{opacity:0.3;cursor:not-allowed}.nd-gallery-img-wrap{position:relative;max-width:calc(90vw - 140px);max-height:70vh}.nd-gallery-img{max-width:100%;max-height:70vh;border-radius:12px;box-shadow:0 8px 32px rgba(0,0,0,0.5)}.nd-gallery-saved-badge{position:absolute;top:12px;left:12px;background:rgba(62,207,142,0.9);padding:4px 10px;border-radius:6px;font-size:11px;color:#fff;font-weight:600}.nd-gallery-thumbs{display:flex;gap:8px;margin-top:20px;padding:12px;background:rgba(0,0,0,0.3);border-radius:12px;max-width:90vw;overflow-x:auto}.nd-gallery-thumb{width:64px;height:64px;border-radius:8px;object-fit:cover;cursor:pointer;border:2px solid transparent;opacity:0.6;transition:all 0.15s;flex-shrink:0}.nd-gallery-thumb:hover{opacity:0.9}.nd-gallery-thumb.active{border-color:#d4a574;opacity:1}.nd-gallery-thumb.saved{border-color:rgba(62,207,142,0.8)}.nd-gallery-actions{display:flex;gap:12px;margin-top:16px}.nd-gallery-btn{padding:10px 20px;border:1px solid rgba(255,255,255,0.2);border-radius:8px;background:rgba(255,255,255,0.1);color:#fff;font-size:13px;cursor:pointer;transition:all 0.15s}.nd-gallery-btn:hover{background:rgba(255,255,255,0.2)}.nd-gallery-btn.primary{background:rgba(212,165,116,0.3);border-color:rgba(212,165,116,0.5)}.nd-gallery-btn.danger{color:#f87171;border-color:rgba(248,113,113,0.3)}.nd-gallery-btn.danger:hover{background:rgba(248,113,113,0.15)}.nd-gallery-info{text-align:center;margin-top:12px;font-size:12px;color:rgba(255,255,255,0.6)}'; document.head.appendChild(style); } function createGalleryOverlay() { if (galleryOverlayCreated) return; galleryOverlayCreated = true; ensureGalleryStyles(); var overlay = document.createElement('div'); overlay.id = 'nd-gallery-overlay'; overlay.innerHTML = '