1 files changed, 31 insertions, 0 deletions
diff --git a/python/bowdst_wire.py b/python/bowdst_wire.py
new file mode 100644
index 00000000..4e8c99f0
--- /dev/null
+++ b/python/bowdst_wire.py
@@ -0,0 +1,31 @@
+from bowdst import get_dir, download_messages
+from csv import DictReader
+from citco_ops.bowdst import BowdstWire
+import datetime
+
+
+def load_wire_report(workdate: datetime.date):
+    p = get_dir(workdate) / f"BowdstWires_{workdate:%d %b %Y}.csv"
+    with open(p) as fh:
+        reader = DictReader(fh)
+        for line in reader:
+            BowdstWire.from_nexen_line(line).stage()
+        BowdstWire.commit()
+
+
+if __name__ == "__main__":
+    import argparse
+    from serenitas.utils.exchange import ExchangeMessage
+
+    parser = argparse.ArgumentParser()
+    parser.add_argument(
+        "workdate",
+        nargs="?",
+        type=datetime.date.fromisoformat,
+        default=datetime.date.today(),
+        help="working date",
+    )
+    args = parser.parse_args()
+    em = ExchangeMessage()
+    download_messages(em)
+    load_wire_report(args.workdate)