GraphQL
The XOOM GraphQL server for smooth legacy integration with complex queries made simple.
The XOOM GraphQL server component is based on XOOM HTTP. The
GraphQLResource is a dynamic resource handler implemented as the Reactive HTTP endpoint used to submit queries to our GraphQL server for asynchronous execution. The GraphQLResource registers the URL /graphql as the only HTTP resource specific to GraphQL applications, and thus handles all GraphQL operations. The single endpoint is logical and actually scales with a configurable number of backing actors. As expected, our GraphQL server is end-to-end Reactive.Queries and Mutations
Queries can be as simple as asking for specific fields and/or nested fields on objects. Queries can accept arguments to fields.
More advanced concepts such as aliases, fragments, operation name, variables, and directives are supported as well. While queries perform data fetching, mutations perform state transformations. The following is a basic example of a find query handled by our GraphQL server:
1
query {
2
bookById(id: "book-1") {
3
id
4
name
5
pageCount
6
author {
7
firstName
8
lastName
9
}
10
}
11
}
Copied!
And the following is an example of mutation on a resource entity. The upsert query means to insert or update as needed, making it an idempotent operation:
1
mutation {
2
upsertBook(id: "book-8", name: "The Mysterious Stranger", pageCount: 200, authorId: "author-2") {
3
id
4
name
5
pageCount
6
author {
7
firstName
8
lastName
9
}
10
}
11
}
Copied!
Schemas and Types
XOOM GraphQL adopts a schema-first approach. The design of a GraphQL API starts with defining a schema. The grammar used for writing schemas is called Schema Definition Language (SDL). A schema definition supports all GraphQL concepts, such as object types, fields, arguments, scalar types, enumeration types, lists and non-null, as well as interfaces and union types. Server side integration with a specific schema is done by following naming conventions. Classes and methods must match with schema definition components. Queries are validated, and any validation mismatches are signaled as failures. Here is an example schema:
1
# The Root Query for the application
2
type Query {
3
bookById(id: ID): Book
4
}
5
​
6
# The Root Mutation for the application
7
type Mutation {
8
upsertBook(id: ID!, name: String!, pageCount: Int, authorId: ID!): Book
9
}
10
​
11
type Book {
12
id: ID
13
name: String
14
pageCount: Int
15
author: Author
16
}
17
​
18
type Author {
19
id: ID
20
firstName: String
21
lastName: String
22
}
Copied!
The schema types
Book and Author map to class Book and Author, respectively:1
public class Book {
2
private String id;
3
private String name;
4
private int pageCount;
5
private Author author;
6
​
7
public Book(String id, String name, int pageCount, Author author) {
8
this.id = id;
9
this.name = name;
10
this.pageCount = pageCount;
11
this.author = author;
12
}
13
​
14
public String getId() {
15
return id;
16
}
17
​
18
public String getName() {
19
return name;
20
}
21
​
22
public int getPageCount() {
23
return pageCount;
24
}
25
​
26
public Author getAuthor() {
27
return author;
28
}
29
​
30
public Book updateWith(final Book from) {
31
this.name = from.name;
32
this.pageCount = from.pageCount;
33
this.author = from.author;
34
​
35
return this;
36
}
37
}
Copied!
1
public class Author {
2
private String id;
3
private String firstName;
4
private String lastName;
5
​
6
public Author(String id, String firstName, String lastName) {
7
this.id = id;
8
this.firstName = firstName;
9
this.lastName = lastName;
10
}
11
​
12
public String getId() {
13
return id;
14
}
15
​
16
public String getFirstName() {
17
return firstName;
18
}
19
​
20
public String getLastName() {
21
return lastName;
22
}
23
}
Copied!
The next topic is resolvers, which link data query results to schemas.
Resolvers
Each query or mutation must have a resolver that is associated by a naming convention. A resolver is responsible for actually performing a specific operation. All resolvers are registered to a
GraphQLProcessor. The GraphQLProcessor is used by the previously discussed GraphQLResource. The GraphProcessor is fully Reactive, being implemented as an actor.This is a basic (and incomplete) query resolver type:
1
package io.vlingo.xoom.graphql.resolvers;
2
​
3
import graphql.kickstart.tools.GraphQLQueryResolver;
4
import io.vlingo.xoom.graphql.Store;
5
import io.vlingo.xoom.graphql.model.Book;
6
​
7
public class BookQuery implements GraphQLQueryResolver {
8
public Book getBookById(String bookId) {
9
// query handling...
10
}
11
}
Copied!
And here is a mutation resolver example (also incomplete):
1
package io.vlingo.xoom.graphql.resolvers;
2
​
3
import graphql.kickstart.tools.GraphQLMutationResolver;
4
import io.vlingo.xoom.graphql.Store;
5
import io.vlingo.xoom.graphql.model.Book;
6
​
7
public class BookMutation implements GraphQLMutationResolver {
8
public Book upsertBook(final String id, final String name, final int pageCount, final String authorId) {
9
// mutation handling...
10
}
11
​
12
private Book upsertBook(final Book book) {
13
// mutation handling...
14
}
15
}
Copied!
Client Integration
XOOM GraphQL supports seamless client side integration that makes for smooth query and mutation operations. There are generated classes for types, queries, mutations, requests, responses, and projections. Both the server side and client side are fully Reactive. Our Reactive HTTP client provided by XOOM HTTP can use the generated classes end-to-end.
The following is an example of a Reactive client consuming a GraphQL response from a query that is executed reactively; note the use of
.andFinallyConsume(...):1
package io.vlingo.xoom.graphql.integration;
2
​
3
import com.kobylynskyi.graphql.codegen.model.graphql.GraphQLOperationRequest;
4
import com.kobylynskyi.graphql.codegen.model.graphql.GraphQLRequest;
5
import com.kobylynskyi.graphql.codegen.model.graphql.GraphQLResponseProjection;
6
​
7
import io.vlingo.xoom.actors.World;
8
import io.vlingo.xoom.http.resource.Client;
9
import io.vlingo.xoom.http.resource.Server;
10
​
11
public class BookStoreTest {
12
private static final String host = "localhost";
13
private static final int port = 8080;
14
​
15
private static World world;
16
private static Server server;
17
private static Client client;
18
19
...
20
​
21
private Response performRequest(final GraphQLOperationRequest request, final GraphQLResponseProjection responseProjection) {
22
final GraphQLRequest graphQLRequest = new GraphQLRequest(request, responseProjection);
23
final String graphQLQuery = graphQLRequest.toHttpJsonBody();
24
​
25
final AccessResponseConsumer responseConsumer = new AccessResponseConsumer();
26
​
27
client.requestWith(
28
Request
29
.has(Method.POST)
30
.and(URI.create("/graphql"))
31
.and(RequestHeader.contentLength(graphQLQuery))
32
.and(RequestHeader.keepAlive())
33
.and(Body.from(graphQLQuery)))
34
.andFinallyConsume(responseConsumer::consume);
35
​
36
return responseConsumer.accessResponse();
37
}
38
39
@BeforeAll
40
public static void setUp() throws Exception {
41
world = World.startWithDefaults("xoom-graphql-test");
42
​
43
GraphQLProcessor processor = TestBootstrap.newProcessor(world.stage());
44
GraphQLResource graphQLResource = new GraphQLResource(world.stage(), processor);
45
​
46
server = Server.startWith(world.stage(), Resources.are(graphQLResource.routes()), port, Configuration.Sizing.define(),
47
new Configuration.Timing(4L, 2L, 100L));
48
​
49
Address address = Address.from(Host.of(host), port, AddressType.NONE);
50
client = Client.using(Client.Configuration.defaultedKeepAliveExceptFor(world.stage(), address, new UnknownResponseConsumer()));
51
}
52
}
Copied!
Don't forget testing your client-side and server-side query and mutation components!
Unit Tests
End-to-end unit tests cover client side tests as well as server side tests together with full communication between both parties.
The classes in the
io.vlingo.xoom.graphql.client.model package are generated based on schema definition. The following is an example unit test:1
package io.vlingo.xoom.graphql.integration;
2
​
3
import io.vlingo.xoom.graphql.client.model.*;
4
​
5
public class BookStoreTest {
6
@Test
7
public void queryExistingBookTest() {
8
final BookByIdQueryRequest bookRequest = BookByIdQueryRequest.builder()
9
.setId("book-1")
10
.build();
11
​
12
final AuthorResponseProjection authorResponseProjection = new AuthorResponseProjection()
13
.firstName()
14
.lastName();
15
​
16
final BookResponseProjection bookResponseProjection = new BookResponseProjection()
17
.id()
18
.name()
19
.pageCount()
20
.author(authorResponseProjection);
21
​
22
Response response = performRequest(bookRequest, bookResponseProjection);
23
Assertions.assertEquals("200", response.statusCode);
24
​
25
BookByIdQueryResponse queryResponse = JsonSerialization.deserialized(response.entity.content(), BookByIdQueryResponse.class);
26
Assertions.assertEquals(0, queryResponse.getErrors().size());
27
​
28
Book book = queryResponse.bookById();
29
Assertions.assertEquals("book-1", book.getId());
30
Assertions.assertEquals("Romeo and Juliet", book.getName());
31
Assertions.assertEquals("William", book.getAuthor().getFirstName());
32
Assertions.assertEquals("Shakespeare", book.getAuthor().getLastName());
33
}
34
}
Copied!
Last modified 7mo ago