Updated Structure, and fixed paths.
- Project does not work still in this version as communication is still not happening between Client/Server/Core. Fake UI is still somewhat needed to progress
This commit is contained in:
@@ -1,7 +1,7 @@
|
|||||||
using System.Security.Cryptography;
|
using System.Security.Cryptography;
|
||||||
using System.Text;
|
using System.Text;
|
||||||
|
|
||||||
namespace RelayCore;
|
namespace RelayClient.Crypto;
|
||||||
|
|
||||||
public static class E2EeHelper
|
public static class E2EeHelper
|
||||||
{
|
{
|
||||||
20
RelayClient/Crypto/KeyStorage.cs
Normal file
20
RelayClient/Crypto/KeyStorage.cs
Normal file
@@ -0,0 +1,20 @@
|
|||||||
|
namespace RelayClient.Crypto;
|
||||||
|
|
||||||
|
public static class KeyStorage
|
||||||
|
{
|
||||||
|
public static void SavePrivateKey(string username, string privateKey)
|
||||||
|
{
|
||||||
|
Directory.CreateDirectory("keys");
|
||||||
|
File.WriteAllText(Path.Combine("keys", $"{username}.private.key"), privateKey);
|
||||||
|
}
|
||||||
|
|
||||||
|
public static string LoadPrivateKey(string username)
|
||||||
|
{
|
||||||
|
return File.ReadAllText(Path.Combine("keys", $"{username}.private.key"));
|
||||||
|
}
|
||||||
|
|
||||||
|
public static bool PrivateKeyExists(string username)
|
||||||
|
{
|
||||||
|
return File.Exists(Path.Combine("keys", $"{username}.private.key"));
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -41,6 +41,7 @@
|
|||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<PackageReference Include="Microsoft.Maui.Controls" Version="$(MauiVersion)" />
|
<PackageReference Include="Microsoft.Maui.Controls" Version="$(MauiVersion)" />
|
||||||
<PackageReference Include="Microsoft.Extensions.Logging.Debug" Version="10.0.0" />
|
<PackageReference Include="Microsoft.Extensions.Logging.Debug" Version="10.0.0" />
|
||||||
|
<PackageReference Include="SurrealDb.Net" Version="0.9.0" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
|
|
||||||
</Project>
|
</Project>
|
||||||
|
|||||||
14
RelayCore/Models/AuthAudits.cs
Normal file
14
RelayCore/Models/AuthAudits.cs
Normal file
@@ -0,0 +1,14 @@
|
|||||||
|
using SurrealDb.Net.Models;
|
||||||
|
|
||||||
|
namespace RelayCore.Models;
|
||||||
|
|
||||||
|
public class AuthAudits : Record
|
||||||
|
{
|
||||||
|
public required string UserId { get; set; }
|
||||||
|
public required int EventType { get; set; }
|
||||||
|
public bool Success { get; set; }
|
||||||
|
public required string IpAddress { get; set; }
|
||||||
|
public required string UserAgent { get; set; }
|
||||||
|
public required string Details { get; set; }
|
||||||
|
public required DateTime CreatedAt { get; set; }
|
||||||
|
}
|
||||||
15
RelayCore/Models/Licenses.cs
Normal file
15
RelayCore/Models/Licenses.cs
Normal file
@@ -0,0 +1,15 @@
|
|||||||
|
using SurrealDb.Net.Models;
|
||||||
|
|
||||||
|
namespace RelayCore.Models;
|
||||||
|
|
||||||
|
public class Licenses : Record
|
||||||
|
{
|
||||||
|
public required string UserId { get; set; }
|
||||||
|
public required int LicenseType { get; set; }
|
||||||
|
public required int Status { get; set; }
|
||||||
|
public required DateTime CreatedAt { get; set; }
|
||||||
|
public required DateTime StartsAt { get; set; }
|
||||||
|
public required DateTime UpdatedAt { get; set; }
|
||||||
|
public required DateTime ExpiresAt { get; set; }
|
||||||
|
|
||||||
|
}
|
||||||
8
RelayCore/Models/PasswordHash.cs
Normal file
8
RelayCore/Models/PasswordHash.cs
Normal file
@@ -0,0 +1,8 @@
|
|||||||
|
using SurrealDb.Net.Models;
|
||||||
|
|
||||||
|
namespace RelayCore.Models;
|
||||||
|
|
||||||
|
public class PasswordHash : Record
|
||||||
|
{
|
||||||
|
public string? Password { get; set; }
|
||||||
|
}
|
||||||
@@ -1,9 +1,8 @@
|
|||||||
using System;
|
using System.Security.Cryptography;
|
||||||
using System.Security.Cryptography;
|
|
||||||
using System.Text;
|
using System.Text;
|
||||||
using Konscious.Security.Cryptography;
|
using Konscious.Security.Cryptography;
|
||||||
|
|
||||||
namespace PasswordHasher
|
namespace RelayCore.Models
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Provides secure password hashing functionality using Argon2id algorithm
|
/// Provides secure password hashing functionality using Argon2id algorithm
|
||||||
|
|||||||
12
RelayCore/Models/PasswordReset.cs
Normal file
12
RelayCore/Models/PasswordReset.cs
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
using SurrealDb.Net.Models;
|
||||||
|
|
||||||
|
namespace RelayCore.Models;
|
||||||
|
|
||||||
|
public class PasswordReset : Record
|
||||||
|
{
|
||||||
|
public required string UserId { get; set; }
|
||||||
|
public required string TokenHash { get; set; }
|
||||||
|
public required DateTime CreatedAt { get; set; }
|
||||||
|
public required DateTime ExpiresAt { get; set; }
|
||||||
|
public bool Revoked { get; set; }
|
||||||
|
}
|
||||||
16
RelayCore/Models/Sessions.cs
Normal file
16
RelayCore/Models/Sessions.cs
Normal file
@@ -0,0 +1,16 @@
|
|||||||
|
using SurrealDb.Net.Models;
|
||||||
|
|
||||||
|
namespace RelayCore.Models;
|
||||||
|
|
||||||
|
public class Sessions : Record
|
||||||
|
{
|
||||||
|
public required string UserId { get; set; }
|
||||||
|
public required string TokenHash { get; set; }
|
||||||
|
public required DateTime IssuedAt { get; set; }
|
||||||
|
public required DateTime ExpiresAt { get; set; }
|
||||||
|
public DateTime? LastUsedAt { get; set; }
|
||||||
|
public bool Revoked { get; set; }
|
||||||
|
public required string DeviceName { get; set; }
|
||||||
|
public required string IpAddress { get; set; }
|
||||||
|
public required string UserAgent { get; set; }
|
||||||
|
}
|
||||||
17
RelayCore/Models/Users.cs
Normal file
17
RelayCore/Models/Users.cs
Normal file
@@ -0,0 +1,17 @@
|
|||||||
|
using SurrealDb.Net.Models;
|
||||||
|
|
||||||
|
namespace RelayCore.Models;
|
||||||
|
|
||||||
|
public class Users : Record
|
||||||
|
{
|
||||||
|
public required string Username { get; set; }
|
||||||
|
public string? Password { get; set; }
|
||||||
|
public required string Email { get; set; }
|
||||||
|
public required DateTime CreatedAt { get; set; }
|
||||||
|
public required DateTime UpdatedAt { get; set; }
|
||||||
|
public required DateTime LastLogin { get; set; }
|
||||||
|
public bool TwoFactorEnabled { get; set; }
|
||||||
|
public bool EmailVerified { get; set; }
|
||||||
|
public required int AccountStatus { get; set; }
|
||||||
|
public required int OnlineStatus { get; set; }
|
||||||
|
}
|
||||||
@@ -2,10 +2,11 @@
|
|||||||
using SurrealDb.Net.Models;
|
using SurrealDb.Net.Models;
|
||||||
using SurrealDb.Net.Models.Auth;
|
using SurrealDb.Net.Models.Auth;
|
||||||
using System.Text.Json;
|
using System.Text.Json;
|
||||||
using PasswordHasher;
|
|
||||||
using RelayCore;
|
using RelayCore;
|
||||||
|
using RelayCore.Enums;
|
||||||
|
using RelayCore.Models;
|
||||||
|
|
||||||
using var db = new SurrealDbClient("ws://127.0.0.1:8000/rpc");
|
await using var db = new SurrealDbClient("ws://127.0.0.1:8000/rpc");
|
||||||
|
|
||||||
await db.SignIn(new RootAuth { Username = "root", Password = "secret" });
|
await db.SignIn(new RootAuth { Username = "root", Password = "secret" });
|
||||||
await db.Use("test", "test");
|
await db.Use("test", "test");
|
||||||
@@ -16,76 +17,6 @@ var kira = await CreateUserAsync(db, "Ru_Kira", "jduesling13@gmail.com", "passwo
|
|||||||
Console.WriteLine($"Keeper created: {ToJsonString(keeper)}");
|
Console.WriteLine($"Keeper created: {ToJsonString(keeper)}");
|
||||||
Console.WriteLine($"Kira created: {ToJsonString(kira)}");
|
Console.WriteLine($"Kira created: {ToJsonString(kira)}");
|
||||||
|
|
||||||
var keeperKeys = E2EeHelper.GenerateRsaKeyPair();
|
|
||||||
var kiraKeys = E2EeHelper.GenerateRsaKeyPair();
|
|
||||||
|
|
||||||
KeyStorage.SavePrivateKey("Keeper317", keeperKeys.privateKey);
|
|
||||||
KeyStorage.SavePrivateKey("Ru_Kira", kiraKeys.privateKey);
|
|
||||||
|
|
||||||
await db.Create("user_keys", new UserKeys
|
|
||||||
{
|
|
||||||
UserId = keeper.Id.ToString(),
|
|
||||||
PublicKey = keeperKeys.publicKey,
|
|
||||||
CreatedAt = DateTime.UtcNow,
|
|
||||||
UpdatedAt = DateTime.UtcNow
|
|
||||||
});
|
|
||||||
|
|
||||||
await db.Create("user_keys", new UserKeys
|
|
||||||
{
|
|
||||||
UserId = kira.Id.ToString(),
|
|
||||||
PublicKey = kiraKeys.publicKey,
|
|
||||||
CreatedAt = DateTime.UtcNow,
|
|
||||||
UpdatedAt = DateTime.UtcNow
|
|
||||||
});
|
|
||||||
|
|
||||||
Console.WriteLine("Public keys stored for both users.");
|
|
||||||
|
|
||||||
var conversation = await db.Create("conversations", new Conversations
|
|
||||||
{
|
|
||||||
CreatedByUserId = keeper.Id.ToString(),
|
|
||||||
CreatedAt = DateTime.UtcNow,
|
|
||||||
UpdatedAt = DateTime.UtcNow,
|
|
||||||
Title = "Keeper317 + Ru_Kira",
|
|
||||||
IsDirectMessage = true
|
|
||||||
});
|
|
||||||
|
|
||||||
Console.WriteLine($"Conversation created: {ToJsonString(conversation)}");
|
|
||||||
|
|
||||||
await db.Create("conversation_members", new ConversationMembers
|
|
||||||
{
|
|
||||||
ConversationId = conversation.Id.ToString(),
|
|
||||||
UserId = keeper.Id.ToString(),
|
|
||||||
JoinedAt = DateTime.UtcNow
|
|
||||||
});
|
|
||||||
|
|
||||||
await db.Create("conversation_members", new ConversationMembers
|
|
||||||
{
|
|
||||||
ConversationId = conversation.Id.ToString(),
|
|
||||||
UserId = kira.Id.ToString(),
|
|
||||||
JoinedAt = DateTime.UtcNow
|
|
||||||
});
|
|
||||||
|
|
||||||
Console.WriteLine("Conversation members added.");
|
|
||||||
|
|
||||||
var encrypted = E2EeHelper.EncryptForRecipient("hello from Keeper317", kiraKeys.publicKey);
|
|
||||||
|
|
||||||
var savedMessage = await db.Create("messages", new Messages
|
|
||||||
{
|
|
||||||
ConversationId = conversation.Id.ToString(),
|
|
||||||
SenderUserId = keeper.Id.ToString(),
|
|
||||||
RecipientUserId = kira.Id.ToString(),
|
|
||||||
CipherText = encrypted.CipherText,
|
|
||||||
Nonce = encrypted.Nonce,
|
|
||||||
Tag = encrypted.Tag,
|
|
||||||
EncryptedKey = encrypted.EncryptedKey,
|
|
||||||
CreatedAt = DateTime.UtcNow
|
|
||||||
});
|
|
||||||
|
|
||||||
Console.WriteLine($"Encrypted message saved: {ToJsonString(savedMessage)}");
|
|
||||||
|
|
||||||
var decrypted = E2EeHelper.DecryptForRecipient(encrypted, kiraKeys.privateKey);
|
|
||||||
Console.WriteLine($"Decrypted for Ru_Kira: {decrypted}");
|
|
||||||
|
|
||||||
return;
|
return;
|
||||||
|
|
||||||
static string ToJsonString(object? o)
|
static string ToJsonString(object? o)
|
||||||
@@ -112,7 +43,7 @@ static async Task<Users> CreateUserAsync(SurrealDbClient db, string username, st
|
|||||||
|
|
||||||
var created = await db.Create("users", user);
|
var created = await db.Create("users", user);
|
||||||
|
|
||||||
var hasher = new PasswordHasher.PasswordHasher();
|
var hasher = new PasswordHasher();
|
||||||
var passwordHash = hasher.HashPassword(created.Id.ToString() + rawPassword);
|
var passwordHash = hasher.HashPassword(created.Id.ToString() + rawPassword);
|
||||||
|
|
||||||
var updated = await db.Merge<PasswordHash, Users>(new PasswordHash
|
var updated = await db.Merge<PasswordHash, Users>(new PasswordHash
|
||||||
@@ -123,176 +54,3 @@ static async Task<Users> CreateUserAsync(SurrealDbClient db, string username, st
|
|||||||
|
|
||||||
return updated;
|
return updated;
|
||||||
}
|
}
|
||||||
|
|
||||||
public static class KeyStorage
|
|
||||||
{
|
|
||||||
public static void SavePrivateKey(string username, string privateKey)
|
|
||||||
{
|
|
||||||
Directory.CreateDirectory("keys");
|
|
||||||
File.WriteAllText(Path.Combine("keys", $"{username}.private.key"), privateKey);
|
|
||||||
}
|
|
||||||
|
|
||||||
public static string LoadPrivateKey(string username)
|
|
||||||
{
|
|
||||||
return File.ReadAllText(Path.Combine("keys", $"{username}.private.key"));
|
|
||||||
}
|
|
||||||
|
|
||||||
public static bool PrivateKeyExists(string username)
|
|
||||||
{
|
|
||||||
return File.Exists(Path.Combine("keys", $"{username}.private.key"));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public class ResponsibilityMerge : Record
|
|
||||||
{
|
|
||||||
public bool Marketing { get; set; }
|
|
||||||
}
|
|
||||||
public class Group
|
|
||||||
{
|
|
||||||
public bool Marketing { get; set; }
|
|
||||||
public int Count { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
public class Users : Record
|
|
||||||
{
|
|
||||||
public required string Username { get; set; }
|
|
||||||
public string? Password { get; set; }
|
|
||||||
public required string Email { get; set; }
|
|
||||||
public required DateTime CreatedAt { get; set; }
|
|
||||||
public required DateTime UpdatedAt { get; set; }
|
|
||||||
public required DateTime LastLogin { get; set; }
|
|
||||||
public bool TwoFactorEnabled { get; set; }
|
|
||||||
public bool EmailVerified { get; set; }
|
|
||||||
public required int AccountStatus { get; set; }
|
|
||||||
public required int OnlineStatus { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
public class PasswordHash : Record
|
|
||||||
{
|
|
||||||
public string? Password { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
public class Sessions : Record
|
|
||||||
{
|
|
||||||
public required string UserId { get; set; }
|
|
||||||
public required string TokenHash { get; set; }
|
|
||||||
public required DateTime IssuedAt { get; set; }
|
|
||||||
public required DateTime ExpiresAt { get; set; }
|
|
||||||
public DateTime? LastUsedAt { get; set; }
|
|
||||||
public bool Revoked { get; set; }
|
|
||||||
public required string DeviceName { get; set; }
|
|
||||||
public required string IpAddress { get; set; }
|
|
||||||
public required string UserAgent { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
public class PasswordReset : Record
|
|
||||||
{
|
|
||||||
public required string UserId { get; set; }
|
|
||||||
public required string TokenHash { get; set; }
|
|
||||||
public required DateTime CreatedAt { get; set; }
|
|
||||||
public required DateTime ExpiresAt { get; set; }
|
|
||||||
public bool Revoked { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
public class Licenses : Record
|
|
||||||
{
|
|
||||||
public required string UserId { get; set; }
|
|
||||||
public required int LicenseType { get; set; }
|
|
||||||
public required int Status { get; set; }
|
|
||||||
public required DateTime CreatedAt { get; set; }
|
|
||||||
public required DateTime StartsAt { get; set; }
|
|
||||||
public required DateTime UpdatedAt { get; set; }
|
|
||||||
public required DateTime ExpiresAt { get; set; }
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
public class AuthAudits : Record
|
|
||||||
{
|
|
||||||
public required string UserId { get; set; }
|
|
||||||
public required int EventType { get; set; }
|
|
||||||
public bool Success { get; set; }
|
|
||||||
public required string IpAddress { get; set; }
|
|
||||||
public required string UserAgent { get; set; }
|
|
||||||
public required string Details { get; set; }
|
|
||||||
public required DateTime CreatedAt { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
public class UserKeys : Record
|
|
||||||
{
|
|
||||||
public required string UserId { get; set; }
|
|
||||||
public required string PublicKey { get; set; }
|
|
||||||
public required DateTime CreatedAt { get; set; }
|
|
||||||
public required DateTime UpdatedAt { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
public class Conversations : Record
|
|
||||||
{
|
|
||||||
public required string CreatedByUserId { get; set; }
|
|
||||||
public required DateTime CreatedAt { get; set; }
|
|
||||||
public required DateTime UpdatedAt { get; set; }
|
|
||||||
public string? Title { get; set; }
|
|
||||||
public bool IsDirectMessage { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
public class ConversationMembers : Record
|
|
||||||
{
|
|
||||||
public required string ConversationId { get; set; }
|
|
||||||
public required string UserId { get; set; }
|
|
||||||
public required DateTime JoinedAt { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
public class Messages : Record
|
|
||||||
{
|
|
||||||
public required string ConversationId { get; set; }
|
|
||||||
public required string SenderUserId { get; set; }
|
|
||||||
public required string RecipientUserId { get; set; }
|
|
||||||
public required string CipherText { get; set; }
|
|
||||||
public required string Nonce { get; set; }
|
|
||||||
public required string Tag { get; set; }
|
|
||||||
public required string EncryptedKey { get; set; }
|
|
||||||
public required DateTime CreatedAt { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
enum AccountStatuses
|
|
||||||
{
|
|
||||||
Active,
|
|
||||||
Suspended,
|
|
||||||
Banned,
|
|
||||||
Deleted
|
|
||||||
}
|
|
||||||
|
|
||||||
enum OnlineStatuses
|
|
||||||
{
|
|
||||||
Online,
|
|
||||||
Busy,
|
|
||||||
DND,
|
|
||||||
Invisible,
|
|
||||||
Offline
|
|
||||||
}
|
|
||||||
|
|
||||||
enum LicenseStatuses
|
|
||||||
{
|
|
||||||
Active,
|
|
||||||
Expired,
|
|
||||||
Renewable,
|
|
||||||
Revoked
|
|
||||||
}
|
|
||||||
|
|
||||||
enum LicenseType
|
|
||||||
{
|
|
||||||
Free,
|
|
||||||
Basic,
|
|
||||||
Advanced,
|
|
||||||
Pro,
|
|
||||||
Enterprise
|
|
||||||
}
|
|
||||||
|
|
||||||
enum LogEvents
|
|
||||||
{
|
|
||||||
LoginSuccess,
|
|
||||||
LoginFailure,
|
|
||||||
LogoutSuccess,
|
|
||||||
LogoutFailure,
|
|
||||||
PasswordResetSuccess,
|
|
||||||
PasswordResetFailure,
|
|
||||||
}
|
|
||||||
10
RelayServer/Models/ConversationMembers.cs
Normal file
10
RelayServer/Models/ConversationMembers.cs
Normal file
@@ -0,0 +1,10 @@
|
|||||||
|
using SurrealDb.Net.Models;
|
||||||
|
|
||||||
|
namespace RelayServer.Models;
|
||||||
|
|
||||||
|
public class ConversationMembers : Record
|
||||||
|
{
|
||||||
|
public required string ConversationId { get; set; }
|
||||||
|
public required string UserId { get; set; }
|
||||||
|
public required DateTime JoinedAt { get; set; }
|
||||||
|
}
|
||||||
12
RelayServer/Models/Conversations.cs
Normal file
12
RelayServer/Models/Conversations.cs
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
using SurrealDb.Net.Models;
|
||||||
|
|
||||||
|
namespace RelayServer.Models;
|
||||||
|
|
||||||
|
public class Conversations : Record
|
||||||
|
{
|
||||||
|
public required string CreatedByUserId { get; set; }
|
||||||
|
public required DateTime CreatedAt { get; set; }
|
||||||
|
public required DateTime UpdatedAt { get; set; }
|
||||||
|
public string? Title { get; set; }
|
||||||
|
public bool IsDirectMessage { get; set; }
|
||||||
|
}
|
||||||
15
RelayServer/Models/Messages.cs
Normal file
15
RelayServer/Models/Messages.cs
Normal file
@@ -0,0 +1,15 @@
|
|||||||
|
using SurrealDb.Net.Models;
|
||||||
|
|
||||||
|
namespace RelayServer.Models;
|
||||||
|
|
||||||
|
public class Messages : Record
|
||||||
|
{
|
||||||
|
public required string ConversationId { get; set; }
|
||||||
|
public required string SenderUserId { get; set; }
|
||||||
|
public required string RecipientUserId { get; set; }
|
||||||
|
public required string CipherText { get; set; }
|
||||||
|
public required string Nonce { get; set; }
|
||||||
|
public required string Tag { get; set; }
|
||||||
|
public required string EncryptedKey { get; set; }
|
||||||
|
public required DateTime CreatedAt { get; set; }
|
||||||
|
}
|
||||||
11
RelayServer/Models/UserKeys.cs
Normal file
11
RelayServer/Models/UserKeys.cs
Normal file
@@ -0,0 +1,11 @@
|
|||||||
|
using SurrealDb.Net.Models;
|
||||||
|
|
||||||
|
namespace RelayServer.Models;
|
||||||
|
|
||||||
|
public class UserKeys : Record
|
||||||
|
{
|
||||||
|
public required string UserId { get; set; }
|
||||||
|
public required string PublicKey { get; set; }
|
||||||
|
public required DateTime CreatedAt { get; set; }
|
||||||
|
public required DateTime UpdatedAt { get; set; }
|
||||||
|
}
|
||||||
@@ -7,4 +7,8 @@
|
|||||||
<Nullable>enable</Nullable>
|
<Nullable>enable</Nullable>
|
||||||
</PropertyGroup>
|
</PropertyGroup>
|
||||||
|
|
||||||
|
<ItemGroup>
|
||||||
|
<PackageReference Include="SurrealDb.Net" Version="0.9.0" />
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
</Project>
|
</Project>
|
||||||
|
|||||||
Reference in New Issue
Block a user