BookingService

package com.srv4pos.server.api.booking;

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.exceptions.enums.ForbiddenErrorType;
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;

/**
 * Created by eugene.shishkin on 05.09.14.
 */
public class BookingService {

    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 BookingService(URL url, Credentials credentials, Transport transport) {
        this.url = url;
        this.credentials = credentials;
        this.transport = transport;
    }

    /**
     * Modifies a booking.
     *
     * @param version     expected latest version of seller
     * @param bookingInfo data to put
     * @param identifier  identifier of booking
     * @throws com.srv4pos.server.api.exceptions.VersionConflictJsonException if version mismatch
     * @throws com.srv4pos.server.api.exceptions.NotFoundJsonException        if booking or seller wasn't found
     * @throws com.srv4pos.server.api.exceptions.ForbiddenJsonException       see:
     *                                                                        {@link ForbiddenErrorType#INSUFFICIENT_ACCESS_RIGHTS}
     */
    public void put(int version, BookingInfo bookingInfo, String identifier) {
        requestVoid(
                format("%s/bookings/%s", credentials.getSellerId(), identifier),
                HttpMethod.PUT,
                url,
                credentials.toAuthentication(),
                HttpHelper.integerToETag(version),
                null,
                new StringConnectionWriter(bookingInfo.toJson()),
                HttpHelper.CONTENT_TYPE_APPLICATION_JSON,
                transport
        );
    }

    /**
     * Deletes a booking.
     *
     * @param version current version of the entity
     * @param identifier  identifier of booking
     * @throws com.srv4pos.server.api.exceptions.VersionConflictJsonException if version mismatch
     * @throws com.srv4pos.server.api.exceptions.NotFoundJsonException        if booking or seller wasn't found
     * @throws com.srv4pos.server.api.exceptions.ForbiddenJsonException       see:
     *                                                                        {@link ForbiddenErrorType#INSUFFICIENT_ACCESS_RIGHTS}
     */
    public void delete(int version, String identifier) {
        requestVoid(
                format("%s/bookings/%s", credentials.getSellerId(), identifier),
                HttpMethod.DELETE,
                url,
                credentials.toAuthentication(),
                HttpHelper.integerToETag(version),
                null,
                EmptyConnectionWriter.EMPTY_CONNECTION_WRITER,
                HttpHelper.CONTENT_TYPE_APPLICATION_JSON,
                transport
        );
    }

    /**
     * Create booking on the server.
     *
     * @param bookingInfo data to put
     * @param version current version of seller
     * @return generated identifier
     * @throws com.srv4pos.server.api.exceptions.NotFoundJsonException if seller wasn't found
     */
    public String create(BookingInfo bookingInfo, Integer version) {
        return IdentifierInfo.fromJsonToIdentifierInfo(
                requestString(
                        format("%s/bookings", credentials.getSellerId()),
                        HttpMethod.POST,
                        url,
                        credentials.toAuthentication(),
                        HttpHelper.integerToETag(version),
                        null,
                        new StringConnectionWriter(bookingInfo.toJson()),
                        HttpHelper.CONTENT_TYPE_APPLICATION_JSON,
                        transport
                ).getContent()).getIdentifier();
    }

    /**
     * Returns an entity.
     *
     * @param identifier identifies entity
     * @return the entity
     * @throws com.srv4pos.server.api.exceptions.NotFoundJsonException  if booking or seller wasn't found
     * @throws com.srv4pos.server.api.exceptions.ForbiddenJsonException           see:
     *                                                                            {@link ForbiddenErrorType#INSUFFICIENT_ACCESS_RIGHTS}
     */
    public BookingInfo get(final String identifier) {
        return BookingInfo.fromJsonToBookingInfo(
                requestString(
                        format("%s/bookings/%s", credentials.getSellerId(), identifier),
                        HttpMethod.GET,
                        url,
                        credentials.toAuthentication(),
                        null,
                        null,
                        EmptyConnectionWriter.EMPTY_CONNECTION_WRITER,
                        HttpHelper.CONTENT_TYPE_APPLICATION_JSON,
                        transport).getContent());
    }

    /**
     * Returns list of bookings.
     *
     * @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 "IDENTIFIER"
     * @param orderDesc   field to direction of ordering
     * @return list of entities which exists on current seller or null if list of entities is not modified since version
     */
    public List<BookingInfo> list(Integer firstResult,
                                  Integer maxResults,
                                  String like,
                                  BookingInfo.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/bookings", credentials.getSellerId()),
                HttpMethod.GET,
                url,
                credentials.toAuthentication(),
                null,
                params,
                EmptyConnectionWriter.EMPTY_CONNECTION_WRITER,
                HttpHelper.CONTENT_TYPE_APPLICATION_JSON,
                transport
        );
        return response == null ? null : (List<BookingInfo>) BookingInfo.fromJsonArrayToBookingInfoes(response.getContent());
    }

    /**
     * Returns list of item changes between two versions. Since we don't have delete and edit methods, it
     * returns only newly created bookings
     *
     * @param versionFrom version from included
     * @param versionTo   version to included
     * @return list of items to be added, edited or deleted (actually, only created)
     */
    public List<BookingInfo> listDiff(int versionFrom, int versionTo) {
        StringResponse response = requestString(String.format("%s/bookings-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<BookingInfo>) BookingInfo.fromJsonArrayToBookingInfoes(response.getContent());
    }
}