/*
 * This file is part of the JDrupes non-blocking HTTP Codec
 * Copyright (C) 2016, 2017  Michael N. Lipp
 *
 * This program is free software; you can redistribute it and/or modify it 
 * under the terms of the GNU Lesser General Public License as published
 * by the Free Software Foundation; either version 3 of the License, or 
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful, but 
 * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
 * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public 
 * License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License along 
 * with this program; if not, see <http://www.gnu.org/licenses/>.
 */

package org.jdrupes.httpcodec.protocols.http;

import java.io.UnsupportedEncodingException;
import java.net.URI;
import java.net.URLDecoder;
import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.StringTokenizer;

import static org.jdrupes.httpcodec.protocols.http.HttpConstants.*;

/**
 * Represents an HTTP request header.
 */
public class HttpRequest extends HttpMessageHeader {

    public static final URI ASTERISK_REQUEST
        = URI.create("http://127.0.0.1/");

    private String method;
    private URI requestUri;
    private String host;
    private int port;
    private HttpResponse response;
    private Map<String, List<String>> decodedQuery = null;

    /**
     * Creates a new request with basic data. The {@link #host()}
     * and {@link #port()} values are initialized with the values from
     * the `requestUri`.
     * 
     * @param method the method
     * @param requestUri the requested resource
     * @param httpProtocol the HTTP protocol version
     * @param hasPayload indicates that the message has a payload body
     */
    public HttpRequest(String method, URI requestUri,
            HttpProtocol httpProtocol, boolean hasPayload) {
        super(httpProtocol, hasPayload);
        this.method = method;
        this.requestUri = requestUri;
        this.host = requestUri.getHost();
        this.port = requestUri.getPort();
    }

    /*
     * (non-Javadoc)
     * 
     * @see HttpMessageHeader#setField(org.jdrupes.httpcodec.fields.HttpField)
     */
    @Override
    public HttpRequest setField(HttpField<?> value) {
        super.setField(value);
        return this;
    }

    /*
     * (non-Javadoc)
     * 
     * @see HttpMessageHeader#setField(java.lang.String, java.lang.Object)
     */
    @Override
    public <T> HttpRequest setField(String name, T value) {
        super.setField(name, value);
        return this;
    }

    /*
     * (non-Javadoc)
     * 
     * @see
     * org.jdrupes.httpcodec.protocols.http.HttpMessageHeader#setHasPayload(
     * boolean)
     */
    @Override
    public HttpRequest setHasPayload(boolean hasPayload) {
        super.setHasPayload(hasPayload);
        return this;
    }

    /**
     * Return the method.
     * 
     * @return the method
     */
    public String method() {
        return method;
    }

    /**
     * Return the URI of the requested resource.
     * 
     * @return the requestUri
     */
    public URI requestUri() {
        return requestUri;
    }

    /**
     * Set the host and port attributes.
     * 
     * @param host the host
     * @param port the port
     * @return the request for easy chaining
     */
    public HttpRequest setHostAndPort(String host, int port) {
        this.host = host;
        this.port = port;
        return this;
    }

    /**
     * @return the host
     */
    public String host() {
        return host;
    }

    /**
     * @return the port
     */
    public int port() {
        return port;
    }

    /**
     * Associates the request with a response. This method is
     * invoked by the request decoder that initializes the response with
     * basic information that can be derived from the request 
     * (e.g. by default the HTTP version is copied). The status code
     * of the preliminary response is 501 "Not implemented".
     * <P>
     * Although not strictly required, users of the API are encouraged to 
     * modify this prepared request and use it when building the response.
     *  
     * @param response the prepared response
     * @return the request for easy chaining
     */
    public HttpRequest setResponse(HttpResponse response) {
        this.response = response;
        return this;
    }

    /**
     * Returns the prepared response.
     * 
     * @return the prepared response
     * @see #setResponse(HttpResponse)
     */
    public Optional<HttpResponse> response() {
        return Optional.ofNullable(response);
    }

    /**
     * Returns the decoded query data from the request URI. The result
     * is a lazily created (and cached) unmodifiable map.
     *
     * @param charset the charset to use for decoding
     * @return the data
     * @throws UnsupportedEncodingException the unsupported encoding exception
     */
    public Map<String, List<String>> queryData(Charset charset)
            throws UnsupportedEncodingException {
        if (decodedQuery != null) {
            return decodedQuery;
        }
        if (requestUri.getRawQuery() == null
            || requestUri.getRawQuery().length() == 0) {
            decodedQuery = Collections.emptyMap();
            return decodedQuery;
        }
        Map<String, List<String>> queryData = new HashMap<>();
        StringTokenizer pairStrings
            = new StringTokenizer(requestUri.getRawQuery(), "&");
        while (pairStrings.hasMoreTokens()) {
            StringTokenizer pair
                = new StringTokenizer(pairStrings.nextToken(), "=");
            String key = URLDecoder.decode(pair.nextToken(), charset.name());
            String value = pair.hasMoreTokens()
                ? URLDecoder.decode(pair.nextToken(), charset.name())
                : null;
            queryData.computeIfAbsent(key, k -> new ArrayList<>()).add(value);
        }
        for (Map.Entry<String, List<String>> entry : queryData.entrySet()) {
            entry.setValue(Collections.unmodifiableList(entry.getValue()));
        }
        decodedQuery = Collections.unmodifiableMap(queryData);
        return decodedQuery;
    }

    /**
     * Short for invoking {@link #queryData(Charset)} with UTF-8 as charset.
     *
     * @return the map
     */
    public Map<String, List<String>> queryData() {
        try {
            return queryData(StandardCharsets.UTF_8);
        } catch (UnsupportedEncodingException e) {
            // Cannot happen
            throw new IllegalStateException(e);
        }
    }

    /*
     * (non-Javadoc)
     * 
     * @see java.lang.Object#toString()
     */
    @Override
    public String toString() {
        StringBuilder builder = new StringBuilder();
        builder.append("HttpRequest [");
        if (method != null) {
            builder.append("method=");
            builder.append(method);
            builder.append(", ");
        }
        if (requestUri != null) {
            builder.append("requestUri=");
            builder.append(requestUri);
            builder.append(", ");
        }
        if (protocol() != null) {
            builder.append("httpVersion=");
            builder.append(protocol());
        }
        builder.append("]");
        return builder.toString();
    }

}