Merge pull request #12 from xconnio/integrate-wampproto

Integrate "wampproto.rb" gem for client APIs

Gemfile

@@ -11,3 +11,5 @@ gem "rspec", "~> 3.0"
 gem "rubocop", "~> 1.21"
 
 gem "async", "~> 2.9"
+
+gem "wampproto", github: "xconnio/wampproto.rb", branch: :main, require: true

lib/wamp.rb

@@ -1,12 +1,11 @@
 # frozen_string_literal: true
 
 require_relative "wamp/version"
-require_relative "wamp/connection/base"
+require_relative "wamp/message_handler"
+require_relative "wamp/connection/session"
+require_relative "wamp/connection/websocket_connection"
 require_relative "wamp/serializer"
 require_relative "wamp/router"
-require_relative "wamp/message"
-require_relative "wamp/manager"
-require_relative "wamp/auth"
 
 module Wamp
   class Error < StandardError; end

lib/wamp/connection/session.rb

@@ -0,0 +1,35 @@
+# frozen_string_literal: true
+
+module Wamp
+  module Connection
+    # Client Session
+    class Session
+      attr_reader :joiner, :session, :store, :api
+      attr_accessor :executor, :stream
+
+      def initialize(joiner = Wampproto::Joiner.new("realm1"))
+        @joiner = joiner
+        @session = Wampproto::Session.new(joiner.serializer)
+        @api = MessageHandler::Api.new(self)
+        @store = {}
+      end
+
+      def on_join(&block)
+        self.executor = block
+      end
+
+      def on_open
+        stream.on_message joiner.send_hello
+      end
+
+      def on_message(data)
+        handler = MessageHandler.resolve(data, self)
+        handler.handle
+      end
+
+      def transmit(data)
+        stream.on_message data
+      end
+    end
+  end
+end