Class GraphQL

CodenameOne/src/com/codename1/io/graphql/GraphQL.java:52–317

/// generated impls call [#execute] / [#subscribe] and never touch
/// `ConnectionRequest` directly.
public final class GraphQL {

    /// Content type for GraphQL-over-HTTP requests.
    public static final String CONTENT_TYPE = "application/json";

    private GraphQL() {
    }

    /// Sends a unary query or mutation and invokes `callback` with the
    /// decoded [GraphQLResponse]. `variables` may be null or empty.
    /// The `operationName` may be null when the document declares a
    /// single operation.
    public static <T> void execute(
            String endpoint,
            String bearerToken,
            String operationName,
            String document,
            Map<String, Object> variables,
            Class<T> dataType,
            final OnComplete<GraphQLResponse<T>> callback) {
        if (callback == null) {
            throw new IllegalArgumentException("callback must not be null");
        }
        String body = buildRequestBody(operationName, document, variables);

        GraphQLConnection<T> conn = new GraphQLConnection<T>(dataType, callback);
        conn.setUrl(endpoint);
        conn.setHttpMethod("POST");
        conn.setPost(true);
        conn.setContentType(CONTENT_TYPE);
        conn.addRequestHeader("Accept", CONTENT_TYPE);
        if (bearerToken != null && bearerToken.length() > 0) {
            conn.addRequestHeader("Authorization", bearerToken);
        }
        conn.setRequestBody(new Data.StringData(body)); // StringData defaults to UTF-8
        CN.addToQueue(conn);
    }

    /// Opens a GraphQL subscription over a WebSocket and streams mapped
    /// `data` payloads to `handler`. Returns a handle whose
    /// [GraphQLSubscription#cancel()] tears the subscription down.
    ///
    /// The `endpoint` is the GraphQL HTTP endpoint; its scheme is
    /// rewritten to `ws`/`wss` for the WebSocket connection. Pass a
    /// `ws://`/`wss://` URL directly to override that heuristic.
    public static <T> GraphQLSubscription subscribe(
            String endpoint,
            String bearerToken,
            String operationName,
            String document,
            Map<String, Object> variables,
            Class<T> dataType,
            GraphQLSubscription.Handler<T> handler) {
        return GraphQLSubscription.start(
                toWebSocketUrl(endpoint), bearerToken, operationName,
                document, variables, dataType, handler);
    }