varun-r-mallya/py-libp2p
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/py-libp2p.git synced 2025-12-31 20:36:24 +00:00
Code Issues Packages Projects Releases Wiki Activity
1,012 Commits 15 Branches 0 Tags
5fdca2ffb2460045b9920739ca481b397ced5946
Commit Graph

465 Commits

Author SHA1 Message Date
Alex Stokes
5fdca2ffb2 Add public key implementation 2019-09-24 09:51:31 -07:00
Alex Stokes
fa7d1d66a8 Fix import path 2019-09-24 09:51:31 -07:00
Alex Stokes
b142964d31 Adds support for verifying ed25519 signatures, for secio 2019-09-24 09:51:31 -07:00
Kevin Mai-Husan Chia
dbc35e8b9d Merge pull request #310 from mhchia/fix/missing_await_for_stream_reset_in_pubsub 
Add the missing `await` for `stream.reset` in pubsub
 2019-09-24 14:04:25 +08:00
mhchia
da34b086d5 Merge branch 'master' into fix/change-notifee-and-add-tests-for-swarm-conn-and-mplex 2019-09-24 13:50:54 +08:00
mhchia
b0c919aab7 Add the missing await 2019-09-24 13:34:26 +08:00
mhchia
7405f078e6 Raise read_delim exception with different msgs 
Separate `len(msg_bytes) == 0` and `msg_bytes[-1:] != b"\n"`, to raise
`ParseError` with different messages.
 2019-09-24 13:22:25 +08:00
mhchia
37bee9fb16 PR feedback 
- Use `TMuxerOptions` and `TSecurityOptions` in libp2p/__init__.py
- Remove the default value for `muxer_transports_by_protocol` in
`MuxerMultistream` and `secure_transports_by_protocol`
`SecureMultistream`
 2019-09-24 12:51:59 +08:00
Kevin Mai-Husan Chia
1bd18c84f2 Apply suggestions from code review 
Co-Authored-By: Alex Stokes <r.alex.stokes@gmail.com>
 2019-09-24 12:33:14 +08:00
mhchia
d1c25b8b1e Fix interop pubsub tests and PR feedback 
- Use `from_id`, the changed field name in `PSMessage`.
- PR feedbacks
        - Add label `test` in `testenv` in tox.ini, to avoid wrong
dispatching an environment's command in the future.
        - Use `pytest` over `py.test`.
 2019-09-24 11:30:52 +08:00
mhchia
95ae718e3d Raise ParseError in read_delim 2019-09-23 16:01:22 +08:00
mhchia
92deae41dc Change SwarmConn.conn to muxed_conn 2019-09-23 15:46:50 +08:00
mhchia
8d2415a404 Move calls to Notifee inside Swarm 2019-09-23 15:01:58 +08:00
mhchia
6f8394e4bd Merge branch 'master' into fix/change-notifee-and-add-tests-for-swarm-conn-and-mplex 2019-09-21 18:34:12 +08:00
mhchia
539047be2d Make mplex.read_message handle RawConnError 2019-09-21 18:17:00 +08:00
mhchia
e44c2145cc Merge branch 'master' into fix/detection-of-close 2019-09-21 18:05:54 +08:00
mhchia
0df578d219 Add the missing exceptions.py 2019-09-21 17:18:55 +08:00
mhchia
a27a817d50 Fix tests 2019-09-20 16:17:13 +08:00
mhchia
89c127eff4 Merge branch 'master' into fix/refactor-mplex-swarm-host 2019-09-20 15:45:28 +08:00
NIC619
7fc958e7be Add exception raised to docstring 2019-09-19 22:19:36 +08:00
NIC619
c6294ad19b Raise MultiselectCommunicatorError: 
when failed to write to communicator
 2019-09-19 21:51:23 +08:00
NIC619
b9d1875027 Catch OpenConnectionError in swarm.dial_peer 2019-09-19 21:24:01 +08:00
NIC619
1f76f6ee1b Raise OpenConnectionError 
when failed to open connection
 2019-09-19 21:23:35 +08:00
NIC619
c44be5e247 Add OpenConnectionError for base transport 2019-09-19 21:23:01 +08:00
mhchia
62b0bc4580 Remove useless protocol_ids in logging 2019-09-19 16:31:42 +08:00
mhchia
02c55e5d14 Add tests for MplexConn 2019-09-19 16:31:42 +08:00
mhchia
a9ad37bc6f Add mplex tests and fix error in SwarmConn.close 2019-09-19 16:31:41 +08:00
mhchia
d61327f5f9 Add tests for SwarmConn 2019-09-19 16:31:41 +08:00
mhchia
b8b5ac5e06 Add test for notifee disconnected 2019-09-19 16:31:41 +08:00
mhchia
5307c0506b Change IMuxedConn to INetConn in Notifee 2019-09-19 16:31:41 +08:00
mhchia
0356380996 Add tests for swarm, and debug 
Fix `swarm_pair_factory`
 2019-09-19 16:31:40 +08:00
mhchia
e7304538da Add test for Swarm.close_peer 2019-09-19 16:31:12 +08:00
mhchia
6923f257f6 Remove print 2019-09-19 16:07:53 +08:00
mhchia
5f064dd329 Refactor: get rid of single huge _handle_incoming 2019-09-19 15:55:27 +08:00
mhchia
4a689c7d57 Fix error when reset 
If `Mplex` is cleanup first, `MplexStream.reset` possibly fails because
`Mplex.streams` is set to `None` in `cleanup`.
 2019-09-19 15:55:27 +08:00
mhchia
b51c2939a8 Handle exceptions inside read_message 
And remove the need of checking `None` for every read messages.
 2019-09-19 15:55:26 +08:00
mhchia
f62f07bb9f Handle IncompleteRead in handle_incoming 2019-09-19 15:55:26 +08:00
mhchia
2d8e02b7eb Add detection for disconnections in mplex 2019-09-19 15:55:26 +08:00
mhchia
393b51a744 isort 2019-09-19 15:53:40 +08:00
mhchia
5653b3f604 Add "closed" and "shutting_down" events 2019-09-19 15:53:39 +08:00
mhchia
7cf0495f37 Remove print 2019-09-19 15:38:38 +08:00
mhchia
a7bc9fc358 Asynchronously handling the accepted stream. 2019-09-19 13:59:51 +08:00
mhchia
6cb033fd1f Refactor multiselect out of Swarm to BasicHost 2019-09-19 13:59:50 +08:00
mhchia
0bd213bbb7 Refactor mplex and start to add close detection 2019-09-19 13:56:05 +08:00
NIC619
f253152858 Handle protocol negotiation failure in swarm new_stream 2019-09-17 16:17:41 +08:00
NIC619
559f419b4e Fix stream registration in accept_stream 2019-09-17 15:42:18 +08:00
NIC619
0080466d86 Handle RawConnError in InsecureSession.run_handshake 2019-09-16 19:16:41 +08:00
NIC619
09bfa0ab09 Handle IOException in create_secure_session 2019-09-16 19:15:40 +08:00
NIC619
c7593bff97 Add InconsistentNonce in secio 2019-09-16 19:11:46 +08:00
NIC619
359bcf45ff SecioException inherit from HandshakeFailure 2019-09-16 19:11:06 +08:00