Contents

# frozen_string_literal: true

module Eventsimple
  module Outbox
    class Cursor < Eventsimple.configuration.parent_record_klass
      self.table_name = 'eventsimple_outbox_cursors'

      def self.fetch(event_klass, group_number)
        existing = find_by(event_klass: event_klass.to_s, group_number: group_number)
        existing ? existing.cursor : 0
      end

      def self.set(event_klass, group_number, cursor)
        upsert(
          {
            event_klass: event_klass.to_s,
            group_number: group_number,
            cursor: cursor,
          },
          unique_by: [:event_klass, :group_number],
        )
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
eventsimple-1.3.3	lib/eventsimple/outbox/models/cursor.rb