package com.srv4pos.server.api.sync.sample;
   
   import com.srv4pos.server.api.sale.SaleSlotInfo;
   import com.srv4pos.server.api.sync.EntitySyncAdapter;
   import com.srv4pos.server.api.sync.Uploader;
   
   import java.util.List;
   
   /**
   * Created by misha on 30.06.16.
   */
  public class SaleSlotSyncAdapter implements EntitySyncAdapter<SaleSlotInfo> {
  
      private MemoryLocalStorage storage;
  
      public SaleSlotSyncAdapter(MemoryLocalStorage storage) {
          this.storage = storage;
      }
  
      public void upload(Uploader<SaleSlotInfo> uploader) {
          List<SyncSaleSlot> saleSlots = storage.getSaleSlots();
          for (SyncSaleSlot saleSlot : saleSlots) {
              if (!saleSlot.isSynced()) {
                  doUpload(uploader, saleSlot);
              }
          }
      }
  
      private void  doUpload(Uploader<SaleSlotInfo> uploader, SyncSaleSlot saleSlot) {
          final SaleSlotInfo saleSlotInfo= saleSlot.getInfo();
  
          final String newIdentifier = uploader.upload(saleSlotInfo, saleSlot.getPictureInputStream());
          if (newIdentifier != null && newIdentifier.length() > 0) {
              saleSlotInfo.setIdentifier(newIdentifier);
          }
  
          saleSlot.setSynced(true);
      }
  
      public void createOrUpdateEntityFromInfo(SaleSlotInfo info) {
          SyncSaleSlot saleSlot = storage.getSaleSlotByIdentifier(info.getIdentifier());
  
          if (saleSlot == null) {
              saleSlot = new SyncSaleSlot(info);
              storage.add(saleSlot); // adding even if info is in "deleted" state (info.isDeleted() == true)
          } else {
              saleSlot.setInfo(info);
          }
  
          saleSlot.setSynced(true);
      }
  }