flip/stellar-models
1
0
Fork 0
mirror of https://github.com/FlipsideCrypto/stellar-models.git synced 2026-02-06 15:06:59 +00:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

fix pricing

Browse Source
This commit is contained in:
Eric Laurello 2025-07-31 09:05:06 -04:00
parent 67aafa1576
commit fa7ea98ae1
3 changed files with 100 additions and 59 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

103
models/silver/prices/silver__complete_provider_asset_metadata.sql
View File

@ -6,45 +6,52 @@
tags = ['silver_prices','scheduled_core']
) }}
SELECT
asset_id AS provider_asset_id,
UPPER(
CASE
WHEN len(TRIM(token_address)) = 56 THEN token_address
ELSE SPLIT_PART(
token_address,
'-',
2
)
END
) AS asset_issuer,
UPPER(
CASE
WHEN token_address LIKE '%-%' THEN SPLIT_PART(
token_address,
'-',
1
)
ELSE symbol
END
) AS asset_code,
NAME,
UPPER(symbol) AS symbol,
platform,
platform_id,
provider,
source,
_inserted_timestamp,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
{{ dbt_utils.generate_surrogate_key(['complete_provider_asset_metadata_id']) }} AS complete_provider_asset_metadata_id,
'{{ invocation_id }}' AS _invocation_id
FROM
{{ ref(
'bronze__complete_provider_asset_metadata'
) }}
WHERE
len(asset_issuer) > 0
WITH base AS(
SELECT
asset_id AS provider_asset_id,
SPLIT_PART(
token_address,
'-',
1
) seg1,
SPLIT_PART(
token_address,
'-',
2
) seg2,
UPPER(
CASE
WHEN len(TRIM(token_address)) = 56 THEN token_address
WHEN token_address ILIKE '%-%'
AND len(seg1) > len(seg2) THEN seg1
WHEN token_address ILIKE '%-%'
AND len(seg2) > len(seg1) THEN seg2
END
) AS asset_issuer,
UPPER(
CASE
WHEN token_address ILIKE '%-%'
AND len(seg1) > len(seg2) THEN seg2
WHEN token_address ILIKE '%-%'
AND len(seg2) > len(seg1) THEN seg1
ELSE symbol
END
) AS asset_code,
NAME,
UPPER(symbol) AS symbol,
platform,
platform_id,
provider,
source,
_inserted_timestamp,
complete_provider_asset_metadata_id
FROM
{{ ref(
'bronze__complete_provider_asset_metadata'
) }}
WHERE
len(asset_issuer) > 0
{% if is_incremental() %}
AND modified_timestamp >= (
@ -56,3 +63,21 @@ AND modified_timestamp >= (
{{ this }}
)
{% endif %}
)
SELECT
provider_asset_id,
asset_issuer,
asset_code,
NAME,
symbol,
platform,
platform_id,
provider,
source,
_inserted_timestamp,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
{{ dbt_utils.generate_surrogate_key(['complete_provider_asset_metadata_id']) }} AS complete_provider_asset_metadata_id,
'{{ invocation_id }}' AS _invocation_id
FROM
base

28
models/silver/prices/silver__complete_token_asset_metadata.sql
View File

@ -10,23 +10,31 @@ WITH providers AS (
SELECT
asset_id AS provider_asset_id,
SPLIT_PART(
token_address,
'-',
1
) seg1,
SPLIT_PART(
token_address,
'-',
2
) seg2,
UPPER(
CASE
WHEN len(TRIM(token_address)) = 56 THEN token_address
ELSE SPLIT_PART(
token_address,
'-',
2
)
WHEN token_address ILIKE '%-%'
AND len(seg1) > len(seg2) THEN seg1
WHEN token_address ILIKE '%-%'
AND len(seg2) > len(seg1) THEN seg2
END
) AS asset_issuer,
UPPER(
CASE
WHEN token_address LIKE '%-%' THEN SPLIT_PART(
token_address,
'-',
1
)
WHEN token_address ILIKE '%-%'
AND len(seg1) > len(seg2) THEN seg2
WHEN token_address ILIKE '%-%'
AND len(seg2) > len(seg1) THEN seg1
ELSE symbol
END
) AS asset_code,

28
models/silver/prices/silver__complete_token_prices.sql
View File

@ -12,23 +12,31 @@ WITH providers AS (
SELECT
HOUR,
asset_id AS provider_asset_id,
SPLIT_PART(
token_address,
'-',
1
) seg1,
SPLIT_PART(
token_address,
'-',
2
) seg2,
UPPER(
CASE
WHEN len(TRIM(token_address)) = 56 THEN token_address
ELSE SPLIT_PART(
token_address,
'-',
2
)
WHEN token_address ILIKE '%-%'
AND len(seg1) > len(seg2) THEN seg1
WHEN token_address ILIKE '%-%'
AND len(seg2) > len(seg1) THEN seg2
END
) AS asset_issuer,
UPPER(
CASE
WHEN token_address LIKE '%-%' THEN SPLIT_PART(
token_address,
'-',
1
)
WHEN token_address ILIKE '%-%'
AND len(seg1) > len(seg2) THEN seg2
WHEN token_address ILIKE '%-%'
AND len(seg2) > len(seg1) THEN seg1
ELSE symbol
END
) AS asset_code,