package com.srv4pos.server.api.ejournal;
   
   import com.srv4pos.commons.io.InputStreamConnectionWriter;
   import com.srv4pos.server.api.infrastructure.EmptyConnectionWriter;
   import com.srv4pos.server.api.infrastructure.HttpMethod;
   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.StreamResponse;
  
  import java.io.InputStream;
  import java.net.URL;
  import java.util.HashMap;
  
  import static com.srv4pos.server.api.infrastructure.request.RequestHelper.requestStream;
  import static com.srv4pos.server.api.infrastructure.request.RequestHelper.requestVoid;
  import static java.lang.String.format;
  
  public class EJournalService {
      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 EJournalService(URL url, Credentials credentials, Transport transport) {
          this.url = url;
          this.credentials = credentials;
          this.transport = transport;
      }
  
      /**
       * Appends passed ejournal csv lines of cash register.
       *
       * @param cashRegisterName name of cash register. Its lines should be appended
       * @param stream           {@link InputStream} with csv lines
       */
      public void append(String cashRegisterName, InputStream stream) {
          requestVoid(
                  format("%s/e-journals/%s", credentials.getSellerId(), cashRegisterName),
                  HttpMethod.POST,
                  url,
                  credentials.toAuthentication(),
                  null,
                  null,
                  new InputStreamConnectionWriter(stream),
                  HttpHelper.CONTENT_TYPE_CSV,
                  transport);
      }
  
      /**
       * Returns stream with csv lines belonging to passed {@code cashRegisterName}.
       *
       * @param cashRegisterName name of cash register. Its lines should be retrieved from server
       * @param orderDesc        ordering, {@code desc} by default
       * @return
       */
      public InputStream get(String cashRegisterName, Boolean orderDesc) {
          HashMap<String, String> params = new HashMap<String, String>();
          if (orderDesc != null) {
              params.put("orderDesc", orderDesc.toString());
          }
          final StreamResponse streamResponse = requestStream(
                  format("%s/e-journals/%s", credentials.getSellerId(), cashRegisterName),
                  HttpMethod.GET,
                  url,
                  credentials.toAuthentication(),
                  null,
                  params,
                  EmptyConnectionWriter.EMPTY_CONNECTION_WRITER,
                  HttpHelper.CONTENT_TYPE_CSV,
                  transport
          );
          return streamResponse != null ? streamResponse.getContent() : null;
      }
  }