package com.srv4pos.server.api.sync.sample;
   
   import com.srv4pos.server.api.commodity.CommodityInfo;
   import com.srv4pos.server.api.sync.EntitySyncAdapter;
   import com.srv4pos.server.api.sync.Uploader;
   
   import java.util.List;
   
   public class CommoditySyncAdapter implements EntitySyncAdapter<CommodityInfo> {
      private final MemoryLocalStorage storage;
  
      public CommoditySyncAdapter(MemoryLocalStorage storage) {
          this.storage = storage;
      }
  
      public void upload(Uploader<CommodityInfo> uploader) {
          List<SyncCommodity> commodities = storage.getCommodities();
          for (SyncCommodity commodity : commodities) {
              if (!commodity.isSynced()) {
                  doUpload(uploader, commodity);
              }
          }
      }
  
      private void doUpload(Uploader<CommodityInfo> uploader, SyncCommodity commodity) {
          final CommodityInfo commodityInfo = commodity.getInfo();
  
          // syncing entity only if it was already synced at least once (has identifier) OR is not deleted
          //if (commodityInfo.getIdentifier() != null || !commodityInfo.isDeleted()) {
  
          commodityInfo.setProduct(commodity.getProduct().getInfo().getIdentifier());
          commodityInfo.setCategory(commodity.getCategory().getInfo().getIdentifier());
  
          final String newIdentifier = uploader.upload(commodityInfo, null);
          if (newIdentifier != null && newIdentifier.length() > 0) {
              commodityInfo.setIdentifier(newIdentifier);
          }
          //}
          commodity.setSynced(true);
      }
  
      public void createOrUpdateEntityFromInfo(CommodityInfo info) {
          SyncCategory category = storage.getCategoryByIdentifier(info.getCategory());
          SyncProduct product = storage.getProductByIdentifier(info.getProduct());
  
          if (category == null) {
              info.setCategory(null);
          }
          if (product == null) {
              info.setProduct(null);
          }
  
          SyncCommodity commodity = storage.getCommodityByIdentifier(info.getIdentifier());
  
          if (commodity == null) {
              // adding even if info is in "deleted" state (info.isDeleted() == true)
              commodity = new SyncCommodity(info, product, category);
              storage.add(commodity);
          } else {
              commodity.setInfo(info);
              commodity.setProduct(product);
              commodity.setCategory(category);
          }
          commodity.setSynced(true);
      }
  }