ohyo-io / wampire Goto Github PK

Enter a command (or type "help")
add 10,10
Error: CallError { reason: InvalidArgument, args: Some([String("Expected integer, got 10")]), kwargs: None }

Router aborted connection.  Reason: CustomReason(URI { uri: "wamp.error.no_auth_method" })

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
    env_logger::Builder::from_env(Env::default().default_filter_or("info")).init();
    info!("start");
  
    tokio::spawn(async move {
        let mut router = Router::new();
        router.add_realm("ca.test");
        
        router.listen("127.0.0.1:12345").join();
       
        println!("router ende");
    });
    println!("Press enter to quit");
    let mut input = String::new();
    io::stdin().read_line(&mut input).unwrap();
    Ok(())
}

#from autobahn.twisted.wamp import ApplicationSession
from autobahn.asyncio.wamp import ApplicationSession, ApplicationRunner
import asyncio
class MyComponent(ApplicationSession):


    async def onJoin(self, details):
        print(details)
        # 3. register a procedure for remote calling
        def add2(x, y):
            return x + y

        await self.register(add2, 'ca.test.add2')

        # 4. call a remote procedure
       
        while True:
            res = await self.call('ca.test.add2', 2, 3)
            print("Got result: {}".format(res))
            await asyncio.sleep(1)
        #self.leave()

    def onDisconnect(self):
        asyncio.get_event_loop().stop()

if __name__ == "__main__":
    print("starte")
    runner = ApplicationRunner("ws://127.0.0.1:12345","ca.test")
    runner.run(MyComponent)

    raise ProtocolError("{0}: invalid value {1} for ID".format(message, value))
autobahn.wamp.exception.ProtocolError: 'registration' in REGISTERED: invalid value 66856894559470078 for ID

[2019-12-26T20:05:13Z ERROR ws::handler] WS Error <Io(Os { code: 10061, kind: ConnectionRefused, message: "No connection could be made because the target machine actively refused it." })>
[2019-12-26T20:05:13Z TRACE ws::io] WebSocket connection to token=Token(0) disconnected.
[2019-12-26T20:05:13Z TRACE ws::io] Active connections 0
[2019-12-26T20:05:13Z DEBUG ws::io] Shutting down websocket client.
[2019-12-26T20:05:13Z DEBUG ws::factory] Factory received WebSocket shutdown request.
[2019-12-26T20:05:13Z TRACE mio::poll] deregistering handle with poller
[2019-12-26T20:05:13Z TRACE mio::poll] deregistering handle with poller
[2019-12-26T20:05:13Z TRACE mio::poll] deregistering handle with poller
[2019-12-26T20:05:13Z DEBUG wampire::client] Result of connection: Ok(())
thread 'main' panicked at 'called `Result::unwrap()` on an `Err` value: RecvError', src\libcore\result.rs:1165:5
note: run with `RUST_BACKTRACE=1` environment variable to display a backtrace.