Contents

require 'crimp'
require 'alephant/cache'
require 'alephant/lookup'
require 'alephant/broker/errors/invalid_cache_key'
require 'alephant/sequencer'
require 'alephant/broker/cache'

module Alephant
  module Broker
    class Component
      attr_reader :id, :batch_id, :options, :content, :opts_hash

      def initialize(meta, data)
        @id        = meta.id
        @batch_id  = meta.batch_id
        @options   = symbolize(meta.options || {})
        @content   = data[:content].force_encoding 'UTF-8'
        @opts_hash = meta.opts_hash
        @data      = data
        @meta      = meta
      end

      def content_type
        headers['Content-Type']
      end

      def headers
        {
          'Content-Type' => data[:content_type].to_s,
        }.merge(data[:headers] || {})
      end

      def status
        200
      end

      private

      attr_reader :meta, :data

      def symbolize(hash)
        Hash[hash.map { |k,v| [k.to_sym, v] }]
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
alephant-broker-3.3.2	lib/alephant/broker/component.rb
alephant-broker-3.3.1	lib/alephant/broker/component.rb
alephant-broker-3.3.0	lib/alephant/broker/component.rb