@@ -52,7 +52,7 @@ def start_bot(self):
52
52
53
53
for trade in trades [:]:
54
54
if trade .is_completed ():
55
- self .move_completed_trade (trade . symbol )
55
+ self .move_completed_trade (trade )
56
56
if not trade_validator .validate (trade ):
57
57
self .logError ('{}:{}' .format (trade .symbol , trade_validator .errors ))
58
58
if len (trade_validator .warnings ) > 0 :
@@ -160,10 +160,9 @@ def check_files_changed(self):
160
160
self .logInfo ('New file detected "{}". Updating trades...' .format (file ))
161
161
update_cloud_files = True
162
162
trades = self .config_loader .load_trade_list (file )
163
- base_dir = os .path .split (file )[0 ]
164
163
for t in trades :
165
164
#if file needs to be adjusted to the new format
166
- new_file_name = os .path .join (base_dir , Utils .get_file_name (t ))
165
+ new_file_name = os .path .join (self . trades_path , Utils .get_file_name (t ))
167
166
if new_file_name != file :
168
167
self .file_watch_list [new_file_name ] = os .stat (new_file_name ).st_mtime
169
168
self .file_watch_list .pop (file , None )
@@ -185,24 +184,22 @@ def check_files_changed(self):
185
184
186
185
def on_trade_updated_by_handler (self , trade : Trade , needs_cloud_sync = True ):
187
186
with self .lock :
188
- file = self .get_file_path (self .trades_path , trade . symbol )
187
+ file = self .get_file_path (self .trades_path , trade )
189
188
190
189
self .config_loader .persist_updated_trade (trade , self .config_loader .json_saver (file ))
191
190
192
191
self .file_watch_list [file ] = os .stat (file ).st_mtime
193
192
194
193
if trade .is_completed ():
195
- self .move_completed_trade (trade . symbol )
194
+ self .move_completed_trade (trade )
196
195
197
196
if self .enable_cloud and needs_cloud_sync :
198
197
self .s3pers .sync (True , True )
199
198
200
- def move_completed_trade (self , symbol ):
201
- shutil .move (self .get_file_path (self .trades_path , symbol ),
202
- self .get_file_path (self .completed_trades_path , symbol , datetime .now ().strftime ('%Y-%m-%d_%H-%M-' )))
199
+ def move_completed_trade (self , trade ):
200
+ shutil .move (self .get_file_path (self .trades_path , trade ),
201
+ self .get_file_path (self .completed_trades_path , trade , datetime .now ().strftime ('%Y-%m-%d_%H-%M-' )))
203
202
204
203
205
- def get_file_path (self , path , symbol , time = '' ):
206
- # TRADE_FILE_PATH_PATTERN = '{path}{time}{symbol}.json'
207
- return os .path .join (path , '{time}{symbol}.json' .format (symbol = symbol , time = time ))
208
- # return ConsoleLauncher.TRADE_FILE_PATH_PATTERN.format(path=path, symbol=symbol, time=time)
204
+ def get_file_path (self , path , trade , time = '' ):
205
+ return os .path .join (path , '{time}{fn}' .format (fn = Utils .get_file_name (trade ), time = time ))
0 commit comments