From a916de776be4f49d633fb2b45638b05cb53201af Mon Sep 17 00:00:00 2001
From: Peter Keen <pk8@sanger.ac.uk>
Date: Wed, 20 Apr 2016 15:24:22 +0100
Subject: [PATCH] audit changes

---
 ddl/versions/117/audit-up.sql | 53 +++++++++++++++++++++++++++++++++++
 1 file changed, 53 insertions(+)

diff --git a/ddl/versions/117/audit-up.sql b/ddl/versions/117/audit-up.sql
index e69de29bb2..63e79236ff 100644
--- a/ddl/versions/117/audit-up.sql
+++ b/ddl/versions/117/audit-up.sql
@@ -0,0 +1,53 @@
+CREATE TABLE audit.priorities (
+audit_op CHAR(1) NOT NULL CHECK (audit_op IN ('D','I','U')),
+audit_user TEXT NOT NULL,
+audit_stamp TIMESTAMP NOT NULL,
+audit_txid INTEGER NOT NULL,
+id text
+);
+CREATE OR REPLACE FUNCTION public.process_priorities_audit()
+RETURNS TRIGGER AS $priorities_audit$
+    BEGIN
+        IF (TG_OP = 'DELETE') THEN
+           INSERT INTO audit.priorities SELECT 'D', user, now(), txid_current(), OLD.*;
+        ELSIF (TG_OP = 'UPDATE') THEN
+           INSERT INTO audit.priorities SELECT 'U', user, now(), txid_current(), NEW.*;
+        ELSIF (TG_OP = 'INSERT') THEN
+           INSERT INTO audit.priorities SELECT 'I', user, now(), txid_current(), NEW.*;
+        END IF;
+        RETURN NULL;
+    END;
+$priorities_audit$ LANGUAGE plpgsql;
+CREATE TRIGGER priorities_audit
+AFTER INSERT OR UPDATE OR DELETE ON public.priorities
+    FOR EACH ROW EXECUTE PROCEDURE public.process_priorities_audit();
+CREATE TABLE audit.messages (
+audit_op CHAR(1) NOT NULL CHECK (audit_op IN ('D','I','U')),
+audit_user TEXT NOT NULL,
+audit_stamp TIMESTAMP NOT NULL,
+audit_txid INTEGER NOT NULL,
+id integer,
+message text,
+created_date timestamp with time zone,
+expiry_date timestamp with time zone,
+priority text,
+wge boolean,
+lims boolean,
+htgt boolean
+);
+CREATE OR REPLACE FUNCTION public.process_messages_audit()
+RETURNS TRIGGER AS $messages_audit$
+    BEGIN
+        IF (TG_OP = 'DELETE') THEN
+           INSERT INTO audit.messages SELECT 'D', user, now(), txid_current(), OLD.*;
+        ELSIF (TG_OP = 'UPDATE') THEN
+           INSERT INTO audit.messages SELECT 'U', user, now(), txid_current(), NEW.*;
+        ELSIF (TG_OP = 'INSERT') THEN
+           INSERT INTO audit.messages SELECT 'I', user, now(), txid_current(), NEW.*;
+        END IF;
+        RETURN NULL;
+    END;
+$messages_audit$ LANGUAGE plpgsql;
+CREATE TRIGGER messages_audit
+AFTER INSERT OR UPDATE OR DELETE ON public.messages
+    FOR EACH ROW EXECUTE PROCEDURE public.process_messages_audit();