Module: Filtered

Defined in:

lib/rbbt/tsv/filter.rb

Defined Under Namespace

Classes: Filter, FilterArray

Class Method Summary

• .extended(base) ⇒ Object

  }}} FILTER.

Instance Method Summary

• #add_filter(match, value, persistence = nil) ⇒ Object
• #filtered_collect(&block) ⇒ Object
• #filtered_delete(key) ⇒ Object
• #filtered_each(&block) ⇒ Object
• #filtered_filename ⇒ Object
• #filtered_keys ⇒ Object
• #filtered_set(key, value, clean = false) ⇒ Object
• #filtered_values ⇒ Object
• #pop_filter ⇒ Object
• #size ⇒ Object

Class Method Details

.extended(base) ⇒ Object

}}} FILTER

# File 'lib/rbbt/tsv/filter.rb', line 154

def self.extended(base)
  if not base.respond_to? :unfiltered_set
    class << base
      attr_accessor :filter_dir, :filters
      
      alias unfiltered_set []=
      alias []= filtered_set

      alias unfiltered_filename filename
      alias filename filtered_filename

      alias unfiltered_keys keys
      alias keys filtered_keys

      alias unfiltered_values values
      alias values filtered_values

      alias unfiltered_each each
      alias each filtered_each

      alias unfiltered_collect collect
      alias collect filtered_collect

      alias unfiltered_delete delete
      alias delete filtered_delete
    end
  end
  base.filters = []
end

Instance Method Details

#add_filter(match, value, persistence = nil) ⇒ Object

# File 'lib/rbbt/tsv/filter.rb', line 260

def add_filter(match, value, persistence = nil)
  if persistence.nil? and filter_dir
    persistence = File.join(filter_dir, match.to_s + '.filter')
  end

  filter = Filter.new self, match, value, persistence
  filters.push filter
end

#filtered_collect(&block) ⇒ Object

# File 'lib/rbbt/tsv/filter.rb', line 236

def filtered_collect(&block)
  if filters.empty?
    self.send(:unfiltered_collect, &block)
  else
    ids = filters.inject(nil){|list,filter| list = (list.nil? ? filter.ids.dup : Misc.intersect_sorted_arrays(list, filter.ids.dup))}

    new = TSV.setup({}, self.options)

    ids.zip(self.send(:values_at, *ids)).each do |id, values|
      new[id] = values
    end
    new.send :collect, &block
  end
end

#filtered_delete(key) ⇒ Object

# File 'lib/rbbt/tsv/filter.rb', line 251

def filtered_delete(key)
  if filters.empty?
    self.send(:unfiltered_delete, key)
  else
    reset_filters
    self.send :unfiltered_delete, key
  end
end

#filtered_each(&block) ⇒ Object

# File 'lib/rbbt/tsv/filter.rb', line 222

def filtered_each(&block)
  if filters.empty?
    self.send(:unfiltered_each, &block)
  else
    ids = filters.inject(nil){|list,filter| list.nil? ? filter.ids.dup : Misc.intersect_sorted_arrays(list, filter.ids.dup)}

    ids.each do |id|
      value = self[id]
      yield id, value if block_given?
      [id, value]
    end
  end
end

#filtered_filename ⇒ Object

# File 'lib/rbbt/tsv/filter.rb', line 184

def filtered_filename
  if filters.empty?
    unfiltered_filename
  else
    unfiltered_filename + ":Filtered[#{filters.collect{|f| [f.match, Array === f.value ? Misc.hash2md5(:values => f.value) : f.value] * "="} * ", "}]"
  end
end

#filtered_keys ⇒ Object

# File 'lib/rbbt/tsv/filter.rb', line 203

def filtered_keys
  with_monitor(false) do
    if filters.empty?
      self.send(:unfiltered_keys)
    else
      filters.inject(nil){|list,filter| list.nil? ? filter.ids.dup : Misc.intersect_sorted_arrays(list, filter.ids.dup)}
    end
  end
end

#filtered_set(key, value, clean = false) ⇒ Object

# File 'lib/rbbt/tsv/filter.rb', line 192

def filtered_set(key, value, clean = false)
  if filters.empty?
    self.send(:unfiltered_set, key, value, clean)
  else
    filters.each do |filter| 
      filter.add key if filter.match_entry key, value
    end
    self.send(:unfiltered_set, key, value, clean)
  end
end

#filtered_values ⇒ Object

# File 'lib/rbbt/tsv/filter.rb', line 213

def filtered_values 
  if filters.empty?  
    self.send(:unfiltered_values) 
  else 
    ids = filters.inject(nil){|list,filter| list.nil? ? filter.ids.dup : Misc.intersect_sorted_arrays(list, filter.ids.dup)}
    self.send :values_at, *ids
  end
end

#pop_filter ⇒ Object

# File 'lib/rbbt/tsv/filter.rb', line 269

def pop_filter
  filters.pop.add_unsaved if filters.any?
end

#size ⇒ Object

# File 'lib/rbbt/tsv/filter.rb', line 273

def size
  filters.empty? ? super : filters.collect{|f| f.ids.length }.min
end