Merge branch 'feat/objectify-ccxt' into feature/catch-exchange-errors

freqtrade/exchange/__init__.py

@@ -3,6 +3,7 @@
 import logging
 from random import randint
 from typing import List, Dict, Any, Optional
+from datetime import datetime
 
 import ccxt
 import arrow
@@ -134,7 +135,8 @@ def buy(pair: str, rate: float, amount: float) -> Dict:
             'side': 'buy',
             'remaining': 0.0,
             'datetime': arrow.utcnow().isoformat(),
-            'status': 'closed'
+            'status': 'closed',
+            'fee': None
         }
         return {'id': order_id}
 
@@ -324,6 +326,25 @@ def get_order(order_id: str, pair: str) -> Dict:
 
 
 @retrier
+def get_trades_for_order(order_id: str, pair: str, since: datetime) -> List:
+    if _CONF['dry_run']:
+        return []
+    if not exchange_has('fetchMyTrades'):
+        return []
+    try:
+        my_trades = _API.fetch_my_trades(pair, since.timestamp())
+        matched_trades = [trade for trade in my_trades if trade['order'] == order_id]
+
+        return matched_trades
+
+    except ccxt.NetworkError as e:
+        raise TemporaryError(
+            'Could not get trades due to networking error. Message: {}'.format(e)
+        )
+    except ccxt.BaseError as e:
+        raise OperationalException(e)
+
+
 def get_pair_detail_url(pair: str) -> str:
     try:
         url_base = _API.urls.get('www')
@@ -371,3 +392,13 @@ def get_fee(symbol='ETH/BTC', type='', side='', amount=1,
                 e.__class__.__name__, e))
     except ccxt.BaseError as e:
         raise OperationalException(e)
+
+
+def get_amount_lots(pair: str, amount: float) -> float:
+    """
+    get buyable amount rounding, ..
+    """
+    # validate that markets are loaded before trying to get fee
+    if not _API.markets:
+        _API.load_markets()
+    return _API.amount_to_lots(pair, amount)