import sys, json, datetime; sys.path.insert(0,'scripts')
from rpc import *
def first_active(w):
    lo,hi=0,int(call("eth_blockNumber",[]),16)
    def act(b): return int(call("eth_getBalance",[w,hex(b)]),16)>0 or int(call("eth_getTransactionCount",[w,hex(b)]),16)>0
    while lo<hi:
        mid=(lo+hi)//2
        if act(mid): hi=mid
        else: lo=mid+1
    return lo
def profile(w, end=None):
    w=w.lower(); head=int(call("eth_blockNumber",[]),16); end=end or head
    fa=first_active(w)
    A=[NATIVE,"0x83fd0bdddafa9a499582899d49515060c361b9aa","0xa163d7624da3b5d9182c50eab5b8cd247ae861bb","0x390128ca6d20661181ffde1259ced84de23fd4f5"]
    ins=get_logs({"address":A,"topics":[XFER,None,pad(w)]},fa,end)
    outs=get_logs({"address":A,"topics":[XFER,pad(w)]},fa,end)
    rows=[]
    for d,ls in (("IN",ins),("OUT",outs)):
        for l in ls:
            if len(l["topics"])!=3: continue
            rows.append({"dir":d,"block":int(l["blockNumber"],16),"li":int(l["logIndex"],16),"asset":l["address"].lower(),"from":"0x"+l["topics"][1][-40:],"to":"0x"+l["topics"][2][-40:],"raw":int(l["data"],16) if l["data"]!="0x" else 0,"tx":l["transactionHash"]})
    rows.sort(key=lambda r:(r["block"],r["li"]))
    return {"wallet":w,"first_active":fa,"rows":rows}
if __name__=="__main__":
    for w in sys.argv[1:]:
        p=profile(w); json.dump(p,open(f"data/wallet_{w[:10].lower()}.json","w"),indent=1)
        print("==",w,flush=True); print("   first active block",p["first_active"],"transfers",len(p["rows"]))