update

azkadev · Nov 8, 2022 · e3e388b · e3e388b
1 parent 1dbbde5
commit e3e388b
Show file tree

Hide file tree

Showing 16 changed files with 785 additions and 86 deletions.
diff --git a/packages/dart/galaxeus_lib/CHANGELOG.md b/packages/dart/galaxeus_lib/CHANGELOG.md
@@ -1,3 +1,13 @@
+## 0.0.21
+- fix tcp server and tcp client, now support auto reconnect
+
+## 0.0.22
+- fix score
+
+## 0.0.23
+- fix score
+
+
 ## 0.0.0
 
 - Initial version.
@@ -15,4 +25,5 @@
 - update
 
 ## 0.0.5
-- update
+- update
+
diff --git a/packages/dart/galaxeus_lib/lib/extension/list.dart b/packages/dart/galaxeus_lib/lib/extension/list.dart
@@ -1,3 +1,5 @@
+// ignore_for_file: non_constant_identifier_names
+
 part of galaxeus_lib;
 
 extension GalaxeusExtensionList on List {

diff --git a/packages/dart/galaxeus_lib/lib/extension/tcp.dart b/packages/dart/galaxeus_lib/lib/extension/tcp.dart
@@ -4,11 +4,21 @@ extension TcpSendDataSocket on Socket {
   void send(List<int> data) {
     return add(data);
   }
-  void sendString(String data) {
+
+  void sendString(
+    String data, {
+    bool isCompress = false,
+  }) {
+    if (isCompress) {
+      return add(gzip.encode(utf8.encode(data)));
+    }
     return add(utf8.encode(data));
   }
-  void sendJson(Map data) {
-    return add(utf8.encode(json.encode(data)));
-  }
 
+  void sendJson(
+    Map data, {
+    bool isCompress = false,
+  }) {
+    return sendString(json.encode(data), isCompress: isCompress);
+  }
 }
diff --git a/packages/dart/galaxeus_lib/lib/galaxeus_lib.dart b/packages/dart/galaxeus_lib/lib/galaxeus_lib.dart
@@ -9,7 +9,6 @@ import 'package:universal_io/io.dart';
 export 'package:http/http.dart';
 import 'package:collection/collection.dart';
 
-import "package:tcp_client_dart/tcp_client_dart.dart";
 part 'extension/list.dart';
 part 'extension/map.dart';
 part 'extension/string.dart';
@@ -20,6 +19,7 @@ part 'src/device_id.dart';
 part 'src/event_emitter.dart';
 part 'src/fetch.dart';
 part 'src/json_to_dart.dart';
+part "src/json_to_message.dart";
 part 'src/json_to_update.dart';
 part 'src/production.dart';
 part 'src/tcp_client.dart';
@@ -34,7 +34,8 @@ String getUuid(int length, {String? text}) {
     ch = text;
   }
   Random r = Random();
-  return String.fromCharCodes(Iterable.generate(length, (_) => ch.codeUnitAt(r.nextInt(ch.length))));
+  return String.fromCharCodes(
+      Iterable.generate(length, (_) => ch.codeUnitAt(r.nextInt(ch.length))));
 }
 
 T getRandomElement<T>(List<T> list) {

diff --git a/packages/dart/galaxeus_lib/lib/src/device_id.dart b/packages/dart/galaxeus_lib/lib/src/device_id.dart
@@ -2,20 +2,21 @@ part of galaxeus_lib;
 
 DeviceId? getDeviceId({bool isGetProductId = false}) {
   if (Platform.isAndroid) {
-    ProcessResult res = Process.runSync("settings", ["get", "secure", "android_id"]);
+    ProcessResult res =
+        Process.runSync("settings", ["get", "secure", "android_id"]);
     return DeviceId(res);
   }
 
   if (Platform.isWindows) {
     ProcessResult res = Process.runSync("wmic", ["os", "get", "serialnumber"]);
     return DeviceId(res);
   }
-  
+
   if (Platform.isLinux) {
     if (isGetProductId) {
       ProcessResult res = Process.runSync("dmidecode", ["-s", "system-uuid"]);
       return DeviceId(res);
-    } else { 
+    } else {
       ProcessResult res = Process.runSync("cat", ["/etc/machine-id"]);
       return DeviceId(res);
     }
@@ -40,7 +41,11 @@ class DeviceId {
 
   String get deviceId {
     if (Platform.isWindows) {
-      return RegExp(r"([a-z0-9]+)-([a-z0-9]+)-([a-z0-9]+)-([a-z0-9]+)", caseSensitive: false).stringMatch(data.stdout.toString().replaceAll(RegExp(r"\n"), "")) ?? "";
+      return RegExp(r"([a-z0-9]+)-([a-z0-9]+)-([a-z0-9]+)-([a-z0-9]+)",
+                  caseSensitive: false)
+              .stringMatch(
+                  data.stdout.toString().replaceAll(RegExp(r"\n"), "")) ??
+          "";
     }
     return data.stdout.toString().replaceAll(RegExp(r"\n"), "");
   }

diff --git a/packages/dart/galaxeus_lib/lib/src/fetch.dart b/packages/dart/galaxeus_lib/lib/src/fetch.dart
@@ -28,13 +28,17 @@ Future<Response> fetch(
   if (method == "get") {
     response = await get(Uri.parse(url), headers: headers);
   } else if (method == "post") {
-    response = await post(Uri.parse(url), body: body, headers: headers, encoding: encoding);
+    response = await post(Uri.parse(url),
+        body: body, headers: headers, encoding: encoding);
   } else if (method == "put") {
-    response = await put(Uri.parse(url), body: body, headers: headers, encoding: encoding);
+    response = await put(Uri.parse(url),
+        body: body, headers: headers, encoding: encoding);
   } else if (method == "patch") {
-    response = await patch(Uri.parse(url), body: body, headers: headers, encoding: encoding);
+    response = await patch(Uri.parse(url),
+        body: body, headers: headers, encoding: encoding);
   } else if (method == "delete") {
-    response = await delete(Uri.parse(url), body: body, headers: headers, encoding: encoding);
+    response = await delete(Uri.parse(url),
+        body: body, headers: headers, encoding: encoding);
   } else if (method == "head") {
     response = await head(Uri.parse(url), headers: headers);
   } else {
@@ -55,8 +59,6 @@ extension OnFetch on Response {
       print(e);
       return null;
     }
-
-    return null;
   }
 }