Merge pull request #180 from mhchia/fix/include-all-pkgs-setuptools

Change `packages` in `setup`

.pylintrc

@@ -11,7 +11,7 @@ ignore=CVS
 
 # Add files or directories matching the regex patterns to the blacklist. The
 # regex matches against base names, not paths.
-ignore-patterns=
+ignore-patterns=.*_pb2.*.py
 
 # Python code to execute, usually for sys.path manipulation such as
 # pygtk.require().

libp2p/__init__.py

@@ -1,8 +1,8 @@
 import asyncio
-import multiaddr
 
 from Crypto.PublicKey import RSA
-from libp2p.security.insecure_security import InsecureTransport
+
+from .security.insecure_security import InsecureTransport
 from .peer.peerstore import PeerStore
 from .peer.id import id_from_public_key
 from .network.swarm import Swarm

libp2p/routing/interfaces.py

@@ -28,4 +28,4 @@ class IPeerRouting(ABC):
         Find specific Peer
         FindPeer searches for a peer with given peer_id, returns a peer.PeerInfo
         with relevant addresses.
-        """
+        """

libp2p/routing/kademlia/kademlia_content_router.py

@@ -11,11 +11,9 @@ class KadmeliaContentRouter(IContentRouting):
         """
         # the DHT finds the closest peers to `key` using the `FIND_NODE` RPC
         # then sends a `ADD_PROVIDER` RPC with its own `PeerInfo` to each of these peers.
-        pass
 
     def find_provider_iter(self, cid, count):
         """
         Search for peers who are able to provide a given key
         returns an iterator of peer.PeerInfo
         """
-        pass

libp2p/transport/listener_interface.py

@@ -4,10 +4,10 @@ from abc import ABC, abstractmethod
 class IListener(ABC):
 
     @abstractmethod
-    def listen(self, multiaddr):
+    def listen(self, maddr):
         """
         put listener in listening mode and wait for incoming connections
-        :param multiaddr: multiaddr of peer
+        :param maddr: multiaddr of peer
         :return: return True if successful
         """
 

libp2p/transport/tcp/tcp.py

@@ -21,13 +21,13 @@ class TCP(ITransport):
             self.server = None
             self.handler = handler_function
 
-        async def listen(self, multiaddr):
+        async def listen(self, maddr):
             """
             put listener in listening mode and wait for incoming connections
-            :param multiaddr: multiaddr of peer
+            :param maddr: maddr of peer
             :return: return True if successful
             """
-            _multiaddr = multiaddr
+            _multiaddr = maddr
             _multiaddr = _multiaddr.decapsulate('/p2p')
 
             coroutine = asyncio.start_server(self.handler,
@@ -64,16 +64,16 @@ class TCP(ITransport):
             self.server = None
             return True
 
-    async def dial(self, multiaddr, self_id, options=None):
+    async def dial(self, maddr, self_id, options=None):
         """
         dial a transport to peer listening on multiaddr
-        :param multiaddr: multiaddr of peer
+        :param maddr: multiaddr of peer
         :param self_id: peer_id of the dialer (to send to receiver)
         :param options: optional object
         :return: True if successful
         """
-        host = multiaddr.value_for_protocol('ip4')
-        port = int(multiaddr.value_for_protocol('tcp'))
+        host = maddr.value_for_protocol('ip4')
+        port = int(maddr.value_for_protocol('tcp'))
 
         reader, writer = await asyncio.open_connection(host, port)
 

libp2p/transport/transport_interface.py

@@ -4,7 +4,7 @@ from abc import ABC, abstractmethod
 class ITransport(ABC):
 
     @abstractmethod
-    def dial(self, multiaddr, self_id, options=None):
+    def dial(self, maddr, self_id, options=None):
         """
         dial a transport to peer listening on multiaddr
         :param multiaddr: multiaddr of peer

setup.py

@@ -2,9 +2,7 @@ import setuptools
 
 
 classifiers = [
-    (
-        "Programming Language :: Python :: %s" % version
-    )
+    f"Programming Language :: Python :: {version}"
     for version in ["3.7"]
 ]
 
@@ -28,6 +26,6 @@ setuptools.setup(
         "lru-dict>=1.1.6",
         "aio_timers"
     ],
-    packages=["libp2p"],
+    packages=setuptools.find_packages(exclude=["tests", "tests.*"]),
     zip_safe=False,
 )