Function get_deployment_count

chirpstack/src/storage/fuota.rs:268–324

(
    user_id: Option<Uuid>,
    tenant_id: Option<Uuid>,
    application_id: Option<Uuid>,
)

}

pub async fn get_deployment_count(
    user_id: Option<Uuid>,
    tenant_id: Option<Uuid>,
    application_id: Option<Uuid>,
) -> Result<i64, Error> {
    let mut q = fuota_deployment::table
        .inner_join(application::table)
        .select(dsl::count_star())
        .into_boxed();

    // filter by user permissions
    if let Some(user_id) = user_id {
        q = q.filter(dsl::exists(
            user::table
                .filter(
                    user::id
                        .eq(fields::Uuid::from(user_id))
                        .and(user::is_active.eq(true)),
                )
                .filter(
                    user::is_admin.eq(true).or(dsl::exists(
                        tenant_user::table
                            .filter(
                                tenant_user::user_id
                                    .eq(user::id)
                                    .and(tenant_user::tenant_id.eq(application::id)),
                            )
                            .filter(
                                tenant_user::is_admin
                                    .eq(true)
                                    .or(tenant_user::is_device_admin.eq(true))
                                    .or(dsl::exists(
                                        tenant_user_application::table.filter(
                                            tenant_user_application::user_id.eq(user::id).and(
                                                tenant_user_application::application_id
                                                    .eq(application::id),
                                            ),
                                        ),
                                    )),
                            ),
                    )),
                ),
        ));
    }

    if let Some(tenant_id) = tenant_id {
        q = q.filter(application::tenant_id.eq(fields::Uuid::from(tenant_id)));
    }

    if let Some(application_id) = application_id {
        q = q.filter(fuota_deployment::application_id.eq(fields::Uuid::from(application_id)));
    }

    q.first(&mut get_async_db_conn().await?)
        .await
        .map_err(|e| Error::from_diesel(e, "".into()))
}