jackhadrill/indexeddb-chunk-store
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Database name and object store name creation

Browse Source
This commit is contained in:
Damjan Bursac 2019-05-16 08:51:57 +02:00
parent 930d35d3b1
commit f43e26b1b9
1 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/Store.ts
View File

@ -11,10 +11,13 @@ export default class Store {
private eventEmitter: EventEmitter; private eventEmitter: EventEmitter;
// Use to count number of store objects created. Determine database nome // Use to count number of store objects created. Determine database name
private static storeCount: number = 0 private static storeCount: number = 0
private readonly currentStoreCount: number = 0 private readonly currentStoreCount: number = 0
/** @var {string} osName - Object store name */
private readonly osName: string = 'chunks'
constructor (chunkLength: number) { constructor (chunkLength: number) {
this.currentStoreCount = Store.storeCount this.currentStoreCount = Store.storeCount
this.chunkLength = chunkLength; this.chunkLength = chunkLength;
@ -45,7 +48,7 @@ export default class Store {
this.db = ev.target.result; this.db = ev.target.result;
// Create an objectStore for this database // Create an objectStore for this database
this.db.createObjectStore('torrent_chunk_store'); this.db.createObjectStore(this.osName);
}; };
} }
@ -61,8 +64,8 @@ export default class Store {
} }
this.executeFn(() => { this.executeFn(() => {
let transaction = self.db.transaction('torrent_chunk_store', 'readonly'); let transaction = this.db.transaction(this.osName, 'readonly');
let request = transaction.objectStore('torrent_chunk_store').get(index); let request = transaction.objectStore(this.osName).get(index);
transaction.onerror = (ev) => { transaction.onerror = (ev) => {
// Don't forget to handle errors! // Don't forget to handle errors!
@ -105,7 +108,7 @@ export default class Store {
// Don't forget to handle errors! // Don't forget to handle errors!
} }
let request = transaction.objectStore('torrent_chunk_store').put(chunkBuffer, index) let request = transaction.objectStore(this.osName).put(chunkBuffer, index)
this.resolveRequest(request, (err, ev) => { this.resolveRequest(request, (err, ev) => {
cb(err, ev) cb(err, ev)
@ -139,7 +142,7 @@ export default class Store {
* Get database name based on storeCount * Get database name based on storeCount
*/ */
private getDatabaseName () { private getDatabaseName () {
const databaseName = 'torrent_chunks' const databaseName = 'torrent_chunk_store'
if (this.currentStoreCount === 0) { if (this.currentStoreCount === 0) {
return databaseName return databaseName
@ -148,6 +151,11 @@ export default class Store {
return databaseName + '_' + this.currentStoreCount return databaseName + '_' + this.currentStoreCount
} }
/**
* Resolve IDBRequest.
* @param {IDBRequest} request
* @param {Function} cb
*/
private resolveRequest (request: IDBRequest, cb?: (err: Error, ev?: Event) => void) { private resolveRequest (request: IDBRequest, cb?: (err: Error, ev?: Event) => void) {
request.onsuccess = (ev) => { request.onsuccess = (ev) => {
cb(null, ev) cb(null, ev)
@ -158,6 +166,10 @@ export default class Store {
} }
} }
/**
* Execute IDBRequest depending whether database is opened or not
* @param cb
*/
private executeFn (cb) { private executeFn (cb) {
if (!this.db) { if (!this.db) {
this.eventEmitter.subscribe(cb) this.eventEmitter.subscribe(cb)