(self: &Arc<Self>, event: Event, payload: Value)
| 246 | } |
| 247 | |
| 248 | async fn on_event(self: &Arc<Self>, event: Event, payload: Value) -> Result<()> { |
| 249 | match event { |
| 250 | Event::MonitorList => { |
| 251 | self.on_monitor_list( |
| 252 | serde_json::from_value(payload) |
| 253 | .log_error(module_path!(), |_| "Failed to deserialize MonitorList") |
| 254 | .unwrap(), |
| 255 | ) |
| 256 | .await? |
| 257 | } |
| 258 | Event::NotificationList => { |
| 259 | self.on_notification_list( |
| 260 | serde_json::from_value(payload) |
| 261 | .log_error(module_path!(), |_| "Failed to deserialize NotificationList") |
| 262 | .unwrap(), |
| 263 | ) |
| 264 | .await? |
| 265 | } |
| 266 | Event::MaintenanceList => { |
| 267 | self.on_maintenance_list( |
| 268 | serde_json::from_value(payload) |
| 269 | .log_error(module_path!(), |_| "Failed to deserialize MaintenanceList") |
| 270 | .unwrap(), |
| 271 | ) |
| 272 | .await? |
| 273 | } |
| 274 | Event::StatusPageList => { |
| 275 | self.on_status_page_list( |
| 276 | serde_json::from_value(payload) |
| 277 | .log_error(module_path!(), |_| "Failed to deserialize StatusPageList") |
| 278 | .unwrap(), |
| 279 | ) |
| 280 | .await? |
| 281 | } |
| 282 | Event::DockerHostList => { |
| 283 | self.on_docker_host_list( |
| 284 | serde_json::from_value(payload) |
| 285 | .log_error(module_path!(), |_| "Failed to deserialize DockerHostList") |
| 286 | .unwrap(), |
| 287 | ) |
| 288 | .await? |
| 289 | } |
| 290 | Event::Info => self.on_info().await?, |
| 291 | Event::AutoLogin => self.on_auto_login().await?, |
| 292 | Event::LoginRequired => self.on_login_required().await?, |
| 293 | Event::UpdateMonitorIntoList => { |
| 294 | self.on_update_monitor_into_list( |
| 295 | serde_json::from_value(payload) |
| 296 | .log_error(module_path!(), |_| { |
| 297 | "Failed to deserialize UpdateMonitorIntoList" |
| 298 | }) |
| 299 | .unwrap(), |
| 300 | ) |
| 301 | .await? |
| 302 | } |
| 303 | Event::DeleteMonitorFromList => { |
| 304 | self.on_delete_monitor_from_list(payload.as_i64().unwrap().try_into().unwrap()) |
| 305 | .await? |
no test coverage detected