package com.srv4pos.server.api.sync.sample;
   
   import com.srv4pos.server.api.product.ProductInfo;
   import com.srv4pos.server.api.sync.EntitySyncAdapter;
   import com.srv4pos.server.api.sync.Uploader;
   
   import java.util.List;
   
   public class ProductSyncAdapter implements EntitySyncAdapter<ProductInfo> {
      private final MemoryLocalStorage storage;
  
      public ProductSyncAdapter(MemoryLocalStorage storage) {
          this.storage = storage;
      }
  
      public void upload(Uploader<ProductInfo> uploader) {
          List<SyncProduct> products = storage.getProducts();
          for (SyncProduct product : products) {
              if (!product.isSynced()) {
                  doUpload(uploader, product);
              }
          }
      }
  
      private void doUpload(Uploader<ProductInfo> uploader, SyncProduct product) {
          final ProductInfo productInfo = product.getInfo();
  
          // syncing entity only if it was already synced at least once (has identifier) OR is not deleted
          //if (productInfo.getIdentifier() != null || !productInfo.isDeleted()) {
          productInfo.setTax(product.getTax().getInfo().getIdentifier());
  
          final String newIdentifier = uploader.upload(productInfo, product.getPictureInputStream());
          if (newIdentifier != null && newIdentifier.length() > 0) {
              productInfo.setIdentifier(newIdentifier);
          }
          //}
          product.setSynced(true);
      }
  
      public void createOrUpdateEntityFromInfo(ProductInfo info) {
          SyncTax tax = storage.getTaxByIdentifier(info.getTax());
  
          if (tax == null) {
              info.setTax(null); // clearing tax identifier if the storage does not have tax with identifier from server
          }
  
          SyncProduct product = storage.getProductByIdentifier(info.getIdentifier());
          if (product == null) {
              product = new SyncProduct(info, tax);
              storage.add(product); // adding even if info is in "deleted" state (info.isDeleted() == true)
          } else {
              product.setInfo(info);
              product.setTax(tax);
          }
          product.setSynced(true);
      }
  }