Skip to content

Commit fd30205

Browse files
committed
style: improve code formatting and readability in Interceptor, WebsocketClient, WebsocketMessage, and WebsocketRequestedMessage classes
1 parent 9b7b064 commit fd30205

File tree

4 files changed

+33
-34
lines changed

4 files changed

+33
-34
lines changed

lib/src/infrastructure/services/wss/interceptor.dart

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,12 @@ import 'package:mineral/src/infrastructure/services/wss/websocket_message.dart';
44
import 'package:mineral/src/infrastructure/services/wss/websocket_requested_message.dart';
55

66
typedef MessageInterceptor = FutureOr<WebsocketMessage> Function(
7-
WebsocketMessage);
7+
WebsocketMessage,
8+
);
9+
810
typedef RequestInterceptor = FutureOr<WebsocketRequestedMessage> Function(
9-
WebsocketRequestedMessage);
11+
WebsocketRequestedMessage,
12+
);
1013

1114
abstract interface class Interceptor {
1215
List<MessageInterceptor> get message;

lib/src/infrastructure/services/wss/websocket_client.dart

Lines changed: 19 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -7,19 +7,12 @@ import 'package:mineral/src/infrastructure/services/wss/websocket_requested_mess
77

88
abstract interface class WebsocketClient {
99
String get name;
10-
1110
String get url;
12-
1311
Stream? get stream;
14-
1512
Interceptor get interceptor;
16-
1713
Future<void> connect();
18-
1914
void disconnect({int? code, String? reason});
20-
2115
Future<void> send(String message);
22-
2316
Future<void> listen(void Function(WebsocketMessage) callback);
2417
}
2518

@@ -43,13 +36,13 @@ final class WebsocketClientImpl implements WebsocketClient {
4336
@override
4437
Stream? stream;
4538

46-
WebsocketClientImpl(
47-
{required this.url,
48-
this.name = 'default',
49-
void Function(Object payload)? onError,
50-
void Function(int? exitCode)? onClose,
51-
void Function(WebsocketMessage)? onOpen})
52-
: _onError = onError,
39+
WebsocketClientImpl({
40+
required this.url,
41+
this.name = 'default',
42+
void Function(Object payload)? onError,
43+
void Function(int? exitCode)? onClose,
44+
void Function(WebsocketMessage)? onOpen,
45+
}) : _onError = onError,
5346
_onClose = onClose,
5447
_onOpen = onOpen;
5548

@@ -103,18 +96,21 @@ final class WebsocketClientImpl implements WebsocketClient {
10396

10497
Future<void> _handleMessage(callback, dynamic message) async {
10598
final interceptedMessage = await _handleMessageInterceptors(
106-
WebsocketMessageImpl(
107-
channelName: name,
108-
originalContent: message,
109-
content: message));
99+
WebsocketMessageImpl(
100+
channelName: name,
101+
originalContent: message,
102+
content: message,
103+
),
104+
);
110105

111106
callback(interceptedMessage);
112107
}
113108

114109
@override
115110
Future<void> send(String message) async {
116111
final interceptedMessage = await _handleRequestedMessageInterceptors(
117-
WebsocketRequestedMessageImpl(channelName: name, content: message));
112+
WebsocketRequestedMessageImpl(channelName: name, content: message),
113+
);
118114

119115
switch (_channel?.readyState) {
120116
case io.WebSocket.open:
@@ -125,7 +121,8 @@ final class WebsocketClientImpl implements WebsocketClient {
125121
}
126122

127123
Future<WebsocketMessage> _handleMessageInterceptors(
128-
WebsocketMessage message) async {
124+
WebsocketMessage message,
125+
) async {
129126
for (final interceptor in interceptor.message) {
130127
message = await interceptor(message);
131128
}
@@ -134,7 +131,8 @@ final class WebsocketClientImpl implements WebsocketClient {
134131
}
135132

136133
Future<WebsocketRequestedMessage> _handleRequestedMessageInterceptors(
137-
WebsocketRequestedMessage message) async {
134+
WebsocketRequestedMessage message,
135+
) async {
138136
for (final interceptor in interceptor.request) {
139137
message = await interceptor(message);
140138
}

lib/src/infrastructure/services/wss/websocket_message.dart

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,7 @@
11
abstract interface class WebsocketMessage<T> {
22
String get channelName;
3-
43
DateTime get createdAt;
5-
64
dynamic get originalContent;
7-
85
abstract T content;
96
}
107

@@ -21,8 +18,9 @@ final class WebsocketMessageImpl<T> implements WebsocketMessage<T> {
2118
@override
2219
T content;
2320

24-
WebsocketMessageImpl(
25-
{required this.channelName,
26-
required this.originalContent,
27-
required this.content});
21+
WebsocketMessageImpl({
22+
required this.channelName,
23+
required this.originalContent,
24+
required this.content,
25+
});
2826
}

lib/src/infrastructure/services/wss/websocket_requested_message.dart

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,6 @@
11
abstract interface class WebsocketRequestedMessage {
22
DateTime get createdAt;
3-
43
String get channelName;
5-
64
dynamic content;
75
}
86

@@ -16,6 +14,8 @@ final class WebsocketRequestedMessageImpl implements WebsocketRequestedMessage {
1614
@override
1715
dynamic content;
1816

19-
WebsocketRequestedMessageImpl(
20-
{required this.channelName, required this.content});
17+
WebsocketRequestedMessageImpl({
18+
required this.channelName,
19+
required this.content,
20+
});
2121
}

0 commit comments

Comments
 (0)