spec/lib/click_house/record_sync_context_spec.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

# frozen_string_literal: true

require 'spec_helper'

RSpec.describe ClickHouse::RecordSyncContext, feature_category: :value_stream_management do
  let(:records) { [Issue.new(id: 1), Issue.new(id: 2), Issue.new(id: 3), Issue.new(id: 4)] }

  subject(:sync_context) { described_class.new(last_record_id: 0, max_records_per_batch: 3) }

  it 'allows processing 3 records per batch' do
    records.take(3).each do |record|
      sync_context.last_processed_id = record.id
    end

    expect(sync_context).to be_record_limit_reached
    expect(sync_context.last_processed_id).to eq(3)

    expect { sync_context.new_batch! }.to change { sync_context.record_count_in_current_batch }.from(3).to(0)

    expect(sync_context).not_to be_record_limit_reached

    records.take(3).each do |record|
      sync_context.last_processed_id = record.id
    end

    expect(sync_context).to be_record_limit_reached
  end

  it 'sets the no more records flag' do
    expect { sync_context.no_more_records! }.to change { sync_context.no_more_records? }.from(false).to(true)
  end
end