Merge branch 'omnivore-app:main' into main

packages/db/migrations/0153.do.library_item_user_id_saved_at_idx.sql

@@ -0,0 +1,6 @@
+-- Type: DO
+-- Name: library_item_user_id_saved_at_idx
+-- Description: Add library_item_user_id_saved_at_idx index on library_item table for user_id and saved_at
+
+-- create index for sorting concurrently to avoid locking
+CREATE INDEX CONCURRENTLY IF NOT EXISTS library_item_user_id_saved_at_idx ON omnivore.library_item (user_id, saved_at DESC NULLS LAST);

packages/db/migrations/0153.undo.library_item_user_id_saved_at_idx.sql

@@ -0,0 +1,9 @@
+-- Type: UNDO
+-- Name: library_item_user_id_saved_at_idx
+-- Description: Add library_item_user_id_saved_at_idx index on library_item table for user_id and saved_at
+
+BEGIN;
+
+DROP INDEX IF EXISTS omnivore.library_item_user_id_saved_at_idx;
+
+COMMIT;

packages/db/migrations/0154.do.library_item_user_id_updated_at_idx.sql

@@ -0,0 +1,6 @@
+-- Type: DO
+-- Name: library_item_user_id_updated_at_idx
+-- Description: Add library_item_user_id_saved_at_idx index on library_item table for user_id and updated_at
+
+-- create index for sorting concurrently to avoid locking
+CREATE INDEX CONCURRENTLY IF NOT EXISTS library_item_user_id_updated_at_idx ON omnivore.library_item (user_id, updated_at DESC NULLS LAST);

packages/db/migrations/0154.undo.library_item_user_id_updated_at_idx.sql

@@ -0,0 +1,9 @@
+-- Type: UNDO
+-- Name: library_item_user_id_updated_at_idx
+-- Description: Add library_item_user_id_saved_at_idx index on library_item table for user_id and updated_at
+
+BEGIN;
+
+DROP INDEX IF EXISTS library_item_user_id_updated_at_idx;
+
+COMMIT;

packages/db/migrations/0155.do.library_item_user_id_published_at_idx.sql

@@ -0,0 +1,6 @@
+-- Type: DO
+-- Name: library_item_user_id_published_at_idx
+-- Description: Add library_item_user_id_published_at_idx index on library_item table for user_id and published_at
+
+-- create index for sorting concurrently to avoid locking
+CREATE INDEX CONCURRENTLY IF NOT EXISTS library_item_user_id_published_at_idx ON omnivore.library_item (user_id, published_at DESC NULLS LAST);

packages/db/migrations/0155.undo.library_item_user_id_published_at_idx.sql

@@ -0,0 +1,9 @@
+-- Type: UNDO
+-- Name: library_item_user_id_published_at_idx
+-- Description: Add library_item_user_id_published_at_idx index on library_item table for user_id and published_at
+
+BEGIN;
+
+DROP INDEX IF EXISTS library_item_user_id_published_at_idx;
+
+COMMIT;

packages/db/migrations/0156.do.library_item_user_id_read_at_idx.sql

@@ -0,0 +1,6 @@
+-- Type: DO
+-- Name: library_item_user_id_read_at_idx
+-- Description: Add library_item_user_id_read_at_idx index on library_item table for user_id and read_at
+
+-- create index for sorting concurrently to avoid locking
+CREATE INDEX CONCURRENTLY IF NOT EXISTS library_item_user_id_read_at_idx ON omnivore.library_item (user_id, read_at DESC NULLS LAST);

packages/db/migrations/0156.undo.library_item_user_id_read_at_idx.sql

@@ -0,0 +1,9 @@
+-- Type: UNDO
+-- Name: library_item_user_id_read_at_idx
+-- Description: Add library_item_user_id_read_at_idx index on library_item table for user_id and read_at
+
+BEGIN;
+
+DROP INDEX IF EXISTS library_item_user_id_read_at_idx;
+
+COMMIT;

packages/db/migrations/0157.do.library_item_user_id_word_count_idx.sql

@@ -0,0 +1,6 @@
+-- Type: DO
+-- Name: library_item_user_id_word_count_idx
+-- Description: Add library_item_user_id_word_count_idx index on library_item table for user_id and word_count
+
+-- create index for sorting concurrently to avoid locking
+CREATE INDEX CONCURRENTLY IF NOT EXISTS library_item_user_id_word_count_idx ON omnivore.library_item (user_id, word_count DESC NULLS LAST);

packages/db/migrations/0157.undo.library_item_user_id_word_count_idx.sql

@@ -0,0 +1,9 @@
+-- Type: UNDO
+-- Name: library_item_user_id_word_count_idx
+-- Description: Add library_item_user_id_word_count_idx index on library_item table for user_id and word_count
+
+BEGIN;
+
+DROP INDEX IF EXISTS library_item_user_id_word_count_idx;
+
+COMMIT;

packages/db/migrations/0158.do.create_label_names_update_trigger.sql

@@ -0,0 +1,34 @@
+-- Type: DO
+-- Name: create_label_names_update_trigger
+-- Description: Create label_names_update trigger in library_item table
+
+BEGIN;
+
+CREATE OR REPLACE FUNCTION update_label_names()
+RETURNS TRIGGER AS $$
+BEGIN
+    UPDATE omnivore.library_item
+    SET label_names = array_replace(label_names, OLD.name, NEW.name)
+    WHERE user_id = OLD.user_id AND OLD.name = ANY(label_names);
+
+    RETURN NEW;
+END;
+$$ LANGUAGE plpgsql;
+
+-- triggers when label name is updated
+CREATE TRIGGER label_names_update
+AFTER UPDATE ON omnivore.labels
+FOR EACH ROW
+WHEN (OLD.name <> NEW.name)
+EXECUTE FUNCTION update_label_names();
+
+-- remove old trigger which is too slow
+DROP TRIGGER IF EXISTS entity_labels_update ON omnivore.labels;
+
+DROP FUNCTION IF EXISTS omnivore.update_entity_labels();
+
+DROP INDEX IF EXISTS omnivore.library_item_saved_at_idx;
+DROP INDEX IF EXISTS omnivore.library_item_updated_at_idx;
+DROP INDEX IF EXISTS omnivore.library_item_read_at_idx;;
+
+COMMIT;

packages/db/migrations/0158.undo.create_label_names_update_trigger.sql

@@ -0,0 +1,34 @@
+-- Type: UNDO
+-- Name: create_label_names_update_trigger
+-- Description: Create label_names_update trigger in library_item table
+
+BEGIN;
+
+CREATE INDEX IF NOT EXISTS library_item_saved_at_idx ON omnivore.library_item (saved_at);
+CREATE INDEX IF NOT EXISTS library_item_updated_at_idx ON omnivore.library_item (updated_at);
+CREATE INDEX IF NOT EXISTS library_item_read_at_idx ON omnivore.library_item (read_at);
+
+CREATE OR REPLACE FUNCTION update_entity_labels()
+RETURNS trigger AS $$
+BEGIN
+    -- update entity_labels table to trigger update on library_item table
+    UPDATE omnivore.entity_labels
+    SET label_id = NEW.id
+    WHERE label_id = OLD.id;
+
+    return NEW;
+END;
+$$ LANGUAGE plpgsql;
+
+-- triggers when label name is updated
+CREATE TRIGGER entity_labels_update
+AFTER UPDATE ON omnivore.labels
+FOR EACH ROW
+WHEN (OLD.name <> NEW.name)
+EXECUTE FUNCTION update_entity_labels();
+
+DROP TRIGGER IF EXISTS label_names_update ON omnivore.labels;
+
+DROP FUNCTION IF EXISTS omnivore.update_label_names();
+
+COMMIT;