Function run

chirpstack/src/cmd/migrate_device_profile_templates.rs:50–166

()

}

pub async fn run() -> Result<()> {
    storage::setup().await?;

    info!("Migrating device-profile templates to device profiles");

    info!("Querying vendors");
    let vendors: Vec<String> = device_profile_template::table
        .select(device_profile_template::vendor)
        .group_by(device_profile_template::vendor)
        .load(&mut get_async_db_conn().await?)
        .await?;

    for vendor in &vendors {
        info!(vendor = %vendor, "Creating vendor");

        let v = device_profile::upsert_vendor(device_profile::Vendor {
            name: vendor.clone(),
            ..Default::default()
        })
        .await?;

        info!(vendor = %vendor, "Querying vendor devices");
        let devices: Vec<String> = device_profile_template::table
            .select(device_profile_template::name)
            .filter(device_profile_template::vendor.eq(vendor))
            .group_by(device_profile_template::name)
            .load(&mut get_async_db_conn().await?)
            .await?;

        for device in &devices {
            info!(vendor = %vendor, device = %device, "Creating device");

            let d = device_profile::upsert_device(device_profile::Device {
                vendor_id: v.id,
                name: device.clone(),
                ..Default::default()
            })
            .await?;

            info!(vendor = %vendor, device = %device, "Querying device profiles");
            let dps: Vec<DeviceProfileTemplate> = device_profile_template::table
                .filter(
                    device_profile_template::vendor
                        .eq(vendor)
                        .and(device_profile_template::name.eq(device)),
                )
                .load(&mut get_async_db_conn().await?)
                .await?;

            for dp in &dps {
                info!(vendor = %vendor, device = %device, firmware = %dp.firmware, region = %dp.region, "Creating device profile");

                let _ = device_profile::create(device_profile::DeviceProfile {
                    name: dp.name.clone(),
                    region: dp.region,
                    mac_version: dp.mac_version,
                    reg_params_revision: dp.reg_params_revision,
                    adr_algorithm_id: "default".into(),