67 lines
2.3 KiB
Rust
67 lines
2.3 KiB
Rust
use std::sync::mpsc;
|
|
|
|
use super::HandlingStatus;
|
|
use crate::pus::create_verification_reporter;
|
|
use log::{error, warn};
|
|
use ops_sat_rs::config::components::PUS_EVENT_MANAGEMENT;
|
|
use satrs::pus::event_man::EventRequestWithToken;
|
|
use satrs::pus::event_srv::PusEventServiceHandler;
|
|
use satrs::pus::verification::VerificationReporter;
|
|
use satrs::pus::{
|
|
EcssTcAndToken, EcssTcInVecConverter, MpscTcReceiver, PusPacketHandlerResult, PusServiceHelper,
|
|
};
|
|
use satrs::tmtc::PacketAsVec;
|
|
|
|
pub fn create_event_service(
|
|
tm_funnel_tx: mpsc::Sender<PacketAsVec>,
|
|
pus_event_rx: mpsc::Receiver<EcssTcAndToken>,
|
|
event_request_tx: mpsc::Sender<EventRequestWithToken>,
|
|
) -> EventServiceWrapper {
|
|
let pus_5_handler = PusEventServiceHandler::new(
|
|
PusServiceHelper::new(
|
|
PUS_EVENT_MANAGEMENT.id(),
|
|
pus_event_rx,
|
|
tm_funnel_tx,
|
|
create_verification_reporter(PUS_EVENT_MANAGEMENT.id(), PUS_EVENT_MANAGEMENT.apid),
|
|
EcssTcInVecConverter::default(),
|
|
),
|
|
event_request_tx,
|
|
);
|
|
EventServiceWrapper {
|
|
handler: pus_5_handler,
|
|
}
|
|
}
|
|
|
|
pub struct EventServiceWrapper {
|
|
pub handler: PusEventServiceHandler<
|
|
MpscTcReceiver,
|
|
mpsc::Sender<PacketAsVec>,
|
|
EcssTcInVecConverter,
|
|
VerificationReporter,
|
|
>,
|
|
}
|
|
|
|
impl EventServiceWrapper {
|
|
pub fn poll_and_handle_next_tc(&mut self, time_stamp: &[u8]) -> HandlingStatus {
|
|
match self.handler.poll_and_handle_next_tc(time_stamp) {
|
|
Ok(result) => match result {
|
|
PusPacketHandlerResult::RequestHandled => {}
|
|
PusPacketHandlerResult::RequestHandledPartialSuccess(e) => {
|
|
warn!("PUS 5 partial packet handling success: {e:?}")
|
|
}
|
|
PusPacketHandlerResult::CustomSubservice(invalid, _) => {
|
|
warn!("PUS 5 invalid subservice {invalid}");
|
|
}
|
|
PusPacketHandlerResult::SubserviceNotImplemented(subservice, _) => {
|
|
warn!("PUS 5 subservice {subservice} not implemented");
|
|
}
|
|
PusPacketHandlerResult::Empty => return HandlingStatus::Empty,
|
|
},
|
|
Err(error) => {
|
|
error!("PUS packet handling error: {error:?}")
|
|
}
|
|
}
|
|
HandlingStatus::HandledOne
|
|
}
|
|
}
|