From b55b3347944d4ec809588091d4dcef6c66817e4d Mon Sep 17 00:00:00 2001 From: Lennart Heinrich Date: Fri, 24 Oct 2025 00:48:20 +0200 Subject: [PATCH] transactions --- pom.xml | 2 +- .../infinimotion/backend/BetterRequestReply.java | 2 -- .../de/infinimotion/backend/RequestResource.java | 16 ++++++---------- src/main/java/de/infinimotion/backend/Utils.java | 9 --------- src/main/resources/application.properties | 1 + 5 files changed, 8 insertions(+), 22 deletions(-) delete mode 100644 src/main/java/de/infinimotion/backend/Utils.java diff --git a/pom.xml b/pom.xml index 21e9cb4..c83abe3 100644 --- a/pom.xml +++ b/pom.xml @@ -35,7 +35,7 @@ de.infinimotion model-backend - 0.0.38 + 0.0.54 diff --git a/src/main/java/de/infinimotion/backend/BetterRequestReply.java b/src/main/java/de/infinimotion/backend/BetterRequestReply.java index a283b54..e7567e9 100644 --- a/src/main/java/de/infinimotion/backend/BetterRequestReply.java +++ b/src/main/java/de/infinimotion/backend/BetterRequestReply.java @@ -1,6 +1,5 @@ package de.infinimotion.backend; -import de.infinimotion.model.backend.Command; import de.infinimotion.model.backend.CommandException; import de.infinimotion.model.backend.CommandWrapper; import jakarta.enterprise.context.ApplicationScoped; @@ -12,7 +11,6 @@ import java.io.IOException; import java.util.Map; import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; -import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ExecutionException; import java.util.concurrent.atomic.AtomicReference; diff --git a/src/main/java/de/infinimotion/backend/RequestResource.java b/src/main/java/de/infinimotion/backend/RequestResource.java index 7f68288..8abd743 100644 --- a/src/main/java/de/infinimotion/backend/RequestResource.java +++ b/src/main/java/de/infinimotion/backend/RequestResource.java @@ -1,13 +1,10 @@ package de.infinimotion.backend; -import com.fasterxml.jackson.annotation.JsonAutoDetect; -import com.fasterxml.jackson.annotation.PropertyAccessor; -import com.fasterxml.jackson.databind.ObjectMapper; -import com.fasterxml.jackson.databind.SerializationFeature; import de.infinimotion.model.backend.*; import jakarta.enterprise.context.ApplicationScoped; import jakarta.inject.Inject; import jakarta.ws.rs.GET; +import jakarta.ws.rs.POST; import jakarta.ws.rs.Path; import jakarta.ws.rs.QueryParam; import org.eclipse.microprofile.reactive.messaging.*; @@ -27,18 +24,17 @@ public class RequestResource { @Path("/kinosaal") public List listKinosaal() throws IOException, ExecutionException, InterruptedException { CommandListKinosaal request = new CommandListKinosaal(); - - CommandWrapper response = requester.request(request.serialize().generateIds()); + CommandWrapper response = requester.request(request.serialize().generateIds().commit()); return CommandListKinosaalResponse.deserialize(response).getList(); } - @GET + @POST @Path("/kinosaal/create") - public Kinosaal createKinosaal(@QueryParam("name") String name) throws IOException, ExecutionException, InterruptedException { + public Kinosaal createKinosaal(Kinosaal hall) throws IOException, ExecutionException, InterruptedException { CommandCreateKinosaal request = new CommandCreateKinosaal(); - request.setName(name); + request.setName(hall.getName()); - CommandWrapper response = requester.request(request.serialize().generateIds()); + CommandWrapper response = requester.request(request.serialize().generateIds().commit()); return CommandCreateKinosaalResponse.deserialize(response).getHall(); } diff --git a/src/main/java/de/infinimotion/backend/Utils.java b/src/main/java/de/infinimotion/backend/Utils.java deleted file mode 100644 index 93e3784..0000000 --- a/src/main/java/de/infinimotion/backend/Utils.java +++ /dev/null @@ -1,9 +0,0 @@ -package de.infinimotion.backend; - -import de.infinimotion.model.backend.Command; - -import java.util.UUID; - -public class Utils { - -} diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties index 0f285a1..78fd63a 100644 --- a/src/main/resources/application.properties +++ b/src/main/resources/application.properties @@ -1,3 +1,4 @@ +%dev.quarkus.http.port=8080 quarkus.http.port=7080 quarkus.http.root-path=/api/