Temp

libp2p/network/swarm.py

@@ -195,6 +195,15 @@ class Swarm(INetwork):
     def add_router(self, router):
         self.router = router
 
+    # TODO: `tear_down`
+    async def tear_down(self) -> None:
+        # pylint: disable=line-too-long
+        # Reference: https://github.com/libp2p/go-libp2p-swarm/blob/8be680aef8dea0a4497283f2f98470c2aeae6b65/swarm.go#L118  # noqa: E501
+        pass
+
+    # TODO: `disconnect`?
+
+
 def create_generic_protocol_handler(swarm):
     """
     Create a generic protocol handler from the given swarm. We use swarm

libp2p/pubsub/pubsub.py

@@ -9,6 +9,14 @@ from typing import (
     Tuple,
 )
 
+from typing import (
+    Any,
+    Dict,
+    List,
+    Sequence,
+    Tuple,
+)
+
 from lru import LRU
 
 from libp2p.host.host_interface import (
@@ -319,3 +327,19 @@ class Pubsub:
         for _, stream in self.peers.items():
             # Write message to stream
             await stream.write(rpc_msg)
+
+    def list_peers(self, topic_id: str) -> Tuple[ID]:
+        return
+
+    def publish(self, topic_id: str, data: bytes) -> None:
+        # TODO: Create pb message
+        # TODO: Sign with our signing key
+        # TODO: `p.pushMsg(p.host.ID(), msg)`
+        # TODO: - Check if the source is in the blacklist. If yes, reject.
+        # TODO: - Check if the `from` is in the blacklist. If yes, reject.
+        # TODO: - Check if the message is seen. If yes, reject it.
+        # TODO: - Validate the message. If failed, reject it.
+        # TODO: - Mark as seen and `publishMessage`
+        # TODO:     - Notify the subscribers
+        # TODO:     - Router.Publish
+        return