Method connect

scapy/layers/msrpce/rpcclient.py:153–252

Initiate a connection. :param host: the host to connect to :param endpoint: (optional) the port/smb pipe to connect to :param interface: (optional) if endpoint isn't provided, uses the endpoint mapper to find the appropriate endpoint for that interface.

(
        self,
        host,
        endpoint: Union[int, str] = None,
        port: Optional[int] = None,
        interface=None,
        timeout=5,
        smb_kwargs={},
    )

        return self.sock.session

    def connect(
        self,
        host,
        endpoint: Union[int, str] = None,
        port: Optional[int] = None,
        interface=None,
        timeout=5,
        smb_kwargs={},
    ):
        """
        Initiate a connection.

        :param host: the host to connect to
        :param endpoint: (optional) the port/smb pipe to connect to
        :param interface: (optional) if endpoint isn't provided, uses the endpoint
            mapper to find the appropriate endpoint for that interface.
        :param timeout: (optional) the connection timeout (default 5)
        :param port: (optional) the port to connect to. (useful for SMB)
        """
        if endpoint is None and interface is not None:
            # Figure out the endpoint using the endpoint mapper

            if self.transport == DCERPC_Transport.NCACN_IP_TCP and port is None:
                # IP/TCP
                # ask the endpoint mapper (port 135) for the IP:PORT
                endpoints = get_endpoint(
                    host,
                    interface,
                    ndrendian=self.ndrendian,
                    verb=self.verb,
                )
                if endpoints:
                    _, endpoint = endpoints[0]
                else:
                    raise ValueError(
                        "Could not find an available endpoint for that interface !"
                    )
            elif self.transport == DCERPC_Transport.NCACN_NP:
                # SMB
                # ask the endpoint mapper (over SMB) for the namedpipe
                endpoints = get_endpoint(
                    host,
                    interface,
                    transport=self.transport,
                    ndrendian=self.ndrendian,
                    verb=self.verb,
                    smb_kwargs=smb_kwargs,
                )
                if endpoints:
                    endpoint = endpoints[0].lstrip("\\pipe\\")
                else:
                    return

        # Assign the default port if no port is provided
        if port is None:
            if self.transport == DCERPC_Transport.NCACN_IP_TCP:  # IP/TCP
                port = endpoint or 135
            elif self.transport == DCERPC_Transport.NCACN_NP:  # SMB