mirror of
https://github.com/osmosis-labs/osmosis.git
synced 2025-07-23 00:52:21 +00:00
3d74adf563
* Script to generate LP incentive payouts from export (prop 12) * Readability changes, payments.csv * Sort output for consistency / replication * Sketch of upgrade payment code (untested) * ParseInt doesn't like whitespace * Add 1mil Osmo to feePool to fix lockup upgrade test. Still needs real test * Testcase for prop12 upgrade, minor refactor
96 lines
3.7 KiB
Python
Executable File
96 lines
3.7 KiB
Python
Executable File
#!/bin/python3
|
|
|
|
# Usage: python3 prop12.py state_export_from_block_65838.json
|
|
# This script returns a csv of addresses and the amount of uosmo to be paid to them
|
|
# 65838 is the epoch detailed in Osmosis prop 12
|
|
# state export should be obtained via version `v1.0.4`
|
|
|
|
import json
|
|
import functools
|
|
import sys
|
|
|
|
osmo_issued = (300000000*1000000*0.45)/365
|
|
|
|
def dict_osmo_rewards_by_gauge_id(data):
|
|
# returns a map of the uosmo rewards for each gauge id in poolincentives
|
|
poolincentives = data["app_state"]["poolincentives"]
|
|
gauge_weights = {x["gauge_id"] : int(x["weight"]) for x in poolincentives["distr_info"]["records"]}
|
|
total_weight = int(poolincentives["distr_info"]["total_weight"])
|
|
return {gid : (osmo_issued*gauge_weights[gid]/total_weight) for gid in gauge_weights}
|
|
|
|
def dict_gauge_id_by_denom_duration(data):
|
|
# returns a map from (denom, duration) to gauge ids
|
|
incentives = data["app_state"]["incentives"]
|
|
return {(x["distribute_to"]["denom"], x["distribute_to"]["duration"]) : x["id"] for x in incentives["gauges"]}
|
|
|
|
def dict_locked_by_gauge_id_by_address(data):
|
|
# returns a map from gauge_id to (a map from address to amount locked in that gauge)
|
|
accum = {}
|
|
gauge_ids = dict_gauge_id_by_denom_duration(data)
|
|
locks = data["app_state"]["lockup"]["locks"]
|
|
|
|
for l in locks:
|
|
amount = int(l["coins"][0]["amount"])
|
|
denom = l["coins"][0]["denom"]
|
|
duration = float(l["duration"][:-1])
|
|
addr = l["owner"]
|
|
|
|
if duration >= 86400:
|
|
gid = gauge_ids[(denom, "86400s")]
|
|
cur = accum.get(gid, {})
|
|
cur[addr] = cur.get(addr, 0)+amount
|
|
accum[gid] = cur
|
|
|
|
if duration >= 604800:
|
|
gid = gauge_ids[(denom, "604800s")]
|
|
cur = accum.get(gid, {})
|
|
cur[addr] = cur.get(addr, 0)+amount
|
|
accum[gid] = cur
|
|
|
|
if duration >= 1209600:
|
|
gid = gauge_ids[(denom, "1209600s")]
|
|
cur = accum.get(gid, {})
|
|
cur[addr] = cur.get(addr, 0)+amount
|
|
accum[gid] = cur
|
|
return accum
|
|
|
|
def dict_rewards_by_address(data):
|
|
osmo_per_gauge = dict_osmo_rewards_by_gauge_id(data)
|
|
locked = dict_locked_by_gauge_id_by_address(data)
|
|
gauge_totals = {gid : sum(locked[gid].values()) for gid in locked}
|
|
|
|
#converts the {gauge_id -> {addr -> amount_locked}} dictionary into {gauge_id -> {addr -> usomo_issued}}
|
|
# by multiplying by uosmo issued to the gauge, and dividing by total locked for the gauge
|
|
mint_by_gauge_addr = {gid : {addr : osmo_per_gauge.get(gid, 0)*locked[gid][addr]/gauge_totals[gid] for addr in locked[gid]} for gid in locked}
|
|
|
|
#merge dictionaries by adding when they share a key (assumes numerical values)
|
|
#example: a={"foo":3, "bar":5} , b={"foo":1, "baz":8} => {"foo":4, "bar":5, "baz":8}
|
|
merge_dict_by_sum = lambda a, b: {k : a[k] + b[k] if k in a and k in b else a.get(k, b.get(k)) for k in a.keys() | b.keys()}
|
|
|
|
#convert {gauge_id -> {addr -> uosmo_issued}} into {addr -> uosmo_issued} by merging the dictionaries for each gauge id, adding the osmo issued for each address
|
|
return functools.reduce(merge_dict_by_sum, mint_by_gauge_addr.values())
|
|
|
|
|
|
def compute_sanity_check_and_export(data):
|
|
rewards = dict_rewards_by_address(data)
|
|
total_paid = sum(rewards.values())
|
|
community_paid = dict_osmo_rewards_by_gauge_id(data)["0"]
|
|
|
|
print("expected total: ", int(osmo_issued), "uosmo")
|
|
print("paid to LPers: ", int(total_paid), "uosmo")
|
|
print("paid to community pool: ", int(community_paid), "uosmo")
|
|
imbalance = int(osmo_issued - (total_paid + community_paid))
|
|
print("imbalance: ", imbalance)
|
|
assert(imbalance == 0)
|
|
|
|
f = open("prop_12_payments.csv","w")
|
|
f.write("\n".join([addr+", "+str(int(rewards[addr])) for addr in sorted(rewards)]))
|
|
f.close()
|
|
|
|
|
|
|
|
if __name__ == "__main__":
|
|
fname = sys.argv[1]
|
|
f = open(fname)
|
|
data = json.loads(f.read())
|
|
compute_sanity_check_and_export(data) |