diff --git a/models/silver/core/silver__transfers.sql b/models/silver/core/silver__transfers.sql index 76a36b4..0160c02 100644 --- a/models/silver/core/silver__transfers.sql +++ b/models/silver/core/silver__transfers.sql @@ -26,6 +26,7 @@ WITH base_atts AS ( WHERE msg_type IN ( 'tx', + 'signer', 'transfer' ) @@ -82,8 +83,16 @@ sender AS ( FROM base_atts WHERE - msg_type = 'tx' - AND attribute_key = 'acc_seq' qualify(ROW_NUMBER() over(PARTITION BY tx_id + ( + ( + msg_type = 'tx' + AND attribute_key = 'acc_seq' + ) + OR ( + msg_type = 'signer' + AND attribute_key = 'sei_addr' + ) + ) qualify(ROW_NUMBER() over(PARTITION BY tx_id ORDER BY msg_index)) = 1 ), diff --git a/models/silver/core/silver__transfers_ibc.sql b/models/silver/core/silver__transfers_ibc.sql index df2debe..a3e266c 100644 --- a/models/silver/core/silver__transfers_ibc.sql +++ b/models/silver/core/silver__transfers_ibc.sql @@ -26,6 +26,7 @@ WITH base_atts AS ( WHERE msg_type IN ( 'tx', + 'signer', 'transfer', 'ibc_transfer', 'write_acknowledgement' @@ -141,8 +142,16 @@ sender AS ( FROM base_atts WHERE - msg_type = 'tx' - AND attribute_key = 'acc_seq' qualify(ROW_NUMBER() over(PARTITION BY tx_id + ( + ( + msg_type = 'tx' + AND attribute_key = 'acc_seq' + ) + OR ( + msg_type = 'signer' + AND attribute_key = 'sei_addr' + ) + ) qualify(ROW_NUMBER() over(PARTITION BY tx_id ORDER BY msg_index)) = 1 ),