From 89deb74c24615700a2a2066303177ad16e75eb3d Mon Sep 17 00:00:00 2001
From: Shivam Mishra <scm.mymail@gmail.com>
Date: Tue, 25 Mar 2025 18:34:30 +0530
Subject: [PATCH] feat: add new indexes

---
 ...50325125320_update_indexes_for_contacts.rb | 51 +++++++++++++++++++
 1 file changed, 51 insertions(+)
 create mode 100644 db/migrate/20250325125320_update_indexes_for_contacts.rb

diff --git a/db/migrate/20250325125320_update_indexes_for_contacts.rb b/db/migrate/20250325125320_update_indexes_for_contacts.rb
new file mode 100644
index 000000000..8af1ec345
--- /dev/null
+++ b/db/migrate/20250325125320_update_indexes_for_contacts.rb
@@ -0,0 +1,51 @@
+class UpdateIndexesForContacts < ActiveRecord::Migration[7.0]
+  disable_ddl_transaction!
+
+  def up
+    add_searchable_index
+    remove_old_index
+    add_activity_index
+  end
+
+  def down
+    remove_index :contacts, name: 'index_contacts_searchable_fields_gin', if_exists: true
+    remove_index :contacts, name: 'index_resolved_contacts_on_account_and_last_activity', if_exists: true
+
+    add_index :contacts,
+              [:account_id, :last_activity_at],
+              order: { last_activity_at: 'DESC NULLS LAST' },
+              algorithm: :concurrently,
+              name: 'index_contacts_on_account_id_and_last_activity_at'
+  end
+
+  private
+
+  def add_searchable_index
+    add_index :contacts,
+              [:name, :email, :phone_number, :identifier, "(additional_attributes->>'company_name')"],
+              name: 'index_contacts_searchable_fields_gin',
+              using: :gin,
+              opclass: {
+                name: :gin_trgm_ops,
+                email: :gin_trgm_ops,
+                phone_number: :gin_trgm_ops,
+                identifier: :gin_trgm_ops,
+                "(additional_attributes->>'company_name')": :gin_trgm_ops
+              },
+              where: "(email <> '' OR phone_number <> '' OR identifier <> '')",
+              algorithm: :concurrently
+  end
+
+  def remove_old_index
+    remove_index :contacts, name: 'index_contacts_on_account_id_and_last_activity_at', if_exists: true
+  end
+
+  def add_activity_index
+    add_index :contacts,
+              [:account_id, :last_activity_at],
+              name: 'index_resolved_contacts_on_account_and_last_activity',
+              where: "(email <> '' OR phone_number <> '' OR identifier <> '')",
+              order: { last_activity_at: 'DESC NULLS LAST' },
+              algorithm: :concurrently
+  end
+end