fix: HttpClientFactory 생명주기 불일치(Scope Capture) 문제를 회피하기 위해 CRM API 클라이언트에 직접 토큰 주입하도록 전면 개편

2026-06-29 15:43:15 +09:00
parent 3e1097f585
commit 5807e1b35e
7 changed files with 90 additions and 18 deletions
@@ -17,14 +17,23 @@ public interface ITaxProfileBrowserClient
    Task DeleteAsync(int id, CancellationToken ct = default);
 }

-public class TaxProfileBrowserClient(HttpClient httpClient, ILogger<TaxProfileBrowserClient> logger) : ITaxProfileBrowserClient
+public class TaxProfileBrowserClient(HttpClient httpClient, ITokenStore tokenStore, ILogger<TaxProfileBrowserClient> logger) : ITaxProfileBrowserClient
 {
    private const string BaseUrl = "/api/taxprofile";

+    private void EnsureAuthHeader()
+    {
+        if (!string.IsNullOrEmpty(tokenStore.AccessToken))
+            httpClient.DefaultRequestHeaders.Authorization = new("Bearer", tokenStore.AccessToken);
+        else
+            httpClient.DefaultRequestHeaders.Authorization = null;
+    }
+
    public async Task<List<TaxProfile>> GetAllAsync(CancellationToken ct = default)
    {
        try
        {
+            EnsureAuthHeader();
            return await httpClient.GetFromJsonAsync<List<TaxProfile>>($"{BaseUrl}", ct) ?? [];
        }
        catch (Exception ex)
@@ -38,6 +47,7 @@ public class TaxProfileBrowserClient(HttpClient httpClient, ILogger<TaxProfileBr
    {
        try
        {
+            EnsureAuthHeader();
            return await httpClient.GetFromJsonAsync<TaxProfile>($"{BaseUrl}/{id}", ct);
        }
        catch (Exception ex)
@@ -51,6 +61,7 @@ public class TaxProfileBrowserClient(HttpClient httpClient, ILogger<TaxProfileBr
    {
        try
        {
+            EnsureAuthHeader();
            return await httpClient.GetFromJsonAsync<List<TaxProfile>>($"{BaseUrl}/client/{clientId}", ct) ?? [];
        }
        catch (Exception ex)
@@ -64,6 +75,7 @@ public class TaxProfileBrowserClient(HttpClient httpClient, ILogger<TaxProfileBr
    {
        try
        {
+            EnsureAuthHeader();
            var response = await httpClient.GetFromJsonAsync<JsonElement>($"{BaseUrl}/high-risk", ct);
            if (response.TryGetProperty("data", out var data))
                return System.Text.Json.JsonSerializer.Deserialize<List<TaxProfile>>(data.GetRawText()) ?? [];
@@ -80,6 +92,7 @@ public class TaxProfileBrowserClient(HttpClient httpClient, ILogger<TaxProfileBr
    {
        try
        {
+            EnsureAuthHeader();
            var response = await httpClient.GetFromJsonAsync<JsonElement>($"{BaseUrl}/upcoming-filings?daysAhead={daysAhead}", ct);
            if (response.TryGetProperty("data", out var data))
                return System.Text.Json.JsonSerializer.Deserialize<List<TaxProfile>>(data.GetRawText()) ?? [];
@@ -97,6 +110,7 @@ public class TaxProfileBrowserClient(HttpClient httpClient, ILogger<TaxProfileBr
    {
        try
        {
+            EnsureAuthHeader();
            var request = new { clientId, businessType, businessRegistration, accountingMethod, establishmentDate };
            var response = await httpClient.PostAsJsonAsync(BaseUrl, request, ct);
            response.EnsureSuccessStatusCode();
@@ -115,6 +129,7 @@ public class TaxProfileBrowserClient(HttpClient httpClient, ILogger<TaxProfileBr
    {
        try
        {
+            EnsureAuthHeader();
            var request = new { businessType, accountingMethod, nextFilingDueDate, taxRiskLevel };
            var response = await httpClient.PutAsJsonAsync($"{BaseUrl}/{id}", request, ct);
            response.EnsureSuccessStatusCode();
@@ -129,6 +144,7 @@ public class TaxProfileBrowserClient(HttpClient httpClient, ILogger<TaxProfileBr
    {
        try
        {
+            EnsureAuthHeader();
            var response = await httpClient.DeleteAsync($"{BaseUrl}/{id}", ct);
            response.EnsureSuccessStatusCode();
        }