package okhttp3.mock;

import okhttp3.*;
import org.junit.Before;
import org.junit.Test;

import java.io.IOException;
import java.util.regex.Pattern;

import static okhttp3.mock.ClasspathResources.resource;
import static okhttp3.mock.HttpCode.HTTP_200_OK;
import static okhttp3.mock.HttpCode.HTTP_401_UNAUTHORIZED;
import static okhttp3.mock.MediaTypes.MEDIATYPE_JSON;
import static org.junit.Assert.assertEquals;

public class MockInterceptorITTest {
    private static final String TEST_URL = "https://api.github.com/users/gmazzo";
    private static final String TEST_RESPONSE = "good!";
    private MockInterceptor interceptor;
    private OkHttpClient client;

    @Before
    public void setup() {
        client = new OkHttpClient.Builder()
                .addInterceptor(interceptor = new MockInterceptor(Behavior.UNORDERED))
                .build();
    }

    @Test
    public void testGet() throws IOException {
        interceptor.addRule()
                .get(TEST_URL)
                .respond(TEST_RESPONSE);

        client.newCall(new Request.Builder()
                .url(TEST_URL)
                .get()
                .build())
                .execute();
    }

    @Test
    public void testGetMultipleTimes() throws IOException {
        interceptor.addRule()
                .get(TEST_URL)
                .anyTimes()
                .respond(TEST_RESPONSE);

        String first = null;
        for (int i = 0; i < 10; i++) {
            String actual = client.newCall(new Request.Builder().url(TEST_URL).get().build())
                    .execute().body().string();

            if (first == null) {
                first = actual;

            } else {
                assertEquals(first, actual);
            }
        }
    }

    @Test
    public void testURLStartsWith() throws IOException {
        interceptor.addRule()
                .get()
                .urlStarts("https://")
                .respond(TEST_RESPONSE);

        client.newCall(new Request.Builder()
                .url(TEST_URL)
                .get()
                .build())
                .execute();
    }

    @Test(expected = AssertionError.class)
    public void testURLStartsWith_Fail() throws IOException {
        interceptor.addRule()
                .get()
                .urlStarts("http://")
                .respond(TEST_RESPONSE)
                .code(HTTP_401_UNAUTHORIZED);

        client.newCall(new Request.Builder()
                .url(TEST_URL)
                .get()
                .build())
                .execute();
    }


    @Test
    public void testBody() throws IOException {
        String request1 = "{ \"id\":1, \"bio\":\"bio here\" }";
        String request2 = "{ \"id\":1 }";

        String expectedResponse1 = TEST_RESPONSE;
        String expectedResponse2 = request1;

        interceptor.addRule()
                .post(TEST_URL)
                .body(request1)
                .respond(expectedResponse1);

        interceptor.addRule()
                .delete(TEST_URL)
                .body(request2)
                .respond(ResponseBody.create(expectedResponse2, MEDIATYPE_JSON));

        Response response1 = client.newCall(new Request.Builder()
                .url(TEST_URL)
                .post(RequestBody.create(request1, MEDIATYPE_JSON))
                .build())
                .execute();

        assertEquals(expectedResponse1, response1.body().string());

        Response response2 = client.newCall(new Request.Builder()
                .url(TEST_URL)
                .delete(RequestBody.create(request2, MEDIATYPE_JSON))
                .build())
                .execute();

        assertEquals(expectedResponse2, response2.body().string());
    }


    @Test(expected = AssertionError.class)
    public void testBody_Fail() throws IOException {
        String requestBody = "{ \"id\":1, \"bio\":\"bio here\" }";
        interceptor.addRule()
                .post(TEST_URL)
                .body("")
                .respond(TEST_RESPONSE);

        client.newCall(new Request.Builder()
                .url(TEST_URL)
                .post(RequestBody.create(requestBody, MEDIATYPE_JSON))
                .build())
                .execute();
    }

    @Test
    public void testResourceResponse() throws IOException {
        interceptor.addRule()
                .respond(resource("sample.json"));

        client.newCall(new Request.Builder()
                .url(TEST_URL)
                .get()
                .build())
                .execute();
    }

    @Test
    public void testCustomResponse() throws IOException {
        final String json = "{\"succeed\":true}";

        interceptor.behavior(Behavior.SEQUENTIAL).addRule()
                .get().or().post().or().put()
                .respond(json, MEDIATYPE_JSON);

        assertEquals(json, client.newCall(new Request.Builder()
                .url(TEST_URL)
                .get()
                .build())
                .execute()
                .body()
                .string());
    }

    @Test
    public void testCustomizeResponse() throws IOException {
        final ResponseBody body = ResponseBody.create(MediaTypes.MEDIATYPE_XML, "<html/>");

        interceptor.addRule().respond(TEST_RESPONSE).body(body).addHeader("Test", "aValue");

        Response response = client.newCall(new Request.Builder().url(TEST_URL).get().build()).execute();

        assertEquals(MediaTypes.MEDIATYPE_XML.type(), response.body().contentType().type());
        assertEquals(MediaTypes.MEDIATYPE_XML.subtype(), response.body().contentType().subtype());
        assertEquals("aValue", response.header("Test"));
        assertEquals("<html/>", response.body().string());
    }


    @Test(expected = IllegalStateException.class)
    public void testWrongOrSyntax1() {
        interceptor.addRule()
                .or().get()
                .respond(HttpCode.HTTP_409_CONFLICT);
    }

    @Test(expected = IllegalStateException.class)
    public void testWrongOrSyntax2() {
        interceptor.addRule()
                .get().or().or().post()
                .respond(HttpCode.HTTP_409_CONFLICT);
    }

    @Test(expected = IllegalStateException.class)
    public void testWrongNotSyntax1() {
        interceptor.addRule()
                .put().not()
                .respond(HttpCode.HTTP_409_CONFLICT);
    }

    @Test(expected = IllegalStateException.class)
    public void testWrongNotSyntax2() {
        interceptor.addRule()
                .not().not().put()
                .respond(HttpCode.HTTP_409_CONFLICT);
    }

    @Test(expected = AssertionError.class)
    public void testFailReasonSequential() throws IOException {
        interceptor.behavior(Behavior.SEQUENTIAL)
                .addRule()
                .get().or().post().or().put()
                .respond("OK");

        client.newCall(new Request.Builder()
                .url(TEST_URL)
                .delete()
                .build())
                .execute();
    }

    @Test
    public void testAnswer() throws IOException {
        interceptor.addRule()
                .get()
                .pathMatches(Pattern.compile("/aPath/(\\w+)"))
                .anyTimes()
                .answer(new RuleAnswer() {

                    @Override
                    public Response.Builder respond(Request request) {
                        return new Response.Builder()
                                .code(HTTP_200_OK)
                                .body(ResponseBody.create(null, request.url().encodedPath()));
                    }

                });

        String[] paths = new String[]{"/aPath/aaa", "/aPath/bbb", "/aPath/ccc"};
        for (String expectedBody : paths) {
            HttpUrl url = HttpUrl.parse(TEST_URL).newBuilder().encodedPath(expectedBody).build();

            String body = client.newCall(new Request.Builder()
                    .url(url)
                    .get()
                    .build())
                    .execute()
                    .body()
                    .string();

            assertEquals(expectedBody, body);
        }
    }

    @Test
    public void testPatch() throws IOException {
        final RequestBody body = RequestBody.create(MediaType.parse("application/json"), "{}");
        interceptor.addRule()
            .patch(TEST_URL)
            .respond(TEST_RESPONSE);

        client.newCall(new Request.Builder()
            .url(TEST_URL)
            .patch(body)
            .build())
            .execute();
    }
}