async fn handle_propagation_msg(
    msg: PropagateMsg,
    state: GlobalStateR,
    channels: Channels
) -> Result<(), PropagateError>