let _ = require('lodash'); let async = require('async'); let restify = require('restify'); let assert = require('chai').assert; import { ConfigParams } from 'pip-services3-commons-node'; import { Descriptor } from 'pip-services3-commons-node'; import { References } from 'pip-services3-commons-node'; import { EmailNullClientV1 } from 'pip-clients-email-node'; import { EmailSettingsV1 } from '../../src/data/version1/EmailSettingsV1'; import { EmailSettingsMemoryPersistence } from '../../src/persistence/EmailSettingsMemoryPersistence'; import { EmailSettingsController } from '../../src/logic/EmailSettingsController'; let SETTINGS = { id: '1', name: 'User 1', email: 'user1@conceptual.vision', language: 'en', verified: false }; suite('EmailSettingsController', () => { let persistence: EmailSettingsMemoryPersistence; let controller: EmailSettingsController; setup(() => { persistence = new EmailSettingsMemoryPersistence(); controller = new EmailSettingsController(); controller.configure(new ConfigParams()); let references: References = References.fromTuples( new Descriptor('pip-services-emailsettings', 'persistence', 'memory', 'default', '1.0'), persistence, new Descriptor('pip-services-emailsettings', 'controller', 'default', 'default', '1.0'), controller, new Descriptor('pip-services-email', 'client', 'null', 'default', '1.0'), new EmailNullClientV1() ); controller.setReferences(references); }); test('CRUD Operations', (done) => { let settings1: EmailSettingsV1; async.series([ // Create email settings (callback) => { controller.setSettings( null, SETTINGS, (err, settings) => { assert.isNull(err); assert.isObject(settings); assert.equal(settings.id, SETTINGS.id); assert.equal(settings.email, SETTINGS.email); assert.isFalse(settings.verified); settings1 = settings; callback(); } ); }, // Update the settings (callback) => { settings1.subscriptions.engagement = true; controller.setSettings( null, settings1, (err, settings) => { assert.isNull(err); assert.isObject(settings); assert.equal(settings.id, settings1.id) assert.isTrue(settings.subscriptions.engagement); callback(); } ); }, // Get settings (callback) => { controller.getSettingsByIds( null, [settings1.id], (err, settings) => { assert.isNull(err); assert.lengthOf(settings, 1); callback(); } ); }, // Delete settings (callback) => { controller.deleteSettingsById( null, settings1.id, (err) => { assert.isNull(err); callback(); } ); }, // Try to get deleted settings (callback) => { controller.getSettingsById( null, settings1.id, (err, settings) => { assert.isNull(err); assert.isNull(settings); callback(); } ); } ], done); }); test('Verify Email', (done) => { let settings1: EmailSettingsV1; async.series([ // Create new settings (callback) => { settings1 = _.clone(SETTINGS); settings1.ver_code = '123'; settings1.verified = false; settings1.ver_expire_time = new Date(new Date().getTime() + 10000); persistence.set( null, settings1, (err, settings) => { assert.isNull(err); assert.isObject(settings); settings1 = settings; assert.isFalse(settings.verified); assert.isDefined(settings.ver_code); callback(); } ); }, // Verify email (callback) => { controller.verifyEmail( null, settings1.id, settings1.ver_code, (err) => { assert.isNull(err); callback(); } ); }, // Check settings (callback) => { persistence.getOneById( null, settings1.id, (err, settings) => { assert.isNull(err); assert.isObject(settings); settings1 = settings; assert.isTrue(settings.verified); assert.isNull(settings.ver_code); callback(); } ); } ], done); }); test('Change verification code length', (done) => { let settings1: EmailSettingsV1; controller.configure(ConfigParams.fromTuples("options.code_length", "6")); async.series([ // Create new settings (callback) => { persistence.set( null, SETTINGS, (err, settings) => { assert.isNull(err); assert.isObject(settings); settings1 = settings; assert.isFalse(settings.verified); assert.isUndefined(settings.ver_code); callback(); } ); }, // Verify email (callback) => { controller.resendVerification( null, settings1.id, (err) => { assert.isNull(err); callback(); } ); }, // Check settings (callback) => { persistence.getOneById( null, settings1.id, (err, settings) => { assert.isNull(err); assert.isObject(settings); settings1 = settings; assert.isFalse(settings.verified); assert.isNotNull(settings.ver_code); assert.equal(settings.ver_code.length, 6); callback(); } ); } ], done); }); test('Resend Verification Email', (done) => { let settings1: EmailSettingsV1; async.series([ // Create new settings (callback) => { persistence.set( null, SETTINGS, (err, settings) => { assert.isNull(err); assert.isObject(settings); settings1 = settings; assert.isFalse(settings.verified); assert.isUndefined(settings.ver_code); callback(); } ); }, // Verify email (callback) => { controller.resendVerification( null, settings1.id, (err) => { assert.isNull(err); callback(); } ); }, // Check settings (callback) => { persistence.getOneById( null, settings1.id, (err, settings) => { assert.isNull(err); assert.isObject(settings); settings1 = settings; assert.isFalse(settings.verified); assert.isNotNull(settings.ver_code); assert.equal(settings.ver_code.length, 9); callback(); } ); } ], done); }); });