aboutsummaryrefslogtreecommitdiffstats
path: root/python/mtm_upload.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/mtm_upload.py')
-rw-r--r--python/mtm_upload.py34
1 files changed, 0 insertions, 34 deletions
diff --git a/python/mtm_upload.py b/python/mtm_upload.py
deleted file mode 100644
index f97bd908..00000000
--- a/python/mtm_upload.py
+++ /dev/null
@@ -1,34 +0,0 @@
-from io import StringIO
-import csv
-from serenitas.utils.env import DAILY_DIR
-from serenitas.utils.remote import SftpClient
-import datetime
-from trade_dataclasses import CDSDeal, SwaptionDeal, TerminationDeal
-from headers import MTM_HEADERS
-
-deal_registry = {
- "cds": CDSDeal,
- "swaption": SwaptionDeal,
- "termination": TerminationDeal,
-}
-
-
-def mtm_process_upload(tradeids, product_type):
- objs = [
- deal_registry[product_type].from_tradeid(tradeid).to_markit()
- for tradeid in tradeids
- ]
- buf = StringIO()
- csvwriter = csv.writer(buf)
- csvwriter.writerow(MTM_HEADERS[product_type])
- csvwriter.writerows(
- [obj.get(h, None) for h in MTM_HEADERS[product_type]] for obj in objs
- )
- buf = buf.getvalue().encode()
- fname = (
- f"MTM.{datetime.datetime.now():%Y%m%d.%H%M%S}.{product_type.capitalize()}.csv"
- )
- sftp = SftpClient.from_creds("mtm")
- sftp.put(buf, fname)
- dest = DAILY_DIR / str(datetime.date.today()) / fname
- dest.write_bytes(buf)