52c270dcf9
warn on failed pubsub subscribe
2020-02-25 17:52:08 -06:00
eb49d4b218
no empty proto dials and add connect method
2020-02-25 17:52:08 -06:00
9efc08cb2f
fix : #83
2020-02-24 08:58:02 -06:00
6a7f9f058c
address review comments
2020-02-21 09:21:06 -06:00
fbcef69891
implicitelly dial pubsub if enabled
2020-02-21 09:21:06 -06:00
cb156f3260
Fix public() using proper bear mulgen
2020-02-18 09:35:14 -06:00
93a480e6f3
removed internal globals
2020-02-18 09:35:14 -06:00
e0e371994c
Remove implicit converters
2020-02-18 09:35:14 -06:00
f039853a19
Add few converters, finish c25519 integration tests
2020-02-18 09:35:14 -06:00
99a169b65d
Curve25519 integration tests (failing, something is wrong)
2020-02-18 09:35:14 -06:00
2103aa59f3
Add chachapoly proper test
2020-02-18 09:35:14 -06:00
6ba274de27
Fix misleading header
2020-02-18 09:35:14 -06:00
f47fb628f0
Fix curve mulgen iterate/derive
2020-02-18 09:35:14 -06:00
8dec368878
Add Curve25519 (BearSSL) required operations for noise
2020-02-18 09:35:14 -06:00
71998ffc67
Start ChaCha20Poly1305 integration (BearSSL)
2020-02-18 09:35:14 -06:00
1a987a9c5b
fix: delete mplex channel
2020-02-16 13:51:03 -06:00
65ed2c7cee
make code more robust
2020-02-16 11:31:35 -06:00
9023bf786d
remove sleeps
2020-02-16 11:31:35 -06:00
acdaeb8f5d
working out synchronization issues
2020-02-16 11:31:35 -06:00
b1dd564c32
make sure we don't exit the handler prematurely
2020-02-16 11:31:35 -06:00
f9ad113d11
don't send close message if remote closed
2020-02-16 11:31:35 -06:00
f767614827
remove unnecesary async lock
2020-02-16 11:31:35 -06:00
934c858542
increase timeout to allow floodsub to finish
2020-02-16 11:31:35 -06:00
26a4510377
remove unnecesary nil check in peerinfo
2020-02-16 11:31:35 -06:00
0349165830
typo
2020-02-16 11:31:35 -06:00
7f8eb0272e
cleanup and fix tests
2020-02-16 11:31:35 -06:00
6316b07e81
don't crash when stringifying nil peerinfo
2020-02-16 11:31:35 -06:00
4faf35c52c
throw exception if handshake failed
2020-02-16 11:31:35 -06:00
f4e9bc8bfb
remove sleepAsync for synchronization
2020-02-16 11:31:35 -06:00
53e163abf2
check for size bounds when reading varints
2020-02-16 11:31:35 -06:00
94fc4e6fd2
don't use sleeps for synchronization
2020-02-16 11:31:35 -06:00
39dc9ad8a3
Revert "Implement timeout in mplex in order to read reliably close state"
...
This reverts commit 314cb6e6bffe122bcfbd155a4ef830849ace66ef.
2020-02-12 11:57:38 -05:00
11bd55308f
Revert "Properly use already specified MaxReadWriteTime as timeout"
...
This reverts commit 8f5dd75e7f28da08de2bf393b93cd290b82ed78b.
2020-02-12 11:57:38 -05:00
ea0d167285
Fix max size write mplex test
2020-02-12 11:57:38 -05:00
cf5dd27e57
Properly use already specified MaxReadWriteTime as timeout
2020-02-12 11:57:38 -05:00
4034dfae19
Implement timeout in mplex in order to read reliably close state
2020-02-12 11:57:38 -05:00
136ac3f550
Use already existing error for channel push over size
2020-02-12 11:57:38 -05:00
f9cbdc252f
Improve connection.nim read error clarity when buffer overflow
2020-02-12 11:57:38 -05:00
120ba0d528
Add a safety check on message size limit when pushing new data in mplex
2020-02-12 11:57:38 -05:00
3531ebf772
Fix typo
2020-02-12 11:57:38 -05:00
5b6f4bf5fa
Export MultiAddress pattern procedures.
2020-02-12 12:04:12 +02:00
540e79a430
Add peer lifetime feature for PeerInfo. ( #77 )
...
* Add peer lifetime feature for PeerInfo.
Refactor peerinfo to use openarrays instead of sequences.
Fix tests and examples to use arrays instead of sequences.
* Add access to lifetime Future[T] itself.
2020-02-11 12:53:39 -05:00
23712ecf3b
Lazy channels ( #78 )
...
* Implemented lazy stream opening for mplex connections
* Properly fix newStream usage
* Make lazy channel open optional
* Add Lazy channel test
* Cleanup mplex test
* Move lazyness properly into LPChannel
* Connection writeLp back to proc
2020-02-11 12:30:36 -05:00
88a030d8fb
fix: removing timeouts from conn
2020-02-05 20:38:43 +01:00
2232ca598e
don't timeout in pubsub
2020-02-04 17:59:57 +01:00
1bd933cd5a
More precise tracing
2020-02-04 17:27:32 +01:00
7bd305471c
Make sure the library can compile with json logging in trace mode
2020-02-04 15:17:39 +01:00
691efaa8a1
dont use result
2020-01-30 09:30:08 -06:00
171d60fb52
fix: reraise exception in readLp
2020-01-30 09:30:08 -06:00
06886290dd
Add links to specifications to varint comments.
2020-01-29 11:14:25 +02:00
d902127595
Fix LibP2P varint implementation to follow latest specification. ( #65 )
...
* Fix LibP2P varint implementation to decode only minimal valus.
2020-01-28 16:29:42 +01:00
007b0219f3
use ECDSA as defaults, faster in tests
2020-01-09 12:55:21 -06:00
667691f784
send messages in batches
2020-01-09 12:55:21 -06:00
cd8961cfb9
close and cleanup connections
2020-01-09 12:55:21 -06:00
c6561b8851
add timeouts to connection/secio
2020-01-09 12:55:21 -06:00
107e71203d
Fix #61 .
2020-01-09 17:38:10 +02:00
58cdefac21
don't expose private api
2019-12-24 10:35:35 -06:00
0fb1f1c5b8
strenghten pubsub interop testing
2019-12-24 10:35:35 -06:00
8714c66353
allow empty protocol string in dial
2019-12-24 10:35:35 -06:00
68cc57669e
Feat/pubsub validators ( #58 )
...
* feat: adding validator hooks to pubsub
* expose add/remove validators on switch
* do less unnecessary copyng
2019-12-16 23:24:03 -06:00
b6b0cdea98
fix: inconsistent error handling ( #56 )
...
* fix: inconsistent error handling
* fixing a few more returns
* remov reduntant returns
* feat: dont sleep in readLoop
2019-12-13 09:25:07 -06:00
e0aae6d8ac
Moved base32, 58 and 64 to stew
2019-12-13 16:00:39 +02:00
293a219dbe
Cleanup ( #55 )
...
* fix: don't allow replacing pubkey
* fix: several small improvements
* removing pubkey setter
* improove error handling
* remove the use of Option[T] if not needed
* don't use optional
* fix-ci: temporarily pin p2pd to a working tag
* fix example to comply with latest changes
* bumping p2pd again to a higher version
2019-12-10 14:50:35 -06:00
77e866d29a
Address review comments
2019-12-09 19:17:29 +02:00
454f658ba8
Fixes and tweaks related to the beacon node integration
...
* Bugfix: Dialing an already connected peer may lead to crash
* Introduced a standard_setup module allowing to instantiate
the `Switch` object in an easier manner.
* Added `Switch.disconnect(peer)`
* Trailing space removed (sorry about polluting the diff)
2019-12-08 23:58:43 +02:00
5f6fcc3d90
extract public and private keys fields from peerid ( #44 )
...
* extract public and private keys fields from peerid
* allow assigning a public key
* cleaned up TODOs
* make pubsub prefix a const
* public key should be an `Option`
2019-12-07 10:36:39 -06:00
e623e70e7b
PubSub (Gossip & Flood) Implementation ( #36 )
...
This adds gossipsub and floodsub, as well as basic interop testing with the go libp2p daemon.
* add close event
* wip: gossipsub
* splitting rpc message
* making message handling more consistent
* initial gossipsub implementation
* feat: nim 1.0 cleanup
* wip: gossipsub protobuf
* adding encoding/decoding of gossipsub messages
* add disconnect handler
* add proper gossipsub msg handling
* misc: cleanup for nim 1.0
* splitting floodsub and gossipsub tests
* feat: add mesh rebalansing
* test pubsub
* add mesh rebalansing tests
* testing mesh maintenance
* finishing mcache implementatin
* wip: commenting out broken tests
* wip: don't run heartbeat for now
* switchout debug for trace logging
* testing gossip peer selection algorithm
* test stream piping
* more work around message amplification
* get the peerid from message
* use timed cache as backing store
* allow setting timeout in constructor
* several changes to improve performance
* more through testing of msg amplification
* prevent gc issues
* allow piping to self and prevent deadlocks
* improove floodsub
* allow running hook on cache eviction
* prevent race conditions
* prevent race conditions and improove tests
* use hashes as cache keys
* removing useless file
* don't create a new seq
* re-enable pubsub tests
* fix imports
* reduce number of runs to speed up tests
* break out control message processing
* normalize sleeps between steps
* implement proper transport filtering
* initial interop testing
* clean up floodsub publish logic
* allow dialing without a protocol
* adding multiple reads/writes
* use protobuf varint in mplex
* don't loose conn's peerInfo
* initial interop pubsub tests
* don't duplicate connections/peers
* bring back interop tests
* wip: interop
* re-enable interop and daemon tests
* add multiple read write tests from handlers
* don't cleanup channel prematurely
* use correct channel to send/receive msgs
* adjust tests with latest changes
* include interop tests
* remove temp logging output
* fix ci
* use correct public key serialization
* additional tests for pubsub interop
2019-12-05 20:16:18 -06:00
903e79ede1
Feat/conn cleanup ( #41 )
...
Backporting proper connection cleanup from #36 to align with latest chronos changes.
* add close event
* use proper varint encoding
* add proper channel cleanup in mplex
* add connection cleanup in secio
* tidy up
* add dollar operator
* fix tests
* don't close connections prematurely
* handle closing streams properly
* misc
* implement address filtering logic
* adding pipe tests
* don't use gcsafe if not needed
* misc
* proper connection cleanup and stream muxing
* re-enable pubsub tests
2019-12-03 22:44:54 -06:00
1df16bdbce
set log level to trace - not enabled by default
2019-12-02 18:43:21 -06:00
f9eed172d4
Don't handle Exception
2019-12-03 01:26:59 +02:00
26366f8b56
use `Exception` to emulate `getCurrentException()`
2019-12-03 01:26:59 +02:00
a5b051a14f
fix: use exception `msg` field in logs
2019-12-03 01:26:59 +02:00
9e437a681b
fix: revert to proper exception handling
2019-12-03 01:26:59 +02:00
dde8c01448
Workaround for https://github.com/nim-lang/Nim/issues/12764 .
...
Remove usage of getCurrentException().
2019-11-28 20:58:56 +02:00
fe3c1d45bb
misc: removing unneded accessors
2019-11-06 12:13:21 -06:00
f3fc763895
daemonapi: direct p2pd's output to parent's streams
2019-11-05 21:16:56 +01:00
76fee97724
Fix MultiAddress.init(PeerID) compilation problem.
2019-11-04 20:57:17 +02:00
833e8c9406
Fix overflow problem.
...
Fix compilation warnings.
2019-10-29 20:51:48 +02:00
400218ba01
fixing remaining overflows in BE/LE
2019-10-29 11:02:28 -06:00
541f0f2a41
avoid buffer overflow on BE/LE conversions
2019-10-29 10:10:19 -06:00
cc0d45c482
Add protoAddress() utility procedure.
2019-10-29 15:38:37 +02:00
21af081066
remove init in favor of upstream init
2019-10-11 08:15:24 +09:00
a4431a86a1
fixing windows build issue
2019-10-11 08:15:24 +09:00
0b77c8c6e3
add init from TransportAddress to multiaddress
2019-10-11 08:15:24 +09:00
ae7b354819
unused directory
2019-10-11 08:15:24 +09:00
9e16fd020e
use PeerID `==` for comparisons
2019-10-11 08:15:24 +09:00
018da65708
compare peer string ids, rather than keys
2019-10-11 08:15:24 +09:00
3194e3ac5b
fixes after building with 0.20.2
2019-10-11 08:15:24 +09:00
bb277d4b56
readLp should warn on ignored exceptions
2019-10-11 08:15:24 +09:00
464d75d159
minor style fixes
2019-10-11 08:15:24 +09:00
2066e81658
set default timeout to 10 secs
2019-10-11 08:15:24 +09:00
1d4b51413e
option to allow triggering own handlers on publish
2019-10-11 08:15:24 +09:00
37d7a03fba
use a timed cache in floodsub
2019-10-11 08:15:24 +09:00
e98ec9fd49
use doAssert for release asserts
2019-10-11 08:15:24 +09:00
f190c155d3
don't throw on missing peer
2019-10-11 08:15:24 +09:00
3b9d34116d
decrease floodsub traffic
2019-10-11 08:15:24 +09:00
f9a04dbb9d
todo: poll should allow for timeouts
2019-10-11 08:15:24 +09:00
cfd31c5251
properly handle empty messages
2019-10-11 08:15:24 +09:00
6cfbf2c124
don't send messages to self
2019-10-11 08:15:24 +09:00
a01d1db6a0
prperly close and chronos connections
2019-10-11 08:15:24 +09:00
968fd85d49
properly exit readLoop on error/stream end
2019-10-11 08:15:24 +09:00
34d1a641de
cleanup/test pubsub
2019-10-11 08:15:24 +09:00
f8872dd51c
make log topics consistent
2019-10-11 08:15:24 +09:00
3c5b77affa
correctly identify incoming connection
2019-10-11 08:15:24 +09:00
68eb142a7c
end multiplex read loop on exception
2019-10-11 08:15:24 +09:00
cc2072d290
always cleanup connection on exit
2019-10-11 08:15:24 +09:00
c7606ce2eb
readMsg should never return an empty buffer
2019-10-11 08:15:24 +09:00
f7e5c8ee30
bring back commented tests
2019-10-11 08:15:24 +09:00
bc46a76029
connection should raise on invalid varint
2019-10-11 08:15:24 +09:00
15bae7bec5
use `result` instead of buffer
2019-10-11 08:15:24 +09:00
f5508be544
yield to chronos in mplex loop
2019-10-11 08:15:24 +09:00
b5c4eaf9b8
don't use result in oneliners
2019-10-11 08:15:24 +09:00
06b759e049
review cleanup
2019-10-11 08:15:24 +09:00
5ae37cac98
no more buffer resets on len prefixed reads
2019-10-11 08:15:24 +09:00
dd3f85965b
should not handle transport exceptions
2019-10-11 08:15:24 +09:00
99869aa8b8
don't reset buffer on exception
2019-10-11 08:15:24 +09:00
6baf089bb4
move tomultiaddr to wire.nim
2019-10-11 08:15:24 +09:00
f3afe0a6ce
feat: allow ussage of 0 addrs
2019-10-11 08:15:24 +09:00
9862064234
changed copyright year
2019-10-11 08:15:24 +09:00
5b3f93ba1c
feat: allow multiple handlers per topic in pubsub
2019-10-11 08:15:24 +09:00
2f31fc6940
misc: TODO for timeouts and message limit in mplex
2019-10-11 08:15:24 +09:00
b270515bb3
feat: make private/public keys Option[T]
2019-10-11 08:15:24 +09:00
663ce6c589
misc: nimpretty
2019-10-11 08:15:24 +09:00
054085620c
logging: switch debug for trace in most cases
2019-10-11 08:15:24 +09:00
011df568b7
finished integrating secio
2019-10-11 08:15:24 +09:00
3eb0cdd5f7
misc
2019-10-11 08:15:24 +09:00
9bb892de69
wip: integrating and testing secio
2019-10-11 08:15:24 +09:00
27e4516796
fix breaking test
2019-10-11 08:15:24 +09:00
b47dc89589
wip: integrating secio
2019-10-11 08:15:24 +09:00
ea142f0e6d
proxy connection through secio
2019-10-11 08:15:24 +09:00
2d00f6a6db
wip: integrating secio
2019-10-11 08:15:24 +09:00
f2fb92d1af
properly close transport
2019-10-11 08:15:24 +09:00
c98e8929bc
reverting change
2019-10-11 08:15:24 +09:00
f39a5cf5e4
temporary fix, until pub/priv keys are Option[T]
2019-10-11 08:15:24 +09:00
ef89e98479
renaming channel
2019-10-11 08:15:24 +09:00
88079a2864
incomming connection handling flow and tests
2019-10-11 08:15:24 +09:00
68d50a97f8
properly initialize hashsets
2019-10-11 08:15:24 +09:00
9f3b80b60c
got pubsub working without signing
2019-10-11 08:15:24 +09:00
80267e81ec
exit main loop correctly
2019-10-11 08:15:24 +09:00
8920cd7d60
misc: pubsub/floodsub and logging
2019-10-11 08:15:24 +09:00
4d9444afe9
proper server startup sequence
2019-10-11 08:15:24 +09:00
5f2d944545
add muxer handler and properly set stream peerinfo
2019-10-11 08:15:24 +09:00
32b74c5d1c
add logging context
2019-10-11 08:15:24 +09:00
875ec346e6
adding bool suport to protobuf methods
2019-10-11 08:15:24 +09:00
003b72ec27
adding bool
2019-10-11 08:15:24 +09:00
67e10d0747
set mplex channel peerInfo correctly
2019-10-11 08:15:24 +09:00
4f158d4e83
adding pubsub interface to switch
2019-10-11 08:15:24 +09:00
41aad2e7e6
make peerId an Option[T]
2019-10-11 08:15:24 +09:00
177eb71ffa
wip: floodsub initial implementation
2019-10-11 08:15:24 +09:00
74d2aea63d
adding chronicles topics
2019-10-11 08:15:24 +09:00
827a8caba6
wip: modeling floodsub
2019-10-11 08:15:24 +09:00
bb648c87e1
wip: modeling secio
2019-10-11 08:15:24 +09:00
525646dcc1
handle secure managers correctly
2019-10-11 08:15:24 +09:00
fc36de21c1
handle exceptions correctly
2019-10-11 08:15:24 +09:00
2febd47e0d
don't complete futures twise
2019-10-11 08:15:24 +09:00
d27ea5d228
whip initial secio
2019-10-11 08:15:24 +09:00
435c69633f
adding chronicles logging
2019-10-11 08:15:24 +09:00
5bc8e7e7b1
remap exceptions
2019-10-11 08:15:24 +09:00
116051208a
make patterns runtime only
2019-10-11 08:15:24 +09:00
93a9fd203a
fix: multistream tests
2019-10-11 08:15:24 +09:00
e31966b6f8
fix: switch, with identify and mplex
2019-10-11 08:15:24 +09:00
701e048ee6
add debug logging
2019-10-11 08:15:24 +09:00
54d740949e
debug logging
2019-10-11 08:15:24 +09:00
0c416e757e
make gcsafe
2019-10-11 08:15:24 +09:00
ddd266f584
small helper to aid in debugging
2019-10-11 08:15:24 +09:00
b5dcfa9bc4
first attempt to proper channel cleanup
2019-10-11 08:15:24 +09:00
65ce1a93fc
prevent interleaved channel data
2019-10-11 08:15:24 +09:00
8c76799d9e
make writes sequential
2019-10-11 08:15:24 +09:00
e53c87e197
reworked to make msg reading sequential
2019-10-11 08:15:24 +09:00
c7fd08e002
use sane defaults
2019-10-11 08:15:24 +09:00
e5b782f094
mplex testing/interop
2019-10-11 08:15:24 +09:00
100f6220b3
dont clash with MultiCodec
2019-10-11 08:15:24 +09:00
6086038b01
raise correct LP exception on incomplete data
2019-10-11 08:15:24 +09:00
ba843f4091
wip: interop testing
2019-10-11 08:15:24 +09:00
13ca6d253d
fix: multistream tests
2019-10-11 08:15:24 +09:00
962f58b436
avoid wrapping in several futures
2019-10-11 08:15:24 +09:00
13837619ed
plaintext security
2019-10-11 08:15:24 +09:00
8338a16aab
testing mplex
2019-10-11 08:15:24 +09:00
b7f999d316
fixing several issues found while testing
2019-10-11 08:15:24 +09:00
dee46c4d37
remove unneded var
2019-10-11 08:15:24 +09:00
14d9150bbb
moving modules to apropriate directories
2019-10-11 08:15:24 +09:00
2f402d68e1
docs/wording
2019-10-11 08:15:24 +09:00
60245a065d
fix: don't call conn handler on dials
2019-10-11 08:15:24 +09:00
0f52a6e798
fix: switch and tests
2019-10-11 08:15:24 +09:00
6f8de062bb
fix: multistream
2019-10-11 08:15:24 +09:00
5237fc8b12
test multiple streams with mplex
2019-10-11 08:15:24 +09:00
746987156d
reworked switch
2019-10-11 08:15:24 +09:00
0b784c5b58
don't pass stream handler through contructor
2019-10-11 08:15:24 +09:00
3cd19ddc47
change root object from ref to obj
2019-10-11 08:15:24 +09:00
f8a942ed67
make peerinfo an optional type
2019-10-11 08:15:24 +09:00
9889bd9cbf
return proto string from select, instead of bool
2019-10-11 08:15:24 +09:00
cc595f7947
allow selecting one of many protos in identify
2019-10-11 08:15:24 +09:00
a7e5fde6f7
check identify request against known pubkey
2019-10-11 08:15:24 +09:00
ec351cc2b0
misc: cleanup mplex
2019-10-11 08:15:24 +09:00
6ce2782e5c
add missing test
2019-10-11 08:15:24 +09:00
80c68206f7
documentation
2019-10-11 08:15:24 +09:00
9b485b3082
feat: half closed channels
2019-10-11 08:15:24 +09:00
6058a3fc69
split mplex
2019-10-11 08:15:24 +09:00
1b02c5e4e4
don't block main loop
2019-10-11 08:15:24 +09:00
36917c5adc
disable switch tests temporarily
2019-10-11 08:15:24 +09:00
Dmitriy Ryajov
Giovanni Petrantoni
cheatfate
Giovanni Petrantoni
Zahary Karadjov
Yuriy Glukhov
Ștefan Talpalaru
cheatfate