aboutsummaryrefslogtreecommitdiffstats
path: root/src/slack.rs
diff options
context:
space:
mode:
authorGustav Sörnäs <gustav@sornas.net>2020-11-13 16:33:23 +0100
committerGustav Sörnäs <gustav@sornas.net>2020-11-13 16:33:23 +0100
commit1d4fcb47451a9154c215c4b3bba4e559d691f7fb (patch)
tree35f3dd4840a15d78ff7dc8519555f1281e4b29b2 /src/slack.rs
parente5b6afd09283e1fc18cd46914e6af9ba0a101f33 (diff)
downloadkodapa-1d4fcb47451a9154c215c4b3bba4e559d691f7fb.tar.gz
only listen to channels we write to
Diffstat (limited to 'src/slack.rs')
-rw-r--r--src/slack.rs29
1 files changed, 13 insertions, 16 deletions
diff --git a/src/slack.rs b/src/slack.rs
index 6ed60c4..1c272cf 100644
--- a/src/slack.rs
+++ b/src/slack.rs
@@ -43,7 +43,6 @@ impl Handler {
impl slack::EventHandler for Handler {
fn on_event(&mut self, cli: &slack::RtmClient, event: slack::Event) {
- println!("on_event: {:#?}", event);
match event {
Event::Hello => {
if self.print_channels {
@@ -57,7 +56,7 @@ impl slack::EventHandler for Handler {
.iter()
.map(|channel| format!("{}: {}",
channel.name.as_ref().unwrap_or(&"??".to_string()), //TODO &"".to_string() ?
- channel.id.as_ref().unwrap_or(&"??".to_string())))
+ channel.id.as_ref().unwrap_or(&"??".to_string()))) //TODO
.collect::<Vec<_>>())
}));
}
@@ -66,29 +65,27 @@ impl slack::EventHandler for Handler {
if let Some(channel) = &self.slack_channel {
match *msg {
Message::Standard(msg) => {
- if let Ok(Some(s)) = parse_message(
- &msg.text.unwrap_or("".to_string()),
- &msg.user.unwrap_or("??".to_string()),
- &self.sender,
- ) {
- self.slack_sender.send_message(channel.as_str(), &s).unwrap();
+ if msg.channel.is_some() && *channel == msg.channel.unwrap() { //TODO
+ if let Ok(Some(s)) = parse_message(
+ &msg.text.unwrap_or("".to_string()),
+ &msg.user.unwrap_or("??".to_string()),
+ &self.sender,
+ ) {
+ self.slack_sender.send_message(channel.as_str(), &s).unwrap();
+ }
}
}
- _ => {}
+ _ => {} // message type
}
}
}
- _ => {}
+ _ => {} // event type
}
}
- fn on_close(&mut self, _cli: &slack::RtmClient) {
- println!("on_close")
- }
+ fn on_close(&mut self, _cli: &slack::RtmClient) {}
- fn on_connect(&mut self, _cli: &slack::RtmClient) {
- println!("on_connect");
- }
+ fn on_connect(&mut self, _cli: &slack::RtmClient) {}
}
pub async fn handle(