1 files changed, 36 insertions, 0 deletions
diff --git a/db/migrate/20221030193943_cleanup_duplicate_pods.rb b/db/migrate/20221030193943_cleanup_duplicate_pods.rb
new file mode 100644
index 000000000..fe1bc5fa2
--- /dev/null
+++ b/db/migrate/20221030193943_cleanup_duplicate_pods.rb
@@ -0,0 +1,36 @@
+# frozen_string_literal: true
+
+class CleanupDuplicatePods < ActiveRecord::Migration[6.1]
+  class Pod < ApplicationRecord
+  end
+
+  def change
+    reversible do |change|
+      change.up do
+        remove_duplicates
+
+        Pod.where(port: nil).update_all(port: -1) # rubocop:disable Rails/SkipsModelValidations
+      end
+
+      change.down do
+        Pod.where(port: -1).update_all(port: nil) # rubocop:disable Rails/SkipsModelValidations
+      end
+    end
+
+    change_column_null :pods, :port, false
+  end
+
+  private
+
+  def remove_duplicates
+    Pod.where(port: nil).group(:host).having("count(*) > 1").pluck(:host).each do |host|
+      duplicate_ids = Pod.where(host: host).order(:id).ids
+      target_pod_id = duplicate_ids.shift
+
+      duplicate_ids.each do |pod_id|
+        Person.where(pod_id: pod_id).update_all(pod_id: target_pod_id) # rubocop:disable Rails/SkipsModelValidations
+        Pod.delete(pod_id)
+      end
+    end
+  end
+end