context.rb

# frozen_string_literal: true

module Wilhelm
  module Core
    # Parent class
    class Context
      attr_reader :interface, :receiver, :transmitter, :multiplexer, :demultiplexer

      NAME = 'Context'

      def initialize(application_object, path)
        setup_interface(path)
        setup_transceiver(interface)
        setup_multiplexing(@receiver.output_buffer, @transmitter.frame_output_buffer)
        setup_event_handling(application_object)
      end

      def on
        @interface.on
        @receiver.on
        @transmitter.on
        @demultiplexer.on
        @multiplexer.on
      end

      def off
        LOGGER.info(NAME) { 'Switching off Multiplexing...' }
        @demultiplexer.off
        @multiplexer.off
        LOGGER.info(NAME) { 'Multiplexing is off! 👍' }

        LOGGER.info(NAME) { 'Switching off Transceiver...' }
        @receiver.off
        @transmitter.off
        LOGGER.info(NAME) { 'Transceiver is off! 👍' }

        LOGGER.info(NAME) { 'Switching off Interface...' }
        @interface.off
        LOGGER.info(NAME) { 'Interface is off! 👍' }
      end

      private

      def setup_interface(path)
        stream = Interface::Stat.new(path)
        stream_handler = stream.handler
        @interface = stream_handler.new(path)
      end

      def setup_transceiver(io_buffer)
        @receiver    = DataLink::Receiver.new(io_buffer)
        @transmitter = DataLink::Transmitter.new(io_buffer)
      end

      def setup_multiplexing(input_buffer, output_buffer)
        @demultiplexer = DataLink::Demultiplexer.new(input_buffer)
        @multiplexer   = DataLink::Multiplexer.new(output_buffer)
      end

      def setup_event_handling(application_object)
        core_listener        = Listener::CoreListener.new
        application_listener = Listener::ApplicationListener.new

        core_listener.interface_handler = InterfaceHandler.new(@receiver, @transmitter)

        @interface.add_observer(core_listener)
        @receiver.add_observer(core_listener)
        application_object.add_observer(application_listener)
      end
    end
  end
end