flip/osmosis-models
1
0
Fork 0
mirror of https://github.com/FlipsideCrypto/osmosis-models.git synced 2026-02-06 16:06:51 +00:00
Code Issues Actions 10 Packages Projects Releases Wiki Activity

base 64 fix

Browse Source
This commit is contained in:
Eric Laurello 2023-12-19 16:29:30 -05:00
parent 75ef5505d2
commit 8f5b03d17d
2 changed files with 51 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
models/silver/core/silver__msg_attributes.sql
View File

@ -18,22 +18,46 @@ SELECT
msg_index,
msg_type,
b.index AS attribute_index,
COALESCE(TRY_BASE64_DECODE_STRING(b.value :key), CASE WHEN block_id >= 12833808 THEN b.value :key END) :: STRING AS attribute_key,
COALESCE(TRY_BASE64_DECODE_STRING(b.value :value), CASE WHEN block_id >= 12833808 THEN b.value :value END) :: STRING AS attribute_value,
_inserted_timestamp,
concat_ws('-', tx_id, msg_index, attribute_index) AS _unique_key,
COALESCE(
CASE
WHEN block_id < 12833808 THEN TRY_BASE64_DECODE_STRING(
b.value :key
)
END,
b.value :key
) :: STRING AS attribute_key,
COALESCE(
CASE
WHEN block_id < 12833808 THEN TRY_BASE64_DECODE_STRING(
b.value :value
)
END,
b.value :value
) :: STRING AS attribute_value,
_inserted_timestamp,
concat_ws(
'-',
tx_id,
msg_index,
attribute_index
) AS _unique_key,
{{ dbt_utils.generate_surrogate_key(['_unique_key']) }} AS msg_attributes_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
{{ ref('silver__msgs') }} A, LATERAL FLATTEN(input => A.msg, path => 'attributes') b
{{ ref('silver__msgs') }} A,
LATERAL FLATTEN(
input => A.msg,
path => 'attributes'
) b
{% if is_incremental() %}
WHERE
_inserted_timestamp >= (
SELECT
MAX(_inserted_timestamp)
FROM
{{ this }})
SELECT
MAX(_inserted_timestamp)
FROM
{{ this }}
)
{% endif %}

30
models/silver/core/silver__msgs.sql
View File

@ -32,31 +32,31 @@ WITH b AS (
) AS is_action,
IFF(
COALESCE(
TRY_BASE64_DECODE_STRING(
msg :attributes [0] :key
),
CASE
WHEN block_id >= 12833808 THEN msg :attributes [0] :key
END
WHEN block_id < 12833808 THEN TRY_BASE64_DECODE_STRING(
msg :attributes [0] :key
)
END,
msg :attributes [0] :key
) :: STRING = 'module',
TRUE,
FALSE
) AS is_module,
COALESCE(
TRY_BASE64_DECODE_STRING(
msg :attributes [0] :key
),
CASE
WHEN block_id >= 12833808 THEN msg :attributes [0] :key
END
WHEN block_id < 12833808 THEN TRY_BASE64_DECODE_STRING(
msg :attributes [0] :key
)
END,
msg :attributes [0] :key
) :: STRING AS attribute_key,
COALESCE(
TRY_BASE64_DECODE_STRING(
msg :attributes [0] :value
),
CASE
WHEN block_id >= 12833808 THEN msg :attributes [0] :value
END
WHEN block_id < 12833808 THEN TRY_BASE64_DECODE_STRING(
msg :attributes [0] :value
)
END,
msg :attributes [0] :value
) :: STRING AS attribute_value,
_inserted_timestamp
FROM