Simplify exception throwing

.fernignore

@@ -8,6 +8,7 @@ LICENSE.md
 src/AssemblyAI/AssemblyAI.csproj
 src/AssemblyAI/Core/ClientOptions.cs
 src/AssemblyAI/Core/JsonConfiguration.cs
+src/AssemblyAI/Core/ExtendedRawClient.cs
 src/AssemblyAI/ClientOptions.cs
 src/AssemblyAI/Constants.cs
 src/AssemblyAI/UserAgent.cs

src/AssemblyAI.IntegrationTests/LemurTests.cs

@@ -1,3 +1,4 @@
+using System.Net;
 using AssemblyAI.Core;
 using AssemblyAI.Lemur;
 
@@ -82,17 +83,18 @@ public async Task Should_Generate_Task()
     }
 
     [Test]
-    [Ignore("Ignore until fixed")]
+    //[Ignore("Ignore until fixed")]
     public void Should_Fail_To_Generate_Summary()
     {
         var client = new AssemblyAIClient(ApiKey);
-        var ex = Assert.ThrowsAsync<BadRequestError>(async () => await client.Lemur.SummaryAsync(new LemurSummaryParams
+        var ex = Assert.ThrowsAsync<HttpOperationException>(async () => await client.Lemur.SummaryAsync(new LemurSummaryParams
         {
             FinalModel = LemurModel.Basic,
             TranscriptIds = ["bad-id"],
             AnswerFormat = "one sentence"
         }).ConfigureAwait(false));
 
+        Assert.That(ex.StatusCode, Is.EqualTo(HttpStatusCode.BadRequest));
         Assert.That(ex.Message, Is.EqualTo("each transcript source id must be valid"));
     }
 

src/AssemblyAI/Core/AssemblyAIException.cs

@@ -0,0 +1,23 @@
+using System;
+
+#nullable enable
+
+namespace AssemblyAI.Core;
+
+/// <summary>
+/// Base exception class for all exceptions thrown by the SDK.
+/// </summary>
+public class AssemblyAIException : Exception
+{
+    public AssemblyAIException()
+    {
+    }
+
+    public AssemblyAIException(string message) : base(message)
+    {
+    }
+
+    public AssemblyAIException(string message, Exception innerException) : base(message, innerException)
+    {
+    }
+}

src/AssemblyAI/Core/ExtendedRawClient.cs

@@ -0,0 +1,42 @@
+using System.Net.Http;
+using System.Text.Json;
+
+namespace AssemblyAI.Core;
+
+#nullable enable
+
+public partial class RawClient
+{
+    private partial async Task OnResponseErrorAsync(HttpResponseMessage response){
+        var responseContentString = await response.Content.ReadAsStringAsync()
+            .ConfigureAwait(false);
+        if (string.IsNullOrEmpty(responseContentString))
+        {
+            throw new HttpOperationException(
+                $"Error with status code {response.StatusCode}", 
+                response.StatusCode, 
+                responseContentString
+            ); 
+        }
+
+        try
+        {
+            var error = JsonUtils.Deserialize<AssemblyAI.Error>(responseContentString);
+            throw new HttpOperationException(
+                error.Error_, 
+                response.StatusCode, 
+                responseContentString
+            );
+        }
+        catch (JsonException)
+        {
+        }
+
+        // use response content as error message if error object cannot be deserialized
+        throw new HttpOperationException(
+            responseContentString, 
+            response.StatusCode, 
+            responseContentString
+        );
+    }
+}

src/AssemblyAI/Core/AssemblyAIClientApiException.cs → src/AssemblyAI/Core/HttpOperationException.cs

@@ -1,3 +1,4 @@
+using System.Net;
 using AssemblyAI.Core;
 
 #nullable enable
@@ -7,16 +8,16 @@ namespace AssemblyAI.Core;
 /// <summary>
 /// This exception type will be thrown for any non-2XX API responses.
 /// </summary>
-public class AssemblyAIClientApiException(string message, int statusCode, object body)
-    : AssemblyAIClientException(message)
+public class HttpOperationException(string message, HttpStatusCode statusCode, string responseContent)
+    : AssemblyAIException(message)
 {
     /// <summary>
     /// The error code of the response that triggered the exception.
     /// </summary>
-    public int StatusCode { get; } = statusCode;
+    public HttpStatusCode StatusCode { get; } = statusCode;
 
     /// <summary>
     /// The body of the response that triggered the exception.
     /// </summary>
-    public object Body { get; } = body;
+    public string ResponseContent { get; } = responseContent;
 }

src/AssemblyAI/Core/RawClient.cs

@@ -1,5 +1,7 @@
+using System.Net;
 using System.Net.Http;
 using System.Text;
+using System.Text.Json;
 
 namespace AssemblyAI.Core;
 
@@ -8,7 +10,7 @@ namespace AssemblyAI.Core;
 /// <summary>
 /// Utility class for making raw HTTP requests to the API.
 /// </summary>
-public class RawClient(
+public partial class RawClient(
     Dictionary<string, string> headers,
     Dictionary<string, Func<string>> headerSuppliers,
     ClientOptions clientOptions
@@ -24,6 +26,8 @@ ClientOptions clientOptions
     /// </summary>
     private readonly Dictionary<string, string> _headers = headers;
 
+    private partial Task OnResponseErrorAsync(HttpResponseMessage response);
+
     public async Task<ApiResponse> MakeRequestAsync(BaseApiRequest request)
     {
         var url = BuildUrl(request);
@@ -32,21 +36,25 @@ public async Task<ApiResponse> MakeRequestAsync(BaseApiRequest request)
         {
             request.Headers.Add("Content-Type", request.ContentType);
         }
+
         // Add global headers to the request
         foreach (var header in _headers)
         {
             httpRequest.Headers.Add(header.Key, header.Value);
         }
+
         // Add global headers to the request from supplier
         foreach (var header in headerSuppliers)
         {
             httpRequest.Headers.Add(header.Key, header.Value.Invoke());
         }
+
         // Add request headers to the request
         foreach (var header in request.Headers)
         {
             httpRequest.Headers.Add(header.Key, header.Value);
         }
+
         // Add the request body to the request
         if (request is JsonApiRequest jsonRequest)
         {
@@ -63,10 +71,18 @@ public async Task<ApiResponse> MakeRequestAsync(BaseApiRequest request)
         {
             httpRequest.Content = new StreamContent(streamRequest.Body);
         }
+
         // Send the request
-        var httpClient = request.Options?.HttpClient ?? Options.HttpClient;
+        var httpClient = request.Options?.HttpClient ?? Options.HttpClient
+            ?? throw new Exception("No HttpClient provided in request or client options");
         var response = await httpClient.SendAsync(httpRequest);
-        return new ApiResponse { StatusCode = (int)response.StatusCode, Raw = response };
+        if (!response.IsSuccessStatusCode)
+        {
+            await OnResponseErrorAsync(response).ConfigureAwait(false);
+        }
+
+        var apiResponse = new ApiResponse { StatusCode = response.StatusCode, Raw = response };
+        return apiResponse;
     }
 
     public record BaseApiRequest
@@ -107,7 +123,7 @@ public record JsonApiRequest : BaseApiRequest
     /// </summary>
     public record ApiResponse
     {
-        public required int StatusCode { get; init; }
+        public required HttpStatusCode StatusCode { get; init; }
 
         public required HttpResponseMessage Raw { get; init; }
     }
@@ -140,10 +156,11 @@ private string BuildUrl(BaseApiRequest request)
                 {
                     current += $"{queryItem.Key}={queryItem.Value}&";
                 }
+
                 return current;
             }
         );
         url = url.Substring(0, url.Length - 1);
         return url;
     }
-}
+}