require File.expand_path("../spec_helper", __dir__)

RSpec.describe SearchFlip::Bulk do
  describe "#bulk" do
    it "uses bulk mode" do
      product1, product2 = create_list(:product, 2)

      expect(ProductIndex.total_count).to eq(0)

      ProductIndex.bulk do |bulk|
        bulk.create product1.id, ProductIndex.serialize(product1)
        bulk.create product2.id, ProductIndex.serialize(product1)
      end

      expect(ProductIndex.total_count).to eq(2)

      ProductIndex.bulk do |bulk|
        bulk.delete product1.id
        bulk.delete product2.id
      end

      expect(ProductIndex.total_count).to eq(0)
    end

    it "accepts and passes options" do
      product1, product2 = create_list(:product, 2)

      ProductIndex.import [product1, product2]

      block = lambda do
        ProductIndex.bulk do |bulk|
          bulk.create product1.id, ProductIndex.serialize(product1)
          bulk.create product2.id, ProductIndex.serialize(product1)
        end
      end

      expect(&block).to raise_error(SearchFlip::Bulk::Error)

      ProductIndex.bulk(ignore_errors: [409]) do |bulk|
        bulk.create product1.id, ProductIndex.serialize(product1)
        bulk.create product2.id, ProductIndex.serialize(product1)
      end
    end

    it "accepts and passes item options" do
      product = create(:product)

      ProductIndex.bulk do |bulk|
        bulk.index product.id, ProductIndex.serialize(product), version: 1, version_type: "external_gt"
      end

      block = lambda do
        ProductIndex.bulk do |bulk|
          bulk.index product.id, ProductIndex.serialize(product), version: 1, version_type: "external_gt"
        end
      end

      expect(&block).to raise_error(SearchFlip::Bulk::Error)
    end

    it "uses the specified http_client" do
      product = create(:product)

      stub_request(:put, "#{ProductIndex.type_url}/_bulk")
        .with(headers: { "X-Header" => "Value" })
        .to_return(status: 500)

      block = lambda do
        ProductIndex.bulk http_client: ProductIndex.connection.http_client.headers("X-Header" => "Value") do |bulk|
          bulk.index product.id, ProductIndex.serialize(product)
        end
      end

      expect(&block).to raise_error(SearchFlip::ResponseError)
    end

    it "transmits up to bulk_max_mb only" do
      product = create(:product)

      allow(product).to receive(:description).and_return("x" * 1024 * 1024)

      ProductIndex.bulk bulk_max_mb: 10 do |bulk|
        allow(bulk).to receive(:upload).and_call_original

        20.times do
          bulk.index product.id, ProductIndex.serialize(product)
        end

        expect(bulk).to have_received(:upload).exactly(2).times
      end
    end

    it "uploads a last time if there is data left within the output buffer" do
      product = create(:product)

      allow(product).to receive(:description).and_return("x" * 1024 * 1024)

      bulk_upload = nil

      ProductIndex.bulk bulk_max_mb: 5.5 do |bulk|
        bulk_upload = bulk

        allow(bulk).to receive(:upload).and_call_original

        6.times do
          bulk.index product.id, ProductIndex.serialize(product)
        end
      end

      expect(bulk_upload).to have_received(:upload).exactly(2).times
    end
  end
end