EVOgeek/Vmeda.Online
1
0
Fork 1
Code Issues Pull Requests Packages Projects Releases Wiki Activity

MOBILE-3565 core: Fix some ESLint of CoreSyncProvider

Browse Source
This commit is contained in:
Dani Palou 2020-10-14 08:31:47 +02:00
parent 7391604008
commit e514000623
1 changed files with 24 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
src/app/services/sync.ts
View File

@ -17,6 +17,8 @@ import { CoreEvents, CoreEventsProvider } from '@services/events';
import { CoreSites, CoreSiteSchema } from '@services/sites'; import { CoreSites, CoreSiteSchema } from '@services/sites';
import { makeSingleton } from '@singletons/core.singletons'; import { makeSingleton } from '@singletons/core.singletons';
const SYNC_TABLE = 'sync';
/* /*
* Service that provides some features regarding synchronization. * Service that provides some features regarding synchronization.
*/ */
@ -24,36 +26,35 @@ import { makeSingleton } from '@singletons/core.singletons';
export class CoreSyncProvider { export class CoreSyncProvider {
// Variables for the database. // Variables for the database.
protected SYNC_TABLE = 'sync';
protected siteSchema: CoreSiteSchema = { protected siteSchema: CoreSiteSchema = {
name: 'CoreSyncProvider', name: 'CoreSyncProvider',
version: 1, version: 1,
tables: [ tables: [
{ {
name: this.SYNC_TABLE, name: SYNC_TABLE,
columns: [ columns: [
{ {
name: 'component', name: 'component',
type: 'TEXT', type: 'TEXT',
notNull: true notNull: true,
}, },
{ {
name: 'id', name: 'id',
type: 'TEXT', type: 'TEXT',
notNull: true notNull: true,
}, },
{ {
name: 'time', name: 'time',
type: 'INTEGER' type: 'INTEGER',
}, },
{ {
name: 'warnings', name: 'warnings',
type: 'TEXT' type: 'TEXT',
} },
],
primaryKeys: ['component', 'id'],
},
], ],
primaryKeys: ['component', 'id']
}
]
}; };
// Store blocked sync objects. // Store blocked sync objects.
@ -63,7 +64,7 @@ export class CoreSyncProvider {
CoreSites.instance.registerSiteSchema(this.siteSchema); CoreSites.instance.registerSiteSchema(this.siteSchema);
// Unblock all blocks on logout. // Unblock all blocks on logout.
CoreEvents.instance.on(CoreEventsProvider.LOGOUT, (data) => { CoreEvents.instance.on(CoreEventsProvider.LOGOUT, (data: {siteId: string}) => {
this.clearAllBlocks(data.siteId); this.clearAllBlocks(data.siteId);
}); });
} }
@ -125,32 +126,33 @@ export class CoreSyncProvider {
/** /**
* Returns a sync record. * Returns a sync record.
*
* @param component Component name. * @param component Component name.
* @param id Unique ID per component. * @param id Unique ID per component.
* @param siteId Site ID. If not defined, current site. * @param siteId Site ID. If not defined, current site.
* @return Record if found or reject. * @return Record if found or reject.
*/ */
getSyncRecord(component: string, id: string | number, siteId?: string): Promise<any> { getSyncRecord(component: string, id: string | number, siteId?: string): Promise<Record<string, unknown>> {
return CoreSites.instance.getSiteDb(siteId).then((db) => { return CoreSites.instance.getSiteDb(siteId).then((db) => db.getRecord(SYNC_TABLE, { component: component, id: id }));
return db.getRecord(this.SYNC_TABLE, { component: component, id: id });
});
} }
/** /**
* Inserts or Updates info of a sync record. * Inserts or Updates info of a sync record.
*
* @param component Component name. * @param component Component name.
* @param id Unique ID per component. * @param id Unique ID per component.
* @param data Data that updates the record. * @param data Data that updates the record.
* @param siteId Site ID. If not defined, current site. * @param siteId Site ID. If not defined, current site.
* @return Promise resolved with done. * @return Promise resolved with done.
*/ */
insertOrUpdateSyncRecord(component: string, id: string | number, data: any, siteId?: string): Promise<any> { async insertOrUpdateSyncRecord(component: string, id: string | number, data: Record<string, unknown>, siteId?: string):
return CoreSites.instance.getSiteDb(siteId).then((db) => { Promise<void> {
const db = await CoreSites.instance.getSiteDb(siteId);
data.component = component; data.component = component;
data.id = id; data.id = id;
return db.insertRecord(this.SYNC_TABLE, data); await db.insertRecord(SYNC_TABLE, data);
});
} }
/** /**
@ -206,6 +208,7 @@ export class CoreSyncProvider {
delete this.blockedItems[siteId][uniqueId][operation]; delete this.blockedItems[siteId][uniqueId][operation];
} }
} }
} }
export class CoreSync extends makeSingleton(CoreSyncProvider) {} export class CoreSync extends makeSingleton(CoreSyncProvider) {}