Released 9.2.5

Author: Auties00

backend/index.js

@@ -35,7 +35,7 @@ express.use(require("./structure/matchmaking.js"));
 express.use(require("./structure/cloudstorage.js"));
 express.use(require("./structure/mcp.js"));
 
-const port = process.env.PORT || 3551;
+const port = 3551;
 express.listen(port, () => {
     console.log("LawinServer started listening on port", port);
 

common/lib/src/constant/game.dart

@@ -11,7 +11,7 @@ const List<String> kCorruptedBuildErrors = [
   "Critical error",
   "when 0 bytes remain",
   "Pak chunk signature verification failed!",
-  "Couldn't find pak signature file"
+  "LogWindows:Error: Fatal error!"
 ];
 const List<String> kCannotConnectErrors = [
   "port 3551 failed: Connection refused",

common/lib/src/extension/path.dart

@@ -9,9 +9,22 @@ extension FortniteVersionExtension on FortniteVersion {
 
   static File? findFile(Directory directory, String name) {
     try{
-      final result = directory.listSync(recursive: true)
-          .firstWhere((element) => path.basename(element.path) == name);
-      return File(result.path);
+      for(final child in directory.listSync()) {
+        if(child is Directory) {
+          if(!path.basename(child.path).startsWith("\.")) {
+            final result = findFile(child, name);
+            if(result != null) {
+              return result;
+            }
+          }
+        }else if(child is File) {
+          if(path.basename(child.path) == name) {
+            return child;
+          }
+        }
+      }
+
+      return null;
     }catch(_){
       return null;
     }

common/lib/src/util/backend.dart

@@ -15,13 +15,16 @@ final Semaphore _semaphore = Semaphore();
 String? _lastIp;
 String? _lastPort;
 
-Future<Process> startEmbeddedBackend(bool detached) async {
+Future<Process> startEmbeddedBackend(bool detached, {void Function(String)? onError}) async {
   final process = await startProcess(
     executable: backendStartExecutable,
     window: detached,
   );
   process.stdOutput.listen((message) => log("[BACKEND] Message: $message"));
-  process.stdError.listen((error) => log("[BACKEND] Error: $error"));
+  process.stdError.listen((error) {
+    log("[BACKEND] Error: $error");
+    onError?.call(error);
+  });
   process.exitCode.then((exitCode) => log("[BACKEND] Exit code: $exitCode"));
   return process;
 }

common/lib/src/util/process.dart

@@ -102,8 +102,7 @@ Future<bool> startElevatedProcess({required String executable, required String a
   shellInput.ref.fMask = ES_AWAYMODE_REQUIRED;
   shellInput.ref.lpVerb = "runas".toNativeUtf16();
   shellInput.ref.cbSize = sizeOf<SHELLEXECUTEINFO>();
-  var shellResult = ShellExecuteEx(shellInput);
-  return shellResult == 1;
+  return ShellExecuteEx(shellInput) == 1;
 }
 
 Future<Process> startProcess({required File executable, List<String>? args, bool useTempBatch = true, bool window = false, String? name, Map<String, String>? environment}) async {
@@ -313,7 +312,14 @@ final class _ExtendedProcess implements Process {
 
 
   @override
-  Future<int> get exitCode => _delegate.exitCode;
+  Future<int> get exitCode {
+    try {
+      return _delegate.exitCode;
+    }catch(_) {
+      return watchProcess(_delegate.pid)
+          .then((_) => -1);
+    }
+  }
 
   @override
   bool kill([ProcessSignal signal = ProcessSignal.sigterm]) => _delegate.kill(signal);

gui/assets/backend/lawinserver.exe

@@ -118,9 +118,7 @@
   "settingsUtilsResetDefaultsName": "Reset settings",
   "settingsUtilsResetDefaultsSubtitle": "Resets the launcher's settings to their default values",
   "settingsUtilsDialogTitle": "Do you want to reset all the setting in this tab to their default values? This action is irreversible",
-  "settingsUtilsResetDefaultsContent": "Reset",
   "settingsUtilsDialogSecondaryAction": "Close",
-  "settingsUtilsDialogPrimaryAction": "Reset",
   "selectFortniteName": "Fortnite version",
   "selectFortniteDescription": "Select the version of Fortnite you want to use",
   "manageVersionsName": "Manage versions",
@@ -262,6 +260,7 @@
   "missingCustomDllError": "The custom {dll}.dll doesn't exist: check your settings",
   "tokenError": "Cannot log in into Fortnite: authentication error (injected dlls: {dlls})",
   "unknownFortniteError": "An unknown error occurred while launching Fortnite: {error}",
+  "fortniteCrashError": "The {name} crashed after being launched",
   "serverNoLongerAvailableUnnamed": "The previous server is no longer available",
   "noServerFound": "No server found: invalid or expired link",
   "settingsUtilsThemeName": "Theme",
@@ -321,6 +320,7 @@
   "none": "none",
   "openLog": "Open log",
   "backendProcessError": "The backend shut down unexpectedly",
+  "backendErrorMessage": "The backend reported an unexpected error",
   "welcomeTitle": "Welcome to Reboot Launcher",
   "welcomeDescription": "If you have never used a Fortnite game server, or this launcher in particular, please click on take a tour\nPlease don't ask for support on Discord without taking the tour: this helps me prioritize real bugs\nYou can always take the tour again in the Info tab",
   "welcomeAction": "Take the tour",
@@ -364,5 +364,8 @@
   "promptSettingsTabActionLabel": "Done",
   "automaticGameServerDialogContent": "The launcher detected that you are not running a game server, but that your matchmaker is set to your local machine. If you don't want to join another player's server, you should start a game server. This is necessary to be able to play!",
   "automaticGameServerDialogIgnore": "Ignore",
-  "automaticGameServerDialogStart": "Start server"
+  "automaticGameServerDialogStart": "Start server",
+  "gameResetDefaultsName": "Reset",
+  "gameResetDefaultsDescription": "Resets the game's settings to their default values",
+  "gameResetDefaultsContent": "Reset"
 }

gui/lib/l10n/reboot_en.arb

@@ -12,6 +12,7 @@ import 'package:local_notifier/local_notifier.dart';
 import 'package:package_info_plus/package_info_plus.dart';
 import 'package:reboot_common/common.dart';
 import 'package:reboot_launcher/src/controller/backend_controller.dart';
+import 'package:reboot_launcher/src/controller/dll_controller.dart';
 import 'package:reboot_launcher/src/controller/game_controller.dart';
 import 'package:reboot_launcher/src/controller/hosting_controller.dart';
 import 'package:reboot_launcher/src/controller/settings_controller.dart';
@@ -188,10 +189,11 @@ void _initWindow() => doWhenWindowReady(() async {
 Future<List<Object>> _initStorage() async {
   final errors = <Object>[];
   try {
-    await GetStorage("game_storage", settingsDirectory.path).initStorage;
-    await GetStorage("backend_storage", settingsDirectory.path).initStorage;
-    await GetStorage("settings_storage", settingsDirectory.path).initStorage;
-    await GetStorage("hosting_storage", settingsDirectory.path).initStorage;
+    await GetStorage(GameController.storageName, settingsDirectory.path).initStorage;
+    await GetStorage(BackendController.storageName, settingsDirectory.path).initStorage;
+    await GetStorage(SettingsController.storageName, settingsDirectory.path).initStorage;
+    await GetStorage(HostingController.storageName, settingsDirectory.path).initStorage;
+    await GetStorage(DllController.storageName, settingsDirectory.path).initStorage;
   }catch(error) {
     appWithNoStorage = true;
     errors.add("The Reboot Launcher configuration in ${settingsDirectory.path} cannot be accessed: running with in memory storage");
@@ -223,6 +225,12 @@ Future<List<Object>> _initStorage() async {
     errors.add(error);
   }
 
+  try {
+    Get.put(DllController());
+  }catch(error) {
+    errors.add(error);
+  }
+
 
   return errors;
 }

gui/lib/main.dart

@@ -2,18 +2,24 @@ import 'dart:async';
 import 'dart:io';
 
 import 'package:fluent_ui/fluent_ui.dart';
+import 'package:flutter/services.dart';
 import 'package:get/get.dart';
 import 'package:get_storage/get_storage.dart';
 import 'package:reboot_common/common.dart';
 import 'package:reboot_launcher/main.dart';
+import 'package:reboot_launcher/src/util/keyboard.dart';
 
 class BackendController extends GetxController {
-  late final GetStorage? storage;
+  static const String storageName = "backend_storage";
+  static const PhysicalKeyboardKey _kDefaultConsoleKey = PhysicalKeyboardKey(0x00070041);
+
+  late final GetStorage? _storage;
   late final TextEditingController host;
   late final TextEditingController port;
   late final Rx<ServerType> type;
   late final TextEditingController gameServerAddress;
   late final FocusNode gameServerAddressFocusNode;
+  late final Rx<PhysicalKeyboardKey> consoleKey;
   late final RxBool started;
   late final RxBool detached;
   StreamSubscription? worker;
@@ -22,13 +28,13 @@ class BackendController extends GetxController {
   HttpServer? remoteServer;
 
   BackendController() {
-    storage = appWithNoStorage ? null : GetStorage("backend_storage");
+    _storage = appWithNoStorage ? null : GetStorage(storageName);
     started = RxBool(false);
-    type = Rx(ServerType.values.elementAt(storage?.read("type") ?? 0));
+    type = Rx(ServerType.values.elementAt(_storage?.read("type") ?? 0));
     type.listen((value) {
       host.text = _readHost();
       port.text = _readPort();
-      storage?.write("type", value.index);
+      _storage?.write("type", value.index);
       if (!started.value) {
         return;
       }
@@ -37,13 +43,13 @@ class BackendController extends GetxController {
     });
     host = TextEditingController(text: _readHost());
     host.addListener(() =>
-        storage?.write("${type.value.name}_host", host.text));
+        _storage?.write("${type.value.name}_host", host.text));
     port = TextEditingController(text: _readPort());
     port.addListener(() =>
-        storage?.write("${type.value.name}_port", port.text));
-    detached = RxBool(storage?.read("detached") ?? false);
-    detached.listen((value) => storage?.write("detached", value));
-    final address = storage?.read("game_server_address");
+        _storage?.write("${type.value.name}_port", port.text));
+    detached = RxBool(_storage?.read("detached") ?? false);
+    detached.listen((value) => _storage?.write("detached", value));
+    final address = _storage?.read("game_server_address");
     gameServerAddress = TextEditingController(text: address == null || address.isEmpty ? "127.0.0.1" : address);
     var lastValue = gameServerAddress.text;
     writeMatchmakingIp(lastValue);
@@ -55,7 +61,7 @@ class BackendController extends GetxController {
 
       lastValue = newValue;
       gameServerAddress.selection = TextSelection.collapsed(offset: newValue.length);
-      storage?.write("game_server_address", newValue);
+      _storage?.write("game_server_address", newValue);
       writeMatchmakingIp(newValue);
     });
     watchMatchmakingIp().listen((event) {
@@ -64,6 +70,37 @@ class BackendController extends GetxController {
       }
     });
     gameServerAddressFocusNode = FocusNode();
+    consoleKey = Rx(_readConsoleKey());
+    _writeConsoleKey(consoleKey.value);
+    consoleKey.listen((newValue) {
+      _storage?.write("console_key", newValue.usbHidUsage);
+      _writeConsoleKey(newValue);
+    });
+  }
+
+  PhysicalKeyboardKey _readConsoleKey() {
+    final consoleKeyValue = _storage?.read("console_key");
+    if(consoleKeyValue == null) {
+      return _kDefaultConsoleKey;
+    }
+
+    final consoleKeyNumber = int.tryParse(consoleKeyValue.toString());
+    if(consoleKeyNumber == null) {
+      return _kDefaultConsoleKey;
+    }
+
+    final consoleKey = PhysicalKeyboardKey(consoleKeyNumber);
+    if(!consoleKey.isUnrealEngineKey) {
+      return _kDefaultConsoleKey;
+    }
+
+    return consoleKey;
+  }
+
+  Future<void> _writeConsoleKey(PhysicalKeyboardKey keyValue) async {
+    final defaultInput = File("${backendDirectory.path}\\CloudStorage\\DefaultInput.ini");
+    await defaultInput.parent.create(recursive: true);
+    await defaultInput.writeAsString("[/Script/Engine.InputSettings]\n+ConsoleKeys=Tilde\n+ConsoleKeys=${keyValue.unrealEngineName}", flush: true);
   }
 
   void joinLocalhost() {
@@ -73,18 +110,19 @@ class BackendController extends GetxController {
   void reset() async {
     type.value = ServerType.values.elementAt(0);
     for (final type in ServerType.values) {
-      storage?.write("${type.name}_host", null);
-      storage?.write("${type.name}_port", null);
+      _storage?.write("${type.name}_host", null);
+      _storage?.write("${type.name}_port", null);
     }
 
     host.text = type.value != ServerType.remote ? kDefaultBackendHost : "";
     port.text = kDefaultBackendPort.toString();
     gameServerAddress.text = "127.0.0.1";
+    consoleKey.value = _kDefaultConsoleKey;
     detached.value = false;
   }
 
   String _readHost() {
-    String? value = storage?.read("${type.value.name}_host");
+    String? value = _storage?.read("${type.value.name}_host");
     if (value != null && value.isNotEmpty) {
       return value;
     }
@@ -97,9 +135,9 @@ class BackendController extends GetxController {
   }
 
   String _readPort() =>
-      storage?.read("${type.value.name}_port") ?? kDefaultBackendPort.toString();
+      _storage?.read("${type.value.name}_port") ?? kDefaultBackendPort.toString();
 
-  Stream<ServerResult> start() async* {
+  Stream<ServerResult> start({required void Function() onExit, required void Function(String) onError}) async* {
     try {
       if(started.value) {
         return;
@@ -144,7 +182,18 @@ class BackendController extends GetxController {
 
       switch(serverType){
         case ServerType.embedded:
-          final process = await startEmbeddedBackend(detached.value);
+          final process = await startEmbeddedBackend(detached.value, onError: (errorMessage) {
+            if(started.value) {
+              started.value = false;
+              onError(errorMessage);
+            }
+          });
+          watchProcess(process.pid).then((_) {
+            if(started.value) {
+              started.value = false;
+              onExit();
+            }
+          });
           embeddedProcessPid = process.pid;
           break;
         case ServerType.remote:
@@ -237,11 +286,14 @@ class BackendController extends GetxController {
     }
   }
 
-  Stream<ServerResult> toggle() async* {
+  Stream<ServerResult> toggle({required void Function() onExit, required void Function(String) onError}) async* {
     if(started()) {
       yield* stop();
     }else {
-      yield* start();
+      yield* start(
+        onExit: onExit,
+        onError: onError
+      );
     }
   }
 }