runtasktic 1.2.1

Command-line task management tool for execution of regular long sequential or parallel tasks.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133

use serde::de::Deserialize;
use std::collections::HashMap;
use std::env::var as get_env;

const ENV_NOTIFICATION_SLACK_URL: &str = "RUNTASKTIK_NOTIFICATION_SLACK_URL";
const ENV_NOTIFICATION_SLACK_CHANNEL: &str = "RUNTASKTIK_NOTIFICATION_SLACK_CHANNEL";
const ENV_NOTIFICATION_SLACK_USERNAME: &str = "RUNTASKTIK_NOTIFICATION_SLACK_USERNAME";

const ENV_NOTIFICATION_DISCORD_URL: &str = "RUNTASKTIK_NOTIFICATION_DISCORD_URL";
const ENV_NOTIFICATION_DISCORD_USERNAME: &str = "RUNTASKTIK_NOTIFICATION_DISCORD_USERNAME";

const ENV_NOTIFICATION_EMAIL_SMTP_HOSTNAME: &str = "RUNTASKTIK_NOTIFICATION_EMAIL_SMTP_HOSTNAME";
const ENV_NOTIFICATION_EMAIL_SMTP_USERNAME: &str = "RUNTASKTIK_NOTIFICATION_EMAIL_SMTP_USERNAME";
const ENV_NOTIFICATION_EMAIL_SMTP_SECRET: &str = "RUNTASKTIK_NOTIFICATION_EMAIL_SMTP_SECRET";

pub fn default_concurrency() -> i64 {
  -1
}

pub fn default_email_port() -> u16 {
  587
}

pub fn default_true() -> bool {
  true
}

pub fn default_email_subject() -> String {
  format!("Runtasktik: task ended")
}

pub fn deserialize_task<'de, D>(deserializer: D) -> Result<HashMap<String, super::Task>, D::Error>
where
  D: serde::Deserializer<'de>,
{
  if let Ok(mut tasks) = HashMap::deserialize(deserializer) {
    for e in tasks.iter_mut() {
      let (id, task): (&String, &mut super::Task) = e;
      task.id = id.clone();
    }
    Ok(tasks)
  } else {
    Ok(HashMap::new())
  }
}

pub fn notification_slack_url<'de, D>(deserializer: D) -> Result<String, D::Error>
where
  D: serde::Deserializer<'de>,
{
  if let Ok(env) = get_env(ENV_NOTIFICATION_SLACK_URL) {
    Ok(env)
  } else {
    String::deserialize(deserializer)
  }
}

pub fn notification_slack_channel<'de, D>(deserializer: D) -> Result<String, D::Error>
where
  D: serde::Deserializer<'de>,
{
  if let Ok(env) = get_env(ENV_NOTIFICATION_SLACK_CHANNEL) {
    Ok(env)
  } else {
    String::deserialize(deserializer)
  }
}

pub fn notification_slack_username<'de, D>(deserializer: D) -> Result<Option<String>, D::Error>
where
  D: serde::Deserializer<'de>,
{
  if let Ok(env) = get_env(ENV_NOTIFICATION_SLACK_USERNAME) {
    Ok(Some(env))
  } else {
    Option::deserialize(deserializer)
  }
}

pub fn notification_discord_url<'de, D>(deserializer: D) -> Result<String, D::Error>
where
  D: serde::Deserializer<'de>,
{
  if let Ok(env) = get_env(ENV_NOTIFICATION_DISCORD_URL) {
    Ok(env)
  } else {
    String::deserialize(deserializer)
  }
}

pub fn notification_discord_username<'de, D>(deserializer: D) -> Result<Option<String>, D::Error>
where
  D: serde::Deserializer<'de>,
{
  if let Ok(env) = get_env(ENV_NOTIFICATION_DISCORD_USERNAME) {
    Ok(Some(env))
  } else {
    Option::deserialize(deserializer)
  }
}

pub fn notification_email_smtp_hostname<'de, D>(deserializer: D) -> Result<String, D::Error>
where
  D: serde::Deserializer<'de>,
{
  if let Ok(env) = get_env(ENV_NOTIFICATION_EMAIL_SMTP_HOSTNAME) {
    Ok(env)
  } else {
    String::deserialize(deserializer)
  }
}

pub fn notification_email_smtp_username<'de, D>(deserializer: D) -> Result<Option<String>, D::Error>
where
  D: serde::Deserializer<'de>,
{
  if let Ok(env) = get_env(ENV_NOTIFICATION_EMAIL_SMTP_USERNAME) {
    Ok(Some(env))
  } else {
    Option::deserialize(deserializer)
  }
}

pub fn notification_email_smtp_secret<'de, D>(deserializer: D) -> Result<String, D::Error>
where
  D: serde::Deserializer<'de>,
{
  if let Ok(env) = get_env(ENV_NOTIFICATION_EMAIL_SMTP_SECRET) {
    Ok(env)
  } else {
    String::deserialize(deserializer)
  }
}