1 files changed, 66 insertions, 0 deletions
diff --git a/monitor/josef_mover.py b/monitor/josef_mover.py
new file mode 100755
index 0000000..3de0cb4
--- /dev/null
+++ b/monitor/josef_mover.py
@@ -0,0 +1,66 @@
+#!/usr/bin/python
+# -*- coding: utf-8 -*-     
+
+import sys
+import time
+import datetime
+import os
+import json
+
+from monitor_conf import *
+from josef_lib import *
+
+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 res
+
+    print "Time:", t
+
+    for log in ctlogs:
+        if str(log_id) == log["id"]:
+            l = log
+            break
+    else:
+        l = {"name" : "Log not found" + log_id}
+    
+    print "Log:", l["name"]
+
+    # check_sct_signature(log["url"], entry, rep, precert, log["key"])
+
+    # print "Signature: CHECKING NOT IMPLEMENTED YET!"
+    # print ""
+
+
+source = ctlogs[0]
+dests = [ctlogs[8]]
+
+first = 20001
+last = 20100
+
+entries = get_entries(source["url"], first, last)["entries"]
+
+# print entries
+
+for log in dests:
+    for item in entries:
+        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)
+
+
+