feat: added implementation of HeadHunter hook for user registration
This commit is contained in:
106
JOBot.Backend/Services/HeadHunterService.cs
Normal file
106
JOBot.Backend/Services/HeadHunterService.cs
Normal file
@@ -0,0 +1,106 @@
|
||||
using System.Text.Json;
|
||||
using JOBot.Backend.DAL.Context;
|
||||
using JOBot.Backend.DTOs.HeadHunterHook;
|
||||
using JOBot.Backend.Infrastructure.Config;
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
using Microsoft.Extensions.Options;
|
||||
|
||||
namespace JOBot.Backend.Services;
|
||||
|
||||
public class HeadHunterService(ILogger<HeadHunterService> logger, IOptions<HeadHunterConfig> config, AppDbContext dbContext)
|
||||
{
|
||||
private readonly HeadHunterConfig _config = config.Value;
|
||||
|
||||
/// <summary>
|
||||
/// Generate HeadHunter oauth authorization link
|
||||
/// </summary>
|
||||
/// <param name="userId">Telegram UserId</param>
|
||||
/// <returns>Link for auth</returns>
|
||||
public string GenerateAuthLink(int userId)
|
||||
{
|
||||
var redirectUri = new UriBuilder(_config.Links.HookDomain)
|
||||
{
|
||||
Port = -1,
|
||||
Scheme = "https",
|
||||
Path = _config.Links.HookRoute,
|
||||
Query = $"?userId={userId}"
|
||||
}.ToString();
|
||||
|
||||
return string.Format(_config.Links.AuthLink, [_config.ClientId, userId, redirectUri]);
|
||||
}
|
||||
|
||||
public async Task<Status> AuthUser(int userId, string authorizationCode, string? error)
|
||||
{
|
||||
logger.LogInformation($"Authorization for user {userId} in process...");
|
||||
|
||||
if (!string.IsNullOrEmpty(error))
|
||||
{
|
||||
logger.LogWarning($"User {userId} auth completed with error {error}");
|
||||
return Status.UserAuthRejectedError;
|
||||
}
|
||||
|
||||
using var client = new HttpClient();
|
||||
var form = new Dictionary<string, string>
|
||||
{
|
||||
{ "client-id", _config.ClientId },
|
||||
{ "client_secret", _config.Secret },
|
||||
{ "code", authorizationCode },
|
||||
{ "grant_type", "authorization_code" }
|
||||
};
|
||||
client.BaseAddress = new UriBuilder(_config.Links.HeadHunterApiDomain)
|
||||
{
|
||||
Port = -1,
|
||||
Scheme = "https"
|
||||
}.Uri;
|
||||
client.DefaultRequestHeaders.UserAgent.ParseAdd("Jobot BackEnd Service");
|
||||
|
||||
using var res = await client.SendAsync(
|
||||
new HttpRequestMessage(
|
||||
HttpMethod.Post,
|
||||
_config.Links.HeadHunterTokenRoute)
|
||||
{
|
||||
Content = new FormUrlEncodedContent(form)
|
||||
});
|
||||
|
||||
if (!res.IsSuccessStatusCode)
|
||||
{
|
||||
logger.LogWarning($"Response of HttpRequest ${_config.Links.HeadHunterApiDomain} " +
|
||||
$"${_config.Links.HeadHunterTokenRoute} has unsuccessful status code {res.StatusCode}");
|
||||
return Status.HeadHunterAuthRejectedError;
|
||||
}
|
||||
|
||||
var responseDto = JsonSerializer.Deserialize<HeadHunterTokenResponseDto>(await res.Content.ReadAsStringAsync());
|
||||
|
||||
if (responseDto == null)
|
||||
{
|
||||
logger.LogWarning($"User {userId} auth completed with error " +
|
||||
$"{nameof(Status.HeadHunterResponseDeserializationFailedError)}");
|
||||
return Status.HeadHunterResponseDeserializationFailedError;
|
||||
}
|
||||
|
||||
var user = await dbContext.Users.FirstOrDefaultAsync(x => x.UserId == userId);
|
||||
|
||||
if (user == null)
|
||||
{
|
||||
logger.LogWarning($"User {userId} search completed with error {nameof(Status.UserNotFoundError)}");
|
||||
return Status.UserNotFoundError;
|
||||
}
|
||||
|
||||
user.AccessToken = responseDto.AccessToken;
|
||||
user.RefreshToken = responseDto.RefreshToken;
|
||||
|
||||
await dbContext.SaveChangesAsync();
|
||||
|
||||
logger.LogInformation($"User {userId} auth completed!");
|
||||
return Status.Success;
|
||||
}
|
||||
|
||||
public enum Status
|
||||
{
|
||||
UserAuthRejectedError,
|
||||
HeadHunterAuthRejectedError,
|
||||
UserNotFoundError,
|
||||
HeadHunterResponseDeserializationFailedError,
|
||||
Success
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user