remove postgraphile trigger, it needs to be reworked after PK updates

This commit is contained in:
i-norden 2021-11-17 18:56:04 -06:00
parent 8e644ebdf4
commit 6105603585
11 changed files with 14 additions and 78 deletions

View File

@ -1,6 +1,6 @@
-- +goose Up -- +goose Up
CREATE TABLE eth.header_cids ( CREATE TABLE eth.header_cids (
block_hash VARCHAR(66) NOT NULL, block_hash VARCHAR(66) PRIMARY KEY,
block_number BIGINT NOT NULL, block_number BIGINT NOT NULL,
parent_hash VARCHAR(66) NOT NULL, parent_hash VARCHAR(66) NOT NULL,
cid TEXT NOT NULL, cid TEXT NOT NULL,

View File

@ -1,6 +1,6 @@
-- +goose Up -- +goose Up
CREATE TABLE eth.uncle_cids ( CREATE TABLE eth.uncle_cids (
block_hash VARCHAR(66) NOT NULL, block_hash VARCHAR(66) PRIMARY KEY,
header_id VARCHAR(66) NOT NULL, header_id VARCHAR(66) NOT NULL,
parent_hash VARCHAR(66) NOT NULL, parent_hash VARCHAR(66) NOT NULL,
cid TEXT NOT NULL, cid TEXT NOT NULL,

View File

@ -1,6 +1,6 @@
-- +goose Up -- +goose Up
CREATE TABLE eth.transaction_cids ( CREATE TABLE eth.transaction_cids (
tx_hash VARCHAR(66) NOT NULL, tx_hash VARCHAR(66) PRIMARY KEY,
header_id VARCHAR(66) NOT NULL, header_id VARCHAR(66) NOT NULL,
index INTEGER NOT NULL, index INTEGER NOT NULL,
cid TEXT NOT NULL, cid TEXT NOT NULL,

View File

@ -1,6 +1,6 @@
-- +goose Up -- +goose Up
CREATE TABLE eth.receipt_cids ( CREATE TABLE eth.receipt_cids (
tx_id VARCHAR(66) NOT NULL, tx_id VARCHAR(66) PRIMARY KEY,
leaf_cid TEXT NOT NULL, leaf_cid TEXT NOT NULL,
leaf_mh_key TEXT NOT NULL, leaf_mh_key TEXT NOT NULL,
contract VARCHAR(66), contract VARCHAR(66),

View File

@ -6,7 +6,8 @@ CREATE TABLE eth.state_cids (
mh_key TEXT NOT NULL, mh_key TEXT NOT NULL,
state_path BYTEA NOT NULL, state_path BYTEA NOT NULL,
node_type INTEGER NOT NULL, node_type INTEGER NOT NULL,
diff BOOLEAN NOT NULL DEFAULT FALSE diff BOOLEAN NOT NULL DEFAULT FALSE,
PRIMARY KEY (header_id, state_path)
); );
-- +goose Down -- +goose Down

View File

@ -7,7 +7,8 @@ CREATE TABLE eth.storage_cids (
mh_key TEXT NOT NULL, mh_key TEXT NOT NULL,
storage_path BYTEA NOT NULL, storage_path BYTEA NOT NULL,
node_type INTEGER NOT NULL, node_type INTEGER NOT NULL,
diff BOOLEAN NOT NULL DEFAULT FALSE diff BOOLEAN NOT NULL DEFAULT FALSE,
PRIMARY KEY (header_id, state_path, storage_path)
); );
-- +goose Down -- +goose Down

View File

@ -5,7 +5,8 @@ CREATE TABLE eth.state_accounts (
balance NUMERIC NOT NULL, balance NUMERIC NOT NULL,
nonce INTEGER NOT NULL, nonce INTEGER NOT NULL,
code_hash BYTEA NOT NULL, code_hash BYTEA NOT NULL,
storage_root VARCHAR(66) NOT NULL storage_root VARCHAR(66) NOT NULL,
PRIMARY KEY (header_id, state_path)
); );
-- +goose Down -- +goose Down

View File

@ -3,7 +3,8 @@ CREATE TABLE eth.access_list_element (
tx_id VARCHAR(66) NOT NULL, tx_id VARCHAR(66) NOT NULL,
index INTEGER NOT NULL, index INTEGER NOT NULL,
address VARCHAR(66), address VARCHAR(66),
storage_keys VARCHAR(66)[] storage_keys VARCHAR(66)[],
PRIMARY KEY (tx_id, index)
); );
-- +goose Down -- +goose Down

View File

@ -9,7 +9,8 @@ CREATE TABLE eth.log_cids (
topic0 VARCHAR(66), topic0 VARCHAR(66),
topic1 VARCHAR(66), topic1 VARCHAR(66),
topic2 VARCHAR(66), topic2 VARCHAR(66),
topic3 VARCHAR(66) topic3 VARCHAR(66),
PRIMARY KEY (rct_id, index)
); );
-- +goose Down -- +goose Down

View File

@ -1,69 +0,0 @@
-- +goose Up
-- +goose StatementBegin
CREATE FUNCTION eth.graphql_subscription() returns TRIGGER as $$
declare
table_name text = TG_ARGV[0];
attribute text = TG_ARGV[1];
id text;
begin
execute 'select $1.' || quote_ident(attribute)
using new
into id;
perform pg_notify('postgraphile:' || table_name,
json_build_object(
'__node__', json_build_array(
table_name,
id
)
)::text
);
return new;
end;
$$ language plpgsql;
-- +goose StatementEnd
CREATE TRIGGER header_cids_ai
after INSERT ON eth.header_cids
for each row
execute procedure eth.graphql_subscription('header_cids', 'id');
CREATE TRIGGER receipt_cids_ai
after INSERT ON eth.receipt_cids
for each row
execute procedure eth.graphql_subscription('receipt_cids', 'id');
CREATE TRIGGER state_accounts_ai
after INSERT ON eth.state_accounts
for each row
execute procedure eth.graphql_subscription('state_accounts', 'id');
CREATE TRIGGER state_cids_ai
after INSERT ON eth.state_cids
for each row
execute procedure eth.graphql_subscription('state_cids', 'id');
CREATE TRIGGER storage_cids_ai
after INSERT ON eth.storage_cids
for each row
execute procedure eth.graphql_subscription('storage_cids', 'id');
CREATE TRIGGER transaction_cids_ai
after INSERT ON eth.transaction_cids
for each row
execute procedure eth.graphql_subscription('transaction_cids', 'id');
CREATE TRIGGER uncle_cids_ai
after INSERT ON eth.uncle_cids
for each row
execute procedure eth.graphql_subscription('uncle_cids', 'id');
-- +goose Down
DROP TRIGGER uncle_cids_ai ON eth.uncle_cids;
DROP TRIGGER transaction_cids_ai ON eth.transaction_cids;
DROP TRIGGER storage_cids_ai ON eth.storage_cids;
DROP TRIGGER state_cids_ai ON eth.state_cids;
DROP TRIGGER state_accounts_ai ON eth.state_accounts;
DROP TRIGGER receipt_cids_ai ON eth.receipt_cids;
DROP TRIGGER header_cids_ai ON eth.header_cids;
DROP FUNCTION eth.graphql_subscription();