Merge pull request #11 from 8thlight/add_postgraphile_subscription

Add Postgraphile subscription exposure for price feed

db/migrations/20180911215603_add_price_feed_trigger.down.sql

@@ -0,0 +1 @@
+DROP TRIGGER notify_pricefeeds ON maker.price_feeds;

db/migrations/20180911215603_add_price_feed_trigger.up.sql

@@ -0,0 +1,13 @@
+CREATE OR REPLACE FUNCTION notify_pricefeed() RETURNS trigger AS $$
+BEGIN
+  PERFORM pg_notify(
+    CAST('postgraphile:price_feed' AS text),
+    row_to_json(NEW)::text);
+  RETURN NEW;
+END;
+$$ LANGUAGE plpgsql;
+
+CREATE TRIGGER notify_pricefeeds
+  AFTER INSERT ON maker.price_feeds
+  FOR EACH ROW
+  EXECUTE PROCEDURE notify_pricefeed();

db/schema.sql

@@ -36,6 +36,22 @@ CREATE EXTENSION IF NOT EXISTS plpgsql WITH SCHEMA pg_catalog;
 COMMENT ON EXTENSION plpgsql IS 'PL/pgSQL procedural language';
 
 
+--
+-- Name: notify_pricefeed(); Type: FUNCTION; Schema: public; Owner: -
+--
+
+CREATE FUNCTION public.notify_pricefeed() RETURNS trigger
+    LANGUAGE plpgsql
+    AS $$
+BEGIN
+  PERFORM pg_notify(
+    CAST('postgraphile:price_feed' AS text),
+    row_to_json(NEW)::text);
+  RETURN NEW;
+END;
+$$;
+
+
 SET default_tablespace = '';
 
 SET default_with_oids = false;
@@ -1482,6 +1498,13 @@ CREATE INDEX tx_from_index ON public.transactions USING btree (tx_from);
 CREATE INDEX tx_to_index ON public.transactions USING btree (tx_to);
 
 
+--
+-- Name: price_feeds notify_pricefeeds; Type: TRIGGER; Schema: maker; Owner: -
+--
+
+CREATE TRIGGER notify_pricefeeds AFTER INSERT ON maker.price_feeds FOR EACH ROW EXECUTE PROCEDURE public.notify_pricefeed();
+
+
 --
 -- Name: bite bite_header_id_fkey; Type: FK CONSTRAINT; Schema: maker; Owner: -
 --