From 1aa263a6c0402076f1619fbd2029c2a3742b2cfd Mon Sep 17 00:00:00 2001
From: Athou <jeremiepanzer@gmail.com>
Date: Mon, 3 Mar 2025 22:29:21 +0100
Subject: [PATCH] simplify UnitOfWork code

---
 .../com/commafeed/backend/dao/UnitOfWork.java | 24 +++++--------------
 1 file changed, 6 insertions(+), 18 deletions(-)

diff --git a/commafeed-server/src/main/java/com/commafeed/backend/dao/UnitOfWork.java b/commafeed-server/src/main/java/com/commafeed/backend/dao/UnitOfWork.java
index d69ad10b..a52e580f 100644
--- a/commafeed-server/src/main/java/com/commafeed/backend/dao/UnitOfWork.java
+++ b/commafeed-server/src/main/java/com/commafeed/backend/dao/UnitOfWork.java
@@ -1,5 +1,7 @@
 package com.commafeed.backend.dao;
 
+import java.util.concurrent.Callable;
+
 import jakarta.inject.Singleton;
 
 import io.quarkus.narayana.jta.QuarkusTransaction;
@@ -7,25 +9,11 @@ import io.quarkus.narayana.jta.QuarkusTransaction;
 @Singleton
 public class UnitOfWork {
 
-	public void run(SessionRunner runner) {
-		call(() -> {
-			runner.runInSession();
-			return null;
-		});
+	public void run(Runnable runnable) {
+		QuarkusTransaction.joiningExisting().run(runnable);
 	}
 
-	public <T> T call(SessionRunnerReturningValue<T> runner) {
-		return QuarkusTransaction.joiningExisting().call(runner::runInSession);
+	public <T> T call(Callable<T> callable) {
+		return QuarkusTransaction.joiningExisting().call(callable);
 	}
-
-	@FunctionalInterface
-	public interface SessionRunner {
-		void runInSession();
-	}
-
-	@FunctionalInterface
-	public interface SessionRunnerReturningValue<T> {
-		T runInSession();
-	}
-
 }