feat: implement channel monitor

Author: Death916

.gitignore

@@ -27,3 +27,30 @@
 /docs/node_modules/
 /docs/.vitepress/cache/
 /docs/.vitepress/dist/
+
+# Nix and Direnv
+.envrc
+.direnv/
+shell.nix
+
+# Devenv
+.devenv*
+devenv.local.nix
+devenv.local.yaml
+
+# direnv
+.direnv
+
+# pre-commit
+.pre-commit-config.yaml
+
+# Devenv
+.devenv*
+devenv.local.nix
+devenv.local.yaml
+
+# direnv
+.direnv
+
+# pre-commit
+.pre-commit-config.yaml

assets/fontello/config.json

@@ -211,6 +211,12 @@
       "css": "eraser",
       "code": 61741,
       "src": "fontawesome"
+    },
+    {
+      "uid": "757afacc32d82967975cbb3b45cfb41b",
+      "css": "desktop",
+      "code": 61704,
+      "src": "fontawesome"
     }
   ]
-}
+}

data/src/buffer.rs

@@ -47,6 +47,8 @@ pub enum Internal {
     FileTransfers,
     Logs,
     Highlights,
+    #[strum(serialize = "Channel Monitor")]
+    ChannelMonitor,
     #[strum(serialize = "Channel Discovery")]
     ChannelDiscovery(Option<Server>),
 }
@@ -125,6 +127,7 @@ impl Internal {
         Self::FileTransfers,
         Self::Logs,
         Self::Highlights,
+        Self::ChannelMonitor,
         Self::ChannelDiscovery(None),
     ];
 
@@ -133,6 +136,7 @@ impl Internal {
             Internal::FileTransfers => "file-transfers",
             Internal::Logs => "logs",
             Internal::Highlights => "highlights",
+            Internal::ChannelMonitor => "channel-monitor",
             Internal::ChannelDiscovery(_) => "channel-discovery",
         }
         .to_string()
@@ -147,6 +151,9 @@ impl From<config::sidebar::InternalBuffer> for Internal {
             }
             config::sidebar::InternalBuffer::Logs => Self::Logs,
             config::sidebar::InternalBuffer::Highlights => Self::Highlights,
+            config::sidebar::InternalBuffer::ChannelMonitor => {
+                Self::ChannelMonitor
+            }
             config::sidebar::InternalBuffer::ChannelDiscovery => {
                 Self::ChannelDiscovery(None)
             }

data/src/config/sidebar.rs

@@ -299,6 +299,7 @@ pub enum OrderChannelsBy {
 pub enum InternalBuffer {
     FileTransfers,
     ChannelDiscovery,
+    ChannelMonitor,
     Highlights,
     Logs,
 }

data/src/history.rs

@@ -47,6 +47,7 @@ pub enum Kind {
     Query(Server, target::Query),
     Logs,
     Highlights,
+    ChannelMonitor,
 }
 
 impl Kind {
@@ -112,6 +113,7 @@ impl Kind {
             }
             message::Target::Logs { .. } => None,
             message::Target::Highlights { .. } => None,
+            message::Target::ChannelMonitor { .. } => None,
         }
     }
 
@@ -131,6 +133,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,
         }
     }
@@ -144,6 +149,7 @@ impl Kind {
             Kind::Query(server, _) => Some(server),
             Kind::Logs => None,
             Kind::Highlights => None,
+            Kind::ChannelMonitor => None,
         }
     }
 
@@ -154,6 +160,7 @@ impl Kind {
             Kind::Query(_, nick) => Some(Target::Query(nick.clone())),
             Kind::Logs => None,
             Kind::Highlights => None,
+            Kind::ChannelMonitor => None,
         }
     }
 }
@@ -168,6 +175,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"),
         }
     }
 }
@@ -186,6 +194,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)
+            }
         }
     }
 }
@@ -398,6 +409,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

@@ -478,6 +478,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,
@@ -881,7 +889,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())
                 }
 
@@ -1150,6 +1159,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

@@ -228,7 +228,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,
@@ -249,6 +249,11 @@ pub enum Target {
         channel: target::Channel,
         source: Source,
     },
+    ChannelMonitor {
+        server: Server,
+        channel: target::Channel,
+        source: Source,
+    },
 }
 
 impl Target {
@@ -265,6 +270,7 @@ impl Target {
             Target::Query { .. } => None,
             Target::Logs { .. } => None,
             Target::Highlights { .. } => None,
+            Target::ChannelMonitor { .. } => None,
         }
     }
 
@@ -275,6 +281,7 @@ impl Target {
             Target::Query { source, .. } => source,
             Target::Logs { source } => source,
             Target::Highlights { source, .. } => source,
+            Target::ChannelMonitor { source, .. } => source,
         }
     }
 
@@ -285,6 +292,7 @@ impl Target {
             Target::Query { source, .. } => source,
             Target::Logs { source } => source,
             Target::Highlights { source, .. } => source,
+            Target::ChannelMonitor { source, .. } => source,
         }
     }
 
@@ -294,7 +302,8 @@ impl Target {
             Target::Query { query, .. } => Some(query.as_str()),
             Target::Server { .. }
             | Target::Logs { .. }
-            | Target::Highlights { .. } => None,
+            | Target::Highlights { .. }
+            | Target::ChannelMonitor { .. } => None,
         }
     }
 
@@ -304,7 +313,8 @@ impl Target {
             Target::Query { .. }
             | Target::Server { .. }
             | Target::Logs { .. }
-            | Target::Highlights { .. } => None,
+            | Target::Highlights { .. }
+            | Target::ChannelMonitor { .. } => None,
         }
     }
 }
@@ -1061,6 +1071,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);