add gRPC

Author: LovchikovMark

Protos/user.proto

@@ -1,19 +1,27 @@
 syntax = "proto3";
 
 service UserGrpc {
-  rpc GetUser (UserRequest) returns (UserResponse);
+    rpc GetUser (UserRequest) returns (UserResponse);
+    rpc GetUsers (UserListRequest) returns (UserListResponse);
 }
 
 message UserRequest {
-  string id = 1;
+    string id = 1;
+}
+
+message UserListRequest {
+    repeated string ids = 1;
 }
 
 message UserResponse {
-  string id = 1;
-  string name = 2;
-  string email = 3;
-  string legend = 4;
-  string avatar = 5;
-  string login = 6;
-  int32 reputationScore = 7;
+    string name = 2;
+    string email = 3;
+    string legend = 4;
+    string avatar = 5;
+    string login = 6;
+    int32 reputationScore = 7;
+}
+
+message UserListResponse {
+    repeated UserResponse users = 1;
 }

User/userGrpcService.cs

@@ -16,12 +16,35 @@ public override async Task<UserResponse> GetUser(UserRequest request, ServerCall
 
         return new UserResponse
         {
-            Id = request.Id,
             Name = user.Name,
             Legend = user.Legend,
             Avatar = user.Avatar,
             Login = user.Login,
             ReputationScore = user.ReputationScore
         };
     }
+
+    public override async Task<UserListResponse> GetUsers(UserListRequest request, ServerCallContext context)
+    {
+
+        string[] userIds = request.Ids.ToArray();
+
+        var result = await _userService.GetUsersInfo(userIds);
+
+        UserListResponse response = new UserListResponse();
+        
+        foreach(var user in result)
+        {
+            response.Users.Add(new UserResponse
+            {
+                Name = user.Name,
+                Legend = user.Legend,
+                Avatar = user.Avatar,
+                Login = user.Login,
+                ReputationScore = user.ReputationScore
+            });
+        }
+
+        return response;
+    }
 }

User/userRepo.cs

@@ -1,9 +1,11 @@
 using Microsoft.EntityFrameworkCore;
+using System.Collections.Generic;
 
 public interface IUserRepo
 {
     Task<User?> GetUser(string login, string password);
     Task<User?> GetUser(string userId);
+    Task<List<User>?> GetUsers(string[] userId);
     Task CreateUser(User UserData);
     Task<bool> DeleteUser(string login);
     Task<string> GetRefreshTokenHashByUserId(Guid userId);
@@ -35,6 +37,11 @@ public UserRepo(ApplicationDbContext context)
         return await _context.Users.Where(e => e.UserId == Guid.Parse(userId)).FirstOrDefaultAsync();
     }
 
+    public async Task<List<User>?> GetUsers(string[] userIds)
+    {
+        return await _context.Users.Where(e => userIds.Contains(e.Id.ToString())).ToListAsync();
+    }
+
     public async Task CreateUser(User UserData)
     {
         try

User/userService.cs

@@ -1,6 +1,4 @@
 using DeveSecurity;
-using Microsoft.AspNetCore.Http.HttpResults;
-using Microsoft.Extensions.Configuration.UserSecrets;
 
 public class ICreateUser
 {
@@ -18,6 +16,7 @@ public interface IUserService
     public Task<bool> DeleteUser(string login);
     public Task<RefreshTokenResponseDto?> RefreshAccessToken(RefreshTokenRequestDto data);
     public Task<GetUserInfoDto> GetUserInfo(string userId);
+    public Task<List<GetUserInfoDto>> GetUsersInfo(string[] userIds);
 
 }
 
@@ -160,4 +159,33 @@ public async Task<GetUserInfoDto> GetUserInfo(string userId)
             throw new Exception(e.Message);
         }
     }
+
+    public async Task<List<GetUserInfoDto>> GetUsersInfo(string[] userIds)
+    {
+        try
+        {
+            var result = await _userRepo.GetUsers(userIds);
+
+            List<GetUserInfoDto> users = [];
+
+            foreach(var user in result!)
+            {
+                users.Add(new GetUserInfoDto
+                {
+                    Name = user!.Name,
+                    Login = user!.Login,
+                    Legend = user!.Legend,
+                    Avatar = user!.AvatarUrl,
+                    ReputationScore = user!.ReputationScore
+                });
+            }
+
+            return users;
+
+        }
+        catch(Exception e)
+        {
+            throw new Exception(e.Message);
+        }
+    }
 }