pwrIPOR_delegation/functions.py at main · Marco112358/pwrIPOR_delegation · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
from pycoingecko import CoinGeckoAPI
import pandas as pd
from datetime import datetime
import math
import requests
from web3 import Web3


def cg_pull(ticker='btc', curr='usd', days='max', intv='daily'):
    cg = CoinGeckoAPI()
    out = cg.get_coin_market_chart_by_id(id=ticker, vs_currency=curr, days=days, interval=intv)
    df = pd.DataFrame(data=out)
    df[['date', 'price']] = pd.DataFrame(df.prices.tolist(), index=df.index)
    df[['date']] = df[['date']] / 1000
    df['datetime'] = [datetime.fromtimestamp(x) for x in df['date']]
    df_out = df[['datetime', 'price']]
    return df_out


def get_price(ticker='ipor', curr='usd', days='max', intv='daily'):
    cg = CoinGeckoAPI()
    out = cg.get_price(ids=ticker, vs_currencies=curr)
    df = pd.DataFrame(data=out)
    val = df[ticker][0]
    return val


def first_curve(ratio=0.01):
    if 0.0 < ratio <= 0.01:
        a = 10
        b = 0.2
    elif 0.01 < ratio <= 0.02:
        a = 4
        b = 0.26
    elif 0.02 < ratio <= 0.03:
        a = 3
        b = 0.28
    elif 0.03 < ratio <= 0.04:
        a = 2
        b = 0.31
    else:
        a = 1
        b= 0.35
    powerup = b + a * ratio
    return powerup


def staking_pool(ip_tkn_stk=None, pwripor_stk=None, ipor_prc=None, vrt_shft=1.0, base_boost=0.4, log_base=2.0,
                 horz_shft=0.5, tkn_per_block=0.5, blocks_per_yr=2628000.0, user_ip_tkn=1.0, user_pwripor=1.0,
                 ratio_scalar=2.0):
    if (user_pwripor / user_ip_tkn) < 0.05:
        user_pwrup = first_curve((user_pwripor / user_ip_tkn))
    else:
        user_pwrup = vrt_shft + base_boost + math.log(horz_shft +
                                                      (ratio_scalar * (user_pwripor / user_ip_tkn)), log_base)
    pool_base_pwrup = vrt_shft + base_boost + math.log(horz_shft + (ratio_scalar * (pwripor_stk / ip_tkn_stk)), log_base)
    base_pool_pwrup = pool_base_pwrup * ip_tkn_stk
    agg_pwrup = base_pool_pwrup  # + user_pwrup * user_ip_tkn
    comp_multiplier = tkn_per_block / agg_pwrup
    user_apr_usd = user_ip_tkn * user_pwrup * comp_multiplier * blocks_per_yr * ipor_prc
    return user_apr_usd


def data_import(url='https://api.ipor.io/monitor/liquidity-mining-statistics'):
    lm_stats_dict = requests.get(url).json()
    pools_list = []
    for pool_info in lm_stats_dict['pools']:
        pools_list.append([pool_info['ipToken'], pool_info['delegatedPwIporAmount'], pool_info['stakedIpTokenAmount']])
    pools_df = pd.DataFrame(data=pools_list, columns=['ipToken', 'delegatedPwIporAmount', 'stakedIpTokenAmount'])
    pools_df = pools_df.set_index('ipToken', drop=True)
    return pools_df


def get_exch_rt(API_KEY="19817a3526604af0aff145aada226a17",
                url="https://mainnet.infura.io/v3/19817a3526604af0aff145aada226a17", scalar=1000000000000000000,
                address=None, abi=None):
    w3 = Web3(Web3.HTTPProvider(url))
    # Get abi from etherscan > contract > code > scroll down to Contract ABI section and copy
    contract = w3.eth.contract(address=address, abi=abi)
    exch_rt = contract.functions.calculateExchangeRate().call() / scalar
    return exch_rt