import { tap, expect } from '@pushrocks/tapbundle'; import * as smartpromise from '@pushrocks/smartpromise'; import { Qenv } from '@pushrocks/qenv'; let testQenv = new Qenv(process.cwd(), process.cwd() + '/.nogit/'); // the tested module import * as smartdata from '../ts/index'; import { smartstring } from '../ts/smartdata.plugins'; import * as shortid from 'shortid'; // ======================================= // Connecting to the database server // ======================================= let testDb = new smartdata.SmartdataDb({ mongoDbName: process.env.MONGO_DBNAME, mongoDbUrl: process.env.MONGO_URL, mongoDbPass: process.env.MONGO_PASS }); tap.test('should establish a connection to the rethink Db cluster', async () => { await testDb.init(); }); // ======================================= // The actual tests // ======================================= // ------ // Collections // ------ @smartdata.Collection(testDb) class Car extends smartdata.SmartDataDbDoc { @smartdata.unI() index: string = shortid(); @smartdata.svDb() color: string; @smartdata.svDb() brand: string; constructor(colorArg: string, brandArg: string) { super(); this.color = colorArg; this.brand = brandArg; } } tap.test('should save the car to the db', async () => { const myCar = new Car('red', 'Volvo'); await myCar.save(); }); tap.test('expect to get instance of Car', async () => { let myCars = await Car.getInstances({ brand: 'Volvo' }); expect(myCars[0].color).to.equal('red'); }); // ======================================= // close the database connection // ======================================= tap.test('should close the database connection', async tools => { await testDb.close(); }); tap.start({ throwOnError: true });