Parse funktioniert mit List<String> als Eingabe

Tests/servicediscovery.py

@@ -3,10 +3,9 @@ import urllib.request
 
 url = "http://localhost:5000/monitoring/service-discovery"
 payload = {
-"ServerId": 1,
-"ContainerId": "aaaaaaaaaaaa",
-"Name": "test-Name",
-"Image": "test-Image"
+    "server_id": 7,
+    "containers": ["{\"id\":\"6621c5b67c25\",\"image\":\"git.triggermeelmo.com/donpat1to/watcher-agent:v0.1.26\",\"name\":\"watcher-agent\"}",
+                   "{\"id\":\"b8c86fb260bd\",\"image\":\"git.triggermeelmo.com/watcher/watcher-server:v0.1.10\",\"name\":\"watcher\"}"]
 }
 
 data = json.dumps(payload).encode("utf-8")

Watcher/Controllers/MonitoringController.cs

@@ -1,8 +1,12 @@
 using System.ComponentModel.DataAnnotations;
+using System.Net.Http.Json;
+using System.Text.Json;
+using System.Text.Json.Serialization;
 using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.CodeAnalysis;
+using Microsoft.CodeAnalysis.CSharp.Syntax;
 using Microsoft.Data.Sqlite;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.IdentityModel.Tokens;
@@ -80,10 +84,8 @@ public class MetricDto
 
 public class ServiceDto
 {
-    public int ServerId { get; set; } // Vom Watcher-Server zugewiesene ID des Hosts
-    public String? ContainerId { get; set; }
-    public String? Image { get; set; }
-    public String? Name { get; set; }
+    public required int server_id { get; set; } // Vom Watcher-Server zugewiesene ID des Hosts
+    public required List<String> containers { get; set; }
 }
 
 [ApiController]
@@ -234,33 +236,102 @@ public class MonitoringController : Controller
                 .Select(e => e.ErrorMessage)
                 .ToList();
 
-            _logger.LogError("Ungültiger ServiceDetection-Payload.");
-            return BadRequest(new { error = "Ungültiger Payload", details = errors });
+            _logger.LogError("Invalid ServiceDetection-Payload.");
+            return BadRequest(new { error = "Invalid Payload", details = errors });
         }
 
-        // Metrics für Container, die zu ServerId gehören, löschen
+        // Json zu was brauchbarem machen
+        //string containersJson = await dto.containers.ReadAsStringAsync();
+        //List<Container> newContainers = JsonSerializer.Deserialize<List<Container>>(containersJson)?? new List<Container>();;
 
-        // Container, die zu ServerId gehören löschen
+        List<Container> newContainers = new List<Container>();
 
-        // Container neu in Datenbank einlesen
-        try
+        foreach (String s in dto.containers)
         {
-            Container container = new Container
+            // JSON zu einem JsonDocument parsen
+            using JsonDocument doc = JsonDocument.Parse(s);
+            JsonElement root = doc.RootElement;
+
+            // Einzelne Werte extrahieren
+            string id = root.GetProperty("id").GetString() ?? "";
+            string image = root.GetProperty("image").GetString() ?? "";
+            string name = root.GetProperty("name").GetString() ?? "";
+
+            Container newContainer = new Container
             {
-                ServerId = dto.ServerId,
-                ContainerId = dto.ContainerId,
-                Image = dto.Name,
-                Name = dto.Name
+                ServerId = dto.server_id,
+                ContainerId = id,
+                Image = image,
+                Name = name,
             };
 
-            _logger.LogInformation(container.Name + " added for Host " + container.ServerId);
 
-            _context.Containers.Add(container);
+            newContainers.Add(newContainer);
+        }
+
+        foreach (Container c in newContainers)
+        {
+            c.ServerId = dto.server_id;
+            // Debug Logs
+            // TODO entfernen wenn fertig getestet
+            Console.WriteLine("---------");
+            Console.WriteLine("ServerId: " + c.ServerId);
+            Console.WriteLine("ContainerId: " + c.ContainerId);
+            Console.WriteLine("Name: " + c.Name);
+            Console.WriteLine("Image: " + c.Image);
+            Console.WriteLine("---------");
+
+        }
+
+        // Container Objekte erstellen
+        //List<Container> newContainers = ParseServiceDiscoveryInput(dto.Server_id, containers);
+
+        // Liste aller Container, die bereits der übergebenen ServerId zugewiesen sind
+        List<Container> existingContainers = _context.Containers
+            .Where(c => c.ServerId == dto.server_id)
+            .ToList();
+
+
+        // Logik, um Container, die mit dem Payload kamen zu verarbeiten
+        foreach (Container c in newContainers)
+        {
+            // Überprüfen, ob ein übergebener Container bereits für den Host registriert ist
+            if (existingContainers.Contains(c))
+            {
+                _logger.LogInformation("Container with id " + c.ContainerId + " already exists.");
+            }
+            // Container auf einen Host/Server registrieren
+            else
+            {
+                // Container in Datenbank einlesen
+                try
+                {
+                    _context.Containers.Add(c);
                     await _context.SaveChangesAsync();
+                    _logger.LogInformation(c.Name + " added for Host " + c.ServerId);
                 }
                 catch (SqliteException e)
                 {
-            _logger.LogError("ServiceDiscovery failed: " + e.Message);
+                    _logger.LogError("Error writing new Containers to Database: " + e.Message);
+                }
+            }
+        }
+
+        // Logik um abgeschaltene Container aus der Datenbank zu entfernen
+        foreach (Container c in existingContainers)
+        {
+            // Abfrage, ob bereits vorhandener Container im Payload vorhanden war
+            if (!newContainers.Contains(c))
+            {
+                // Container entfernen
+                _context.Containers.Remove(c);
+                await _context.SaveChangesAsync();
+
+                // Metrics für den Container entfernen
+                //Todo 
+
+                _logger.LogInformation("Container " + c.Name + " (" + c.Id + ") on Host-Id " + c.ServerId + " was successfully removed from the database.");
+            }
         }
 
         return Ok();
@@ -268,7 +339,6 @@ public class MonitoringController : Controller
     }
 
     // Durchschnittliche Werte Berechnen
-    [HttpGet("median")]
     public async Task<IActionResult> CalculateMedian(string Metric, int HoursToMonitor, int ServerId)
     {
         // Aktuelle Zeit - X Stunden = letzter Wert, der berücksichtigt werden soll
@@ -368,4 +438,13 @@ public class MonitoringController : Controller
         return metric_input;
     }
 
+    private List<Container> ParseServiceDiscoveryInput(int server_id, List<Container> containers)
+    {
+        List<Container> containerList = new List<Container>();
+
+        // JSON-Objekt auslesen und Container-Objekte erstellen
+        
+
+        return containerList;
+    }
 }

Watcher/Migrations/20251029105954_container-changed.Designer.cs

@@ -0,0 +1,355 @@
+// <auto-generated />
+using System;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Infrastructure;
+using Microsoft.EntityFrameworkCore.Migrations;
+using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
+using Watcher.Data;
+
+#nullable disable
+
+namespace Watcher.Migrations
+{
+    [DbContext(typeof(AppDbContext))]
+    [Migration("20251029105954_container-changed")]
+    partial class containerchanged
+    {
+        /// <inheritdoc />
+        protected override void BuildTargetModel(ModelBuilder modelBuilder)
+        {
+#pragma warning disable 612, 618
+            modelBuilder.HasAnnotation("ProductVersion", "8.0.6");
+
+            modelBuilder.Entity("Watcher.Models.Container", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("INTEGER");
+
+                    b.Property<string>("ContainerId")
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("Image")
+                        .HasColumnType("TEXT");
+
+                    b.Property<int?>("ImageId")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<bool>("IsRunning")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<string>("Name")
+                        .HasColumnType("TEXT");
+
+                    b.Property<int>("ServerId")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<int?>("TagId")
+                        .HasColumnType("INTEGER");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("ImageId");
+
+                    b.HasIndex("TagId");
+
+                    b.ToTable("Containers");
+                });
+
+            modelBuilder.Entity("Watcher.Models.Image", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("INTEGER");
+
+                    b.Property<string>("Name")
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("Tag")
+                        .HasColumnType("TEXT");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("Images");
+                });
+
+            modelBuilder.Entity("Watcher.Models.LogEvent", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("INTEGER");
+
+                    b.Property<int?>("ContainerId")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<string>("Level")
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("Message")
+                        .HasColumnType("TEXT");
+
+                    b.Property<int?>("ServerId")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<DateTime>("Timestamp")
+                        .HasColumnType("TEXT");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("ContainerId");
+
+                    b.HasIndex("ServerId");
+
+                    b.ToTable("LogEvents");
+                });
+
+            modelBuilder.Entity("Watcher.Models.Metric", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("INTEGER");
+
+                    b.Property<double>("CPU_Load")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("CPU_Temp")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("DISK_Size")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("DISK_Temp")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("DISK_Usage")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("GPU_Load")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("GPU_Temp")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("GPU_Vram_Size")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("GPU_Vram_Usage")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("NET_In")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("NET_Out")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("RAM_Load")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("RAM_Size")
+                        .HasColumnType("REAL");
+
+                    b.Property<int?>("ServerId")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<DateTime>("Timestamp")
+                        .HasColumnType("TEXT");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("Metrics");
+                });
+
+            modelBuilder.Entity("Watcher.Models.Server", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("INTEGER");
+
+                    b.Property<double>("CPU_Load_Critical")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("CPU_Load_Warning")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("CPU_Temp_Critical")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("CPU_Temp_Warning")
+                        .HasColumnType("REAL");
+
+                    b.Property<int>("CpuCores")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<string>("CpuType")
+                        .HasColumnType("TEXT");
+
+                    b.Property<DateTime>("CreatedAt")
+                        .HasColumnType("TEXT");
+
+                    b.Property<double>("DISK_Temp_Critical")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("DISK_Temp_Warning")
+                        .HasColumnType("REAL");
+
+                    b.Property<string>("Description")
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("DiskSpace")
+                        .HasColumnType("TEXT");
+
+                    b.Property<double>("Disk_Usage_Critical")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("Disk_Usage_Warning")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("GPU_Load_Critical")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("GPU_Load_Warning")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("GPU_Temp_Critical")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("GPU_Temp_Warning")
+                        .HasColumnType("REAL");
+
+                    b.Property<string>("GpuType")
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("IPAddress")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.Property<bool>("IsOnline")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<bool>("IsVerified")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<DateTime>("LastSeen")
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("Name")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.Property<double>("RAM_Load_Critical")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("RAM_Load_Warning")
+                        .HasColumnType("REAL");
+
+                    b.Property<double>("RamSize")
+                        .HasColumnType("REAL");
+
+                    b.Property<int?>("TagId")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<string>("Type")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("TagId");
+
+                    b.ToTable("Servers");
+                });
+
+            modelBuilder.Entity("Watcher.Models.Tag", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("INTEGER");
+
+                    b.Property<string>("Name")
+                        .HasColumnType("TEXT");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("Tags");
+                });
+
+            modelBuilder.Entity("Watcher.Models.User", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("INTEGER");
+
+                    b.Property<string>("Email")
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("IdentityProvider")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.Property<DateTime>("LastLogin")
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("OIDC_Id")
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("Password")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("Username")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("Users");
+                });
+
+            modelBuilder.Entity("Watcher.Models.Container", b =>
+                {
+                    b.HasOne("Watcher.Models.Image", null)
+                        .WithMany("Containers")
+                        .HasForeignKey("ImageId");
+
+                    b.HasOne("Watcher.Models.Tag", null)
+                        .WithMany("Containers")
+                        .HasForeignKey("TagId");
+                });
+
+            modelBuilder.Entity("Watcher.Models.LogEvent", b =>
+                {
+                    b.HasOne("Watcher.Models.Container", "Container")
+                        .WithMany()
+                        .HasForeignKey("ContainerId");
+
+                    b.HasOne("Watcher.Models.Server", "Server")
+                        .WithMany()
+                        .HasForeignKey("ServerId");
+
+                    b.Navigation("Container");
+
+                    b.Navigation("Server");
+                });
+
+            modelBuilder.Entity("Watcher.Models.Server", b =>
+                {
+                    b.HasOne("Watcher.Models.Tag", null)
+                        .WithMany("Servers")
+                        .HasForeignKey("TagId");
+                });
+
+            modelBuilder.Entity("Watcher.Models.Image", b =>
+                {
+                    b.Navigation("Containers");
+                });
+
+            modelBuilder.Entity("Watcher.Models.Tag", b =>
+                {
+                    b.Navigation("Containers");
+
+                    b.Navigation("Servers");
+                });
+#pragma warning restore 612, 618
+        }
+    }
+}

Watcher/Migrations/20251029105954_container-changed.cs

@@ -0,0 +1,22 @@
+using Microsoft.EntityFrameworkCore.Migrations;
+
+#nullable disable
+
+namespace Watcher.Migrations
+{
+    /// <inheritdoc />
+    public partial class containerchanged : Migration
+    {
+        /// <inheritdoc />
+        protected override void Up(MigrationBuilder migrationBuilder)
+        {
+
+        }
+
+        /// <inheritdoc />
+        protected override void Down(MigrationBuilder migrationBuilder)
+        {
+
+        }
+    }
+}

Watcher/Models/Container.cs

@@ -1,14 +1,23 @@
+using System.Text.Json.Serialization;
+
 namespace Watcher.Models;
 
 public class Container
 {
+    [JsonPropertyName("id")]
     public int Id { get; set; }
 
     public int ServerId { get; set; }
 
     public String? ContainerId { get; set; }
+
+    [JsonPropertyName("image")]
     public String? Image { get; set; }
+
+    [JsonPropertyName("name")]
     public String? Name { get; set; }
 
+    // keine Variable, die vom Agent übergeben wird. Ein container ist immer Running, die Variable dient nur für die Übersicht
+    // auf dem Dashboard.
     public Boolean IsRunning { get; set; } = true;
 }

Watcher/Views/Container/Overview.cshtml

@@ -12,20 +12,22 @@
     <div >
             <table class="ServiceList">
                 <tr>
-                    <th>Service</th>
-                    <th>HostServer</th>
-                    <th>Status</th>
-                    <th>Deployment</th>
-                    <th></th>
+                    <th>Container-ID</th>
+                    <th>Name</th>
+                    <th>Image</th>
+                    <th>Host-ID</th>
+                    <th>Aktionen</th>
 
                 </tr>
                 @foreach (Container container in Model.Containers)
                 {
                     <tr class="ServiceRow">
+                        <td>@container.ContainerId</td>
                         <td>@container.Name</td>
-                        <td><a  class="ServiceEntry" href="/Server/Details/${containerId}">@container.ServerId</a></td>
-                        <td>nicht automatisiert</td>
-                        <td>Docker</td>
+                        <td>@container.Image</td>
+                        <!-- TODO: Link Hardcoded -->
+                        <td><a  class="ServiceEntry" href="/Server/Details/2">@container.ServerId</a></td>
+                        <td>nicht verfügbar</td>
                     </tr>
                 }
             </table>