package com.srv4pos.server.api.sync.sample;
   
   import com.srv4pos.server.api.sync.EntitySyncAdapter;
   import com.srv4pos.server.api.sync.Uploader;
   import com.srv4pos.server.api.treasurer.TreasurerInfo;
   
   /**
    * Created by ivkosh on 25.05.15.
    */
  public class TreasurerSyncAdapter implements EntitySyncAdapter<TreasurerInfo> {
      private final MemoryLocalStorage storage;
  
      public TreasurerSyncAdapter(MemoryLocalStorage storage) {
          this.storage = storage;
      }
  
      public void upload(Uploader<TreasurerInfo> uploader) {
          for (SyncTreasurer t : storage.getTreasurers()) {
              if (!t.isSynced()) {
                  doUpload(uploader, t);
              }
          }
      }
  
      private void doUpload(Uploader<TreasurerInfo> uploader, SyncTreasurer treasurer) {
          final TreasurerInfo treasurerInfo = treasurer.getInfo();
  
          // syncing entity only if it was already synced at least once (has identifier) OR is not deleted
          //if (treasurerInfo.getIdentifier() != null || !treasurerInfo.isDeleted()) {
  
          final String newIdentifier = uploader.upload(treasurerInfo, null);
          if (newIdentifier != null && newIdentifier.length() > 0) {
              treasurerInfo.setIdentifier(newIdentifier);
          }
          //}
          treasurer.setSynced(true);
      }
  
      public void createOrUpdateEntityFromInfo(TreasurerInfo info) {
          SyncTreasurer treasurer = storage.getTreasurerByIdentifier(info.getIdentifier());
          if (treasurer == null) {
              treasurer = storage.getTreasurerBySsn(info.getSsn());
          }
  
          if (treasurer == null) {
              treasurer = new SyncTreasurer(info);
              storage.add(treasurer); // adding even if info is in "deleted" state (info.isDeleted() == true)
          } else {
              treasurer.setInfo(info);
          }
          treasurer.setSynced(true);
      }
  }