1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
#![warn(clippy::all)]
use anyhow::{Context as _, Error};
use fidl_fuchsia_update_channelcontrol::{ChannelControlRequest, ChannelControlRequestStream};
use fuchsia_async as fasync;
use fuchsia_component::server::ServiceFs;
use futures::prelude::*;
enum IncomingServices {
ChannelControl(ChannelControlRequestStream),
}
#[fasync::run_singlethreaded]
async fn main() -> Result<(), Error> {
let mut fs = ServiceFs::new_local();
fs.dir("svc").add_fidl_service(IncomingServices::ChannelControl);
fs.take_and_serve_directory_handle().context("while serving directory handle")?;
let mut target_channel = String::new();
while let Some(service) = fs.next().await {
match service {
IncomingServices::ChannelControl(mut stream) => {
while let Some(request) =
stream.try_next().await.context("error receiving ChannelControl request")?
{
match request {
ChannelControlRequest::GetCurrent { responder } => {
responder.send("fake-current-channel")?;
}
ChannelControlRequest::GetTarget { responder } => {
responder.send(&target_channel)?;
}
ChannelControlRequest::SetTarget { channel, responder } => {
target_channel = channel;
responder.send()?;
}
ChannelControlRequest::GetTargetList { responder } => {
responder.send(
&mut vec!["fake-current-channel", "other-channel"].into_iter(),
)?;
}
}
}
}
}
}
Ok(())
}