X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=market.py;h=7a37cf622aed28899f4815cd1b388e89e0a98a34;hb=1d72880c097ea8259ce9cc63cfe55e6cc7516bd2;hp=10d1ad8936b3f671ca2ca7e9a1623a856dce29db;hpb=90d7423eec074a0ed0af680c223180f8d7e1d4e6;p=perso%2FImmae%2FProjets%2FCryptomonnaies%2FCryptoportfolio%2FTrader.git diff --git a/market.py b/market.py index 10d1ad8..7a37cf6 100644 --- a/market.py +++ b/market.py @@ -5,6 +5,7 @@ import psycopg2 from store import * from cachetools.func import ttl_cache from datetime import datetime +import datetime from retry import retry import portfolio @@ -25,11 +26,10 @@ class Market: self.balances = BalanceStore(self) self.processor = Processor(self) - for key in ["user_id", "market_id", "report_path", "pg_config"]: + for key in ["user_id", "market_id", "pg_config"]: setattr(self, key, kwargs.get(key, None)) - self.report.log_market(self.args, self.user_id, self.market_id, - self.report_path, self.debug) + self.report.log_market(self.args) @classmethod def from_config(cls, config, args, **kwargs): @@ -41,15 +41,15 @@ class Market: def store_report(self): self.report.merge(Portfolio.report) - date = datetime.now() - if self.report_path is not None: + date = datetime.datetime.now() + if self.args.report_path is not None: self.store_file_report(date) - if self.pg_config is not None: + if self.pg_config is not None and self.args.report_db: self.store_database_report(date) def store_file_report(self, date): try: - report_file = "{}/{}_{}".format(self.report_path, date.isoformat(), self.user_id) + report_file = "{}/{}_{}".format(self.args.report_path, date.isoformat(), self.user_id) with open(report_file + ".json", "w") as f: f.write(self.report.to_json()) with open(report_file + ".log", "w") as f: