Skip to content

Commit e4e05cf

Browse files
lewinpaulilewinpauli
committed
fix(graphql): apply dart format
1 parent ffe3352 commit e4e05cf

File tree

8 files changed

+104
-50
lines changed

8 files changed

+104
-50
lines changed

‎packages/graphql/lib/src/core/_base_options.dart‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,8 @@ abstract class BaseOptions<TParsed extends Object?> {
9797
];
9898

9999
OperationType get type {
100-
final definitions = document.definitions.whereType<OperationDefinitionNode>().toList();
100+
final definitions =
101+
document.definitions.whereType<OperationDefinitionNode>().toList();
101102
if (operationName != null) {
102103
definitions.removeWhere(
103104
(node) => node.name!.value != operationName,

‎packages/graphql/lib/src/core/mutation_options.dart‎

Lines changed: 14 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,8 @@ import 'package:graphql/src/core/result_parser.dart';
77

88
import 'package:meta/meta.dart';
99

10-
typedef OnMutationCompleted = FutureOr<void> Function(Map<String, dynamic>? data);
10+
typedef OnMutationCompleted = FutureOr<void> Function(
11+
Map<String, dynamic>? data);
1112
typedef OnMutationUpdate<TParsed> = FutureOr<void> Function(
1213
GraphQLDataProxy cache,
1314
QueryResult<TParsed>? result,
@@ -57,7 +58,8 @@ class MutationOptions<TParsed extends Object?> extends BaseOptions<TParsed> {
5758
onError,
5859
];
5960

60-
MutationOptions<TParsed> copyWithPolicies(Policies policies) => MutationOptions(
61+
MutationOptions<TParsed> copyWithPolicies(Policies policies) =>
62+
MutationOptions(
6163
document: document,
6264
operationName: operationName,
6365
variables: variables,
@@ -74,7 +76,8 @@ class MutationOptions<TParsed extends Object?> extends BaseOptions<TParsed> {
7476
cancellationToken: cancellationToken,
7577
);
7678

77-
WatchQueryOptions<TParsed> asWatchQueryOptions() => WatchQueryOptions<TParsed>(
79+
WatchQueryOptions<TParsed> asWatchQueryOptions() =>
80+
WatchQueryOptions<TParsed>(
7881
document: document,
7982
operationName: operationName,
8083
variables: variables,
@@ -103,8 +106,11 @@ class MutationCallbackHandler<TParsed> {
103106

104107
// callbacks will be called against each result in the stream,
105108
// which should then rebroadcast queries with the appropriate optimism
106-
Iterable<OnData<TParsed>> get callbacks =>
107-
<OnData<TParsed>?>[onCompleted, update, onError].whereType<OnData<TParsed>>();
109+
Iterable<OnData<TParsed>> get callbacks => <OnData<TParsed>?>[
110+
onCompleted,
111+
update,
112+
onError
113+
].whereType<OnData<TParsed>>();
108114

109115
// Todo: probably move this to its own class
110116
OnData<TParsed>? get onCompleted {
@@ -121,7 +127,9 @@ class MutationCallbackHandler<TParsed> {
121127
OnData<TParsed>? get onError {
122128
if (options.onError != null) {
123129
return (QueryResult? result) {
124-
if (!result!.isLoading && result.hasException && options.errorPolicy != ErrorPolicy.ignore) {
130+
if (!result!.isLoading &&
131+
result.hasException &&
132+
options.errorPolicy != ErrorPolicy.ignore) {
125133
return options.onError!(result.exception);
126134
}
127135
};

‎packages/graphql/lib/src/core/query_manager.dart‎

Lines changed: 28 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,8 @@ DeepEqualsFn gqlDeepEquals = const DeepCollectionEquality().equals;
3535
/// during asynchronous operations like rebroadcast checks.
3636
///
3737
/// Can be provided via the constructor for custom or isolate-based comparison logic.
38-
AsyncDeepEqualsFn gqlAsyncDeepEquals = (dynamic a, dynamic b) async => gqlDeepEquals(a, b);
38+
AsyncDeepEqualsFn gqlAsyncDeepEquals =
39+
(dynamic a, dynamic b) async => gqlDeepEquals(a, b);
3940

4041
class QueryManager {
4142
QueryManager({
@@ -73,12 +74,14 @@ class QueryManager {
7374
int idCounter = 1;
7475

7576
/// [ObservableQuery] registry
76-
Map<String, ObservableQuery<Object?>> queries = <String, ObservableQuery<Object?>>{};
77+
Map<String, ObservableQuery<Object?>> queries =
78+
<String, ObservableQuery<Object?>>{};
7779

7880
/// prevents rebroadcasting for some intensive bulk operation like [refetchSafeQueries]
7981
bool rebroadcastLocked = false;
8082

81-
ObservableQuery<TParsed> watchQuery<TParsed>(WatchQueryOptions<TParsed> options) {
83+
ObservableQuery<TParsed> watchQuery<TParsed>(
84+
WatchQueryOptions<TParsed> options) {
8285
final ObservableQuery<TParsed> observableQuery = ObservableQuery<TParsed>(
8386
queryManager: this,
8487
options: options,
@@ -89,7 +92,8 @@ class QueryManager {
8992
return observableQuery;
9093
}
9194

92-
Stream<QueryResult<TParsed>> subscribe<TParsed>(SubscriptionOptions<TParsed> options) async* {
95+
Stream<QueryResult<TParsed>> subscribe<TParsed>(
96+
SubscriptionOptions<TParsed> options) async* {
9397
assert(
9498
options.fetchPolicy != FetchPolicy.cacheOnly,
9599
"Cannot subscribe with FetchPolicy.cacheOnly: $options",
@@ -178,11 +182,13 @@ class QueryManager {
178182
}
179183
}
180184

181-
Future<QueryResult<TParsed>> query<TParsed>(QueryOptions<TParsed> options) async {
185+
Future<QueryResult<TParsed>> query<TParsed>(
186+
QueryOptions<TParsed> options) async {
182187
final results = await fetchQueryAsMultiSourceResult(_oneOffOpId, options);
183188
final eagerResult = results.eagerResult;
184189
final networkResult = results.networkResult;
185-
if (options.fetchPolicy != FetchPolicy.cacheAndNetwork || eagerResult.isLoading) {
190+
if (options.fetchPolicy != FetchPolicy.cacheAndNetwork ||
191+
eagerResult.isLoading) {
186192
final result = networkResult ?? eagerResult;
187193
await result;
188194
maybeRebroadcastQueriesAsync();
@@ -195,7 +201,8 @@ class QueryManager {
195201
return eagerResult;
196202
}
197203

198-
Future<QueryResult<TParsed>> mutate<TParsed>(MutationOptions<TParsed> options) async {
204+
Future<QueryResult<TParsed>> mutate<TParsed>(
205+
MutationOptions<TParsed> options) async {
199206
final result = await fetchQuery(_oneOffOpId, options);
200207
// once the mutation has been process successfully, execute callbacks
201208
// before returning the results
@@ -221,7 +228,8 @@ class QueryManager {
221228
String queryId,
222229
BaseOptions<TParsed> options,
223230
) async {
224-
final MultiSourceResult<TParsed> allResults = fetchQueryAsMultiSourceResult(queryId, options);
231+
final MultiSourceResult<TParsed> allResults =
232+
fetchQueryAsMultiSourceResult(queryId, options);
225233
return allResults.networkResult ?? allResults.eagerResult;
226234
}
227235

@@ -245,9 +253,10 @@ class QueryManager {
245253
return MultiSourceResult(
246254
options: options,
247255
eagerResult: eagerResult,
248-
networkResult: (shouldStopAtCache(options.fetchPolicy) && !eagerResult.isLoading)
249-
? null
250-
: _resolveQueryOnNetwork(request, queryId, options),
256+
networkResult:
257+
(shouldStopAtCache(options.fetchPolicy) && !eagerResult.isLoading)
258+
? null
259+
: _resolveQueryOnNetwork(request, queryId, options),
251260
);
252261
}
253262

@@ -395,7 +404,8 @@ class QueryManager {
395404

396405
// if we haven't already resolved results optimistically,
397406
// we attempt to resolve the from the cache
398-
if (shouldRespondEagerlyFromCache(options.fetchPolicy) && !queryResult.isOptimistic) {
407+
if (shouldRespondEagerlyFromCache(options.fetchPolicy) &&
408+
!queryResult.isOptimistic) {
399409
final latestResult = _getQueryResultByRequest<TParsed>(request);
400410
if (latestResult != null && latestResult.data != null) {
401411
// we have a result already cached + deserialized for this request
@@ -418,7 +428,8 @@ class QueryManager {
418428
}
419429
}
420430

421-
if (options.fetchPolicy == FetchPolicy.cacheOnly && queryResult.isLoading) {
431+
if (options.fetchPolicy == FetchPolicy.cacheOnly &&
432+
queryResult.isLoading) {
422433
queryResult = QueryResult(
423434
options: options,
424435
source: QueryResultSource.cache,
@@ -584,7 +595,8 @@ class QueryManager {
584595
final Map<Request, QueryResult<Object?>> diffQueryResultCache = {};
585596
final Map<Request, bool> ignoreQueryResults = {};
586597

587-
final List<ObservableQuery<Object?>> queriesSnapshot = List.of(queries.values);
598+
final List<ObservableQuery<Object?>> queriesSnapshot =
599+
List.of(queries.values);
588600

589601
for (final query in queriesSnapshot) {
590602
final Request request = query.options.asRequest;
@@ -649,7 +661,8 @@ class QueryManager {
649661
queries[observableQuery.queryId] = observableQuery;
650662
}
651663

652-
void closeQuery(ObservableQuery<Object?> observableQuery, {bool fromQuery = false}) {
664+
void closeQuery(ObservableQuery<Object?> observableQuery,
665+
{bool fromQuery = false}) {
653666
if (!fromQuery) {
654667
observableQuery.close(fromManager: true);
655668
}

‎packages/graphql/lib/src/core/query_options.dart‎

Lines changed: 23 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,8 @@ class QueryOptions<TParsed extends Object?> extends BaseOptions<TParsed> {
111111
},
112112
);
113113

114-
WatchQueryOptions<TParsed> asWatchQueryOptions({bool fetchResults = true}) => WatchQueryOptions(
114+
WatchQueryOptions<TParsed> asWatchQueryOptions({bool fetchResults = true}) =>
115+
WatchQueryOptions(
115116
document: document,
116117
operationName: operationName,
117118
variables: variables,
@@ -144,7 +145,8 @@ class QueryOptions<TParsed extends Object?> extends BaseOptions<TParsed> {
144145
}
145146

146147
@immutable
147-
class SubscriptionOptions<TParsed extends Object?> extends BaseOptions<TParsed> {
148+
class SubscriptionOptions<TParsed extends Object?>
149+
extends BaseOptions<TParsed> {
148150
SubscriptionOptions({
149151
required DocumentNode document,
150152
String? operationName,
@@ -170,7 +172,8 @@ class SubscriptionOptions<TParsed extends Object?> extends BaseOptions<TParsed>
170172
queryRequestTimeout: queryRequestTimeout,
171173
cancellationToken: cancellationToken,
172174
);
173-
SubscriptionOptions<TParsed> copyWithPolicies(Policies policies) => SubscriptionOptions(
175+
SubscriptionOptions<TParsed> copyWithPolicies(Policies policies) =>
176+
SubscriptionOptions(
174177
document: document,
175178
operationName: operationName,
176179
variables: variables,
@@ -271,7 +274,8 @@ class WatchQueryOptions<TParsed extends Object?> extends QueryOptions<TParsed> {
271274
pollInterval: pollInterval ?? this.pollInterval,
272275
fetchResults: fetchResults ?? this.fetchResults,
273276
eagerlyFetchResults: eagerlyFetchResults ?? this.eagerlyFetchResults,
274-
carryForwardDataOnException: carryForwardDataOnException ?? this.carryForwardDataOnException,
277+
carryForwardDataOnException:
278+
carryForwardDataOnException ?? this.carryForwardDataOnException,
275279
context: context ?? this.context,
276280
parserFn: parserFn ?? this.parserFn,
277281
queryRequestTimeout: queryRequestTimeout ?? this.queryRequestTimeout,
@@ -319,7 +323,8 @@ class WatchQueryOptions<TParsed extends Object?> extends QueryOptions<TParsed> {
319323
cancellationToken: cancellationToken,
320324
);
321325

322-
WatchQueryOptions<TParsed> copyWithPollInterval(Duration? pollInterval) => WatchQueryOptions<TParsed>(
326+
WatchQueryOptions<TParsed> copyWithPollInterval(Duration? pollInterval) =>
327+
WatchQueryOptions<TParsed>(
323328
document: document,
324329
operationName: operationName,
325330
variables: variables,
@@ -337,7 +342,9 @@ class WatchQueryOptions<TParsed extends Object?> extends QueryOptions<TParsed> {
337342
cancellationToken: cancellationToken,
338343
);
339344

340-
WatchQueryOptions<TParsed> copyWithVariables(Map<String, dynamic> variables) => WatchQueryOptions<TParsed>(
345+
WatchQueryOptions<TParsed> copyWithVariables(
346+
Map<String, dynamic> variables) =>
347+
WatchQueryOptions<TParsed>(
341348
document: document,
342349
operationName: operationName,
343350
variables: variables,
@@ -355,7 +362,9 @@ class WatchQueryOptions<TParsed extends Object?> extends QueryOptions<TParsed> {
355362
cancellationToken: cancellationToken,
356363
);
357364

358-
WatchQueryOptions<TParsed> copyWithOptimisticResult(Object? optimisticResult) => WatchQueryOptions<TParsed>(
365+
WatchQueryOptions<TParsed> copyWithOptimisticResult(
366+
Object? optimisticResult) =>
367+
WatchQueryOptions<TParsed>(
359368
document: document,
360369
operationName: operationName,
361370
variables: variables,
@@ -416,9 +425,10 @@ class FetchMoreOptions {
416425
final UpdateQuery updateQuery;
417426

418427
/// Wrap an [UpdateQuery] in a [deeplyMergeLeft] of the `previousResultData`.
419-
static UpdateQuery partialUpdater(UpdateQuery update) => (previous, fetched) => deeplyMergeLeft(
420-
[previous, update(previous, fetched)],
421-
);
428+
static UpdateQuery partialUpdater(UpdateQuery update) =>
429+
(previous, fetched) => deeplyMergeLeft(
430+
[previous, update(previous, fetched)],
431+
);
422432
}
423433

424434
/// merge fetchMore result data with earlier result data
@@ -429,7 +439,9 @@ typedef UpdateQuery = Map<String, dynamic>? Function(
429439

430440
extension WithType on Request {
431441
OperationType get type {
432-
final definitions = operation.document.definitions.whereType<OperationDefinitionNode>().toList();
442+
final definitions = operation.document.definitions
443+
.whereType<OperationDefinitionNode>()
444+
.toList();
433445
if (operation.operationName != null) {
434446
definitions.removeWhere(
435447
(node) => node.name!.value != operation.operationName,

‎packages/graphql/lib/src/exceptions/exceptions_next.dart‎

Lines changed: 16 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,8 @@ class CancelledException extends LinkException {
2424
/// to the cache with [expectedData]
2525
@immutable
2626
class CacheMissException extends LinkException {
27-
CacheMissException(this.message, this.request, {this.expectedData}) : super(null, null);
27+
CacheMissException(this.message, this.request, {this.expectedData})
28+
: super(null, null);
2829

2930
final String message;
3031
final Request request;
@@ -33,8 +34,11 @@ class CacheMissException extends LinkException {
3334
final Map<String, dynamic>? expectedData;
3435

3536
@override
36-
String toString() =>
37-
['CacheMissException($message', '$request', if (expectedData != null) 'expectedData: $expectedData)'].join(', ');
37+
String toString() => [
38+
'CacheMissException($message',
39+
'$request',
40+
if (expectedData != null) 'expectedData: $expectedData)'
41+
].join(', ');
3842
}
3943

4044
/// A failure due to a data structure mismatch between the data and the expected
@@ -73,7 +77,8 @@ class MismatchedDataStructureException extends LinkException {
7377
///
7478
/// This is checked by leveraging `normalize`
7579
@immutable
76-
class CacheMisconfigurationException extends LinkException implements MismatchedDataStructureException {
80+
class CacheMisconfigurationException extends LinkException
81+
implements MismatchedDataStructureException {
7782
const CacheMisconfigurationException(
7883
this.originalException,
7984
this.originalStackTrace, {
@@ -109,7 +114,8 @@ class CacheMisconfigurationException extends LinkException implements Mismatched
109114
///
110115
/// This is checked by leveraging `normalize`
111116
@immutable
112-
class UnexpectedResponseStructureException extends ServerException implements MismatchedDataStructureException {
117+
class UnexpectedResponseStructureException extends ServerException
118+
implements MismatchedDataStructureException {
113119
const UnexpectedResponseStructureException(
114120
this.originalException,
115121
this.originalStackTrace, {
@@ -154,7 +160,8 @@ class UnknownException extends LinkException {
154160
) : super(originalException, originalStackTrace);
155161

156162
@override
157-
String toString() => "UnknownException($originalException, stack:\n$originalStackTrace\n)";
163+
String toString() =>
164+
"UnknownException($originalException, stack:\n$originalStackTrace\n)";
158165
}
159166

160167
/// Container for both [graphqlErrors] returned from the server
@@ -198,7 +205,9 @@ OperationException? coalesceErrors({
198205
List<dynamic>? raw,
199206
OperationException? exception,
200207
}) {
201-
if (exception != null || linkException != null || (graphqlErrors != null && graphqlErrors.isNotEmpty)) {
208+
if (exception != null ||
209+
linkException != null ||
210+
(graphqlErrors != null && graphqlErrors.isNotEmpty)) {
202211
return OperationException(
203212
linkException: linkException ?? exception?.linkException,
204213
raw: raw,

0 commit comments

Comments
 (0)