Sha256: 30b5bc0c4543c6c811541a0dfd188adcd1f2a086e68ecd11c8f7df584b71ffab
Contents?: true
Size: 1.84 KB
Versions: 7
Compression:
Stored size: 1.84 KB
Contents
# frozen_string_literal: true
require 'active_job'
module WCC::Contentful
# This job uses the Contentful Sync API to update the configured store with
# the latest data from Contentful.
class DelayedSyncJob < ActiveJob::Base
include WCC::Contentful::ServiceAccessors
self.queue_adapter = :async
queue_as :default
def self.mutex
@mutex ||= Mutex.new
end
def perform(event = nil)
up_to_id = nil
up_to_id = event[:up_to_id] || event.dig('sys', 'id') if event
sync!(up_to_id: up_to_id)
end
# Calls the Contentful Sync API and updates the configured store with the returned
# data.
#
# @param [String] up_to_id
# An ID that we know has changed and should come back from the sync.
# If we don't find this ID in the sync data, then drop a job to try
# the sync again after a few minutes.
#
def sync!(up_to_id: nil)
return unless store.respond_to?(:index)
self.class.mutex.synchronize do
next_sync_token = store.find('sync:token')&.fetch('token')
sync_resp = client.sync(sync_token: next_sync_token)
id_found = up_to_id.nil?
count = 0
sync_resp.items.each do |item|
id = item.dig('sys', 'id')
id_found ||= id == up_to_id
store.index(item)
count += 1
end
store.set('sync:token', token: sync_resp.next_sync_token)
logger.info "Synced #{count} entries. Next sync token:\n #{sync_resp.next_sync_token}"
sync_later!(up_to_id: up_to_id) unless id_found
sync_resp.next_sync_token
end
end
# Drops an ActiveJob job to invoke WCC::Contentful.sync! after a given amount
# of time.
def sync_later!(up_to_id: nil, wait: 10.minutes)
WCC::Contentful::DelayedSyncJob.set(wait: wait)
.perform_later(up_to_id: up_to_id)
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems