tilera/nyxx
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Shared zlib context for connection

Browse source 
[ci skip]
This commit is contained in:
Szymon Uglis 2020-06-18 01:16:51 +02:00
parent 4517e91254
commit fca76754f0
2 changed files with 21 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
nyxx/lib/src/internal/_Constants.dart
View file

@ -34,6 +34,7 @@ class Constants {
/// Url to Nyxx repo
static const String repoUrl = "https://github.com/l7ssha/nyxx";
// TODO: invesitgate &compress=zlib-stream
/// Returns [Uri] to gateway
static Uri gatewayUri(String gatewayHost) => Uri.parse("$gatewayHost?v=6&encoding=json");
}

24
nyxx/lib/src/internal/shard/shardHandler.dart
View file

@ -1,12 +1,11 @@
part of nyxx;
// Decodes zlib compresses string into string json
Map<String, dynamic> _decodeBytes(dynamic rawPayload) {
Map<String, dynamic> _decodeBytes(dynamic rawPayload, ZLibDecoder decoder) {
if (rawPayload is String) {
return jsonDecode(rawPayload) as Map<String, dynamic>;
}
final decoded = zlib.decoder.convert(rawPayload as List<int>);
final decoded = decoder.convert(rawPayload as List<int>);
final rawStr = utf8.decode(decoded);
return jsonDecode(rawStr) as Map<String, dynamic>;
}
@ -40,13 +39,30 @@ Future<void> _shardHandler(SendPort shardPort) async {
transport_vm.configureWTransportForVM();
// TODO: ???
/*
ProcessSignal.sigterm.watch().listen((event) async {
await _socketSubscription?.cancel();
await _socket?.close(1000);
print("CLOSED");
});
ProcessSignal.sigint.watch().listen((event) async {
await _socketSubscription?.cancel();
await _socket?.close(1000);
print("CLOSED");
});
*/
// Attempts to connect to ws
Future<void> _connect() async {
await transport.WebSocket.connect(gatewayUri).then((ws) {
final zlibDecoder = ZLibDecoder(); // Create zlib decoder specific to this connection. New connection should get new zlib context
shardPort.send({ "cmd" : "CONNECT_ACK" });
_socket = ws;
_socketSubscription = _socket!.listen((data) {
shardPort.send({ "cmd" : "DATA", "jsonData" : _decodeBytes(data) });
shardPort.send({ "cmd" : "DATA", "jsonData" : _decodeBytes(data, zlibDecoder) });
}, onDone: () async {
shardPort.send({ "cmd" : "DISCONNECTED", "errorCode" : _socket!.closeCode, "errorReason" : _socket!.closeReason });
}, cancelOnError: true, onError: (err) => shardPort.send({ "cmd" : "ERROR", "error": err.toString(), "errorCode" : _socket!.closeCode, "errorReason" : _socket!.closeReason }));