Fix (global.db): Test consistency with updates

Signed-off-by: OjusWiZard <ojuswimail@gmail.com>
rotki · May 21, 2024 · 62d32a1 · 62d32a1
1 parent 9d3691b
commit 62d32a1
Show file tree

Hide file tree

Showing 3 changed files with 354 additions and 4 deletions.
diff --git a/rotkehlchen/data/global.db b/rotkehlchen/data/global.db
diff --git a/rotkehlchen/globaldb/updates.py b/rotkehlchen/globaldb/updates.py
@@ -434,7 +434,14 @@ def _handle_asset_update(
 
         try:
             with connection.savepoint_ctx() as cursor:
-                executeall(cursor, action)
+                if action.strip().startswith('UPDATE') and cursor.execute(
+                    'SELECT COUNT(*) FROM assets WHERE identifier=?',
+                    (remote_asset_data.identifier,),
+                ).fetchone()[0] == 0:
+                    executeall(cursor, full_insert)
+                else:
+                    executeall(cursor, action)
+
                 if local_asset is not None:
                     AssetResolver().clean_memory_cache(identifier=local_asset.identifier)
         except sqlite3.Error:  # https://docs.python.org/3/library/sqlite3.html#exceptions