forked from noxious/client
70 lines
1.9 KiB
TypeScript
70 lines
1.9 KiB
TypeScript
import config from '@/config'
|
|
import Dexie from 'dexie'
|
|
import type { AssetDataT } from '@/types'
|
|
|
|
export class AssetStorage {
|
|
private db: Dexie
|
|
|
|
constructor() {
|
|
this.db = new Dexie('assets')
|
|
this.db.version(1).stores({
|
|
assets: 'key, group'
|
|
})
|
|
}
|
|
|
|
async download(asset: AssetDataT) {
|
|
try {
|
|
// Check if the asset already exists, then check if updatedAt is newer
|
|
const _asset = await this.db.table('assets').get(asset.key)
|
|
if (_asset && _asset.updatedAt > asset.updatedAt) {
|
|
return
|
|
}
|
|
|
|
// Download the asset
|
|
const response = await fetch(config.server_endpoint + asset.data)
|
|
const blob = await response.blob()
|
|
|
|
// Store the asset in the database
|
|
await this.db.table('assets').put({ key: asset.key, data: blob, group: asset.group, updatedAt: asset.updatedAt, frameCount: asset.frameCount, frameWidth: asset.frameWidth, frameHeight: asset.frameHeight })
|
|
} catch (error) {
|
|
console.error(`Failed to add asset ${asset.key}:`, error)
|
|
}
|
|
}
|
|
|
|
async get(key: string) {
|
|
try {
|
|
const asset = await this.db.table('assets').get(key)
|
|
if (asset) {
|
|
return {
|
|
...asset,
|
|
data: URL.createObjectURL(asset.data) // Convert blob to data URL
|
|
}
|
|
}
|
|
} catch (error) {
|
|
console.error(`Failed to retrieve asset ${key}:`, error)
|
|
}
|
|
return null
|
|
}
|
|
|
|
async getByGroup(group: string) {
|
|
try {
|
|
const assets = await this.db.table('assets').where('group').equals(group).toArray()
|
|
return assets.map((asset) => ({
|
|
...asset,
|
|
data: URL.createObjectURL(asset.data) // Convert blob to data URL
|
|
}))
|
|
} catch (error) {
|
|
console.error(`Failed to retrieve assets for group ${group}:`, error)
|
|
return []
|
|
}
|
|
}
|
|
|
|
async delete(key: string) {
|
|
try {
|
|
await this.db.table('assets').delete(key)
|
|
} catch (error) {
|
|
console.error(`Failed to delete asset ${key}:`, error)
|
|
}
|
|
}
|
|
}
|