mod util;
use util::*;
use anyhow::Result;
use firedbg_rust_debugger::{Bytes, Debugger, Event, EventStream};
use pretty_assertions::assert_eq;
use sea_streamer::{Buffer, Consumer, Message, Producer};
#[tokio::test]
async fn main() -> Result<()> {
let testcase = "for_range";
let (producer, consumer) = setup(testcase).await?;
let debugger_params = debugger_params_from_file(testcase);
Debugger::run(debugger_params, producer.clone());
producer.end().await?;
for i in 0..8 {
let payload = consumer.next().await?.message().into_bytes();
let event = EventStream::read_from(Bytes::from(payload));
println!("#{i} {:?}", event);
match &event {
Event::Breakpoint { .. } => (),
Event::FunctionCall { function_name, .. } => {
assert_eq!(
function_name,
match i {
0 => "for_range::main",
1 => "for_range::run",
2 => "for_range::iter",
4 => "for_range::iter",
_ => panic!("Unexpected i {i}"),
}
);
}
Event::FunctionReturn { function_name, .. } => {
assert_eq!(
function_name,
match i {
3 => "for_range::iter",
5 => "for_range::iter",
6 => "for_range::run",
7 => "for_range::main",
_ => panic!("Unexpected i {i}"),
}
);
}
}
}
Ok(())
}