Function handle_vendor

chirpstack/src/cmd/import_device_profiles.rs:140–167

(dir: &Path)

}

async fn handle_vendor(dir: &Path) -> Result<()> {
    let vendor_conf = dir.join("vendor.toml");
    info!(path = ?vendor_conf, "Reading vendor configuration");
    let vendor_conf: VendorConfig = toml::from_str(&fs::read_to_string(vendor_conf)?)?;
    info!(vendor_name = %vendor_conf.vendor.name, "Vendor loaded");

    info!(id = %vendor_conf.vendor.id, "Upserting vendor");
    let _ = device_profile::upsert_vendor(device_profile::Vendor {
        id: vendor_conf.vendor.id.into(),
        name: vendor_conf.vendor.name.clone(),
        vendor_id: vendor_conf.vendor.vendor_id,
        ouis: fields::StringVec::new(
            vendor_conf
                .vendor
                .ouis
                .iter()
                .map(|v| Some(v.clone()))
                .collect(),
        ),
        metadata: fields::KeyValue::new(vendor_conf.vendor.metadata.clone()),
        ..Default::default()
    })
    .await?;

    handle_devices(dir, &vendor_conf.vendor).await?;

    Ok(())
}

async fn handle_devices(dir: &Path, vendor: &Vendor) -> Result<()> {
    info!(id = %vendor.id, "Upserting vendor devices");