process raw_store_events records automatically via triggers

database_migrations/000002_processed_tables.down.sql

@@ -1,3 +1,7 @@
+BEGIN;
+
 DROP TABLE tiktok_store_events;
 DROP TABLE etsy_store_events;
 DROP TABLE wix_store_events;
+
+COMMIT;

database_migrations/000002_processed_tables.up.sql

@@ -1,3 +1,5 @@
+BEGIN;
+
 CREATE TABLE tiktok_store_events (
 	platform			TEXT 			NOT NULL DEFAULT 'tiktok' CHECK (platform = 'tiktok'),
 	store_id			TEXT 			NOT NULL,
@@ -27,3 +29,5 @@ CREATE TABLE wix_store_events (
 	PRIMARY KEY (store_id, event_id, event_timestamp),
 	FOREIGN KEY (platform, store_id, event_id, event_timestamp) REFERENCES raw_store_events
 );
+
+COMMIT;

database_migrations/000003_process_raw_events_tiktok.down.sql

@@ -0,0 +1,10 @@
+BEGIN;
+
+
+DROP TRIGGER tiktok_store_events;
+
+DROP FUNCTION process_raw_tiktok_event;
+
+
+COMMIT;
+

database_migrations/000003_process_raw_events_tiktok.up.sql

@@ -0,0 +1,28 @@
+BEGIN;
+
+
+CREATE OR REPLACE FUNCTION process_raw_tiktok_event() RETURNS TRIGGER AS $process_raw_tiktok_event$
+	BEGIN
+		INSERT INTO tiktok_store_events (
+			platform,
+			store_id,
+			event_timestamp,
+			event_id
+		)
+		SELECT
+			NEW.platform,
+			NEW.store_id,
+			NEW.event_timestamp,
+			NEW.event_id;
+		RETURN NULL;
+	END;
+$process_raw_tiktok_event$ LANGUAGE plpgsql;
+
+CREATE OR REPLACE TRIGGER tiktok_store_events
+	AFTER INSERT ON raw_store_events
+	FOR EACH ROW
+	WHEN (NEW.platform = 'tiktok')
+	EXECUTE FUNCTION process_raw_tiktok_event();
+
+
+COMMIT;

database_migrations/000004_drop_parsed_column.up.sql

@@ -0,0 +1 @@
+ALTER TABLE raw_store_events DROP COLUMN IF EXISTS parsed;

database_migrations/000005_process_raw_events_etsy.down.sql

@@ -0,0 +1,9 @@
+BEGIN;
+
+
+DROP TRIGGER etsy_store_events;
+
+DROP FUNCTION process_raw_etsy_event;
+
+
+COMMIT;

database_migrations/000005_process_raw_events_etsy.up.sql

@@ -0,0 +1,29 @@
+BEGIN;
+
+
+CREATE OR REPLACE FUNCTION process_raw_etsy_event() RETURNS TRIGGER AS $process_raw_etsy_event$
+	BEGIN
+		INSERT INTO etsy_store_events (
+			platform,
+			store_id,
+			event_timestamp,
+			event_id
+		)
+		SELECT
+			NEW.platform,
+			NEW.store_id,
+			NEW.event_timestamp,
+			NEW.event_id;
+		RETURN NULL;
+	END;
+$process_raw_etsy_event$ LANGUAGE plpgsql;
+
+CREATE OR REPLACE TRIGGER etsy_store_events
+	AFTER INSERT ON raw_store_events
+	FOR EACH ROW
+	WHEN (NEW.platform = 'etsy')
+	EXECUTE FUNCTION process_raw_etsy_event();
+
+
+COMMIT;
+

database_migrations/000006_process_raw_events_wix.down.sql

@@ -0,0 +1,9 @@
+BEGIN;
+
+
+DROP TRIGGER wix_store_events;
+
+DROP FUNCTION process_raw_wix_event;
+
+
+COMMIT;

database_migrations/000006_process_raw_events_wix.up.sql

@@ -0,0 +1,29 @@
+BEGIN;
+
+
+CREATE OR REPLACE FUNCTION process_raw_wix_event() RETURNS TRIGGER AS $process_raw_wix_event$
+	BEGIN
+		INSERT INTO wix_store_events (
+			platform,
+			store_id,
+			event_timestamp,
+			event_id
+		)
+		SELECT
+			NEW.platform,
+			NEW.store_id,
+			NEW.event_timestamp,
+			NEW.event_id;
+		RETURN NULL;
+	END;
+$process_raw_wix_event$ LANGUAGE plpgsql;
+
+CREATE OR REPLACE TRIGGER wix_store_events
+	AFTER INSERT ON raw_store_events
+	FOR EACH ROW
+	WHEN (NEW.platform = 'wix')
+	EXECUTE FUNCTION process_raw_wix_event();
+
+
+COMMIT;
+