9.1.3

common/lib/src/extension/process.dart

@@ -2,7 +2,7 @@ import 'dart:convert';
 import 'dart:io';
 
 extension ProcessExtension on Process {
-  Stream<String> get stdOutput => this.stdout.expand((event) => utf8.decode(event).split("\n"));
+  Stream<String> get stdOutput => this.stdout.expand((event) => utf8.decode(event, allowMalformed: true).split("\n"));
 
-  Stream<String> get stdError => this.stderr.expand((event) => utf8.decode(event).split("\n"));
+  Stream<String> get stdError => this.stderr.expand((event) => utf8.decode(event, allowMalformed: true).split("\n"));
 }

common/lib/src/model/game_instance.dart

@@ -1,11 +1,14 @@
 import 'dart:io';
 
+import 'package:reboot_common/common.dart';
+
 
 class GameInstance {
   final String versionName;
   final int gamePid;
   final int? launcherPid;
   final int? eacPid;
+  final List<InjectableDll> injectedDlls;
   bool hosting;
   bool launched;
   bool movedToVirtualDesktop;
@@ -19,7 +22,7 @@ class GameInstance {
     required this.eacPid,
     required this.hosting,
     required this.child
-  }): tokenError = false, launched = false, movedToVirtualDesktop = false;
+  }): tokenError = false, launched = false, movedToVirtualDesktop = false, injectedDlls = [];
 
   void kill() {
     Process.killPid(gamePid, ProcessSignal.sigabrt);

common/lib/src/util/build.dart

@@ -145,9 +145,11 @@ Future<void> _extractArchive(Completer<dynamic> stopped, String extension, File
           '"${tempFile.path}"'
         ],
       );
+      var completed = false;
       process.stdOutput.listen((data) {
         final now = DateTime.now().millisecondsSinceEpoch;
         if(data.toLowerCase().contains("everything is ok")) {
+          completed = true;
           _onProgress(startTime, now, 100, true, options);
           process?.kill(ProcessSignal.sigabrt);
           return;
@@ -166,6 +168,11 @@ Future<void> _extractArchive(Completer<dynamic> stopped, String extension, File
           _onError(data, options);
         }
       });
+      process.exitCode.then((_) {
+        if(!completed) {
+          _onError("Corrupted zip archive", options);
+        }
+      });
       break;
     case ".rar":
       final winrar = File("${assetsDirectory.path}\\build\\winrar.exe");
@@ -183,10 +190,12 @@ Future<void> _extractArchive(Completer<dynamic> stopped, String extension, File
             '"${options.destination.path}"'
           ]
       );
+      var completed = false;
       process.stdOutput.listen((data) {
         final now = DateTime.now().millisecondsSinceEpoch;
         data = data.replaceAll("\r", "").replaceAll("\b", "").trim();
         if(data == "All OK") {
+          completed = true;
           _onProgress(startTime, now, 100, true, options);
           process?.kill(ProcessSignal.sigabrt);
           return;
@@ -205,6 +214,11 @@ Future<void> _extractArchive(Completer<dynamic> stopped, String extension, File
           _onError(data, options);
         }
       });
+      process.exitCode.then((_) {
+        if(!completed) {
+          _onError("Corrupted rar archive", options);
+        }
+      });
       break;
     default:
       throw ArgumentError("Unexpected file extension: $extension}");

common/lib/src/util/process.dart

@@ -238,6 +238,31 @@ List<String> createRebootArgs(String username, String password, bool host, bool
   return args;
 }
 
+void handleGameOutput({
+  required String line,
+  required bool host,
+  required void Function() onDisplayAttached,
+  required void Function() onLoggedIn,
+  required void Function() onMatchEnd,
+  required void Function() onShutdown,
+  required void Function() onTokenError,
+  required void Function() onBuildCorrupted,
+}) {
+  if (line.contains(kShutdownLine)) {
+    onShutdown();
+  }else if(kCorruptedBuildErrors.any((element) => line.contains(element))){
+    onBuildCorrupted();
+  }else if(kCannotConnectErrors.any((element) => line.contains(element))){
+    onTokenError();
+  }else if(kLoggedInLines.every((entry) => line.contains(entry))) {
+    onLoggedIn();
+  }else if(line.contains(kGameFinishedLine) && host) {
+    onMatchEnd();
+  }else if(line.contains(kDisplayInitializedLine) && host) {
+    onDisplayAttached();
+  }
+}
+
 String _parseUsername(String username, bool host) {
   if(host) {
     return "Player${Random().nextInt(1000)}";