fix new db sync bug

This commit is contained in:
2026-08-05 15:27:49 +02:00
parent 3017be812d
commit d9d22011ca
+6
View File
@@ -38,6 +38,9 @@ def sync_account(conn, account, href_to_uid_cache: dict):
else: else:
logger.warning("[%s] vCard konnte nicht geparst werden, überspringe", account.name) logger.warning("[%s] vCard konnte nicht geparst werden, überspringe", account.name)
db.replace_all_contacts_for_account(conn, account.name, contacts, run_id) db.replace_all_contacts_for_account(conn, account.name, contacts, run_id)
_, _, _, new_token = client.sync_collection(collection_url, None)
if new_token:
db.save_sync_token(conn, account.name, new_token)
db.finish_sync_run(conn, run_id, "success", upserted=len(contacts), deleted=0) db.finish_sync_run(conn, run_id, "success", upserted=len(contacts), deleted=0)
logger.info("[%s] Initialer Sync abgeschlossen: %d Kontakte", account.name, len(contacts)) logger.info("[%s] Initialer Sync abgeschlossen: %d Kontakte", account.name, len(contacts))
return return
@@ -56,6 +59,9 @@ def sync_account(conn, account, href_to_uid_cache: dict):
else: else:
logger.warning("[%s] vCard konnte nicht geparst werden, überspringe", account.name) logger.warning("[%s] vCard konnte nicht geparst werden, überspringe", account.name)
db.replace_all_contacts_for_account(conn, account.name, contacts, run_id) db.replace_all_contacts_for_account(conn, account.name, contacts, run_id)
_, _, _, new_token = client.sync_collection(collection_url, None)
if new_token:
db.save_sync_token(conn, account.name, new_token)
db.finish_sync_run(conn, run_id, "success", upserted=len(contacts), deleted=0) db.finish_sync_run(conn, run_id, "success", upserted=len(contacts), deleted=0)
logger.info("[%s] Re-Sync abgeschlossen: %d Kontakte", account.name, len(contacts)) logger.info("[%s] Re-Sync abgeschlossen: %d Kontakte", account.name, len(contacts))
return return