From c5de5ded4ce1b5b2f66e4393f62c1af7f5f3df98 Mon Sep 17 00:00:00 2001 From: Eric Laurello Date: Tue, 18 Jun 2024 09:49:11 -0400 Subject: [PATCH] osmosis -> blockjoy --- macros/snowflake_api/get_blockchain_api.sql | 4 ++-- .../silver/core/realtime/streamline__balances_realtime.sql | 4 ++-- .../silver/core/realtime/streamline__blocks_realtime.sql | 4 ++-- .../core/realtime/streamline__pool_balances_realtime.sql | 4 ++-- .../core/realtime/streamline__transactions_realtime.sql | 4 ++-- .../silver/core/realtime/streamline__tx_counts_realtime.sql | 4 ++-- models/streamline/silver/core/streamline__chainhead.sql | 4 ++-- 7 files changed, 14 insertions(+), 14 deletions(-) diff --git a/macros/snowflake_api/get_blockchain_api.sql b/macros/snowflake_api/get_blockchain_api.sql index 8e277c7..f65ec9b 100644 --- a/macros/snowflake_api/get_blockchain_api.sql +++ b/macros/snowflake_api/get_blockchain_api.sql @@ -108,13 +108,13 @@ SELECT call, {{ target.database }}.live.udf_api ( 'POST', - '{Service}/{Authentication}', + '{Service}/rpc', OBJECT_CONSTRUCT( 'Content-Type', 'application/json' ), call, - 'Vault/prod/osmosis/atn/mainnet' + 'Vault/prod/osmosis/blockjoy/mainnet' ) AS DATA, SYSDATE() FROM diff --git a/models/streamline/silver/core/realtime/streamline__balances_realtime.sql b/models/streamline/silver/core/realtime/streamline__balances_realtime.sql index df1503a..b4b8a40 100644 --- a/models/streamline/silver/core/realtime/streamline__balances_realtime.sql +++ b/models/streamline/silver/core/realtime/streamline__balances_realtime.sql @@ -32,7 +32,7 @@ SELECT ) AS partition_key, {{ target.database }}.live.udf_api( 'GET', - 'https://osmosis-mainnet.g.allthatnode.com/archive/rest/{Authentication}/cosmos/bank/v1beta1/balances/' || address || '?pagination.limit=10000', + '{Service}/cosmos/bank/v1beta1/balances/' || address || '?pagination.limit=10000', OBJECT_CONSTRUCT( 'Content-Type', 'application/json', @@ -40,7 +40,7 @@ SELECT block_number :: STRING ), PARSE_JSON('{}'), - 'vault/prod/osmosis/atn/mainnet' + 'Vault/prod/osmosis/blockjoy/mainnet' ) AS request, block_number, address diff --git a/models/streamline/silver/core/realtime/streamline__blocks_realtime.sql b/models/streamline/silver/core/realtime/streamline__blocks_realtime.sql index 9966db8..e0deb89 100644 --- a/models/streamline/silver/core/realtime/streamline__blocks_realtime.sql +++ b/models/streamline/silver/core/realtime/streamline__blocks_realtime.sql @@ -30,7 +30,7 @@ SELECT ) :: INT AS partition_key, {{ target.database }}.live.udf_api( 'POST', - '{Service}/{Authentication}', + '{Service}/rpc', OBJECT_CONSTRUCT( 'Content-Type', 'application/json' @@ -47,7 +47,7 @@ SELECT block_number :: STRING ) ), - 'vault/prod/osmosis/atn/mainnet' + 'Vault/prod/osmosis/blockjoy/mainnet' ) AS request FROM blocks diff --git a/models/streamline/silver/core/realtime/streamline__pool_balances_realtime.sql b/models/streamline/silver/core/realtime/streamline__pool_balances_realtime.sql index db3539f..1fd8988 100644 --- a/models/streamline/silver/core/realtime/streamline__pool_balances_realtime.sql +++ b/models/streamline/silver/core/realtime/streamline__pool_balances_realtime.sql @@ -46,7 +46,7 @@ SELECT {{ target.database }}.live.udf_api( 'GET', REPLACE( - 'https://osmosis-mainnet.g.allthatnode.com/archive/rest/{Authentication}/osmosis/gamm/v1beta1/pools?pagination.limit=10000', + '{Service}/osmosis/gamm/v1beta1/pools?pagination.limit=10000', 'tendermint', 'rest' ), @@ -57,7 +57,7 @@ SELECT block_number :: STRING ), PARSE_JSON('{}'), - 'vault/prod/osmosis/atn/mainnet' + 'Vault/prod/osmosis/blockjoy/mainnet' ) AS request, block_number FROM diff --git a/models/streamline/silver/core/realtime/streamline__transactions_realtime.sql b/models/streamline/silver/core/realtime/streamline__transactions_realtime.sql index 44e2a5d..a748cec 100644 --- a/models/streamline/silver/core/realtime/streamline__transactions_realtime.sql +++ b/models/streamline/silver/core/realtime/streamline__transactions_realtime.sql @@ -88,7 +88,7 @@ numbers AS ( ) :: INT AS partition_key, live.udf_api( 'POST', - '{Service}/{Authentication}', + '{Service}/rpc', OBJECT_CONSTRUCT( 'Content-Type', 'application/json' @@ -109,7 +109,7 @@ numbers AS ( 'asc' ) ), - 'vault/prod/osmosis/atn/mainnet' + 'Vault/prod/osmosis/blockjoy/mainnet' ) AS request, page_number, block_number AS block_number_requested diff --git a/models/streamline/silver/core/realtime/streamline__tx_counts_realtime.sql b/models/streamline/silver/core/realtime/streamline__tx_counts_realtime.sql index a8c0bf8..0297502 100644 --- a/models/streamline/silver/core/realtime/streamline__tx_counts_realtime.sql +++ b/models/streamline/silver/core/realtime/streamline__tx_counts_realtime.sql @@ -30,7 +30,7 @@ SELECT ) :: INT AS partition_key, {{ target.database }}.live.udf_api( 'POST', - '{Service}/{Authentication}', + '{Service}/rpc', OBJECT_CONSTRUCT( 'Content-Type', 'application/json' @@ -51,7 +51,7 @@ SELECT 'asc' ) ), - 'vault/prod/osmosis/atn/mainnet' + 'Vault/prod/osmosis/blockjoy/mainnet' ) AS request FROM blocks diff --git a/models/streamline/silver/core/streamline__chainhead.sql b/models/streamline/silver/core/streamline__chainhead.sql index 0f0b358..a822ea4 100644 --- a/models/streamline/silver/core/streamline__chainhead.sql +++ b/models/streamline/silver/core/streamline__chainhead.sql @@ -6,7 +6,7 @@ SELECT {{ target.database }}.live.udf_api( 'POST', - '{Service}/{Authentication}', + '{Service}/rpc', OBJECT_CONSTRUCT( 'Content-Type', 'application/json', @@ -23,5 +23,5 @@ SELECT 'params', [] ), - 'vault/prod/osmosis/atn/mainnet' + 'Vault/prod/osmosis/blockjoy/mainnet' ) :data :result :sync_info :latest_block_height :: INT AS block_number