Add vesting scheduler json to csv converter

convert_vesting_schedule.py

+import json
+
+q = json.load(open('query-claims.json', 'rb'))
+
+out = open('out.csv', 'w')
+
+#print(f"account_id, l1, l2, round_num, days", file=out)
+
+calc_lockups = []
+for account_id, lockups in q.items():
+    for lockup in lockups:
+        l1 = lockup[0]
+        l2 = lockup[1]
+        round_num = lockup[2]
+        # *[roundtime] / num_seconds_in_minute / num_minutes_in_hr / num_hrs_in_day
+        days = round_num*6/60/60/24
+        # print(f"{account_id}, {l1}, {l2}, {round_num}, {days}", file=out)
+        calc_lockups.append({
+            'account_id': account_id,
+            'l1': l1,
+            'l2': l2,
+            'round_num': round_num,
+            'days': days,
+        })
+
+daynames = []
+for cl in calc_lockups:
+    if cl['days'] not in daynames:
+        daynames.append(cl['days'])
+
+colnames = sorted(daynames)
+colnames.insert(0, 'account_id')
+print(colnames)
+
+import csv
+rows = dict()
+for cl in calc_lockups:
+    aid = cl['account_id']
+    if aid not in rows:
+        rows[aid] = {
+            'account_id': aid,
+        }
+    for col in colnames[1:]:
+        if col not in rows[aid]:
+            rows[aid][col] = 0
+        if cl['days'] == col:
+            rows[aid][col] = cl['l1']
+
+
+out = csv.writer(open('out.csv', 'w'), delimiter=',')
+out.writerow(colnames)
+for _,r in rows.items():
+    out.writerow([x for x in r.values()])

dump_all_balances.py

@@ -25,7 +25,7 @@ def main(url, output):
     substrate = SubstrateInterface(url=url)
     account_len = 0
     result = substrate.query_map('System', 'Account', page_size=200,
-                                 max_results=400)
+                                 max_results=100000)
     out = csv.writer(output, delimiter=',')
     headers = False
     for account, account_info in result:

query.py

@@ -2,6 +2,7 @@ import json
 import logging as log
 import argparse
 from json import JSONDecodeError
+import csv
 from substrateinterface import SubstrateInterface  # pip3 install substrate-interface
 ########################################################################################################################
 # Auxiliar Functions
@@ -161,5 +162,22 @@ def main():
             file.write(json.dumps(result, indent=4))
     else:
         print(json.dumps(result, indent=4))
+
+    out = csv.writer(open('out.csv', 'w'), delimiter=',')
+    headers = False
+    for k, v in result.items():
+        r = [k]
+        if type(v) is dict:
+            if not headers:
+                headers = True
+                r = ["account_id"]
+                r.extend([x for x in v.keys()])
+                out.writerow(r)
+            r = [k]
+            r.extend([x for x in v.values()])
+        else:
+            r = [k, v]
+        out.writerow(r)
+
 if __name__ == "__main__":
     main()