calculate prices from csv

src/book.py

@@ -834,6 +834,35 @@ def detect_exchange(self, file_path: Path) -> Optional[str]:
 
         return None
 
+    def get_price_from_csv(self):
+        print("hi")
+        for platform, operations_a in misc.group_by(
+            self.operations, "platform"
+        ).items():
+            for timestamp, operations_b in misc.group_by(
+                operations_a, "utc_time"
+            ).items():
+                if len(operations_b) > 1:
+                    buytr = selltr = None
+                    for operation in operations_b:
+                        if isinstance(operation, tr.Buy):
+                            buytr = operation
+                        elif isinstance(operation, tr.Sell):
+                            selltr = operation
+                        if buytr is not None and selltr is not None:
+                            price = decimal.Decimal(selltr.change / buytr.change)
+                            logging.debug(
+                                f"Added price from csv: {selltr.coin}/{buytr.coin} price: {price}"
+                            )
+                            self.price_data.set_price_db(
+                                platform,
+                                selltr.coin,
+                                buytr.coin,
+                                timestamp,
+                                price,
+                            )
+                            break
+
     def read_file(self, file_path: Path) -> None:
         """Import transactions form an account statement.
 

src/main.py

@@ -34,7 +34,7 @@ def main() -> None:
     if not status:
         log.warning("Stopping CoinTaxman.")
         return
-
+    book.get_price_from_csv()
     taxman.evaluate_taxation()
     taxman.export_evaluation_as_csv()
     taxman.print_evaluation()

src/price_data.py

@@ -550,7 +550,7 @@ def __set_price_db(
                     create_query = (
                         f"CREATE TABLE `{tablename}`"
                         "(utc_time DATETIME PRIMARY KEY, "
-                        "price FLOAT NOT NULL);"
+                        "price STR NOT NULL);"
                     )
                     cur.execute(create_query)
                     cur.execute(query, (utc_time, str(price)))
@@ -580,13 +580,19 @@ def set_price_db(
             price (decimal.Decimal): [description]
         """
         assert coin != reference_coin
+        if coin < reference_coin:
+            coin_a = coin
+            coin_b = reference_coin
+        else:
+            coin_a = reference_coin
+            coin_b = coin
         db_path = self.get_db_path(platform)
-        tablename = self.get_tablename(coin, reference_coin)
+        tablename = self.get_tablename(coin_a, coin_b)
         try:
             self.__set_price_db(db_path, tablename, utc_time, price)
         except sqlite3.IntegrityError as e:
             if str(e) == f"UNIQUE constraint failed: {tablename}.utc_time":
-                price_db = self.get_price(platform, coin, utc_time, reference_coin)
+                price_db = self.get_price(platform, coin_a, utc_time, coin_b)
                 if price != price_db:
                     log.warning(
                         "Tried to write price to database, "
@@ -627,15 +633,22 @@ def get_price(
             return decimal.Decimal("1")
 
         db_path = self.get_db_path(platform)
-        tablename = self.get_tablename(coin, reference_coin)
+        if coin < reference_coin:
+            coin_a = coin
+            coin_b = reference_coin
+            inverted = False
+        else:
+            coin_a = reference_coin
+            coin_b = coin
+            inverted = True
+        tablename = self.get_tablename(coin_a, coin_b)
 
         # Check if price exists already in our database.
         if (price := self.__get_price_db(db_path, tablename, utc_time)) is None:
             try:
                 get_price = getattr(self, f"_get_price_{platform}")
             except AttributeError:
                 raise NotImplementedError("Unable to read data from %s", platform)
-
             price = get_price(coin, utc_time, reference_coin, **kwargs)
             assert isinstance(price, decimal.Decimal)
             self.__set_price_db(db_path, tablename, utc_time, price)
@@ -646,7 +659,10 @@ def get_price(
             # Do not save price in database.
             price = self.__mean_price_db(db_path, tablename, utc_time)
 
-        return price
+        if inverted:
+            return decimal.Decimal(1 / price)
+        else:
+            return price
 
     def get_cost(
         self,