lib/alephant/publisher/writer.rb in alephant-publisher-0.5.1 vs lib/alephant/publisher/writer.rb in alephant-publisher-0.6.1

@@ -6,11 +6,11 @@
 require 'alephant/renderer'
 require 'alephant/lookup'
 require 'alephant/logger'
 require 'alephant/sequencer'
 require 'alephant/support/parser'
-require 'alephant/publisher/render_mapper'
+require 'alephant/publisher/view_mapper'
 
 module Alephant
   module Publisher
     class Writer
       include Logger
@@ -21,11 +21,11 @@
         @config   = config
         @message  = message
       end
 
       def mapper
-        @mapper ||= RenderMapper.new(
+        @mapper ||= ViewMapper.new(
           config[:renderer_id],
           config[:view_path]
         )
       end
 
@@ -47,30 +47,30 @@
       end
 
       protected
 
       def perform
-        Proc.new { renders.peach { |id, r| write(id, r) } }
+        Proc.new { views.each { |id, view| write(id, view) } }
       end
 
-      def write(id, r)
+      def write(id, view)
         seq_for(id).sequence(message) do
-          store(id, r.render, location_for(id))
+          store(id, view, location_for(id))
         end
       end
 
-      def store(id, content, location)
-        cache.put(location, content, :msg_id => message.id)
+      def store(id, view, location)
+        cache.put(location, view.render, view.content_type, :msg_id => message.id)
         lookup.write(id, options, seq_id, location)
       end
 
       def location_for(id)
         "#{config[:renderer_id]}/#{id}/#{opt_hash}/#{seq_id}"
       end
 
       def batch
-        @batch ||= (renders.count > 1) ? seq_for(config[:renderer_id]) : nil
+        @batch ||= (views.count > 1) ? seq_for(config[:renderer_id]) : nil
       end
 
       def batch?
         !batch.nil?
       end
@@ -90,11 +90,11 @@
 
       def seq_id
         @seq_id ||= Sequencer::Sequencer.sequence_id_from(message, config[:sequence_id_path])
       end
 
-      def renders
-        @renders ||= mapper.generate(data)
+      def views
+        @views ||= mapper.generate(data)
       end
 
       def opt_hash
         @opt_hash ||= Crimp.signature(options)
       end