Sha256: d61f63f4a9a6a1eca2fd308a6c8cd332377b9541f7906feabcd58c25c1e54287
Contents?: true
Size: 1.36 KB
Versions: 3
Compression:
Stored size: 1.36 KB
Contents
module DiscoApp::Concerns::Synchronises extend ActiveSupport::Concern class_methods do # Define the number of resources per page to fetch. SYNCHRONISES_PAGE_LIMIT = 250 def should_synchronise?(shop, data) true end def synchronise_by(shop, data) { id: data[:id] } end def synchronise(shop, data) data = data.with_indifferent_access return unless should_synchronise?(shop, data) begin instance = self.find_or_create_by!(self.synchronise_by(shop, data)) do |instance| instance.shop = shop instance.data = data end rescue ActiveRecord::RecordNotUnique, PG::UniqueViolation retry end instance.update(data: data) instance end def should_synchronise_deletion?(shop, data) true end def synchronise_deletion(shop, data) data = data.with_indifferent_access return unless should_synchronise_deletion?(shop, data) self.destroy_all(shop: shop, id: data[:id]) end def synchronise_all(shop, params = {}) resource_count = shop.temp { self::SHOPIFY_API_CLASS.count(params) } (1..(resource_count / SYNCHRONISES_PAGE_LIMIT.to_f).ceil).each do |page| DiscoApp::SynchroniseResourcesJob.perform_later(shop, self.name, params.merge(page: page, limit: SYNCHRONISES_PAGE_LIMIT)) end end end end
Version data entries
3 entries across 3 versions & 1 rubygems