Merge branch 'dev' into 5418-buscador-lateral-fixed-price

db/changes/231202/00-delivery.sql

@@ -0,0 +1,74 @@
+DROP TABLE `vn`.`dmsRecover`;
+
+ALTER TABLE `vn`.`delivery` DROP FOREIGN KEY delivery_FK;
+ALTER TABLE `vn`.`delivery` DROP COLUMN addressFk;
+ALTER TABLE `vn`.`delivery` ADD ticketFk INT NOT NULL;
+ALTER TABLE `vn`.`delivery` ADD CONSTRAINT delivery_ticketFk_FK FOREIGN KEY (`ticketFk`) REFERENCES `vn`.`ticket`(`id`);
+
+DELETE FROM `salix`.`ACL` WHERE `property` = 'saveSign';
+INSERT INTO `salix`.`ACL` (`model`,`property`,`accessType`,`permission`,`principalId`)
+    VALUES
+        ('Ticket','saveSign','WRITE','ALLOW','employee');
+
+DROP PROCEDURE IF EXISTS vn.route_getTickets;
+
+DELIMITER $$
+$$
+CREATE DEFINER=`root`@`localhost` PROCEDURE `vn`.`route_getTickets`(vRouteFk INT)
+BEGIN
+/**
+ * Pasado un RouteFk devuelve la información
+ * de sus tickets.
+ *
+ * @param vRouteFk
+ *
+ * @select Información de los tickets
+ */
+
+    SELECT
+            t.id Id,
+            t.clientFk Client,
+            a.id Address,
+            t.packages Packages,
+            a.street AddressName,
+            a.postalCode PostalCode,
+            a.city City,
+            sub2.itemPackingTypeFk PackingType,
+            c.phone ClientPhone,
+            c.mobile ClientMobile,
+            a.phone AddressPhone,
+            a.mobile AddressMobile,
+            d.longitude Longitude,
+            d.latitude Latitude,
+            wm.mediaValue SalePersonPhone,
+            tob.Note Note,
+            t.isSigned Signed
+        FROM ticket t
+            JOIN client c ON t.clientFk = c.id
+            JOIN address a ON t.addressFk = a.id
+            LEFT JOIN delivery d ON t.id = d.ticketFk
+            LEFT JOIN workerMedia wm ON wm.workerFk = c.salesPersonFk
+            LEFT JOIN
+                (SELECT tob.description Note, t.id
+                    FROM ticketObservation tob
+                        JOIN ticket t ON tob.ticketFk = t.id
+                        JOIN observationType ot ON ot.id = tob.observationTypeFk
+                    WHERE t.routeFk = vRouteFk
+                        AND ot.code = 'delivery'
+                )tob ON tob.id = t.id
+            LEFT JOIN
+                (SELECT sub.ticketFk,
+                    CONCAT('(', GROUP_CONCAT(DISTINCT sub.itemPackingTypeFk ORDER BY sub.items DESC SEPARATOR ','), ') ') itemPackingTypeFk
+                    FROM (SELECT s.ticketFk , i.itemPackingTypeFk, COUNT(*) items
+                        FROM ticket t
+                        JOIN sale s ON s.ticketFk = t.id
+                        JOIN item i ON i.id = s.itemFk
+                        WHERE t.routeFk = vRouteFk
+                        GROUP BY t.id,i.itemPackingTypeFk)sub
+                    GROUP BY sub.ticketFk
+                ) sub2 ON sub2.ticketFk = t.id
+        WHERE t.routeFk = vRouteFk
+        GROUP BY t.id
+        ORDER BY t.priority;
+END$$
+DELIMITER ;

db/changes/231203/00-delivery.sql

@@ -0,0 +1,67 @@
+DELETE FROM `salix`.`ACL` WHERE `property` = 'saveSign';
+INSERT INTO `salix`.`ACL` (`model`,`property`,`accessType`,`permission`,`principalId`)
+    VALUES
+        ('Ticket','saveSign','WRITE','ALLOW','employee');
+
+DROP PROCEDURE IF EXISTS vn.route_getTickets;
+
+DELIMITER $$
+$$
+CREATE DEFINER=`root`@`localhost` PROCEDURE `vn`.`route_getTickets`(vRouteFk INT)
+BEGIN
+/**
+ * Pasado un RouteFk devuelve la información
+ * de sus tickets.
+ *
+ * @param vRouteFk
+ *
+ * @select Información de los tickets
+ */
+
+    SELECT
+            t.id Id,
+            t.clientFk Client,
+            a.id Address,
+            t.packages Packages,
+            a.street AddressName,
+            a.postalCode PostalCode,
+            a.city City,
+            sub2.itemPackingTypeFk PackingType,
+            c.phone ClientPhone,
+            c.mobile ClientMobile,
+            a.phone AddressPhone,
+            a.mobile AddressMobile,
+            d.longitude Longitude,
+            d.latitude Latitude,
+            wm.mediaValue SalePersonPhone,
+            tob.Note Note,
+            t.isSigned Signed
+        FROM ticket t
+            JOIN client c ON t.clientFk = c.id
+            JOIN address a ON t.addressFk = a.id
+            LEFT JOIN delivery d ON t.id = d.ticketFk
+            LEFT JOIN workerMedia wm ON wm.workerFk = c.salesPersonFk
+            LEFT JOIN
+                (SELECT tob.description Note, t.id
+                    FROM ticketObservation tob
+                        JOIN ticket t ON tob.ticketFk = t.id
+                        JOIN observationType ot ON ot.id = tob.observationTypeFk
+                    WHERE t.routeFk = vRouteFk
+                        AND ot.code = 'delivery'
+                )tob ON tob.id = t.id
+            LEFT JOIN
+                (SELECT sub.ticketFk,
+                    CONCAT('(', GROUP_CONCAT(DISTINCT sub.itemPackingTypeFk ORDER BY sub.items DESC SEPARATOR ','), ') ') itemPackingTypeFk
+                    FROM (SELECT s.ticketFk , i.itemPackingTypeFk, COUNT(*) items
+                        FROM ticket t
+                        JOIN sale s ON s.ticketFk = t.id
+                        JOIN item i ON i.id = s.itemFk
+                        WHERE t.routeFk = vRouteFk
+                        GROUP BY t.id,i.itemPackingTypeFk)sub
+                    GROUP BY sub.ticketFk
+                ) sub2 ON sub2.ticketFk = t.id
+        WHERE t.routeFk = vRouteFk
+        GROUP BY t.id
+        ORDER BY t.priority;
+END$$
+DELIMITER ;

db/changes/231204/00-rollbackDelivery.sql

@@ -0,0 +1,83 @@
+CREATE TABLE `vn`.`dmsRecover` (
+  `id` int(11) NOT NULL AUTO_INCREMENT,
+  `ticketFk` int(11) DEFAULT NULL,
+  `sign` text DEFAULT NULL,
+  `created` timestamp NULL DEFAULT current_timestamp(),
+  PRIMARY KEY (`id`),
+  KEY `ticketFk_idx` (`ticketFk`),
+  CONSTRAINT `ticketFk` FOREIGN KEY (`ticketFk`) REFERENCES `ticket` (`id`) ON DELETE CASCADE ON UPDATE CASCADE
+) ENGINE=InnoDB AUTO_INCREMENT=31917 DEFAULT CHARSET=utf8mb3 COLLATE=utf8mb3_unicode_ci;
+
+ALTER TABLE `vn`.`delivery` ADD addressFk INT;
+
+DROP PROCEDURE IF EXISTS `vn`.`route_getTickets`;
+
+DELIMITER $$
+$$
+CREATE DEFINER=`root`@`localhost` PROCEDURE `vn`.`route_getTickets`(vRouteFk INT)
+BEGIN
+/**
+ * Pasado un RouteFk devuelve la información
+ * de sus tickets.
+ *
+ * @param vRouteFk
+ * @select Información de los tickets
+ */
+SELECT	*
+	FROM (
+		SELECT t.id Id,
+				t.clientFk Client,
+				a.id Address,
+				a.nickname ClientName,
+				t.packages Packages,
+				a.street AddressName,
+				a.postalCode PostalCode,
+				a.city City,
+				sub2.itemPackingTypeFk PackingType,
+				c.phone ClientPhone,
+				c.mobile ClientMobile,
+				a.phone AddressPhone,
+				a.mobile AddressMobile,
+				d.longitude Longitude,
+				d.latitude Latitude,
+				wm.mediaValue SalePersonPhone,
+				tob.description Note,
+				t.isSigned Signed,
+				t.priority
+			FROM ticket t
+				JOIN client c ON t.clientFk = c.id
+				JOIN address a ON t.addressFk = a.id
+				LEFT JOIN delivery d ON d.addressFk = a.id
+				LEFT JOIN workerMedia wm ON wm.workerFk = c.salesPersonFk
+				LEFT JOIN(
+					SELECT tob.description, t.id
+						FROM ticketObservation tob
+							JOIN ticket t ON tob.ticketFk = t.id
+							JOIN observationType ot ON ot.id = tob.observationTypeFk
+						WHERE t.routeFk = vRouteFk
+							AND ot.code = 'delivery'
+				)tob ON tob.id = t.id
+				LEFT JOIN(
+					SELECT sub.ticketFk,
+							CONCAT('(',
+								GROUP_CONCAT(DISTINCT sub.itemPackingTypeFk
+									ORDER BY sub.items DESC SEPARATOR ','),
+								') ') itemPackingTypeFk
+						FROM (
+							SELECT s.ticketFk, i.itemPackingTypeFk, COUNT(*) items
+								FROM ticket t
+									JOIN sale s ON s.ticketFk = t.id
+									JOIN item i ON i.id = s.itemFk
+								WHERE t.routeFk = vRouteFk
+								GROUP BY t.id, i.itemPackingTypeFk
+						)sub
+						GROUP BY sub.ticketFk
+				)sub2 ON sub2.ticketFk = t.id
+			WHERE t.routeFk = vRouteFk
+			ORDER BY d.id DESC
+			LIMIT 10000000000000000000
+	)sub3
+	GROUP BY sub3.id
+	ORDER BY sub3.priority;
+END$$
+DELIMITER ;

e2e/paths/02-client/13_log.spec.js

@@ -28,22 +28,4 @@ describe('Client log path', () => {
     it('should navigate to the log section', async() => {
         await page.accessToSection('client.card.log');
     });
-
-    it('should check the previous value of the last logged change', async() => {
-        let lastModificationPreviousValue = await page
-            .waitToGetProperty(selectors.clientLog.lastModificationPreviousValue, 'innerText');
-
-        expect(lastModificationPreviousValue).toContain('DavidCharlesHaller');
-    });
-
-    it('should check the current value of the last logged change', async() => {
-        let lastModificationPreviousValue = await page
-            .waitToGetProperty(selectors.clientLog.lastModificationPreviousValue, 'innerText');
-
-        let lastModificationCurrentValue = await page.
-            waitToGetProperty(selectors.clientLog.lastModificationCurrentValue, 'innerText');
-
-        expect(lastModificationPreviousValue).toEqual('DavidCharlesHaller');
-        expect(lastModificationCurrentValue).toEqual('this is a test');
-    });
 });

e2e/paths/04-item/10_item_log.spec.js

@@ -42,23 +42,4 @@ describe('Item log path', () => {
         await page.waitForSelector(selectors.itemsIndex.createItemButton);
         await page.waitForState('item.index');
     });
-
-    it(`should search for the created item and navigate to it's log section`, async() => {
-        await page.accessToSearchResult('Knowledge artifact');
-        await page.accessToSection('item.card.log');
-    });
-
-    it(`should confirm the log is showing 4 entries`, async() => {
-        await page.waitForSelector(selectors.itemLog.anyLineCreated);
-        const anyLineCreatedCount = await page.countElement(selectors.itemLog.anyLineCreated);
-
-        expect(anyLineCreatedCount).toEqual(4);
-    });
-
-    xit(`should confirm the log is showing the intrastat for the created item`, async() => {
-        const fifthLineCreatedProperty = await page
-            .waitToGetProperty(selectors.itemLog.fifthLineCreatedProperty, 'innerText');
-
-        expect(fifthLineCreatedProperty).toEqual('05080000');
-    });
 });

e2e/paths/05-ticket/02_expeditions_and_log.spec.js

@@ -29,20 +29,4 @@ describe('Ticket expeditions and log path', () => {
 
         expect(result).toEqual(3);
     });
-
-    it(`should confirm the expedition deleted is shown now in the ticket log`, async() => {
-        await page.accessToSection('ticket.card.log');
-        const user = await page
-            .waitToGetProperty(selectors.ticketLog.user, 'innerText');
-
-        const action = await page
-            .waitToGetProperty(selectors.ticketLog.action, 'innerText');
-
-        const id = await page
-            .waitToGetProperty(selectors.ticketLog.id, 'innerText');
-
-        expect(user).toContain('production');
-        expect(action).toContain('Deletes');
-        expect(id).toEqual('2');
-    });
 });

e2e/paths/05-ticket/17_log.spec.js

@@ -31,30 +31,4 @@ describe('Ticket log path', () => {
 
         expect(message.text).toContain('Data saved!');
     });
-
-    it('should navigate to the log section', async() => {
-        await page.accessToSection('ticket.card.log');
-    });
-
-    it('should set the viewport width to 1920 to see the table full width', async() => {
-        await page.setViewport({
-            width: 1920,
-            height: 0,
-        });
-
-        const result = await page.waitToGetProperty(selectors.ticketLog.firstTD, 'innerText');
-
-        expect(result.length).not.toBeGreaterThan('20');
-    });
-
-    it('should set the viewport width to 800 to see the table shrink and move data to the 1st column', async() => {
-        await page.setViewport({
-            width: 800,
-            height: 0,
-        });
-
-        const result = await page.waitToGetProperty(selectors.ticketLog.firstTD, 'innerText');
-
-        expect(result.length).toBeGreaterThan('15');
-    });
 });

e2e/paths/11-zone/02_descriptor.spec.js

@@ -29,14 +29,4 @@ describe('Zone descriptor path', () => {
 
         expect(count).toEqual(0);
     });
-
-    it('should check the ticket whom lost the zone and see evidence on the logs', async() => {
-        await page.waitToClick(selectors.globalItems.homeButton);
-        await page.selectModule('ticket');
-        await page.accessToSearchResult('20');
-        await page.accessToSection('ticket.card.log');
-        const lastChanges = await page.waitToGetProperty(selectors.ticketLog.changes, 'innerText');
-
-        expect(lastChanges).toContain('1');
-    });
 });

e2e/paths/13-supplier/02_basic_data.spec.js

@@ -64,14 +64,4 @@ describe('Supplier basic data path', () => {
 
         expect(result).toEqual('Some notes');
     });
-
-    it('should navigate to the log section', async() => {
-        await page.accessToSection('supplier.card.log');
-    });
-
-    it('should check the changes have been recorded', async() => {
-        const result = await page.waitToGetProperty('vn-tr table  tr:nth-child(3) td.after', 'innerText');
-
-        expect(result).toEqual('Some notes');
-    });
 });

loopback/common/methods/vn-model/specs/crud.spec.js

@@ -1,6 +1,20 @@
 const app = require('vn-loopback/server/server');
+const LoopBackContext = require('loopback-context');
 
 describe('Model crud()', () => {
+    beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
     let insertId;
     const barcodeModel = app.models.ItemBarcode;
 

loopback/common/methods/vn-model/specs/rewriteDbError.spec.js

@@ -1,6 +1,21 @@
 const models = require('vn-loopback/server/server').models;
+const LoopBackContext = require('loopback-context');
 
 describe('Model rewriteDbError()', () => {
+    beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
+
     it('should extend rewriteDbError properties to any model passed', () => {
         const exampleModel = models.ItemTag;
 

loopback/server/connectors/vn-mysql.js

@@ -1,41 +1,9 @@
 const mysql = require('mysql');
 const MySQL = require('loopback-connector-mysql').MySQL;
 const EnumFactory = require('loopback-connector-mysql').EnumFactory;
-const { Transaction, SQLConnector, ParameterizedSQL } = require('loopback-connector');
+const {Transaction, SQLConnector, ParameterizedSQL} = require('loopback-connector');
 const fs = require('fs');
 
-const limitSet = new Set([
-    'save',
-    'updateOrCreate',
-    'replaceOrCreate',
-    'replaceById',
-    'update'
-]);
-
-const opOpts = {
-    update: [
-        'update',
-        'replaceById',
-        // |insert
-        'save',
-        'updateOrCreate',
-        'replaceOrCreate'
-    ],
-    delete: [
-        'destroy',
-        'destroyAll'
-    ],
-    insert: [
-        'create'
-    ]
-};
-
-const opMap = new Map();
-for (const op in opOpts) {
-    for (const met of opOpts[op])
-        opMap.set(met, op);
-}
-
 class VnMySQL extends MySQL {
     /**
      * Promisified version of execute().
@@ -253,49 +221,49 @@ class VnMySQL extends MySQL {
     }
 
     create(model, data, opts, cb) {
-        const ctx = { data };
+        const ctx = {data};
         this.invokeMethod('create',
             arguments, model, ctx, opts, cb);
     }
 
     createAll(model, data, opts, cb) {
-        const ctx = { data };
+        const ctx = {data};
         this.invokeMethod('createAll',
             arguments, model, ctx, opts, cb);
     }
 
     save(model, data, opts, cb) {
-        const ctx = { data };
+        const ctx = {data};
         this.invokeMethod('save',
             arguments, model, ctx, opts, cb);
     }
 
     updateOrCreate(model, data, opts, cb) {
-        const ctx = { data };
+        const ctx = {data};
         this.invokeMethod('updateOrCreate',
             arguments, model, ctx, opts, cb);
     }
 
     replaceOrCreate(model, data, opts, cb) {
-        const ctx = { data };
+        const ctx = {data};
         this.invokeMethod('replaceOrCreate',
             arguments, model, ctx, opts, cb);
     }
 
     destroyAll(model, where, opts, cb) {
-        const ctx = { where };
+        const ctx = {where};
         this.invokeMethod('destroyAll',
             arguments, model, ctx, opts, cb);
     }
 
     update(model, where, data, opts, cb) {
-        const ctx = { where, data };
+        const ctx = {where, data};
         this.invokeMethod('update',
             arguments, model, ctx, opts, cb);
     }
 
     replaceById(model, id, data, opts, cb) {
-        const ctx = { id, data };
+        const ctx = {id, data};
         this.invokeMethod('replaceById',
             arguments, model, ctx, opts, cb);
     }
@@ -316,45 +284,17 @@ class VnMySQL extends MySQL {
 
     async invokeMethodP(method, args, model, ctx, opts) {
         const Model = this.getModelDefinition(model).model;
-        const settings = Model.definition.settings;
         let tx;
         if (!opts.transaction) {
             tx = await Transaction.begin(this, {});
-            opts = Object.assign({ transaction: tx, httpCtx: opts.httpCtx }, opts);
+            opts = Object.assign({transaction: tx, httpCtx: opts.httpCtx}, opts);
         }
 
         try {
-            // Fetch old values (update|delete) or login
+            const userId = opts.httpCtx && opts.httpCtx.active.accessToken.userId;
-            let where, id, data, idName, limit, op, oldInstances, newInstances;
+            if (userId) {
-            const hasGrabUser = settings.log && settings.log.grabUser;
+                const user = await Model.app.models.Account.findById(userId, {fields: ['name']}, opts);
-            if (hasGrabUser) {
-                const userId = opts.httpCtx && opts.httpCtx.active.accessToken.userId;
-                const user = await Model.app.models.Account.findById(userId, { fields: ['name'] }, opts);
                 await this.executeP(`CALL account.myUser_loginWithName(?)`, [user.name], opts);
-            } else {
-                where = ctx.where;
-                id = ctx.id;
-                data = ctx.data;
-                idName = this.idName(model);
-
-                limit = limitSet.has(method);
-
-                op = opMap.get(method);
-
-                if (!where) {
-                    if (id) where = { [idName]: id };
-                    else where = { [idName]: data[idName] };
-                }
-
-                // Fetch old values
-                switch (op) {
-                    case 'update':
-                    case 'delete':
-                        // Single entity operation
-                        const stmt = this.buildSelectStmt(op, data, idName, model, where, limit);
-                        stmt.merge(`FOR UPDATE`);
-                        oldInstances = await this.executeStmt(stmt, opts);
-                }
             }
 
             const res = await new Promise((resolve, reject) => {
@@ -366,38 +306,7 @@ class VnMySQL extends MySQL {
                 super[method].apply(this, fnArgs);
             });
 
-            if (hasGrabUser)
+            if (userId) await this.executeP(`CALL account.myUser_logout()`, null, opts);
-                await this.executeP(`CALL account.myUser_logout()`, null, opts);
-            else {
-                // Fetch new values
-                const ids = [];
-
-                switch (op) {
-                    case 'insert':
-                    case 'update': {
-                        switch (method) {
-                            case 'createAll':
-                                for (const row of res[0])
-                                    ids.push(row[idName]);
-                                break;
-                            case 'create':
-                                ids.push(res[0]);
-                                break;
-                            case 'update':
-                                if (data[idName] != null)
-                                    ids.push(data[idName]);
-                                break;
-                        }
-
-                        const newWhere = ids.length ? {[idName]: {inq: ids}} : where;
-
-                        const stmt = this.buildSelectStmt(op, data, idName, model, newWhere, limit);
-                        newInstances = await this.executeStmt(stmt, opts);
-                    }
-                }
-
-                await this.createLogRecord(oldInstances, newInstances, model, opts);
-            }
             if (tx) await tx.commit();
             return res;
         } catch (err) {
@@ -405,125 +314,6 @@ class VnMySQL extends MySQL {
             throw err;
         }
     }
-
-    buildSelectStmt(op, data, idName, model, where, limit) {
-        const Model = this.getModelDefinition(model).model;
-        const properties = Object.keys(Model.definition.properties);
-
-        const fields = data ? Object.keys(data) : [];
-        if (op == 'delete')
-            properties.forEach(property => fields.push(property));
-        else {
-            const log = Model.definition.settings.log;
-            fields.push(idName);
-            if (log.relation) fields.push(Model.relations[log.relation].keyFrom);
-            if (log.showField) fields.push(log.showField);
-            else {
-                const showFieldNames = ['name', 'description', 'code', 'nickname'];
-                for (const field of showFieldNames) {
-                    if (properties.includes(field)) {
-                        log.showField = field;
-                        fields.push(field);
-                        break;
-                    }
-                }
-            }
-        }
-
-        const stmt = new ParameterizedSQL(
-            'SELECT ' +
-            this.buildColumnNames(model, { fields }) +
-            ' FROM ' +
-            this.tableEscaped(model)
-        );
-        stmt.merge(this.buildWhere(model, where));
-        if (limit) stmt.merge(`LIMIT 1`);
-
-        return stmt;
-    }
-
-    async createLogRecord(oldInstances, newInstances, model, opts) {
-        function setActionType() {
-            if (oldInstances && newInstances)
-                return 'update';
-            else if (!oldInstances && newInstances)
-                return 'insert';
-            return 'delete';
-        }
-
-        const action = setActionType();
-        if (!newInstances && action != 'delete') return;
-
-        const Model = this.getModelDefinition(model).model;
-        const models = Model.app.models;
-        const definition = Model.definition;
-        const log = definition.settings.log;
-
-        const primaryKey = this.idName(model);
-        const originRelation = log.relation;
-        const originFkField = originRelation
-            ? Model.relations[originRelation].keyFrom
-            : primaryKey;
-
-        // Prevent adding logs when deleting a principal entity (Client, Zone...)
-        if (action == 'delete' && !originRelation) return;
-
-        function map(instances) {
-            const map = new Map();
-            if (!instances) return;
-            for (const instance of instances)
-                map.set(instance[primaryKey], instance);
-            return map;
-        }
-
-        const changedModel = definition.name;
-        const userFk = opts.httpCtx && opts.httpCtx.active.accessToken.userId;
-        const oldMap = map(oldInstances);
-        const newMap = map(newInstances);
-        const ids = (oldMap || newMap).keys();
-
-        const logEntries = [];
-
-        function insertValuesLogEntry(logEntry, instance) {
-            logEntry.originFk = instance[originFkField];
-            logEntry.changedModelId = instance[primaryKey];
-            if (log.showField) logEntry.changedModelValue = instance[log.showField];
-        }
-
-        for (const id of ids) {
-            const oldI = oldMap && oldMap.get(id);
-            const newI = newMap && newMap.get(id);
-
-            const logEntry = {
-                action,
-                userFk,
-                changedModel,
-            };
-
-            if (newI) {
-                insertValuesLogEntry(logEntry, newI);
-                // Delete unchanged properties
-                if (oldI) {
-                    Object.keys(oldI).forEach(prop => {
-                        const hasChanges = oldI[prop] instanceof Date ?
-                            oldI[prop]?.getTime() != newI[prop]?.getTime() :
-                            oldI[prop] != newI[prop];
-
-                        if (!hasChanges) {
-                            delete oldI[prop];
-                            delete newI[prop];
-                        }
-                    });
-                }
-            } else
-                insertValuesLogEntry(logEntry, oldI);
-
-            logEntry.oldInstance = oldI;
-            logEntry.newInstance = newI;
-            logEntries.push(logEntry);
-        }
-        await models[log.model].create(logEntries, opts);
-    }
 }
 
 exports.VnMySQL = VnMySQL;
@@ -544,7 +334,7 @@ exports.initialize = function initialize(dataSource, callback) {
 
     if (callback) {
         if (dataSource.settings.lazyConnect) {
-            process.nextTick(function () {
+            process.nextTick(function() {
                 callback();
             });
         } else
@@ -552,13 +342,13 @@ exports.initialize = function initialize(dataSource, callback) {
     }
 };
 
-MySQL.prototype.connect = function (callback) {
+MySQL.prototype.connect = function(callback) {
     const self = this;
     const options = generateOptions(this.settings);
 
     if (this.client) {
         if (callback) {
-            process.nextTick(function () {
+            process.nextTick(function() {
                 callback(null, self.client);
             });
         }
@@ -567,7 +357,7 @@ MySQL.prototype.connect = function (callback) {
 
     function connectionHandler(options, callback) {
         const client = mysql.createPool(options);
-        client.getConnection(function (err, connection) {
+        client.getConnection(function(err, connection) {
             const conn = connection;
             if (!err) {
                 if (self.debug)
@@ -647,30 +437,27 @@ function generateOptions(settings) {
     return options;
 }
 
-
 SQLConnector.prototype.all = function find(model, filter, options, cb) {
     const self = this;
     // Order by id if no order is specified
     filter = filter || {};
     const stmt = this.buildSelect(model, filter, options);
-    this.execute(stmt.sql, stmt.params, options, function (err, data) {
+    this.execute(stmt.sql, stmt.params, options, function(err, data) {
-        if (err) {
+        if (err)
             return cb(err, []);
-        }
 
         try {
-            const objs = data.map(function (obj) {
+            const objs = data.map(function(obj) {
                 return self.fromRow(model, obj);
             });
             if (filter && filter.include) {
                 self.getModelDefinition(model).model.include(
                     objs, filter.include, options, cb,
                 );
-            } else {
+            } else
                 cb(null, objs);
-            }
         } catch (error) {
-            cb(error, [])
+            cb(error, []);
         }
     });
 };

modules/claim/back/methods/claim/specs/updateClaim.spec.js

@@ -1,6 +1,20 @@
 const app = require('vn-loopback/server/server');
+const LoopBackContext = require('loopback-context');
 
 describe('Update Claim', () => {
+    beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
     const newDate = Date.vnNew();
     const originalData = {
         ticketFk: 3,

modules/claim/back/methods/claim/specs/updateClaimAction.spec.js

@@ -1,6 +1,20 @@
 const app = require('vn-loopback/server/server');
+const LoopBackContext = require('loopback-context');
 
 describe('Update Claim', () => {
+    beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
     const newDate = Date.vnNew();
     const original = {
         ticketFk: 3,

modules/claim/back/models/claim-beginning.json

@@ -1,11 +1,6 @@
 {
     "name": "ClaimBeginning",
     "base": "Loggable",
-    "log": {
-      "model": "ClaimLog",
-      "relation": "claim",
-      "showField": "quantity"
-    },
     "options": {
         "mysql": {
             "table": "claimBeginning"

modules/claim/back/models/claim-development.json

@@ -1,10 +1,6 @@
 {
     "name": "ClaimDevelopment",
     "base": "Loggable",
-    "log": {
-      "model": "ClaimLog",
-      "relation": "claim"
-    },
     "options": {
         "mysql": {
             "table": "claimDevelopment"

modules/claim/back/models/claim-dms.json

@@ -1,18 +1,14 @@
 {
     "name": "ClaimDms",
     "base": "Loggable",
-    "log": {
-        "model": "ClaimLog",
-        "relation": "claim"
-    },
     "options": {
         "mysql": {
             "table": "claimDms"
         }
     },
     "allowedContentTypes": [
-        "image/png", 
+        "image/png",
-        "image/jpeg", 
+        "image/jpeg",
         "image/jpg"
     ],
     "properties": {
@@ -34,4 +30,4 @@
             "foreignKey": "dmsFk"
         }
     }
-}
+}

modules/claim/back/models/claim-end.json

@@ -1,10 +1,6 @@
 {
     "name": "ClaimEnd",
     "base": "Loggable",
-    "log": {
-      "model": "ClaimLog",
-      "relation": "claim"
-    },
     "options": {
         "mysql": {
             "table": "claimEnd"

modules/claim/back/models/claim-observation.json

@@ -1,10 +1,6 @@
 {
     "name": "ClaimObservation",
     "base": "Loggable",
-    "log": {
-      "model": "ClaimLog",
-      "relation": "claim"
-    },
     "options": {
         "mysql": {
             "table": "claimObservation"
@@ -40,4 +36,4 @@
             "foreignKey": "claimFk"
         }
     }
-}
+}

modules/claim/back/models/claim-state.json

@@ -1,11 +1,6 @@
 {
     "name": "ClaimState",
     "base": "Loggable",
-    "log": {
-        "model": "ClaimLog",
-        "relation": "claim",
-        "showField": "description"
-    },
     "options": {
         "mysql": {
             "table": "claimState"

modules/claim/back/models/claim.json

@@ -1,10 +1,6 @@
 {
     "name": "Claim",
     "base": "Loggable",
-    "log": {
-      "model": "ClaimLog",
-      "showField": "id"
-    },
     "options": {
         "mysql": {
             "table": "claim"

modules/client/back/models/address.json

@@ -2,11 +2,6 @@
     "name": "Address",
     "description": "Client addresses",
     "base": "Loggable",
-    "log": {
-        "model": "ClientLog",
-        "relation": "client",
-        "showField": "nickname"
-    },
     "options": {
         "mysql": {
             "table": "address"
@@ -88,4 +83,4 @@
             "foreignKey": "customsAgentFk"
         }
     }
-}
+}

modules/client/back/models/client-contact.json

@@ -2,11 +2,6 @@
     "name": "ClientContact",
     "description": "Client phone contacts",
     "base": "Loggable",
-    "log": {
-        "model": "ClientLog",
-        "relation": "client",
-        "showField": "name"
-    },
     "options": {
         "mysql": {
             "table": "clientContact"
@@ -33,4 +28,4 @@
             "foreignKey": "clientFk"
         }
     }
-}
+}

modules/client/back/models/client-dms.json

@@ -1,11 +1,6 @@
 {
     "name": "ClientDms",
     "base": "Loggable",
-	"log": {
-        "model":"ClientLog",
-        "relation": "client",
-        "showField": "dmsFk"
-    },
     "options": {
         "mysql": {
             "table": "clientDms"

modules/client/back/models/client-observation.json

@@ -2,10 +2,6 @@
   	"name": "ClientObservation",
 	"description": "Client notes",
 	"base": "Loggable",
-	"log": {
-		"model": "ClientLog",
-		"relation": "client"
-	},
 	"options": {
 		"mysql": {
 			"table": "clientObservation"

modules/client/back/models/client-sample.json

@@ -1,11 +1,6 @@
 {
     "name": "ClientSample",
     "base": "Loggable",
-    "log": {
-      "model": "ClientLog",
-      "relation": "client",
-      "showField": "type"
-    },
     "options": {
         "mysql": {
         "table": "clientSample"

modules/client/back/models/client.json

@@ -1,10 +1,6 @@
 {
 	"name": "Client",
 	"base": "Loggable",
-	"log": {
-		"model":"ClientLog",
-		"showField": "id"
-	},
 	"options": {
 		"mysql": {
 			"table": "client"
@@ -260,4 +256,4 @@
             }
         }
     }
-}
+}

modules/client/back/models/greuge.json

@@ -1,11 +1,6 @@
 {
     "name": "Greuge",
     "base": "Loggable",
-    "log": {
-        "model": "ClientLog",
-        "relation": "client",
-        "showField": "description"
-    },
     "options": {
         "mysql": {
             "table": "greuge"
@@ -58,4 +53,4 @@
             "foreignKey": "userFk"
         }
     }
-}
+}

modules/client/back/models/recovery.json

@@ -1,10 +1,6 @@
 {
     "name": "Recovery",
     "base": "Loggable",
-    "log": {
-        "model": "ClientLog",
-        "relation": "client"
-    },
     "options": {
         "mysql": {
             "table": "recovery"
@@ -38,4 +34,4 @@
             "foreignKey": "clientFk"
         }
     }
-}
+}

modules/entry/back/models/buy.json

@@ -1,11 +1,6 @@
 {
     "name": "Buy",
     "base": "Loggable",
-    "log": {
-        "model": "EntryLog",
-        "relation": "entry",
-        "grabUser": true
-      },
     "options": {
         "mysql": {
         "table": "buy"

modules/entry/back/models/entry-observation.json

@@ -1,10 +1,6 @@
 {
     "name": "EntryObservation",
     "base": "Loggable",
-    "log": {
-      "model": "EntryLog",
-      "relation": "entry"
-    },
     "options": {
         "mysql": {
             "table": "entryObservation"

modules/entry/back/models/entry.json

@@ -1,10 +1,6 @@
 {
     "name": "Entry",
     "base": "Loggable",
-    "log": {
-        "model":"EntryLog",
-        "grabUser": true
-	},
     "options": {
         "mysql": {
             "table": "entry"

modules/invoiceIn/back/methods/invoice-in/specs/clone.spec.js

@@ -1,6 +1,21 @@
 const models = require('vn-loopback/server/server').models;
+const LoopBackContext = require('loopback-context');
 
 describe('invoiceIn clone()', () => {
+    beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
+
     it('should return the cloned invoiceIn and also clone invoiceInDueDays and invoiceInTaxes if there are any referencing the invoiceIn', async() => {
         const userId = 1;
         const ctx = {

modules/invoiceIn/back/models/invoice-in-tax.json

@@ -1,10 +1,6 @@
 {
     "name": "InvoiceInTax",
     "base": "Loggable",
-    "log": {
-        "model": "InvoiceInLog",
-        "relation": "invoiceIn"
-    },
     "options": {
         "mysql": {
             "table": "invoiceInTax"
@@ -55,4 +51,4 @@
             "foreignKey": "transactionTypeSageFk"
         }
     }
-}
+}

modules/invoiceIn/back/models/invoice-in.json

@@ -1,9 +1,6 @@
 {
     "name": "InvoiceIn",
     "base": "Loggable",
-    "log": {
-        "model": "InvoiceInLog"
-    },
     "options": {
         "mysql": {
             "table": "invoiceIn"

modules/invoiceOut/back/methods/invoiceOut/createPdf.js

@@ -56,7 +56,7 @@ module.exports = Self => {
                 reference: invoiceOut.ref,
                 recipientId: invoiceOut.clientFk
             });
-            const stream = await invoiceReport.toPdfStream();
+            const buffer = await invoiceReport.toPdfStream();
 
             const issued = invoiceOut.issued;
             const year = issued.getFullYear().toString();
@@ -66,7 +66,7 @@ module.exports = Self => {
             const fileName = `${year}${invoiceOut.ref}.pdf`;
 
             // Store invoice
-            print.storage.write(stream, {
+            await print.storage.write(buffer, {
                 type: 'invoice',
                 path: `${year}/${month}/${day}`,
                 fileName: fileName

modules/invoiceOut/front/global-invoicing/index.js

@@ -100,16 +100,23 @@ class Controller extends Section {
         };
 
         this.$http.post(`InvoiceOuts/invoiceClient`, params)
+            .then(() => this.invoiceNext())
             .catch(res => {
-                this.errors.unshift({
+                const message = res.data?.error?.message || res.message;
-                    address,
+                if (res.status >= 400 && res.status < 500) {
-                    message: res.data.error.message
+                    this.errors.unshift({address, message});
-                });
+                    this.invoiceNext();
+                } else {
+                    this.invoicing = false;
+                    this.status = 'done';
+                    throw new UserError(`Critical invoicing error, proccess stopped`);
+                }
             })
-            .finally(() => {
+    }
-                this.addressIndex++;
+
-                this.invoiceOut();
+    invoiceNext() {
-            });
+        this.addressIndex++;
+        this.invoiceOut();
     }
 
     get nAddresses() {

modules/invoiceOut/front/global-invoicing/locale/es.yml

@@ -17,4 +17,5 @@ Ended process: Proceso finalizado
 Invoice out: Facturar
 One client: Un solo cliente
 Choose a valid client: Selecciona un cliente válido
-Stop: Parar
+Stop: Parar
+Critical invoicing error, proccess stopped: Error crítico al facturar, proceso detenido

modules/item/back/methods/item/specs/updateTaxes.spec.js

@@ -1,6 +1,21 @@
 const models = require('vn-loopback/server/server').models;
+const LoopBackContext = require('loopback-context');
 
 describe('item updateTaxes()', () => {
+    beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
+
     it('should throw an error if the taxClassFk is blank', async() => {
         const tx = await models.Item.beginTransaction({});
         const options = {transaction: tx};

modules/item/back/methods/tag/specs/onSubmit.spec.js

@@ -1,6 +1,21 @@
 const models = require('vn-loopback/server/server').models;
+const LoopBackContext = require('loopback-context');
 
 describe('tag onSubmit()', () => {
+    beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
+
     it('should delete a tag', async() => {
         const tx = await models.Item.beginTransaction({});
         const options = {transaction: tx};

modules/item/back/models/item-barcode.json

@@ -1,11 +1,6 @@
 {
   "name": "ItemBarcode",
   "base": "Loggable",
-  "log": {
-    "model": "ItemLog",
-    "relation": "item",
-    "showField": "code"
-  },
   "options": {
       "mysql": {
         "table": "itemBarcode"
@@ -27,6 +22,6 @@
       "type": "belongsTo",
       "model": "Item",
       "foreignKey": "itemFk"
-    }     
+    }
   }
 }

modules/item/back/models/item-botanical.json

@@ -1,10 +1,6 @@
 {
     "name": "ItemBotanical",
     "base": "Loggable",
-    "log": {
-      "model": "ItemLog",
-      "relation": "item"
-    },
     "options": {
         "mysql": {
           "table": "itemBotanical"
@@ -34,4 +30,4 @@
             "foreignKey": "specieFk"
         }
     }
-}
+}

modules/item/back/models/item-tag.json

@@ -1,11 +1,6 @@
 {
     "name": "ItemTag",
     "base": "Loggable",
-    "log": {
-        "model": "ItemLog",
-        "relation": "item",
-        "showField": "value"
-    },
     "options": {
         "mysql": {
             "table": "itemTag"

modules/item/back/models/item-tax-country.json

@@ -1,11 +1,6 @@
 {
     "name": "ItemTaxCountry",
     "base": "Loggable",
-    "log": {
-        "model": "ItemLog",
-        "relation": "item",
-        "showField": "countryFk"
-    },
     "options": {
         "mysql": {
           "table": "itemTaxCountry"
@@ -47,4 +42,4 @@
             "foreignKey": "taxClassFk"
         }
     }
-}
+}

modules/item/back/models/item.json

@@ -1,11 +1,6 @@
 {
     "name": "Item",
     "base": "Loggable",
-    "log": {
-        "model": "ItemLog",
-        "showField": "id",
-        "grabUser": true
-    },
     "options": {
         "mysql": {
             "table": "item"

modules/route/back/methods/agency-term/specs/createInvoiceIn.spec.js

@@ -1,6 +1,20 @@
 const models = require('vn-loopback/server/server').models;
+const LoopBackContext = require('loopback-context');
 
 describe('AgencyTerm createInvoiceIn()', () => {
+    beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
     const rows = [
         {
             routeFk: 2,

modules/route/back/models/route.json

@@ -1,10 +1,6 @@
 {
     "name": "Route",
 	"base": "Loggable",
-	"log": {
-		"model":"RouteLog",
-        "grabUser": true
-	},
     "options": {
         "mysql": {
             "table": "route"

modules/shelving/back/models/shelving.json

@@ -1,10 +1,6 @@
 {
     "name": "Shelving",
 	"base": "Loggable",
-    "log": {
-        "model": "ShelvingLog",
-        "showField": "id"
-    },
     "options": {
         "mysql": {
             "table": "shelving"

modules/supplier/back/models/supplier-account.json

@@ -1,10 +1,6 @@
 {
     "name": "SupplierAccount",
     "base": "Loggable",
-    "log": {
-        "model":"SupplierLog",
-        "relation": "supplier"
-	},
     "options": {
         "mysql": {
             "table": "supplierAccount"
@@ -35,4 +31,4 @@
 			"foreignKey": "bankEntityFk"
 		}
     }
-}
+}

modules/supplier/back/models/supplier-address.json

@@ -2,11 +2,6 @@
     "name": "SupplierAddress",
     "description": "Supplier addresses",
     "base": "Loggable",
-    "log": {
-        "model": "SupplierLog",
-        "relation": "supplier",
-        "showField": "name"
-    },
     "options": {
         "mysql": {
             "table": "supplierAddress"
@@ -52,4 +47,4 @@
             "foreignKey": "supplierFk"
         }
     }
-}
+}

modules/supplier/back/models/supplier-contact.json

@@ -1,10 +1,6 @@
 {
     "name": "SupplierContact",
     "base": "Loggable",
-    "log": {
-        "model":"SupplierLog",
-        "relation": "supplier"
-	},
     "options": {
         "mysql": {
             "table": "supplierContact"
@@ -50,4 +46,4 @@
         "permission": "ALLOW"
         }
     ]
-}
+}

modules/supplier/back/models/supplier.json

@@ -1,9 +1,6 @@
 {
     "name": "Supplier",
     "base": "Loggable",
-    "log": {
-        "model":"SupplierLog"
-	},
     "options": {
         "mysql": {
             "table": "supplier"

modules/supplier/front/agency-term/create/index.html

@@ -22,7 +22,7 @@
                 value-field="id"
                 rule>
             </vn-autocomplete>
-            <vn-input-number 
+            <vn-input-number
                 type="number"
                 label="Minimum M3"
                 ng-model="$ctrl.supplierAgencyTerm.minimumM3"
@@ -31,19 +31,20 @@
             </vn-input-number>
         </vn-horizontal>
         <vn-horizontal>
-            <vn-input-number 
+            <vn-input-number
                 type="number"
                 label="Package Price"
                 ng-model="$ctrl.supplierAgencyTerm.packagePrice"
                 rule>
             </vn-input-number>
-            <vn-input-number 
+            <vn-input-number
                 type="number"
                 label="Km Price"
                 ng-model="$ctrl.supplierAgencyTerm.kmPrice"
+                step="0.01"
                 rule>
             </vn-input-number>
-            <vn-input-number 
+            <vn-input-number
                 type="number"
                 label="M3 Price"
                 ng-model="$ctrl.supplierAgencyTerm.m3Price"
@@ -52,13 +53,13 @@
             </vn-input-number>
         </vn-horizontal>
         <vn-horizontal>
-            <vn-input-number 
+            <vn-input-number
                 type="number"
                 label="Route Price"
                 ng-model="$ctrl.supplierAgencyTerm.routePrice"
                 rule>
             </vn-input-number>
-            <vn-input-number 
+            <vn-input-number
                 type="number"
                 label="Minimum Km"
                 ng-model="$ctrl.supplierAgencyTerm.minimumKm"
@@ -73,4 +74,4 @@
             ui-sref="supplier.card.agencyTerm.index">
         </vn-button>
     </vn-button-bar>
-</form>
+</form>

modules/ticket/back/methods/expedition/specs/deleteExpeditions.spec.js

@@ -1,6 +1,21 @@
 const models = require('vn-loopback/server/server').models;
+const LoopBackContext = require('loopback-context');
 
 describe('ticket deleteExpeditions()', () => {
+    beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
+
     it('should delete the selected expeditions', async() => {
         const tx = await models.Expedition.beginTransaction({});
 

modules/ticket/back/methods/expedition/specs/moveExpeditions.spec.js

@@ -1,6 +1,21 @@
 const models = require('vn-loopback/server/server').models;
+const LoopBackContext = require('loopback-context');
 
 describe('ticket moveExpeditions()', () => {
+    beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
+
     it('should move the selected expeditions to new ticket', async() => {
         const tx = await models.Expedition.beginTransaction({});
         const ctx = {

modules/ticket/back/methods/ticket-request/specs/confirm.spec.js

@@ -1,6 +1,20 @@
 const models = require('vn-loopback/server/server').models;
+const LoopBackContext = require('loopback-context');
 
 describe('ticket-request confirm()', () => {
+    beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
     let ctx = {
         req: {
             accessToken: {userId: 9},

modules/ticket/back/methods/ticket-request/specs/deny.spec.js

@@ -1,6 +1,21 @@
 const models = require('vn-loopback/server/server').models;
+const LoopBackContext = require('loopback-context');
 
 describe('ticket-request deny()', () => {
+    beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
+
     it('should return the denied ticket request', async() => {
         const tx = await models.TicketRequest.beginTransaction({});
 

modules/ticket/back/methods/ticket/closure.js

@@ -46,7 +46,7 @@ module.exports = async function(Self, tickets, reqArgs = {}) {
                 const fileName = `${year}${invoiceOut.ref}.pdf`;
 
                 // Store invoice
-                storage.write(stream, {
+                await storage.write(stream, {
                     type: 'invoice',
                     path: `${year}/${month}/${day}`,
                     fileName: fileName

modules/ticket/back/methods/ticket/specs/componentUpdate.spec.js

@@ -17,6 +17,17 @@ describe('ticket componentUpdate()', () => {
     let componentValue;
 
     beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
         const deliveryComponenet = await models.Component.findOne({where: {code: 'delivery'}});
         deliveryComponentId = deliveryComponenet.id;
         componentOfSaleSeven = `SELECT value
@@ -180,9 +191,6 @@ describe('ticket componentUpdate()', () => {
                 }
             };
 
-            spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
-                active: ctx.req
-            });
             const oldTicket = await models.Ticket.findById(ticketID, null, options);
 
             await models.Ticket.componentUpdate(ctx, options);

modules/ticket/back/models/expedition.json

@@ -1,10 +1,6 @@
 {
     "name": "Expedition",
     "base": "Loggable",
-    "log": {
-      "model": "TicketLog",
-      "relation": "ticket"
-    },
     "options": {
         "mysql": {
           "table": "expedition"
@@ -59,4 +55,3 @@
       }
     }
   }
-  

modules/ticket/back/models/sale.json

@@ -1,12 +1,6 @@
 {
     "name": "Sale",
     "base": "Loggable",
-    "log": {
-      "model": "TicketLog",
-      "relation": "ticket",
-      "showField": "concept",
-      "grabUser": true
-    },
     "options": {
         "mysql": {
         "table": "sale"

modules/ticket/back/models/specs/ticket-packaging.spec.js

@@ -1,6 +1,20 @@
 const app = require('vn-loopback/server/server');
+const LoopBackContext = require('loopback-context');
 
 describe('ticket model TicketTracking', () => {
+    beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
     let ticketTrackingId;
 
     afterAll(async() => {

modules/ticket/back/models/ticket-dms.json

@@ -1,10 +1,6 @@
 {
     "name": "TicketDms",
     "base": "Loggable",
-    "log": {
-        "model": "TicketLog",
-        "relation": "ticket"
-    },
     "options": {
         "mysql": {
             "table": "ticketDms"
@@ -29,4 +25,4 @@
             "foreignKey": "dmsFk"
         }
     }
-}
+}

modules/ticket/back/models/ticket-observation.json

@@ -1,10 +1,6 @@
 {
     "name": "TicketObservation",
     "base": "Loggable",
-    "log": {
-      "model": "TicketLog",
-      "relation": "ticket"
-    },
     "options": {
         "mysql": {
             "table": "ticketObservation"

modules/ticket/back/models/ticket-packaging.json

@@ -1,10 +1,6 @@
 {
     "name": "TicketPackaging",
     "base": "Loggable",
-    "log": {
-        "model": "TicketLog",
-        "relation": "ticket"
-    },
     "options": {
         "mysql": {
             "table": "ticketPackaging"

modules/ticket/back/models/ticket-refund.json

@@ -6,10 +6,6 @@
             "table": "ticketRefund"
         }
     },
-    "log": {
-        "model": "TicketLog",
-        "relation": "originalTicket"
-    },
     "properties": {
         "id": {
             "id": true,

modules/ticket/back/models/ticket-request.json

@@ -1,10 +1,6 @@
 {
     "name": "TicketRequest",
     "base": "Loggable",
-    "log": {
-      "model": "TicketLog",
-      "relation": "ticket"
-    },
     "options": {
         "mysql": {
         "table": "ticketRequest"
@@ -64,4 +60,4 @@
             "foreignKey": "itemFk"
         }
     }
-}
+}

modules/ticket/back/models/ticket-service.json

@@ -1,11 +1,6 @@
 {
     "name": "TicketService",
     "base": "Loggable",
-    "log": {
-        "model": "TicketLog",
-        "relation": "ticket",
-        "showField": "description"
-    },
     "options": {
         "mysql": {
             "table": "ticketService"
@@ -59,4 +54,4 @@
             "foreignKey": "ticketServiceTypeFk"
         }
     }
-}
+}

modules/ticket/back/models/ticket-tracking.json

@@ -1,16 +1,11 @@
 {
     "name": "TicketTracking",
     "base": "Loggable",
-    "log": {
+    "options": {
-        "model": "TicketLog",
+        "mysql": {
-        "relation": "ticket",
+            "table": "ticketTracking"
-        "showField": "stateFk"
+        }
-        },
+    },
-        "options": {
-            "mysql": {
-                "table": "ticketTracking"
-            }
-        },
     "properties": {
         "id": {
                 "id": true,
@@ -48,4 +43,3 @@
         }
     }
 }
-  

modules/ticket/back/models/ticket-weekly.json

@@ -1,11 +1,6 @@
 {
     "name": "TicketWeekly",
     "base": "Loggable",
-    "log": {
-      "model": "TicketLog",
-      "relation": "ticket",
-      "showField": "ticketFk"
-    },
     "options": {
         "mysql": {
             "table": "ticketWeekly"
@@ -32,4 +27,4 @@
             "foreignKey": "agencyModeFk"
         }
     }
-}
+}

modules/ticket/back/models/ticket.json

@@ -1,11 +1,6 @@
 {
     "name": "Ticket",
 	"base": "Loggable",
-	"log": {
-		"model":"TicketLog",
-        "showField": "id",
-        "grabUser": true
-	},
     "options": {
         "mysql": {
         "table": "ticket"

modules/travel/back/methods/travel/specs/createThermograph.spec.js

@@ -1,6 +1,20 @@
 const models = require('vn-loopback/server/server').models;
+const LoopBackContext = require('loopback-context');
 
 describe('Travel createThermograph()', () => {
+    beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
     const travelId = 3;
     const currentUserId = 1102;
     const thermographId = '138350-0';

modules/travel/back/models/travel-thermograph.json

@@ -1,14 +1,9 @@
 {
     "name": "TravelThermograph",
     "base": "Loggable",
-    "log": {
-        "model":"TravelLog",
-        "relation": "travel",
-        "showField": "ref"
-	},
     "options": {
         "mysql": {
-        "table": "travelThermograph"
+            "table": "travelThermograph"
         }
     },
     "properties": {

modules/travel/back/models/travel.json

@@ -1,11 +1,6 @@
 {
     "name": "Travel",
 	"base": "Loggable",
-	"log": {
-		"model":"TravelLog",
-        "showField": "ref",
-        "grabUser": true
-	},
     "options": {
         "mysql": {
             "table": "travel"

modules/worker/back/models/worker-dms.json

@@ -1,11 +1,6 @@
 {
     "name": "WorkerDms",
     "base": "Loggable",
-	"log": {
-        "model":"ClientLog",
-        "relation": "worker",
-        "showField": "dmsFk"
-    },
     "options": {
         "mysql": {
             "table": "workerDocument"

modules/worker/back/models/worker.json

@@ -2,10 +2,6 @@
     "name": "Worker",
     "description": "Company employees",
     "base": "Loggable",
-    "log": {
-        "model":"WorkerLog",
-        "showField": "firstName"
-	},
     "options": {
         "mysql": {
             "table": "worker"

modules/zone/back/methods/zone/specs/clone.spec.js

@@ -1,6 +1,21 @@
 const models = require('vn-loopback/server/server').models;
+const LoopBackContext = require('loopback-context');
 
 describe('agency clone()', () => {
+    beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
+
     it('should clone a zone', async() => {
         const tx = await models.Zone.beginTransaction({});
 

modules/zone/back/methods/zone/specs/exclusionGeo.spec.js

@@ -1,6 +1,20 @@
 const models = require('vn-loopback/server/server').models;
+const LoopBackContext = require('loopback-context');
 
 describe('zone exclusionGeo()', () => {
+    beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
     const zoneId = 1;
     const today = Date.vnNew();
 

modules/zone/back/methods/zone/specs/toggleIsIncluded.spec.js

@@ -1,6 +1,21 @@
 const models = require('vn-loopback/server/server').models;
+const LoopBackContext = require('loopback-context');
 
 describe('zone toggleIsIncluded()', () => {
+    beforeAll(async() => {
+        const activeCtx = {
+            accessToken: {userId: 9},
+            http: {
+                req: {
+                    headers: {origin: 'http://localhost'}
+                }
+            }
+        };
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
+
     it('should return the created location with isIncluded true', async() => {
         const tx = await models.Zone.beginTransaction({});
 

modules/zone/back/models/zone-event.json

@@ -1,10 +1,6 @@
 {
 	"name": "ZoneEvent",
 	"base": "Loggable",
-	"log": {
-		"model":"ZoneLog",
-        "relation": "zone"
-	},
 	"options": {
 		"mysql": {
 			"table": "zoneEvent"
@@ -57,4 +53,4 @@
             "foreignKey": "zoneFk"
         }
     }
-}
+}

modules/zone/back/models/zone-exclusion.json

@@ -1,10 +1,6 @@
 {
 	"name": "ZoneExclusion",
 	"base": "Loggable",
-	"log": {
-		"model":"ZoneLog",
-        "relation": "zone"
-	},
 	"options": {
 		"mysql": {
 			"table": "zoneExclusion"
@@ -27,4 +23,4 @@
             "foreignKey": "zoneFk"
         }
     }
-}
+}

modules/zone/back/models/zone-included.json

@@ -1,11 +1,6 @@
 {
 	"name": "ZoneIncluded",
 	"base": "Loggable",
-	"log": {
-        "model": "ZoneLog",
-		"relation": "zone",
-		"showField": "isIncluded"
-    },
 	"options": {
 		"mysql": {
 			"table": "zoneIncluded"
@@ -32,4 +27,4 @@
             "foreignKey": "geoFk"
         }
     }
-}
+}

modules/zone/back/models/zone-warehouse.json

@@ -1,10 +1,6 @@
 {
 	"name": "ZoneWarehouse",
 	"base": "Loggable",
-	"log": {
-		"model":"ZoneLog",
-        "relation": "zone"
-	},
 	"options": {
 		"mysql": {
 			"table": "zoneWarehouse"
@@ -32,4 +28,4 @@
             "foreignKey": "warehouseFk"
         }
     }
-}
+}

modules/zone/back/models/zone.json

@@ -1,10 +1,6 @@
 {
 	"name": "Zone",
 	"base": "Loggable",
-	"log": {
-		"model":"ZoneLog",
-        "showField": "name"
-	},
 	"options": {
 		"mysql": {
 			"table": "zone"
@@ -59,7 +55,7 @@
 		"exclusions": {
             "type": "hasMany",
             "model": "ZoneExclusion",
-			"foreignKey": "zoneFk" 
+			"foreignKey": "zoneFk"
 		},
 		"warehouses": {
 			"type": "hasMany",
@@ -72,4 +68,4 @@
 			"foreignKey": "zoneFk"
         }
     }
-}
+}

print/core/cluster.js

@@ -4,40 +4,38 @@ const {cpus} = require('os');
 
 module.exports = {
     init() {
-        if (!this.pool) {
+        if (this.pool) return;
-            Cluster.launch({
+        Cluster.launch({
-                concurrency: Cluster.CONCURRENCY_CONTEXT,
+            concurrency: Cluster.CONCURRENCY_CONTEXT,
-                maxConcurrency: cpus().length,
+            maxConcurrency: cpus().length,
-                puppeteerOptions: {
+            puppeteerOptions: {
-                    headless: true,
+                headless: true,
-                    args: [
+                args: [
-                        '--no-sandbox',
+                    '--no-sandbox',
-                        '--disable-setuid-sandbox',
+                    '--disable-setuid-sandbox',
-                        '--no-zygote'
+                    '--no-zygote'
-                    ]
+                ]
-                }
+            }
-            })
+        }).then(cluster => {
-                .then(cluster => {
+            this.pool = cluster;
-                    this.pool = cluster;
 
-                    log4js.configure({
+            log4js.configure({
-                        appenders: {
+                appenders: {
-                            out: {type: 'stdout'}
+                    out: {type: 'stdout'}
-                        },
+                },
-                        categories: {default: {appenders: ['out'], level: 'info'}},
+                categories: {default: {appenders: ['out'], level: 'info'}},
-                    });
+            });
 
-                    const logger = log4js.getLogger();
+            const logger = log4js.getLogger();
 
-                    cluster.on('taskerror', (err, data, willRetry) => {
+            cluster.on('taskerror', (err, data, willRetry) => {
-                        if (willRetry)
+                if (willRetry)
-                            logger.warn(`[Print] => ${err.message}\nThis job will be retried`);
+                    logger.warn(`[Print] => ${err.message}\nThis job will be retried`);
-                        else
+                else
-                            logger.error(`[Print] => ${err.message}`);
+                    logger.error(`[Print] => ${err.message}`);
-                    });
+            });
 
-                    cluster.on('queue', () => logger.info('Printing task initialized by pool'));
+            cluster.on('queue', () => logger.info('Printing task initialized by pool'));
-                });
+        });
-        }
     }
 };

print/core/report.js

@@ -32,28 +32,31 @@ class Report extends Component {
         if (fs.existsSync(fullPath))
             options = require(optionsPath);
 
-        return new Promise(resolve => {
+        return new Promise((resolve, reject) => {
             Cluster.pool.queue({}, async({page}) => {
-                await page.emulateMediaType('screen');
+                try {
-                await page.setContent(template);
+                    await page.emulateMediaType('screen');
+                    await page.setContent(template);
 
-                const element = await page.$('#pageFooter');
+                    const element = await page.$('#pageFooter');
 
-                let footer = '\n';
+                    let footer = '\n';
-                if (element) {
+                    if (element) {
-                    footer = await page.evaluate(el => {
+                        footer = await page.evaluate(el => {
-                        const html = el.innerHTML;
+                            const html = el.innerHTML;
-                        el.remove();
+                            el.remove();
-                        return html;
+                            return html;
-                    }, element);
+                        }, element);
+                    }
+
+                    options.headerTemplate = '\n';
+                    options.footerTemplate = footer;
+
+                    const buffer = await page.pdf(options);
+                    resolve(buffer);
+                } catch (err) {
+                    reject(err);
                 }
-
-                options.headerTemplate = '\n';
-                options.footerTemplate = footer;
-
-                const stream = await page.pdf(options);
-
-                resolve(stream);
             });
         });
     }

print/core/storage.js

@@ -3,26 +3,14 @@ const path = require('path');
 const fs = require('fs-extra');
 
 module.exports = {
-    async write(stream, options) {
+    async write(buffer, options) {
         const storage = config.storage[options.type];
-
         if (!storage) return;
 
         const src = path.join(storage.root, options.path);
         const fileSrc = path.join(src, options.fileName);
 
         await fs.mkdir(src, {recursive: true});
-
+        await fs.writeFile(fileSrc, buffer);
-        const writeStream = fs.createWriteStream(fileSrc);
-        writeStream.on('open', () => writeStream.write(stream));
-        writeStream.on('finish', () => writeStream.end());
-
-        return new Promise(resolve => {
-            writeStream.on('close', () => resolve());
-        });
-    },
-
-    load(type, data) {
-
     }
 };