connectanum 1.0.5 copy "connectanum: ^1.0.5" to clipboard
connectanum: ^1.0.5 copied to clipboard

outdated

This is a WAMP client (Web Application Messaging Protocol) implementation for the dart language and flutter projects.

connectanum-dart #

travis codecov

This is a WAMP client implementation for the dart language and flutter projects. The projects aims to provide a simple and extensible structure that is easy to use. With this project I want return something to the great WAMP-Protocol community.

WAMP is trademark of Crossbar.io Technologies GmbH.

Other Projects #

TODOs #

  • Multithreading for callee invocations
    • callee interrupt thread on incoming cancellations
  • better docs
  • msgpack serializer
  • get the auth id that called a method

Supported WAMP features #

Authentication #

Advanced RPC features #

  • ☑ Progressive Call Results
  • ☑ Progressive Calls
  • ⬜ Call Timeouts
  • ☑ Call Canceling
  • ☑ Caller Identification
  • ⬜ Call Trust Levels
  • ☑ Shared Registration
  • ⬜ Sharded Registration

Advanced PUB/SUB features #

  • ☑ Subscriber Black- and Whitelisting
  • ☑ Publisher Exclusion
  • ☑ Publisher Identification
  • ⬜ Publication Trust Levels
  • ☑ Pattern-based Subscriptions
  • ⬜ Sharded Subscriptions
  • ☑ Subscription Revocation

Stream model #

The transport contains an incoming stream that is usually a single subscribe stream. A session will internally open a new broadcast stream as soon as the authentication process is successful. The transport stream subscription passes all incoming messages to the broad cast stream. If the transport stream is done, the broadcast stream will close as well. The broad cast stream is used to handle all session methods. The user will never touch the transport stream directly.

Start the client #

To start a client you need to choose a transport module and connect it to the desired endpoint. When the connection has been established you can start to negotiate a client session by calling the client.connect() method from the client instance. On success the client will return a session object.

If your transport disconnects the session will invalidate. If a reconnect is configured, the session will try to authenticate an revalidate the session again. All subscriptions and registrations will be recovered if possible.

import 'package:connectanum/connectanum.dart';
import 'package:connectanum/json.dart';

final client = Client(
  realm: "my.realm",
  transport: WebSocketTransport(
    "ws://localhost:8080/wamp",
    new Serializer(),
    WebSocketSerialization.SERIALIZATION_JSON
  )
);
final session = await client.connect().first;

RPC #

to work with RPCs you need to have an established session.

import 'package:connectanum/connectanum.dart';
import 'package:connectanum/json.dart';

final client = Client(
  realm: "my.realm",
  transport: WebSocketTransport(
    "ws://localhost:8080/wamp",
    new Serializer(),
    WebSocketSerialization.SERIALIZATION_JSON
  )
);
final session = await client.connect().first;

// Register a procedure
final registered = await session.register("my.procedure");
registered.onInvoke((invocation) {
  // to something with the invocation
})

// Call a procedure
await for (final result in session.call("my.procedure")) {
  // do something with the result
}
10
likes
0
pub points
72%
popularity

Publisher

verified publisherdart.konsultaner.de

This is a WAMP client (Web Application Messaging Protocol) implementation for the dart language and flutter projects.

Repository (GitHub)
View/report issues

License

unknown (license)

Dependencies

logging, meta, pedantic, pointycastle, saslprep

More

Packages that depend on connectanum