fedi/lemmy
1
0
Fork 0
mirror of https://github.com/LemmyNet/lemmy.git synced 2024-12-13 22:22:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'combined_profile' into combined_modlog

Browse source
This commit is contained in:
Dessalines 2024-12-09 08:25:09 -05:00
parent 5c2205ae8b 63b7f726cb
commit 6363e7d5db
1 changed files with 43 additions and 67 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

74
crates/db_schema/replaceable_schema/triggers.sql
View file

@ -714,74 +714,50 @@ CALL r.create_person_content_combined_trigger ('post');
CALL r.create_person_content_combined_trigger ('comment'); CALL r.create_person_content_combined_trigger ('comment');
-- person_saved (comment, post) -- person_saved (comment, post)
-- TODO, not sure how to handle changes to post_actions and comment_actions.saved column using @dullbanana's trigger method. -- This one is a little different, because it triggers using x_actions.saved,
-- Post -- Rather than any row insert
CREATE FUNCTION r.person_saved_combined_change_values_post () CREATE PROCEDURE r.create_person_saved_combined_trigger (table_name text)
LANGUAGE plpgsql
AS $a$
BEGIN
EXECUTE replace($b$ CREATE FUNCTION r.person_saved_combined_change_values_thing ( )
RETURNS TRIGGER RETURNS TRIGGER
LANGUAGE plpgsql LANGUAGE plpgsql
AS $$ AS $$
BEGIN BEGIN
IF (TG_OP = 'DELETE') THEN IF (TG_OP = 'DELETE') THEN
DELETE FROM person_saved_combined AS p DELETE FROM person_saved_combined AS p
WHERE p.person_id = OLD.person_id WHERE p.person_id = OLD.person_id
AND p.post_id = OLD.post_id; AND p.thing_id = OLD.thing_id;
ELSIF (TG_OP = 'INSERT') THEN ELSIF (TG_OP = 'INSERT') THEN
IF NEW.saved IS NOT NULL THEN IF NEW.saved IS NOT NULL THEN
INSERT INTO person_saved_combined (published, person_id, post_id) INSERT INTO person_saved_combined (published, person_id, thing_id)
VALUES (NEW.saved, NEW.person_id, NEW.post_id); VALUES (NEW.saved, NEW.person_id, NEW.thing_id);
END IF; END IF;
ELSIF (TG_OP = 'UPDATE') THEN ELSIF (TG_OP = 'UPDATE') THEN
IF NEW.saved IS NOT NULL THEN IF NEW.saved IS NOT NULL THEN
INSERT INTO person_saved_combined (published, person_id, post_id) INSERT INTO person_saved_combined (published, person_id, thing_id)
VALUES (NEW.saved, NEW.person_id, NEW.post_id); VALUES (NEW.saved, NEW.person_id, NEW.thing_id);
-- If saved gets set as null, delete the row -- If saved gets set as null, delete the row
ELSE ELSE
DELETE FROM person_saved_combined AS p DELETE FROM person_saved_combined AS p
WHERE p.person_id = NEW.person_id WHERE p.person_id = NEW.person_id
AND p.post_id = NEW.post_id; AND p.thing_id = NEW.thing_id;
END IF; END IF;
END IF; END IF;
RETURN NULL; RETURN NULL;
END END $$;
$$; CREATE TRIGGER person_saved_combined
AFTER INSERT OR DELETE OR UPDATE OF saved ON thing_actions
CREATE TRIGGER person_saved_combined_post
AFTER INSERT OR DELETE OR UPDATE OF saved ON post_actions
FOR EACH ROW FOR EACH ROW
EXECUTE FUNCTION r.person_saved_combined_change_values_post (); EXECUTE FUNCTION r.person_saved_combined_change_values_thing ( );
$b$,
'thing',
table_name);
END;
$a$;
-- Comment CALL r.create_person_saved_combined_trigger ('post');
CREATE FUNCTION r.person_saved_combined_change_values_comment ()
RETURNS TRIGGER
LANGUAGE plpgsql
AS $$
BEGIN
IF (TG_OP = 'DELETE') THEN
DELETE FROM person_saved_combined AS p
WHERE p.person_id = OLD.person_id
AND p.comment_id = OLD.comment_id;
ELSIF (TG_OP = 'INSERT') THEN
IF NEW.saved IS NOT NULL THEN
INSERT INTO person_saved_combined (published, person_id, comment_id)
VALUES (NEW.saved, NEW.person_id, NEW.comment_id);
END IF;
ELSIF (TG_OP = 'UPDATE') THEN
IF NEW.saved IS NOT NULL THEN
INSERT INTO person_saved_combined (published, person_id, comment_id)
VALUES (NEW.saved, NEW.person_id, NEW.comment_id);
-- If saved gets set as null, delete the row
ELSE
DELETE FROM person_saved_combined AS p
WHERE p.person_id = NEW.person_id
AND p.comment_id = NEW.comment_id;
END IF;
END IF;
RETURN NULL;
END
$$;
CREATE TRIGGER person_saved_combined_comment CALL r.create_person_saved_combined_trigger ('comment');
AFTER INSERT OR DELETE OR UPDATE OF saved ON comment_actions
FOR EACH ROW
EXECUTE FUNCTION r.person_saved_combined_change_values_comment ();