Function set_device_timeout_error

chirpstack/src/storage/fuota.rs:529–577

(
    fuota_deployment_id: Uuid,
    mc_group_setup_timeout: bool,
    mc_session_timeout: bool,
    frag_session_setup_timeout: bool,
    frag_status_timeout: bool,
)

}

pub async fn set_device_timeout_error(
    fuota_deployment_id: Uuid,
    mc_group_setup_timeout: bool,
    mc_session_timeout: bool,
    frag_session_setup_timeout: bool,
    frag_status_timeout: bool,
) -> Result<()> {
    let fuota_deployment_id = fields::Uuid::from(fuota_deployment_id);

    let mut error_msg = String::new();
    if mc_group_setup_timeout {
        error_msg = "McGroupSetupReq timeout.".into();
    }
    if mc_session_timeout {
        error_msg = "McSessionReq timeout".into();
    }
    if frag_session_setup_timeout {
        error_msg = "FragSessionSetupReq timeout.".into();
    }
    if frag_status_timeout {
        error_msg = "FragStatusReq timeout.".into();
    }

    let mut q = diesel::update(fuota_deployment_device::table)
        .set(fuota_deployment_device::dsl::error_msg.eq(&error_msg))
        .filter(fuota_deployment_device::dsl::fuota_deployment_id.eq(&fuota_deployment_id))
        .filter(fuota_deployment_device::dsl::error_msg.eq(""))
        .into_boxed();

    if mc_group_setup_timeout {
        q = q.filter(fuota_deployment_device::dsl::mc_group_setup_completed_at.is_null());
    }

    if mc_session_timeout {
        q = q.filter(fuota_deployment_device::dsl::mc_session_completed_at.is_null());
    }

    if frag_session_setup_timeout {
        q = q.filter(fuota_deployment_device::dsl::frag_session_setup_completed_at.is_null());
    }

    if frag_status_timeout {
        q = q.filter(fuota_deployment_device::dsl::frag_status_completed_at.is_null());
    }

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

    Ok(())
}

pub async fn set_device_completed(
    fuota_deployment_id: Uuid,