java-tutorials/aws-app-sync/src/test/java/com/baeldung/awsappsync/AwsAppSyncApplicationTests.java

package com.baeldung.awsappsync;

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
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"));
    }
}