Method
txack_event
(
&self,
_vars: &HashMap<String, String>,
pl: &integration::TxAckEvent,
)
Source from the content-addressed store, hash-verified
| 60 | } |
| 61 | |
| 62 | async fn txack_event( |
| 63 | &self, |
| 64 | _vars: &HashMap<String, String>, |
| 65 | pl: &integration::TxAckEvent, |
| 66 | ) -> Result<()> { |
| 67 | let dev_info = pl |
| 68 | .device_info |
| 69 | .as_ref() |
| 70 | .ok_or_else(|| anyhow!("device_info is None"))?; |
| 71 | let b = pl.encode_to_vec(); |
| 72 | stream::event::log_event_for_device("txack", &dev_info.dev_eui, &b).await |
| 73 | } |
| 74 | |
| 75 | async fn log_event( |
| 76 | &self, |