Migrate TaxRuleSyncAdapter

Author: antweb

libpretixsync/src/main/java/eu/pretix/libpretixsync/sync/SyncManager.java

@@ -426,7 +426,7 @@ protected void downloadData(ProgressFeedback feedback, Boolean skip_orders, Stri
                 download(new QuestionSyncAdapter(dataStore, fileStorage, eventSlug, api, configStore.getSyncCycleId(), feedback));
                 if (profile == Profile.PRETIXPOS) {
                     download(new QuotaSyncAdapter(dataStore, fileStorage, eventSlug, api, configStore.getSyncCycleId(), feedback, subEvent));
-                    download(new TaxRuleSyncAdapter(dataStore, fileStorage, eventSlug, api, configStore.getSyncCycleId(), feedback));
+                    download(new TaxRuleSyncAdapter(db, fileStorage, eventSlug, api, configStore.getSyncCycleId(), feedback));
                     download(new TicketLayoutSyncAdapter(dataStore, fileStorage, eventSlug, api, configStore.getSyncCycleId(), feedback));
                 }
                 download(new BadgeLayoutSyncAdapter(dataStore, fileStorage, eventSlug, api, configStore.getSyncCycleId(), feedback));

libpretixsync/src/main/java/eu/pretix/libpretixsync/sync/TaxRuleSyncAdapter.java

@@ -0,0 +1,77 @@
+package eu.pretix.libpretixsync.sync
+
+import app.cash.sqldelight.TransactionWithoutReturn
+import app.cash.sqldelight.db.QueryResult
+import eu.pretix.libpretixsync.api.PretixApi
+import eu.pretix.libpretixsync.sqldelight.SyncDatabase
+import eu.pretix.libpretixsync.sqldelight.TaxRule
+import eu.pretix.libpretixsync.sync.SyncManager.ProgressFeedback
+import org.json.JSONObject
+
+class TaxRuleSyncAdapter(
+    db: SyncDatabase,
+    fileStorage: FileStorage,
+    eventSlug: String,
+    api: PretixApi,
+    syncCycleId: String,
+    feedback: ProgressFeedback?,
+) : SqBaseConditionalSyncAdapter<TaxRule, Long>(
+    db = db,
+    fileStorage = fileStorage,
+    eventSlug = eventSlug,
+    api = api,
+    syncCycleId = syncCycleId,
+    feedback = feedback,
+) {
+    override fun queryKnownIDs(): MutableSet<Long>? {
+        val res = mutableSetOf<Long>()
+        db.taxRuleQueries.selectServerIdsByEventSlug(eventSlug).execute { cursor ->
+            while (cursor.next().value) {
+                val id = cursor.getLong(0) ?: throw RuntimeException("id column not available")
+                res.add(id)
+            }
+            QueryResult.Unit
+        }
+
+        return res
+    }
+
+    override fun getResourceName(): String = "taxrules"
+
+    override fun getId(obj: JSONObject): Long = obj.getLong("id")
+
+    override fun runInTransaction(body: TransactionWithoutReturn.() -> Unit) {
+        db.taxRuleQueries.transaction(false, body)
+    }
+
+    override fun insert(jsonobj: JSONObject) {
+        db.taxRuleQueries.insert(
+            event_slug = eventSlug,
+            json_data = jsonobj.toString(),
+            server_id = jsonobj.getLong("id"),
+        )
+    }
+
+    override fun update(obj: TaxRule, jsonobj: JSONObject) {
+        db.taxRuleQueries.updateFromJson(
+            event_slug = eventSlug,
+            json_data = jsonobj.toString(),
+            id = obj.id,
+        )
+    }
+
+    override fun runBatch(parameterBatch: List<Long>): List<TaxRule> =
+        db.taxRuleQueries.selectByServerIdListAndEventSlug(
+            server_id = parameterBatch,
+            event_slug = eventSlug,
+        ).executeAsList()
+
+    override fun getJSON(obj: TaxRule): JSONObject = JSONObject(obj.json_data!!)
+
+    override fun delete(key: Long) {
+        db.taxRuleQueries.deleteByServerId(key)
+    }
+
+    override fun getId(obj: TaxRule): Long = obj.server_id!!
+
+}

libpretixsync/src/main/java/eu/pretix/libpretixsync/sync/TaxRuleSyncAdapter.kt

@@ -7,3 +7,35 @@ selectByServerId:
 SELECT *
 FROM TaxRule
 WHERE server_id = ?;
+
+selectByServerIdListAndEventSlug:
+SELECT *
+FROM TaxRule
+WHERE server_id IN ? AND event_slug = ?;
+
+selectServerIdsByEventSlug:
+SELECT server_id
+FROM TaxRule
+WHERE event_slug = ?;
+
+deleteByServerId:
+DELETE FROM TaxRule
+WHERE server_id = ?;
+
+insert:
+INSERT INTO TaxRule(
+    event_slug,
+    json_data,
+    server_id
+) VALUES (
+    ?,
+    ?,
+    ?
+);
+
+updateFromJson:
+UPDATE TaxRule
+SET
+    event_slug = ?,
+    json_data = ?
+WHERE id = ?;