feat: implemented return of user info and eula accept logic

This commit is contained in:
2025-07-10 23:58:12 +03:00
parent 252adf0fc7
commit 4a7810f571
15 changed files with 209 additions and 48 deletions

View File

@@ -1,43 +1,96 @@
using Grpc.Core;
using JOBot.Proto;
using JOBot.Backend.DAL.Context;
using Models = JOBot.Backend.DAL.Models;
using JOBot.Backend.DAL.Models;
using JOBot.Proto;
using Microsoft.EntityFrameworkCore;
using User = JOBot.Backend.DAL.Models.User;
namespace JOBot.Backend.Services.gRPC;
public class UserService(AppDbContext dbContext) : User.UserBase
public class UserService(AppDbContext dbContext) : Proto.User.UserBase
{
public override Task<RegisterResponse> Register(
/// <summary>
/// Create user
/// </summary>
/// <param name="request"></param>
/// <param name="_"></param>
/// <returns>Status of operation (fail if user exists)</returns>
public override async Task<RegisterResponse> Register(
RegisterRequest request,
ServerCallContext context)
ServerCallContext _)
{
if(!dbContext.Users
.Any(x => x.TelegramId == request.UserId))
if(!await dbContext.Users
.AnyAsync(x => x.UserId == request.UserId))
{
dbContext.Users.Add(new Models.User
dbContext.Users.Add(new User
{
TelegramId = request.UserId,
UserId = request.UserId,
Username = !string.IsNullOrEmpty(request.Username) ? request.Username : null
});
dbContext.SaveChanges();
return Task.FromResult(new RegisterResponse
await dbContext.SaveChangesAsync();
return new RegisterResponse
{
Success = true
});
};
}
return Task.FromResult(new RegisterResponse
return new RegisterResponse
{
Success = false
});
};
}
public override Task<GetUserResponse> GetUser(
/// <summary>
/// Get user for client
/// </summary>
/// <param name="request"></param>
/// <param name="_"></param>
/// <returns>User, or throws RPC exception if not found</returns>
public override async Task<GetUserResponse> GetUser(
GetUserRequest request,
ServerCallContext context)
ServerCallContext _)
{
return null;
var user = await dbContext.Users.FirstOrDefaultAsync(x => x.UserId == request.UserId);
ValidateUserFound(user);
return user!.MapToResponse();
}
/// <summary>
/// Accept EULA for user
/// </summary>
/// <param name="request"></param>
/// <param name="_"></param>
/// <returns>Status of operation</returns>
public override async Task<AcceptEulaResponse> AcceptEula(AcceptEulaRequest request, ServerCallContext _)
{
var user = await dbContext.Users.FirstOrDefaultAsync(x => x.UserId == request.UserId);
if (user == null)
{
return new AcceptEulaResponse
{
Success = false
};
}
user.Eula = request.EulaAccepted;
await dbContext.SaveChangesAsync();
return new AcceptEulaResponse
{
Success = true
};
}
/// <summary>
/// Throw RPCException if user not found
/// </summary>
/// <param name="user"></param>
/// <exception cref="RpcException"></exception>
private void ValidateUserFound(User? user)
{
if (user == null)
throw new RpcException(new Status(StatusCode.NotFound, "User not found"));
}
}