mirror of
https://github.com/JustArchiNET/ArchiSteamFarm.git
synced 2025-12-23 17:56:49 +00:00
1b626caa53
* Initial .NET 9 bump * Resolve selected .NET 9 analyzer warnings * Fill TODO * Fix build errors * Misc * Use new methods * .NET 9 changes * Dockerfiles no longer preview * Misc * Trimming works again * Trimming works in docker too * Test fix * Update Directory.Build.props
718 lines
22 KiB
C#
718 lines
22 KiB
C#
// ----------------------------------------------------------------------------------------------
|
|
// _ _ _ ____ _ _____
|
|
// / \ _ __ ___ | |__ (_)/ ___| | |_ ___ __ _ _ __ ___ | ___|__ _ _ __ _ __ ___
|
|
// / _ \ | '__|/ __|| '_ \ | |\___ \ | __|/ _ \ / _` || '_ ` _ \ | |_ / _` || '__|| '_ ` _ \
|
|
// / ___ \ | | | (__ | | | || | ___) || |_| __/| (_| || | | | | || _|| (_| || | | | | | | |
|
|
// /_/ \_\|_| \___||_| |_||_||____/ \__|\___| \__,_||_| |_| |_||_| \__,_||_| |_| |_| |_|
|
|
// ----------------------------------------------------------------------------------------------
|
|
// |
|
|
// Copyright 2015-2024 Łukasz "JustArchi" Domeradzki
|
|
// Contact: JustArchi@JustArchi.net
|
|
// |
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
// |
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
// |
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
using System;
|
|
using System.Collections.Frozen;
|
|
using System.Collections.Generic;
|
|
using System.Diagnostics;
|
|
using System.Globalization;
|
|
using System.IO;
|
|
using System.Linq;
|
|
using System.Net.Http;
|
|
using System.Net.Quic;
|
|
using System.Reflection;
|
|
using System.Runtime.InteropServices;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
using ArchiSteamFarm.Core;
|
|
using ArchiSteamFarm.Helpers;
|
|
using ArchiSteamFarm.Helpers.Json;
|
|
using ArchiSteamFarm.IPC;
|
|
using ArchiSteamFarm.Localization;
|
|
using ArchiSteamFarm.NLog;
|
|
using ArchiSteamFarm.NLog.Targets;
|
|
using ArchiSteamFarm.Steam;
|
|
using ArchiSteamFarm.Storage;
|
|
using ArchiSteamFarm.Web;
|
|
using NLog;
|
|
using SteamKit2;
|
|
|
|
namespace ArchiSteamFarm;
|
|
|
|
internal static class Program {
|
|
internal static bool AllowCrashFileRemoval { get; set; }
|
|
internal static bool ConfigMigrate { get; private set; } = true;
|
|
internal static bool ConfigWatch { get; private set; } = true;
|
|
internal static bool IgnoreUnsupportedEnvironment { get; private set; }
|
|
internal static string? NetworkGroup { get; private set; }
|
|
internal static bool RestartAllowed { get; private set; } = true;
|
|
internal static bool Service { get; private set; }
|
|
internal static bool ShutdownSequenceInitialized { get; private set; }
|
|
internal static bool SteamParentalGeneration { get; private set; } = true;
|
|
|
|
private static readonly Dictionary<PosixSignal, PosixSignalRegistration> RegisteredPosixSignals = new();
|
|
private static readonly TaskCompletionSource<byte> ShutdownResetEvent = new();
|
|
private static readonly FrozenSet<PosixSignal> SupportedPosixSignals = new HashSet<PosixSignal>(2) { PosixSignal.SIGINT, PosixSignal.SIGTERM }.ToFrozenSet();
|
|
|
|
private static bool InputCryptkeyManually;
|
|
private static bool Minimized;
|
|
private static bool SystemRequired;
|
|
|
|
internal static async Task Exit(byte exitCode = 0) {
|
|
if (exitCode != 0) {
|
|
ASF.ArchiLogger.LogGenericError(Strings.FormatErrorExitingWithNonZeroErrorCode(exitCode));
|
|
}
|
|
|
|
await Shutdown(exitCode).ConfigureAwait(false);
|
|
Environment.Exit(exitCode);
|
|
}
|
|
|
|
internal static async Task Restart() {
|
|
if (!await InitShutdownSequence().ConfigureAwait(false)) {
|
|
return;
|
|
}
|
|
|
|
string executableName = Path.GetFileNameWithoutExtension(OS.ProcessFileName);
|
|
|
|
ArgumentException.ThrowIfNullOrEmpty(executableName);
|
|
|
|
IEnumerable<string> arguments = Environment.GetCommandLineArgs().Skip(executableName.Equals(SharedInfo.AssemblyName, StringComparison.Ordinal) ? 1 : 0);
|
|
|
|
try {
|
|
Process.Start(OS.ProcessFileName, string.Join(' ', arguments));
|
|
} catch (Exception e) {
|
|
ASF.ArchiLogger.LogGenericException(e);
|
|
}
|
|
|
|
// Give new process some time to take over the window (if needed)
|
|
await Task.Delay(5000).ConfigureAwait(false);
|
|
|
|
ShutdownResetEvent.TrySetResult(0);
|
|
Environment.Exit(0);
|
|
}
|
|
|
|
private static void HandleCryptKeyArgument(string cryptKey) {
|
|
ArgumentException.ThrowIfNullOrEmpty(cryptKey);
|
|
|
|
ArchiCryptoHelper.SetEncryptionKey(cryptKey);
|
|
}
|
|
|
|
private static async Task<bool> HandleCryptKeyFileArgument(string cryptKeyFile) {
|
|
ArgumentException.ThrowIfNullOrEmpty(cryptKeyFile);
|
|
|
|
if (!File.Exists(cryptKeyFile)) {
|
|
ASF.ArchiLogger.LogGenericError(Strings.FormatErrorIsInvalid(nameof(cryptKeyFile)));
|
|
|
|
return false;
|
|
}
|
|
|
|
string cryptKey;
|
|
|
|
try {
|
|
cryptKey = await File.ReadAllTextAsync(cryptKeyFile).ConfigureAwait(false);
|
|
} catch (Exception e) {
|
|
ASF.ArchiLogger.LogGenericException(e);
|
|
|
|
return false;
|
|
}
|
|
|
|
if (string.IsNullOrEmpty(cryptKey)) {
|
|
ASF.ArchiLogger.LogGenericError(Strings.FormatErrorIsEmpty(nameof(cryptKeyFile)));
|
|
|
|
return false;
|
|
}
|
|
|
|
HandleCryptKeyArgument(cryptKey);
|
|
|
|
return true;
|
|
}
|
|
|
|
private static void HandleNetworkGroupArgument(string networkGroup) {
|
|
ArgumentException.ThrowIfNullOrEmpty(networkGroup);
|
|
|
|
NetworkGroup = networkGroup;
|
|
}
|
|
|
|
private static bool HandlePathArgument(string path) {
|
|
ArgumentException.ThrowIfNullOrEmpty(path);
|
|
|
|
// Aid userspace and replace ~ with user's home directory if possible
|
|
if (path.Contains('~', StringComparison.Ordinal)) {
|
|
try {
|
|
string homeDirectory = Environment.GetFolderPath(Environment.SpecialFolder.UserProfile, Environment.SpecialFolderOption.DoNotVerify);
|
|
|
|
if (!string.IsNullOrEmpty(homeDirectory)) {
|
|
path = path.Replace("~", homeDirectory, StringComparison.Ordinal);
|
|
}
|
|
} catch (Exception e) {
|
|
ASF.ArchiLogger.LogGenericException(e);
|
|
|
|
return false;
|
|
}
|
|
}
|
|
|
|
try {
|
|
Directory.SetCurrentDirectory(path);
|
|
} catch (Exception e) {
|
|
ASF.ArchiLogger.LogGenericException(e);
|
|
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
private static async Task Init(IReadOnlyCollection<string>? args) {
|
|
AppDomain.CurrentDomain.ProcessExit += OnProcessExit;
|
|
AppDomain.CurrentDomain.UnhandledException += OnUnhandledException;
|
|
TaskScheduler.UnobservedTaskException += OnUnobservedTaskException;
|
|
|
|
if (OperatingSystem.IsFreeBSD() || OperatingSystem.IsLinux() || OperatingSystem.IsMacOS()) {
|
|
foreach (PosixSignal signal in SupportedPosixSignals) {
|
|
RegisteredPosixSignals[signal] = PosixSignalRegistration.Create(signal, OnPosixSignal);
|
|
}
|
|
}
|
|
|
|
Console.CancelKeyPress += OnCancelKeyPress;
|
|
|
|
// Add support for custom encodings
|
|
Encoding.RegisterProvider(CodePagesEncodingProvider.Instance);
|
|
|
|
// Add support for custom logging targets
|
|
LogManager.Setup().SetupExtensions(
|
|
static extensions => {
|
|
extensions.RegisterTarget<HistoryTarget>(HistoryTarget.TargetName);
|
|
extensions.RegisterTarget<SteamTarget>(SteamTarget.TargetName);
|
|
}
|
|
);
|
|
|
|
if (!await InitCore(args).ConfigureAwait(false) || !await InitASF().ConfigureAwait(false)) {
|
|
await Exit(1).ConfigureAwait(false);
|
|
}
|
|
}
|
|
|
|
private static async Task<bool> InitASF() {
|
|
if (!await InitGlobalConfigAndLanguage().ConfigureAwait(false)) {
|
|
return false;
|
|
}
|
|
|
|
OS.Init(ASF.GlobalConfig?.OptimizationMode ?? GlobalConfig.DefaultOptimizationMode);
|
|
|
|
return await InitGlobalDatabaseAndServices().ConfigureAwait(false) && await ASF.Init().ConfigureAwait(false);
|
|
}
|
|
|
|
private static async Task<bool> InitCore(IReadOnlyCollection<string>? args) {
|
|
// Init emergency loggers used for failures before setting up ones according to preference of the user
|
|
Logging.InitEmergencyLoggers();
|
|
|
|
Directory.SetCurrentDirectory(SharedInfo.HomeDirectory);
|
|
|
|
// Allow loading configs from source tree if it's a debug build
|
|
if (Debugging.IsDebugBuild) {
|
|
// Common structure is bin/(x64/)Debug/ArchiSteamFarm.exe, so we allow up to 4 directories up
|
|
for (byte i = 0; i < 4; i++) {
|
|
Directory.SetCurrentDirectory("..");
|
|
|
|
if (Directory.Exists(SharedInfo.ConfigDirectory)) {
|
|
break;
|
|
}
|
|
}
|
|
|
|
// If config directory doesn't exist after our adjustment, abort all of that
|
|
if (!Directory.Exists(SharedInfo.ConfigDirectory)) {
|
|
Directory.SetCurrentDirectory(SharedInfo.HomeDirectory);
|
|
}
|
|
}
|
|
|
|
// Parse environment variables
|
|
if (!await ParseEnvironmentVariables().ConfigureAwait(false)) {
|
|
await Task.Delay(SharedInfo.InformationDelay).ConfigureAwait(false);
|
|
|
|
return false;
|
|
}
|
|
|
|
// Parse ASF_ARGS
|
|
try {
|
|
string[]? asfArgs = Environment.GetEnvironmentVariable(SharedInfo.EnvironmentVariableArguments)?.Split(Array.Empty<char>(), StringSplitOptions.RemoveEmptyEntries);
|
|
|
|
if (asfArgs?.Length > 0) {
|
|
if (!await ParseArgs(asfArgs).ConfigureAwait(false)) {
|
|
await Task.Delay(SharedInfo.InformationDelay).ConfigureAwait(false);
|
|
|
|
return false;
|
|
}
|
|
}
|
|
} catch (Exception e) {
|
|
ASF.ArchiLogger.LogGenericException(e);
|
|
|
|
await Task.Delay(SharedInfo.InformationDelay).ConfigureAwait(false);
|
|
|
|
return false;
|
|
}
|
|
|
|
// Parse cmdline args
|
|
if (args?.Count > 0) {
|
|
if (!await ParseArgs(args).ConfigureAwait(false)) {
|
|
await Task.Delay(SharedInfo.InformationDelay).ConfigureAwait(false);
|
|
|
|
return false;
|
|
}
|
|
}
|
|
|
|
bool uniqueInstance = await OS.RegisterProcess().ConfigureAwait(false);
|
|
|
|
// Init core loggers according to user's preferences
|
|
Logging.InitCoreLoggers(uniqueInstance);
|
|
|
|
if (!uniqueInstance) {
|
|
ASF.ArchiLogger.LogGenericError(Strings.ErrorSingleInstanceRequired);
|
|
await Task.Delay(SharedInfo.InformationDelay).ConfigureAwait(false);
|
|
|
|
return false;
|
|
}
|
|
|
|
OS.CoreInit(Minimized, SystemRequired);
|
|
|
|
Console.Title = SharedInfo.ProgramIdentifier;
|
|
ASF.ArchiLogger.LogGenericInfo(SharedInfo.ProgramIdentifier);
|
|
|
|
string? copyright = Assembly.GetExecutingAssembly().GetCustomAttribute<AssemblyCopyrightAttribute>()?.Copyright;
|
|
|
|
if (!string.IsNullOrEmpty(copyright)) {
|
|
ASF.ArchiLogger.LogGenericInfo(copyright);
|
|
}
|
|
|
|
if (IgnoreUnsupportedEnvironment) {
|
|
ASF.ArchiLogger.LogGenericWarning(Strings.WarningRunningInUnsupportedEnvironment);
|
|
} else {
|
|
if (!OS.VerifyEnvironment()) {
|
|
ASF.ArchiLogger.LogGenericError(Strings.FormatWarningUnsupportedEnvironment(BuildInfo.Variant, OS.Version));
|
|
await Task.Delay(SharedInfo.InformationDelay).ConfigureAwait(false);
|
|
|
|
return false;
|
|
}
|
|
|
|
if (OS.IsRunningAsRoot()) {
|
|
ASF.ArchiLogger.LogGenericWarning(Strings.WarningRunningAsRoot);
|
|
await Task.Delay(SharedInfo.ShortInformationDelay).ConfigureAwait(false);
|
|
}
|
|
}
|
|
|
|
if (InputCryptkeyManually) {
|
|
string? cryptkey = await Logging.GetUserInput(ASF.EUserInputType.Cryptkey).ConfigureAwait(false);
|
|
|
|
if (string.IsNullOrEmpty(cryptkey)) {
|
|
ASF.ArchiLogger.LogGenericError(Strings.FormatErrorIsInvalid(nameof(cryptkey)));
|
|
|
|
return false;
|
|
}
|
|
|
|
ArchiCryptoHelper.SetEncryptionKey(cryptkey);
|
|
}
|
|
|
|
if (!Directory.Exists(SharedInfo.ConfigDirectory)) {
|
|
ASF.ArchiLogger.LogGenericError(Strings.ErrorConfigDirectoryNotFound);
|
|
await Task.Delay(SharedInfo.InformationDelay).ConfigureAwait(false);
|
|
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
private static async Task<bool> InitGlobalConfigAndLanguage() {
|
|
string globalConfigFile = ASF.GetFilePath(ASF.EFileType.Config);
|
|
|
|
if (string.IsNullOrEmpty(globalConfigFile)) {
|
|
throw new InvalidOperationException(nameof(globalConfigFile));
|
|
}
|
|
|
|
string? latestJson = null;
|
|
|
|
GlobalConfig? globalConfig;
|
|
|
|
if (File.Exists(globalConfigFile)) {
|
|
(globalConfig, latestJson) = await GlobalConfig.Load(globalConfigFile).ConfigureAwait(false);
|
|
|
|
if (globalConfig == null) {
|
|
ASF.ArchiLogger.LogGenericError(Strings.FormatErrorGlobalConfigNotLoaded(globalConfigFile));
|
|
await Task.Delay(SharedInfo.ShortInformationDelay).ConfigureAwait(false);
|
|
|
|
return false;
|
|
}
|
|
} else {
|
|
globalConfig = new GlobalConfig();
|
|
}
|
|
|
|
if (globalConfig.Debug) {
|
|
ASF.ArchiLogger.LogGenericDebug($"{globalConfigFile}: {globalConfig.ToJsonText(true)}");
|
|
}
|
|
|
|
if (!string.IsNullOrEmpty(globalConfig.CurrentCulture)) {
|
|
try {
|
|
// GetCultureInfo() would be better but we can't use it for specifying neutral cultures such as "en"
|
|
CultureInfo culture = CultureInfo.CreateSpecificCulture(globalConfig.CurrentCulture);
|
|
CultureInfo.DefaultThreadCurrentCulture = CultureInfo.DefaultThreadCurrentUICulture = culture;
|
|
} catch (Exception e) {
|
|
ASF.ArchiLogger.LogGenericWarningException(e);
|
|
|
|
ASF.ArchiLogger.LogGenericError(Strings.ErrorInvalidCurrentCulture);
|
|
}
|
|
} else {
|
|
// April Fools easter egg logic
|
|
AprilFools.Init();
|
|
}
|
|
|
|
if (!string.IsNullOrEmpty(latestJson)) {
|
|
ASF.ArchiLogger.LogGenericWarning(Strings.FormatAutomaticFileMigration(globalConfigFile));
|
|
|
|
await SerializableFile.Write(globalConfigFile, latestJson).ConfigureAwait(false);
|
|
|
|
ASF.ArchiLogger.LogGenericInfo(Strings.Done);
|
|
}
|
|
|
|
ASF.GlobalConfig = globalConfig;
|
|
|
|
Utilities.WarnAboutIncompleteTranslation(Strings.ResourceManager);
|
|
|
|
return true;
|
|
}
|
|
|
|
private static async Task<bool> InitGlobalDatabaseAndServices() {
|
|
string globalDatabaseFile = ASF.GetFilePath(ASF.EFileType.Database);
|
|
|
|
if (string.IsNullOrEmpty(globalDatabaseFile)) {
|
|
throw new InvalidOperationException(nameof(globalDatabaseFile));
|
|
}
|
|
|
|
if (!File.Exists(globalDatabaseFile)) {
|
|
ASF.ArchiLogger.LogGenericInfo(Strings.Welcome);
|
|
await Task.Delay(SharedInfo.InformationDelay).ConfigureAwait(false);
|
|
ASF.ArchiLogger.LogGenericWarning(Strings.WarningPrivacyPolicy);
|
|
await Task.Delay(SharedInfo.ShortInformationDelay).ConfigureAwait(false);
|
|
}
|
|
|
|
GlobalDatabase? globalDatabase = await GlobalDatabase.CreateOrLoad(globalDatabaseFile).ConfigureAwait(false);
|
|
|
|
if (globalDatabase == null) {
|
|
ASF.ArchiLogger.LogGenericError(Strings.FormatErrorDatabaseInvalid(globalDatabaseFile));
|
|
await Task.Delay(SharedInfo.ShortInformationDelay).ConfigureAwait(false);
|
|
|
|
return false;
|
|
}
|
|
|
|
ASF.GlobalDatabase = globalDatabase;
|
|
|
|
// If debugging is on, we prepare debug directory prior to running
|
|
if (Debugging.IsUserDebugging) {
|
|
Logging.EnableTraceLogging();
|
|
|
|
if (Debugging.IsDebugConfigured) {
|
|
ASF.ArchiLogger.LogGenericDebug($"{globalDatabaseFile}: {globalDatabase.ToJsonText(true)}");
|
|
|
|
DebugLog.AddListener(new Debugging.DebugListener());
|
|
|
|
DebugLog.Enabled = true;
|
|
|
|
try {
|
|
Directory.CreateDirectory(ASF.DebugDirectory);
|
|
} catch (Exception e) {
|
|
ASF.ArchiLogger.LogGenericException(e);
|
|
}
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
private static async Task<bool> InitShutdownSequence(byte exitCode = 0) {
|
|
if (ShutdownSequenceInitialized) {
|
|
// We've already initialized shutdown sequence before, we won't allow the caller to init shutdown sequence again
|
|
// While normally this will be respected, caller might not have any say in this for example because it's the runtime terminating ASF due to fatal exception
|
|
// Because of that, the least we can still do, is to ensure that exception is written to any logs on our "best effort" basis
|
|
LogManager.Flush();
|
|
|
|
return false;
|
|
}
|
|
|
|
ShutdownSequenceInitialized = true;
|
|
|
|
// Unregister from registered signals
|
|
if (OperatingSystem.IsFreeBSD() || OperatingSystem.IsLinux() || OperatingSystem.IsMacOS()) {
|
|
foreach (PosixSignalRegistration registration in RegisteredPosixSignals.Values) {
|
|
registration.Dispose();
|
|
}
|
|
|
|
RegisteredPosixSignals.Clear();
|
|
}
|
|
|
|
// Remove crash file if allowed
|
|
if ((exitCode == 0) && AllowCrashFileRemoval) {
|
|
string crashFile = ASF.GetFilePath(ASF.EFileType.Crash);
|
|
|
|
if (File.Exists(crashFile)) {
|
|
try {
|
|
File.Delete(crashFile);
|
|
} catch (Exception e) {
|
|
ASF.ArchiLogger.LogGenericException(e);
|
|
}
|
|
}
|
|
}
|
|
|
|
// Sockets created by IPC might still be running for a short while after complete app shutdown
|
|
// Ensure that IPC is stopped before we finalize shutdown sequence
|
|
await ArchiKestrel.Stop().ConfigureAwait(false);
|
|
|
|
// Stop all the active bots so they can disconnect cleanly
|
|
if (Bot.Bots?.Count > 0) {
|
|
// Stop() function can block due to SK2 sockets, don't forget a maximum delay
|
|
await Task.WhenAny(Utilities.InParallel(Bot.Bots.Values.Select(static bot => Task.Run(() => bot.Stop(true)))), Task.Delay((Bot.Bots.Count + WebBrowser.MaxTries) * 1000)).ConfigureAwait(false);
|
|
|
|
// Extra second for Steam requests to go through
|
|
await Task.Delay(1000).ConfigureAwait(false);
|
|
}
|
|
|
|
// Flush all the pending writes to log files
|
|
LogManager.Flush();
|
|
|
|
// Unregister the process from single instancing
|
|
OS.UnregisterProcess();
|
|
|
|
return true;
|
|
}
|
|
|
|
private static async Task<int> Main(string[] args) {
|
|
ArgumentNullException.ThrowIfNull(args);
|
|
|
|
// Initialize
|
|
await Init(args.Length > 0 ? args : null).ConfigureAwait(false);
|
|
|
|
// Wait for shutdown event
|
|
return await ShutdownResetEvent.Task.ConfigureAwait(false);
|
|
}
|
|
|
|
private static async void OnCancelKeyPress(object? sender, ConsoleCancelEventArgs e) => await Exit().ConfigureAwait(false);
|
|
|
|
private static async void OnPosixSignal(PosixSignalContext signal) {
|
|
ArgumentNullException.ThrowIfNull(signal);
|
|
|
|
switch (signal.Signal) {
|
|
case PosixSignal.SIGINT:
|
|
case PosixSignal.SIGTERM:
|
|
await Exit().ConfigureAwait(false);
|
|
|
|
break;
|
|
default:
|
|
throw new InvalidOperationException(nameof(signal.Signal));
|
|
}
|
|
}
|
|
|
|
private static async void OnProcessExit(object? sender, EventArgs e) => await Shutdown().ConfigureAwait(false);
|
|
|
|
private static async void OnUnhandledException(object? sender, UnhandledExceptionEventArgs e) {
|
|
ArgumentNullException.ThrowIfNull(e);
|
|
ArgumentNullException.ThrowIfNull(e.ExceptionObject);
|
|
|
|
await ASF.ArchiLogger.LogFatalException((Exception) e.ExceptionObject).ConfigureAwait(false);
|
|
|
|
if (e.IsTerminating) {
|
|
await Exit(1).ConfigureAwait(false);
|
|
}
|
|
}
|
|
|
|
private static async void OnUnobservedTaskException(object? sender, UnobservedTaskExceptionEventArgs e) {
|
|
ArgumentNullException.ThrowIfNull(e);
|
|
ArgumentNullException.ThrowIfNull(e.Exception);
|
|
|
|
// TODO: Remove conditionally ignoring exceptions once reports are resolved
|
|
// https://github.com/dotnet/runtime/issues/80111
|
|
// https://github.com/dotnet/runtime/issues/102772
|
|
bool ignored = e.Exception.InnerExceptions.Any(static exception => exception is HttpIOException or QuicException);
|
|
|
|
if (!ignored) {
|
|
await ASF.ArchiLogger.LogFatalException(e.Exception).ConfigureAwait(false);
|
|
}
|
|
|
|
// Normally we should abort the application, but due to the fact that unobserved exceptions do not have to do that, it's a better idea to log it and try to continue
|
|
e.SetObserved();
|
|
}
|
|
|
|
private static async Task<bool> ParseArgs(IReadOnlyCollection<string> args) {
|
|
if ((args == null) || (args.Count == 0)) {
|
|
throw new ArgumentNullException(nameof(args));
|
|
}
|
|
|
|
bool cryptKeyNext = false;
|
|
bool cryptKeyFileNext = false;
|
|
bool networkGroupNext = false;
|
|
bool pathNext = false;
|
|
|
|
foreach (string arg in args) {
|
|
switch (arg.ToUpperInvariant()) {
|
|
case "--CRYPTKEY" when noArgumentValueNext():
|
|
cryptKeyNext = true;
|
|
|
|
break;
|
|
case "--CRYPTKEY-FILE" when noArgumentValueNext():
|
|
cryptKeyFileNext = true;
|
|
|
|
break;
|
|
case "--IGNORE-UNSUPPORTED-ENVIRONMENT" when noArgumentValueNext():
|
|
IgnoreUnsupportedEnvironment = true;
|
|
|
|
break;
|
|
case "--INPUT-CRYPTKEY" when noArgumentValueNext():
|
|
InputCryptkeyManually = true;
|
|
|
|
break;
|
|
case "--MINIMIZED" when noArgumentValueNext():
|
|
Minimized = true;
|
|
|
|
break;
|
|
case "--NETWORK-GROUP" when noArgumentValueNext():
|
|
networkGroupNext = true;
|
|
|
|
break;
|
|
case "--NO-CONFIG-MIGRATE" when noArgumentValueNext():
|
|
ConfigMigrate = false;
|
|
|
|
break;
|
|
case "--NO-CONFIG-WATCH" when noArgumentValueNext():
|
|
ConfigWatch = false;
|
|
|
|
break;
|
|
case "--NO-RESTART" when noArgumentValueNext():
|
|
RestartAllowed = false;
|
|
|
|
break;
|
|
case "--NO-STEAM-PARENTAL-GENERATION" when noArgumentValueNext():
|
|
SteamParentalGeneration = false;
|
|
|
|
break;
|
|
case "--PATH" when noArgumentValueNext():
|
|
pathNext = true;
|
|
|
|
break;
|
|
case "--SERVICE" when noArgumentValueNext():
|
|
Service = true;
|
|
|
|
break;
|
|
case "--SYSTEM-REQUIRED" when noArgumentValueNext():
|
|
SystemRequired = true;
|
|
|
|
break;
|
|
default:
|
|
if (cryptKeyNext) {
|
|
cryptKeyNext = false;
|
|
HandleCryptKeyArgument(arg);
|
|
} else if (cryptKeyFileNext) {
|
|
cryptKeyFileNext = false;
|
|
|
|
if (!await HandleCryptKeyFileArgument(arg).ConfigureAwait(false)) {
|
|
return false;
|
|
}
|
|
} else if (networkGroupNext) {
|
|
networkGroupNext = false;
|
|
HandleNetworkGroupArgument(arg);
|
|
} else if (pathNext) {
|
|
pathNext = false;
|
|
|
|
if (!HandlePathArgument(arg)) {
|
|
return false;
|
|
}
|
|
} else {
|
|
switch (arg.Length) {
|
|
case > 16 when arg.StartsWith("--CRYPTKEY-FILE=", StringComparison.OrdinalIgnoreCase):
|
|
if (!await HandleCryptKeyFileArgument(arg[16..]).ConfigureAwait(false)) {
|
|
return false;
|
|
}
|
|
|
|
break;
|
|
case > 16 when arg.StartsWith("--NETWORK-GROUP=", StringComparison.OrdinalIgnoreCase):
|
|
HandleNetworkGroupArgument(arg[16..]);
|
|
|
|
break;
|
|
case > 11 when arg.StartsWith("--CRYPTKEY=", StringComparison.OrdinalIgnoreCase):
|
|
HandleCryptKeyArgument(arg[11..]);
|
|
|
|
break;
|
|
case > 7 when arg.StartsWith("--PATH=", StringComparison.OrdinalIgnoreCase):
|
|
if (!HandlePathArgument(arg[7..])) {
|
|
return false;
|
|
}
|
|
|
|
break;
|
|
default:
|
|
ASF.ArchiLogger.LogGenericWarning(Strings.FormatWarningUnknownCommandLineArgument(arg));
|
|
|
|
break;
|
|
}
|
|
}
|
|
|
|
break;
|
|
}
|
|
}
|
|
|
|
return true;
|
|
|
|
bool noArgumentValueNext() => !cryptKeyNext && !cryptKeyFileNext && !networkGroupNext && !pathNext;
|
|
}
|
|
|
|
private static async Task<bool> ParseEnvironmentVariables() {
|
|
// We're using a single try-catch block here, as a failure for getting one variable will result in the same failure for all other ones
|
|
try {
|
|
string? envPath = Environment.GetEnvironmentVariable(SharedInfo.EnvironmentVariablePath);
|
|
|
|
if (!string.IsNullOrEmpty(envPath)) {
|
|
if (!HandlePathArgument(envPath)) {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
string? envCryptKey = Environment.GetEnvironmentVariable(SharedInfo.EnvironmentVariableCryptKey);
|
|
|
|
if (!string.IsNullOrEmpty(envCryptKey)) {
|
|
HandleCryptKeyArgument(envCryptKey);
|
|
}
|
|
|
|
string? envCryptKeyFile = Environment.GetEnvironmentVariable(SharedInfo.EnvironmentVariableCryptKeyFile);
|
|
|
|
if (!string.IsNullOrEmpty(envCryptKeyFile)) {
|
|
if (!await HandleCryptKeyFileArgument(envCryptKeyFile).ConfigureAwait(false)) {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
string? envNetworkGroup = Environment.GetEnvironmentVariable(SharedInfo.EnvironmentVariableNetworkGroup);
|
|
|
|
if (!string.IsNullOrEmpty(envNetworkGroup)) {
|
|
HandleNetworkGroupArgument(envNetworkGroup);
|
|
}
|
|
} catch (Exception e) {
|
|
ASF.ArchiLogger.LogGenericException(e);
|
|
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
private static async Task Shutdown(byte exitCode = 0) {
|
|
if (!await InitShutdownSequence(exitCode).ConfigureAwait(false)) {
|
|
return;
|
|
}
|
|
|
|
ShutdownResetEvent.TrySetResult(exitCode);
|
|
}
|
|
}
|