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

Refactor package info and their access tokens, add ISteamPICSChanges plugin interface

Browse Source
This commit is contained in:
JustArchi
2020-06-09 22:56:04 +02:00
parent 3203daf787
commit 0fa4d5e2a6
7 changed files with 282 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

60
ArchiSteamFarm/Plugins/PluginsCore.cs
View File

@@ -63,6 +63,30 @@ namespace ArchiSteamFarm.Plugins {
return result ?? StringComparer.Ordinal;
}
internal static async Task<uint> GetChangeNumberToStartFrom() {
if (!HasActivePluginsLoaded) {
return 0;
}
IList<uint> results;
try {
results = await Utilities.InParallel(ActivePlugins.OfType<ISteamPICSChanges>().Select(plugin => plugin.GetPreferredChangeNumberToStartFrom())).ConfigureAwait(false);
} catch (Exception e) {
ASF.ArchiLogger.LogGenericException(e);
return 0;
}
uint changeNumberToStartFrom = uint.MaxValue;
foreach (uint result in results.Where(result => (result > 0) && (result < changeNumberToStartFrom))) {
changeNumberToStartFrom = result;
}
return changeNumberToStartFrom == uint.MaxValue ? 0 : changeNumberToStartFrom;
}
internal static bool InitPlugins() {
if (HasActivePluginsLoaded) {
return false;
@@ -493,6 +517,42 @@ namespace ArchiSteamFarm.Plugins {
}
}
internal static async Task OnPICSChanges(uint currentChangeNumber, IReadOnlyDictionary<uint, SteamApps.PICSChangesCallback.PICSChangeData> appChanges, IReadOnlyDictionary<uint, SteamApps.PICSChangesCallback.PICSChangeData> packageChanges) {
if ((currentChangeNumber == 0) || (appChanges == null) || (packageChanges == null)) {
ASF.ArchiLogger.LogNullError(nameof(currentChangeNumber) + " || " + nameof(appChanges) + " || " + nameof(packageChanges));
return;
}
if (!HasActivePluginsLoaded) {
return;
}
try {
await Utilities.InParallel(ActivePlugins.OfType<ISteamPICSChanges>().Select(plugin => Task.Run(() => plugin.OnPICSChanges(currentChangeNumber, appChanges, packageChanges)))).ConfigureAwait(false);
} catch (Exception e) {
ASF.ArchiLogger.LogGenericException(e);
}
}
internal static async Task OnPICSChangesRestart(uint currentChangeNumber) {
if (currentChangeNumber == 0) {
ASF.ArchiLogger.LogNullError(nameof(currentChangeNumber));
return;
}
if (!HasActivePluginsLoaded) {
return;
}
try {
await Utilities.InParallel(ActivePlugins.OfType<ISteamPICSChanges>().Select(plugin => Task.Run(() => plugin.OnPICSChangesRestart(currentChangeNumber)))).ConfigureAwait(false);
} catch (Exception e) {
ASF.ArchiLogger.LogGenericException(e);
}
}
private static HashSet<Assembly> LoadAssembliesFrom(string path) {
if (string.IsNullOrEmpty(path)) {
ASF.ArchiLogger.LogNullError(nameof(path));