Function _join_event

chirpstack/src/integration/mod.rs:247–270

(
    application_id: Uuid,
    vars: &HashMap<String, String>,
    pl: &integration::JoinEvent,
)

}

async fn _join_event(
    application_id: Uuid,
    vars: &HashMap<String, String>,
    pl: &integration::JoinEvent,
) -> Result<()> {
    let app_ints = for_application_id(application_id)
        .await
        .context("Get integrations for application")?;
    let global_ints = GLOBAL_INTEGRATIONS.read().await;
    let mut futures = Vec::new();

    for (i, _) in app_ints.iter().enumerate() {
        futures.push(app_ints[i].join_event(vars, pl));
    }
    for (i, _) in global_ints.iter().enumerate() {
        futures.push(global_ints[i].join_event(vars, pl));
    }

    for e in join_all(futures).await {
        e?;
    }

    Ok(())
}

pub async fn ack_event(
    application_id: Uuid,