Skip to content

Commit 9d4f734

Browse files
committed
Pass payload on for Apollo subscription GQL_CONNECTION_INIT (fix #100)
1 parent 5ba8c6f commit 9d4f734

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

src/main/java/graphql/servlet/GraphQLContextBuilder.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,9 @@
55
import javax.websocket.server.HandshakeRequest;
66

77
public interface GraphQLContextBuilder {
8+
89
GraphQLContext build(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse);
10+
911
GraphQLContext build(HandshakeRequest handshakeRequest);
1012

1113
/**

src/main/java/graphql/servlet/internal/ApolloSubscriptionProtocolHandler.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -48,8 +48,8 @@ public void onMessage(HandshakeRequest request, Session session, WsSessionSubscr
4848

4949
switch(message.getType()) {
5050
case GQL_CONNECTION_INIT:
51-
sendMessage(session, OperationMessage.Type.GQL_CONNECTION_ACK, message.getId());
52-
sendMessage(session, OperationMessage.Type.GQL_CONNECTION_KEEP_ALIVE, message.getId());
51+
sendMessage(session, OperationMessage.Type.GQL_CONNECTION_ACK, message.getId(), message.getPayload());
52+
sendMessage(session, OperationMessage.Type.GQL_CONNECTION_KEEP_ALIVE, message.getId(), message.getPayload());
5353
break;
5454

5555
case GQL_START:
@@ -58,7 +58,7 @@ public void onMessage(HandshakeRequest request, Session session, WsSessionSubscr
5858
subscriptions,
5959
message.id,
6060
input.getQueryInvoker().query(input.getInvocationInputFactory().create(
61-
input.getGraphQLObjectMapper().getJacksonMapper().convertValue(message.payload, GraphQLRequest.class),
61+
input.getGraphQLObjectMapper().getJacksonMapper().convertValue(message.getPayload(), GraphQLRequest.class),
6262
(HandshakeRequest) session.getUserProperties().get(HandshakeRequest.class.getName())
6363
))
6464
);

0 commit comments

Comments
 (0)