38 lines
1.9 KiB
C#
38 lines
1.9 KiB
C#
|
using FrontOffice.BFF.User.Protobuf.Protos.User;
|
||
|
|
using FrontOffice.BFF.WebApi.Common.Services;
|
||
|
|
using FrontOffice.BFF.Application.UserCQ.Commands.CreateNewUser;
|
||
|
|
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;
|
||
|
|
namespace FrontOffice.BFF.WebApi.Services;
|
||
|
|
public class UserService : UserContract.UserContractBase
|
||
|
|
{
|
||
|
|
private readonly IDispatchRequestToCQRS _dispatchRequestToCQRS;
|
||
|
|
|
||
|
|
public UserService(IDispatchRequestToCQRS dispatchRequestToCQRS)
|
||
|
|
{
|
||
|
|
_dispatchRequestToCQRS = dispatchRequestToCQRS;
|
||
|
|
}
|
||
|
|
public override async Task<CreateNewUserResponse> CreateNewUser(CreateNewUserRequest request, ServerCallContext context)
|
||
|
|
{
|
||
|
|
return await _dispatchRequestToCQRS.Handle<CreateNewUserRequest, CreateNewUserCommand, CreateNewUserResponse>(request, context);
|
||
|
|
}
|
||
|
|
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(GetUserRequest request, ServerCallContext context)
|
||
|
|
{
|
||
|
|
return await _dispatchRequestToCQRS.Handle<GetUserRequest, GetUserQuery, GetUserResponse>(request, context);
|
||
|
|
}
|
||
|
|
public override async Task<GetAllUserByFilterResponse> GetAllUserByFilter(GetAllUserByFilterRequest request, ServerCallContext context)
|
||
|
|
{
|
||
|
|
return await _dispatchRequestToCQRS.Handle<GetAllUserByFilterRequest, GetAllUserByFilterQuery, GetAllUserByFilterResponse>(request, context);
|
||
|
|
}
|
||
|
|
}
|