houdini/spec/migration/delete_custom_field_join_spec.rb

# frozen_string_literal: true

# License: AGPL-3.0-or-later WITH WTO-AP-3.0-or-later
# Full license explanation at https://github.com/houdiniproject/houdini/blob/master/LICENSE
require 'rspec'
require 'rails_helper'

describe 'DeleteCustomFieldJoin' do
  it 'copying should be safe and reverable' do
    skip 'this code is only valuable if you are on migration "20170805180556_add_the_tag_joins_backup_table.rb" but before "20170805180557_add_index_for_tag_joins_and_add_constraint.rb"'
    build(:custom_field_join, supporter_id: 100, custom_field_master_id: 200).save(validate: false)

    last_times_for_supporter_ids = {}
    3.times do |j|
      j += 1
      5.times do |i|
        i += 1
        time = DateTime.now.advance(seconds: -j * i)
        last_times_for_supporter_ids[i] = time if j == 1
        build(:custom_field_join, supporter_id: i, custom_field_master_id: i + 1, updated_at: time).save(validate: false)
      end
    end

    expect(CustomFieldJoin.count).to eq(16)

    qx_results = Qx.select("CONCAT(custom_field_joins.supporter_id, '_', custom_field_joins.custom_field_master_id) AS our_concat, COUNT(id) AS our_count")
                   .from(:custom_field_joins)
                   .group_by('our_concat')
                   .having('COUNT(id) > 1')
                   .execute

    expect(qx_results.count).to eq(5)

    tag_joins_from_qx = CustomFieldJoin.where("CONCAT(supporter_id, '_', custom_field_master_id) IN (?)", qx_results.map { |i| i['our_concat'] })

    expect(tag_joins_from_qx.count).to eq(15)

    expect(tag_joins_from_qx.count).to eq(qx_results.sum { |r| r['our_count'] })

    tag_join_groups = CustomFieldJoin.all.to_a.group_by { |tj| "#{tj.supporter_id}_#{tj.custom_field_master_id}" }.select { |_k, v| v.count > 1 }.to_a

    expect(qx_results.count).to eq(tag_join_groups.length)

    expect(tag_join_groups.sum { |_, v| v.count }).to eq(qx_results.sum { |r| r['our_count'] })

    grouped_tagged_joins = tag_joins_from_qx.group_by { |tj| "#{tj.supporter_id}_#{tj.custom_field_master_id}" }

    ids_to_delete = DeleteCustomFieldJoins.find_multiple_custom_field_joins
    our_test_cfj = CustomFieldJoin.find(ids_to_delete)
    DeleteCustomFieldJoins.copy_and_delete(ids_to_delete)

    expect(CustomFieldJoin.count).to eq(6)

    last_times_for_supporter_ids.each do |k, v|
      results = CustomFieldJoin.where('supporter_id = ? and custom_field_master_id = ?', k, k + 1)
      expect(results.count).to eq(1)

      expect(results.first.updated_at).to eq(v)
    end

    expect(CustomFieldJoin.where('supporter_id = ? and custom_field_master_id = ?', 100, 200).count).to eq 1

    5.times do |i|
      i += 1

      expect(CustomFieldJoin.where('supporter_id = ? and custom_field_master_id =? ', i, i + 1).count).to eq 1
    end

    expect(Qx.select('COUNT(id)').from(:custom_field_joins_backup).execute[0]['count']).to eq ids_to_delete.count

    expect(Qx.select('COUNT(id)').from(:custom_field_joins_backup).where('id NOT IN ($ids)', ids: ids_to_delete).execute[0]['count']).to eq(0)

    expect(Qx.select('COUNT(id)').from(:custom_field_joins_backup).where('id IN ($ids)', ids: ids_to_delete).execute[0]['count']).to eq(ids_to_delete.count)

    expect(Qx.select('*').from(:custom_field_joins_backup).where('id IN ($id)', id: ids_to_delete).execute).to match_array(our_test_cfj.map(&:attributes))

    DeleteCustomFieldJoins.revert
    expect(Qx.select('COUNT(id)').from(:custom_field_joins_backup).execute[0]['count']).to eq 0
    expect(CustomFieldJoin.count).to eq(16)
    expect(CustomFieldJoin.find(ids_to_delete)).to match_array(our_test_cfj)
  end
end