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
|
use serde::{Deserialize, Serialize};
use std::{fmt, fs};
use tokio::sync::mpsc;
#[derive(Clone, Debug, Deserialize, Serialize)]
pub struct AgendaPoint {
title: String,
adder: String,
}
impl fmt::Display for AgendaPoint {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
write!(f, "{} ({})", self.title, self.adder)
}
}
impl AgendaPoint {
pub fn to_add_message(&self) -> String {
format!("'{}' added by {}", self.title, self.adder)
}
}
#[derive(Deserialize, Serialize)]
pub struct Agenda {
points: Vec<AgendaPoint>,
}
impl Agenda {
fn write(&self) {
fs::write(
std::path::Path::new("agenda.json"),
serde_json::to_string_pretty(&self).expect("Can't serialize agenda"),
)
.expect("Can't write agenda.json");
}
}
impl fmt::Display for Agenda {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
let s = self
.points
.iter()
.map(|p| p.to_string())
.collect::<Vec<_>>()
.join("\n");
write!(
f,
"{}",
match s.as_str() {
"" => "Empty agenda",
_ => &s,
}
)
}
}
pub enum Emoji {
Ok,
Confused,
Err,
}
pub fn parse_message<F>(
message: &str,
sender: &str,
send_message: F,
point_sender: &mpsc::UnboundedSender<AgendaPoint>,
) -> Option<Emoji>
where
F: FnOnce(String),
{
if message.starts_with("!add ") {
let mut agenda = read_agenda();
let agenda_point = AgendaPoint {
title: message[5..].to_string(),
adder: sender.to_string(),
};
point_sender.send(agenda_point.clone()).unwrap();
agenda.points.push(agenda_point);
agenda.write();
Some(Emoji::Ok)
} else if message.starts_with("!agenda") {
send_message(read_agenda().to_string());
None
} else if message.starts_with("!clear") {
Agenda { points: Vec::new() }.write();
Some(Emoji::Ok)
} else if message.starts_with("!help") {
send_message("Available commands:\n```!add -- Add something\n!agenda -- Print the agenda\n!clear -- Remove all items\n!help```".to_string());
None
} else if message.starts_with("!") {
Some(Emoji::Confused)
} else {
Some(Emoji::Err)
}
}
pub fn read_agenda() -> Agenda {
match fs::read_to_string("agenda.json") {
Ok(s) => serde_json::from_str(&s).expect("Error parsing agenda.json"),
Err(_) => Agenda { points: Vec::new() },
}
}
|
