code: def send_connect_request(self, connection_id):
          
          connect_message = ConnectionRequest(endpoint=self._public_endpoint)
          self._safe_send(
              validator_pb2.Message.NETWORK_CONNECT,
              connect_message.SerializeToString(),
              connection_id,
              callback=partial(
                  self._inbound_connection_request_callback,
                  connection_id=connection_id))
docs: Send ConnectionRequest to an inbound connection. This allows
          the validator to be authorized by the incoming connection.