Contents

# frozen_string_literal: true

require "forwardable"

module Wamp
  module MessageHandler
    # Result
    class Base
      extend Forwardable
      attr_reader :message, :connection

      def initialize(message, connection)
        @message = message
        @connection = connection
      end

      def handle
        raise NotImplementedError
      end

      def send_message
        raise NotImplementedError
      end

      private

      def stored_data
        @stored_data ||= store.delete(store_key) || {}
      end

      def store_key
        "#{prefix}_#{identity}"
      end

      def prefix
        "request"
      end

      def identity
        message.request_id
      end

      def deliver_response(response)
        callback = stored_data.fetch(:callback, proc {})
        return unless callback

        return callback.call(response) unless response.nil?

        callback.call(message)
      end

      def validate_received_message
        connection.session.receive_message(message)
      end

      def send_serialized(message)
        connection.transmit session.send_message(message)
      end

      def_delegators :@connection, :store, :joiner, :session
      # def_delegator :auth, :authenticate
      # def_delegator :@connection, :remove_all_listeners, :off
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
xconn-0.1.2	lib/wamp/message_handler/base.rb
xconn-0.1.1	lib/wamp/message_handler/base.rb
xconn-0.1.0	lib/wamp/message_handler/base.rb