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 */ collection: SmartdataCollection; /** * how the Doc in memory was created, may prove useful later. */ creationStatus: TDocCreation = 'new'; /** * unique indexes */ uniqueIndexes: string[]; /** * an array of saveable properties of a doc */ saveableProperties: string[]; /** * name */ name: string; /** * primary id in the database */ dbDocUniqueId: string; /** * class constructor */ constructor() { this.name = this.constructor['name']; this.collection = this.constructor['smartdataCollection']; } static async getInstances(filterArg): Promise { let self: any = this; // fool typesystem let referenceMongoDBCollection: SmartdataCollection = self.smartdataCollection; const foundDocs = await referenceMongoDBCollection.find(filterArg); const returnArray = []; for (let item of foundDocs) { let newInstance = new this(); for (let key in item) { if (key !== 'id') { newInstance[key] = item[key]; } } returnArray.push(newInstance); } return returnArray; } static async getInstance(filterArg): Promise { let 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 */ async save() { let self: any = this; switch (this.creationStatus) { case 'db': await this.collection.update(self); break; case 'new': let writeResult = await this.collection.insert(self); this.creationStatus = 'db'; break; default: console.error('neither new nor in db?'); } } /** * also store any referenced objects to DB * better for data consistency */ saveDeep(savedMapArg: Objectmap> = null) { if (!savedMapArg) { savedMapArg = new Objectmap>(); } savedMapArg.add(this); this.save(); for (let propertyKey in this) { let property: any = this[propertyKey]; if (property instanceof SmartDataDbDoc && !savedMapArg.checkForObject(property)) { property.saveDeep(savedMapArg); } } } async createSavableObject() { let saveableObject: any = {}; // is not exposed to outside, so any is ok here for (let propertyNameString of this.saveableProperties) { saveableObject[propertyNameString] = this[propertyNameString]; } return saveableObject; } }