module Euston
  module Repository
    class << self
      attr_accessor :event_store

      def find type, id
        stream = event_store.open_stream :stream_id => id
        return nil if stream.committed_events.empty?

        type.hydrate stream
      end

      def save aggregate
        stream = event_store.open_stream :stream_id => aggregate.aggregate_id
        aggregate.uncommitted_events.each { |e| stream << e }
        stream.commit_changes Euston.uuid.generate
      end
    end
  end
end