Union/ProjectLighthouse
1
0
Fork 0
mirror of https://github.com/LBPUnion/ProjectLighthouse.git synced 2025-07-01 02:41:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Theoretically move friend/blocked data to Redis

Browse source 
Untested due to shenanigans with Redis.
This commit is contained in:
jvyden 2022-05-15 13:33:28 -04:00
parent 82091c6d8b
commit bd41997aae
No known key found for this signature in database
GPG key ID: 18BCF2BE0262B278
11 changed files with 166 additions and 133 deletions
Download patch file Download diff file Expand all files Collapse all files

19
ProjectLighthouse.Servers.GameServer/Controllers/FriendsController.cs
View file

@ -53,14 +53,13 @@ public class FriendsController : ControllerBase
blockedUsers.Add(blockedUser.UserId);
}
if (FriendHelper.FriendIdsByUserId.ContainsKey(user.UserId))
{
FriendHelper.FriendIdsByUserId.Remove(user.UserId);
FriendHelper.BlockedIdsByUserId.Remove(user.UserId);
}
UserFriendStore? friendStore = Redis.GetUserFriendStore(user.UserId);
if (friendStore == null) friendStore = Redis.CreateUserFriendStore(user.UserId);
FriendHelper.FriendIdsByUserId.Add(user.UserId, friends.Select(u => u.UserId).ToArray());
FriendHelper.BlockedIdsByUserId.Add(user.UserId, blockedUsers.ToArray());
friendStore.FriendIds = friends.Select(u => u.UserId).ToList();
friendStore.BlockedIds = blockedUsers;
Redis.UpdateFriendStore(friendStore);
string friendsSerialized = friends.Aggregate(string.Empty, (current, user1) => current + LbpSerializer.StringElement("npHandle", user1.Username));
@ -78,11 +77,13 @@ public class FriendsController : ControllerBase
User user = userAndToken.Value.Item1;
GameToken gameToken = userAndToken.Value.Item2;
if (!FriendHelper.FriendIdsByUserId.TryGetValue(user.UserId, out int[]? friendIds) || friendIds == null)
UserFriendStore? friendStore = Redis.GetUserFriendStore(user.UserId);
if (friendStore == null)
return this.Ok(LbpSerializer.BlankElement("myFriends"));
string friends = "";
foreach (int friendId in friendIds)
foreach (int friendId in friendStore.FriendIds)
{
User? friend = await this.database.Users.Include(u => u.Location).FirstOrDefaultAsync(u => u.UserId == friendId);
if (friend == null) continue;