package com.srv4pos.server.api.sync.sample;
   
   import com.srv4pos.server.api.category.CategoryInfo;
   import com.srv4pos.server.api.sync.EntitySyncAdapter;
   import com.srv4pos.server.api.sync.Uploader;
   
   import java.util.List;
   
   public class CategorySyncAdapter implements EntitySyncAdapter<CategoryInfo> {
      private final MemoryLocalStorage storage;
  
      public CategorySyncAdapter(MemoryLocalStorage storage) {
          this.storage = storage;
      }
  
      public void upload(Uploader<CategoryInfo> uploader) {
          List<SyncCategory> cats = storage.getCategories();
          for (SyncCategory cat : cats) {
              if (!cat.isSynced()) {
                  doUpload(uploader, cat);
              }
          }
      }
  
      private void doUpload(Uploader<CategoryInfo> uploader, SyncCategory cat) {
          final CategoryInfo catInfo = cat.getInfo();
  
          // syncing entity only if it was already synced at least once (has identifier) OR is not deleted
          //if (catInfo.getIdentifier() != null || !catInfo.isDeleted()) {
  
          final String newIdentifier = uploader.upload(catInfo, cat.getPictureInputStream());
          if (newIdentifier != null && newIdentifier.length() > 0) {
              catInfo.setIdentifier(newIdentifier);
          }
          //}
          cat.setSynced(true);
      }
  
      public void createOrUpdateEntityFromInfo(CategoryInfo info) {
          SyncCategory cat = storage.getCategoryByIdentifier(info.getIdentifier());
  
          if (cat == null) {
              cat = new SyncCategory(info);
              storage.add(cat); // adding even if info is in "deleted" state (info.isDeleted() == true)
          } else {
              cat.setInfo(info);
          }
  
          cat.setSynced(true);
      }
  }