talexander/record_watch
1
0
Fork 0
Code Issues Pull Requests Releases Activity

Detect events.

Browse Source
This commit is contained in:
Tom Alexander 2022-02-20 22:16:51 -05:00
parent e85f9d3d41
commit 4dc352714c
Signed by: talexander
GPG Key ID: D3A179C9A53C0EDE
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/mpvctl/mpvctl.rs
View File

@ -56,6 +56,15 @@ impl MpvCtl {
match framed_read.read_frame().await { match framed_read.read_frame().await {
Ok(Some(frame)) => { Ok(Some(frame)) => {
println!("Read {}", frame); println!("Read {}", frame);
// check if its an event
let is_event = match &frame {
serde_json::Value::Object(obj) => obj.contains_key("event"),
_ => false,
};
if is_event {
// TODO: Currently we are not doing anything with events. Perhaps they should be dumped onto a stream? Perhaps many streams each representing a listener to an event?
return Ok(());
}
// get the request id and push the result into the channel // get the request id and push the result into the channel
let reqid = { let reqid = {
let obj = match &frame { let obj = match &frame {
@ -64,6 +73,10 @@ impl MpvCtl {
return Err("Got back a json value that wasn't an object.".into()); return Err("Got back a json value that wasn't an object.".into());
} }
}; };
match obj.get("event") {
Some(event) => {}
_ => (),
};
match obj.get("request_id") { match obj.get("request_id") {
Some(serde_json::Value::Number(reqid)) if reqid.is_u64() => { Some(serde_json::Value::Number(reqid)) if reqid.is_u64() => {
reqid.as_u64().unwrap() reqid.as_u64().unwrap()