import * as plugins from './smartdata.plugins'; import { ObjectMap } from '@pushrocks/lik'; import { SmartdataDb } from './smartdata.classes.db'; import { SmartdataCollection } from './smartdata.classes.collection'; export type TDocCreation = 'db' | 'new' | 'mixed'; /** * saveable - saveable decorator to be used on class properties */ export function svDb() { return (target: SmartDataDbDoc, key: string) => { console.log(`called svDb() on ${key}`); if (!target.saveableProperties) { target.saveableProperties = []; } target.saveableProperties.push(key); }; } /** * unique index - decorator to mark a unique index */ export function unI() { return (target: SmartDataDbDoc, key: string) => { console.log('called unI'); // mark the index as unique if (!target.uniqueIndexes) { target.uniqueIndexes = []; } target.uniqueIndexes.push(key); // and also save it if (!target.saveableProperties) { target.saveableProperties = []; } target.saveableProperties.push(key); }; } export class SmartDataDbDoc { /** * the collection object an Doc belongs to */ public collection: SmartdataCollection; /** * how the Doc in memory was created, may prove useful later. */ public creationStatus: TDocCreation = 'new'; /** * unique indexes */ public uniqueIndexes: string[]; /** * an array of saveable properties of a doc */ public saveableProperties: string[]; /** * name */ public name: string; /** * primary id in the database */ public dbDocUniqueId: string; /** * class constructor */ constructor() { this.name = this.constructor['name']; if (this.constructor['smartdataCollection']) { // tslint:disable-next-line: no-string-literal this.collection = this.constructor['smartdataCollection']; // tslint:disable-next-line: no-string-literal } else if (typeof this.constructor['smartdataDelayedCollection'] === 'function') { // tslint:disable-next-line: no-string-literal this.collection = this.constructor['smartdataDelayedCollection'](); } else { console.error('Could not determine collection for DbDoc'); } } public static async getInstances(filterArg: Partial): Promise { const self: any = this; // fool typesystem let referenceMongoDBCollection: SmartdataCollection; if (self.smartdataCollection) { referenceMongoDBCollection = self.smartdataCollection; } else if (self.smartdataDelayedCollection) { referenceMongoDBCollection = self.smartdataDelayedCollection(); } const foundDocs = await referenceMongoDBCollection.find(filterArg); const returnArray = []; for (const item of foundDocs) { const newInstance = new this(); newInstance.creationStatus = 'db'; for (const key of Object.keys(item)) { newInstance[key] = item[key]; } returnArray.push(newInstance); } return returnArray; } public static async getInstance(filterArg: Partial): Promise { const result = await this.getInstances(filterArg); if (result && result.length > 0) { return result[0]; } } /** * saves this instance but not any connected items * may lead to data inconsistencies, but is faster */ public async save() { // tslint:disable-next-line: no-this-assignment const self: any = this; switch (this.creationStatus) { case 'db': await this.collection.update(self); break; case 'new': const writeResult = await this.collection.insert(self); this.creationStatus = 'db'; break; default: console.error('neither new nor in db?'); } } /** * deletes a document from the database */ public async delete() { const self: any = this; await this.collection.delete(self); } /** * also store any referenced objects to DB * better for data consistency */ public saveDeep(savedMapArg: ObjectMap> = null) { if (!savedMapArg) { savedMapArg = new ObjectMap>(); } savedMapArg.add(this); this.save(); for (const propertyKey of Object.keys(this)) { const property: any = this[propertyKey]; if (property instanceof SmartDataDbDoc && !savedMapArg.checkForObject(property)) { property.saveDeep(savedMapArg); } } } /** * creates a saveable object so the instance can be persisted as json in the database */ public async createSavableObject(): Promise { const saveableObject: unknown = {}; // is not exposed to outside, so any is ok here for (const propertyNameString of this.saveableProperties) { saveableObject[propertyNameString] = this[propertyNameString]; } return saveableObject as TImplements; } /** * creates an identifiable object for operations that require filtering */ public async createIdentifiableObject() { const identifiableObject: any = {}; // is not exposed to outside, so any is ok here for (const propertyNameString of this.uniqueIndexes) { identifiableObject[propertyNameString] = this[propertyNameString]; } return identifiableObject; } }