From 61c324508e62bb640b4526183d0837fc57d742c2 Mon Sep 17 00:00:00 2001
From: Andrew Godwin
Date: Tue, 8 Nov 2022 23:06:29 -0700
Subject: Midway point in task refactor - changing direction

---
 miniq/tasks.py | 34 ----------------------------------
 1 file changed, 34 deletions(-)
 delete mode 100644 miniq/tasks.py

(limited to 'miniq/tasks.py')

diff --git a/miniq/tasks.py b/miniq/tasks.py
deleted file mode 100644
index fedf8fd..0000000
--- a/miniq/tasks.py
+++ /dev/null
@@ -1,34 +0,0 @@
-import traceback
-
-from users.tasks.follow import handle_follow_request
-from users.tasks.identity import handle_identity_fetch
-from users.tasks.inbox import handle_inbox_item
-
-
-class TaskHandler:
-
-    handlers = {
-        "identity_fetch": handle_identity_fetch,
-        "inbox_item": handle_inbox_item,
-        "follow_request": handle_follow_request,
-    }
-
-    def __init__(self, task):
-        self.task = task
-        self.subject = self.task.subject
-        self.payload = self.task.payload
-
-    async def handle(self):
-        try:
-            print(f"Task {self.task}: Starting")
-            if self.task.type not in self.handlers:
-                raise ValueError(f"Cannot handle type {self.task.type}")
-            await self.handlers[self.task.type](
-                self,
-            )
-            await self.task.complete()
-            print(f"Task {self.task}: Complete")
-        except BaseException as e:
-            print(f"Task {self.task}: Error {e}")
-            traceback.print_exc()
-            await self.task.fail(f"{e}\n\n" + traceback.format_exc())
-- 
cgit v1.2.3