X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=market.py;h=2ddebfac3795ebc51167676255e16e4113a834a5;hb=718e3e919acb9b57269d3155543f9e8ad1b91324;hp=388dea0cadb1265f966c1aa4afe2c66b85f93c26;hpb=ada1b5f109ebaa6f3adb7cd87b007c6db891811c;p=perso%2FImmae%2FProjets%2FCryptomonnaies%2FCryptoportfolio%2FTrader.git diff --git a/market.py b/market.py index 388dea0..2ddebfa 100644 --- a/market.py +++ b/market.py @@ -46,11 +46,14 @@ class Market: return cls(ccxt_instance, debug=debug, user_id=user_id, report_path=report_path) def store_report(self): + self.report.merge(Portfolio.report) try: if self.report_path is not None: - report_file = "{}/{}_{}.json".format(self.report_path, datetime.now().isoformat(), self.user_id) - with open(report_file, "w") as f: + report_file = "{}/{}_{}".format(self.report_path, datetime.now().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: + f.write("\n".join(map(lambda x: x[1], self.report.print_logs))) except Exception as e: print("impossible to store report file: {}; {}".format(e.__class__.__name__, e)) @@ -192,6 +195,33 @@ class Market: class Processor: scenarios = { + "wait_for_cryptoportfolio": [ + { + "name": "wait", + "number": 1, + "before": False, + "after": True, + "wait_for_recent": {}, + }, + ], + "print_orders": [ + { + "name": "wait", + "number": 1, + "before": False, + "after": True, + "wait_for_recent": {}, + }, + { + "name": "make_orders", + "number": 2, + "before": False, + "after": True, + "fetch_balances": ["begin"], + "prepare_trades": { "compute_value": "average" }, + "prepare_orders": { "compute_value": "average" }, + }, + ], "sell_needed": [ { "name": "wait",