Contents

# frozen_string_literal: true

module Logux
  module Rack
    LOGUX_ROOT_PATH = '/logux'

    class App < Sinatra::Base
      before do
        request.body.rewind
        content_type 'application/json'
      end

      post LOGUX_ROOT_PATH do
        stream do |out|
          begin
            logux_stream = Logux::Stream.new(out)
            logux_stream.write('[')
            Logux.verify_request_meta_data(meta_params)
            Logux.process_batch(stream: logux_stream, batch: command_params)
          rescue => e
            handle_processing_errors(logux_stream, e)
          ensure
            logux_stream.write(']')
            logux_stream.close
          end
        end
      end

      private

      def logux_params
        @logux_params ||= JSON.parse(request.body.read)
      end

      def command_params
        logux_params.dig('commands') || []
      end

      def meta_params
        logux_params&.slice('version', 'password')
      end

      def handle_processing_errors(logux_stream, exception)
        Logux.configuration.on_error&.call(exception)
        Logux.logger.error("#{exception}\n#{exception.backtrace.join("\n")}")
      ensure
        logux_stream.write(Logux::ErrorRenderer.new(exception).message)
      end
    end
  end

  def self.application
    Logux::Rack::App
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
logux-rack-0.1.0	lib/logux/rack/app.rb