Module: GoodData::Bam::Taps
- Defined in:
- lib/base/taps.rb
Class Method Summary collapse
- .get_deleted_records_info(taps, client) ⇒ Object
- .get_file(taps) ⇒ Object
- .get_incremental(taps) ⇒ Object
- .get_salesforce(taps) ⇒ Object
Class Method Details
.get_deleted_records_info(taps, client) ⇒ Object
17 18 19 20 21 22 23 24 25 26 |
# File 'lib/base/taps.rb', line 17 def self.get_deleted_records_info(taps, client) deleted = client.modules.map {|i| {:name => i[:name], :flag => i[:replicateable]}}.reduce({}) {|memo, x| memo.merge({x[:name] => x[:flag]})} taps.map do |t| if t[:source_type] == :salesforce t.merge({:has_deleted_records => deleted[t[:object]]}) else t.merge({:has_deleted_records => false}) end end end |
.get_file(taps) ⇒ Object
13 14 15 |
# File 'lib/base/taps.rb', line 13 def self.get_file(taps) taps.find_all {|t| [:web, :file].include?(t[:source_type]) } end |
.get_incremental(taps) ⇒ Object
5 6 7 |
# File 'lib/base/taps.rb', line 5 def self.get_incremental(taps) taps.find_all {|t| t[:direct] == false || t[:direct].nil? } end |
.get_salesforce(taps) ⇒ Object
9 10 11 |
# File 'lib/base/taps.rb', line 9 def self.get_salesforce(taps) taps.find_all {|t| t[:source_type] == :salesforce} end |