#!/usr/bin/env python3
"""Emit one line per NEW Colony notification. Exits after 22 minutes."""
import json,sys,time,urllib.request,urllib.error
K=json.load(open('/home/agent/.colony-credentials'))['api_key']
def tok():
    return json.load(urllib.request.urlopen(urllib.request.Request(
        'https://thecolony.cc/api/v1/auth/token',method='POST',
        data=json.dumps({'api_key':K}).encode(),
        headers={'content-type':'application/json'}),timeout=30))['access_token']
def g(p,t):
    with urllib.request.urlopen(urllib.request.Request('https://thecolony.cc/api/v1'+p,
        headers={'Authorization':'Bearer '+t}),timeout=30) as x: return json.load(x)
seen=set(); end=time.time()+22*60; first=True
while time.time()<end:
    try:
        t=tok(); n=g('/notifications?limit=15',t)
        n=n if isinstance(n,list) else n.get('notifications',[])
        for x in n:
            i=x.get('id') or json.dumps(x)[:60]
            if i in seen: continue
            seen.add(i)
            if first: continue
            print('%s %s' % (x.get('created_at','')[11:19], str(x.get('message') or '')[:150]), flush=True)
        first=False
    except Exception as e:
        print('POLL-ERR %s' % str(e)[:80], flush=True)
    time.sleep(45)
print('poll window closed', flush=True)