richards/websocket-debug
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

cargo fmt

Browse Source
This commit is contained in:
Richard
2026-02-04 20:23:49 +00:00
parent 519f75803d
commit 7ad031c6a9
1 changed files with 26 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
src/main.rs
View File

@@ -76,13 +76,16 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
let (parsed, errs) = jaq_parse::parse(expr, jaq_parse::main()); let (parsed, errs) = jaq_parse::parse(expr, jaq_parse::main());
if !errs.is_empty() { if !errs.is_empty() {
let err_msgs: Vec<String> = errs.iter().map(|e| format!("{:?}", e)).collect(); let err_msgs: Vec<String> = errs.iter().map(|e| format!("{:?}", e)).collect();
return Err( return Err(format!(
format!("Failed to parse jaq expression '{}': {}", expr, err_msgs.join(", ")) "Failed to parse jaq expression '{}': {}",
.into(), expr,
); err_msgs.join(", ")
)
.into());
} }
let parsed = parsed.ok_or_else(|| format!("Failed to parse jaq expression '{}'", expr))?; let parsed =
parsed.ok_or_else(|| format!("Failed to parse jaq expression '{}'", expr))?;
let filter = defs.compile(parsed); let filter = defs.compile(parsed);
if !defs.errs.is_empty() { if !defs.errs.is_empty() {
@@ -274,7 +277,10 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
if jaq_filters.is_empty() { if jaq_filters.is_empty() {
let preview: String = text.chars().take(50).collect(); let preview: String = text.chars().take(50).collect();
let truncated = if text.len() > 50 { "..." } else { "" }; let truncated = if text.len() > 50 { "..." } else { "" };
info!("[{}:{}] Text: {}{}", letter, seq_num, preview, truncated); info!(
"[{}:{}] Text: {}{}",
letter, seq_num, preview, truncated
);
} else { } else {
match serde_json::from_str::<serde_json::Value>(&text) { match serde_json::from_str::<serde_json::Value>(&text) {
Ok(json_val) => { Ok(json_val) => {
@@ -283,7 +289,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
for filter in jaq_filters.iter() { for filter in jaq_filters.iter() {
let inputs = RcIter::new(core::iter::empty()); let inputs = RcIter::new(core::iter::empty());
let ctx = Ctx::new([], &inputs); let ctx = Ctx::new([], &inputs);
let out = filter.run((ctx, Val::from(json_val.clone()))); let out =
filter.run((ctx, Val::from(json_val.clone())));
let mut filter_outputs = Vec::new(); let mut filter_outputs = Vec::new();
for result in out { for result in out {
@@ -306,7 +313,12 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
} }
} }
info!("[{}:{}] {}", letter, seq_num, all_outputs.join(" | ")); info!(
"[{}:{}] {}",
letter,
seq_num,
all_outputs.join(" | ")
);
} }
Err(e) => { Err(e) => {
warn!( warn!(
@@ -314,8 +326,12 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
letter, seq_num, e letter, seq_num, e
); );
let preview: String = text.chars().take(50).collect(); let preview: String = text.chars().take(50).collect();
let truncated = if text.len() > 50 { "..." } else { "" }; let truncated =
info!("[{}:{}] Text: {}{}", letter, seq_num, preview, truncated); if text.len() > 50 { "..." } else { "" };
info!(
"[{}:{}] Text: {}{}",
letter, seq_num, preview, truncated
);
} }
} }
} }