added terminal width cli and config option for terminal sink

src/bin/oura/watch.rs

@@ -77,6 +77,11 @@ pub fn run(args: &ArgMatches) -> Result<(), Error> {
         false => None,
     };
 
+    let terminal_width = match args.is_present("terminal-width") {
+        true => Some(args.value_of_t("terminal-width")?),
+        false => None
+    };
+
     let mapper = MapperConfig {
         include_block_end_events: true,
         ..Default::default()
@@ -114,6 +119,7 @@ pub fn run(args: &ArgMatches) -> Result<(), Error> {
 
     let sink_setup = oura::sinks::terminal::Config {
         throttle_min_span_millis: throttle,
+        terminal_width: terminal_width
     };
 
     let (source_handle, source_output) = match source_setup {
@@ -152,10 +158,17 @@ pub(crate) fn command_definition<'a>() -> clap::Command<'a> {
                 .takes_value(true)
                 .help("milliseconds to wait between output lines (for easier reading)"),
         )
+        .arg(
+            clap::Arg::new("terminal-width")
+                .long("terminal-width")
+                .takes_value(true)
+                .help("width of the terminal"),
+        )
         .arg(
             clap::Arg::new("mode")
                 .long("mode")
                 .takes_value(true)
                 .possible_values(&["node", "client"]),
         )
+
 }

src/sinks/terminal/format.rs

@@ -391,9 +391,17 @@ impl Display for LogLine {
 
             match self.content.len() {
                 x if x > max_width => {
-                    let partial: String = self.content.chars().take(max_width - 3).collect();
-                    partial.with(Color::Grey).fmt(f)?;
-                    f.write_str("...")?;
+                    let wrapped: String = self.content
+                        .chars()
+                        .enumerate()
+                        .fold(String::new(), |acc, (i, c)| {
+                            if i != 0 && i % max_width == 0 {
+                                format!("{}\n{}", acc, c)
+                            } else {
+                                format!("{}{}", acc, c)
+                            }
+                        });
+                    wrapped.with(Color::Grey).fmt(f)?;
                 }
                 _ => {
                     let full = &self.content[..];

src/sinks/terminal/run.rs

@@ -15,6 +15,7 @@ use super::format::*;
 
 pub fn reducer_loop(
     throttle_min_span: Duration,
+    terminal_width: Option<u16>,
     input: StageReceiver,
     utils: Arc<Utils>,
 ) -> Result<(), Error> {
@@ -27,7 +28,11 @@ pub fn reducer_loop(
     ))?;
 
     for evt in input.iter() {
-        let (width, _) = crossterm::terminal::size()?;
+
+        let width = match terminal_width {
+             Some(w) => w,
+             None => crossterm::terminal::size()?.0
+        };
 
         throttle.wait_turn();
         let line = LogLine::new(&evt, width as usize, &utils);

src/sinks/terminal/setup.rs

@@ -14,6 +14,7 @@ const THROTTLE_MIN_SPAN_MILLIS: u64 = 300;
 #[derive(Default, Debug, Deserialize)]
 pub struct Config {
     pub throttle_min_span_millis: Option<u64>,
+    pub terminal_width: Option<u16>
 }
 
 impl SinkProvider for WithUtils<Config> {
@@ -24,10 +25,12 @@ impl SinkProvider for WithUtils<Config> {
                 .unwrap_or(THROTTLE_MIN_SPAN_MILLIS),
         );
 
+        let terminal_width = self.inner.terminal_width;
+
         let utils = self.utils.clone();
 
         let handle = std::thread::spawn(move || {
-            reducer_loop(throttle_min_span, input, utils).expect("terminal sink loop failed");
+            reducer_loop(throttle_min_span, terminal_width, input, utils).expect("terminal sink loop failed");
         });
 
         Ok(handle)