async fn republish_pending_messages<T>(
    api: &T,
    network_sender: &Sender<NetworkMessage>,
    network_name: &str,
    pending: &RwLock<HashMap<Address, MsgSet>>,
    cur_tipset: &Mutex<Arc<Tipset>>,
    republished: &RwLock<HashSet<Cid>>,
    local_addrs: &RwLock<Vec<Address>>,
    chain_config: &ChainConfig,
) -> Result<(), Error>
where T: Provider,