77 lines
2.6 KiB
Dart
77 lines
2.6 KiB
Dart
import 'package:graphql_schema/graphql_schema.dart';
|
|
|
|
/// A basic message in the Apollo WebSocket protocol.
|
|
class OperationMessage {
|
|
static const String gqlConnectionInit = 'connection_init',
|
|
gqlConnectionAck = 'connection_ack',
|
|
gqlConnectionKeepAlive = 'ka',
|
|
gqlConnectionError = 'connection_error',
|
|
gqlStart = 'start',
|
|
gqlStop = 'stop',
|
|
gqlConnectionTerminate = 'connection_terminate',
|
|
gqlData = 'data',
|
|
gqlError = 'error',
|
|
gqlComplete = 'complete';
|
|
static const String legacyGqlConnectionInit = 'connection_init',
|
|
legacyGqlConnectionAck = 'connection_ack',
|
|
legacyGqlConnectionKeepAlive = 'ka',
|
|
legacyGqlConnectionError = 'connection_error',
|
|
legacyGqlStart = 'start',
|
|
legacyGqlStop = 'stop',
|
|
legacyGqlConnectionTerminate = 'connection_terminate',
|
|
legacyGqlData = 'data',
|
|
legacyGqlError = 'error',
|
|
legacyGqlComplete = 'complete';
|
|
|
|
// static const String gqlConnectionInit = 'GQL_CONNECTION_INIT',
|
|
// gqlConnectionAck = 'GQL_CONNECTION_ACK',
|
|
// gqlConnectionKeepAlive = 'GQL_CONNECTION_KEEP_ALIVE',
|
|
// gqlConnectionError = 'GQL_CONNECTION_ERROR',
|
|
// gqlStart = 'GQL_START',
|
|
// gqlStop = 'GQL_STOP',
|
|
// gqlConnectionTerminate = 'GQL_CONNECTION_TERMINATE',
|
|
// gqlData = 'GQL_DATA',
|
|
// gqlError = 'GQL_ERROR',
|
|
// gqlComplete = 'GQL_COMPLETE';
|
|
final dynamic payload;
|
|
final String id;
|
|
final String type;
|
|
|
|
OperationMessage(this.type, {this.payload, this.id});
|
|
|
|
factory OperationMessage.fromJson(Map map) {
|
|
var type = map['type'];
|
|
var payload = map['payload'];
|
|
var id = map['id'];
|
|
|
|
if (type == null)
|
|
throw ArgumentError.notNull('type');
|
|
else if (type is! String)
|
|
throw ArgumentError.value(type, 'type', 'must be a string');
|
|
else if (id is num)
|
|
id = id.toString();
|
|
else if (id != null && id is! String)
|
|
throw ArgumentError.value(id, 'id', 'must be a string or number');
|
|
|
|
// TODO: This is technically a violation of the spec.
|
|
// https://github.com/apollographql/subscriptions-transport-ws/issues/551
|
|
if (map.containsKey('query') ||
|
|
map.containsKey('operationName') ||
|
|
map.containsKey('variables')) payload = Map.from(map);
|
|
return OperationMessage(type as String, id: id as String, payload: payload);
|
|
}
|
|
|
|
Map<String, dynamic> toJson() {
|
|
var out = <String, dynamic>{'type': type};
|
|
if (id != null) out['id'] = id;
|
|
if (payload != null) out['payload'] = payload;
|
|
return out;
|
|
}
|
|
}
|
|
|
|
class GraphQLResult {
|
|
final dynamic data;
|
|
final Iterable<GraphQLExceptionError> errors;
|
|
|
|
GraphQLResult(this.data, {this.errors: const []});
|
|
}
|