Function set_device_completed

chirpstack/src/storage/fuota.rs:579–612

(
    fuota_deployment_id: Uuid,
    mc_group_setup_completed: bool,
    mc_session_completed: bool,
    frag_session_setup_completed: bool,
    frag_status_completed: bool,
)

}

pub async fn set_device_completed(
    fuota_deployment_id: Uuid,
    mc_group_setup_completed: bool,
    mc_session_completed: bool,
    frag_session_setup_completed: bool,
    frag_status_completed: bool,
) -> Result<()> {
    let fuota_deployment_id = fields::Uuid::from(fuota_deployment_id);

    let mut q = diesel::update(fuota_deployment_device::table)
        .set(fuota_deployment_device::dsl::completed_at.eq(Some(Utc::now())))
        .filter(fuota_deployment_device::dsl::fuota_deployment_id.eq(&fuota_deployment_id))
        .into_boxed();

    if mc_group_setup_completed {
        q = q.filter(fuota_deployment_device::dsl::mc_group_setup_completed_at.is_not_null());
    }

    if mc_session_completed {
        q = q.filter(fuota_deployment_device::dsl::mc_session_completed_at.is_not_null());
    }

    if frag_session_setup_completed {
        q = q.filter(fuota_deployment_device::dsl::frag_session_setup_completed_at.is_not_null());
    }

    if frag_status_completed {
        q = q.filter(fuota_deployment_device::dsl::frag_status_completed_at.is_not_null());
    }

    q.execute(&mut get_async_db_conn().await?).await?;

    Ok(())
}

pub async fn add_gateways(fuota_deployment_id: Uuid, gateway_ids: Vec<EUI64>) -> Result<(), Error> {
    let mut errors = Vec::new();