infinimotion/backend
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

transactions

Browse Source
This commit is contained in:
Lennart Heinrich
2025-10-24 00:48:20 +02:00
parent 0dfc3441ac
commit b55b334794
5 changed files with 8 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pom.xml
View File

@@ -35,7 +35,7 @@
<dependency> <dependency>
<groupId>de.infinimotion</groupId> <groupId>de.infinimotion</groupId>
<artifactId>model-backend</artifactId> <artifactId>model-backend</artifactId>
<version>0.0.38</version> <version>0.0.54</version>
</dependency> </dependency>
<!-- Quarkus --> <!-- Quarkus -->

2
src/main/java/de/infinimotion/backend/BetterRequestReply.java
View File

@@ -1,6 +1,5 @@
package de.infinimotion.backend; package de.infinimotion.backend;
import de.infinimotion.model.backend.Command;
import de.infinimotion.model.backend.CommandException; import de.infinimotion.model.backend.CommandException;
import de.infinimotion.model.backend.CommandWrapper; import de.infinimotion.model.backend.CommandWrapper;
import jakarta.enterprise.context.ApplicationScoped; import jakarta.enterprise.context.ApplicationScoped;
@@ -12,7 +11,6 @@ import java.io.IOException;
import java.util.Map; import java.util.Map;
import java.util.UUID; import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutionException;
import java.util.concurrent.atomic.AtomicReference; import java.util.concurrent.atomic.AtomicReference;

16
src/main/java/de/infinimotion/backend/RequestResource.java
View File

@@ -1,13 +1,10 @@
package de.infinimotion.backend; 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 de.infinimotion.model.backend.*;
import jakarta.enterprise.context.ApplicationScoped; import jakarta.enterprise.context.ApplicationScoped;
import jakarta.inject.Inject; import jakarta.inject.Inject;
import jakarta.ws.rs.GET; import jakarta.ws.rs.GET;
import jakarta.ws.rs.POST;
import jakarta.ws.rs.Path; import jakarta.ws.rs.Path;
import jakarta.ws.rs.QueryParam; import jakarta.ws.rs.QueryParam;
import org.eclipse.microprofile.reactive.messaging.*; import org.eclipse.microprofile.reactive.messaging.*;
@@ -27,18 +24,17 @@ public class RequestResource {
@Path("/kinosaal") @Path("/kinosaal")
public List<Kinosaal> listKinosaal() throws IOException, ExecutionException, InterruptedException { public List<Kinosaal> listKinosaal() throws IOException, ExecutionException, InterruptedException {
CommandListKinosaal request = new CommandListKinosaal(); CommandListKinosaal request = new CommandListKinosaal();
CommandWrapper response = requester.request(request.serialize().generateIds().commit());
CommandWrapper response = requester.request(request.serialize().generateIds());
return CommandListKinosaalResponse.deserialize(response).getList(); return CommandListKinosaalResponse.deserialize(response).getList();
} }
@GET @POST
@Path("/kinosaal/create") @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(); 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(); return CommandCreateKinosaalResponse.deserialize(response).getHall();
} }

9
src/main/java/de/infinimotion/backend/Utils.java
View File

@@ -1,9 +0,0 @@
package de.infinimotion.backend;
import de.infinimotion.model.backend.Command;
import java.util.UUID;
public class Utils {
}

1
src/main/resources/application.properties
View File

@@ -1,3 +1,4 @@
%dev.quarkus.http.port=8080
quarkus.http.port=7080 quarkus.http.port=7080
quarkus.http.root-path=/api/ quarkus.http.root-path=/api/