eHealthAfrica/LMIS-Chrome

'use strict';

angular.module('lmisChromeApp')
    .factory('inventoryFactory', function ($q, storageService, productTypeFactory, programsFactory, storageUnitFactory, batchFactory, facilityFactory, uomFactory, utility) {

      function getByUUID(uuid) {
        var deferred = $q.defer();
        storageService.find(storageService.INVENTORY, uuid).then(function (data) {

          var inventoryLine = data;

          if (data !== undefined) {

            // Attach nested attributes complete JSON object.
            batchFactory.getByBatchNo(inventoryLine.batch).then(function (data) {
              if (data.toString() === '[object Object]') {
                inventoryLine.batch = data;
              }

              var promises = {
                product_type: productTypeFactory.get(inventoryLine.product_type),
                program: programsFactory.get(inventoryLine.program),
                uom: uomFactory.get(inventoryLine.uom),
                receiving_facility: facilityFactory.get(inventoryLine.receiving_facility),
                sending_facility: facilityFactory.get(inventoryLine.sending_facility),
                storage_unit: storageUnitFactory.get(inventoryLine.storage_unit)
              };

              $q.all(promises).then(function (result) {
                for (var key in result) {
                  inventoryLine[key] = result[key];
                }
                deferred.resolve(inventoryLine);
              });
            });
          }
        });
        return deferred.promise;
      }

      return {
        get: getByUUID,

        /**
         *  This functions returns all the inventory of a given facility.
         *
         * @param facility - this can be a string(facilityUUID) or an object(facility object with uuid as its property).
         */
        getFacilityInventory: function (facility) {
          var uuid = angular.isObject(facility) ? facility.uuid : facility;
          var deferred = $q.defer(),
              inventory = [];

          storageService.all(storageService.INVENTORY).then(function (data) {

            angular.forEach(data, function (datum) {
              if (datum.receiving_facility === uuid) {
                inventory.push(getByUUID(datum.uuid).then(function (inventoryLine) {
                  deferred.notify(datum);
                  return inventoryLine;
                }));
              }
            });

            $q.all(inventory).then(function (results) {
              deferred.resolve(results);
            });

          });
          return deferred.promise;
        },

        getUniqueProducts: function (facility) {
          var deferred = $q.defer();
          this.getFacilityInventory(facility)
              .then(function (inventories) {
                var collateCodes = function () {
                  var codes = {}, code = '', batch;
                  for (var i = inventories.length - 1; i >= 0; i--) {
                    batch = inventories[i].batch;
                    if (typeof batch !== 'string') {
                      if (utility.has(batch, 'product')) {
                        code = batch.product.code;
                        codes[code] = {};
                      }
                    }
                  }
                  deferred.resolve(codes);
                };
                collateCodes();
              });
          return deferred.promise;
        },

        save: function (inventory) {
          var batches = [],
              deferred = $q.defer();

          angular.forEach(inventory.inventory_lines, function (inventoryLine) {

            var newInventory = {
              date_receipt: inventory.date_receipt,
              receiving_facility: inventory.receiving_facility.uuid,
              sending_facility: inventory.sending_facility,
              batch: inventoryLine.batch_no,
              quantity: inventoryLine.quantity,
              program: inventoryLine.program,
              storage_unit: inventoryLine.storage_unit,
              uom: inventoryLine.uom,
              bundle_no: inventory.bundle_no,
              product_type: inventoryLine.productType
            };
            batches.push(newInventory);
          });

          storageService.insertBatch(storageService.INVENTORY, batches).then(function (result) {
            deferred.resolve(result);
          }, function (error) {
            deferred.reject(error);
          });
          return deferred.promise;
        }

      };
    });