mirror of
https://github.com/hanzo-fi/payments.git
synced 2026-10-30 20:31:20 +00:00
Paul NicolasandGitHub
d66040c0eb
* feat(models): add bank bridge models * feat(storage): add bank bridge migrations and functions * feat(engine): add bank bridge workflows * feat(connectors): add plaid bank bridge connector * feat(events): add bank bridge events * feat(api): add bank bridge router * feat(*): bank bridge boilerplate * fix nil pointer crash * add more check when getting link attempts + change enum * fix tests * remove print * fixes after reviews * add specific table for access tokens * fixes after reviews * fix go mod tidy * remove indexes + null default * plaid: add tests * *: add more tests * fix after rebase
114 lines
3.8 KiB
SQL
114 lines
3.8 KiB
SQL
create table if not exists bank_bridge_connection_attempts (
|
|
sort_id bigserial not null,
|
|
|
|
-- Mandatory fields
|
|
id uuid not null,
|
|
psu_id uuid not null,
|
|
created_at timestamp without time zone not null,
|
|
connector_id varchar not null,
|
|
status text not null,
|
|
|
|
-- Optional fields
|
|
client_redirect_url text,
|
|
temporary_token text,
|
|
expires_at timestamp without time zone,
|
|
state jsonb,
|
|
error text,
|
|
|
|
-- Primary key
|
|
primary key (id)
|
|
);
|
|
|
|
create index bank_bridge_connection_attempts_created_at_sort_id on bank_bridge_connection_attempts (created_at, sort_id);
|
|
create index bank_bridge_connection_attempts_connector_id on bank_bridge_connection_attempts (connector_id);
|
|
create index bank_bridge_connection_attempts_psu_id on bank_bridge_connection_attempts (psu_id);
|
|
alter table bank_bridge_connection_attempts
|
|
add constraint bank_bridge_connection_attempts_connector_id_fk foreign key (connector_id)
|
|
references connectors (id)
|
|
on delete cascade;
|
|
|
|
alter table bank_bridge_connection_attempts
|
|
add constraint bank_bridge_connection_attempts_psu_id_fk foreign key (psu_id)
|
|
references payment_service_users (id)
|
|
on delete cascade;
|
|
|
|
create table if not exists psu_bank_bridges (
|
|
sort_id bigserial not null,
|
|
|
|
-- Mandatory fields
|
|
psu_id uuid not null,
|
|
connector_id varchar not null,
|
|
|
|
-- Optional fields
|
|
expires_at timestamp without time zone,
|
|
metadata jsonb,
|
|
|
|
-- Primary key
|
|
primary key (psu_id, connector_id)
|
|
);
|
|
|
|
create index psu_bank_bridges_connector_id on psu_bank_bridges (connector_id);
|
|
create index psu_bank_bridges_psu_id on psu_bank_bridges (psu_id);
|
|
alter table psu_bank_bridges
|
|
add constraint psu_bank_bridges_connector_id_fk foreign key (connector_id)
|
|
references connectors (id)
|
|
on delete cascade;
|
|
|
|
alter table psu_bank_bridges
|
|
add constraint psu_bank_bridges_psu_id_fk foreign key (psu_id)
|
|
references payment_service_users (id)
|
|
on delete cascade;
|
|
|
|
create table if not exists psu_bank_bridge_connections (
|
|
sort_id bigserial not null,
|
|
|
|
-- Mandatory fields
|
|
psu_id uuid not null,
|
|
connector_id varchar not null,
|
|
connection_id varchar not null,
|
|
created_at timestamp without time zone not null,
|
|
data_updated_at timestamp without time zone not null,
|
|
status text not null,
|
|
|
|
-- Optional fields
|
|
error text,
|
|
metadata jsonb,
|
|
|
|
-- Primary key
|
|
primary key (psu_id, connector_id, connection_id)
|
|
);
|
|
|
|
create index psu_bank_bridge_connections_connector_id on psu_bank_bridge_connections (connector_id);
|
|
create index psu_bank_bridge_connections_psu_id on psu_bank_bridge_connections (psu_id);
|
|
create index psu_bank_bridge_connections_created_at_sort_id on psu_bank_bridge_connections (created_at, sort_id);
|
|
alter table psu_bank_bridge_connections
|
|
add constraint psu_bank_bridge_connections_psu_id_fk foreign key (psu_id)
|
|
references payment_service_users (id)
|
|
on delete cascade;
|
|
|
|
alter table psu_bank_bridge_connections
|
|
add constraint psu_bank_bridge_connections_connector_id_fk foreign key (connector_id)
|
|
references connectors (id)
|
|
on delete cascade;
|
|
|
|
create table psu_bank_bridge_access_tokens (
|
|
sort_id bigserial not null,
|
|
|
|
psu_id uuid not null,
|
|
connector_id varchar not null,
|
|
connection_id varchar not null default '',
|
|
access_token text not null,
|
|
expires_at timestamp without time zone not null,
|
|
|
|
primary key (psu_id, connector_id, connection_id)
|
|
);
|
|
|
|
alter table psu_bank_bridge_access_tokens
|
|
add constraint psu_bank_bridge_access_tokens_psu_id_fk foreign key (psu_id)
|
|
references payment_service_users (id)
|
|
on delete cascade;
|
|
|
|
alter table psu_bank_bridge_access_tokens
|
|
add constraint psu_bank_bridge_access_tokens_connector_id_fk foreign key (connector_id)
|
|
references connectors (id)
|
|
on delete cascade; |