Akatsuki-Misaki/ArchiSteamFarm
1
0
Fork 0
mirror of https://github.com/JustArchiNET/ArchiSteamFarm.git synced 2026-01-01 14:10:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

Allow plugin creators to initialize their own limiters

Browse Source
This commit is contained in:
JustArchi
2022-07-08 19:11:27 +02:00
parent 39cc6e6ea6
commit 0e5490cc3a
1 changed files with 26 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

50
ArchiSteamFarm/Plugins/PluginsCore.cs
View File

@@ -40,6 +40,7 @@ using ArchiSteamFarm.Steam;
using ArchiSteamFarm.Steam.Data;
using ArchiSteamFarm.Steam.Exchange;
using ArchiSteamFarm.Steam.Integration.Callbacks;
using JetBrains.Annotations;
using Newtonsoft.Json.Linq;
using SteamKit2;
@@ -51,6 +52,31 @@ internal static class PluginsCore {
[ImportMany]
internal static ImmutableHashSet<IPlugin>? ActivePlugins { get; private set; }
[PublicAPI]
public static async Task<ICrossProcessSemaphore> GetCrossProcessSemaphore(string objectName) {
if (string.IsNullOrEmpty(objectName)) {
throw new ArgumentNullException(nameof(objectName));
}
string resourceName = OS.GetOsResourceName(objectName);
if ((ActivePlugins == null) || (ActivePlugins.Count == 0)) {
return new CrossProcessFileBasedSemaphore(resourceName);
}
IList<ICrossProcessSemaphore?> responses;
try {
responses = await Utilities.InParallel(ActivePlugins.OfType<ICrossProcessSemaphoreProvider>().Select(plugin => plugin.GetCrossProcessSemaphore(resourceName))).ConfigureAwait(false);
} catch (Exception e) {
ASF.ArchiLogger.LogGenericException(e);
return new CrossProcessFileBasedSemaphore(resourceName);
}
return responses.FirstOrDefault(static response => response != null) ?? new CrossProcessFileBasedSemaphore(resourceName);
}
internal static async Task<StringComparer> GetBotsComparer() {
if (ActivePlugins == null) {
return StringComparer.Ordinal;
@@ -95,30 +121,6 @@ internal static class PluginsCore {
return lastChangeNumber;
}
internal static async Task<ICrossProcessSemaphore> GetCrossProcessSemaphore(string objectName) {
if (string.IsNullOrEmpty(objectName)) {
throw new ArgumentNullException(nameof(objectName));
}
string resourceName = OS.GetOsResourceName(objectName);
if ((ActivePlugins == null) || (ActivePlugins.Count == 0)) {
return new CrossProcessFileBasedSemaphore(resourceName);
}
IList<ICrossProcessSemaphore?> responses;
try {
responses = await Utilities.InParallel(ActivePlugins.OfType<ICrossProcessSemaphoreProvider>().Select(plugin => plugin.GetCrossProcessSemaphore(resourceName))).ConfigureAwait(false);
} catch (Exception e) {
ASF.ArchiLogger.LogGenericException(e);
return new CrossProcessFileBasedSemaphore(resourceName);
}
return responses.FirstOrDefault(static response => response != null) ?? new CrossProcessFileBasedSemaphore(resourceName);
}
internal static async Task<IMachineInfoProvider?> GetCustomMachineInfoProvider() {
if (ActivePlugins == null) {
return null;