async def on_connect(peer: ws.WSChiaConnection):
    msg = make_msg(ProtocolMessageTypes.request_peers_introducer, introducer_protocol.RequestPeersIntroducer())
    (await peer.send_message(msg))
async def on_connect(peer: ws.WSChiaConnection):
    msg = make_msg(ProtocolMessageTypes.request_peers_introducer, introducer_protocol.RequestPeersIntroducer())
    (await peer.send_message(msg))