Added custom NumbersException class

build.gradle

@@ -44,6 +44,7 @@ dependencies {
     compile 'org.asynchttpclient:async-http-client:2.6.0'
     compile 'com.google.guava:guava:27.0-jre'
     compile 'com.fasterxml.jackson.datatype:jackson-datatype-guava:2.9.5'
+    compile 'com.fasterxml.jackson.dataformat:jackson-dataformat-xml:2.9.4'
     testCompile('org.assertj:assertj-core:3.6.2')
     testCompile('org.mockito:mockito-core:2.7.9')
     testCompile('junit:junit:4.4')

src/main/java/com/bandwidth/sdk/numbers/exception/ExceptionUtils.java

@@ -0,0 +1,25 @@
+package com.bandwidth.sdk.numbers.exception;
+
+import java.util.concurrent.CompletableFuture;
+
+public class ExceptionUtils {
+
+    public static <T> CompletableFuture<T> catchAsyncClientExceptions(ThrowableSupplier<CompletableFuture<T>> supplier) {
+        try {
+            return supplier.get();
+        } catch (Throwable e) {
+            CompletableFuture<T> future = new CompletableFuture<>();
+            future.completeExceptionally(new NumbersClientException(e));
+            return future;
+        }
+    }
+
+    public static <T> T catchClientExceptions(ThrowableSupplier<T> supplier) {
+        try {
+            return supplier.get();
+        } catch (Throwable e) {
+            throw new NumbersClientException(e);
+        }
+    }
+
+}

src/main/java/com/bandwidth/sdk/numbers/exception/NumbersClientException.java

@@ -0,0 +1,18 @@
+package com.bandwidth.sdk.numbers.exception;
+
+
+public class NumbersClientException extends RuntimeException {
+
+
+    public NumbersClientException(String message) {
+        super(message);
+    }
+
+    public NumbersClientException(Throwable cause) {
+        super(cause);
+    }
+
+    public NumbersClientException(String message, Throwable cause) {
+        super(message, cause);
+    }
+}

src/main/java/com/bandwidth/sdk/numbers/exception/NumbersServiceException.java

@@ -0,0 +1,35 @@
+package com.bandwidth.sdk.numbers.exception;
+
+import com.bandwidth.sdk.numbers.serde.NumbersSerde;
+import com.bandwidth.sdk.numbers.models.NumbersApiError;
+import org.asynchttpclient.Response;
+
+public class NumbersServiceException extends RuntimeException {
+
+    private NumbersApiError error;
+
+    public NumbersServiceException(NumbersApiError error) {
+        super(error.toString());
+        this.error = error;
+    }
+
+    public NumbersApiError getError() {
+        return error;
+    }
+
+    public static void throwIfApiError(Response apiResponse) {
+        if (!isSuccessfulHttpStatusCode(apiResponse.getStatusCode())) {
+            try {
+                throw new NumbersServiceException(
+                        new NumbersSerde().deserialize(apiResponse.getResponseBody(), NumbersApiError.class)
+                );
+            } catch (Exception e) {
+                throw new NumbersClientException("Unknown error response from API: " + apiResponse);
+            }
+        }
+    }
+
+    static boolean isSuccessfulHttpStatusCode(int statusCode) {
+        return (statusCode / 100) == 2;
+    }
+}

src/main/java/com/bandwidth/sdk/numbers/exception/ThrowableSupplier.java

@@ -0,0 +1,5 @@
+package com.bandwidth.sdk.numbers.exception;
+
+public interface ThrowableSupplier<T> {
+    T get() throws Throwable;
+}

src/main/java/com/bandwidth/sdk/numbers/models/NumbersApiError.java

@@ -0,0 +1,16 @@
+package com.bandwidth.sdk.numbers.models;
+
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import org.immutables.value.Value;
+
+import java.util.List;
+
+@Value.Immutable
+@JsonSerialize(as = ImmutableNumbersApiError.class)
+@JsonDeserialize(as = ImmutableNumbersApiError.class)
+public abstract class NumbersApiError {
+    public abstract String getType();
+    public abstract String getDescription();
+    public abstract List<NumbersApiFieldError> getFieldErrors();
+}

src/main/java/com/bandwidth/sdk/numbers/models/NumbersApiFieldError.java

@@ -0,0 +1,14 @@
+package com.bandwidth.sdk.numbers.models;
+
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import org.immutables.value.Value;
+
+@Value.Immutable
+@JsonSerialize(as = ImmutableNumbersApiFieldError.class)
+@JsonDeserialize(as = ImmutableNumbersApiFieldError.class)
+public abstract class NumbersApiFieldError {
+    public abstract String getFieldName();
+    public abstract String getDescription();
+
+}

src/main/java/com/bandwidth/sdk/numbers/serde/NumbersSerde.java

@@ -0,0 +1,27 @@
+package com.bandwidth.sdk.numbers.serde;
+
+import static com.bandwidth.sdk.numbers.exception.ExceptionUtils.catchClientExceptions;
+
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.dataformat.xml.XmlMapper;
+import com.fasterxml.jackson.datatype.jdk8.Jdk8Module;
+
+
+public class NumbersSerde {
+
+    private static final XmlMapper mapper = new XmlMapper();
+
+    public <T> T deserialize(String messageBody, TypeReference<T> clazz) {
+        return catchClientExceptions(() -> mapper.readValue(messageBody, clazz));
+    }
+
+    public <T> T deserialize(String messageBody, Class<T> clazz) {
+        return catchClientExceptions(() -> mapper.readValue(messageBody, clazz));
+    }
+
+    public <T> String serialize(T objectToMap) {
+        return catchClientExceptions(() -> mapper.writeValueAsString(objectToMap));
+    }
+
+}
+