Class: Webhookdb::Replicator::SponsyPublicationV1::Backfiller
- Inherits:
-
Base::ServiceBackfiller
- Object
- Backfiller
- Base::ServiceBackfiller
- Webhookdb::Replicator::SponsyPublicationV1::Backfiller
- Defined in:
- lib/webhookdb/replicator/sponsy_publication_v1.rb
Overview
Normal backfiller that keeps track of inserted items, and marks anything not backfilled as deleted.
Instance Attribute Summary
Attributes inherited from Base::ServiceBackfiller
#server_error_backoff, #server_error_retries, #svc
Instance Method Summary collapse
Methods inherited from Base::ServiceBackfiller
#__retryordie, #fetch_backfill_page, #initialize
Methods inherited from Backfiller
#_fetch_backfill_page_with_retry, #backfill, do_retry_wait, #fetch_backfill_page, #max_backfill_retry_attempts, #wait_for_retry_attempt
Constructor Details
This class inherits a constructor from Webhookdb::Replicator::Base::ServiceBackfiller
Instance Method Details
#flush_pending_inserts ⇒ Object
119 120 121 122 123 |
# File 'lib/webhookdb/replicator/sponsy_publication_v1.rb', line 119 def flush_pending_inserts self.svc.admin_dataset do |ds| ds.exclude(sponsy_id: @seen_ids).where(deleted_at: nil).update(deleted_at: Sequel.function(:now)) end end |
#handle_item(item) ⇒ Object
113 114 115 116 117 |
# File 'lib/webhookdb/replicator/sponsy_publication_v1.rb', line 113 def handle_item(item) super @seen_ids ||= [] @seen_ids << item.fetch("id") end |