refactor and small deserializer fix

Author: elasticroentgen

CloudBan.cs

@@ -0,0 +1,8 @@
+namespace GithubActionsOrchestrator;
+
+internal class CloudBan
+{
+    public string Cloud { get; set; }
+    public string Size { get; set; }
+    public DateTime UnbanTime { get; set; }
+}

CloudControllers/CspServer.cs

@@ -0,0 +1,8 @@
+namespace GithubActionsOrchestrator.CloudControllers;
+
+public class CspServer
+{
+    public long Id { get; set; }
+    public string Name { get; set; }
+    public DateTime CreatedAt { get; set; }
+}

CloudControllers/HetznerCloudController.cs

@@ -187,19 +187,4 @@ public async Task<int> GetServerCountFromCsp()
     }
 
     public string CloudIdentifier => "htz";
-}
-
-public class UnsupportedMachineTypeException : Exception
-{
-    public UnsupportedMachineTypeException()
-    {
-    }
-
-    public UnsupportedMachineTypeException(string message) : base(message)
-    {
-    }
-
-    public UnsupportedMachineTypeException(string message, Exception inner) : base(message, inner)
-    {
-    }
-}
+}

CloudControllers/ICloudController.cs

@@ -11,11 +11,4 @@ public interface ICloudController
     Task<int> GetServerCountFromCsp();
 
     string CloudIdentifier { get; }
-}
-
-public class CspServer
-{
-    public long Id { get; set; }
-    public string Name { get; set; }
-    public DateTime CreatedAt { get; set; }
 }

CloudControllers/UnsupportedMachineTypeException.cs

@@ -0,0 +1,16 @@
+namespace GithubActionsOrchestrator.CloudControllers;
+
+public class UnsupportedMachineTypeException : Exception
+{
+    public UnsupportedMachineTypeException()
+    {
+    }
+
+    public UnsupportedMachineTypeException(string message) : base(message)
+    {
+    }
+
+    public UnsupportedMachineTypeException(string message, Exception inner) : base(message, inner)
+    {
+    }
+}

Database/ActionsRunnerContext.cs

@@ -0,0 +1,62 @@
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace GithubActionsOrchestrator.Database;
+using Microsoft.EntityFrameworkCore;
+using System;
+
+public class ActionsRunnerContext()
+    : DbContext
+{
+    public DbSet<Runner> Runners { get; set; }
+    public DbSet<Job> Jobs { get; set; }
+    public DbSet<RunnerLifecycle> RunnerLifecycles { get; set; }
+
+    
+    
+    protected override void OnConfiguring(DbContextOptionsBuilder options)
+        => options.UseNpgsql(Program.Config.DbConnectionString);
+
+    protected override void OnModelCreating(ModelBuilder modelBuilder)
+    {
+        modelBuilder.Entity<Runner>()
+            .HasOne(r => r.Job)
+            .WithOne()
+            .HasForeignKey<Runner>(r => r.JobId)
+            .IsRequired(false);
+
+        modelBuilder.Entity<Job>()
+            .HasOne(j => j.Runner)
+            .WithOne()
+            .HasForeignKey<Job>(j => j.RunnerId)
+            .IsRequired(false);
+    }
+
+    public async Task<Runner> LinkJobToRunner(long jobId, string runnerName)
+    {
+        try
+        {
+            var job = await Jobs.Include(x => x.Runner).FirstOrDefaultAsync(x => x.GithubJobId == jobId);
+            var runner = await Runners.Include(x => x.Job).Include(x => x.Lifecycle).FirstOrDefaultAsync(x => x.Hostname == runnerName);
+            runner.Job = job;
+            job.Runner = runner;
+            job.InProgressTime = DateTime.UtcNow;
+            runner.Lifecycle.Add(new()
+            {
+                Event = $"Runner got picked by job {jobId}",
+                Status = RunnerStatus.Processing,
+                EventTimeUtc = DateTime.UtcNow
+            });
+            await SaveChangesAsync();
+            return runner;
+        }
+        catch
+        {
+            // unable to link
+            return null;
+        }
+
+    }
+    
+}
+
+// Runners provisioned over time

Database/DbContext.cs

@@ -0,0 +1,25 @@
+using System.Text.Json.Serialization;
+
+namespace GithubActionsOrchestrator.Database;
+
+public class Job
+{
+    public int JobId { get; set; }
+    public long GithubJobId { get; set; }
+    public string Repository { get; set; }
+    public string Owner { get; set; }
+    public JobState State { get; set; }
+    public DateTime InProgressTime { get; set; }
+    public DateTime QueueTime { get; set; }
+    public DateTime CompleteTime { get; set; }
+    public string JobUrl { get; set; }
+    
+    //Relations
+    public int? RunnerId { get; set; }
+
+    [JsonIgnore]
+    public Runner Runner { get; set; }
+    public bool Orphan { get; set; }
+    public string RequestedProfile { get; set; }
+    public string RequestedSize { get; set; }
+}

Database/Job.cs

@@ -0,0 +1,10 @@
+namespace GithubActionsOrchestrator.Database;
+
+public enum JobState
+{
+    Unknown = 0,
+    Queued = 1,
+    InProgress = 2,
+    Completed = 3,
+    Vanished = 4
+}

Database/JobState.cs

@@ -0,0 +1,52 @@
+namespace GithubActionsOrchestrator.Database;
+
+public class Runner
+{
+    public string IPv4 { get; set; }
+    public int RunnerId { get; set; }
+    public string Cloud { get; set; }
+    public string Hostname { get; set; }
+    public string Size { get; set; }
+    public string Profile { get; set; }
+    
+    // Relations
+
+    public int? JobId { get; set; }
+    public Job Job { get; set; }
+    public ICollection<RunnerLifecycle> Lifecycle { get; set; }
+    public long CloudServerId { get; set; }
+
+    public DateTime CreateTime
+    {
+        get
+        {
+            return Lifecycle.FirstOrDefault(x => x.Status == RunnerStatus.CreationQueued)!.EventTimeUtc;
+        }
+    }
+
+    public RunnerStatus LastState
+    {
+        get
+        {
+            return Lifecycle.MaxBy(x => x.EventTimeUtc).Status;
+        }
+    }
+
+    public bool IsOnline { get; set; }
+    public string Arch { get; set; }
+    public string Owner { get; set; }
+    public bool IsCustom { get; set; }
+
+    public DateTime LastStateTime
+    {
+        get
+        {
+            return Lifecycle.MaxBy(x => x.EventTimeUtc).EventTimeUtc;
+        }
+    }
+
+    public bool StuckJobReplacement { get; set; } = false;
+    public bool UsePrivateNetwork { get; set; }
+    public string ProvisionId { get; set; }
+    public string ProvisionPayload { get; set; }
+}