feat(watcher): update config impl with alert channels

applications/tari_watcher/Cargo.toml

@@ -9,6 +9,8 @@ license.workspace = true
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
+#tari_common = { workspace = true }
+
 clap = { workspace = true, features = ["derive"] }
 serde = { workspace = true, features = ["derive"] }
 serde_json = { workspace = true }

applications/tari_watcher/src/cli.rs

@@ -5,6 +5,8 @@ use std::path::PathBuf;
 
 use clap::Parser;
 
+use crate::config::Config;
+
 #[derive(Clone, Debug, Parser)]
 pub struct Cli {
     #[clap(flatten)]
@@ -34,15 +36,25 @@ impl Cli {
 pub struct CommonCli {
     #[clap(short = 'b', long, parse(from_os_str))]
     pub base_dir: Option<PathBuf>,
-    #[clap(short, long, parse(from_os_str), default_value = "./data/watcher/config.toml")]
+    #[clap(short = 'c', long, parse(from_os_str), default_value = "./data/watcher/config.toml")]
     pub config_path: PathBuf,
 }
 
 #[derive(Clone, Debug, clap::Subcommand)]
 pub enum Commands {
-    Init,
+    Init(InitArgs),
     Start,
 }
 
 #[derive(Clone, Debug, clap::Args)]
-pub struct Overrides {}
+pub struct InitArgs {
+    #[clap(long)]
+    /// Disable initial and auto registration of the validator node
+    pub no_auto_register: bool,
+}
+
+impl InitArgs {
+    pub fn apply(&self, config: &mut Config) {
+        config.auto_register = !self.no_auto_register;
+    }
+}

applications/tari_watcher/src/config.rs

@@ -1,12 +1,16 @@
 // Copyright 2024 The Tari Project
 // SPDX-License-Identifier: BSD-3-Clause
 
-use crate::Cli;
-use std::collections::HashMap;
-use std::fmt::{self, Display};
-use std::path::PathBuf;
+use std::{
+    collections::HashMap,
+    fmt::{self, Display},
+    path::PathBuf,
+};
+
 use tokio::io::{self, AsyncWriteExt};
 
+use crate::Cli;
+
 #[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
 pub struct Config {
     /// Allow watcher to submit a new validator node registration transaction initially and before
@@ -31,6 +35,9 @@ pub struct Config {
 
     /// The process specific configuration for the executables
     pub executable_config: Vec<ExecutableConfig>,
+
+    /// The channel configuration for alerting and monitoring
+    pub channel_config: Vec<ChannelConfig>,
 }
 
 impl Config {
@@ -53,6 +60,13 @@ impl Display for InstanceType {
     }
 }
 
+#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
+pub struct ChannelConfig {
+    pub name: String,
+    pub enabled: bool,
+    pub credentials: String,
+}
+
 #[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
 pub struct ExecutableConfig {
     pub instance_type: InstanceType,
@@ -150,5 +164,17 @@ pub fn get_base_config(cli: &Cli) -> anyhow::Result<Config> {
         vn_registration_file: base_dir.join("vn_registration.toml"),
         instance_config: instances.to_vec(),
         executable_config: executables,
+        channel_config: vec![
+            ChannelConfig {
+                name: "mattermost".to_string(),
+                enabled: true,
+                credentials: "".to_string(),
+            },
+            ChannelConfig {
+                name: "telegram".to_string(),
+                enabled: true,
+                credentials: "".to_string(),
+            },
+        ],
     })
 }

applications/tari_watcher/src/main.rs

@@ -1,11 +1,13 @@
 // Copyright 2024 The Tari Project
 // SPDX-License-Identifier: BSD-3-Clause
 
-use crate::cli::{Cli, Commands};
 use anyhow::{anyhow, Context};
 use tokio::fs;
 
-use crate::config::get_base_config;
+use crate::{
+    cli::{Cli, Commands},
+    config::get_base_config,
+};
 
 mod cli;
 mod config;
@@ -16,12 +18,14 @@ async fn main() -> anyhow::Result<()> {
     let config_path = cli.get_config_path();
 
     match cli.command {
-        Commands::Init => {
+        Commands::Init(ref args) => {
             // set by default in CommonCli
             let parent = config_path.parent().unwrap();
             fs::create_dir_all(parent).await?;
 
-            let config = get_base_config(&cli)?;
+            let mut config = get_base_config(&cli)?;
+            // optionally disables auto register
+            args.apply(&mut config);
 
             let file = fs::File::create(&config_path)
                 .await
@@ -31,6 +35,9 @@ async fn main() -> anyhow::Result<()> {
             let config_path = config_path
                 .canonicalize()
                 .context("Failed to canonicalize config path")?;
+
+            // TODO: use standardised logging
+            // if let Err(e) = initialize_logging(..)
             log::info!("Config file created at {}", config_path.display());
         },
         Commands::Start => {