embed plugin loader directly into the launcher

2022-10-29 01:50:14 +07:00
parent 7204815c0c
commit 66d3dc2ead
53 changed files with 5689 additions and 10 deletions
--- a/PluginLoader/SteamAPI.cs
+++ b/PluginLoader/SteamAPI.cs
@@ -0,0 +1,83 @@
+using System.Reflection;
+using System.Text;
+using HarmonyLib;
+using Sandbox.Engine.Networking;
+using Steamworks;
+using VRage.Game;
+using VRage.Utils;
+using Parallel = ParallelTasks.Parallel;
+
+namespace PluginLoader;
+
+public static class SteamAPI
+{
+    private static MethodInfo DownloadModsBlocking;
+
+    public static bool IsSubscribed(ulong id)
+    {
+        var state = (EItemState)SteamUGC.GetItemState(new(id));
+        return (state & EItemState.k_EItemStateSubscribed) == EItemState.k_EItemStateSubscribed;
+    }
+
+    public static void SubscribeToItem(ulong id)
+    {
+        SteamUGC.SubscribeItem(new(id));
+    }
+
+    public static void Update(IEnumerable<ulong> ids)
+    {
+        if (!ids.Any())
+            return;
+
+        var modItems =
+            new List<MyObjectBuilder_Checkpoint.ModItem>(
+                ids.Select(x => new MyObjectBuilder_Checkpoint.ModItem(x, "Steam")));
+        LogFile.WriteLine($"Updating {modItems.Count} workshop items");
+
+        // Source: MyWorkshop.DownloadWorldModsBlocking
+        var result = new MyWorkshop.ResultData();
+        var task = Parallel.Start(delegate { result = UpdateInternal(modItems); });
+        while (!task.IsComplete)
+        {
+            MyGameService.Update();
+            Thread.Sleep(10);
+        }
+
+        if (!result.Success)
+        {
+            var exceptions = task.Exceptions;
+            if (exceptions != null && exceptions.Length > 0)
+            {
+                var sb = new StringBuilder();
+                sb.AppendLine("An error occurred while updating workshop items:");
+                foreach (var e in exceptions)
+                    sb.Append(e);
+                LogFile.WriteLine(sb.ToString());
+            }
+            else
+            {
+                LogFile.WriteLine("Unable to update workshop items");
+            }
+        }
+    }
+
+    public static MyWorkshop.ResultData UpdateInternal(List<MyObjectBuilder_Checkpoint.ModItem> mods)
+    {
+        // Source: MyWorkshop.DownloadWorldModsBlockingInternal
+
+        MyLog.Default.IncreaseIndent();
+
+        var list = new List<WorkshopId>(mods.Select(x => new WorkshopId(x.PublishedFileId, x.PublishedServiceName)));
+
+        if (DownloadModsBlocking == null)
+            DownloadModsBlocking = AccessTools.Method(typeof(MyWorkshop), "DownloadModsBlocking");
+
+        var resultData = (MyWorkshop.ResultData)DownloadModsBlocking.Invoke(mods, new object[]
+        {
+            mods, new MyWorkshop.ResultData { Success = true }, list, new MyWorkshop.CancelToken()
+        });
+
+        MyLog.Default.DecreaseIndent();
+        return resultData;
+    }
+}