Migrate the SRA demo package (io.narayana.sra.demo) over to the [quic…

rts/at/README.md

@@ -77,3 +77,6 @@ Demonstrator
 An example using the ruby language showing how to start and end a transaction using REST style semantics
 and how services can recover from failures during the commitment protocol.
 
+Annotations
+============
+A quickstart that demonstrates how to use REST-AT annotations to define transactional microservices.

rts/at/annotation/README.md

@@ -0,0 +1,45 @@
+OVERVIEW
+--------
+A example that demonstrates how to use [REST-AT annotations](https://github.com/jbosstm/narayana/tree/main/rts/at/tx/src/main/java/org/jboss/jbossts/star/annotation) to define transactional microservices.
+
+USAGE
+--------------------
+
+Prior to running the example make sure that the [REST-AT coordinator is deployed](../README.md#usage).
+
+Once REST-AT coordinator is deployed build and run the annotation example application to run on port 8082, 8083 and 8084 as it in configured in application.properties
+
+    cd <narayana-repo>/rts/at/annotation/
+    mvn clean package -DskipTests
+    java -jar flight-service/target/quarkus-app/quarkus-run.jar &
+    java -jar hotel-service/target/quarkus-app/quarkus-run.jar &
+    java -jar trip-service/target/quarkus-app/quarkus-run.jar &
+
+Book a trip within a transaction, refer to the [`bookTrip` method in the trip service](./trip-service/src/main/java/io/narayana/sra/demo/api/TripController.java) to see how it is annotated. The following curl command will invoke the resource.
+
+    curl -XPOST http://localhost:8082/trip/book?hotelName=Rex&flightNumber=123
+    curl http://localhost:8082/trip/status?sraId={paste sraId here}
+
+
+
+Since the `bookTrip` resource is annotated with `@SRA(value = SRA.Type.REQUIRED)`, the curl request will start a new REST-AT transaction and you can verify that it is running by querying the coordinator:  `curl http://localhost:8080/rest-at-coordinator/tx/transaction-manager`.
+
+EXPECTED OUTPUT
+---------------
+    SRA: 0_ffff0ad775f3_-2e0999fe_64d0a461_3f8: Updating flight participant state to: TransactionPrepared
+    SRA: 0_ffff0ad775f3_-2e0999fe_64d0a461_3f8: Updating hotel participant state to: TransactionPrepared
+    SRA: 0_ffff0ad775f3_-2e0999fe_64d0a461_3f8: Updating trip participant state to: TransactionPrepared
+    SRA: 0_ffff0ad775f3_-2e0999fe_64d0a461_3f8: Updating trip participant state to: TransactionCommitted
+    SRA: 0_ffff0ad775f3_-2e0999fe_64d0a461_3f8: Updating hotel participant state to: TransactionCommitted
+    SRA: 0_ffff0ad775f3_-2e0999fe_64d0a461_3f8: Updating flight participant state to: TransactionCommitted
+    {"cancelPending":false,"details":[{"cancelPending":false,"details":[],"encodedId":"0_ffff0ad775f3_-2e0999fe_64d0a461_3f8","id":"0_ffff0ad775f3_-2e0999fe_64d0a461_3f8","name":"Rex","quantity":1,"sraId":"http://localhost:8080/rest-at-coordinator/tx/transaction-manager/0_ffff0ad775f3_-2e0999fe_64d0a461_3f8","status":"PROVISIONAL","type":"Hotel"},{"cancelPending":false,"details":[],"encodedId":"0_ffff0ad775f3_-2e0999fe_64d0a461_3f8","id":"0_ffff0ad775f3_-2e0999fe_64d0a461_3f8","name":"456","quantity":1,"sraId":"http://localhost:8080/rest-at-coordinator/tx/transaction-manager/0_ffff0ad775f3_-2e0999fe_64d0a461_3f8","status":"PROVISIONAL","type":"Flight"}],"encodedId":"0_ffff0ad775f3_-2e0999fe_64d0a461_3f8","id":"0_ffff0ad775f3_-2e0999fe_64d0a461_3f8","name":"Aggregate Booking","quantity":1,"sraId":"http://localhost:8080/rest-at-coordinator/tx/transaction-manager/0_ffff0ad775f3_-2e0999fe_64d0a461_3f8","status":"CONFIRMED","type":"Trip"}
+    Confirming tripBooking id 0_ffff0ad775f3_-2e0999fe_64d0a461_4a4 (Aggregate Booking) status: CONFIRMED
+
+WHAT JUST HAPPENED?
+-------------------
+
+1. Build and run the REST-AT annotation application, it starts all three microservice on different port i.e 8082, 8083 and 8084 which is configured in application.properties such as in [flight-service](flight-service/src/main/resources/application.properties), [hotel-service](hotel-service/src/main/resources/application.properties) and [trip-service](flight-service/src/main/resources/application.properties).
+
+2. Invoke book trip which start REST-AT transaction and calls individual hotel and flight service issuing the POST request to the trip service.
+
+> **_NOTE:_** The quickstart marks the services as REST-AT aware participants because they are extending a [helper](https://github.com/jbosstm/narayana/blob/main/rts/at/tx/src/main/java/org/jboss/jbossts/star/client/SRAParticipant.java) class that provides the relevant REST-AT support.

rts/at/annotation/common-service/pom.xml

@@ -0,0 +1,19 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+  <parent>
+    <groupId>org.jboss.narayana.quickstart.rts</groupId>
+    <artifactId>annotation</artifactId>
+    <version>7.0.1.Final-SNAPSHOT</version>
+  </parent>
+  <groupId>org.jboss.narayana.quickstart.rts</groupId>
+  <artifactId>common-service</artifactId>
+  <packaging>jar</packaging>
+  <name>common-service</name>
+  <dependencies>
+    <dependency>
+      <groupId>com.fasterxml.jackson.core</groupId>
+      <artifactId>jackson-annotations</artifactId>
+    </dependency>
+  </dependencies>
+</project>

rts/at/annotation/common-service/src/main/java/io/narayana/sra/demo/constant/ServiceConstant.java

@@ -0,0 +1,22 @@
+package io.narayana.sra.demo.constant;
+
+public class ServiceConstant {
+    public static final String HOTEL_PATH = "/hotel";
+    public static final String HOTEL_NAME_PARAM = "hotelName";
+    public static final String HOTEL_BEDS_PARAM = "beds";
+
+    public static final String FLIGHT_PATH = "/flight";
+    public static final String FLIGHT_NUMBER_PARAM = "flightNumber";
+    public static final String ALT_FLIGHT_NUMBER_PARAM = "altFlightNumber";
+    public static final String FLIGHT_SEATS_PARAM = "flightSeats";
+
+    public static final String TRIP_PATH = "/trip";
+    public static final String SERVICE_PORT_PROPERTY = "quarkus.http.port";
+
+    public static final String HOTEL_SERVICE_PORT_PROPERTY = "hotel.quarkus.http.port";
+
+    public static final String FLIGHT_SERVICE_PORT_PROPERTY = "flight.quarkus.http.port";
+
+    public static final String BOOKING_ID = "bookingId";
+    public static final String SRA_ID = "sraId";
+}

rts/at/annotation/common-service/src/main/java/io/narayana/sra/demo/model/Booking.java

@@ -0,0 +1,242 @@
+package io.narayana.sra.demo.model;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import java.io.IOException;
+import java.io.UnsupportedEncodingException;
+import java.lang.reflect.Array;
+import java.net.URLEncoder;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.List;
+import java.util.stream.IntStream;
+
+public class Booking {
+    @JsonProperty("id")
+    private String id;
+
+    @JsonProperty("sraId")
+    private String sraId;
+    @JsonProperty("name")
+    private String name;
+    @JsonProperty("quantity")
+    private Integer quantity;
+    @JsonProperty("status")
+    private BookingStatus status;
+    @JsonProperty("type")
+    private String type;
+    @JsonProperty("details")
+    private Booking[] details;
+
+    private IOException decodingException;
+
+    public Booking() {
+        this("", "", 0, "");
+    }
+
+    public Booking(String id, String name, Integer quantity, String type) {
+        this(id, name, quantity, type, BookingStatus.PROVISIONAL, null);
+    }
+
+    public Booking(String id, String type, Booking... bookings) {
+        this(id, "Aggregate Booking", 1, type, BookingStatus.PROVISIONAL, bookings);
+    }
+
+    @JsonCreator
+    public Booking(@JsonProperty("id") String id,
+                   @JsonProperty("name") String name,
+                   @JsonProperty("quantity") Integer quantity,
+                   @JsonProperty("type") String type,
+                   @JsonProperty("status") BookingStatus status,
+                   @JsonProperty("details") Booking[] details) {
+
+        init(id, name, quantity, type, status, details);
+    }
+
+    public Booking(IOException decodingException) {
+        this.decodingException = decodingException;
+    }
+
+    public Booking(Booking booking) {
+        this.init(booking.getId(), booking.getName(), booking.getQuantity(), booking.getType(), booking.getStatus(), null);
+
+        details = new Booking[booking.getDetails().length];
+
+        IntStream.range(0, details.length).forEach(i -> details[i] = new Booking(booking.getDetails()[i]));
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public void setQuantity(Integer quantity) {
+        this.quantity = quantity;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+
+    public void setDetails(Booking[] details) {
+        this.details = details;
+    }
+
+    public void setDecodingException(IOException decodingException) {
+        this.decodingException = decodingException;
+    }
+
+    public static Booking fromJson(String json) {
+        try {
+            return new ObjectMapper().readValue(json, Booking.class);
+        } catch (IOException e) {
+            return new Booking(e);
+        }
+    }
+
+    public static List<Booking> listFromJson(String json) throws IOException {
+        ObjectMapper mapper = new ObjectMapper();
+
+        return Arrays.asList(mapper.readValue(json, Booking[].class));
+    }
+
+    private void init(String id, String name, Integer quantity, String type, BookingStatus status, Booking[] details) {
+        this.sraId = id;
+        String[] segments = id.split("/");
+
+        this.id = segments[segments.length - 1];// this is just a demo so don't check for a single /
+
+        this.name = name == null ? "" : name;
+        this.quantity = quantity;
+        this.type = type == null ? "" : type;
+        this.status = status;
+        this.details = details == null ? new Booking[0] : removeNullEnElements(details);
+    }
+
+    @SuppressWarnings("unchecked")
+    private <T> T[] removeNullEnElements(T[] a) {
+        List<T> list = new ArrayList<T>(Arrays.asList(a));
+        list.removeAll(Collections.singleton(null));
+        return list.toArray((T[]) Array.newInstance(a.getClass().getComponentType(), list.size()));
+    }
+
+    public String getId() {
+        return id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public Integer getQuantity() {
+        return quantity;
+    }
+
+    public String getType() {
+        return type;
+    }
+
+    public Booking[] getDetails() {
+        return details;
+    }
+
+    public BookingStatus getStatus() {
+        return status;
+    }
+
+    public void setStatus(BookingStatus status) {
+        this.status = status;
+    }
+
+    public void requestCancel() {
+        status = BookingStatus.CANCEL_REQUESTED;
+    }
+
+    public String getSraId() {
+        return sraId;
+    }
+
+    public void setSraId(String sraId) {
+        this.sraId = sraId;
+    }
+
+    public void setConfirmed() {
+        status = BookingStatus.CONFIRMED;
+    }
+
+    public String toString() {
+        return String.format("{\"id\":\"%s\",\"name\":\"%s\",\"quantity\":\"%d\",\"type\":\"%s\",\"status\":\"%s\"}",
+                id, name, quantity, type, status);
+    }
+
+    public void setCanceled() {
+        status = BookingStatus.CANCELLED;
+    }
+
+    public void setConfirming() {
+        status = BookingStatus.CONFIRMING;
+    }
+
+    @JsonIgnore
+    public boolean isCancelPending() {
+        return status == BookingStatus.CANCEL_REQUESTED;
+    }
+
+    public boolean merge(Booking booking) {
+        if (!id.equals(booking.getId()))
+            return false; // or throw an exception
+
+        name = booking.getName();
+        quantity = booking.getQuantity();
+        status = booking.getStatus();
+
+        return true;
+    }
+
+    @JsonIgnore
+    public String getEncodedId() {
+        try {
+            return URLEncoder.encode(id, "UTF-8");
+        } catch (UnsupportedEncodingException e) {
+            return id; // TODD do it in the constructor
+        }
+    }
+
+    public String toJson() throws JsonProcessingException {
+        ObjectMapper objectMapper = new ObjectMapper();
+
+        return objectMapper.writeValueAsString(this);
+    }
+
+    @JsonIgnore
+    public IOException getDecodingException() {
+        return decodingException;
+    }
+
+/*    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (!(o instanceof Booking)) return false;
+
+        Booking booking = (Booking) o;
+
+        return getId().equals(booking.getId());
+    }
+
+    @Override
+    public int hashCode() {
+        return getId().hashCode();
+    }*/
+
+    public enum BookingStatus {
+        CONFIRMED, CANCELLED, PROVISIONAL, CONFIRMING, CANCEL_REQUESTED
+    }
+}

rts/at/annotation/common-service/src/main/java/io/narayana/sra/demo/service/BookingException.java

@@ -0,0 +1,16 @@
+package io.narayana.sra.demo.service;
+
+public class BookingException extends Exception {
+    int reason;
+
+    public BookingException(int reason, String message) {
+        super(message);
+
+        this.reason = reason;
+
+    }
+
+    public int getReason() {
+        return reason;
+    }
+}

rts/at/annotation/common-service/src/main/java/io/narayana/sra/demo/service/BookingExceptionMapper.java

@@ -0,0 +1,15 @@
+package io.narayana.sra.demo.service;
+
+import jakarta.ws.rs.core.Response;
+import jakarta.ws.rs.ext.ExceptionMapper;
+import jakarta.ws.rs.ext.Provider;
+
+@Provider
+public class BookingExceptionMapper implements ExceptionMapper<BookingException> {
+    @Override
+    public Response toResponse(BookingException exception) {
+
+        return Response.status(exception.getReason())
+                .entity(exception.getMessage()).build();
+    }
+}