(dir: &Path, vendor: &Vendor)
| 167 | } |
| 168 | |
| 169 | async fn handle_devices(dir: &Path, vendor: &Vendor) -> Result<()> { |
| 170 | info!(id = %vendor.id, "Upserting vendor devices"); |
| 171 | |
| 172 | let devices_dir = dir.join("devices"); |
| 173 | let devices = fs::read_dir(devices_dir)?; |
| 174 | |
| 175 | for device in devices.flatten() { |
| 176 | let device = device |
| 177 | .file_name() |
| 178 | .into_string() |
| 179 | .map_err(|e| anyhow!("{:?}", e))?; |
| 180 | let span = span!(Level::INFO, "", device = %device); |
| 181 | handle_device(dir, vendor, &device).instrument(span).await?; |
| 182 | } |
| 183 | |
| 184 | Ok(()) |
| 185 | } |
| 186 | |
| 187 | async fn handle_device(dir: &Path, vendor: &Vendor, device: &str) -> Result<()> { |
| 188 | let device_conf = dir.join("devices").join(device); |
no test coverage detected