From 4d07476fe76d2b99eff23b78777833a62c8eb4c7 Mon Sep 17 00:00:00 2001
From: asonix <asonix@asonix.dog>
Date: Mon, 20 Apr 2020 20:03:46 -0500
Subject: [PATCH] Give jobs better names

---
 src/jobs/apub/announce.rs     | 2 +-
 src/jobs/apub/follow.rs       | 2 +-
 src/jobs/apub/forward.rs      | 2 +-
 src/jobs/apub/reject.rs       | 2 +-
 src/jobs/apub/undo.rs         | 2 +-
 src/jobs/deliver.rs           | 2 +-
 src/jobs/deliver_many.rs      | 2 +-
 src/jobs/instance.rs          | 2 +-
 src/jobs/nodeinfo.rs          | 2 +-
 src/jobs/process_listeners.rs | 2 +-
 10 files changed, 10 insertions(+), 10 deletions(-)

diff --git a/src/jobs/apub/announce.rs b/src/jobs/apub/announce.rs
index 059139d..b71d3b1 100644
--- a/src/jobs/apub/announce.rs
+++ b/src/jobs/apub/announce.rs
@@ -60,7 +60,7 @@ impl ActixJob for Announce {
     type State = JobState;
     type Future = Pin<Box<dyn Future<Output = Result<(), anyhow::Error>>>>;
 
-    const NAME: &'static str = "AnnounceProcessor";
+    const NAME: &'static str = "relay::jobs::apub::Announce";
 
     fn run(self, state: Self::State) -> Self::Future {
         Box::pin(self.perform(state))
diff --git a/src/jobs/apub/follow.rs b/src/jobs/apub/follow.rs
index ea8156b..3d20890 100644
--- a/src/jobs/apub/follow.rs
+++ b/src/jobs/apub/follow.rs
@@ -105,7 +105,7 @@ impl ActixJob for Follow {
     type State = JobState;
     type Future = Pin<Box<dyn Future<Output = Result<(), anyhow::Error>>>>;
 
-    const NAME: &'static str = "FollowProcessor";
+    const NAME: &'static str = "relay::jobs::apub::Follow";
 
     fn run(self, state: Self::State) -> Self::Future {
         Box::pin(self.perform(state))
diff --git a/src/jobs/apub/forward.rs b/src/jobs/apub/forward.rs
index a358610..c6d8aed 100644
--- a/src/jobs/apub/forward.rs
+++ b/src/jobs/apub/forward.rs
@@ -34,7 +34,7 @@ impl ActixJob for Forward {
     type State = JobState;
     type Future = Pin<Box<dyn Future<Output = Result<(), anyhow::Error>>>>;
 
-    const NAME: &'static str = "ForwardProcessor";
+    const NAME: &'static str = "relay::jobs::apub::Forward";
 
     fn run(self, state: Self::State) -> Self::Future {
         Box::pin(self.perform(state))
diff --git a/src/jobs/apub/reject.rs b/src/jobs/apub/reject.rs
index 401fbc3..758669e 100644
--- a/src/jobs/apub/reject.rs
+++ b/src/jobs/apub/reject.rs
@@ -29,7 +29,7 @@ impl ActixJob for Reject {
     type State = JobState;
     type Future = Pin<Box<dyn Future<Output = Result<(), anyhow::Error>>>>;
 
-    const NAME: &'static str = "RejectProcessor";
+    const NAME: &'static str = "relay::jobs::apub::Reject";
 
     fn run(self, state: Self::State) -> Self::Future {
         Box::pin(self.perform(state))
diff --git a/src/jobs/apub/undo.rs b/src/jobs/apub/undo.rs
index 5c6e3bc..0a7ab4c 100644
--- a/src/jobs/apub/undo.rs
+++ b/src/jobs/apub/undo.rs
@@ -42,7 +42,7 @@ impl ActixJob for Undo {
     type State = JobState;
     type Future = Pin<Box<dyn Future<Output = Result<(), anyhow::Error>>>>;
 
-    const NAME: &'static str = "UndoProcessor";
+    const NAME: &'static str = "relay::jobs::apub::Undo";
 
     fn run(self, state: Self::State) -> Self::Future {
         Box::pin(self.perform(state))
diff --git a/src/jobs/deliver.rs b/src/jobs/deliver.rs
index 8ad8bc4..95ad1ec 100644
--- a/src/jobs/deliver.rs
+++ b/src/jobs/deliver.rs
@@ -26,7 +26,7 @@ impl ActixJob for Deliver {
     type State = JobState;
     type Future = Pin<Box<dyn Future<Output = Result<(), Error>>>>;
 
-    const NAME: &'static str = "DeliverProcessor";
+    const NAME: &'static str = "relay::jobs::Deliver";
     const BACKOFF: Backoff = Backoff::Exponential(8);
 
     fn run(self, state: Self::State) -> Self::Future {
diff --git a/src/jobs/deliver_many.rs b/src/jobs/deliver_many.rs
index 0957f5c..977faa1 100644
--- a/src/jobs/deliver_many.rs
+++ b/src/jobs/deliver_many.rs
@@ -39,7 +39,7 @@ impl ActixJob for DeliverMany {
     type State = JobState;
     type Future = Ready<Result<(), Error>>;
 
-    const NAME: &'static str = "DeliverManyProcessor";
+    const NAME: &'static str = "relay::jobs::DeliverMany";
 
     fn run(self, state: Self::State) -> Self::Future {
         ready(self.perform(state))
diff --git a/src/jobs/instance.rs b/src/jobs/instance.rs
index 362114a..f272c91 100644
--- a/src/jobs/instance.rs
+++ b/src/jobs/instance.rs
@@ -85,7 +85,7 @@ impl ActixJob for QueryInstance {
     type State = JobState;
     type Future = Pin<Box<dyn Future<Output = Result<(), Error>>>>;
 
-    const NAME: &'static str = "InstanceProcessor";
+    const NAME: &'static str = "relay::jobs::QueryInstance";
 
     fn run(self, state: Self::State) -> Self::Future {
         Box::pin(self.perform(state))
diff --git a/src/jobs/nodeinfo.rs b/src/jobs/nodeinfo.rs
index 70878d2..a076d0e 100644
--- a/src/jobs/nodeinfo.rs
+++ b/src/jobs/nodeinfo.rs
@@ -56,7 +56,7 @@ impl ActixJob for QueryNodeinfo {
     type State = JobState;
     type Future = Pin<Box<dyn Future<Output = Result<(), Error>>>>;
 
-    const NAME: &'static str = "NodeinfoProcessor";
+    const NAME: &'static str = "relay::jobs::QueryNodeinfo";
 
     fn run(self, state: Self::State) -> Self::Future {
         Box::pin(self.perform(state))
diff --git a/src/jobs/process_listeners.rs b/src/jobs/process_listeners.rs
index 9ed8c79..b44fc1f 100644
--- a/src/jobs/process_listeners.rs
+++ b/src/jobs/process_listeners.rs
@@ -23,7 +23,7 @@ impl ActixJob for Listeners {
     type State = JobState;
     type Future = Pin<Box<dyn Future<Output = Result<(), Error>>>>;
 
-    const NAME: &'static str = "ProcessListenersProcessor";
+    const NAME: &'static str = "relay::jobs::Listeners";
 
     fn run(self, state: Self::State) -> Self::Future {
         Box::pin(self.perform(state))