Implement MigrateEconomyJob

Author: Trojaner

.github/workflows/deployment.yml

@@ -22,7 +22,7 @@ jobs:
     - name: Install dependencies
       run: dotnet restore src/OpenMod.Installer.RocketMod.csproj
     - name: Update version
-      run: "sed -i \"s#<Version>0.0.0</Version>#<Version>${{ github.event.inputs.version }}</Version>#\" src/OpenMod.Installer.RocketMod.csproj"  
+      run: "sed -i \"s#<Version>0.0.0</Version>#<Version>${{ github.event.inputs.version }}</Version>#\" src/OpenMod.Installer.RocketMod.csproj"
     - name: Build
       run: dotnet build src/OpenMod.Installer.RocketMod.csproj --configuration Release --no-restore
     - name: Create Release
@@ -32,7 +32,7 @@ jobs:
         GITHUB_TOKEN: ${{ github.token }}
       with:
         tag_name: ${{ github.event.inputs.version }}
-        release_name: Release v${{ github.event.inputs.version }}
+        release_name: v${{ github.event.inputs.version }}
         draft: false
         prerelease: false      
     - name: Upload release asset
@@ -41,6 +41,6 @@ jobs:
         GITHUB_TOKEN: ${{ github.token }}
       with:
         upload_url: ${{ steps.create_release.outputs.upload_url }}
-        asset_path: ./src/bin/Release/netstandard2.0/OpenMod.Installer.RocketMod.dll
+        asset_path: ./src/bin/Release/net461/OpenMod.Installer.RocketMod.dll
         asset_name: OpenMod.Installer.RocketMod-v${{ github.event.inputs.version }}.dll
-        asset_content_type: application/octet-stream
+        asset_content_type: application/octet-stream

src/Helpers/AsyncHelperEx.cs

@@ -10,5 +10,10 @@ public static void RunSync(Func<Task> task)
         {
             AsyncContext.Run(task);
         }
+
+        public static T RunSync<T>(Func<Task<T>> task)
+        {
+            return AsyncContext.Run(task);
+        }
     }
 }

src/Jobs/MigrateEconomyJob.cs

@@ -1,4 +1,13 @@
-using Rocket.Core.Logging;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using OpenMod.API.Jobs;
+using OpenMod.API.Persistence;
+using OpenMod.Core.Helpers;
+using OpenMod.Core.Jobs;
+using OpenMod.Core.Persistence;
+using OpenMod.Installer.RocketMod.Helpers;
+using Rocket.Core.Logging;
 
 namespace OpenMod.Installer.RocketMod.Jobs
 {
@@ -7,7 +16,49 @@ public class MigrateEconomyJob : IJob
         public void ExecuteMigration(string[] args)
         {
             Logger.Log("Adding economy migration job to autoexec.yaml...");
-            //todo check if job exists
+            var openmodDirectory = OpenModInstallerPlugin.Instance.OpenModManager.WorkingDirectory;
+            var autoexecYaml = Path.Combine(openmodDirectory, "autoexec.yaml");
+
+            var dataStore = new YamlDataStore(new DataStoreCreationParameters
+            {
+                WorkingDirectory = openmodDirectory,
+                LogOnChange = false
+            }, null, null);
+
+            if (!AsyncHelper.RunSync(() => dataStore.ExistsAsync("autoexec")))
+            {
+                var openmodAssembly = typeof(YamlDataStore).Assembly;
+                using var autoexecFileStream = openmodAssembly.GetManifestResourceStream("OpenMod.Core.autoexec.yaml");
+                using var ms = new MemoryStream();
+                autoexecFileStream!.CopyTo(ms);
+
+                ms.Seek(0, SeekOrigin.Begin);
+                File.WriteAllBytes(autoexecYaml, ms.ToArray());
+            }
+
+            var jobsFile = AsyncHelperEx.RunSync(() => dataStore.LoadAsync<ScheduledJobsFile>("autoexec"));
+            if (jobsFile!.Jobs!.Any(d => d.Name?.Equals("OpenMod.Installer.EconomyMigration") ?? false))
+            {
+                return;
+            }
+
+            jobsFile.Jobs.Add(new ScheduledJob
+            {
+                Name = "OpenMod.Installer.EconomyMigration",
+                Enabled = true,
+                Task = "openmod_command",
+                Args = new Dictionary<string, object>
+                {
+                    { "commands", new List<string>
+                        {
+                            "MigrateUconomy"
+                        }
+                    }
+                },
+                Schedule = "@single_exec"
+            });
+
+            AsyncHelperEx.RunSync(() => dataStore.SaveAsync("autoexec", jobsFile));
         }
     }
 }

src/OpenMod.Installer.RocketMod.csproj

@@ -8,6 +8,7 @@
 
   <ItemGroup>
     <PackageReference Include="Nito.AsyncEx.Context" Version="5.1.0" />
+    <PackageReference Include="OpenMod.Core" Version="3.0.0-beta1" />
     <PackageReference Include="OpenMod.NuGet" Version="3.0.0-beta1" />
     <PackageReference Include="OpenMod.UnityEngine.Redist" Version="2019.4.10" />
     <PackageReference Include="OpenMod.Unturned.Redist" Version="3.20.14" />