Class: Webhookdb::Replicator::IcalendarCalendarV1::Upserter

Inherits:
Object
  • Object
show all
Includes:
Backfiller::Bulk
Defined in:
lib/webhookdb/replicator/icalendar_calendar_v1.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Backfiller::Bulk

#dry_run?, #flush_pending_inserts, #handle_item, #pending_inserts, #remote_key_column_name

Constructor Details

#initialize(replicator, calendar_external_id, now:) ⇒ Upserter

Returns a new instance of Upserter.



151
152
153
154
155
 
# File 'lib/webhookdb/replicator/icalendar_calendar_v1.rb', line 151

def initialize(replicator, calendar_external_id, now:)
  @upserting_replicator = replicator
  @calendar_external_id = calendar_external_id
  @now = now
end

Instance Attribute Details

#calendar_external_id ⇒ Object (readonly)

Returns the value of attribute calendar_external_id.



149
150
151
 
# File 'lib/webhookdb/replicator/icalendar_calendar_v1.rb', line 149

def calendar_external_id
  @calendar_external_id
end

#now ⇒ Object (readonly)

Returns the value of attribute now.



149
150
151
 
# File 'lib/webhookdb/replicator/icalendar_calendar_v1.rb', line 149

def now
  @now
end

#upserting_replicator ⇒ Object (readonly)

Returns the value of attribute upserting_replicator.



149
150
151
 
# File 'lib/webhookdb/replicator/icalendar_calendar_v1.rb', line 149

def upserting_replicator
  @upserting_replicator
end

Instance Method Details

#conditional_upsert? ⇒ Boolean

Returns:

  • (Boolean) 


158
 
# File 'lib/webhookdb/replicator/icalendar_calendar_v1.rb', line 158

def conditional_upsert? = true

#prepare_body(body) ⇒ Object 



160
161
162
163
 
# File 'lib/webhookdb/replicator/icalendar_calendar_v1.rb', line 160

def prepare_body(body)
  body["calendar_external_id"] = @calendar_external_id
  body["row_updated_at"] = @now
end

#upsert_page_size ⇒ Object 



157
 
# File 'lib/webhookdb/replicator/icalendar_calendar_v1.rb', line 157

def upsert_page_size = 500