(
&self,
_vars: &HashMap<String, String>,
pl: &integration::JoinEvent,
)
| 141 | } |
| 142 | |
| 143 | async fn join_event( |
| 144 | &self, |
| 145 | _vars: &HashMap<String, String>, |
| 146 | pl: &integration::JoinEvent, |
| 147 | ) -> Result<()> { |
| 148 | let di = pl.device_info.as_ref().unwrap(); |
| 149 | let pl = match self.json { |
| 150 | true => serde_json::to_string(&pl)?, |
| 151 | false => general_purpose::STANDARD.encode(pl.encode_to_vec()), |
| 152 | }; |
| 153 | |
| 154 | self.publish("join", &di.application_id, &di.dev_eui, &pl) |
| 155 | .await |
| 156 | } |
| 157 | |
| 158 | async fn ack_event( |
| 159 | &self, |