Update fang from 0.9 to 0.10

Cargo.toml

@@ -16,7 +16,7 @@ chrono = "0.4"
 diesel = { version = "2", features = ["postgres","r2d2"] }
 dotenv = "0.15"
 pretty_env_logger = "0.4"
-fang = { version = "0.9", features = ["blocking"], default-features = false }
+fang = { version = "0.10", features = ["blocking"], default-features = false }
 feed-rs = "1"
 frankenstein = { version = "0.20", default-features = false, features = ["telegram-trait"] }
 handlebars = "4"

migrations/2022-09-30-045157_modify_fang_tables/down.sql

@@ -0,0 +1,21 @@
+DROP TABLE fang_tasks;
+DROP TYPE fang_task_state;
+
+CREATE TYPE fang_task_state AS ENUM ('new', 'in_progress', 'failed', 'finished');
+
+CREATE TABLE fang_tasks (
+     id uuid PRIMARY KEY DEFAULT uuid_generate_v4(),
+     metadata jsonb NOT NULL,
+     error_message TEXT,
+     state fang_task_state DEFAULT 'new' NOT NULL,
+     task_type VARCHAR DEFAULT 'common' NOT NULL,
+     uniq_hash CHAR(64),
+     scheduled_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
+     created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
+     updated_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
+);
+
+CREATE INDEX fang_tasks_state_index ON fang_tasks(state);
+CREATE INDEX fang_tasks_type_index ON fang_tasks(task_type);
+CREATE INDEX fang_tasks_scheduled_at_index ON fang_tasks(scheduled_at);
+CREATE INDEX fang_tasks_uniq_hash ON fang_tasks(uniq_hash);

migrations/2022-09-30-045157_modify_fang_tables/up.sql

@@ -0,0 +1,22 @@
+DROP TABLE fang_tasks;
+DROP TYPE fang_task_state;
+
+CREATE TYPE fang_task_state AS ENUM ('new', 'in_progress', 'failed', 'finished', 'retried');
+
+CREATE TABLE fang_tasks (
+     id uuid PRIMARY KEY DEFAULT uuid_generate_v4(),
+     metadata jsonb NOT NULL,
+     error_message TEXT,
+     state fang_task_state DEFAULT 'new' NOT NULL,
+     task_type VARCHAR DEFAULT 'common' NOT NULL,
+     uniq_hash CHAR(64),
+     retries INTEGER DEFAULT 0 NOT NULL,
+     scheduled_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
+     created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
+     updated_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
+);
+
+CREATE INDEX fang_tasks_state_index ON fang_tasks(state);
+CREATE INDEX fang_tasks_type_index ON fang_tasks(task_type);
+CREATE INDEX fang_tasks_scheduled_at_index ON fang_tasks(scheduled_at);
+CREATE INDEX fang_tasks_uniq_hash ON fang_tasks(uniq_hash);

src/cleaner/clean_job.rs

@@ -88,6 +88,10 @@ impl Runnable for CleanJob {
         super::JOB_TYPE.to_string()
     }
 
+    fn max_retries(&self) -> i32 {
+        0
+    }
+
     fn cron(&self) -> Option<Scheduled> {
         Some(Scheduled::CronPattern(Config::clean_cron_pattern()))
     }

src/cleaner/remove_old_items_job.rs

@@ -44,6 +44,10 @@ impl Runnable for RemoveOldItemsJob {
         true
     }
 
+    fn max_retries(&self) -> i32 {
+        0
+    }
+
     fn task_type(&self) -> String {
         super::JOB_TYPE.to_string()
     }

src/deliver/deliver_chat_updates_job.rs

@@ -300,6 +300,10 @@ impl Runnable for DeliverChatUpdatesJob {
         true
     }
 
+    fn max_retries(&self) -> i32 {
+        0
+    }
+
     fn task_type(&self) -> String {
         JOB_TYPE.to_string()
     }

src/deliver/deliver_job.rs

@@ -78,6 +78,10 @@ impl Runnable for DeliverJob {
         true
     }
 
+    fn max_retries(&self) -> i32 {
+        0
+    }
+
     fn task_type(&self) -> String {
         super::JOB_TYPE.to_string()
     }

src/sync/sync_feed_job.rs

@@ -59,6 +59,10 @@ impl Runnable for SyncFeedJob {
         true
     }
 
+    fn max_retries(&self) -> i32 {
+        0
+    }
+
     fn task_type(&self) -> String {
         super::JOB_TYPE.to_string()
     }

src/sync/sync_job.rs

@@ -89,6 +89,10 @@ impl Runnable for SyncJob {
         true
     }
 
+    fn max_retries(&self) -> i32 {
+        0
+    }
+
     fn task_type(&self) -> String {
         super::JOB_TYPE.to_string()
     }