/**
 * Copyright 2012-2020 The Feign Authors
 *
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
 * in compliance with the License. You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software distributed under the License
 * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
 * or implied. See the License for the specific language governing permissions and limitations under
 * the License.
 */
package feign;

import static feign.assertj.FeignAssertions.assertThat;
import static java.util.Arrays.asList;
import static org.assertj.core.data.MapEntry.entry;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import java.util.Arrays;
import java.util.Collection;
import java.util.Collections;
import java.util.LinkedHashMap;
import java.util.Map;
import org.junit.Rule;
import org.junit.Test;
import org.junit.rules.ExpectedException;
import feign.Request.HttpMethod;
import feign.template.UriUtils;

public class RequestTemplateTest {

  @Rule
  public final ExpectedException thrown = ExpectedException.none();

  /**
   * Avoid depending on guava solely for map literals.
   */
  private static <K, V> Map<K, V> mapOf(K key, V val) {
    Map<K, V> result = new LinkedHashMap<>();
    result.put(key, val);
    return result;
  }

  private static <K, V> Map<K, V> mapOf(K k1, V v1, K k2, V v2) {
    Map<K, V> result = mapOf(k1, v1);
    result.put(k2, v2);
    return result;
  }

  private static <K, V> Map<K, V> mapOf(K k1, V v1, K k2, V v2, K k3, V v3) {
    Map<K, V> result = mapOf(k1, v1, k2, v2);
    result.put(k3, v3);
    return result;
  }

  private static String expand(String template, Map<String, Object> variables) {
    RequestTemplate requestTemplate = new RequestTemplate();
    requestTemplate.uri(template);
    return requestTemplate.resolve(variables).url();
  }

  @Test
  public void expandUrlEncoded() {
    for (String val : Arrays.asList("apples", "sp ace", "unic???de", "qu?stion")) {
      assertThat(expand("/users/{user}", mapOf("user", val)))
          .isEqualTo("/users/" + UriUtils.encode(val, Util.UTF_8));
    }
  }

  @Test
  public void expandMultipleParams() {
    assertThat(expand("/users/{user}/{repo}", mapOf("user", "unic???de", "repo", "foo")))
        .isEqualTo("/users/unic%3F%3F%3Fde/foo");
  }

  @Test
  public void expandParamKeyHyphen() {
    assertThat(expand("/{user-dir}", mapOf("user-dir", "foo")))
        .isEqualTo("/foo");
  }

  @Test
  public void expandMissingParamProceeds() {
    assertThat(expand("/{user-dir}", mapOf("user_dir", "foo")))
        .isEqualTo("/");
  }

  @Test
  public void resolveTemplateWithParameterizedPathSkipsEncodingSlash() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.GET)
        .uri("{zoneId}");

    template = template.resolve(mapOf("zoneId", "/hostedzone/Z1PA6795UKMFR9"));

    assertThat(template)
        .hasUrl("/hostedzone/Z1PA6795UKMFR9");
  }

  @Test
  public void resolveTemplateWithBinaryBody() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.GET)
        .uri("{zoneId}")
        .body(new byte[] {7, 3, -3, -7}, null);
    template = template.resolve(mapOf("zoneId", "/hostedzone/Z1PA6795UKMFR9"));

    assertThat(template)
        .hasUrl("/hostedzone/Z1PA6795UKMFR9");
  }

  @Test
  public void canInsertAbsoluteHref() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.GET)
        .uri("/hostedzone/Z1PA6795UKMFR9");

    template.target("https://route53.amazonaws.com/2012-12-12");

    assertThat(template)
        .hasUrl("https://route53.amazonaws.com/2012-12-12/hostedzone/Z1PA6795UKMFR9");
  }

  @Test
  public void resolveTemplateWithRelativeUriWithQuery() {
    RequestTemplate template = new RequestTemplate()
        .method(HttpMethod.GET)
        .uri("/wsdl/testcase?wsdl")
        .target("https://api.example.com");

    assertThat(template).hasUrl("https://api.example.com/wsdl/testcase?wsdl");
  }

  @Test
  public void resolveTemplateWithBaseAndParameterizedQuery() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.GET)
        .uri("/?Action=DescribeRegions").query("RegionName.1", "{region}");

    template = template.resolve(mapOf("region", "eu-west-1"));

    assertThat(template)
        .hasQueries(
            entry("Action", Collections.singletonList("DescribeRegions")),
            entry("RegionName.1", Collections.singletonList("eu-west-1")));
  }

  @Test
  public void resolveTemplateWithBaseAndParameterizedIterableQuery() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.GET)
        .uri("/?Query=one").query("Queries", "{queries}");

    template = template.resolve(mapOf("queries", Arrays.asList("us-east-1", "eu-west-1")));

    assertThat(template)
        .hasQueries(
            entry("Query", Collections.singletonList("one")),
            entry("Queries", asList("us-east-1", "eu-west-1")));
  }

  @Test
  public void resolveTemplateWithMixedCollectionFormatsByQuery() {
    RequestTemplate template = new RequestTemplate()
        .method(HttpMethod.GET)
        .collectionFormat(CollectionFormat.EXPLODED)
        .uri("/api/collections")
        .query("keys", "{keys}") // default collection format
        .query("values[]", Collections.singletonList("{values[]}"), CollectionFormat.CSV);

    template = template.resolve(mapOf("keys", Arrays.asList("one", "two"),
        "values[]", Arrays.asList("1", "2")));

    assertThat(template.url())
        .isEqualToIgnoringCase("/api/collections?keys=one&keys=two&values%5B%5D=1%2C2");
  }

  @Test
  public void resolveTemplateWithHeaderSubstitutions() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.GET)
        .header("Auth-Token", "{authToken}");

    template = template.resolve(mapOf("authToken", "1234"));

    assertThat(template)
        .hasHeaders(entry("Auth-Token", Collections.singletonList("1234")));
  }

  @Test
  public void resolveTemplateWithHeaderSubstitutionsNotAtStart() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.GET)
        .header("Authorization", "Bearer {token}");

    template = template.resolve(mapOf("token", "1234"));

    assertThat(template)
        .hasHeaders(entry("Authorization", Collections.singletonList("Bearer 1234")));
  }

  @Test
  public void resolveTemplateWithHeaderWithEscapedCurlyBrace() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.GET)
        .header("Encoded", "{{{{dont_expand_me}}");

    template.resolve(mapOf("dont_expand_me", "1234"));

    assertThat(template)
        .hasHeaders(entry("Encoded", Collections.singletonList("{{{{dont_expand_me}}")));
  }

  /**
   * This ensures we don't mess up vnd types
   */
  @Test
  public void resolveTemplateWithHeaderIncludingSpecialCharacters() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.GET)
        .header("Accept", "application/vnd.github.v3+{type}");

    template = template.resolve(mapOf("type", "json"));

    assertThat(template)
        .hasHeaders(entry("Accept", Collections.singletonList("application/vnd.github.v3+json")));
  }

  @Test
  public void resolveTemplateWithHeaderEmptyResult() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.GET)
        .header("Encoded", "{var}");

    template = template.resolve(mapOf("var", ""));

    assertThat(template)
        .hasNoHeader("Encoded");
  }

  @Test
  public void resolveTemplateWithMixedRequestLineParams() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.GET)//
        .uri("/domains/{domainId}/records")//
        .query("name", "{name}")//
        .query("type", "{type}");

    template = template.resolve(
        mapOf("domainId", 1001, "name", "denominator.io", "type", "CNAME"));

    assertThat(template)
        .hasQueries(
            entry("name", Collections.singletonList("denominator.io")),
            entry("type", Collections.singletonList("CNAME")));
  }

  @Test
  public void insertHasQueryParams() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.GET)//
        .uri("/domains/1001/records")//
        .query("name", "denominator.io")//
        .query("type", "CNAME");

    template.target("https://host/v1.0/1234?provider=foo");

    assertThat(template)
        .hasPath("https://host/v1.0/1234/domains/1001/records")
        .hasQueries(
            entry("name", Collections.singletonList("denominator.io")),
            entry("type", Collections.singletonList("CNAME")),
            entry("provider", Collections.singletonList("foo")));
  }

  @Test
  public void resolveTemplateWithBodyTemplateSetsBodyAndContentLength() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.POST)
        .bodyTemplate(
            "%7B\"customer_name\": \"{customer_name}\", \"user_name\": \"{user_name}\", " +
                "\"password\": \"{password}\"%7D",
            Util.UTF_8);

    template = template.resolve(
        mapOf(
            "customer_name", "netflix",
            "user_name", "denominator",
            "password", "password"));

    assertThat(template)
        .hasBody(
            "{\"customer_name\": \"netflix\", \"user_name\": \"denominator\", \"password\": \"password\"}")
        .hasHeaders(
            entry("Content-Length",
                Collections.singletonList(String.valueOf(template.body().length))));
  }

  @Test
  public void resolveTemplateWithBodyTemplateDoesNotDoubleDecode() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.POST)
        .bodyTemplate(
            "%7B\"customer_name\": \"{customer_name}\", \"user_name\": \"{user_name}\", \"password\": \"{password}\"%7D",
            Util.UTF_8);

    template = template.resolve(
        mapOf(
            "customer_name", "netflix",
            "user_name", "denominator",
            "password", "abc+123%25d8"));

    assertThat(template)
        .hasBody(
            "{\"customer_name\": \"netflix\", \"user_name\": \"denominator\", \"password\": \"abc+123%25d8\"}");
  }

  @Test
  public void skipUnresolvedQueries() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.GET)
        .uri("/domains/{domainId}/records")//
        .query("optional", "{optional}")//
        .query("name", "{nameVariable}");

    template = template.resolve(mapOf(
        "domainId", 1001,
        "nameVariable", "denominator.io"));

    assertThat(template)
        .hasQueries(
            entry("name", Collections.singletonList("denominator.io")));
  }

  @Test
  public void allQueriesUnresolvable() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.GET)//
        .uri("/domains/{domainId}/records")//
        .query("optional", "{optional}")//
        .query("optional2", "{optional2}");

    template = template.resolve(mapOf("domainId", 1001));

    assertThat(template)
        .hasUrl("/domains/1001/records")
        .hasQueries();
  }

  @Test
  public void spaceEncodingInUrlParam() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.GET)//
        .uri("/api/{value1}?key={value2}");

    template = template.resolve(mapOf("value1", "ABC 123", "value2", "XYZ 123"));

    assertThat(template.request().url())
        .isEqualTo("/api/ABC%20123?key=XYZ%20123");
  }

  @Test
  public void useCaseInsensitiveHeaderFieldNames() {
    final RequestTemplate template = new RequestTemplate();

    final String value = "value1";
    template.header("TEST", value);

    final String value2 = "value2";
    template.header("tEST", value2);

    final Collection<String> test = template.headers().get("test");

    final String assertionMessage = "Header field names should be case insensitive";

    assertNotNull(assertionMessage, test);
    assertTrue(assertionMessage, test.contains(value));
    assertTrue(assertionMessage, test.contains(value2));
    assertEquals(1, template.headers().size());
    assertEquals(2, template.headers().get("tesT").size());
  }

  @Test
  public void encodeSlashTest() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.GET)
        .uri("/api/{vhost}")
        .decodeSlash(false);

    template = template.resolve(mapOf("vhost", "/"));

    assertThat(template)
        .hasUrl("/api/%2F");
  }

  @Test
  public void encodedQueryClearedOnNull() {
    RequestTemplate template = new RequestTemplate();

    template.query("param[]", "value");
    assertThat(template).hasQueries(entry("param[]", Collections.singletonList("value")));

    template.query("param[]", (String[]) null);
    assertThat(template.queries()).isEmpty();
  }

  @Test
  public void encodedQuery() {
    RequestTemplate template = new RequestTemplate().query("params[]", "foo%20bar");
    assertThat(template.queryLine()).isEqualTo("?params%5B%5D=foo%20bar");
    assertThat(template).hasQueries(entry("params[]", Collections.singletonList("foo%20bar")));
  }

  @Test
  public void encodedQueryWithUnsafeCharactersMixedWithUnencoded() {
    RequestTemplate template = new RequestTemplate()
        .query("params[]", "not encoded") // stored as "param%5D%5B"
        .query("params[]", "encoded"); // stored as "param[]"

    assertThat(template.queryLine()).isEqualTo("?params%5B%5D=not%20encoded&params%5B%5D=encoded");
    Map<String, Collection<String>> queries = template.queries();
    assertThat(queries).containsKey("params[]");
    assertThat(queries.get("params[]")).contains("encoded").contains("not%20encoded");
  }

  @SuppressWarnings("unchecked")
  @Test
  public void shouldRetrieveHeadersWithoutNull() {
    RequestTemplate template = new RequestTemplate()
        .header("key1", (String) null)
        .header("key2", Collections.emptyList())
        .header("key3", (Collection) null)
        .header("key4", "valid")
        .header("key5", "valid")
        .header("key6", "valid")
        .header("key7", "valid");

    assertThat(template.headers()).hasSize(4);
    assertThat(template.headers().keySet()).containsExactly("key4", "key5", "key6", "key7");

  }

  @SuppressWarnings("ConstantConditions")
  @Test(expected = UnsupportedOperationException.class)
  public void shouldNotInsertHeadersImmutableMap() {
    RequestTemplate template = new RequestTemplate()
        .header("key1", "valid");

    assertThat(template.headers()).hasSize(1);
    assertThat(template.headers().keySet()).containsExactly("key1");

    template.headers().put("key2", Collections.singletonList("other value"));
  }

  @Test
  public void fragmentShouldNotBeEncodedInUri() {
    RequestTemplate template = new RequestTemplate()
        .method(HttpMethod.GET)
        .uri("/path#fragment")
        .queries(mapOf("key1", Collections.singletonList("value1")));

    assertThat(template.url()).isEqualTo("/path?key1=value1#fragment");
  }

  @Test
  public void fragmentShouldNotBeEncodedInTarget() {
    RequestTemplate template = new RequestTemplate()
        .method(HttpMethod.GET)
        .target("https://example.com/path#fragment")
        .queries(mapOf("key1", Collections.singletonList("value1")));

    assertThat(template.url()).isEqualTo("https://example.com/path?key1=value1#fragment");
  }

  @Test
  public void slashShouldNotBeAppendedForMatrixParams() {
    RequestTemplate template = new RequestTemplate().method(HttpMethod.GET)
        .uri("/path;key1=value1;key2=value2", true);

    assertThat(template.url()).isEqualTo("/path;key1=value1;key2=value2");
  }

  @Test
  public void encodedReservedPreserveSlash() {
    RequestTemplate template = new RequestTemplate();
    template.uri("/get?url={url}");
    template.method(HttpMethod.GET);
    template = template.resolve(Collections.singletonMap("url", "https://www.google.com"));
    assertThat(template.url()).isEqualToIgnoringCase("/get?url=https%3A//www.google.com");
  }

  @Test
  public void encodedReservedEncodeSlash() {
    RequestTemplate template = new RequestTemplate();
    template.uri("/get?url={url}");
    template.decodeSlash(false);
    template.method(HttpMethod.GET);
    template = template.resolve(Collections.singletonMap("url", "https://www.google.com"));
    assertThat(template.url()).isEqualToIgnoringCase("/get?url=https%3A%2F%2Fwww.google.com");
  }
}