1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
// SPDX-FileCopyrightText: 2026 Progmasoft <support@progmasoft.com>
// SPDX-License-Identifier: AGPL-3.0-or-later WITH AdditionRef-Progmasoft-Patent-Grant-1.1
namespace Progmasoft.Progmaweb.Api.Accounts;
// This development store models the uniqueness and session semantics required by the future PostgreSQL implementation.
// It deliberately exposes no enumeration or bulk-delete surface to public endpoints.
internal sealed class InMemoryAccountStore : IAccountStore
{
private readonly Lock gate = new();
private readonly Dictionary<Guid, AccountRecord> accountsById = [];
private readonly Dictionary<string, Guid> accountIdsByEmail = new(StringComparer.Ordinal);
private readonly Dictionary<string, Guid> accountIdsByGoogleSubject = new(StringComparer.Ordinal);
private readonly Dictionary<string, Guid> accountIdsByName = new(StringComparer.Ordinal);
private readonly Dictionary<string, SessionRecord> sessionsByDigest = new(StringComparer.Ordinal);
public ValueTask<CreateAccountResult> CreateAsync(AccountRecord account, CancellationToken cancellationToken)
{
cancellationToken.ThrowIfCancellationRequested();
lock (gate)
{
if (account.GoogleSubject is not null && accountIdsByGoogleSubject.ContainsKey(account.GoogleSubject))
{
return ValueTask.FromResult(CreateAccountResult.GoogleSubjectUnavailable());
}
if (accountIdsByName.ContainsKey(account.NormalizedAccountName))
{
return ValueTask.FromResult(CreateAccountResult.AccountNameUnavailable());
}
if (accountIdsByEmail.ContainsKey(account.NormalizedEmail))
{
return ValueTask.FromResult(CreateAccountResult.EmailUnavailable());
}
accountsById.Add(account.Id, account);
accountIdsByName.Add(account.NormalizedAccountName, account.Id);
accountIdsByEmail.Add(account.NormalizedEmail, account.Id);
if (account.GoogleSubject is not null)
{
accountIdsByGoogleSubject.Add(account.GoogleSubject, account.Id);
}
return ValueTask.FromResult(CreateAccountResult.Created(account));
}
}
public ValueTask<AccountRecord?> FindByGoogleSubjectAsync(
string googleSubject,
CancellationToken cancellationToken)
{
cancellationToken.ThrowIfCancellationRequested();
lock (gate)
{
return ValueTask.FromResult(
accountIdsByGoogleSubject.TryGetValue(googleSubject, out Guid id) ? accountsById[id] : null);
}
}
public ValueTask<AccountRecord?> FindByEmailAsync(string normalizedEmail, CancellationToken cancellationToken)
{
cancellationToken.ThrowIfCancellationRequested();
lock (gate)
{
return ValueTask.FromResult(
accountIdsByEmail.TryGetValue(normalizedEmail, out Guid id) ? accountsById[id] : null);
}
}
public ValueTask<AccountRecord?> FindByIdAsync(Guid id, CancellationToken cancellationToken)
{
cancellationToken.ThrowIfCancellationRequested();
lock (gate)
{
accountsById.TryGetValue(id, out AccountRecord? account);
return ValueTask.FromResult(account);
}
}
public ValueTask StoreSessionAsync(SessionRecord session, CancellationToken cancellationToken)
{
cancellationToken.ThrowIfCancellationRequested();
lock (gate)
{
sessionsByDigest[Convert.ToHexString(session.TokenDigest)] = session;
return ValueTask.CompletedTask;
}
}
public ValueTask<SessionRecord?> FindSessionAsync(byte[] tokenDigest, CancellationToken cancellationToken)
{
cancellationToken.ThrowIfCancellationRequested();
lock (gate)
{
sessionsByDigest.TryGetValue(Convert.ToHexString(tokenDigest), out SessionRecord? session);
return ValueTask.FromResult(session);
}
}
public ValueTask RevokeSessionAsync(byte[] tokenDigest, CancellationToken cancellationToken)
{
cancellationToken.ThrowIfCancellationRequested();
lock (gate)
{
sessionsByDigest.Remove(Convert.ToHexString(tokenDigest));
return ValueTask.CompletedTask;
}
}
}
|