graham/towerops-agent
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

format

Browse source
This commit is contained in:
Graham McIntire 2026-02-07 11:43:38 -06:00
parent f5b7e589f2
commit cee0788300
No known key found for this signature in database
1 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/websocket_client.rs
View file

@ -512,7 +512,8 @@ impl AgentClient {
tokio::spawn(async move { tokio::spawn(async move {
let start_time = std::time::Instant::now(); let start_time = std::time::Instant::now();
match execute_mikrotik_job(job, mikrotik_result_tx).await { match execute_mikrotik_job(job, mikrotik_result_tx).await {
Ok(_) => { Ok(_) =>
{
#[cfg(feature = "tui")] #[cfg(feature = "tui")]
if let Some(ref bus) = event_bus { if let Some(ref bus) = event_bus {
let _ = bus.send(crate::tui::AgentEvent::JobCompleted { let _ = bus.send(crate::tui::AgentEvent::JobCompleted {
@ -547,7 +548,8 @@ impl AgentClient {
tokio::spawn(async move { tokio::spawn(async move {
let start_time = std::time::Instant::now(); let start_time = std::time::Instant::now();
match execute_credential_test(job, credential_test_tx).await { match execute_credential_test(job, credential_test_tx).await {
Ok(_) => { Ok(_) =>
{
#[cfg(feature = "tui")] #[cfg(feature = "tui")]
if let Some(ref bus) = event_bus { if let Some(ref bus) = event_bus {
let _ = bus.send(crate::tui::AgentEvent::JobCompleted { let _ = bus.send(crate::tui::AgentEvent::JobCompleted {
@ -585,12 +587,15 @@ impl AgentClient {
tokio::spawn(async move { tokio::spawn(async move {
let start_time = std::time::Instant::now(); let start_time = std::time::Instant::now();
#[cfg(feature = "tui")] #[cfg(feature = "tui")]
let result = execute_snmp_job(job, result_tx, poller_registry, event_bus_for_task).await; let result =
execute_snmp_job(job, result_tx, poller_registry, event_bus_for_task)
.await;
#[cfg(not(feature = "tui"))] #[cfg(not(feature = "tui"))]
let result = execute_snmp_job(job, result_tx, poller_registry).await; let result = execute_snmp_job(job, result_tx, poller_registry).await;
match result { match result {
Ok(_) => { Ok(_) =>
{
#[cfg(feature = "tui")] #[cfg(feature = "tui")]
if let Some(ref bus) = event_bus { if let Some(ref bus) = event_bus {
let _ = bus.send(crate::tui::AgentEvent::JobCompleted { let _ = bus.send(crate::tui::AgentEvent::JobCompleted {