Method
join_event
(
&self,
_vars: &HashMap<String, String>,
pl: &integration::JoinEvent,
)
Source from the content-addressed store, hash-verified
| 34 | } |
| 35 | |
| 36 | async fn join_event( |
| 37 | &self, |
| 38 | _vars: &HashMap<String, String>, |
| 39 | pl: &integration::JoinEvent, |
| 40 | ) -> Result<()> { |
| 41 | let dev_info = pl |
| 42 | .device_info |
| 43 | .as_ref() |
| 44 | .ok_or_else(|| anyhow!("device_info is None"))?; |
| 45 | let b = pl.encode_to_vec(); |
| 46 | stream::event::log_event_for_device("join", &dev_info.dev_eui, &b).await |
| 47 | } |
| 48 | |
| 49 | async fn ack_event( |
| 50 | &self, |