package com.srv4pos.server.api.treasurer;
   
   import com.srv4pos.server.api.infrastructure.EmptyConnectionWriter;
   import com.srv4pos.server.api.infrastructure.HttpMethod;
   import com.srv4pos.server.api.infrastructure.IdentifierInfo;
   import com.srv4pos.server.api.infrastructure.StringConnectionWriter;
   import com.srv4pos.server.api.infrastructure.credentials.Credentials;
   import com.srv4pos.server.api.infrastructure.http.HttpHelper;
   import com.srv4pos.server.api.infrastructure.http.Transport;
  import com.srv4pos.server.api.infrastructure.request.StringResponse;
  
  import java.net.URL;
  import java.util.HashMap;
  import java.util.List;
  
  import static com.srv4pos.server.api.infrastructure.request.RequestHelper.requestString;
  import static com.srv4pos.server.api.infrastructure.request.RequestHelper.requestVoid;
  import static java.lang.String.format;
  
  /**
   * To work with Treasurer entity.
   * @author Ruslan Kashapov.
   */
  public class TreasurerService {
      private URL url;
      private Credentials credentials;
      private Transport transport;
  
      /**
       * Constructs the service.
       *
       * @param url of the server
       * @param credentials to work with the server
       * @param transport to know the method to reach the server
       */
      public TreasurerService(URL url, Credentials credentials, Transport transport) {
          this.url = url;
          this.credentials = credentials;
          this.transport = transport;
      }
  
      /**
       * Returns an treasurer entity.
       *
       * @param version    latest version of seller, may be null (if latest data needed)
       * @param identifier identifies entity. must match to {@link com.srv4pos.server.api.infrastructure.Constraints#WINDOWS_FILENAME_REGEX}
       * @return null if not modified since version or entity. if version is null then return value can not be null
       * @throws com.srv4pos.server.api.exceptions.VersionConflictJsonException
       *          if version mismatch
       * @throws com.srv4pos.server.api.exceptions.NotFoundJsonException
       *          if entity is not found
       */
      public TreasurerInfo get(Integer version, String identifier) {
          StringResponse response = requestString(
                  format("%s/treasurers/%s", credentials.getSellerId(), identifier),
                  HttpMethod.GET,
                  url,
                  credentials.toAuthentication(),
                  HttpHelper.integerToETag(version),
                  null,
                  EmptyConnectionWriter.EMPTY_CONNECTION_WRITER,
                  HttpHelper.CONTENT_TYPE_APPLICATION_JSON,
                  transport
          );
          return response == null ? null : TreasurerInfo.fromJsonToTreasurerInfo(response.getContent());
      }
  
      /**
       * Put treasurer to the server.
       *
       * @param version   expected latest version of seller
       * @param treasurerInfo data to put
       * @throws com.srv4pos.server.api.exceptions.VersionConflictJsonException
       *          if version mismatch
       */
      public void put(int version, TreasurerInfo treasurerInfo) {
          requestVoid(
                  format("%s/treasurers/%s", credentials.getSellerId(), treasurerInfo.getIdentifier()),
                  HttpMethod.PUT,
                  url,
                  credentials.toAuthentication(),
                  HttpHelper.integerToETag(version),
                  null,
                  new StringConnectionWriter(treasurerInfo.toJson()),
                  HttpHelper.CONTENT_TYPE_APPLICATION_JSON,
                  transport
          );
      }
  
      /**
       * Create treasurer on the server.
       *
       * @param version   expected latest version of seller
       * @param treasurerInfo data to put
       * @return identifier info
       * @throws com.srv4pos.server.api.exceptions.VersionConflictJsonException
       *          if version mismatch
       */
      public IdentifierInfo create(int version, TreasurerInfo treasurerInfo) {
         return IdentifierInfo.fromJsonToIdentifierInfo(
                 requestString(
                         format("%s/treasurers", credentials.getSellerId()),
                         HttpMethod.POST,
                         url,
                         credentials.toAuthentication(),
                         HttpHelper.integerToETag(version),
                         null,
                         new StringConnectionWriter(treasurerInfo.toJson()),
                         HttpHelper.CONTENT_TYPE_APPLICATION_JSON,
                         transport
                 ).getContent()
         );
     }
 
     /**
      * Delete entity from the server.
      *
      * @param version    current seller version
      * @param identifier identifies entity. must match to {@link com.srv4pos.server.api.infrastructure.Constraints#WINDOWS_FILENAME_REGEX}
      * @throws com.srv4pos.server.api.exceptions.VersionConflictJsonException
      *          if version mismatch
      * @throws com.srv4pos.server.api.exceptions.NotFoundJsonException
      *          if entity is not found
      */
     public void delete(int version, String identifier) {
         requestVoid(
                 format("%s/treasurers/%s", credentials.getSellerId(), identifier),
                 HttpMethod.DELETE,
                 url,
                 credentials.toAuthentication(),
                 HttpHelper.integerToETag(version),
                 null,
                 EmptyConnectionWriter.EMPTY_CONNECTION_WRITER,
                 HttpHelper.CONTENT_TYPE_APPLICATION_JSON,
                 transport
         );
     }
 
     /**
      * Returns list of item changes between two versions.
      *
      * @param versionFrom version from included
      * @param versionTo   version to included
      * @return list of items to be added, edited or deleted ({@link com.srv4pos.server.api.treasurer.TreasurerInfo#isDeleted()} = true)
      */
     public List<TreasurerInfo> listDiff(int versionFrom, int versionTo) {
         StringResponse response = requestString(
                 format("%s/treasurers-diff/%s/%s", credentials.getSellerId(), versionFrom, versionTo),
                 HttpMethod.GET,
                 url,
                 credentials.toAuthentication(),
                 null,
                 null,
                 EmptyConnectionWriter.EMPTY_CONNECTION_WRITER,
                 HttpHelper.CONTENT_TYPE_APPLICATION_JSON,
                 transport
         );
         return (List<TreasurerInfo>) TreasurerInfo.fromJsonArrayToTreasurerInfoes(response.getContent());
     }
 
     /**
      * Returns list of entities.
      *
      * @param version version or null if fresh data required
      * @return list of entities which exists on current seller or null if list of entities is not modified since version
      */
     public List<TreasurerInfo> list(Integer version) {
         return list(version, null, null, null, null, null);
     }
 
     /**
      * Returns list of entities.
      *
      * @param firstResult when pagination starts or null
      * @param maxResults  amount of items per page or null
      * @param like search string filter or null
      * @param orderBy field to order by, possible values are {@link com.srv4pos.server.api.treasurer.TreasurerInfo.Fields}
      * @param orderDesc field to direction of ordering
      * @param version version or null if fresh data required
      * @return list of entities which exists on current seller or null if list of entities is not modified since version
      */
     public List<TreasurerInfo> list(Integer version,
                                     Integer firstResult,
                                     Integer maxResults,
                                     String like,
                                     TreasurerInfo.Fields orderBy,
                                     Boolean orderDesc) {
         HashMap<String, String> params = new HashMap<String, String>();
         if (orderBy != null) {
             params.put("orderBy", orderBy.name());
         }
         if (orderDesc != null) {
             params.put("orderDesc", orderDesc.toString());
         }
         if (firstResult != null) {
             params.put("firstResult", Integer.toString(firstResult));
         }
         if (maxResults != null) {
             params.put("maxResults", Integer.toString(maxResults));
         }
         if (like != null) {
             params.put("like", like);
         }
 
         StringResponse response = requestString(format("%s/treasurers",
                         credentials.getSellerId()),
                 HttpMethod.GET,
                 url,
                 credentials.toAuthentication(),
                 HttpHelper.integerToETag(version),
                 params,
                 EmptyConnectionWriter.EMPTY_CONNECTION_WRITER,
                 HttpHelper.CONTENT_TYPE_APPLICATION_JSON,
                 transport);
 
         return response == null ? null : (List<TreasurerInfo>) TreasurerInfo.fromJsonArrayToTreasurerInfoes(response.getContent());
     }
 }