git.delta.rocks / fleet / refs/commits / b66112ef1437

180		)180		)
181	};181	};
182182
183	let filter = EnvFilter::try_from_default_env().unwrap_or_else(|_| EnvFilter::new("info"));183	let filter = EnvFilter::try_from_default_env().unwrap_or_else(|_| EnvFilter::new("noq_udp=warn,info"));
184184
185	let tree = {185	let tree = {
186		#[cfg(feature = "indicatif")]186		#[cfg(feature = "indicatif")]

18use remowt_ui_prompt::{PrependSourcePrompter, Source};18use remowt_ui_prompt::{PrependSourcePrompter, Source};
19use tokio::io::unix::AsyncFd;19use tokio::io::unix::AsyncFd;
20use tokio::io::{AsyncRead, ReadBuf};20use tokio::io::{AsyncRead, ReadBuf};
21use tokio::signal::unix::{signal, SignalKind};21use tokio::signal::unix::{SignalKind, signal};
22use tracing::debug;22use tracing::debug;
23use tracing_subscriber::prelude::*;23use tracing_subscriber::EnvFilter;
24use tracing_subscriber::EnvFilter;24use tracing_subscriber::prelude::*;
2525
26#[derive(Parser)]26#[derive(Parser)]
27enum Opts {27enum Opts {

27	fs,27	fs,
28	io::{AsyncBufReadExt as _, AsyncReadExt as _, AsyncWriteExt as _, BufReader},28	io::{AsyncBufReadExt as _, AsyncReadExt as _, AsyncWriteExt as _, BufReader},
29};29};
30use tracing::{debug, info, warn};30use tracing::{Instrument as _, debug, info, warn};
31use uuid::Uuid;31use uuid::Uuid;
3232
33pub mod editor;33pub mod editor;
677			}678				}
678		}679			}
679	})680		}
681		.in_current_span(),
682	)
680}683}
681684

1use std::process::Stdio;1use std::process::Stdio;
2use std::sync::Arc;2use std::sync::Arc;
33
4use bifrostlink::declarative::endpoints;4use bifrostlink::Config;
5use bifrostlink::Config;5use bifrostlink::declarative::endpoints;
6use remowt_link_shared::iroh_tunnel::{TunnelAddr, TunnelDialer};6use remowt_link_shared::iroh_tunnel::{TunnelAddr, TunnelDialer};
7use serde::{Deserialize, Serialize};7use serde::{Deserialize, Serialize};
8use std::result::Result;8use std::result::Result;
9use tokio::io::{self, AsyncWriteExt as _};
9use tokio::process::Command;10use tokio::process::Command;
1011
11#[derive(Clone)]12#[derive(Clone)]
47		let mut stdin = child.stdin.take().expect("piped");48		let mut stdin = child.stdin.take().expect("piped");
48		let mut stdout = child.stdout.take().expect("piped");49		let mut stdout = child.stdout.take().expect("piped");
49		tokio::spawn(async move {50		tokio::spawn(async move {
50			let (mut tr, mut tw) = tokio::io::split(tunnel);51			let (mut tr, mut tw) = io::split(tunnel);
51			let _ = tokio::join!(52			let to_child = async {
52				tokio::io::copy(&mut tr, &mut stdin),53				let _ = io::copy(&mut tr, &mut stdin).await;
53				tokio::io::copy(&mut stdout, &mut tw),54				let _ = stdin.shutdown().await;
54			);55			};
56			let from_child = async {
57				let _ = io::copy(&mut stdout, &mut tw).await;
58				let _ = tw.shutdown().await;
59			};
60			tokio::join!(to_child, from_child);
55			let _ = child.wait().await;61			let _ = child.wait().await;
56		});62		});
57		Ok(())63		Ok(())