core/gap-detector/new-block-trigger-function.sql at master · spec-dev/core · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
-- ETHEREUM --------

CREATE OR REPLACE FUNCTION new_ethereum_block_sub() RETURNS trigger AS $$
DECLARE
    rec RECORD;
    payload TEXT;
BEGIN
    rec := NEW;
    payload := '{"number":"' || rec.number || '"}';
    PERFORM pg_notify('new_block_chain_1', payload);
    RETURN rec;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER on_new_ethereum_block AFTER INSERT ON ethereum.blocks
FOR EACH ROW EXECUTE PROCEDURE new_ethereum_block_sub();

-- GOERLI --------

CREATE OR REPLACE FUNCTION new_goerli_block_sub() RETURNS trigger AS $$
DECLARE
    rec RECORD;
    payload TEXT;
BEGIN
    rec := NEW;
    payload := '{"number":"' || rec.number || '"}';
    PERFORM pg_notify('new_block_chain_5', payload);
    RETURN rec;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER on_new_goerli_block AFTER INSERT ON goerli.blocks
FOR EACH ROW EXECUTE PROCEDURE new_goerli_block_sub();

-- POLYGON --------

CREATE OR REPLACE FUNCTION new_polygon_block_sub() RETURNS trigger AS $$
DECLARE
    rec RECORD;
    payload TEXT;
BEGIN
    rec := NEW;
    payload := '{"number":"' || rec.number || '"}';
    PERFORM pg_notify('new_block_chain_137', payload);
    RETURN rec;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER on_new_polygon_block AFTER INSERT ON polygon.blocks
FOR EACH ROW EXECUTE PROCEDURE new_polygon_block_sub();

-- MUMBAI --------

CREATE OR REPLACE FUNCTION new_mumbai_block_sub() RETURNS trigger AS $$
DECLARE
    rec RECORD;
    payload TEXT;
BEGIN
    rec := NEW;
    payload := '{"number":"' || rec.number || '"}';
    PERFORM pg_notify('new_block_chain_80001', payload);
    RETURN rec;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER on_new_mumbai_block AFTER INSERT ON mumbai.blocks
FOR EACH ROW EXECUTE PROCEDURE new_mumbai_block_sub();

-- BASE --------

CREATE OR REPLACE FUNCTION new_base_block_sub() RETURNS trigger AS $$
DECLARE
    rec RECORD;
    payload TEXT;
BEGIN
    rec := NEW;
    payload := '{"number":"' || rec.number || '"}';
    PERFORM pg_notify('new_block_chain_8453', payload);
    RETURN rec;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER on_new_base_block AFTER INSERT ON base.blocks
FOR EACH ROW EXECUTE PROCEDURE new_base_block_sub();