```ruby
require 'replay'
require "replay/rails/version"

module Replay
  module Rails
    class ActiveRecordEventStore 
      class Event < ActiveRecord::Base
        self.table_name = "domain_events"

        def readonly?
          persisted?
        end

        def destroy
          raise ActiveRecord::ReadOnlyRecord.new
        end
        def delete
          raise ActiveRecord::ReadOnlyRecord.new
        end

        def self.delete_all(*args)
          raise ActiveRecord::ReadOnlyRecord.new
        end

        def self.delete(*args)
          raise ActiveRecord::ReadOnlyRecord.new
        end

        def event
          event_type.constantize.new(JSON.parse(data))
        end

        def self.events_for(stream_id)
          where(:stream_id => stream_id).order('created_at asc')
        end

        def self.event_stream(stream_id)
          events_for(stream_id).to_a.map(&:event)
        end

      end

      def self.published(envelope)
        Event.create(stream_id: envelope.stream_id, event_type: envelope.type, data: envelope.event.to_json, envelope_data: envelope.metadata.to_json)
      end

      def self.event_stream(stream_id)
        Event.event_stream(stream_id)
      end
    end
  end
end

Replay::Backends.register(:active_record, Replay::Rails::ActiveRecordEventStore)
```

Store should be returning an entire event envelope
user
```ruby
require 'replay'
require "replay/rails/version"

module Replay
  module Rails
    class ActiveRecordEventStore 
      class Event < ActiveRecord::Base
        self.table_name = "domain_events"

        def readonly?
          persisted?
        end

        def destroy
          raise ActiveRecord::ReadOnlyRecord.new
        end
        def delete
          raise ActiveRecord::ReadOnlyRecord.new
        end

        def self.delete_all(*args)
          raise ActiveRecord::ReadOnlyRecord.new
        end

        def self.delete(*args)
          raise ActiveRecord::ReadOnlyRecord.new
        end

        def event
          event_type.constantize.new(JSON.parse(data))
        end

        def metadata
          Hash.new(envelope_data)
        end

        def envelope
          @envelope ||= Replay::EventEnvelope.new(
            stream_id,
            event,
            metadata
          )
        end

        def self.events_for(stream_id)
          where(:stream_id => stream_id).order('created_at asc')
        end

        def self.event_stream(stream_id)
          events_for(stream_id).to_a.map(&:envelope)
        end

      end

      def self.published(envelope)
        Event.create(stream_id: envelope.stream_id, event_type: envelope.type, data: envelope.event.to_json, envelope_data: envelope.metadata.to_json)
      end

      def self.event_stream(stream_id)
        Event.event_stream(stream_id)
      end
    end
  end
end

Replay::Backends.register(:active_record, Replay::Rails::ActiveRecordEventStore)
```
assistant