diff --git a/build.gradle b/build.gradle
index 8664f41..1380be8 100644
--- a/build.gradle
+++ b/build.gradle
@@ -10,7 +10,7 @@ repositories {
 sourceCompatibility = JavaVersion.VERSION_1_8
 
 dependencies {
-    implementation 'com.mashape.unirest:unirest-java:1.4.9'
+    implementation 'com.konghq:unirest-java:2.3.08'
     implementation 'com.squareup.moshi:moshi:1.8.0'
     testImplementation 'junit:junit:4.12'
 }
diff --git a/src/main/java/com/aaroncoplan/todoist/Todoist.java b/src/main/java/com/aaroncoplan/todoist/Todoist.java
index ea9c29c..675c903 100644
--- a/src/main/java/com/aaroncoplan/todoist/Todoist.java
+++ b/src/main/java/com/aaroncoplan/todoist/Todoist.java
@@ -2,9 +2,10 @@
 
 import com.aaroncoplan.todoist.helpers.*;
 import com.aaroncoplan.todoist.model.*;
-import com.mashape.unirest.http.HttpResponse;
-import com.mashape.unirest.http.Unirest;
+import kong.unirest.HttpResponse;
+import kong.unirest.Unirest;
 
+import java.io.IOException;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -16,441 +17,288 @@ public class Todoist {
     private final String URL_BASE = "https://beta.todoist.com/API/v8";
 
     public Todoist(String token) {
-        Unirest.setTimeouts(20_000, 20_000);
-        Unirest.setDefaultHeader("Authorization", String.format("Bearer %s", token));
+        Unirest.config()
+                .connectTimeout(20_000)
+                .socketTimeout(20_000)
+                .addDefaultHeader("Authorization", String.format("Bearer %s", token));
     }
 
-    public List<Project> getAllProjects() {
+    public <T> T extract(CheckedFunction<String, T> extractionFunction, HttpResponse<String> httpResponse) throws TodoistException {
         try {
-            HttpResponse<String> response = Unirest.get(URL_BASE + "/projects")
-                    .asString();
-            if(response.getStatus() != HTTP_OK) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-            return JsonAdapters.extractProjectList(response.getBody());
-        } catch (Exception e) {
-            e.printStackTrace();
-            return null;
+            return extractionFunction.apply(httpResponse.getBody());
+        } catch (IOException e) {
+            throw new TodoistException("Error mapping JSON to Object");
         }
     }
 
-    public Project getProject(long id) {
-        try {
-            HttpResponse<String> response = Unirest.get(URL_BASE + "/projects/" + id)
-                    .asString();
-            if(response.getStatus() != HTTP_OK) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-            return JsonAdapters.extractProject(response.getBody());
-        } catch (Exception e) {
-            e.printStackTrace();
-            return null;
-        }
+    public interface CheckedFunction<P, R> {
+        R apply(P t) throws IOException;
     }
 
-    public Project createNewProject(String name) {
-        try {
-            HttpResponse<String> response = Unirest.post(URL_BASE + "/projects")
-                    .header("Content-Type", "application/json")
-                    .body(JsonAdapters.writeProjectRequest(new ProjectRequest(name)))
-                    .asString();
-            if(response.getStatus() != HTTP_OK) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-            return JsonAdapters.extractProject(response.getBody());
-        } catch (Exception e) {
-            e.printStackTrace();
-            return null;
-        }
+    public List<Project> getAllProjects() throws TodoistException {
+        HttpResponse<String> response = Unirest.get(URL_BASE + "/projects")
+                .asString();
+        if (response.getStatus() != HTTP_OK) throw new TodoistException(response.getStatus());
+        return extract(JsonAdapters::extractProjectList, response);
     }
 
-    public void updateProject(long id, String name) {
-        try {
-            HttpResponse<String> response = Unirest.post(URL_BASE + "/projects/" + id)
-                    .header("Content-Type", "application/json")
-                    .body(JsonAdapters.writeProjectRequest(new ProjectRequest(name)))
-                    .asString();
-            if(response.getStatus() != HTTP_OK_NO_CONTENT) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
+    public Project getProject(long id) throws TodoistException {
+        HttpResponse<String> response = Unirest.get(URL_BASE + "/projects/" + id)
+                .asString();
+        if(response.getStatus() != HTTP_OK) throw new TodoistException(response.getStatus());
+        return extract(JsonAdapters::extractProject, response);
     }
 
-    public void deleteProject(long id) {
-        try {
-            HttpResponse<String> response = Unirest.delete(URL_BASE + "/projects/" + id)
-                    .asString();
-            if(response.getStatus() != HTTP_OK_NO_CONTENT) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
+    public Project createNewProject(String name) throws TodoistException {
+        HttpResponse<String> response = Unirest.post(URL_BASE + "/projects")
+                .header("Content-Type", "application/json")
+                .body(JsonAdapters.writeProjectRequest(new ProjectRequest(name)))
+                .asString();
+        if(response.getStatus() != HTTP_OK) throw new TodoistException(response.getStatus());
+        return extract(JsonAdapters::extractProject, response);
     }
 
-    public List<Task> getActiveTasks() {
-        try {
-            HttpResponse<String> response = Unirest.get(URL_BASE + "/tasks")
-                    .asString();
-            if(response.getStatus() != HTTP_OK) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-
-            return JsonAdapters.extractTaskList(response.getBody());
-        } catch (Exception e) {
-            e.printStackTrace();
-            return null;
-        }
+    public void updateProject(long id, String name) throws TodoistException {
+        HttpResponse<String> response = Unirest.post(URL_BASE + "/projects/" + id)
+                .header("Content-Type", "application/json")
+                .body(JsonAdapters.writeProjectRequest(new ProjectRequest(name)))
+                .asString();
+        if(response.getStatus() != HTTP_OK_NO_CONTENT) throw new TodoistException(response.getStatus());
     }
 
-    public List<Task> getActiveTasks(Long projectId, Long labelId, String filter, String lang) {
-        try {
-            Map<String, Object> params = new HashMap<>();
-            if(projectId != null) params.put("project_id", projectId);
-            if(labelId != null) params.put("label_id", labelId);
-            if(filter != null) params.put("filter", filter);
-            if(lang != null) params.put("lang", lang);
-
-            HttpResponse<String> response = Unirest.get(URL_BASE + "/tasks")
-                    .queryString(params)
-                    .asString();
-            if(response.getStatus() != HTTP_OK) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-            return JsonAdapters.extractTaskList(response.getBody());
-        } catch (Exception e) {
-            e.printStackTrace();
-            return null;
-        }
+    public void deleteProject(long id) throws TodoistException {
+        HttpResponse<String> response = Unirest.delete(URL_BASE + "/projects/" + id)
+                .asString();
+        if(response.getStatus() != HTTP_OK_NO_CONTENT) throw new TodoistException(response.getStatus());
     }
 
-    private Task createNewTask(TaskRequest taskRequest) {
-        try {
-            HttpResponse<String> response = Unirest.post(URL_BASE + "/tasks")
-                    .header("Content-Type", "application/json")
-                    .body(JsonAdapters.writeTaskRequest(taskRequest))
-                    .asString();
-            if(response.getStatus() != HTTP_OK) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-            return JsonAdapters.extractTask(response.getBody());
-        } catch (Exception e) {
-            e.printStackTrace();
-            return null;
-        }
+    public List<Task> getActiveTasks() throws TodoistException {
+        HttpResponse<String> response = Unirest.get(URL_BASE + "/tasks")
+                .asString();
+        if(response.getStatus() != HTTP_OK) throw new TodoistException(response.getStatus());
+        return extract(JsonAdapters::extractTaskList, response);
     }
 
-    public Task createNewTask(String content) {
+    public List<Task> getActiveTasks(Long projectId, Long labelId, String filter, String lang) throws TodoistException {
+        Map<String, Object> params = new HashMap<>();
+        if(projectId != null) params.put("project_id", projectId);
+        if(labelId != null) params.put("label_id", labelId);
+        if(filter != null) params.put("filter", filter);
+        if(lang != null) params.put("lang", lang);
+
+        HttpResponse<String> response = Unirest.get(URL_BASE + "/tasks")
+                .queryString(params)
+                .asString();
+        if(response.getStatus() != HTTP_OK) throw new TodoistException(response.getStatus());
+        return extract(JsonAdapters::extractTaskList, response);
+    }
+
+    private Task createNewTask(TaskRequest taskRequest) throws TodoistException {
+        HttpResponse<String> response = Unirest.post(URL_BASE + "/tasks")
+                .header("Content-Type", "application/json")
+                .body(JsonAdapters.writeTaskRequest(taskRequest))
+                .asString();
+        if(response.getStatus() != HTTP_OK) throw new TodoistException(response.getStatus());
+        return extract(JsonAdapters::extractTask, response);
+    }
+
+    public Task createNewTask(String content) throws TodoistException {
         return createNewTask(new TaskRequest(content, null, null, null, null, null, null, null, null));
     }
 
-    public Task createNewTask(String content, Long projectId, Integer order, List<Long> labelIds, Integer priority, String dueString, String dueDate, String dueDateTime, String dueLang) {
+    public Task createNewTask(String content, Long projectId, Integer order, List<Long> labelIds, Integer priority, String dueString, String dueDate, String dueDateTime, String dueLang) throws TodoistException {
         return createNewTask(new TaskRequest(content, projectId, order, labelIds, priority, dueString, dueDate, dueDateTime, dueLang));
     }
 
-    public Task getActiveTask(long id) {
-        try {
-            HttpResponse<String> response = Unirest.get(URL_BASE + "/tasks/" + id)
-                    .asString();
-            if(response.getStatus() != HTTP_OK) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-            return JsonAdapters.extractTask(response.getBody());
-        } catch (Exception e) {
-            e.printStackTrace();
-            return null;
-        }
+    public Task getActiveTask(long id) throws TodoistException {
+        HttpResponse<String> response = Unirest.get(URL_BASE + "/tasks/" + id)
+                .asString();
+        if(response.getStatus() != HTTP_OK) throw new TodoistException(response.getStatus());
+        return extract(JsonAdapters::extractTask, response);
     }
 
-    public void updateTask(long id, String content, Long projectId, List<Long> labelIds, Integer priority, String dueString, String dueDate, String dueDateTime, String dueLang) {
-        try {
-            HttpResponse<String> response = Unirest.post(URL_BASE + "/tasks/" + id)
-                    .header("Content-Type", "application/json")
-                    .body(JsonAdapters.writeTaskRequest(new TaskRequest(content, projectId, null, labelIds, priority, dueString, dueDate, dueDateTime, dueLang)))
-                    .asString();
-            if(response.getStatus() != HTTP_OK_NO_CONTENT) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
+    public void updateTask(long id, String content, Long projectId, List<Long> labelIds, Integer priority, String dueString, String dueDate, String dueDateTime, String dueLang) throws TodoistException {
+        HttpResponse<String> response = Unirest.post(URL_BASE + "/tasks/" + id)
+                .header("Content-Type", "application/json")
+                .body(JsonAdapters.writeTaskRequest(new TaskRequest(content, projectId, null, labelIds, priority, dueString, dueDate, dueDateTime, dueLang)))
+                .asString();
+        if(response.getStatus() != HTTP_OK_NO_CONTENT) throw new TodoistException(response.getStatus());
     }
 
-    public void closeTask(long id) {
-        try {
-            HttpResponse<String> response = Unirest.post(URL_BASE + "/tasks/" + id + "/close")
-                    .asString();
-            if(response.getStatus() != HTTP_OK_NO_CONTENT) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
+    public void closeTask(long id) throws TodoistException {
+        HttpResponse<String> response = Unirest.post(URL_BASE + "/tasks/" + id + "/close")
+                .asString();
+        if(response.getStatus() != HTTP_OK_NO_CONTENT) throw new TodoistException(response.getStatus());
     }
 
-    public void deleteTask(long id) {
-        try {
-            HttpResponse<String> response = Unirest.delete(URL_BASE + "/tasks/" + id)
-                    .asString();
-            if(response.getStatus() != HTTP_OK_NO_CONTENT) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
+    public void deleteTask(long id) throws TodoistException {
+        HttpResponse<String> response = Unirest.delete(URL_BASE + "/tasks/" + id)
+                .asString();
+        if(response.getStatus() != HTTP_OK_NO_CONTENT) throw new TodoistException(response.getStatus());
     }
 
-    public List<Label> getAllLabels() {
-        try {
-            HttpResponse<String> response = Unirest.get(URL_BASE + "/labels")
-                    .asString();
-            if(response.getStatus() != HTTP_OK) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-            return JsonAdapters.extractLabelList(response.getBody());
-        } catch (Exception e) {
-            e.printStackTrace();
-            return null;
-        }
+    public List<Label> getAllLabels() throws TodoistException {
+        HttpResponse<String> response = Unirest.get(URL_BASE + "/labels")
+                .asString();
+        if(response.getStatus() != HTTP_OK) throw new TodoistException(response.getStatus());
+        return extract(JsonAdapters::extractLabelList, response);
     }
 
-    public Label createNewLabel(String name) {
+    public Label createNewLabel(String name) throws TodoistException {
         return createNewLabel(name, null);
     }
 
-    public Label createNewLabel(String name, Integer order) {
-        try {
-            HttpResponse<String> response = Unirest.post(URL_BASE + "/labels")
-                    .header("Content-Type", "application/json")
-                    .body(JsonAdapters.writeLabelRequest(new LabelRequest(name, order)))
-                    .asString();
-            if(response.getStatus() != HTTP_OK) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-            return JsonAdapters.extractLabel(response.getBody());
-        } catch (Exception e) {
-            e.printStackTrace();
-            return null;
-        }
+    public Label createNewLabel(String name, Integer order) throws TodoistException {
+        HttpResponse<String> response = Unirest.post(URL_BASE + "/labels")
+                .header("Content-Type", "application/json")
+                .body(JsonAdapters.writeLabelRequest(new LabelRequest(name, order)))
+                .asString();
+        if(response.getStatus() != HTTP_OK) throw new TodoistException(response.getStatus());
+        return extract(JsonAdapters::extractLabel, response);
     }
 
-    public Label getLabel(long id) {
-        try {
-            HttpResponse<String> response = Unirest.get(URL_BASE + "/labels/" + id)
-                    .asString();
-            if(response.getStatus() != HTTP_OK) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-            return JsonAdapters.extractLabel(response.getBody());
-        } catch (Exception e) {
-            e.printStackTrace();
-            return null;
-        }
+    public Label getLabel(long id) throws TodoistException {
+        HttpResponse<String> response = Unirest.get(URL_BASE + "/labels/" + id)
+                .asString();
+        if(response.getStatus() != HTTP_OK) throw new TodoistException(response.getStatus());
+        return extract(JsonAdapters::extractLabel, response);
     }
 
-    public void updateLabel(long id, String name, Integer order) {
-        try {
-            HttpResponse<String> response = Unirest.post(URL_BASE + "/labels/" + id)
-                    .header("Content-Type", "application/json")
-                    .body(JsonAdapters.writeLabelRequest(new LabelRequest(name, order)))
-                    .asString();
-            if(response.getStatus() != HTTP_OK_NO_CONTENT) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
+    public void updateLabel(long id, String name, Integer order) throws TodoistException {
+        HttpResponse<String> response = Unirest.post(URL_BASE + "/labels/" + id)
+                .header("Content-Type", "application/json")
+                .body(JsonAdapters.writeLabelRequest(new LabelRequest(name, order)))
+                .asString();
+        if(response.getStatus() != HTTP_OK_NO_CONTENT) throw new TodoistException(response.getStatus());
     }
 
-    public void deleteLabel(long id) {
-        try {
-            HttpResponse<String> response = Unirest.delete(URL_BASE + "/labels/" + id)
-                    .asString();
-            if(response.getStatus() != HTTP_OK_NO_CONTENT) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
+    public void deleteLabel(long id) throws TodoistException {
+        HttpResponse<String> response = Unirest.delete(URL_BASE + "/labels/" + id)
+                .asString();
+        if(response.getStatus() != HTTP_OK_NO_CONTENT) throw new TodoistException(response.getStatus());
     }
 
-    public List<Comment> getAllCommentsForProject(long id) {
-        try {
-            HttpResponse<String> response = Unirest.get(URL_BASE + "/comments")
-                    .queryString("project_id", id)
-                    .asString();
-            if(response.getStatus() != HTTP_OK) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-            return JsonAdapters.extractCommentList(response.getBody());
-        } catch (Exception e) {
-            e.printStackTrace();
-            return null;
-        }
+    public List<Comment> getAllCommentsForProject(long id) throws TodoistException {
+        HttpResponse<String> response = Unirest.get(URL_BASE + "/comments")
+                .queryString("project_id", id)
+                .asString();
+        if(response.getStatus() != HTTP_OK) throw new TodoistException(response.getStatus());
+        return extract(JsonAdapters::extractCommentList, response);
     }
 
-    public List<Comment> getAllCommentsForTask(long id) {
-        try {
-            HttpResponse<String> response = Unirest.get(URL_BASE + "/comments")
-                    .queryString("task_id", id)
-                    .asString();
-            if(response.getStatus() != HTTP_OK) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-            return JsonAdapters.extractCommentList(response.getBody());
-        } catch (Exception e) {
-            e.printStackTrace();
-            return null;
-        }
+    public List<Comment> getAllCommentsForTask(long id) throws TodoistException {
+        HttpResponse<String> response = Unirest.get(URL_BASE + "/comments")
+                .queryString("task_id", id)
+                .asString();
+        if(response.getStatus() != HTTP_OK) throw new TodoistException(response.getStatus());
+        return extract(JsonAdapters::extractCommentList, response);
     }
 
-    private Comment createNewComment(Long taskId, Long projectId, String content, AttachmentRequest attachmentRequest) {
-        try {
-            HttpResponse<String> response = Unirest.post(URL_BASE + "/comments")
-                    .header("Content-Type", "application/json")
-                    .body(JsonAdapters.writeCommentRequest(new CommentRequest(taskId, projectId, content, attachmentRequest)))
-                    .asString();
-            if(response.getStatus() != HTTP_OK) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-            return JsonAdapters.extractComment(response.getBody());
-        } catch (Exception e) {
-            e.printStackTrace();
-            return null;
-        }
+    private Comment createNewComment(Long taskId, Long projectId, String content, AttachmentRequest attachmentRequest) throws TodoistException {
+        HttpResponse<String> response = Unirest.post(URL_BASE + "/comments")
+                .header("Content-Type", "application/json")
+                .body(JsonAdapters.writeCommentRequest(new CommentRequest(taskId, projectId, content, attachmentRequest)))
+                .asString();
+        if(response.getStatus() != HTTP_OK) throw new TodoistException(response.getStatus());
+        return extract(JsonAdapters::extractComment, response);
     }
 
-    public Comment createNewCommentForTask(long id, String content) {
+    public Comment createNewCommentForTask(long id, String content) throws TodoistException {
         return createNewComment(id, null, content, null);
     }
 
-    public Comment createNewCommentForTask(long id, String content, AttachmentRequest attachmentRequest) {
+    public Comment createNewCommentForTask(long id, String content, AttachmentRequest attachmentRequest) throws TodoistException {
         return createNewComment(id, null, content, attachmentRequest);
     }
 
-    public Comment createNewCommentForProject(long id, String content) {
+    public Comment createNewCommentForProject(long id, String content) throws TodoistException {
         return createNewComment(null, id, content, null);
     }
 
-    public Comment createNewCommentForProject(long id, String content, AttachmentRequest attachmentRequest) {
+    public Comment createNewCommentForProject(long id, String content, AttachmentRequest attachmentRequest) throws TodoistException {
         return createNewComment(null, id, content, attachmentRequest);
     }
 
-    public Comment getComment(long id) {
-        try {
-            HttpResponse<String> response = Unirest.get(URL_BASE + "/comments/" + id)
-                    .asString();
-            if(response.getStatus() != HTTP_OK) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-            return JsonAdapters.extractComment(response.getBody());
-        } catch (Exception e) {
-            e.printStackTrace();
-            return null;
-        }
+    public Comment getComment(long id) throws TodoistException {
+        HttpResponse<String> response = Unirest.get(URL_BASE + "/comments/" + id)
+                .asString();
+        if(response.getStatus() != HTTP_OK) throw new TodoistException(response.getStatus());
+        return extract(JsonAdapters::extractComment, response);
     }
 
-    public void updateComment(long id, String content) {
-        try {
-            HttpResponse<String> response = Unirest.post(URL_BASE + "/comments/" + id)
-                    .header("Content-Type", "application/json")
-                    .body(JsonAdapters.writeCommentRequest(new CommentRequest(null, null, content, null)))
-                    .asString();
-            if(response.getStatus() != HTTP_OK_NO_CONTENT) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
+    public void updateComment(long id, String content) throws TodoistException {
+        HttpResponse<String> response = Unirest.post(URL_BASE + "/comments/" + id)
+                .header("Content-Type", "application/json")
+                .body(JsonAdapters.writeCommentRequest(new CommentRequest(null, null, content, null)))
+                .asString();
+        if(response.getStatus() != HTTP_OK_NO_CONTENT) throw new TodoistException(response.getStatus());
     }
 
-    public void deleteComment(long id) {
-        try {
-            HttpResponse<String> response = Unirest.delete(URL_BASE + "/comments/" + id)
-                    .asString();
-            if(response.getStatus() != HTTP_OK_NO_CONTENT) {
-                throw new Exception("HTTP STATUS " + response.getStatus());
-            }
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
+    public void deleteComment(long id) throws TodoistException {
+        HttpResponse<String> response = Unirest.delete(URL_BASE + "/comments/" + id)
+                .asString();
+        if(response.getStatus() != HTTP_OK_NO_CONTENT) throw new TodoistException(response.getStatus());
     }
 
-    public List<Activity> getActivityForProject(long id) {
+    public List<Activity> getActivityForProject(long id) throws TodoistException {
         return getActivityForProject(id, ActivityType.ALL);
     }
 
-    public List<Activity> getActivityForProject(long id, ActivityType... types) {
-        try {
-            int limit = 30;
-            int offset = 0;
-            int count;
-
-            List<String> activityTypes = Arrays.stream(types)
-                    .flatMap(ActivityType::getStream)
-                    .collect(Collectors.toList());
-
-            List<Activity> activityList = new ArrayList<>();
-            do {
-                HttpResponse<String> response = Unirest.post("https://todoist.com/API/v8/activity/get")
-                        .header("Content-Type", "application/json")
-                        .body(JsonAdapters.writeActivityRequest(new ActivityRequest(limit, offset, activityTypes, null, null, true, id, true)))
-                        .asString();
-                if (response.getStatus() != HTTP_OK) {
-                    throw new Exception("HTTP STATUS " + response.getStatus());
-                }
-
-                ActivityResponse activityResponse = JsonAdapters.extractActivityResponse(response.getBody());
-                activityList.addAll(activityResponse.events);
-
-                count = activityResponse.count;
-                offset += limit;
-            } while(offset < count);
-
-            return activityList;
-        } catch (Exception e) {
-            e.printStackTrace();
-            return null;
-        }
+    public List<Activity> getActivityForProject(long id, ActivityType... types) throws TodoistException {
+        int limit = 30;
+        int offset = 0;
+        int count;
+
+        List<String> activityTypes = Arrays.stream(types)
+                .flatMap(ActivityType::getStream)
+                .collect(Collectors.toList());
+
+        List<Activity> activityList = new ArrayList<>();
+        do {
+            HttpResponse<String> response = Unirest.post("https://todoist.com/API/v8/activity/get")
+                    .header("Content-Type", "application/json")
+                    .body(JsonAdapters.writeActivityRequest(new ActivityRequest(limit, offset, activityTypes, null, null, true, id, true)))
+                    .asString();
+            if (response.getStatus() != HTTP_OK) throw new TodoistException(response.getStatus());
+
+            ActivityResponse activityResponse = extract(JsonAdapters::extractActivityResponse, response);
+            activityList.addAll(activityResponse.events);
+
+            count = activityResponse.count;
+            offset += limit;
+        } while(offset < count);
+
+        return activityList;
     }
 
-    public List<Activity> getActivityForTask(long id) {
+    public List<Activity> getActivityForTask(long id) throws TodoistException {
         return getActivityForTask(id, ActivityType.ALL);
     }
 
-    public List<Activity> getActivityForTask(long id, ActivityType... types) {
-        try {
-            int limit = 30;
-            int offset = 0;
-            int count;
-
-            List<String> activityTypes = Arrays.stream(types)
-                    .flatMap(ActivityType::getStream)
-                    .collect(Collectors.toList());
-
-            List<Activity> activityList = new ArrayList<>();
-            do {
-                HttpResponse<String> response = Unirest.post("https://todoist.com/API/v8/activity/get")
-                        .header("Content-Type", "application/json")
-                        .body(JsonAdapters.writeActivityRequest(new ActivityRequest(limit, offset, activityTypes, id, true, true, null, null)))
-                        .asString();
-                if (response.getStatus() != HTTP_OK) {
-                    throw new Exception("HTTP STATUS " + response.getStatus());
-                }
-
-                ActivityResponse activityResponse = JsonAdapters.extractActivityResponse(response.getBody());
-                activityList.addAll(activityResponse.events);
-
-                count = activityResponse.count;
-                offset += limit;
-            } while(offset < count);
-
-            return activityList;
-        } catch (Exception e) {
-            e.printStackTrace();
-            return null;
-        }
+    public List<Activity> getActivityForTask(long id, ActivityType... types) throws TodoistException {
+        int limit = 30;
+        int offset = 0;
+        int count;
+
+        List<String> activityTypes = Arrays.stream(types)
+                .flatMap(ActivityType::getStream)
+                .collect(Collectors.toList());
+
+        List<Activity> activityList = new ArrayList<>();
+        do {
+            HttpResponse<String> response = Unirest.post("https://todoist.com/API/v8/activity/get")
+                    .header("Content-Type", "application/json")
+                    .body(JsonAdapters.writeActivityRequest(new ActivityRequest(limit, offset, activityTypes, id, true, true, null, null)))
+                    .asString();
+            if (response.getStatus() != HTTP_OK) throw new TodoistException(response.getStatus());
+
+            ActivityResponse activityResponse = extract(JsonAdapters::extractActivityResponse, response);
+            activityList.addAll(activityResponse.events);
+
+            count = activityResponse.count;
+            offset += limit;
+        } while(offset < count);
+
+        return activityList;
     }
 }
diff --git a/src/main/java/com/aaroncoplan/todoist/TodoistException.java b/src/main/java/com/aaroncoplan/todoist/TodoistException.java
new file mode 100644
index 0000000..0618c4f
--- /dev/null
+++ b/src/main/java/com/aaroncoplan/todoist/TodoistException.java
@@ -0,0 +1,12 @@
+package com.aaroncoplan.todoist;
+
+public class TodoistException extends Exception {
+
+    public TodoistException(int httpStatus) {
+        super(String.format("Request failed with HTTP Status %d", httpStatus));
+    }
+
+    public TodoistException(String message) {
+        super(message);
+    }
+}