Class: Streamline::Stores::ActiveRecordStore
- Extended by:
- Forwardable
- Defined in:
- lib/streamline/stores/active_record_store.rb
Instance Method Summary collapse
Instance Method Details
#find_event(id) ⇒ Object
12 13 14 |
# File 'lib/streamline/stores/active_record_store.rb', line 12 def find_event(id) prepare_event(model.find(id).attributes) end |
#find_subsequent_events(event) ⇒ Object
16 17 18 19 20 21 |
# File 'lib/streamline/stores/active_record_store.rb', line 16 def find_subsequent_events(event) model .where('occurred_at > ?', event['occurred_at']) .order('occurred_at ASC') .map { |e| prepare_event(e.attributes) } end |
#save_event(attributes) ⇒ Object
8 9 10 |
# File 'lib/streamline/stores/active_record_store.rb', line 8 def save_event(attributes) model.create!(attributes).id end |