feat: implement Channel Monitor

Author: Death916

.gitignore

@@ -27,3 +27,8 @@
 /docs/node_modules/
 /docs/.vitepress/cache/
 /docs/.vitepress/dist/
+
+# Nix and Direnv
+.envrc
+.direnv/
+shell.nix

assets/fontello/config.json

@@ -289,6 +289,10 @@
       "css": "reply-1",
       "code": 59419,
       "src": "entypo"
+      "uid": "757afacc32d82967975cbb3b45cfb41b",
+      "css": "desktop",
+      "code": 61704,
+      "src": "fontawesome"
     }
   ]
 }

data/src/buffer.rs

@@ -35,6 +35,8 @@ pub enum Internal {
     FileTransfers,
     Logs,
     Highlights,
+    #[strum(serialize = "Channel Monitor")]
+    ChannelMonitor,
     #[strum(serialize = "Channel Discovery")]
     ChannelDiscovery(Option<Server>),
 }
@@ -106,6 +108,7 @@ impl Internal {
         Self::FileTransfers,
         Self::Logs,
         Self::Highlights,
+        Self::ChannelMonitor,
         Self::ChannelDiscovery(None),
     ];
 
@@ -114,6 +117,7 @@ impl Internal {
             Internal::FileTransfers => "file-transfers",
             Internal::Logs => "logs",
             Internal::Highlights => "highlights",
+            Internal::ChannelMonitor => "channel-monitor",
             Internal::ChannelDiscovery(_) => "channel-discovery",
         }
         .to_string()

data/src/history.rs

@@ -46,6 +46,7 @@ pub enum Kind {
     Query(Server, target::Query),
     Logs,
     Highlights,
+    ChannelMonitor,
 }
 
 impl Kind {
@@ -111,6 +112,7 @@ impl Kind {
             }
             message::Target::Logs { .. } => None,
             message::Target::Highlights { .. } => None,
+            message::Target::ChannelMonitor { .. } => None,
         }
     }
 
@@ -130,6 +132,9 @@ impl Kind {
                 Some(Kind::Highlights)
             }
             Buffer::Internal(buffer::Internal::FileTransfers) => None,
+            Buffer::Internal(buffer::Internal::ChannelMonitor) => {
+                Some(Kind::ChannelMonitor)
+            }
             Buffer::Internal(buffer::Internal::ChannelDiscovery(_)) => None,
         }
     }
@@ -143,6 +148,7 @@ impl Kind {
             Kind::Query(server, _) => Some(server),
             Kind::Logs => None,
             Kind::Highlights => None,
+            Kind::ChannelMonitor => None,
         }
     }
 
@@ -153,6 +159,7 @@ impl Kind {
             Kind::Query(_, nick) => Some(Target::Query(nick.clone())),
             Kind::Logs => None,
             Kind::Highlights => None,
+            Kind::ChannelMonitor => None,
         }
     }
 }
@@ -167,6 +174,7 @@ impl fmt::Display for Kind {
             Kind::Query(server, nick) => write!(f, "user {nick} on {server}"),
             Kind::Logs => write!(f, "logs"),
             Kind::Highlights => write!(f, "highlights"),
+            Kind::ChannelMonitor => write!(f, "channel monitor"),
         }
     }
 }
@@ -185,6 +193,9 @@ impl From<Kind> for Buffer {
             }
             Kind::Logs => Buffer::Internal(buffer::Internal::Logs),
             Kind::Highlights => Buffer::Internal(buffer::Internal::Highlights),
+            Kind::ChannelMonitor => {
+                Buffer::Internal(buffer::Internal::ChannelMonitor)
+            }
         }
     }
 }
@@ -394,6 +405,7 @@ async fn path(kind: &Kind) -> Result<PathBuf, Error> {
         }
         Kind::Logs => "logs".to_string(),
         Kind::Highlights => "highlights".to_string(),
+        Kind::ChannelMonitor => "channel_monitor".to_string(),
     };
 
     let hashed_name = seahash::hash(name.as_bytes());

data/src/history/filter.rs

@@ -287,6 +287,7 @@ impl Filter {
                 | Kind::Channel(server, _)
                 | Kind::Query(server, _) => target_server == server,
                 Kind::Highlights | Kind::Logs => false,
+                Kind::ChannelMonitor => false,
             },
         }
     }

data/src/history/manager.rs

@@ -473,6 +473,14 @@ impl Manager {
             .collect()
     }
 
+    pub fn record_channel_monitor_message(
+        &mut self,
+        message: crate::Message,
+    ) -> Option<impl Future<Output = Message> + use<>> {
+        self.data
+            .add_message(history::Kind::ChannelMonitor, message, None)
+    }
+
     pub fn record_reaction(
         &mut self,
         server: &Server,
@@ -837,7 +845,8 @@ impl Manager {
             // Check if target is included/excluded.
             let target_ref = match &message.target {
                 message::Target::Channel { channel, .. }
-                | message::Target::Highlights { channel, .. } => {
+                | message::Target::Highlights { channel, .. }
+                | message::Target::ChannelMonitor { channel, .. } => {
                     Some(channel.as_target_ref())
                 }
 
@@ -1106,6 +1115,10 @@ impl Manager {
                                 }
                                 | message::Target::Highlights {
                                     channel, ..
+                                }
+                                | message::Target::ChannelMonitor {
+                                    channel,
+                                    ..
                                 } => Some(channel.as_target_ref()),
 
                                 message::Target::Query { query, .. } => {

data/src/history/metadata.rs

@@ -219,6 +219,7 @@ async fn path(kind: &Kind) -> Result<PathBuf, Error> {
         }
         Kind::Logs => "logs-metadata".to_string(),
         Kind::Highlights => "highlights-metadata".to_string(),
+        Kind::ChannelMonitor => "channel-monitor-metadata".to_string(),
     };
 
     let hashed_name = seahash::hash(name.as_bytes());

data/src/message.rs

@@ -209,7 +209,7 @@ impl From<Encoded> for proto::Message {
     }
 }
 
-#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
 pub enum Target {
     Server {
         source: Source,
@@ -230,6 +230,11 @@ pub enum Target {
         channel: target::Channel,
         source: Source,
     },
+    ChannelMonitor {
+        server: Server,
+        channel: target::Channel,
+        source: Source,
+    },
 }
 
 impl Target {
@@ -246,6 +251,7 @@ impl Target {
             Target::Query { .. } => None,
             Target::Logs { .. } => None,
             Target::Highlights { .. } => None,
+            Target::ChannelMonitor { .. } => None,
         }
     }
 
@@ -256,6 +262,7 @@ impl Target {
             Target::Query { source, .. } => source,
             Target::Logs { source } => source,
             Target::Highlights { source, .. } => source,
+            Target::ChannelMonitor { source, .. } => source,
         }
     }
 
@@ -266,6 +273,7 @@ impl Target {
             Target::Query { source, .. } => source,
             Target::Logs { source } => source,
             Target::Highlights { source, .. } => source,
+            Target::ChannelMonitor { source, .. } => source,
         }
     }
 
@@ -275,7 +283,8 @@ impl Target {
             Target::Query { query, .. } => Some(query.as_str()),
             Target::Server { .. }
             | Target::Logs { .. }
-            | Target::Highlights { .. } => None,
+            | Target::Highlights { .. }
+            | Target::ChannelMonitor { .. } => None,
         }
     }
 
@@ -285,7 +294,8 @@ impl Target {
             Target::Query { .. }
             | Target::Server { .. }
             | Target::Logs { .. }
-            | Target::Highlights { .. } => None,
+            | Target::Highlights { .. }
+            | Target::ChannelMonitor { .. } => None,
         }
     }
 }
@@ -1009,6 +1019,13 @@ pub fn condense(
                 channel: channel.clone(),
                 source,
             },
+            Target::ChannelMonitor {
+                server, channel, ..
+            } => Target::ChannelMonitor {
+                server: server.clone(),
+                channel: channel.clone(),
+                source,
+            },
         };
 
         let nick_associations = find_nickname_associations(messages);