package com.baeldung.awsappsync;

import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.web.reactive.function.client.WebClient;

import java.util.HashMap;
import java.util.Map;

import static org.junit.jupiter.api.Assertions.*;

@SpringBootTest
@Disabled
class AwsAppSyncApplicationTests {

    @Test
    void givenGraphQuery_whenListEvents_thenReturnAllEvents() {

        Map<String, Object> requestBody = new HashMap<>();
        requestBody.put("query", "query ListEvents {"
                + "  listEvents {"
                + "    items {"
                + "      id"
                + "      name"
                + "      where"
                + "      when"
                + "      description"
                + "    }"
                + "  }"
                + "}");
        requestBody.put("variables", "");
        requestBody.put("operationName", "ListEvents");

        String bodyString = AppSyncClientHelper.getResponseBodySpec(requestBody)
                .bodyToMono(String.class).block();

        assertNotNull(bodyString);
        assertTrue(bodyString.contains("My First Event"));
        assertTrue(bodyString.contains("where"));
        assertTrue(bodyString.contains("when"));
    }

    @Test
    void givenGraphAdd_whenMutation_thenReturnIdNameDesc() {

        String queryString = "mutation add {"
                + "    createEvent("
                + "        name:\"My added GraphQL event\""
                + "        where:\"Day 2\""
                + "        when:\"Saturday night\""
                + "        description:\"Studying GraphQL\""
                + "    ){"
                + "        id"
                + "        name"
                + "        description"
                + "    }"
                + "}";

        Map<String, Object> requestBody = new HashMap<>();
        requestBody.put("query", queryString);
        requestBody.put("variables", "");
        requestBody.put("operationName", "add");

        WebClient.ResponseSpec response = AppSyncClientHelper.getResponseBodySpec(requestBody);

        String bodyString = response.bodyToMono(String.class).block();

        assertNotNull(bodyString);
        assertTrue(bodyString.contains("My added GraphQL event"));
        assertFalse(bodyString.contains("where"));
        assertFalse(bodyString.contains("when"));
    }
}