1. Feb 23, 2021
  2. Feb 22, 2021
  3. Feb 18, 2021
    • Niklas Adolfsson's avatar
      [ws client]: add `wss` test + refactor `WebSocketTransport builder` (#209) · 1cdd1381
      Niklas Adolfsson authored
      * test(ws client): wss (TLS)
      
      * fix(ws client): bug replace target with host.
      
      * address review suggestions
      
      * tests: add tests for non-ascii URLs
      
      * refactor: impl TryFrom for WebSocketTransportBuild
      
      * fix nit: try to connect to all sockaddrs
      
      * document `Host type`
      
      * doc(ws client): default port.
      
      * remove helper function
      1cdd1381
  4. Feb 15, 2021
  5. Feb 12, 2021
  6. Feb 11, 2021
  7. Feb 10, 2021
  8. Feb 08, 2021
  9. Feb 02, 2021
    • Niklas Adolfsson's avatar
      [ws client]: use `max_payload_size` in transport (#198) · 7dc9435e
      Niklas Adolfsson authored
      
      
      * fix examples
      
      * [ws client]: transport use `max_payload_size`
      
      * fix nits
      
      * fix more nits
      
      * Update ws-client/src/client.rs
      
      * fix doc tests
      
      * [ws client]: all transport config configurable
      
      * Update ws-client/src/client.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * Update ws-client/src/manager.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * address grumbles
      
      * grumbles: WsDnsError -> WsHandshakeError
      
      * grumbles: remove needless clone
      
      * fix lint: remove explicit lifetime
      
      * fix nits: channel capacity + docs
      
      * clippy nits
      
      * clippy nits
      
      * fix grumbles: channel capacity 256
      
      As Maciej pointed out the capacity is the number of messages (not bytes) and each message is 96 bytes.
      Thus, 256 * 96 = ~24kB which is reasonable default value.
      
      * Update ws-client/src/client.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * grumbles: docs
      
      Co-authored-by: default avatarDavid <[email protected]>
      7dc9435e
  10. Jan 28, 2021
  11. Jan 27, 2021
  12. Jan 26, 2021
  13. Jan 21, 2021
  14. Jan 18, 2021
    • Niklas Adolfsson's avatar
      merge v2 to master (#180) · 61656562
      Niklas Adolfsson authored
      * update http example
      
      * ungeneric crate
      
      * update dependencies
      
      * [client]: add WebSocket client again.
      
      * [deps]: remove needless dev dependencies
      
      * nits: forgot to commit new files
      
      * [ws client]: `send_text` instead of `send_binary`
      
      This is temporary fix to work with the `server` which assumes that
      `WebSocket` resonses are `text`
      
      * chore: add a bunch of more logging
      
      * [ws]: port tests but some are failing.
      
      * chore: fmt
      
      * [server API]: expose `fn local_addr` as public API.
      
      * [tests]: make them less ugly by using `127.0.0.1:0`
      
      * fix: a bunch of compiler warnings.
      
      * [api]: uniform naming, `bind -> new` in transport.
      
      * [websocket server]: reply when deserial fails
      
      When the server receives an request with invalid JSON
      `-32700, Parse error shall be returned`
      
      * chore: fmt
      
      * [tests]: fix remaining tests
      
      * [websocket server]: support `binary` and `text`
      
      * [ws server]: fix bug in subscription response.
      
      `.await` was missing in RegisteredSubscription::send() and no responses
      were actually sent which this commit fixes.
      
      * [client API]: export `WsSubscription`
      
      * [examples]: use `localhost` instead of `127.0.0.1`
      
      Hostname is required when using `wss` and `127.0.0.1` is not valid hostname.
      
      * [examples]: add subscription example.
      
      * chore: fmt
      
      * [ws server]: fix bug register new subscription.
      
      Fixes newly introduced bug that causes `register_subscription` to have
      side-effects even if the subscription fails.
      
      * fmt
      
      * more uniform logs
      
      * [ws server]: simple subscription test.
      
      * [ws server]: subscription tests improved.
      
      * [tests]: extract test helpers to a separate crate (#125)
      
      * [ws server]: don't close connection when `deserialization` fails (#131)
      
      * [ws server]: don't close conn. when `deser` fails
      
      * Update src/ws/transport.rs
      
      * grumbles: prefer matching of if else.
      
      * chore: CI warn `intra_doc_link_resolution_failure` (#139)
      
      Since we have not updated the documentation properly it's annoying that
      the entire job fails.
      
      * chore: rustfmt.toml (#138)
      
      * chore: add `rustfmt.toml` for formatting
      
      * style: `cargo fmt --all` with new config
      
      * [server raw params]: fix debug implementation (#137)
      
      * [server]: simply raw params impl
      
      Use debug implementation of `common::Params` instead of doing something
      similar that doesn't work properly.
      
      * [raw params]: derive `Debug` impl.
      
      * [ws server]: parse subscription ID for unsubscription instead of hardcoding `JsonValue::Null` (#136)
      
      * [ws server]: fix broken unsubscribe.
      
      Try to parse the subscription ID as the first element of an Array or the `subscription`
      field of an Object/Map.
      
      If both of those fails then regard it as a error.
      
      * fmt
      
      * fix grumbles: remove space indentation
      
      * fix(ws server): sub/unsubscribe to same method should generate an error (#140)
      
      * fix(ws server): sub/unsubscribe to same method err
      
      Subscribe and unsubscribe to the same method should generate an error, which this commit fixed.
      This bug was introduced by myself in https://github.com/paritytech/jsonrpsee/commit/fc87889de2615dbb3d0cf2d91a306f016d48df2d
      
      
      
      * Update src/ws/server.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * chore: add naive benches for request/response (#142)
      
      Co-authored-by: default avatarNiklas <[email protected]>
      
      * fix(ws server): remove faulty debug_assert (#145)
      
      The code assumed that `subscription id` is still in `active_subscriptions` when the
      connection was dropped.
      
      The list of subscriptions (kept in raw server) are not notified when a client dropped its
      subscription/unsubscribed thus it's possible that the actual subscriptions are closed before the
      entire client was dropped.
      
      * ci(benches): cargo check on benches. (#146)
      
      * fix(http client): implement `clone` uniform API. (#147)
      
      * chore(deps): update `futures v0.3.7` (#148)
      
      * chore(deps): update remaining crates (#149)
      
      * chore(deps): update `futures v0.3.7`
      
      * chore(deps): bump the rest of deps
      
      * Improve HTTP client background thread (#150)
      
      * refactor: resultify API + some crate reorg (#144)
      
      * [ws client]: resultify API and fix subscribe.
      
      * The commit changes the API to return `Err` when it's possible and to not ignore underlying errors.
      * Fix that `fn subscribe` doesn't accept the subscription and unsubscription to be same which causes
      errors in the server.
      
      * nits: Err::SubscriptionMetod -> Err::Subscription
      
      * refactor(client): common error type
      
      * refactor(http client): resultify
      
      * refactor(common): rename common -> types..
      
      This commit renames the `common module` to `types` and tries to distinguish the types that is
      directly related to the `JSON-RPC v2 specification` from others.
      
      Somethings are a little big sloppy named as naming is hard.
      
      Also, as bonus a removed a bunch of needless stuff in http server related to subscription.
      
      * Update src/ws/tests.rs
      
      * style: cargo fmt
      
      * fix(grumble): matches -> assert(matches)
      
      * fix(grumbles): `jsonrpc_v2` -> `jsonrpc`
      
      * fix(nit): remove unused code.
      
      * fix(benches): make it compile again.
      
      * style: cargo fmt
      
      * fix nits (#151)
      
      * fix(ws client): send binary (1 byte less payload)
      
      * docs(ws server): fix bad comment.
      
      * chore: add `editorconfig` (#152)
      
      * chore: make `debug log` less verbose. (#153)
      
      * chore: make `debug log` less verbose.
      
      The debug logging was just too verbose and this commit simplies it as follows:
      
      ```
      DEBUG recv: {"jsonrpc":"2.0","method":"<METHOD>","params":<PARAMS>,"id":<ID>}
      DEBUG send: {"jsonrpc":"2.0","result":"<RESULT>","id":<ID>}
      ```
      
      * style: cargo fmt
      
      * fix: missed logs
      
      * [jsonrpc types]: implement Display for Request/Response (#160)
      
      * feat(jsonrpc response/request): impl `Display`
      
      * refactor(logging): use display impl
      
      * use serde_json for verbosity
      
      * [http client]: refactor with "syncronous-like" design (#156)
      
      * experimental
      
      * ci(benches): sync and concurrent roundtrips
      
      Improve benchmarks to take concurrent requests into account.
      
      * ci(benches): sync and concurrent roundtrips
      
      Improve benchmarks to take concurrent requests into account.
      
      * fix(nits)
      
      * feat(http client): limit max request body size
      
      * test(http transport): request limit test
      
      * test(http client): add tests.
      
      * fix typo
      
      * fix(benches): make it compile again.
      
      * fix(ws example): revert unintentional change.
      
      * test(http client): subscription response on call.
      
      * fix(cleanup)
      
      * fix(benches): make it compile again.
      
      * Update src/client/http/transport.rs
      
      * fix(http client): `&str` -> `AsRef<str>`
      
      * docs(client types): better docs for Mismatch type.
      
      * style: `Default::default` -> `HttpConfig::default`
      
      * fix(http client): read body size from header.
      
      Expermential to read number of bytes from `HTTP Content Length` to pre-allocate the number of bytes and bail early
      if the length is bigger than the `max_request_body size`
      
      Need to be benched with bigger requests.
      
      * test(raw http): enable tests to works again.
      
      * style: cargo fmt
      
      * benches: address grumbles
      
      * feat(jsonrpc response/request): impl `Display`
      
      * refactor(logging): use display impl
      
      * fix(http client): nits.
      
      * Update benches/benches.rs
      
      * fix bad merge.
      
      * chore(deps): update dependencies. (#164)
      
      * feat(http server): configurable request body limit (#162)
      
      * feat(http server): configurable request body limit
      
      * refactor(crate reorg): to have shared http helpers.
      
      * Merge client and server errors.
      * Move `http_server_utils` to `utils/http`
      * Minor cleanup
      
      * fix nits
      
      * fix(hyper helper): u64 -> u32
      
      * Update src/utils/http/hyper_helpers.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * Update src/utils/http/hyper_helpers.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * fix: grumbles
      
      * Update src/utils/http/hyper_helpers.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * Update src/http/server.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * ci: remove nightly (#167)
      
      Use stabilized `broken_intra_doc_links` instead of `intra_doc_link_resolution_failure`
      
      * fix(websocket client): drop subscriptions that can't keep up with the internal buffer size (#166)
      
      * fix(ws client): drop subscriptions when full.
      
      This commit changes the behavior in the `WebSocket Client` where each subscription channel is used in a non-blocking
      matter until it is determined as full or disconnected. When that occurs the channel is simply dropped and when
      the user `poll` the subscription it will return all sent subscriptions before it was and terminate (return None)
      once it's polled one last time. Similarly as `Streams` works in Rust.
      
      It also adds configuration for the `WebSocket Client` to configure capacity for the different internal channels to avoid
      filling the buffers when it's not expected.
      
      * tests(ws client): simple subscription test.
      
      * fix: nits
      
      * Update src/client/ws/client.rs
      
      * refactor(tests): introduce integration_tests
      
      Make the repo structure more understable w.r.t testing.
      
      * chore(license): add missing license headers
      
      * Update src/client/ws/client.rs
      
      * Update src/client/ws/client.rs
      
      * style: remove unintended spaces.
      
      * tests: add concurrent deadlock test
      
      Ensure that if more than the requested channel buffer capacity is exceeded it should not deadlock.
      Such as spawning alot of concurrent requests, notifications or new subscriptions.
      
      * Update src/client/ws/client.rs
      
      * fix: review grumbles
      
      * fix nits: `remove needless closure`
      
      * fix: cargo fmt
      
      * Update src/client/ws/client.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * fix more nits
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * fix(ws client): embed request id in `SubscriptionClosed` (#170)
      
      * fix(ws client): embed request id SubscriptClosed
      
      Fixes https://github.com/paritytech/jsonrpsee/issues/169
      
      
      
      * Update src/client/ws/client.rs
      
      * Update src/client/ws/client.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * Update src/client/ws/client.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * chore(deps): bump dependencies (#172)
      
      * [ws client]: add tests (#134)
      
      * [test utils]: add `internal_err` and consts
      [errors]: unify client/server errors
      [test utils]: fake WebSocket jsonrpc server
      [ws client]: export errors
      [ws client]: add some basic tests
      
      * fmt
      
      * remove log target
      
      * fix nits
      
      * [ws client]: add subscription test
      
      * revert unintendend changes.
      
      * fmt
      
      * [ws client]: fix panic in tests
      
      * cleanup
      
      * tests(ws client): test for invalid request ID.
      
      * fix nits
      
      * [ws client]: kill raw client (#171)
      
      * getting started
      
      * WIP WIP
      
      * cleanup
      
      * cleanup v2
      
      * cleanup v3
      
      * perf: use BufReader BufWriter
      
      * fix(request manager): resultify insert API
      
      The rationale behind this change is that the `insert_methods` takes ownership of the `send_back_oneshot`
      and if the operation fails it should be propagated the frontend.
      
      So returning the `Err(send_back_oneshot)` if it fails makes it possible.
      
      * fix nits
      
      * examples(ws): revert changes
      
      * Update tests/integration_tests.rs
      
      * nits: fix unwraps
      
      * Update src/client/ws/manager.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * Update src/client/ws/transport.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * Update src/client/ws/client.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * fix build
      
      * refactor: simplify `Error::InvalidRequestId`
      
      It was hard to use when the expected id is not known.
      
      * fix(ws client): error handling.
      
      * fix(grumble error type): better error message.
      
      * fix(grumble): docs `JSONRPC WebSocket transport`
      
      * fix(ws manager): fix grumbles.
      
      * Add better documentation
      * Rename methods.
      * Add `proof` to unreachable!
      
      * fix(ws manager): fix nit in docs.
      
      * fix(grumbles): ws client
      
      * fix more nits
      
      * fix compile warning: export websocket transports.
      
      * Update src/client/ws/manager.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * deps: tokio 1.0 and hyper 0.14 (#176)
      
      * deps: tokio 1.0 and hyper 0.14
      
      * Update Cargo.toml
      
      * refactor: crate re-organization with separate crates (#177)
      
      * [ci]: feature `http` and `ws` removed.
      
      * refactor: re-org crate with smaller crates.
      
      * fmt
      
      * [ci]: remove default features
      
      Currently there are no features in the crates, so that check is not needed.
      
      * [http client]: remove unused dependency tokio
      
      * docs(http client): fix nits tokio 0.2 -> tokio 1.0 (#178)
      
      * docs(http client): tokio 0.2 -> tokio 1.0
      
      * fix: better link
      
      * [ci]: github actions (#179)
      
      * docs(http client): tokio 0.2 -> tokio 1.0
      
      * [ci]: remove travis
      
      * [ci]: add github actions.
      
      * [ci]: fix identation nits
      
      * [ci]: use cache for actions
      
      * [ci]: filter to clippy
      
      * [ci]: remove hacks
      
      * separate action for ci and benchmarks
      
      * [ci]: tweak to run on master branch.
      
      * examples/subscription -> examples/ws_subscription
      
      * force CI
      
      Co-authored-by: default avatarDavid <[email protected]>
      Co-authored-by: default avatarMaciej Hirsz <[email protected]>
      Co-authored-by: default avatarAtkins <[email protected]>
      61656562
  15. Jul 21, 2020
  16. Jun 30, 2020
  17. Jun 29, 2020
  18. Jun 17, 2020
  19. Jun 13, 2020
  20. Jun 11, 2020
  21. Mar 16, 2020
  22. Feb 28, 2020
  23. Feb 26, 2020
  24. Feb 24, 2020
  25. Feb 19, 2020
  26. Jan 28, 2020
  27. Jan 20, 2020
    • Andrew Jones's avatar
      Support websockets client TLS (#85) · f17b12d4
      Andrew Jones authored and Pierre Krieger's avatar Pierre Krieger committed
      * Experiment using TLS for ws client
      
      * Polkadot example works
      
      * Fmt
      
      * Support both Plain and Tls streams
      
      * Dependencies in alphabetic order
      
      * Use url scheme in connect to determine Plain or Tls
      
      * Fmt
      
      * Fix mode match
      
      * License and docs stream.rs
      
      * Move url parsing to ClientBuilder
      
      * Remove commented out line, remove default port from wss
      f17b12d4
    • Andrew Jones's avatar
      Fix panic when dropping subscription (#87) · 20bce1b1
      Andrew Jones authored and Pierre Krieger's avatar Pierre Krieger committed
      * Fix panic when dropping subscription
      
      * Remove remove active subscription
      20bce1b1
  28. Jan 13, 2020
  29. Jan 09, 2020
    • Andrew Jones's avatar
      Update to stable futures (#77) · 3090cd82
      Andrew Jones authored and Pierre Krieger's avatar Pierre Krieger committed
      
      
      * Update to stable futures
      
      * Fix breaking hyper and tokio changes
      
      * Fix breaking soketto changes
      
      * Try to fix hyper update errors
      
      * Fix remaining hyper compilation error
      
      * Update futures timer
      
      * Update to tokio 0.2
      
      * Enable basic_scheduler
      
      * Enable logging in example
      
      * Bind server inside runtime context
      
      * Format code
      
      * Return error via channel if async server bind fails
      
      * Apply suggestions from code review
      
      Co-Authored-By: default avatarPierre Krieger <[email protected]>
      
      * Question mark
      
      Co-authored-by: default avatarPierre Krieger <[email protected]>
      3090cd82
  30. Jan 03, 2020