diff --git a/models/gold/core/core__ez_transfers.sql b/models/gold/core/core__ez_transfers.sql index 8315090e..867978e8 100644 --- a/models/gold/core/core__ez_transfers.sql +++ b/models/gold/core/core__ez_transfers.sql @@ -7,6 +7,7 @@ SELECT a.block_timestamp, a.block_id, a.tx_id, + a.signers[0] AS signer, COALESCE(SPLIT_PART(a.INDEX :: text, '.', 1) :: INT, a.INDEX :: INT) AS index, NULLIF(SPLIT_PART(a.INDEX :: text, '.', 2), '') :: INT AS inner_index, a.tx_from, diff --git a/models/gold/core/core__ez_transfers.yml b/models/gold/core/core__ez_transfers.yml index bce4feb0..41882a48 100644 --- a/models/gold/core/core__ez_transfers.yml +++ b/models/gold/core/core__ez_transfers.yml @@ -10,6 +10,8 @@ models: description: "{{ doc('block_id') }}" - name: TX_ID description: "{{ doc('tx_id') }}" + - name: SIGNER + description: "{{ doc('signer') }}" - name: INDEX description: "{{ doc('index') }}" - name: INNER_INDEX diff --git a/models/gold/core/core__fact_transfers.sql b/models/gold/core/core__fact_transfers.sql index 38b8e333..9b753435 100644 --- a/models/gold/core/core__fact_transfers.sql +++ b/models/gold/core/core__fact_transfers.sql @@ -7,6 +7,7 @@ SELECT block_timestamp, block_id, tx_id, + signers, index, tx_from, tx_to, diff --git a/models/gold/core/core__fact_transfers.yml b/models/gold/core/core__fact_transfers.yml index d94cf415..ba24a15e 100644 --- a/models/gold/core/core__fact_transfers.yml +++ b/models/gold/core/core__fact_transfers.yml @@ -15,6 +15,10 @@ models: description: "{{ doc('tx_id') }}" tests: - dbt_expectations.expect_column_to_exist + - name: SIGNERS + description: "{{ doc('signers') }}" + tests: + - dbt_expectations.expect_column_to_exist - name: INDEX description: "{{ doc('index') }}" tests: diff --git a/models/silver/core/silver__transfers.sql b/models/silver/core/silver__transfers.sql index a3d01e48..4b43f2a4 100644 --- a/models/silver/core/silver__transfers.sql +++ b/models/silver/core/silver__transfers.sql @@ -26,6 +26,7 @@ WITH base_transfers_i AS ( block_id, block_timestamp, tx_id, + signers, INDEX::string as index, event_type, program_id, @@ -72,6 +73,7 @@ AND block_id, block_timestamp, tx_id, + signers, CONCAT( instruction_index, '.', @@ -221,6 +223,7 @@ spl_transfers AS ( e.block_id, e.block_timestamp, e.tx_id, + e.signers, e.index, e.program_id, e.succeeded, @@ -290,6 +293,7 @@ sol_transfers AS ( e.block_id, e.block_timestamp, e.tx_id, + e.signers, e.index, e.program_id, e.succeeded, @@ -315,6 +319,7 @@ SELECT block_id, block_timestamp, tx_id, + signers, program_id, succeeded, INDEX, @@ -338,6 +343,7 @@ SELECT block_id, block_timestamp, tx_id, + signers, program_id, succeeded, INDEX, diff --git a/models/silver/core/silver__transfers.yml b/models/silver/core/silver__transfers.yml index 49d7b82b..b0a7c6ed 100644 --- a/models/silver/core/silver__transfers.yml +++ b/models/silver/core/silver__transfers.yml @@ -28,6 +28,10 @@ models: description: "{{ doc('tx_id') }}" tests: - not_null: *recent_date_filter + - name: SIGNERS + description: "{{ doc('signers') }}" + tests: + - not_null: *recent_date_filter - name: SUCCEEDED description: "{{ doc('tx_succeeded') }}" tests: