This sections contains different ParsiQL code samples
Ethereum
Uniswap Swap spikes
The following Smart-Trigger allows to monitor a defined Table of Uniswap Pair Pools, perform calculations and detect Swap spikes according to threshold.
In this example we observe the PRQ/ETH Pair's Pool and set the ETH (WETH to be precise) as the trading asset (TradingAsset) to set the thresholds against.
User Data
Table for storing Uniswap Pairs Pool data
Smart-Trigger
1
stream UniswapSwapSpikes
2
# We are interested in the Token Transfers for the Uniswap case.
3
from TokenTransfers
4
# We have a table with (interesting to us) Uniswap Pools. We want to monitor both BUYs and SELLs for them.
5
where @to in UniswapPools || @from in UniswapPools
6
process
7
8
# Basic initialization variable for later usage
9
let threshold = 0
10
let initiator = 0x0
11
let pool = 0x0
12
let action = ""
13
14
# If our Trading Asset is used for BUY operation
15
if @to in UniswapPools && @code_address == UniswapPools[@to].TradingAsset then
16
threshold = UniswapPools[@to].BuyThreshold
17
# The address that initiated the BUY operation
18
initiator = @from
19
# The pool that was
20
pool = @to
21
action = "BUY"
22
# If our Trading Asset is used for SELL operation
23
elseif @from in UniswapPools && @code_address == UniswapPools[@from].TradingAsset then
24
threshold = UniswapPools[@from].SellThreshold
25
initiator = @to
26
pool = @from
27
action = "SELL"
28
end
29
30
# Check that BUY or SELL happened
31
if action != "" then
32
# Additional check that we are dealing with ERC-20'ies
33
if @is_erc20 then
34
# We compare that the BUY/SELL amount is exceeding the defined (Buy/Sell)Threshold
35
if compare({value: @value, decimals: @erc20.decimals}, {value: threshold, decimals: 0}) >= 0 then
This Smart-Trigger is a more simple and specific solution to the same task as in "Uniswap Swap spikes", only that it monitors Uniswap spikes specifically for PRQ/ETH Pair Pool against ETH (WETH to be precise)
User Data
Uniswap spike threshold values against PRQ and ETH separately
A Primitive Record to store WETH's Smart-Contract address
A Struct Record of fields that hold some PRQ related addresses
Smart-Trigger
1
stream PRQTransfers
2
from TokenTransfers
3
where @code_address == WETH && @to == PRQTrackingData.UniswapAddress
4
process
5
if compare({value: @value, decimals: @erc20.decimals}, {value: UniswapSpikeThreshold.ETH, decimals: 0}) >= 0 then
The following ParsiQL code stands behind the Flashr (PRQ Project to be precise in this example) that is a sub-product of PARSIQ Monitoring and is completely based on the Public Project feature. It allows to monitor all PRQ TokenTransfers with a defined threshold that is large enough to be counted as a whale one.
User Data
Smart-Trigger
1
stream WhaleTransfers
2
from TokenTransfers
3
where @code_address == PRQ.ContractAddress
4
process
5
if compare({@value, decimals: @erc20.decimals}, {value: PRQ.WhaleTransferThreshold, decimals: 0}) >= 0 then
This example shows how one can have multiple Datatokens and aggregate the volume of Datatokens used as a payment for specifc Dataset (matched against CorporateDatatokens Table Record) consumptions.
Smart-Trigger
1
stream CorporateDatasetAccounting
2
# Stream all possible Dataset consumes on the Ocean Protocol
3
from OceanDatasetConsumes
4
# Filter those that match our Datatokens
5
where @dataToken in CorporateDatatokens
6
process
7
# Initialize Datatoken volumes to 0
8
state labelledAnimalImagesDatatokenVolume = 0
9
state ebayProductsDatatokenVolume = 0
10
11
# Detect Dataset
12
let dataset = CorporateDatatokens[@dataToken].Dataset
In this particular case - we would like to aggregate the volume of TWT Tokens swapped in the context of TWT/WBNB Pair (BSC scan link) and then compare two approaches to calculating according USD volume: continuously or post factum.
User Data
Smart-Trigger
1
stream PancakeSwapTradesForTWTBNB
2
# We are interested in the BEP20 Token Transfers for the PancakeSwap case.
3
from BscBEP20Transfers
4
# We have a table with (interesting to us) PancakeSwap Pairs. We want to monitor both BUYs and SELLs for them.
5
where @to in PancakeSwapPairs || @from in PancakeSwapPairs
6
# Filter out everything except TWT/WBNB
7
where @to in PancakeSwapPairs && PancakeSwapPairs[@to].Pair == "TWT/WBNB" || @from in PancakeSwapPairs && PancakeSwapPairs[@from].Pair == "TWT/WBNB"
8
process
9
state startingBlock = 0
10
state buyVolumeTWT = 0
11
state sellVolumeTWT = 0
12
state buyVolumeInUSD = {value: 0, decimals: 0}
13
state sellVolumeInUSD = {value: 0, decimals: 0}
14
15
# Basic initialization variable for later usage
16
let initiator = 0x0
17
let pair = 0x0
18
let action = ""
19
let TWTinUSD = {value: 0, decimals: 0}
20
21
if startingBlock == 0 then
22
startingBlock = @block.number
23
end
24
25
let cryptorankPriceInUSDforTWT = {value: 0, decimals: 0}