This commit is contained in:
lda
2025-12-07 16:03:38 +07:00 Unverified
parent fc6548e15c
commit af0682a1f0
7 changed files with 51 additions and 55 deletions
+13 -1
View File
@@ -24,7 +24,18 @@ pub async fn get(
if !output.status.success() {
bail!(String::from_utf8_lossy(&output.stderr).into_owned())
} else {
serde_json::from_slice(&output.stdout).context("Deserialize failed")
let mut fuckass: Vec<NeighborItem> =
serde_json::from_slice(&output.stdout).context("Deserialize failed")?;
// i hate ts.
if let Some(dev) = dev {
for item in &mut fuckass {
if item.dev.is_none() {
item.dev = Some(dev.to_owned());
}
}
};
Ok(fuckass)
}
}
@@ -33,6 +44,7 @@ pub async fn _get(ip: Option<IpAddr>, dev: Option<&str>, nud: &[NUDState]) -> io
cmd.args(["-j", "neigh", "show"]);
if let Some(ip) = ip {
// cmd.arg("to");
cmd.arg(ip.to_canonical().to_string());
};
+2 -1
View File
@@ -73,7 +73,8 @@ pub enum NUDState {
pub struct NeighborItem {
#[serde(rename(deserialize = "dst"))]
pub ip: IpAddr,
pub dev: String,
#[serde(default)]
pub dev: Option<String>,
#[serde(with = "option_mac", default, rename(deserialize = "lladdr"))]
pub mac: Option<MacAddr>,
#[serde(default)]
+2 -2
View File
@@ -93,7 +93,7 @@ pub async fn get(
name
};
let Some((ip, dev)) = ip.zip(dev) else {
let (Some(ip), Some(dev)) = (ip, dev) else {
continue 'big;
};
@@ -116,7 +116,7 @@ pub async fn get(
result.push(NeighborItem {
ip,
dev,
dev: Some(dev),
mac,
state,
});
+1 -1
View File
@@ -1,2 +1,2 @@
pub mod iter;
// pub mod iter;
pub mod serialize;
+12 -6
View File
@@ -53,13 +53,19 @@ impl From<NUDState> for ipjs_neigh::NUDState {
}
impl From<NeighborItem> for IpNeighLine {
fn from(item: NeighborItem) -> Self {
fn from(
NeighborItem {
ip,
dev,
mac,
state,
}: NeighborItem,
) -> Self {
IpNeighLine {
ip: item.ip,
dev: Some(item.dev),
mac: item.mac,
state: item
.state
ip,
dev,
mac,
state: state
.first()
.copied()
.map(Into::into)
+20 -30
View File
@@ -50,45 +50,35 @@ pub struct Filters {
pub async fn get_status_json(
Query(DeviceQuery {
name,
filter:
Filters {
ips,
devs,
nuds,
macs,
},
filter: filters,
..
}): Query<DeviceQuery>,
) -> impl IntoResponse {
match get_macs(
&name.iter().collect::<Vec<_>>(),
&ips,
&devs.iter().collect::<Vec<_>>(),
&nuds,
&macs,
name.as_slice(),
&filters.ips,
&filters.devs,
&filters.nuds,
&filters.macs,
)
.await
{
Ok(table) => {
let filters = Filters {
ips,
devs,
nuds,
macs,
};
(
StatusCode::OK,
Json(Status {
name,
table,
filters,
}),
)
.into_response()
}
Ok(table) => (
StatusCode::OK,
Json(Status {
name,
table,
filters,
}),
)
.into_response(),
Err(error) => ApiError {
code: StatusCode::BAD_GATEWAY,
error: error.to_string(),
error: error
.chain()
.map(ToString::to_string)
.collect::<Vec<_>>()
.join(": "),
}
.into_response(),
}
+1 -14
View File
@@ -107,20 +107,7 @@ pub async fn get_mac(
.await
.context("Calling ip -j neigh failed")?;
let lines = items
.into_iter()
.map(|item| IpNeighLine {
ip: item.ip,
dev: Some(item.dev),
mac: item.mac,
state: item
.state
.first()
.copied()
.map(Into::into)
.unwrap_or(NUDState::None),
})
.collect();
let lines = items.into_iter().map(Into::into).collect();
Ok(lines)
}