Contents

module ActiveMetadata::Streamable

  def stream_for field
    sort_stream(collect_stream_data(field))
  end

  private
  def sort_stream stream
    stream.sort{|a,b| b.updated_at <=> a.updated_at}
  end

  def collect_stream_data field
    res = []
    ActiveMetadata::CONFIG['streamables'].each do |model|
      res.concat self.send(stream_collect_method(model.to_s),field).collect { |el| el }
    end
    res
  end

  def stream_collect_method model
    model.to_s == 'note' ? 'notes_for' : 'attachments_for'
  end


end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
active_metadata-0.6.6	lib/active_metadata/streamable.rb
active_metadata-0.6.5	lib/active_metadata/streamable.rb
active_metadata-0.6.4	lib/active_metadata/streamable.rb
active_metadata-0.6.3	lib/active_metadata/streamable.rb
active_metadata-0.6.2	lib/active_metadata/streamable.rb
active_metadata-0.6.1	lib/active_metadata/streamable.rb
active_metadata-0.6.0	lib/active_metadata/streamable.rb