Skip to content

Commit 1bc369e

Browse files
committed
feat: remove useless acquireLock
feat: improve SessionMemberData.AuthCheckClientInstanceIds management
1 parent 327fa3b commit 1bc369e

2 files changed

Lines changed: 6 additions & 4 deletions

File tree

src/ByteSync.ServerCommon/Commands/CloudSessions/FinalizeJoinCloudSessionCommandHandler.cs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -43,8 +43,6 @@ public async Task<FinalizeJoinSessionResult> Handle(FinalizeJoinCloudSessionRequ
4343

4444
var transaction = _redisInfrastructureService.OpenTransaction();
4545

46-
await using var sessionRedisLock = await _redisInfrastructureService.AcquireLockAsync(EntityType.Session, parameters.SessionId);
47-
4846
var updateResult = await _cloudSessionsRepository.Update(parameters.SessionId, innerCloudSessionData =>
4947
{
5048
if (innerCloudSessionData.IsSessionRemoved)
@@ -99,7 +97,7 @@ public async Task<FinalizeJoinSessionResult> Handle(FinalizeJoinCloudSessionRequ
9997
{
10098
return false;
10199
}
102-
}, transaction, sessionRedisLock);
100+
}, transaction);
103101

104102
if (updateResult.IsWaitingForTransaction)
105103
{

src/ByteSync.ServerCommon/Commands/Trusts/SendDigitalSignaturesCommandHandler.cs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,11 @@ await _cloudSessionsRepository.Update(cloudSession.SessionId, cloudSessionData =
7171
{
7272
foreach (var digitalSignatureCheckInfo in parameters.DigitalSignatureCheckInfos)
7373
{
74-
member.AuthCheckClientInstanceIds.Add(digitalSignatureCheckInfo.Recipient);
74+
var recipient = digitalSignatureCheckInfo.Recipient;
75+
if (!member.AuthCheckClientInstanceIds.Contains(recipient))
76+
{
77+
member.AuthCheckClientInstanceIds.Add(recipient);
78+
}
7579
}
7680

7781
return true;

0 commit comments

Comments
 (0)