Skip to content
  1. Jul 10, 2021
    • David's avatar
      Pass OwnedRpcParams to async methods (#410) · d5d67e98
      David authored 
      

* Pass OwnedRpcParams to async methods

* Cow-ified RpcParams

* fmt

* Separate `RpcParamsSequence` parser from `RpcParams`

* Remove OwnedId, use Id<'static> instead

* Ensure that parsed `Id` is borrowing from input slice

* Tweak/add some docs
Test that parse() works after calling sequence()

* Fix rustdoc link

Co-authored-by: default avatarMaciej Hirsz <[email protected]>
      d5d67e98
  3. Jul 01, 2021
    • Igor Aleksanov's avatar
      New proc macro (#387) · ddb50806
      Igor Aleksanov authored 
      

* Start working on the new proc macro system

* Add skeleton for rendering

* Improve error reporting

* Main part of 'render_client'

* Implement RPC client generation

* Client successfully rendered

* Add doc-comment generation for the API client

* Check that all the methods have receiver

* Start working on the server impl

* Add helper method to find server crate

* Fix usage of client rpc path

* Decent progress on the server macro implementation

* Server macro compiled successfully

* Remove unneeded re-export

* Insert SubscriptionSink argument to the subscription server signatures

* Add basic doc-comment for the macro

* no_run -> ignore

* Trait with subscription compiles

* Extend the example

* Add integration test for client/server impl

* Add trybuild setup

* Set correct span for attribute parsing related errors

* Add basic set of trybuild tests

* Add tests for client and server generated separately

* Improve proc-macro documentation

* Update proc-macros/src/lib.rs

Co-authored-by: default avatarNiklas Adolfsson <[email protected]>

* Fix a couple of bugs in docs

* Fix rendering subscription with params

Co-authored-by: default avatarNiklas Adolfsson <[email protected]>
      ddb50806
    • Maciej Hirsz's avatar
      Streaming RpcParams parsing (#401) · 095db9b2
      Maciej Hirsz authored 
      * Streaming RpcParams parsing

* DRY RpcParams::one again

* Fix doc comments
      095db9b2
  5. Jun 24, 2021
  7. Jun 03, 2021
    • David's avatar
      Add a builder to the ws server (#365) · fa1f9e0e
      David authored 
      * Add a builder to the ws server

* Use the WsServerBuilder in tests&examples

* cleanup

* fmt

* Fix benches

* fix error message

* Add connection count limiting and associated config item

* Use the strong_count to `methods` to know how many connections we currently have

* Fix test
      fa1f9e0e
  9. Jun 02, 2021
  11. Jun 01, 2021
  13. May 28, 2021
  15. May 19, 2021
  17. May 18, 2021
  19. May 12, 2021
    • Billy Lindeman's avatar
      [ws client] RegisterNotification support (#303) · c7384471
      Billy Lindeman authored 
      * Rename NotifResponse to SubscriptionResponse to make room for new impl

* Add support for on_notification Subscription<T> types

* Fix handling of NotificationHandler in manager

* cleanup

* Implement NotificationHandler to replace Subscription<T> and clean up plumbing

* More cleanup

* impl Drop for NotificationHandler

* Address pr feedback #1

* ws client register_notification pr feedback 2

* Fix doc

* fix typo

* Add tests, get NH working

* More cleanup of String/&str

* fix doc

* Drop notification handler on send_back_sink error

* ws client notification auto unsubscribe when channel full test
      c7384471
  21. May 04, 2021
    • Niklas Adolfsson's avatar
      [servers] return error if context or params fails (#295) · b51abeca
      Niklas Adolfsson authored 
      * ret err if context/params fails

* address grumbles: specific error_code context fail

* address grumbles: make env_logger dev-dependency

* address grumbles: add tests

* chore(deps): remove unused deps

* address grumbles: rename types and docs

* address grumbles: more renaming.

* fix build
      b51abeca
    • David's avatar
      [http server] Batch requests (#292) · 2cae10b6
      David authored 
      

* WIP

* Implement draft of batch requests

* fmt

* cleanup

* Explain why we don't use an untagged enum

* Avoid allocating a Vec for single requets

* Add comment

* Add a benchmark for batch requests

* Add more tests, noting where we diverge from the spec
Fix empty batch case, i.e. `[]`

* Obey the fmt

* Update benches/bench.rs

Co-authored-by: default avatarAndrew Plaza <[email protected]>

* Update http-server/src/server.rs

Co-authored-by: default avatarAndrew Plaza <[email protected]>

* Add link to issue

* Explain why we're closing the receiving end of the channel.

* Limit logging of requests and response to 1kb
Add more comments
Factor out batch response collection

* Wrap comment

* tweak log line

* Benchmark batch request over different batch sizes

* fmt

Co-authored-by: default avatarAndrew Plaza <[email protected]>
      2cae10b6
  23. Apr 28, 2021
  25. Apr 26, 2021
    • Niklas Adolfsson's avatar
      [types]: allow `data` field in jsonrpc error obj. (#286) · 187ee5e9
      Niklas Adolfsson authored 
      * [types]: allow `data` field in jsonrpc error obj.

* fmt

* revert change to make fail

* remove redundant test

* [types]: bring back `data` and `message` in error.

Basically deducing the error message from server defined error doesn't work
and we should not strip out this information from to user which might be useful.

* remove boiler plate code

* [types]: impl From<ErrorCode> for JsonRpcError

* address grumbles

* remove more boiler plate
      187ee5e9
  27. Apr 20, 2021
    • Niklas Adolfsson's avatar
      [client] use types v2 (less alloc) (#269) · 31153ac7
      Niklas Adolfsson authored 
      * rewrite me

* v2

* PoC works without batch request

* remove `PartialEq` bounds

* add naive benches types

* misc

* remove useless lifetime

* [ws client]: move request ID generation to client

* make tests compile again

* [client transport]: kill leaky abstractions.

* [http client transport]: minor changes in the API.

* [ws client]: fix batch requests.

* fix nits

* [ws client]: generate two request IDs for subscrib

* fix tests

* remove unused types + less alloc for params.

* fix nits

* more tweaks.

* remove unused code

* fix more nits

* remove unused legacy types

* reorg types_v2 mod

* port macros to new types

* fix tests again; more jsonvalue

* [proc macros]: bring back impl Into for params.

* fix build

* [proc macros]: make it work for external crates.

* [types]: remove weird From<Option<T>> to impl.

* cleanup again

* [examples]: remove unused async-std dep

* Update types/src/v2/mod.rs

* [types]: remove unsed dep smallvec

* rewrite me

* [types]: error code impl ser/deser

Manual implementation of serialize/deserialize to get rid of duplicated message string

* [types v2]: re-org with explicit mods

* fix faulty test

* add missed files

* [ws client]: req_manager reserve unsubscribe slot.

* simplify test code

* add tracking issue for TODO

* remove unused deps
      31153ac7
  29. Apr 12, 2021
    • Niklas Adolfsson's avatar
      [utils]: use futures mpsc instead of tokio sync (#263) · 495e0bb3
      Niklas Adolfsson authored 
      * [utils]: use futures mpsc

Use futures::channel::mpsc as it's already brought in as dependency and to avoid bring
in tokio sync as an additional dependency.

* remove unused deps/code

* fix nit

* [utils]: future mpsc works without alloc.

* [http server]: future mpsc works without alloc.
      495e0bb3
  31. Apr 01, 2021
    • Niklas Adolfsson's avatar
      HTTP server refactor (#253) · 49899740
      Niklas Adolfsson authored 
      * refactor benches

* start

* fix build: enable `raw value` feature serde_json

* start

* port it

* make tests compile

* fix bench

* fix bench

* introduce builder pattern

* tweaks

* remove unused code

* cleanup

* [http server]: configure tcp socket manually.

The major reason is to provide a uniform API with the WebSocket server to return the local address.

* remove unused deps

* [examples]: remove needless sleep

* chore: add docs and refactor noise.

* Update types/src/jsonrpc/error.rs

* http server use constants
      49899740