From 09c80ee491c811506d2f9ec2f554fe3abef98663 Mon Sep 17 00:00:00 2001
From: tarikceric <tarik@flipsidecrypto.com>
Date: Tue, 18 Nov 2025 20:21:54 +0100
Subject: [PATCH] add signer

---
 .../marinade__ez_liquid_staking_actions.sql     |  2 ++
 .../marinade__ez_liquid_staking_actions.yml     |  5 +++++
 .../silver__marinade_liquid_staking_actions.sql | 17 ++++++++++++++++-
 3 files changed, 23 insertions(+), 1 deletion(-)

diff --git a/models/gold/marinade/marinade__ez_liquid_staking_actions.sql b/models/gold/marinade/marinade__ez_liquid_staking_actions.sql
index 9670a2c5..132d41e9 100644
--- a/models/gold/marinade/marinade__ez_liquid_staking_actions.sql
+++ b/models/gold/marinade/marinade__ez_liquid_staking_actions.sql
@@ -26,6 +26,7 @@ WITH liquid_staking_actions AS (
         tx_id,
         index,
         inner_index,
+        signer,
         action_type,
         provider_address,
         deposit_amount,
@@ -59,6 +60,7 @@ SELECT
     a.tx_id,
     a.index,
     a.inner_index,
+    a.signer,
     a.action_type,
     a.provider_address,
     a.deposit_amount,
diff --git a/models/gold/marinade/marinade__ez_liquid_staking_actions.yml b/models/gold/marinade/marinade__ez_liquid_staking_actions.yml
index 86e1b758..81a5c23a 100644
--- a/models/gold/marinade/marinade__ez_liquid_staking_actions.yml
+++ b/models/gold/marinade/marinade__ez_liquid_staking_actions.yml
@@ -40,6 +40,11 @@ models:
         description: "{{ doc('inner_index') }}"
         tests:
           - dbt_expectations.expect_column_to_exist
+      - name: SIGNER
+        description: "{{ doc('signer') }}"
+        tests:
+          - dbt_expectations.expect_column_to_exist
+          - not_null: *recent_date_filter
       - name: ACTION_TYPE
         description: "{{ doc('action') }}"
         tests:
diff --git a/models/silver/protocols/marinade/silver__marinade_liquid_staking_actions.sql b/models/silver/protocols/marinade/silver__marinade_liquid_staking_actions.sql
index ac8f1df2..43c37e59 100644
--- a/models/silver/protocols/marinade/silver__marinade_liquid_staking_actions.sql
+++ b/models/silver/protocols/marinade/silver__marinade_liquid_staking_actions.sql
@@ -13,7 +13,16 @@
     {% set base_query %}
     CREATE OR REPLACE TEMPORARY TABLE silver.marinade_liquid_staking_actions__intermediate_tmp AS
     SELECT
-        *
+        block_id,
+        block_timestamp,
+        tx_id,
+        index,
+        inner_index,
+        signers[0]::STRING AS signer,
+        program_id,
+        decoded_instruction,
+        event_type,
+        _inserted_timestamp
     FROM
         {{ ref('silver__decoded_instructions_combined') }}
     WHERE
@@ -100,6 +109,7 @@ deposits AS (
         a.tx_id,
         a.index,
         a.inner_index,
+        a.signer,
         a.event_type AS action_type,
         CASE 
             WHEN a.event_type = 'deposit' THEN silver.udf_get_account_pubkey_by_name('transferFrom', decoded_instruction:accounts)
@@ -134,6 +144,7 @@ order_unstakes AS (
         tx_id,
         index,
         inner_index,
+        signer,
         event_type AS action_type,
         silver.udf_get_account_pubkey_by_name('burnMsolAuthority', decoded_instruction:accounts) AS provider_address,
         (decoded_instruction:args:msolAmount::int) * pow(10, -9) AS msol_burned,
@@ -151,6 +162,7 @@ claims AS (
         a.tx_id,
         a.index,
         a.inner_index,
+        a.signer,
         a.event_type AS action_type,
         silver.udf_get_account_pubkey_by_name('transferSolTo', a.decoded_instruction:accounts) AS provider_address,
         b.amount AS claim_amount,
@@ -175,6 +187,7 @@ SELECT
     tx_id,
     index,
     inner_index,
+    signer,
     action_type,
     provider_address,
     deposit_amount,
@@ -196,6 +209,7 @@ SELECT
     tx_id,
     index,
     inner_index,
+    signer,
     action_type,
     provider_address,
     NULL AS deposit_amount,
@@ -217,6 +231,7 @@ SELECT
     tx_id,
     index,
     inner_index,
+    signer,
     action_type,
     provider_address,
     NULL AS deposit_amount,