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
|
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");
}
}
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") {
let s = read_agenda()
.points
.iter()
.map(|p| p.to_string())
.collect::<Vec<_>>()
.join("\n");
send_message(match s.as_str() {
"" => "Agenda is empty".to_string(),
_ => s
});
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)
}
}
fn read_agenda() -> Agenda {
serde_json::from_str::<Agenda>(
&fs::read_to_string("agenda.json")
.expect("Can't read agenda.json"))
.expect("Error parsing agenda.json")
}
|
