266 lines
9.1 KiB
PL/PgSQL
266 lines
9.1 KiB
PL/PgSQL
-- This script manages user karma based on comment interactions. It handles karma points
|
|
-- for comment approvals, verifications, spam status changes, and votes (upvotes/downvotes).
|
|
-- Karma transactions are recorded, and user karma totals are updated accordingly.
|
|
|
|
-- Drop existing triggers first
|
|
DROP TRIGGER IF EXISTS comment_status_change_trigger ON "Comment";
|
|
DROP TRIGGER IF EXISTS comment_suspicious_change_trigger ON "Comment";
|
|
DROP TRIGGER IF EXISTS comment_upvote_change_trigger ON "Comment";
|
|
DROP TRIGGER IF EXISTS comment_vote_change_trigger ON "CommentVote";
|
|
DROP TRIGGER IF EXISTS suggestion_status_change_trigger ON "ServiceSuggestion";
|
|
|
|
-- Drop existing functions
|
|
DROP FUNCTION IF EXISTS handle_comment_upvote_change();
|
|
DROP FUNCTION IF EXISTS handle_comment_status_change();
|
|
DROP FUNCTION IF EXISTS handle_comment_approval();
|
|
DROP FUNCTION IF EXISTS handle_comment_verification();
|
|
DROP FUNCTION IF EXISTS handle_comment_spam_status();
|
|
DROP FUNCTION IF EXISTS handle_comment_vote_change();
|
|
DROP FUNCTION IF EXISTS insert_karma_transaction();
|
|
DROP FUNCTION IF EXISTS update_user_karma();
|
|
DROP FUNCTION IF EXISTS handle_suggestion_status_change();
|
|
|
|
-- Helper function to insert karma transaction
|
|
CREATE OR REPLACE FUNCTION insert_karma_transaction(
|
|
p_user_id INT,
|
|
p_points INT,
|
|
p_action TEXT,
|
|
p_comment_id INT,
|
|
p_description TEXT,
|
|
p_suggestion_id INT DEFAULT NULL
|
|
) RETURNS VOID AS $$
|
|
BEGIN
|
|
INSERT INTO "KarmaTransaction" (
|
|
"userId", "points", "action", "commentId",
|
|
"suggestionId",
|
|
"description", "processed", "createdAt"
|
|
)
|
|
VALUES (
|
|
p_user_id, p_points, p_action, p_comment_id,
|
|
p_suggestion_id,
|
|
p_description, true, NOW()
|
|
);
|
|
END;
|
|
$$ LANGUAGE plpgsql;
|
|
|
|
-- Helper function to update user karma
|
|
CREATE OR REPLACE FUNCTION update_user_karma(
|
|
p_user_id INT,
|
|
p_karma_change INT
|
|
) RETURNS VOID AS $$
|
|
BEGIN
|
|
UPDATE "User"
|
|
SET "totalKarma" = "totalKarma" + p_karma_change
|
|
WHERE id = p_user_id;
|
|
END;
|
|
$$ LANGUAGE plpgsql;
|
|
|
|
-- Handle comment approval
|
|
CREATE OR REPLACE FUNCTION handle_comment_approval(
|
|
NEW RECORD,
|
|
OLD RECORD
|
|
) RETURNS VOID AS $$
|
|
BEGIN
|
|
IF OLD.status = 'PENDING' AND NEW.status = 'APPROVED' THEN
|
|
PERFORM insert_karma_transaction(
|
|
NEW."authorId",
|
|
1,
|
|
'comment_approved',
|
|
NEW.id,
|
|
format('Your comment #comment-%s in %s has been approved!',
|
|
NEW.id,
|
|
(SELECT name FROM "Service" WHERE id = NEW."serviceId"))
|
|
);
|
|
PERFORM update_user_karma(NEW."authorId", 1);
|
|
END IF;
|
|
END;
|
|
$$ LANGUAGE plpgsql;
|
|
|
|
-- Handle comment verification
|
|
CREATE OR REPLACE FUNCTION handle_comment_verification(
|
|
NEW RECORD,
|
|
OLD RECORD
|
|
) RETURNS VOID AS $$
|
|
BEGIN
|
|
IF NEW.status = 'VERIFIED' AND OLD.status != 'VERIFIED' THEN
|
|
PERFORM insert_karma_transaction(
|
|
NEW."authorId",
|
|
5,
|
|
'comment_verified',
|
|
NEW.id,
|
|
format('Your comment #comment-%s in %s has been verified!',
|
|
NEW.id,
|
|
(SELECT name FROM "Service" WHERE id = NEW."serviceId"))
|
|
);
|
|
PERFORM update_user_karma(NEW."authorId", 5);
|
|
END IF;
|
|
END;
|
|
$$ LANGUAGE plpgsql;
|
|
|
|
-- Handle spam status changes
|
|
CREATE OR REPLACE FUNCTION handle_comment_spam_status(
|
|
NEW RECORD,
|
|
OLD RECORD
|
|
) RETURNS VOID AS $$
|
|
BEGIN
|
|
-- Handle marking as spam
|
|
IF NEW.suspicious = true AND OLD.suspicious = false THEN
|
|
PERFORM insert_karma_transaction(
|
|
NEW."authorId",
|
|
-10,
|
|
'comment_spam',
|
|
NEW.id,
|
|
format('Your comment #comment-%s in %s has been marked as spam.',
|
|
NEW.id,
|
|
(SELECT name FROM "Service" WHERE id = NEW."serviceId"))
|
|
);
|
|
PERFORM update_user_karma(NEW."authorId", -10);
|
|
-- Handle unmarking as spam
|
|
ELSIF NEW.suspicious = false AND OLD.suspicious = true THEN
|
|
PERFORM insert_karma_transaction(
|
|
NEW."authorId",
|
|
10,
|
|
'comment_spam_reverted',
|
|
NEW.id,
|
|
format('Your comment #comment-%s in %s is no longer marked as spam.',
|
|
NEW.id,
|
|
(SELECT name FROM "Service" WHERE id = NEW."serviceId"))
|
|
);
|
|
PERFORM update_user_karma(NEW."authorId", 10);
|
|
END IF;
|
|
END;
|
|
$$ LANGUAGE plpgsql;
|
|
|
|
-- Function for handling vote changes
|
|
CREATE OR REPLACE FUNCTION handle_comment_vote_change()
|
|
RETURNS TRIGGER AS $$
|
|
DECLARE
|
|
karma_points INT;
|
|
vote_action TEXT;
|
|
vote_description TEXT;
|
|
comment_author_id INT;
|
|
service_name TEXT;
|
|
upvote_change INT := 0; -- Variable to track change in upvotes
|
|
BEGIN
|
|
-- Get comment author and service info
|
|
SELECT c."authorId", s.name INTO comment_author_id, service_name
|
|
FROM "Comment" c
|
|
JOIN "Service" s ON c.id = COALESCE(NEW."commentId", OLD."commentId") AND c."serviceId" = s.id;
|
|
|
|
-- Calculate karma impact based on vote type
|
|
IF TG_OP = 'INSERT' THEN
|
|
-- New vote
|
|
karma_points := CASE WHEN NEW.downvote THEN -1 ELSE 1 END;
|
|
vote_action := CASE WHEN NEW.downvote THEN 'comment_downvote' ELSE 'comment_upvote' END;
|
|
vote_description := format('Your comment #comment-%s in %s received %s',
|
|
NEW."commentId",
|
|
service_name,
|
|
CASE WHEN NEW.downvote THEN 'a downvote' ELSE 'an upvote' END);
|
|
upvote_change := CASE WHEN NEW.downvote THEN -1 ELSE 1 END; -- -1 for downvote, +1 for upvote
|
|
ELSIF TG_OP = 'DELETE' THEN
|
|
-- Removed vote
|
|
karma_points := CASE WHEN OLD.downvote THEN 1 ELSE -1 END;
|
|
vote_action := 'comment_vote_removed';
|
|
vote_description := format('A vote was removed from your comment #comment-%s in %s',
|
|
OLD."commentId",
|
|
service_name);
|
|
upvote_change := CASE WHEN OLD.downvote THEN 1 ELSE -1 END; -- +1 if downvote removed, -1 if upvote removed
|
|
ELSIF TG_OP = 'UPDATE' THEN
|
|
-- Changed vote (from upvote to downvote or vice versa)
|
|
karma_points := CASE WHEN NEW.downvote THEN -2 ELSE 2 END;
|
|
vote_action := CASE WHEN NEW.downvote THEN 'comment_downvote' ELSE 'comment_upvote' END;
|
|
vote_description := format('Your comment #comment-%s in %s vote changed to %s',
|
|
NEW."commentId",
|
|
service_name,
|
|
CASE WHEN NEW.downvote THEN 'downvote' ELSE 'upvote' END);
|
|
upvote_change := CASE WHEN NEW.downvote THEN -2 ELSE 2 END; -- -2 if upvote->downvote, +2 if downvote->upvote
|
|
END IF;
|
|
|
|
-- Record karma transaction and update user karma
|
|
PERFORM insert_karma_transaction(
|
|
comment_author_id,
|
|
karma_points,
|
|
vote_action,
|
|
COALESCE(NEW."commentId", OLD."commentId"),
|
|
vote_description
|
|
);
|
|
|
|
PERFORM update_user_karma(comment_author_id, karma_points);
|
|
|
|
-- Update comment's upvotes count incrementally
|
|
UPDATE "Comment"
|
|
SET upvotes = upvotes + upvote_change
|
|
WHERE id = COALESCE(NEW."commentId", OLD."commentId");
|
|
|
|
RETURN NEW;
|
|
END;
|
|
$$ LANGUAGE plpgsql;
|
|
|
|
-- Main function for handling status changes
|
|
CREATE OR REPLACE FUNCTION handle_comment_status_change()
|
|
RETURNS TRIGGER AS $$
|
|
BEGIN
|
|
PERFORM handle_comment_approval(NEW, OLD);
|
|
PERFORM handle_comment_verification(NEW, OLD);
|
|
PERFORM handle_comment_spam_status(NEW, OLD);
|
|
RETURN NEW;
|
|
END;
|
|
$$ LANGUAGE plpgsql;
|
|
|
|
-- Create triggers
|
|
CREATE TRIGGER comment_status_change_trigger
|
|
AFTER UPDATE OF status
|
|
ON "Comment"
|
|
FOR EACH ROW
|
|
EXECUTE FUNCTION handle_comment_status_change();
|
|
|
|
CREATE TRIGGER comment_suspicious_change_trigger
|
|
AFTER UPDATE OF suspicious
|
|
ON "Comment"
|
|
FOR EACH ROW
|
|
EXECUTE FUNCTION handle_comment_status_change();
|
|
|
|
CREATE TRIGGER comment_vote_change_trigger
|
|
AFTER INSERT OR UPDATE OR DELETE
|
|
ON "CommentVote"
|
|
FOR EACH ROW
|
|
EXECUTE FUNCTION handle_comment_vote_change();
|
|
|
|
-- Function to handle suggestion status changes and award karma
|
|
CREATE OR REPLACE FUNCTION handle_suggestion_status_change()
|
|
RETURNS TRIGGER AS $$
|
|
DECLARE
|
|
service_name TEXT;
|
|
BEGIN
|
|
-- Award karma for first approval
|
|
-- Check that OLD.status is not NULL to handle the initial creation case if needed,
|
|
-- and ensure it wasn't already APPROVED.
|
|
IF OLD.status IS DISTINCT FROM 'APPROVED' AND NEW.status = 'APPROVED' THEN
|
|
-- Fetch service name for the description
|
|
SELECT name INTO service_name FROM "Service" WHERE id = NEW."serviceId";
|
|
|
|
-- Insert karma transaction, linking it to the suggestion
|
|
PERFORM insert_karma_transaction(
|
|
NEW."userId",
|
|
10,
|
|
'suggestion_approved',
|
|
NULL, -- p_comment_id (not applicable)
|
|
format('Your suggestion for service ''%s'' has been approved!', service_name),
|
|
NEW.id -- p_suggestion_id
|
|
);
|
|
|
|
-- Update user's total karma
|
|
PERFORM update_user_karma(NEW."userId", 10);
|
|
END IF;
|
|
|
|
RETURN NEW; -- Result is ignored since this is an AFTER trigger
|
|
END;
|
|
$$ LANGUAGE plpgsql;
|
|
|
|
-- Create triggers
|
|
CREATE TRIGGER suggestion_status_change_trigger
|
|
AFTER UPDATE OF status
|
|
ON "ServiceSuggestion"
|
|
FOR EACH ROW
|
|
EXECUTE FUNCTION handle_suggestion_status_change();
|