Commit Graph

1010 Commits

Author SHA1 Message Date
b142964d31 Adds support for verifying ed25519 signatures, for secio 2019-09-24 09:51:31 -07:00
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
b53ca5708f Merge pull request #305 from mhchia/fix/change-notifee-and-add-tests-for-swarm-conn-and-mplex
Change `Notifee`, add tests for `SwarmConn` and `Mplex`
2019-09-24 14:02:58 +08:00
da34b086d5 Merge branch 'master' into fix/change-notifee-and-add-tests-for-swarm-conn-and-mplex 2019-09-24 13:50:54 +08:00
3e9df896f4 Merge pull request #308 from mhchia/fix/move-deps-on-p2pclient-to-tox
Move interop tests outside `tests`
2019-09-24 13:49:35 +08:00
b0c919aab7 Add the missing await 2019-09-24 13:34:26 +08:00
e217acf4ac Add additional sleep
To be more confident that the stream handler is registered in the
daemon.
2019-09-24 13:28:25 +08:00
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
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
1bd18c84f2 Apply suggestions from code review
Co-Authored-By: Alex Stokes <r.alex.stokes@gmail.com>
2019-09-24 12:33:14 +08:00
1bfc6b41e4 Add pexpect in isort third party 2019-09-24 12:18:31 +08:00
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
19c17dd512 Remove the leftover test in testenv commands
To make `tox -e py37-interop` run.
2019-09-23 22:10:47 +08:00
006002f687 Move interop tests out of tests
It is moved to the top level package `tests_interop`, to avoid circular
dependency, with the dependency moved to `tox`.
2019-09-23 22:00:40 +08:00
95ae718e3d Raise ParseError in read_delim 2019-09-23 16:01:22 +08:00
92deae41dc Change SwarmConn.conn to muxed_conn 2019-09-23 15:46:50 +08:00
8d2415a404 Move calls to Notifee inside Swarm 2019-09-23 15:01:58 +08:00
6f8394e4bd Merge branch 'master' into fix/change-notifee-and-add-tests-for-swarm-conn-and-mplex 2019-09-21 18:34:12 +08:00
4a838033ff Merge pull request #304 from mhchia/fix/detection-of-close
Detect closed `Mplex`
2019-09-21 18:28:16 +08:00
539047be2d Make mplex.read_message handle RawConnError 2019-09-21 18:17:00 +08:00
e44c2145cc Merge branch 'master' into fix/detection-of-close 2019-09-21 18:05:54 +08:00
99ef3f08d8 Merge pull request #303 from mhchia/fix/refactor-mplex-swarm-host
Refactor: `Mplex`, `Swarm`, and `BasicHost`
2019-09-21 17:27:09 +08:00
0df578d219 Add the missing exceptions.py 2019-09-21 17:18:55 +08:00
a27a817d50 Fix tests 2019-09-20 16:17:13 +08:00
89c127eff4 Merge branch 'master' into fix/refactor-mplex-swarm-host 2019-09-20 15:45:28 +08:00
85457fa308 Merge pull request #299 from NIC619/add_more_error_handling
Add more error handling
2019-09-19 23:45:02 +08:00
7fc958e7be Add exception raised to docstring 2019-09-19 22:19:36 +08:00
c6294ad19b Raise MultiselectCommunicatorError:
when failed to write to communicator
2019-09-19 21:51:23 +08:00
b9d1875027 Catch OpenConnectionError in swarm.dial_peer 2019-09-19 21:24:01 +08:00
1f76f6ee1b Raise OpenConnectionError
when failed to open connection
2019-09-19 21:23:35 +08:00
c44be5e247 Add OpenConnectionError for base transport 2019-09-19 21:23:01 +08:00
62b0bc4580 Remove useless protocol_ids in logging 2019-09-19 16:31:42 +08:00
313ae45b45 Add tests for MplexStream 2019-09-19 16:31:42 +08:00
02c55e5d14 Add tests for MplexConn 2019-09-19 16:31:42 +08:00
a9ad37bc6f Add mplex tests and fix error in SwarmConn.close 2019-09-19 16:31:41 +08:00
d61327f5f9 Add tests for SwarmConn 2019-09-19 16:31:41 +08:00
b8b5ac5e06 Add test for notifee disconnected 2019-09-19 16:31:41 +08:00
675c61ce3b Move test_notify from libp2p to network 2019-09-19 16:31:41 +08:00
5307c0506b Change IMuxedConn to INetConn in Notifee 2019-09-19 16:31:41 +08:00
0356380996 Add tests for swarm, and debug
Fix `swarm_pair_factory`
2019-09-19 16:31:40 +08:00
276ac4d8ab Add initial test for Swarm.close_peer 2019-09-19 16:31:13 +08:00
e7304538da Add test for Swarm.close_peer 2019-09-19 16:31:12 +08:00
6923f257f6 Remove print 2019-09-19 16:07:53 +08:00
5f064dd329 Refactor: get rid of single huge _handle_incoming 2019-09-19 15:55:27 +08:00
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
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
f62f07bb9f Handle IncompleteRead in handle_incoming 2019-09-19 15:55:26 +08:00
2d8e02b7eb Add detection for disconnections in mplex 2019-09-19 15:55:26 +08:00
393b51a744 isort 2019-09-19 15:53:40 +08:00
5653b3f604 Add "closed" and "shutting_down" events 2019-09-19 15:53:39 +08:00