package com.srv4pos.server.api.sync.sample;
   
   import com.srv4pos.server.api.sale.SaleInfo;
   import com.srv4pos.server.api.sync.EntitySyncAdapter;
   import com.srv4pos.server.api.sync.Uploader;
   import com.srv4pos.server.api.transportation.TripInfo;
   
   import java.util.ArrayList;
   import java.util.List;
  
  /**
   * Created by moonsweel on 07/06/2017.
   */
  
  public class TripSyncAdapter implements EntitySyncAdapter<TripInfo> {
  
      private final MemoryLocalStorage storage;
  
      public TripSyncAdapter(MemoryLocalStorage storage) {
          this.storage = storage;
      }
  
      public void upload(Uploader<TripInfo> uploader) {
          List<SyncTrip> trips = storage.getTrips();
          for (SyncTrip trip : trips) {
              if (!trip.isSynced()) {
                  doUpload(uploader, trip);
              }
          }
      }
  
      private void doUpload(Uploader<TripInfo> uploader, SyncTrip trip) {
          TripInfo tripInfo = trip.getInfo();
  
          if (trip.getSales() != null) {
              List<SaleInfo> sales = new ArrayList<SaleInfo>();
              for (SyncSale sale : trip.getSales()) {
                  sales.add(sale.getInfo());
              }
              tripInfo.setSales(sales);
          }
  
          uploader.upload(tripInfo, null);
          trip.setSynced(true);
      }
  
      public void createOrUpdateEntityFromInfo(TripInfo info) {
          List<SyncSale> sales = storage.getSalesByTripIdentifier(info.getIdentifier());
          if (sales == null) {
              info.setSales(null);
          }
  
          SyncTrip trip = storage.getTripByIdentifier(info.getIdentifier());
  
          if (trip == null) {
              trip = new SyncTrip(info, sales);
              storage.add(trip);
          } else  {
              trip.setInfo(info);
              trip.setSales(sales);
          }
  
          trip.setSynced(true);
      }
  }