diff options
Diffstat (limited to 'monitor/josef_mover.py')
| -rwxr-xr-x | monitor/josef_mover.py | 67 |
1 files changed, 35 insertions, 32 deletions
diff --git a/monitor/josef_mover.py b/monitor/josef_mover.py index c2724d7..52b9dd6 100755 --- a/monitor/josef_mover.py +++ b/monitor/josef_mover.py @@ -15,7 +15,6 @@ def print_reply(rep, entry, precert): t = datetime.datetime.fromtimestamp(rep['timestamp'] / 1000, UTC()).strftime("%Y-%m-%d %H:%M:%S") log_id = rep["id"] - print "Time:", t for log in ctlogs: if str(log_id) == log["id"]: @@ -24,7 +23,8 @@ def print_reply(rep, entry, precert): else: l = {"name" : "Log not found" + log_id} - print "Log:", l["name"] + # print "Log:", l["name"] + print "Time:", t if precert: print "Type: Precert" @@ -44,39 +44,42 @@ def print_reply(rep, entry, precert): print "" -source = ctlogs[1] -dests = [ctlogs[1]] - -first = 360 -last = 365 +# source = [ctlogs[0]] +source = ctlogs +# dests = [ctlogs[0]] +dests = ctlogs -entries = get_entries(source["url"], first, last)["entries"] +first = 0 +last = 0 # print entries - -for log in dests: - for item in entries: - try: - entry = extract_original_entry(item) - if entry[2]: - precert = True - else: - precert = False - submission = [] - - for e in entry[0]: - submission.append(base64.b64encode(e)) - - if precert: - res = add_prechain(log["url"], {"chain" : submission}) - else: - res = add_chain(log["url"], {"chain" : submission}) - print_reply(res, entry, precert) - # time.sleep(5) - except KeyboardInterrupt: - break - except: - print "FAILED!" +for s_log in source: + entries = get_entries(s_log["url"], first, last)["entries"] + print "\n\nSource: " + s_log["name"] + "\n" + for d_log in dests: + for item in entries: + print "Log: " + d_log["name"] + try: + entry = extract_original_entry(item) + if entry[2]: + precert = True + else: + precert = False + submission = [] + + for e in entry[0]: + submission.append(base64.b64encode(e)) + + if precert: + res = add_prechain(d_log["url"], {"chain" : submission}) + else: + res = add_chain(d_log["url"], {"chain" : submission}) + print_reply(res, entry, precert) + # time.sleep(5) + except KeyboardInterrupt: + sys.exit() + except: + print "FAILED!\n" |