In `Pubsub.continuously_read_stream`, it checks whether this is a
control message enclosed in RPC message with `if rpc_incoming.control:`.
However, in pb2, the condition is always true because a default value is
returned when a field is not set. Solved it by changing it to
`if rpc_incoming.HasField("control"):`.
* Add handle_rpc call to pubsub
* Scaffold gossipsub functions
* Add timer
* Implement most of mesh construction
* Implement emit and handle
* Implement fanout heartbeat
* Refactor emit
* some gossipsub cleanup and test
* minor lint stuff, more to come
* Implement publish
* Fix comment
* Modify pubsub/gossipsub so that floodsub tests pass using gossipsub router
* Add floodsub tests to gossipsub
* Handle case where select_from_minus, num_to_select > size(pool-minus)
* Add topic membership
* Implement handle ihave
* Implement most of iwant
* Add mcache.add and comments
* Refactor handle_ihave
* Implement stream write in handle_iwant
* Implement gossip heartbeat
* unresolved vars
* initial mcache code
* documenting mcache
* writing test/debugging mcache
* finished mcache test and debugged
* Make gossipsub backward compatibility its own file
* remove mcache prints
* DEBUGGING
* Add sender_peer_id to handle_rpc to get gossip test passing
* Modify gossipsub to make fanout work
* fanout maintenance test
* debugging gsub GOSSIP
* DEBUGGING
* debugged sender seen cachce
* adding lru, removing prints
* pylint cleanup
* Fix github comments in PR
* minor floodsub possible bugfix
* Add notifee interface
* Add notify function to network interface
* Implement notify feature
* Add tests for notify
* Make notifee functions all async
* Fix linting issue
* Fix linting issue
* Scaffold pubsub router interface
* Scaffold pubsub directory
* Store peer_id in muxed connection
* Implement pubsub notifee
* Remove outdated files
* Implement pubsub first attempt
* Prepare pubsub for floodsub
* Add mplex conn to net stream and add conn in notify tests
* Implement floodsub
* Use NetStream in generic protocol handler
* Debugging async issues
* Modify test to perform proper assert. Test passes
* Remove callbacks. Reduce sleep time
* Add simple three node test
* Clean up code. Add message classes
* Add test for two topics
* Add conn to net stream and conn tests
* Refactor test setup to remove duplicate code
* Fix linting issues
* Fix linting issue
* Fix linting issue
* Fix outstanding unrelated lint issue in multiselect_client
* Add connect function
* Remove debug prints
* Remove debug prints from floodsub
* Use MessageTalk in place of direct message breakdown
* Remove extra prints
* Remove outdated function
* Add message to queues for all topics in message
* Debugging
* Add message self delivery
* Increase read timeout to 5 to get pubsub tests passing
* Refactor testing helper func. Add tests
* Add tests and increase timeout to get tests passing
* Add dummy account demo scaffolding
* Attempt to use threads. Test fails
* Implement basic dummy node tests using threads
* Add generic testing function
* Add simple seven node tree test
* Add more complex seven node tree tests
* Add five node ring tests
* Remove unnecessary get_message_type func
* Add documentation to classes
* Add message id to messages
* Add documentation to test helper func
* Add docs to dummy account node helper func
* Add more docs to dummy account node test helper func
* fixed linting errors in floodsub
* small notify bugfix
* move pubsub into libp2p
* fixed pubsub linting
* fixing pubsub test failures
* linting
