Function dispatch_untrusted_fan_in 

pub async fn dispatch_untrusted_fan_in(
    engine: &Arc<Mutex<SopEngine>>,
    audit: &SopAuditLogger,
    source: SopTriggerSource,
    topic: Option<&str>,
    payload: Option<&str>,
    dedup: Option<(String, bool)>,
) -> Vec<DispatchResult>