Merge branch 'main' of https://git.innov.energy/Innovenergy/git_trunk

csharp/InnovEnergy.sln

@@ -24,8 +24,6 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "S3", "lib/S3/S3.csproj", "{
 EndProject
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "deprecated", "deprecated", "{46DE03C4-52D1-47AA-8E60-8BB15361D723}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CsController", "app/CsController/CsController.csproj", "{72DBBE42-A09F-43C0-9613-331039857056}"
-EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "SaliMax", "app/SaliMax/SaliMax.csproj", "{25073794-D859-4824-9984-194C7E928496}"
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "StatusApi", "lib/StatusApi/StatusApi.csproj", "{9D17E78C-8A70-43DB-A619-DC12D20D023D}"
@@ -112,10 +110,6 @@ Global
 		{C3639841-13F4-4F24-99C6-7D965593BF89}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{C3639841-13F4-4F24-99C6-7D965593BF89}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{C3639841-13F4-4F24-99C6-7D965593BF89}.Release|Any CPU.Build.0 = Release|Any CPU
-		{72DBBE42-A09F-43C0-9613-331039857056}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{72DBBE42-A09F-43C0-9613-331039857056}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{72DBBE42-A09F-43C0-9613-331039857056}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{72DBBE42-A09F-43C0-9613-331039857056}.Release|Any CPU.Build.0 = Release|Any CPU
 		{25073794-D859-4824-9984-194C7E928496}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{25073794-D859-4824-9984-194C7E928496}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{25073794-D859-4824-9984-194C7E928496}.Release|Any CPU.ActiveCfg = Release|Any CPU
@@ -195,7 +189,6 @@ Global
 		{E3A5F3A3-72A5-47CC-85C6-2D8E962A0EC1} = {145597B4-3E30-45E6-9F72-4DD43194539A}
 		{46DE03C4-52D1-47AA-8E60-8BB15361D723} = {AD5B98A8-AB7F-4DA2-B66D-5B4E63E7D854}
 		{4A67D79F-F0C9-4BBC-9601-D5948E6C05D3} = {46DE03C4-52D1-47AA-8E60-8BB15361D723}
-		{72DBBE42-A09F-43C0-9613-331039857056} = {145597B4-3E30-45E6-9F72-4DD43194539A}
 		{25073794-D859-4824-9984-194C7E928496} = {145597B4-3E30-45E6-9F72-4DD43194539A}
 		{9D17E78C-8A70-43DB-A619-DC12D20D023D} = {AD5B98A8-AB7F-4DA2-B66D-5B4E63E7D854}
 		{C3639841-13F4-4F24-99C6-7D965593BF89} = {46DE03C4-52D1-47AA-8E60-8BB15361D723}

csharp/app/Backend/Backend.csproj

@@ -4,6 +4,8 @@
         <TargetFramework>net6.0</TargetFramework>
         <Nullable>enable</Nullable>
         <ImplicitUsings>enable</ImplicitUsings>
+        <LangVersion>preview</LangVersion>
+        <RootNamespace>Innovenergy.Backend</RootNamespace>
     </PropertyGroup>
 
     <ItemGroup>

csharp/app/Backend/Controllers/Controller.cs

@@ -1,21 +1,21 @@
 using System.Net;
 using System.Text;
-using System.Text.Json;
+using Innovenergy.Backend.Database;
-using Backend.Database;
+using Innovenergy.Backend.Model;
-using Backend.Model;
+using Innovenergy.Backend.Model.Relations;
-using Backend.Model.Relations;
+using Innovenergy.Backend.Utils;
-using Backend.Utils;
 using Microsoft.AspNetCore.Mvc;
 using HttpContextAccessor = Microsoft.AspNetCore.Http.HttpContextAccessor;
 
-namespace Backend.Controllers;
+namespace Innovenergy.Backend.Controllers;
 
 [ApiController]
 [Route("api/")]
 public class Controller  
 {
-    [ProducesResponseType(200)]
+    [Returns<String>]
-    [ProducesResponseType(401)]
+    [Returns(HttpStatusCode.Unauthorized)]
+    [Returns(HttpStatusCode.BadRequest)]
     [HttpPost($"{nameof(Login)}")]
     public Object Login(Credentials credentials)
     {
@@ -29,14 +29,282 @@ public class Controller
         if (user is null)
             return new HttpResponseMessage(HttpStatusCode.Unauthorized);
 
-        // if (!VerifyPassword(password, user))
+        #if !DEBUG
-        //     return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+        if (!VerifyPassword(credentials.Password, user))
+             return new HttpResponseMessage(HttpStatusCode.Unauthorized);   
+        #endif
         
         var ses = new Session(user);
         db.NewSession(ses);
         return ses.Token;
     }
 
+
+    [Returns(HttpStatusCode.OK)]
+    [Returns(HttpStatusCode.Unauthorized)]
+    [HttpPost($"{nameof(Logout)}")]
+    public Object Logout()
+    {
+        var caller = GetCaller();
+
+        if (caller is null)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+        
+        using var db = Db.Connect();
+        return db.DeleteSession(caller.Id);
+    }
+    
+    
+    [Returns(HttpStatusCode.OK)]
+    [Returns(HttpStatusCode.Unauthorized)]
+    [HttpPost($"{nameof(UpdateS3Credentials)}")]
+    public Object UpdateS3Credentials()
+    {
+        // TODO: S3Credentials should be per session, not per user
+        
+        var caller = GetCaller();
+        if (caller is null)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+        
+        using var db = Db.Connect();
+        
+        return db.CreateAndSaveUserS3ApiKey(caller);
+    }
+    
+
+    [Returns<User>]
+    [Returns(HttpStatusCode.Unauthorized)]
+    [HttpGet($"{nameof(GetUserById)}")]
+    public Object GetUserById(Int64 id)
+    {
+        var caller = GetCaller();
+        if (caller is null)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+        
+        using var db = Db.Connect();
+
+        var user = db
+                  .GetDescendantUsers(caller)
+                  .FirstOrDefault(u => u.Id == id);
+        
+        return user as Object ?? new HttpResponseMessage(HttpStatusCode.Unauthorized);
+    }
+
+    
+    [Returns<Installation>]
+    [Returns(HttpStatusCode.Unauthorized)]
+    [HttpGet($"{nameof(GetInstallationById)}")]
+    public Object GetInstallationById(Int64 id)
+    {
+        var caller = GetCaller();
+        if (caller == null)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+        
+        using var db = Db.Connect();
+        
+        var installation = db
+                          .GetAllAccessibleInstallations(caller)
+                          .FirstOrDefault(i => i.Id == id);
+
+        return installation as Object ?? new HttpResponseMessage(HttpStatusCode.NotFound);
+    }
+
+    
+    [Returns<Folder>]
+    [Returns(HttpStatusCode.Unauthorized)]
+    [HttpGet($"{nameof(GetFolderById)}")]
+    public Object GetFolderById(Int64 id)
+    {
+        var caller = GetCaller();
+        if (caller == null)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+        
+        using var db = Db.Connect();
+        
+        var folder = db
+                    .GetAllAccessibleFolders(caller)
+                    .FirstOrDefault(f => f.Id == id);
+
+        return folder as Object ?? new HttpResponseMessage(HttpStatusCode.NotFound);
+    }
+    
+    
+    [Returns<Installation[]>]  // assuming swagger knows about arrays but not lists (JSON) 
+    [Returns(HttpStatusCode.Unauthorized)]
+    [HttpGet($"{nameof(GetAllInstallations)}/")]
+    public Object GetAllInstallations()
+    {
+        var caller = GetCaller();
+        if (caller == null)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+   
+        using var db = Db.Connect();
+        
+        return db
+              .GetAllAccessibleInstallations(caller)
+              .ToList(); // important!
+    }
+    
+    
+    [Returns<Folder[]>]  // assuming swagger knows about arrays but not lists (JSON)
+    [Returns(HttpStatusCode.Unauthorized)]
+    [HttpGet($"{nameof(GetAllFolders)}/")]
+    public Object GetAllFolders()
+    {
+        var caller = GetCaller();
+        if (caller == null)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+
+        using var db = Db.Connect();
+        return db
+              .GetAllAccessibleFolders(caller)
+              .ToList();  // important!
+    }
+
+    
+    [Returns(HttpStatusCode.OK)]
+    [Returns(HttpStatusCode.Unauthorized)]
+    [HttpPut($"{nameof(UpdateUser)}/")]
+    public Object UpdateUser(User updatedUser)
+    {
+        // TODO: distinguish between create and update
+        
+        var caller = GetCaller();
+        if (caller == null)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+        
+        using var db = Db.Connect();
+        
+        return db.GetUserById(updatedUser.Id) != null 
+             ? db.UpdateUser(updatedUser) 
+             : db.CreateUser(updatedUser);
+    }
+    
+    
+    [Returns(HttpStatusCode.OK)]
+    [Returns(HttpStatusCode.Unauthorized)]
+    [HttpPut($"{nameof(UpdateInstallation)}/")]
+    public Object UpdateInstallation(Installation updatedInstallation)
+    {
+        var caller = GetCaller();
+        
+        if (caller is null || !caller.HasWriteAccess)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+        
+        using var db = Db.Connect();
+        
+        var hasAccessToInstallation = db
+                                     .GetAllAccessibleInstallations(caller)
+                                     .Any(i => i.Id == updatedInstallation.Id);
+        
+        if (!hasAccessToInstallation)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+
+        // TODO: accessibility by other users etc
+        // TODO: sanity check changes
+        
+        return db.UpdateInstallation(updatedInstallation);
+    }
+    
+    
+    [Returns(HttpStatusCode.OK)]
+    [Returns(HttpStatusCode.Unauthorized)]
+    [HttpPut($"{nameof(UpdateFolder)}/")]
+    public Object UpdateFolder(Folder folder)
+    {
+        var caller = GetCaller();
+        
+        if (caller is null || !caller.HasWriteAccess)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+        
+        using var db = Db.Connect();
+        
+        var hasAccessToFolder = db
+                               .GetAllAccessibleFolders(caller)
+                               .Any(f => f.Id == folder.Id);
+
+        if (!hasAccessToFolder)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+        
+        // TODO: accessibility by other users etc
+        // TODO: sanity check changes
+                
+        return db.UpdateFolder(folder);
+    }
+    
+    [Returns(HttpStatusCode.OK)]
+    [Returns(HttpStatusCode.Unauthorized)]
+    [HttpDelete($"{nameof(DeleteUser)}/")]
+    public Object DeleteUser(Int64 userId)
+    {
+        var caller = GetCaller();
+        
+        if (caller is null || !caller.HasWriteAccess)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+        
+        using var db = Db.Connect();
+        
+        var userToBeDeleted = db
+                             .GetDescendantUsers(caller)
+                             .FirstOrDefault(u => u.Id == userId);
+
+        if (userToBeDeleted is null)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+        
+        return db.DeleteUser(userToBeDeleted);
+    }
+    
+    [Returns(HttpStatusCode.OK)]
+    [Returns(HttpStatusCode.Unauthorized)]
+    [HttpDelete($"{nameof(DeleteInstallation)}/")]
+    public Object DeleteInstallation(Int64 installationId)
+    {
+        var caller = GetCaller();
+        
+        if (caller is null || !caller.HasWriteAccess)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+        
+        using var db = Db.Connect();
+
+        var installationToBeDeleted = db
+                                     .GetAllAccessibleInstallations(caller)
+                                     .FirstOrDefault(i => i.Id == installationId);
+        
+        if (installationToBeDeleted is null)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+        
+        return db.DeleteInstallation(installationToBeDeleted);
+    }
+    
+    
+    [ProducesResponseType(200)]
+    [ProducesResponseType(401)]
+    [HttpDelete($"{nameof(DeleteFolder)}/")]
+    public Object DeleteFolder(Int64 folderId)
+    {
+        var caller = GetCaller();
+        if (caller == null)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+        
+        using var db = Db.Connect();
+
+        var folderToDelete = db
+                            .GetAllAccessibleFolders(caller)
+                            .FirstOrDefault(f => f.Id == folderId);
+        
+        if (folderToDelete is null)
+            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
+        
+        return db.DeleteFolder(folderToDelete);
+    }
+    
+
+    private static User? GetCaller()
+    {
+        var ctxAccessor = new HttpContextAccessor();
+        return ctxAccessor.HttpContext?.Items["User"] as User;
+    }
+    
     private static Boolean VerifyPassword(String password, User user)
     {
         var pwdBytes  = Encoding.UTF8.GetBytes(password);
@@ -46,258 +314,7 @@ public class Controller
         return user.Password == pwdHash;
     }
 
-    [ProducesResponseType(200)]
-    [ProducesResponseType(401)]
-    [HttpPost($"{nameof(Logout)}")]
-    public Object Logout()
-    {
-        var ctxAccessor = new HttpContextAccessor();
-        var ctx = ctxAccessor.HttpContext;
-        using var db = Db.Connect();
-        var currentUser = (User)ctx.Items["User"];
-
-        if (currentUser is null)
-            return new HttpResponseMessage(HttpStatusCode.Conflict);
-        
-        return db.DeleteSession(currentUser.Id);
-    }
-    
-    [ProducesResponseType(200)]
-    [ProducesResponseType(401)]
-    [HttpPost($"{nameof(UpdateS3Creds)}")]
-    public Object UpdateS3Creds()
-    {
-        var ctxAccessor = new HttpContextAccessor();
-        var ctx = ctxAccessor.HttpContext;
-        using var db = Db.Connect();
-        var currentUser = (User)ctx!.Items["User"]!;
-        
-        return db.CreateAndSaveUserS3ApiKey(currentUser);
 }
 
 
-    [ProducesResponseType(typeof(User), 200)]
-    [ProducesResponseType(401)]
-    [HttpGet($"{nameof(GetUserById)}")]
-    public Object GetUserById(Int64 id)
-    {
-        var ctxAccessor = new HttpContextAccessor();
-        var ctx = ctxAccessor.HttpContext;
-        using var db = Db.Connect();
-        var currentUser = (User)ctx.Items["User"];
-        var viewedUser = db.GetUserById(id);
-        
-        //using the same error to prevent fishing for ids
-        if (currentUser == null || viewedUser == null  || !db.IsParentOfChild(currentUser, viewedUser))
-            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
-
-        return viewedUser;
-    }
-
-    [ProducesResponseType(typeof(Installation), 200)]
-    [ProducesResponseType(401)]
-    [HttpGet($"{nameof(GetInstallationById)}")]
-    public Object GetInstallationById(Int64 id)
-    {
-        var ctxAccessor = new HttpContextAccessor();
-        var ctx = ctxAccessor.HttpContext;
-        using var db = Db.Connect();
-        var currentUser = (User)ctx.Items["User"];
-        
-        if (currentUser == null)
-            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
-        
-        var installation = db
-                          .GetAllAccessibleInstallations(currentUser)
-                          .FirstOrDefault(i => i.Id == id);
-
-        if (installation is null)
-            return new HttpResponseMessage(HttpStatusCode.NotFound);
-
-        return installation;
-    }
-
-    [ProducesResponseType(typeof(Folder), 200)]
-    [ProducesResponseType(401)]
-    [HttpGet($"{nameof(GetFolderById)}")]
-    public Object GetFolderById(Int64 id)
-    {
-        var ctxAccessor = new HttpContextAccessor();
-        var ctx = ctxAccessor.HttpContext;
-        using var db = Db.Connect();
-        var currentUser = (User)ctx.Items["User"];
-
-        var folder = db
-                    .GetAllAccessibleFolders(currentUser!)
-                    .FirstOrDefault(f => f.Id == id);
-
-        if(folder is null)
-            return new HttpResponseMessage(HttpStatusCode.NotFound);
-
-        return folder;
-    }
-    
-    [ProducesResponseType(200)]
-    [ProducesResponseType(401)]
-    [HttpGet($"{nameof(GetAllInstallations)}/")]
-    public Object GetAllInstallations()
-    {
-        var ctxAccessor = new HttpContextAccessor();
-        var ctx = ctxAccessor.HttpContext;
-        using var db = Db.Connect();
-        var user = (User)ctx.Items["User"];
-
-        if (user == null)
-            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
-        
-        return db.GetAllAccessibleInstallations(user).ToList();
-    }
-    
-    [ProducesResponseType(200)]
-    [ProducesResponseType(401)]
-    [HttpGet($"{nameof(GetAllFolders)}/")]
-    public Object GetAllFolders()
-    {
-        var ctxAccessor = new HttpContextAccessor();
-        var ctx = ctxAccessor.HttpContext;
-        var user = (User)ctx.Items["User"];
-        
-        using var db = Db.Connect();
-
-        if (user == null)
-            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
-        
-        return db.GetAllAccessibleFolders(user).ToList();
-    }
-    
-    [ProducesResponseType(200)]
-    [ProducesResponseType(401)]
-    [HttpPut($"{nameof(UpdateUser)}/")]
-    public Object UpdateUser(User updatedUser)
-    {
-        var ctxAccessor = new HttpContextAccessor();
-        var ctx = ctxAccessor.HttpContext;
-        using var db = Db.Connect();
-        var currentUser = (User)ctx.Items["User"];
-
-        if (currentUser == null || !currentUser.HasWriteAccess || !db.IsParentOfChild(currentUser, updatedUser))
-            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
-        
-        return db.GetUserById(updatedUser.Id) != null ? db.UpdateUser(updatedUser) : db.CreateUser(updatedUser);
-    }
-    
-    [ProducesResponseType(200)]
-    [ProducesResponseType(401)]
-    [HttpPut($"{nameof(UpdateInstallation)}/")]
-    public Object UpdateInstallation(Installation updatedInstallation)
-    {
-        var ctxAccessor = new HttpContextAccessor();
-        var ctx = ctxAccessor.HttpContext;
-        
-        var currentUser = (User)ctx.Items["User"];
-
-        if (currentUser == null || !currentUser.HasWriteAccess)
-            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
-
-        using var db = Db.Connect();
-        
-        var hasAccess = db.GetAllAccessibleInstallations(currentUser)
-                          .Any(i => i.Id == updatedInstallation.Id);
-        if (!hasAccess)
-            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
-
-        // TODO: accessibility by other users etc
-        // TODO: sanity check changes
-        
-        return db.UpdateInstallation(updatedInstallation);
-    }
-    
-    
-    [ProducesResponseType(200)]
-    [ProducesResponseType(401)]
-    [HttpPut($"{nameof(UpdateFolder)}/")]
-    public Object UpdateFolder(Folder updatedFolder)
-    {
-        var ctxAccessor = new HttpContextAccessor();
-        var ctx = ctxAccessor.HttpContext;
-        using var db = Db.Connect();
-        var currentUser = (User)ctx.Items["User"];
-
-        if (currentUser == null || !currentUser.HasWriteAccess)
-            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
-        
-        var hasAccess = db.GetAllAccessibleFolders(currentUser)
-                          .Any(f => f.Id == updatedFolder.Id);
-
-        if (!hasAccess)
-            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
-        
-        // TODO: accessibility by other users etc
-        // TODO: sanity check changes
-                
-        return db.UpdateFolder(updatedFolder);
-    }
-    
-    [ProducesResponseType(200)]
-    [ProducesResponseType(401)]
-    [HttpDelete($"{nameof(DeleteUser)}/")]
-    public Object DeleteUser(Int64 userId)
-    {
-        var ctxAccessor = new HttpContextAccessor();
-        var ctx = ctxAccessor.HttpContext;
-        using var db = Db.Connect();
-        var currentUser = (User)ctx.Items["User"];
-        var userToBeDeleted = db.GetUserById(userId);
-        
-        if (currentUser == null 
-                                || userToBeDeleted == null 
-                                || !currentUser.HasWriteAccess
-                                || !db.IsParentOfChild(currentUser,userToBeDeleted))
-            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
-        
-        return db.DeleteUser(userToBeDeleted);
-    }
-    
-    [ProducesResponseType(200)]
-    [ProducesResponseType(401)]
-    [HttpDelete($"{nameof(DeleteInstallation)}/")]
-    public Object DeleteInstallation(Int64 idOfInstallationToBeDeleted)
-    {
-        var ctxAccessor = new HttpContextAccessor();
-        var ctx = ctxAccessor.HttpContext;
-        using var db = Db.Connect();
-        var currentUser = (User)ctx.Items["User"];
-
-        var installationToBeDeleted = db
-                                     .GetAllAccessibleInstallations(currentUser!)
-                                     .FirstOrDefault(i => i.Id == idOfInstallationToBeDeleted);
-        
-        if (installationToBeDeleted is null)
-            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
-        
-        return db.DeleteInstallation(installationToBeDeleted);
-    }
-    
-    [ProducesResponseType(200)]
-    [ProducesResponseType(401)]
-    [HttpDelete($"{nameof(DeleteFolder)}/")]
-    public Object DeleteFolder(Int64 folderId)
-    {
-        var ctxAccessor = new HttpContextAccessor();
-        var ctx = ctxAccessor.HttpContext;
-        using var db = Db.Connect();
-        var currentUser = (User)ctx.Items["User"];
-
-        var folderToDelete = db
-                            .GetAllAccessibleFolders(currentUser!)
-                            .FirstOrDefault(f => f.Id == folderId);
-        
-        if (folderToDelete is null)
-            return new HttpResponseMessage(HttpStatusCode.Unauthorized);
-        
-        return db.DeleteFolder(folderToDelete);
-    }
-    
-
-}
 

csharp/app/Backend/Controllers/Credentials.cs

@@ -1,3 +1,6 @@
-namespace Backend.Controllers;
+using System.Diagnostics.CodeAnalysis;
 
+namespace Innovenergy.Backend.Controllers;
+
+[DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.All)]
 public record Credentials(String Username, String Password);

csharp/app/Backend/Controllers/ReturnsAttribute.cs

@@ -0,0 +1,22 @@
+using System.Net;
+using Microsoft.AspNetCore.Mvc;
+
+namespace Innovenergy.Backend.Controllers;
+
+public class ReturnsAttribute : ProducesResponseTypeAttribute
+{
+    public ReturnsAttribute(HttpStatusCode statusCode) : base((Int32)statusCode)
+    {
+    }
+}
+
+public class ReturnsAttribute<T> : ProducesResponseTypeAttribute
+{
+    public ReturnsAttribute(HttpStatusCode statusCode) : base(typeof(T), (Int32)statusCode)
+    {
+    }
+    
+    public ReturnsAttribute() : base(typeof(T), (Int32)HttpStatusCode.OK)
+    {
+    }
+}

csharp/app/Backend/Database/Db.cs

@@ -1,11 +1,11 @@
 using System.Diagnostics.CodeAnalysis;
-using Backend.Model;
+using Innovenergy.Backend.Model;
-using Backend.Model.Relations;
+using Innovenergy.Backend.Model.Relations;
-using Backend.Utils;
+using Innovenergy.Backend.Utils;
 using InnovEnergy.Lib.Utils;
 using SQLite;
 
-namespace Backend.Database;
+namespace Innovenergy.Backend.Database;
 
 public partial class Db : IDisposable
 {
@@ -98,6 +98,8 @@ public partial class Db : IDisposable
     }
     
 
+    
+  
     public IEnumerable<Folder> GetAllAccessibleFolders(User user)
     {
         return GetDirectlyAccessibleFolders(user)

csharp/app/Backend/Database/Fake.cs

@@ -1,6 +1,6 @@
-using Backend.Model.Relations;
+using Innovenergy.Backend.Model.Relations;
 
-namespace Backend.Database;
+namespace Innovenergy.Backend.Database;
 
 public partial class Db
 {

csharp/app/Backend/Database/Folder.cs

@@ -1,9 +1,9 @@
-using Backend.Model;
+using Innovenergy.Backend.Model;
-using Backend.Utils;
+using Innovenergy.Backend.Utils;
 using InnovEnergy.Lib.Utils;
 using SQLite;
 
-namespace Backend.Database;
+namespace Innovenergy.Backend.Database;
 
 public partial class Db
 {
@@ -37,6 +37,15 @@ public partial class Db
         return Installations.Where(f => f.ParentId == parent.Id);
     }
     
+    public IEnumerable<User> GetChildUsers(User parent)
+    {
+        return Users.Where(f => f.ParentId == parent.Id);
+    }
+
+    public IEnumerable<User> GetDescendantUsers(User parent)
+    {
+        return parent.Traverse(GetChildUsers);
+    }
     
     public Result CreateFolder(Folder folder)
     {

csharp/app/Backend/Database/Installation.cs

@@ -1,8 +1,8 @@
-using Backend.Model;
+using Innovenergy.Backend.Model;
-using Backend.Utils;
+using Innovenergy.Backend.Utils;
 using SQLite;
 
-namespace Backend.Database;
+namespace Innovenergy.Backend.Database;
 
 public partial class Db
 {

csharp/app/Backend/Database/User.cs

@@ -1,18 +1,16 @@
-using System.Net;
 using System.Net.Mail;
 using System.Security.Cryptography;
 using System.Text;
-using System.Text.Json;
-using Backend.Model;
-using Backend.Utils;
 using Flurl.Http;
+using Innovenergy.Backend.Model;
+using Innovenergy.Backend.Utils;
 using InnovEnergy.Lib.Utils;
-using Microsoft.AspNetCore.DataProtection;
 using SQLite;
+
 #pragma warning disable CS0472
 #pragma warning disable CS8602
 
-namespace Backend.Database;
+namespace Innovenergy.Backend.Database;
 
 public partial class Db
 {
@@ -65,9 +63,11 @@ public partial class Db
         const String secret = "S2K1okphiCSNK4mzqr4swguFzngWAMb1OoSlZsJa9F0";
         const String apiKey = "EXOb98ec9008e3ec16e19d7b593";
         var payload = new
-            { name = user.Email, 
+        {
+            name = user.Email,
             operations = new List<String> { "getObject", "listBucket" },
-                content =  new List<Object>{}};
+            content = new List<Object> { }
+        };
 
         var installationIdList = User2Installation
             .Where(i => i.UserId == user.Id)
@@ -140,10 +140,7 @@ public partial class Db
         {
             return false;
         }
+
         return true;
     }
-
-
-
 }
-

csharp/app/Backend/Database/User2Folder.cs

@@ -1,7 +1,7 @@
-using Backend.Model.Relations;
+using Innovenergy.Backend.Model.Relations;
 using SQLite;
 
-namespace Backend.Database;
+namespace Innovenergy.Backend.Database;
 
 public partial class Db
 {

csharp/app/Backend/Database/User2Installation.cs

@@ -1,7 +1,7 @@
-using Backend.Model.Relations;
+using Innovenergy.Backend.Model.Relations;
 using SQLite;
 
-namespace Backend.Database;
+namespace Innovenergy.Backend.Database;
 
 public partial class Db
 {

csharp/app/Backend/HeaderFilter.cs

@@ -0,0 +1,24 @@
+using Microsoft.OpenApi.Models;
+using Swashbuckle.AspNetCore.SwaggerGen;
+
+namespace Innovenergy.Backend;
+
+/// <summary>
+/// This is for convenient testing! Todo throw me out?
+/// Operation filter to add the requirement of the custom header
+/// </summary>
+public class HeaderFilter : IOperationFilter
+{
+    public void Apply(OpenApiOperation operation, OperationFilterContext context)
+    {
+        operation.Parameters ??= new List<OpenApiParameter>();
+
+        operation.Parameters.Add(new OpenApiParameter
+        {
+            Name = "auth",
+            In =  ParameterLocation.Header,
+            Content = new Dictionary<String, OpenApiMediaType>(),
+            Required = false
+        });
+    }
+}

csharp/app/Backend/Model/Folder.cs

@@ -1,6 +1,4 @@
-using SQLite;
+namespace Innovenergy.Backend.Model;
-
-namespace Backend.Model;
 
 public class Folder : TreeNode
 {

csharp/app/Backend/Model/Installation.cs

@@ -1,6 +1,4 @@
-using SQLite;
+namespace Innovenergy.Backend.Model;
-
-namespace Backend.Model;
 
 
 public class Installation : TreeNode

csharp/app/Backend/Model/Relations/Relation.cs

@@ -1,7 +1,7 @@
 using System.Diagnostics.CodeAnalysis;
 using SQLite;
 
-namespace Backend.Model.Relations;
+namespace Innovenergy.Backend.Model.Relations;
 
 public abstract class Relation<L,R>
 {

csharp/app/Backend/Model/Relations/Session.cs

@@ -1,6 +1,6 @@
 using SQLite;
 
-namespace Backend.Model.Relations;
+namespace Innovenergy.Backend.Model.Relations;
 
 public class Session : Relation<String, Int64>
 {

csharp/app/Backend/Model/Relations/User2Folder.cs

@@ -1,6 +1,6 @@
 using SQLite;
 
-namespace Backend.Model.Relations;
+namespace Innovenergy.Backend.Model.Relations;
 
 internal class User2Folder : Relation<Int64, Int64>
 {

csharp/app/Backend/Model/Relations/User2Installation.cs

@@ -1,6 +1,6 @@
 using SQLite;
 
-namespace Backend.Model.Relations;
+namespace Innovenergy.Backend.Model.Relations;
 
 internal class User2Installation : Relation<Int64, Int64>
 {

csharp/app/Backend/Model/TreeNode.cs

@@ -1,7 +1,6 @@
 using SQLite;
 
-
+namespace Innovenergy.Backend.Model;
-namespace Backend.Model;
 
 public abstract class TreeNode
 {

csharp/app/Backend/Model/User.cs

@@ -1,6 +1,6 @@
 using SQLite;
 
-namespace Backend.Model;
+namespace Innovenergy.Backend.Model;
 
 public class User : TreeNode
 {

csharp/app/Backend/Utils/Crypto.cs

@@ -1,6 +1,6 @@
 using System.Security.Cryptography;
 
-namespace Backend.Utils;
+namespace Innovenergy.Backend.Utils;
 
 public static class Crypto
 {

csharp/app/Backend/Utils/Result.cs

@@ -1,4 +1,4 @@
-namespace Backend.Utils;
+namespace Innovenergy.Backend.Utils;
 
 public class Result
 {

csharp/app/Backend/program.cs

@@ -1,15 +1,14 @@
-using Backend.Controllers;
+using Innovenergy.Backend.Database;
-using Backend.Database;
 using Microsoft.OpenApi.Models;
-using Swashbuckle.AspNetCore.SwaggerGen;
 
+namespace Innovenergy.Backend;
 
-using (var db = Db.Connect())
+public class Program
 {
+    public static void Main(string[] args)
+    {
+        using (var db = Db.Connect())
             db.CreateFakeRelations();
-}
-
-
 
         var builder = WebApplication.CreateBuilder(args);
 
@@ -22,11 +21,10 @@ builder.Services.AddCors(o => o.AddDefaultPolicy(p => p.WithOrigins("*").AllowAn
         builder.Services.AddSwaggerGen(config =>
         {
             config.SwaggerDoc("v1", new OpenApiInfo{ Title = "My API", Version = "V1" });
-    config.OperationFilter<MyHeaderFilter>();   //Todo testing throw me out
+            config.OperationFilter<HeaderFilter>();   //Todo testing throw me out
         });
 
 
-
         var app = builder.Build();
 
         // Configure the HTTP request pipeline.
@@ -43,62 +41,19 @@ app.Use(SetSessionUser);
         app.MapControllers();
 
         app.Run();
+    }
 
-
+    private static async Task SetSessionUser(HttpContext ctx, RequestDelegate next)
-
-
-
-
-//================= Functions for above ===================
-
-//Setting User for current Session
-async Task SetSessionUser(HttpContext ctx, RequestDelegate next)
     {
         var headers  = ctx.Request.Headers;
         var hasToken = headers.TryGetValue("auth", out var token);
 
-    if (!ctx.Request.Path.ToString().Contains(nameof(Controller.Login)))
+        if (hasToken)
         {
-        if (!hasToken)
-        {
-            ctx.Response.StatusCode = 403;
-            return;
-        }
-        
             using var db = Db.Connect();
-        var user = db.GetUserByToken(token.ToString());
+            ctx.Items["User"] = db.GetUserByToken(token.ToString());
-
-        if (user is null)
-        {
-            ctx.Response.StatusCode = 403;
-            return;                
-        }
-        
-        ctx.Items["User"] = user;    
         }
 
         await next(ctx);
     }
-
-
-
-
-/// <summary>
-/// This is for convenient testing! Todo throw me out?
-/// Operation filter to add the requirement of the custom header
-/// </summary>
-public class MyHeaderFilter : IOperationFilter
-{
-    public void Apply(OpenApiOperation operation, OperationFilterContext context)
-    {
-        operation.Parameters ??= new List<OpenApiParameter>();
-
-        operation.Parameters.Add(new OpenApiParameter
-        {
-            Name = "auth",
-            In =  ParameterLocation.Header,
-            Content = new Dictionary<String, OpenApiMediaType>(),
-            Required = false
-        });
-    }
 }

csharp/app/CsController/CsController.csproj

@@ -1,15 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-    <Import Project="../InnovEnergy.app.props" />
-
-    <PropertyGroup>
-        <ImplicitUsings>enable</ImplicitUsings>
-        <RootNamespace>InnovEnergy.CsController</RootNamespace>
-        <InvariantGlobalization>true</InvariantGlobalization>
-    </PropertyGroup>
-
-    <ItemGroup>
-      <ProjectReference Include="../../lib/Victron/VeDBus/VeDBus.csproj" />
-    </ItemGroup>
-
-
-</Project>

csharp/app/CsController/Program.cs

@@ -1,62 +0,0 @@
-using System.Reactive.Linq;
-using InnovEnergy.Lib.Protocols.DBus;
-using InnovEnergy.Lib.Protocols.DBus.Protocol.DataTypes;
-using InnovEnergy.Lib.Victron.VeDBus;
-
-
-// dotnet publish EmuMeter.csproj -c Release -r linux-arm -p:PublishSingleFile=true --self-contained true && \
-// rsync -av bin/Release/net6.0/linux-arm/publish/ root@10.2.1.6:/home/root/emu && clear && \
-// ssh root@10.2.1.6 /home/root/emu/EmuMeter
-
-
-Console.WriteLine("Starting CsController ");
-
-//Enable out InnovEnergy GUI Page through DBusService.DBUS_SERVICE_UNSUPPORTED
-// var service = new DBusService("com.victronenergy.unsupported");
-var veProperties = new VeProperties();
-veProperties.Set("/CustomName", "InnovEnergy");
-veProperties.Set("/ProductName", "InnovEnergySW");
-
-
-var dbus = new DBusConnection(Bus.System);
-// var ep = new UnixDomainSocketEndPoint("/home/kim/graber_dbus.sock");
-// var auth = AuthenticationMethod.ExternalAsRoot();
-// var dbusAddress = new Bus(ep, auth);
-// var dbus = new DBusConnection(dbusAddress);
-
-
-await veProperties.PublishOnDBus(Bus.System, "com.victronenergy.unsupported");
-
-var battery = "com.victronenergy.battery.ttyUSB0";
-var soc = 21.0; 
-
-//TODO change ttyUSB0 for generic Battery on dbus
-var names = await dbus.ListNames();
-foreach (var name in names)
-{
-    if(name.Contains("com.victronenergy.battery."))
-    {
-        battery = name;
-        break;
-    }
-}
-
-var mustCharge = dbus
-    .ObserveSignalMessages(sender: battery, objectPath: "/Soc")
-    .Select(m => m.Payload)!
-    .OfType<IDictionary<String, Variant>>()
-    .Where(d => d.ContainsKey("Value"))
-    .Select(d => d["Value"].Value)
-    .OfType<Double>()
-    .Do(s => Console.WriteLine($"soc = {s}"))
-    .Select(d => d < 67)
-    .DistinctUntilChanged();
-
-
-mustCharge.Subscribe(b =>
-{
-    dbus.SetValue("com.victronenergy.settings", "/Settings/CGwacs/BatteryLife/State", b ? 9 : 10);          // 9 = charge battery, 10 = optimized (no batterylife)
-});
-
-
-// Console.ReadLine();

csharp/app/CsController/debug.sh

@@ -1,21 +0,0 @@
-#!/bin/bash
-
-csproj="CsController.csproj"
-exe="CsController"
-remote="10.2.1.6"
-#remote="10.2.2.152"
-
-netVersion="net6.0"
-platform="linux-arm"
-config="Release"
-host="root@$remote"
-dir="/data/innovenergy/$exe"
-
-set -e
-
-dotnet publish "$csproj" -c $config -r $platform -p:SuppressTrimmAnalysisWarnings=true -p:PublishSingleFile=true -p:PublishTrimmed=true -p:DebugType=None -p:DebugSymbols=false --self-contained true 
-rsync -av "bin/$config/$netVersion/$platform/publish/" "$host:$dir" 
-
-clear 
-ssh "$host" "$dir/$exe"
-  

csharp/app/CsController/service/log/run

@@ -1,3 +0,0 @@
-#!/bin/sh
-exec 2>&1
-exec multilog t s25000 n4 /var/log/CsController

csharp/app/CsController/service/run

@@ -1,3 +0,0 @@
-#!/bin/sh
-exec 2>&1
-exec softlimit -d 100000000 -s 1000000 -a 100000000 /opt/innovenergy/CsController/CsController

csharp/app/SaliMax/src/Program.cs

@@ -1,4 +1,4 @@
-#undef BatteriesAllowed 
+
 
 
 using System.Diagnostics;
@@ -11,13 +11,11 @@ using InnovEnergy.Lib.Devices.Trumpf.TruConvertAc;
 using InnovEnergy.Lib.Devices.Trumpf.TruConvertDc;
 using InnovEnergy.Lib.Devices.Ampt;
 using InnovEnergy.Lib.Devices.Battery48TL;
-using InnovEnergy.Lib.Utils;
 using InnovEnergy.SaliMax.Controller;
 using InnovEnergy.SaliMax.Log;
 using InnovEnergy.SaliMax.SaliMaxRelays;
 using InnovEnergy.SaliMax.SystemConfig;
 using InnovEnergy.Time.Unix;
-using Utils = InnovEnergy.Lib.StatusApi.Utils;
 
 
 #pragma warning disable IL2026
@@ -148,7 +146,7 @@ internal static class Program
 
             //JsonSerializer.Serialize(jsonLog, JsonOptions).WriteLine(ConsoleColor.DarkBlue);
 #endif
-            PrintTopology(status);
+            Topology.Print(status);
 
             while (UnixTime.Now == t)
                 await Task.Delay(delayTime);
@@ -157,181 +155,8 @@ internal static class Program
     }
 
 
-    private static void PrintTopology(StatusRecord s)
-    {
-        const String chargingSeparator = ">>>>>>>>>>";
-        const String dischargingSeparator = "<<<<<<<<<";
-        const Int32  height = 25;
 
 
-        var pwr = s.InverterStatus!.Ac.ActivePower;
-        var pvPower = (s.AmptStatus!.Devices[0].Dc.Voltage * s.AmptStatus.Devices[0].Dc.Current + s.AmptStatus!.Devices[1].Dc.Voltage * s.AmptStatus.Devices[1].Dc.Current).Round0(); // TODO using one Ampt
-        var loadPower = Utils.Round3((s.GridMeterStatus!.ActivePowerL123 + pwr)); // it's a + because the pwr is inverted
-
-        var gridSeparator = s.GridMeterStatus!.ActivePowerL123 > 0 ? chargingSeparator : dischargingSeparator;
-        var inverterSeparator = -pwr > 0 ? chargingSeparator : dischargingSeparator;
-        var dcSeparator = -s.DcDcStatus!.Dc.Power > 0 ? chargingSeparator : dischargingSeparator;
-#if BatteriesAllowed        
-        var battery1Separator = s.BatteriesStatus[0]!.Power > 0 ? chargingSeparator : dischargingSeparator;
-        var battery2Separator = s.BatteriesStatus[1]!.Power > 0 ? chargingSeparator : dischargingSeparator;
-#endif
-
-        ////////////////// Grid //////////////////////
-        var boxGrid = AsciiArt.CreateBox
-        (
-            "Grid",
-            s.GridMeterStatus.Ac.L1.Voltage.V(),
-            s.GridMeterStatus.Ac.L2.Voltage.V(),
-            s.GridMeterStatus.Ac.L3.Voltage.V()
-        ).AlignCenterVertical(height);
-
-        var gridAcBusArrow = AsciiArt.CreateHorizontalArrow(s.GridMeterStatus!.ActivePowerL123.Round0(), gridSeparator)
-            .AlignCenterVertical(height);
-
-
-        ////////////////// Ac Bus //////////////////////
-        var boxAcBus = AsciiArt.CreateBox
-        (
-            "AC Bus",
-            s.InverterStatus.Ac.L1.Voltage.V(),
-            s.InverterStatus.Ac.L2.Voltage.V(),
-            s.InverterStatus.Ac.L3.Voltage.V()
-        );
-
-        var boxLoad = AsciiArt.CreateBox
-        (
-            "",
-            "LOAD",
-            ""
-        );
-
-        var loadRect = CreateRect(boxAcBus, boxLoad, loadPower).AlignBottom(height);
-
-        var acBusInvertArrow = AsciiArt.CreateHorizontalArrow(-pwr.Round0(), inverterSeparator)
-            .AlignCenterVertical(height);
-
-        //////////////////// Inverter /////////////////////////
-        var inverterBox = AsciiArt.CreateBox
-        (
-            "",
-            "Inverter",
-            ""
-        ).AlignCenterVertical(height);
-
-        var inverterArrow = AsciiArt.CreateHorizontalArrow(-pwr.Round0(), inverterSeparator)
-            .AlignCenterVertical(height);
-
-
-        //////////////////// DC Bus /////////////////////////
-        var dcBusBox = AsciiArt.CreateBox
-        (
-            "DC Bus",
-            (s.InverterStatus.ActualDcLinkVoltageLowerHalfExt + s.InverterStatus.ActualDcLinkVoltageUpperHalfExt).V(),
-            ""
-        );
-
-        var pvBox = AsciiArt.CreateBox
-        (
-            "MPPT",
-            ((s.AmptStatus!.Devices[0].Dc.Voltage + s.AmptStatus!.Devices[1].Dc.Voltage) / 2).Round0().V(),
-            ""
-        );
-
-        var pvRect = CreateRect(pvBox, dcBusBox, pvPower).AlignTop(height);
-
-        var dcBusArrow = AsciiArt.CreateHorizontalArrow(-s.DcDcStatus!.Dc.Power, dcSeparator)
-            .AlignCenterVertical(height);
-
-        //////////////////// Dc/Dc /////////////////////////
-        var dcBox = AsciiArt.CreateBox
-        (
-            "Dc/Dc",
-            s.DcDcStatus.BatteryVoltage.V(),
-            ""
-        ).AlignCenterVertical(height);
-#if BatteriesAllowed   
-        var dcArrow1 = AsciiArt.CreateHorizontalArrow(s.BatteriesStatus[0]!.Power.Round0(), battery1Separator);
-        var dcArrow2 = AsciiArt.CreateHorizontalArrow(s.BatteriesStatus[1]!.Power.Round0(), battery2Separator);
-#else
-        var dcArrow1 ="";
-        var dcArrow2 = "";
-        var dcArrowRect = CreateRect(dcArrow1, dcArrow2).AlignCenterVertical(height);
-#endif
-
-
-#if BatteriesAllowed   
-        
-        //////////////////// Batteries /////////////////////////
-        var battery1Box = AsciiArt.CreateBox
-        (
-            "Battery 1",
-            s.BatteriesStatus[0].Voltage.V(),
-            s.BatteriesStatus[0].Soc.Percent(),
-            s.BatteriesStatus[0].Temperature.Celsius()
-        );
-
-        var battery2Box = AsciiArt.CreateBox
-        (
-            "Battery 2",
-            s.BatteriesStatus[1].Voltage.V(),
-            s.BatteriesStatus[1].Soc.Percent(),
-            s.BatteriesStatus[1].Temperature.Celsius()
-        );
-        
-        var batteryRect = CreateRect(battery1Box, battery2Box).AlignCenterVertical(height);
-
-        var avgBatteryBox = AsciiArt.CreateBox
-        (
-            "Batteries",
-            s.AvgBatteriesStatus!.Voltage.V(),
-            s.AvgBatteriesStatus.Soc.Percent(),
-            s.AvgBatteriesStatus.Temperature.Celsius()
-        ).AlignCenterVertical(height);
-
-
-        var topology = boxGrid.SideBySideWith(gridAcBusArrow, "")
-                              .SideBySideWith(loadRect, "")
-                              .SideBySideWith(acBusInvertArrow, "")
-                              .SideBySideWith(inverterBox, "")
-                              .SideBySideWith(inverterArrow, "")
-                              .SideBySideWith(pvRect, "")
-                              .SideBySideWith(dcBusArrow, "")
-                              .SideBySideWith(dcBox, "")
-                              .SideBySideWith(dcArrowRect, "")
-                              .SideBySideWith(batteryRect, "")
-                              .SideBySideWith(avgBatteryBox, "")+ "\n";
-#else
-        var topology = boxGrid.SideBySideWith(gridAcBusArrow, "")
-            .SideBySideWith(loadRect, "")
-            .SideBySideWith(acBusInvertArrow, "")
-            .SideBySideWith(inverterBox, "")
-            .SideBySideWith(inverterArrow, "")
-            .SideBySideWith(pvRect, "")
-            .SideBySideWith(dcBusArrow, "")
-            .SideBySideWith(dcBox, "")+ "\n";
-#endif
-        Console.WriteLine(topology);
-    }
-
-    private static String CreateRect(String boxTop, String boxBottom, Decimal power)
-    {
-        var powerArrow = AsciiArt.CreateVerticalArrow(power);
-        var boxes = new[] { boxTop, powerArrow, boxBottom };
-        var maxWidth = boxes.Max(l => l.Width());
-
-        var rect = boxes.Select(l => l.AlignCenterHorizontal(maxWidth)).JoinLines();
-        return rect;
-    }
-
-    private static String CreateRect(String boxTop, String boxBottom)
-    {
-        var boxes = new[] { boxTop, boxBottom };
-        var maxWidth = boxes.Max(l => l.Width());
-
-        var rect = boxes.Select(l => l.AlignCenterHorizontal(maxWidth)).JoinLines();
-        return rect;
-    }
-
     // to delete not used anymore
     [Conditional("RELEASE")]
     private static void ReleaseWriteLog(JsonObject jsonLog, UnixTime timestamp)

csharp/app/SaliMax/src/Topology.cs

@@ -0,0 +1,186 @@
+#undef BatteriesAllowed 
+
+using InnovEnergy.Lib.Utils;
+using InnovEnergy.SaliMax.Controller;
+using InnovEnergy.SaliMax.Log;
+
+namespace InnovEnergy.SaliMax;
+
+public static class Topology
+{
+    public static void Print(StatusRecord s)
+    {
+        const String chargingSeparator = ">>>>>>>>>>";
+        const String dischargingSeparator = "<<<<<<<<<";
+        const Int32  height = 25;
+
+
+        var pwr = s.InverterStatus!.Ac.ActivePower;
+        var pvPower = (s.AmptStatus!.Devices[0].Dc.Voltage * s.AmptStatus.Devices[0].Dc.Current + s.AmptStatus!.Devices[1].Dc.Voltage * s.AmptStatus.Devices[1].Dc.Current).Round0(); // TODO using one Ampt
+        var loadPower = Utils.Round3((s.GridMeterStatus!.ActivePowerL123 + pwr)); // it's a + because the pwr is inverted
+
+        var gridSeparator = s.GridMeterStatus!.ActivePowerL123 > 0 ? chargingSeparator : dischargingSeparator;
+        var inverterSeparator = -pwr > 0 ? chargingSeparator : dischargingSeparator;
+        var dcSeparator = -s.DcDcStatus!.Dc.Power > 0 ? chargingSeparator : dischargingSeparator;
+#if BatteriesAllowed        
+        var battery1Separator = s.BatteriesStatus[0]!.Power > 0 ? chargingSeparator : dischargingSeparator;
+        var battery2Separator = s.BatteriesStatus[1]!.Power > 0 ? chargingSeparator : dischargingSeparator;
+#endif
+
+        ////////////////// Grid //////////////////////
+        var boxGrid = AsciiArt.CreateBox
+        (
+            "Grid",
+            s.GridMeterStatus.Ac.L1.Voltage.V(),
+            s.GridMeterStatus.Ac.L2.Voltage.V(),
+            s.GridMeterStatus.Ac.L3.Voltage.V()
+        ).AlignCenterVertical(height);
+
+        var gridAcBusArrow = AsciiArt.CreateHorizontalArrow(s.GridMeterStatus!.ActivePowerL123.Round0(), gridSeparator)
+            .AlignCenterVertical(height);
+
+
+        ////////////////// Ac Bus //////////////////////
+        var boxAcBus = AsciiArt.CreateBox
+        (
+            "AC Bus",
+            s.InverterStatus.Ac.L1.Voltage.V(),
+            s.InverterStatus.Ac.L2.Voltage.V(),
+            s.InverterStatus.Ac.L3.Voltage.V()
+        );
+
+        var boxLoad = AsciiArt.CreateBox
+        (
+            "",
+            "LOAD",
+            ""
+        );
+
+        var loadRect = StringUtils.AlignBottom(CreateRect(boxAcBus, boxLoad, loadPower), height);
+
+        var acBusInvertArrow = AsciiArt.CreateHorizontalArrow(-pwr.Round0(), inverterSeparator)
+            .AlignCenterVertical(height);
+
+        //////////////////// Inverter /////////////////////////
+        var inverterBox = AsciiArt.CreateBox
+        (
+            "",
+            "Inverter",
+            ""
+        ).AlignCenterVertical(height);
+
+        var inverterArrow = AsciiArt.CreateHorizontalArrow(-pwr.Round0(), inverterSeparator)
+            .AlignCenterVertical(height);
+
+
+        //////////////////// DC Bus /////////////////////////
+        var dcBusBox = AsciiArt.CreateBox
+        (
+            "DC Bus",
+            (s.InverterStatus.ActualDcLinkVoltageLowerHalfExt + s.InverterStatus.ActualDcLinkVoltageUpperHalfExt).V(),
+            ""
+        );
+
+        var pvBox = AsciiArt.CreateBox
+        (
+            "MPPT",
+            ((s.AmptStatus!.Devices[0].Dc.Voltage + s.AmptStatus!.Devices[1].Dc.Voltage) / 2).Round0().V(),
+            ""
+        );
+
+        var pvRect = StringUtils.AlignTop(CreateRect(pvBox, dcBusBox, pvPower), height);
+
+        var dcBusArrow = AsciiArt.CreateHorizontalArrow(-s.DcDcStatus!.Dc.Power, dcSeparator)
+            .AlignCenterVertical(height);
+
+        //////////////////// Dc/Dc /////////////////////////
+        var dcBox = AsciiArt.CreateBox
+        (
+            "Dc/Dc",
+            s.DcDcStatus.BatteryVoltage.V(),
+            ""
+        ).AlignCenterVertical(height);
+#if BatteriesAllowed   
+        var dcArrow1 = AsciiArt.CreateHorizontalArrow(s.BatteriesStatus[0]!.Power.Round0(), battery1Separator);
+        var dcArrow2 = AsciiArt.CreateHorizontalArrow(s.BatteriesStatus[1]!.Power.Round0(), battery2Separator);
+#else
+        var dcArrow1 ="";
+        var dcArrow2 = "";
+        var dcArrowRect = StringUtils.AlignCenterVertical(CreateRect(dcArrow1, dcArrow2), height);
+#endif
+
+
+#if BatteriesAllowed   
+        
+        //////////////////// Batteries /////////////////////////
+        var battery1Box = AsciiArt.CreateBox
+        (
+            "Battery 1",
+            s.BatteriesStatus[0].Voltage.V(),
+            s.BatteriesStatus[0].Soc.Percent(),
+            s.BatteriesStatus[0].Temperature.Celsius()
+        );
+
+        var battery2Box = AsciiArt.CreateBox
+        (
+            "Battery 2",
+            s.BatteriesStatus[1].Voltage.V(),
+            s.BatteriesStatus[1].Soc.Percent(),
+            s.BatteriesStatus[1].Temperature.Celsius()
+        );
+        
+        var batteryRect = CreateRect(battery1Box, battery2Box).AlignCenterVertical(height);
+
+        var avgBatteryBox = AsciiArt.CreateBox
+        (
+            "Batteries",
+            s.AvgBatteriesStatus!.Voltage.V(),
+            s.AvgBatteriesStatus.Soc.Percent(),
+            s.AvgBatteriesStatus.Temperature.Celsius()
+        ).AlignCenterVertical(height);
+
+
+        var topology = boxGrid.SideBySideWith(gridAcBusArrow, "")
+                              .SideBySideWith(loadRect, "")
+                              .SideBySideWith(acBusInvertArrow, "")
+                              .SideBySideWith(inverterBox, "")
+                              .SideBySideWith(inverterArrow, "")
+                              .SideBySideWith(pvRect, "")
+                              .SideBySideWith(dcBusArrow, "")
+                              .SideBySideWith(dcBox, "")
+                              .SideBySideWith(dcArrowRect, "")
+                              .SideBySideWith(batteryRect, "")
+                              .SideBySideWith(avgBatteryBox, "")+ "\n";
+#else
+        var topology = boxGrid.SideBySideWith(gridAcBusArrow, "")
+                              .SideBySideWith(loadRect, "")
+                              .SideBySideWith(acBusInvertArrow, "")
+                              .SideBySideWith(inverterBox, "")
+                              .SideBySideWith(inverterArrow, "")
+                              .SideBySideWith(pvRect, "")
+                              .SideBySideWith(dcBusArrow, "")
+                              .SideBySideWith(dcBox, "")+ "\n";
+#endif
+        Console.WriteLine(topology);
+    }
+    
+    private static String CreateRect(String boxTop, String boxBottom, Decimal power)
+    {
+        var powerArrow = AsciiArt.CreateVerticalArrow(power);
+        var boxes = new[] { boxTop, powerArrow, boxBottom };
+        var maxWidth = boxes.Max(l => l.Width());
+
+        var rect = boxes.Select(l => l.AlignCenterHorizontal(maxWidth)).JoinLines();
+        return rect;
+    }
+
+    private static String CreateRect(String boxTop, String boxBottom)
+    {
+        var boxes = new[] { boxTop, boxBottom };
+        var maxWidth = boxes.Max(l => l.Width());
+
+        var rect = boxes.Select(l => l.AlignCenterHorizontal(maxWidth)).JoinLines();
+        return rect;
+    }
+
+}