1*cf78ab8cSAndroid Build Coastguard Worker // Copyright 2024 Google LLC
2*cf78ab8cSAndroid Build Coastguard Worker //
3*cf78ab8cSAndroid Build Coastguard Worker // Licensed under the Apache License, Version 2.0 (the "License");
4*cf78ab8cSAndroid Build Coastguard Worker // you may not use this file except in compliance with the License.
5*cf78ab8cSAndroid Build Coastguard Worker // You may obtain a copy of the License at
6*cf78ab8cSAndroid Build Coastguard Worker //
7*cf78ab8cSAndroid Build Coastguard Worker // https://www.apache.org/licenses/LICENSE-2.0
8*cf78ab8cSAndroid Build Coastguard Worker //
9*cf78ab8cSAndroid Build Coastguard Worker // Unless required by applicable law or agreed to in writing, software
10*cf78ab8cSAndroid Build Coastguard Worker // distributed under the License is distributed on an "AS IS" BASIS,
11*cf78ab8cSAndroid Build Coastguard Worker // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12*cf78ab8cSAndroid Build Coastguard Worker // See the License for the specific language governing permissions and
13*cf78ab8cSAndroid Build Coastguard Worker // limitations under the License.
14*cf78ab8cSAndroid Build Coastguard Worker
15*cf78ab8cSAndroid Build Coastguard Worker /// LibSlirp Interface for Network Simulation
16*cf78ab8cSAndroid Build Coastguard Worker use bytes::Bytes;
17*cf78ab8cSAndroid Build Coastguard Worker use http_proxy::Manager;
18*cf78ab8cSAndroid Build Coastguard Worker pub use libslirp_rs::libslirp::LibSlirp;
19*cf78ab8cSAndroid Build Coastguard Worker use libslirp_rs::libslirp::ProxyManager;
20*cf78ab8cSAndroid Build Coastguard Worker use libslirp_rs::libslirp_config::{lookup_host_dns, SlirpConfig};
21*cf78ab8cSAndroid Build Coastguard Worker use netsim_proto::config::SlirpOptions as ProtoSlirpOptions;
22*cf78ab8cSAndroid Build Coastguard Worker use std::sync::mpsc;
23*cf78ab8cSAndroid Build Coastguard Worker use tokio::runtime::Runtime;
24*cf78ab8cSAndroid Build Coastguard Worker
slirp_run( opt: ProtoSlirpOptions, tx_bytes: mpsc::Sender<Bytes>, ) -> anyhow::Result<LibSlirp>25*cf78ab8cSAndroid Build Coastguard Worker pub fn slirp_run(
26*cf78ab8cSAndroid Build Coastguard Worker opt: ProtoSlirpOptions,
27*cf78ab8cSAndroid Build Coastguard Worker tx_bytes: mpsc::Sender<Bytes>,
28*cf78ab8cSAndroid Build Coastguard Worker ) -> anyhow::Result<LibSlirp> {
29*cf78ab8cSAndroid Build Coastguard Worker // TODO: Convert ProtoSlirpOptions to SlirpConfig.
30*cf78ab8cSAndroid Build Coastguard Worker let http_proxy = Some(opt.http_proxy).filter(|s| !s.is_empty());
31*cf78ab8cSAndroid Build Coastguard Worker let proxy_manager = if let Some(proxy) = http_proxy {
32*cf78ab8cSAndroid Build Coastguard Worker Some(Box::new(Manager::new(&proxy)?) as Box<dyn ProxyManager + 'static>)
33*cf78ab8cSAndroid Build Coastguard Worker } else {
34*cf78ab8cSAndroid Build Coastguard Worker None
35*cf78ab8cSAndroid Build Coastguard Worker };
36*cf78ab8cSAndroid Build Coastguard Worker
37*cf78ab8cSAndroid Build Coastguard Worker let mut config = SlirpConfig { http_proxy_on: proxy_manager.is_some(), ..Default::default() };
38*cf78ab8cSAndroid Build Coastguard Worker
39*cf78ab8cSAndroid Build Coastguard Worker if !opt.host_dns.is_empty() {
40*cf78ab8cSAndroid Build Coastguard Worker let rt = Runtime::new().unwrap();
41*cf78ab8cSAndroid Build Coastguard Worker config.host_dns = rt.block_on(lookup_host_dns(&opt.host_dns))?;
42*cf78ab8cSAndroid Build Coastguard Worker }
43*cf78ab8cSAndroid Build Coastguard Worker
44*cf78ab8cSAndroid Build Coastguard Worker Ok(LibSlirp::new(config, tx_bytes, proxy_manager))
45*cf78ab8cSAndroid Build Coastguard Worker }
46