125 lines
3.8 KiB
TypeScript
125 lines
3.8 KiB
TypeScript
// IndexedDB cache management
|
|
import { BibleChapter, CacheEntry } from '@/types'
|
|
|
|
const DB_NAME = 'BibleReaderDB'
|
|
const DB_VERSION = 1
|
|
const STORE_NAME = 'chapters'
|
|
const CACHE_DURATION_MS = 30 * 24 * 60 * 60 * 1000 // 30 days
|
|
const MAX_CACHE_SIZE = 50 // keep last 50 chapters
|
|
|
|
let db: IDBDatabase | null = null
|
|
|
|
export async function initDatabase(): Promise<IDBDatabase> {
|
|
return new Promise((resolve, reject) => {
|
|
const request = indexedDB.open(DB_NAME, DB_VERSION)
|
|
|
|
request.onerror = () => reject(request.error)
|
|
request.onsuccess = () => {
|
|
db = request.result
|
|
resolve(db)
|
|
}
|
|
|
|
request.onupgradeneeded = (event) => {
|
|
const database = (event.target as IDBOpenDBRequest).result
|
|
if (!database.objectStoreNames.contains(STORE_NAME)) {
|
|
const store = database.createObjectStore(STORE_NAME, { keyPath: 'chapterId' })
|
|
store.createIndex('timestamp', 'timestamp', { unique: false })
|
|
}
|
|
}
|
|
})
|
|
}
|
|
|
|
export async function cacheChapter(chapter: BibleChapter): Promise<void> {
|
|
if (!db) await initDatabase()
|
|
|
|
return new Promise((resolve, reject) => {
|
|
const entry: CacheEntry = {
|
|
chapterId: chapter.id,
|
|
data: chapter,
|
|
timestamp: Date.now(),
|
|
expiresAt: Date.now() + CACHE_DURATION_MS
|
|
}
|
|
|
|
const transaction = db!.transaction([STORE_NAME], 'readwrite')
|
|
const store = transaction.objectStore(STORE_NAME)
|
|
|
|
// First, check if we need to delete oldest entry
|
|
const countRequest = store.count()
|
|
countRequest.onsuccess = () => {
|
|
if (countRequest.result >= MAX_CACHE_SIZE) {
|
|
// Delete oldest entry
|
|
const index = store.index('timestamp')
|
|
const deleteRequest = index.openCursor()
|
|
let deleted = false
|
|
|
|
deleteRequest.onsuccess = (event) => {
|
|
const cursor = (event.target as IDBRequest).result
|
|
if (cursor && !deleted) {
|
|
cursor.delete()
|
|
deleted = true
|
|
// Continue with adding new entry after delete
|
|
const putRequest = store.put(entry)
|
|
putRequest.onerror = () => reject(putRequest.error)
|
|
putRequest.onsuccess = () => resolve()
|
|
}
|
|
}
|
|
deleteRequest.onerror = () => reject(deleteRequest.error)
|
|
} else {
|
|
// Just add the entry
|
|
const putRequest = store.put(entry)
|
|
putRequest.onerror = () => reject(putRequest.error)
|
|
putRequest.onsuccess = () => resolve()
|
|
}
|
|
}
|
|
|
|
countRequest.onerror = () => reject(countRequest.error)
|
|
})
|
|
}
|
|
|
|
export async function getCachedChapter(chapterId: string): Promise<BibleChapter | null> {
|
|
if (!db) await initDatabase()
|
|
|
|
return new Promise((resolve, reject) => {
|
|
const transaction = db!.transaction([STORE_NAME], 'readonly')
|
|
const store = transaction.objectStore(STORE_NAME)
|
|
const request = store.get(chapterId)
|
|
|
|
request.onerror = () => reject(request.error)
|
|
request.onsuccess = () => {
|
|
const entry = request.result as CacheEntry | undefined
|
|
if (entry && entry.expiresAt > Date.now()) {
|
|
resolve(entry.data)
|
|
} else {
|
|
resolve(null)
|
|
}
|
|
}
|
|
})
|
|
}
|
|
|
|
export async function clearExpiredCache(): Promise<void> {
|
|
if (!db) await initDatabase()
|
|
|
|
return new Promise((resolve, reject) => {
|
|
const transaction = db!.transaction([STORE_NAME], 'readwrite')
|
|
const store = transaction.objectStore(STORE_NAME)
|
|
const request = store.openCursor()
|
|
const now = Date.now()
|
|
|
|
request.onsuccess = (event) => {
|
|
const cursor = (event.target as IDBRequest).result
|
|
if (cursor) {
|
|
const entry = cursor.value as CacheEntry
|
|
if (entry.expiresAt < now) {
|
|
cursor.delete()
|
|
}
|
|
cursor.continue()
|
|
} else {
|
|
// Cursor is done, resolve
|
|
resolve()
|
|
}
|
|
}
|
|
|
|
request.onerror = () => reject(request.error)
|
|
})
|
|
}
|