OpenCloud
/
PeerTube
mirror of https://github.com/Chocobozzz/PeerTube
1
0
Fork 0
Code Issues Releases Wiki Activity

Catch indexdb database destroy

pull/572/head
Chocobozzz 2018-05-15 16:52:19 +02:00
parent e998cf3cc7
commit 4935a6a1fd
No known key found for this signature in database
GPG Key ID: 583A612D890159BE
1 changed files with 12 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
client/src/assets/player/peertube-chunk-store.ts
View File

@ -183,25 +183,21 @@ export class PeertubeChunkStore extends EventEmitter {
private checkExpiration () {
this.expirationDB.transaction('rw', this.expirationDB.databases, async () => {
try {
// Update our database expiration since we are alive
await this.expirationDB.databases.put({
name: this.databaseName,
expiration: new Date().getTime() + PeertubeChunkStore.CLEANER_EXPIRATION_MS
})
// Update our database expiration since we are alive
await this.expirationDB.databases.put({
name: this.databaseName,
expiration: new Date().getTime() + PeertubeChunkStore.CLEANER_EXPIRATION_MS
})
const now = new Date().getTime()
const databasesToDeleteInfo = await this.expirationDB.databases.where('expiration').below(now).toArray()
const now = new Date().getTime()
const databasesToDeleteInfo = await this.expirationDB.databases.where('expiration').below(now).toArray()
for (const databaseToDeleteInfo of databasesToDeleteInfo) {
await this.dropDatabase(databaseToDeleteInfo.name)
for (const databaseToDeleteInfo of databasesToDeleteInfo) {
await this.dropDatabase(databaseToDeleteInfo.name)
await this.expirationDB.databases.where({ name: databaseToDeleteInfo.name }).delete()
}
} catch (err) {
console.error('Cannot check expiration.', err)
await this.expirationDB.databases.where({ name: databaseToDeleteInfo.name }).delete()
}
})
}).catch(err => console.error('Cannot check expiration.', err))
}
private dropDatabase (databaseName: string) {
@ -209,6 +205,7 @@ export class PeertubeChunkStore extends EventEmitter {
console.log('Deleting %s.', databaseName)
return dbToDelete.delete()
.catch(err => console.error('Cannot delete %s.', databaseName))
}
private nextTick (cb, err, val?) {