Websocket_transport (init.Init.Graphql_internal.Make.Websocket

module Json = Yojson.Basic.Util

val (>>=) : 'a Schema.Io.t -> ( 'a -> 'b Schema.Io.t ) -> 'b Schema.Io.t

type t = Websocket_handler.Make(Schema.Io)(Ws).t = {

conn : Ws.t;

subscriptions : ( string, unit -> unit ) Stdlib.Hashtbl.t;

}

type client_message = Websocket_handler.Make(Schema.Io)(Ws).client_message =

| Gql_connection_init

| Gql_start of {

id : string;

query : string;

variables : (string * Graphql_parser.const_value) list option;

operation_name : string option;

}

| Gql_stop of {

id : string;

}

| Gql_connection_terminate

type server_message = Websocket_handler.Make(Schema.Io)(Ws).server_message =

| Gql_connection_error

| Gql_connection_ack

| Gql_data

| Gql_error

| Gql_complete

val client_message_of_payload : 
  Yojson.Basic.t ->
  ( client_message, string ) Stdlib.result

val server_message_to_string : server_message -> string

val create_message : 
  ?opcode:Websocket.Frame.Opcode.t ->
  ?id:string ->
  ?payload:Yojson.Basic.t ->
  server_message ->
  Websocket.Frame.t

val handle_frame : 
  t ->
  execute_query:
    ( (string * Graphql_parser.const_value) list option ->
      string option ->
      string ->
      ( [< `Response of Yojson.Basic.t
        | `Stream of
          ( Yojson.Basic.t, Yojson.Basic.t ) Stdlib.result Schema.Io.Stream.t ],
        Yojson.Basic.t )
        Stdlib.result
        Schema.Io.t ) ->
  Websocket.Frame.t ->
  unit Ws.IO.t

val handle : 
  ( (string * Graphql_parser.const_value) list option ->
    string option ->
    string ->
    ( [< `Response of Yojson.Basic.t
      | `Stream of
        ( Yojson.Basic.t, Yojson.Basic.t ) Stdlib.result Schema.Io.Stream.t ],
      Yojson.Basic.t )
      Stdlib.result
      Schema.Io.t ) ->
  Ws.t ->
  'a Schema.Io.t