Add encryption for Kaigen server auth

src/Managing.Application.Tests/BotsTests.cs

@@ -34,6 +34,7 @@ namespace Managing.Application.Tests
             var discordService = new Mock<IMessengerService>().Object;
             var scenarioService = new Mock<IScenarioService>().Object;
             var messengerService = new Mock<IMessengerService>().Object;
+            var kaigenService = new Mock<IKaigenService>().Object;
             var tradingBotLogger = TradingBaseTests.CreateTradingBotLogger();
             var backtestLogger = TradingBaseTests.CreateBacktesterLogger();
             var botService = new Mock<IBotService>().Object;
@@ -45,7 +46,7 @@ namespace Managing.Application.Tests
                 _tradingService.Object,
                 botService);
             _backtester = new Backtester(_exchangeService, _botFactory, backtestRepository, backtestLogger,
-                scenarioService, _accountService.Object, messengerService);
+                scenarioService, _accountService.Object, messengerService, kaigenService);
             _elapsedTimes = new List<double>();
 
             // Initialize cross-platform file paths

src/Managing.Application.Tests/CryptoHelpersTests.cs

@@ -0,0 +1,39 @@
+using System.Security.Cryptography;
+using Managing.Core;
+using Xunit;
+
+namespace Managing.Application.Tests;
+
+public class CryptoHelpersTests
+{
+    [Fact]
+    public void EncryptAesGcm_And_DecryptAesGcm_RoundTrip_Works()
+    {
+        // Arrange
+        var secretKey = "supersecretkey1234567890123456"; // 32 bytes
+        var token = "0x1234567890abcdef-johndoe";
+
+        // Act
+        var encrypted = CryptoHelpers.EncryptAesGcm(token, secretKey);
+        var decrypted = CryptoHelpers.DecryptAesGcm(encrypted, secretKey);
+
+        // Assert
+        Assert.NotNull(encrypted);
+        Assert.NotEqual(token, encrypted); // Should be encrypted
+        Assert.Equal(token, decrypted); // Should decrypt to original
+    }
+
+    [Fact]
+    public void DecryptAesGcm_WithWrongKey_Throws()
+    {
+        // Arrange
+        var secretKey = "supersecretkey1234567890123456";
+        var wrongKey = "wrongsecretkey6543210987654321";
+        var token = "0xabcdef-jane";
+        var encrypted = CryptoHelpers.EncryptAesGcm(token, secretKey);
+
+        // Act & Assert
+        Assert.Throws<CryptographicException>(() =>
+            CryptoHelpers.DecryptAesGcm(encrypted, wrongKey));
+    }
+}

src/Managing.Core/CryptoHelpers.cs

@@ -0,0 +1,147 @@
+using System.Security.Cryptography;
+using System.Text;
+
+namespace Managing.Core;
+
+/// <summary>
+/// Provides AES-256-CBC encryption utilities with HMAC-SHA256 authentication for secure token generation.
+/// </summary>
+public static class CryptoHelpers
+{
+    /// <summary>
+    /// Encrypts a string using AES-256-CBC encryption with HMAC-SHA256 authentication.
+    /// </summary>
+    /// <param name="plaintext">The text to encrypt</param>
+    /// <param name="secretKey">The secret key for encryption (should be 32 bytes for AES-256)</param>
+    /// <returns>Base64 encoded encrypted data with IV and HMAC</returns>
+    public static string EncryptAesCbc(string plaintext, string secretKey)
+    {
+        if (string.IsNullOrEmpty(plaintext))
+            throw new ArgumentException("Plaintext cannot be null or empty", nameof(plaintext));
+        
+        if (string.IsNullOrEmpty(secretKey))
+            throw new ArgumentException("Secret key cannot be null or empty", nameof(secretKey));
+
+        // Convert secret key to bytes (ensure it's 32 bytes for AES-256)
+        var keyBytes = Encoding.UTF8.GetBytes(secretKey);
+        if (keyBytes.Length != 32)
+        {
+            // If key is not 32 bytes, hash it to get 32 bytes
+            using var sha256 = SHA256.Create();
+            keyBytes = sha256.ComputeHash(keyBytes);
+        }
+
+        // Convert plaintext to bytes
+        var plaintextBytes = Encoding.UTF8.GetBytes(plaintext);
+
+        // Generate a random IV (16 bytes for AES)
+        var iv = new byte[16];
+        using (var rng = RandomNumberGenerator.Create())
+        {
+            rng.GetBytes(iv);
+        }
+
+        // Encrypt using AES-CBC
+        using var aes = Aes.Create();
+        aes.Key = keyBytes;
+        aes.Mode = CipherMode.CBC;
+        aes.Padding = PaddingMode.PKCS7;
+        aes.IV = iv;
+
+        using var encryptor = aes.CreateEncryptor();
+        var ciphertext = encryptor.TransformFinalBlock(plaintextBytes, 0, plaintextBytes.Length);
+
+        // Create HMAC for authentication
+        using var hmac = new HMACSHA256(keyBytes);
+        var hmacBytes = hmac.ComputeHash(ciphertext);
+
+        // Combine IV + encrypted data + HMAC
+        var result = new byte[iv.Length + ciphertext.Length + hmacBytes.Length];
+        Buffer.BlockCopy(iv, 0, result, 0, iv.Length);
+        Buffer.BlockCopy(ciphertext, 0, result, iv.Length, ciphertext.Length);
+        Buffer.BlockCopy(hmacBytes, 0, result, iv.Length + ciphertext.Length, hmacBytes.Length);
+
+        return Convert.ToBase64String(result);
+    }
+
+    /// <summary>
+    /// Decrypts a string using AES-256-CBC decryption with HMAC-SHA256 authentication.
+    /// </summary>
+    /// <param name="encryptedData">Base64 encoded encrypted data with IV and HMAC</param>
+    /// <param name="secretKey">The secret key for decryption (should be 32 bytes for AES-256)</param>
+    /// <returns>The decrypted plaintext</returns>
+    public static string DecryptAesCbc(string encryptedData, string secretKey)
+    {
+        if (string.IsNullOrEmpty(encryptedData))
+            throw new ArgumentException("Encrypted data cannot be null or empty", nameof(encryptedData));
+        
+        if (string.IsNullOrEmpty(secretKey))
+            throw new ArgumentException("Secret key cannot be null or empty", nameof(secretKey));
+
+        // Convert secret key to bytes (ensure it's 32 bytes for AES-256)
+        var keyBytes = Encoding.UTF8.GetBytes(secretKey);
+        if (keyBytes.Length != 32)
+        {
+            // If key is not 32 bytes, hash it to get 32 bytes
+            using var sha256 = SHA256.Create();
+            keyBytes = sha256.ComputeHash(keyBytes);
+        }
+
+        // Decode the base64 data
+        var encryptedBytes = Convert.FromBase64String(encryptedData);
+
+        // Extract IV (first 16 bytes), HMAC (last 32 bytes), and ciphertext (middle)
+        if (encryptedBytes.Length < 48) // 16 (IV) + 32 (HMAC) = minimum 48 bytes
+            throw new ArgumentException("Encrypted data is too short", nameof(encryptedData));
+
+        var iv = new byte[16];
+        var hmacBytes = new byte[32];
+        var ciphertext = new byte[encryptedBytes.Length - 48];
+
+        Buffer.BlockCopy(encryptedBytes, 0, iv, 0, 16);
+        Buffer.BlockCopy(encryptedBytes, encryptedBytes.Length - 32, hmacBytes, 0, 32);
+        Buffer.BlockCopy(encryptedBytes, 16, ciphertext, 0, ciphertext.Length);
+
+        // Verify HMAC for authentication
+        using var hmac = new HMACSHA256(keyBytes);
+        var computedHmac = hmac.ComputeHash(ciphertext);
+        
+        if (!computedHmac.SequenceEqual(hmacBytes))
+        {
+            throw new CryptographicException("HMAC verification failed - data may have been tampered with");
+        }
+
+        // Decrypt using AES-CBC
+        using var aes = Aes.Create();
+        aes.Key = keyBytes;
+        aes.Mode = CipherMode.CBC;
+        aes.Padding = PaddingMode.PKCS7;
+        aes.IV = iv;
+
+        using var decryptor = aes.CreateDecryptor();
+        var decryptedBytes = decryptor.TransformFinalBlock(ciphertext, 0, ciphertext.Length);
+        return Encoding.UTF8.GetString(decryptedBytes);
+    }
+
+    /// <summary>
+    /// Encrypts a string using AES-256-CBC encryption (alias for EncryptAesCbc for backward compatibility).
+    /// </summary>
+    /// <param name="plaintext">The text to encrypt</param>
+    /// <param name="secretKey">The secret key for encryption</param>
+    /// <returns>Base64 encoded encrypted data</returns>
+    public static string EncryptAesGcm(string plaintext, string secretKey)
+    {
+        return EncryptAesCbc(plaintext, secretKey);
+    }
+
+    /// <summary>
+    /// Decrypts a string using AES-256-CBC decryption (alias for DecryptAesCbc for backward compatibility).
+    /// </summary>
+    /// <param name="encryptedData">Base64 encoded encrypted data</param>
+    /// <param name="secretKey">The secret key for decryption</param>
+    /// <returns>The decrypted plaintext</returns>
+    public static string DecryptAesGcm(string encryptedData, string secretKey)
+    {
+        return DecryptAesCbc(encryptedData, secretKey);
+    }
+} 

src/Managing.Infrastructure.Web3/Managing.Infrastructure.Evm.csproj

@@ -25,6 +25,7 @@
         <ProjectReference Include="..\Managing.ABI.GmxV2\Managing.ABI.GmxV2.csproj"/>
         <ProjectReference Include="..\Managing.Application.Abstractions\Managing.Application.Abstractions.csproj"/>
         <ProjectReference Include="..\Managing.Application\Managing.Application.csproj" />
+        <ProjectReference Include="..\Managing.Core\Managing.Core.csproj"/>
         <ProjectReference Include="..\Managing.Tools.ABI\Managing.Tools.ABI.csproj"/>
     </ItemGroup>
 

src/Managing.Infrastructure.Web3/Services/KaigenService.cs

@@ -1,23 +1,25 @@
+using System.Net.Http.Headers;
 using System.Net.Http.Json;
+using System.Text;
 using System.Text.Json;
 using Managing.Application.Abstractions.Services;
+using Managing.Core;
 using Managing.Domain.Users;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
-using Nethereum.Signer;
 
 namespace Managing.Infrastructure.Evm.Services;
 
 /// <summary>
 /// Configuration settings for Kaigen credit management service.
-/// The PrivateKey should be set via the KAIGEN_PRIVATE_KEY environment variable for security.
+/// The SecretKey should be set via the KAIGEN_SECRET_KEY environment variable for security.
 /// </summary>
 public class KaigenSettings
 {
     public string BaseUrl { get; set; } = "https://api.kaigen.managing.live";
     public string DebitEndpoint { get; set; } = "/api/credits/debit";
     public string RefundEndpoint { get; set; } = "/api/credits/refund";
-    public string PrivateKey { get; set; } = string.Empty;
+    public string SecretKey { get; set; } = string.Empty;
 }
 
 public class KaigenService : IKaigenService
@@ -45,22 +47,22 @@ public class KaigenService : IKaigenService
         if (!_creditsEnabled)
         {
             _logger.LogInformation("Kaigen credits are disabled via KAIGEN_CREDITS_ENABLED environment variable");
-            return; // Skip private key validation if credits are disabled
+            return; // Skip secret key validation if credits are disabled
         }
 
         // Always read from environment variable for security
-        var envPrivateKey = Environment.GetEnvironmentVariable("KAIGEN_PRIVATE_KEY");
-        if (!string.IsNullOrEmpty(envPrivateKey))
+        var envSecretKey = Environment.GetEnvironmentVariable("KAIGEN_SECRET_KEY");
+        if (!string.IsNullOrEmpty(envSecretKey))
         {
-            _settings.PrivateKey = envPrivateKey;
-            _logger.LogInformation("Using KAIGEN_PRIVATE_KEY from environment variable");
+            _settings.SecretKey = envSecretKey;
+            _logger.LogInformation("Using KAIGEN_SECRET_KEY from environment variable");
         }
 
         // Validate required settings only if credits are enabled
-        if (string.IsNullOrEmpty(_settings.PrivateKey))
+        if (string.IsNullOrEmpty(_settings.SecretKey))
         {
             throw new InvalidOperationException(
-                "Kaigen PrivateKey is not configured. Please set the KAIGEN_PRIVATE_KEY environment variable.");
+                "Kaigen SecretKey is not configured. Please set the KAIGEN_SECRET_KEY environment variable.");
         }
 
         if (string.IsNullOrEmpty(_settings.BaseUrl))
@@ -86,29 +88,22 @@ public class KaigenService : IKaigenService
             var walletAddress = GetUserWalletAddress(user);
             var requestId = Guid.NewGuid().ToString();
 
-            // Create the message to sign (concatenate the values)
-            var message = $"{requestId}{walletAddress}{debitAmount}";
-
-            // Sign the message
-            var signature = SignMessage(message, _settings.PrivateKey);
-
             // Create the request payload
             var requestPayload = new
             {
                 requestId = requestId,
                 walletAddress = walletAddress,
-                debitAmount = debitAmount,
-                signature = signature
+                debitAmount = debitAmount
             };
 
             _logger.LogInformation(
                 "Debiting {Amount} credits for user {UserName} (wallet: {WalletAddress}) with request ID {RequestId}",
                 debitAmount, user.Name, walletAddress, requestId);
 
-            var response = await _httpClient.PutAsJsonAsync(
+            var response = await SendAuthenticatedRequestAsync(
                 $"{_settings.BaseUrl}{_settings.DebitEndpoint}",
                 requestPayload,
-                _jsonOptions);
+                user);
 
             if (!response.IsSuccessStatusCode)
             {
@@ -146,28 +141,21 @@ public class KaigenService : IKaigenService
         {
             var walletAddress = GetUserWalletAddress(user);
 
-            // Create the message to sign (concatenate the values)
-            var message = $"{requestId}{walletAddress}";
-
-            // Sign the message
-            var signature = SignMessage(message, _settings.PrivateKey);
-
             // Create the request payload
             var requestPayload = new
             {
                 requestId = requestId,
-                walletAddress = walletAddress,
-                signature = signature
+                walletAddress = walletAddress
             };
 
             _logger.LogInformation(
                 "Refunding credits for user {UserName} (wallet: {WalletAddress}) with request ID {RequestId}",
                 user.Name, walletAddress, requestId);
 
-            var response = await _httpClient.PutAsJsonAsync(
+            var response = await SendAuthenticatedRequestAsync(
                 $"{_settings.BaseUrl}{_settings.RefundEndpoint}",
                 requestPayload,
-                _jsonOptions);
+                user);
 
             if (!response.IsSuccessStatusCode)
             {
@@ -188,6 +176,28 @@ public class KaigenService : IKaigenService
         }
     }
 
+    private async Task<HttpResponseMessage> SendAuthenticatedRequestAsync(string url, object payload, User user)
+    {
+        // Create the auth token: "walletaddress-username"
+        var authToken = $"{GetUserWalletAddress(user)}-{user.Name}";
+        
+        // Encrypt the auth token using AES-256-GCM
+        var encryptedToken = CryptoHelpers.EncryptAesGcm(authToken, _settings.SecretKey);
+        
+        // Create Basic Auth header with the encrypted token
+        var basicAuthString = $"{encryptedToken}:";
+        var base64Auth = Convert.ToBase64String(Encoding.ASCII.GetBytes(basicAuthString));
+        
+        // Create a new request with the auth header
+        var request = new HttpRequestMessage(HttpMethod.Put, url)
+        {
+            Content = JsonContent.Create(payload, options: _jsonOptions)
+        };
+        request.Headers.Authorization = new AuthenticationHeaderValue("Basic", base64Auth);
+        
+        return await _httpClient.SendAsync(request);
+    }
+
     private string GetUserWalletAddress(User user)
     {
         if (user?.Accounts == null || !user.Accounts.Any())
@@ -206,13 +216,6 @@ public class KaigenService : IKaigenService
         return walletAddress;
     }
 
-    private string SignMessage(string message, string privateKey)
-    {
-        var signer = new EthereumMessageSigner();
-        var signature = signer.EncodeUTF8AndSign(message, new EthECKey(privateKey));
-        return signature;
-    }
-
     private class KaigenResponse
     {
         public bool Success { get; set; }