rom-rb/rom-redis

module ROM
  module Redis
    class Dataset
      attr_reader :connection, :commands

      def initialize(connection, commands = [])
        @connection = connection
        @commands   = commands
      end

      def to_a
        view
      end

      def each(&block)
        view.each(&block)
      end

      def map(&block)
        view.map(&block)
      end

      def method_missing(command, *args)
        self.class.new(connection, commands.clone.push([command, args]))
      end

      private

      def view
        commands.map do |command, args|
          connection.send(command, *args)
        end
      end
    end
  end
end