FrontOffice.BFF/src/FrontOffice.BFF.WebApi/Services/UserService.cs

using FrontOffice.BFF.WebApi.Common.Services;
using FrontOffice.BFF.Application.UserCQ.Commands.UpdateUser;
using FrontOffice.BFF.Application.UserCQ.Commands.DeleteUser;
using FrontOffice.BFF.Application.UserCQ.Queries.GetUser;
using FrontOffice.BFF.Application.UserCQ.Queries.GetAllUserByFilter;
using FrontOffice.BFF.Application.UserCQ.Commands.CreateNewOtpToken;
using FrontOffice.BFF.Application.UserCQ.Commands.VerifyOtpToken;
using FrontOffice.BFF.Application.UserCQ.Queries.AdminGetJwtToken;
using FrontOffice.BFF.Application.UserCQ.Commands.SetPasswordForUser;
using FrontOffice.BFF.User.Protobuf.Protos.User;

namespace FrontOffice.BFF.WebApi.Services;
public class UserService : UserContract.UserContractBase
{
    private readonly IDispatchRequestToCQRS _dispatchRequestToCQRS;

    public UserService(IDispatchRequestToCQRS dispatchRequestToCQRS)
    {
        _dispatchRequestToCQRS = dispatchRequestToCQRS;
    }
    [Authorize(Roles = "user")]
    public override async Task<Empty> UpdateUser(UpdateUserRequest request, ServerCallContext context)
    {
        return await _dispatchRequestToCQRS.Handle<UpdateUserRequest, UpdateUserCommand>(request, context);
    }
    public override async Task<Empty> DeleteUser(DeleteUserRequest request, ServerCallContext context)
    {
        return await _dispatchRequestToCQRS.Handle<DeleteUserRequest, DeleteUserCommand>(request, context);
    }
    public override async Task<GetUserResponse> GetUser(Empty request, ServerCallContext context)
    {
        return await _dispatchRequestToCQRS.Handle<GetUserQuery, GetUserResponse>(context);
    }
    public override async Task<GetAllUserByFilterResponse> GetAllUserByFilter(GetAllUserByFilterRequest request, ServerCallContext context)
    {
        return await _dispatchRequestToCQRS.Handle<GetAllUserByFilterRequest, GetAllUserByFilterQuery, GetAllUserByFilterResponse>(request, context);
    }
    public override async Task<CreateNewOtpTokenResponse> CreateNewOtpToken(CreateNewOtpTokenRequest request, ServerCallContext context)
    {
        return await _dispatchRequestToCQRS.Handle<CreateNewOtpTokenRequest, CreateNewOtpTokenCommand, CreateNewOtpTokenResponse>(request, context);
    }
    [Authorize(Roles = "user")]
    public override async Task<VerifyOtpTokenResponse> VerifyOtpToken(VerifyOtpTokenRequest request, ServerCallContext context)
    {
        return await _dispatchRequestToCQRS.Handle<VerifyOtpTokenRequest, VerifyOtpTokenCommand, VerifyOtpTokenResponse>(request, context);
    }
    [Authorize(Roles = "user")]
    public override async Task<AdminGetJwtTokenResponse> AdminGetJwtToken(AdminGetJwtTokenRequest request, ServerCallContext context)
    {
        return await _dispatchRequestToCQRS.Handle<AdminGetJwtTokenRequest, AdminGetJwtTokenQuery, AdminGetJwtTokenResponse>(request, context);
    }
    public override async Task<Empty> SetPasswordForUser(SetPasswordForUserRequest request, ServerCallContext context)
    {
        return await _dispatchRequestToCQRS.Handle<SetPasswordForUserRequest, SetPasswordForUserCommand>(request, context);
    }
}