Long Running Actions (LRA)

<dependencies>
    <dependency>
      <groupId>io.helidon.microprofile.lra</groupId>
      <artifactId>helidon-microprofile-lra</artifactId>
    </dependency>
    <!-- Support for Narayana coordinator -->
    <dependency>
      <groupId>io.helidon.lra</groupId>
      <artifactId>helidon-lra-coordinator-narayana-client</artifactId>
    </dependency>
</dependencies>

io.helidon.microprofile.lra

mp.lra:
  coordinator.url: http://localhost:8070/lra-coordinator (1)
  propagation.active: true (2)
  participant.url: https://coordinator.visible.host:443/awesomeapp (3)

@PUT
@LRA(LRA.Type.REQUIRES_NEW) // (1)
@Path("start-example")
public Response startExample(@HeaderParam(LRA_HTTP_CONTEXT_HEADER) URI lraId, //(2)
                             String data) {
    if (data.contains("BOOM")) {
        throw new RuntimeException("BOOM 💥"); // (3)
    }

    LOGGER.info("Data " + data + " processed 🏭");
    return Response.ok().build(); // (4)
}

@PUT
@Complete // (5)
@Path("complete-example")
public Response completeExample(@HeaderParam(LRA_HTTP_CONTEXT_HEADER) URI lraId) {
    LOGGER.log(Level.INFO, "LRA ID: {0} completed 🎉", lraId);
    return LRAResponse.completed();
}

@PUT
@Compensate // (6)
@Path("compensate-example")
public Response compensateExample(@HeaderParam(LRA_HTTP_CONTEXT_HEADER) URI lraId) {
    LOGGER.log(Level.SEVERE, "LRA ID: {0} compensated 🦺", lraId);
    return LRAResponse.compensated();
}

<dependency>
    <groupId>io.helidon.microprofile.lra</groupId>
    <artifactId>helidon-microprofile-lra-testing</artifactId>
    <scope>test</scope>
</dependency>

@ApplicationScoped
@Path("/test")
public class WithdrawResource {

    private final List<String> completedLras = new CopyOnWriteArrayList<>();
    private final List<String> cancelledLras = new CopyOnWriteArrayList<>();

    @PUT
    @Path("/withdraw")
    @LRA(LRA.Type.REQUIRES_NEW)
    public Response withdraw(@HeaderParam(LRA.LRA_HTTP_CONTEXT_HEADER) Optional<URI> lraId, String content) {
        if ("BOOM".equals(content)) {
            throw new IllegalArgumentException("BOOM");
        }
        return Response.ok().build();
    }

    @Complete
    public void complete(URI lraId) {
        completedLras.add(lraId.toString());
    }

    @Compensate
    public void rollback(URI lraId) {
        cancelledLras.add(lraId.toString());
    }

    public List<String> getCompletedLras() {
        return completedLras;
    }
}

@HelidonTest
//@AddBean(WithdrawResource.class) //(1)
@AddBean(TestLraCoordinator.class) //(2)
public class LraTest {

    @Inject
    private WithdrawResource withdrawTestResource;

    @Inject
    private TestLraCoordinator coordinator; //(3)

    @Inject
    private WebTarget target;

    @Test
    public void testLraComplete() {
        try (Response res = target
                .path("/test/withdraw")
                .request()
                .put(Entity.entity("test", MediaType.TEXT_PLAIN_TYPE))) {
            assertThat(res.getStatus(), is(200));
            String lraId = res.getHeaderString(LRA.LRA_HTTP_CONTEXT_HEADER);
            Lra lra = coordinator.lra(lraId); //(4)
            assertThat(lra.status(), is(LRAStatus.Closed)); //(5)
            assertThat(withdrawTestResource.getCompletedLras(), contains(lraId));
        }
    }
}

@HelidonTest
@AddBean(TestLraCoordinator.class)
@AddConfig(key = "server.sockets.500.port", value = "8070") //(1)
@AddConfig(key = "server.sockets.500.bind-address", value = "custom.bind.name") //(2)
@AddConfig(key = "helidon.lra.coordinator.persistence", value = "true") //(3)
@AddConfig(key = "helidon.lra.participant.use-build-time-index", value = "true") //(4)
public class LraCustomConfigTest {
}

@HelidonTest
@DisableDiscovery
@AddJaxRs
@AddBean(TestLraCoordinator.class)
@AddExtension(LraCdiExtension.class)
@AddExtension(ConfigCdiExtension.class)
@AddBean(WithdrawResource.class)
public class LraNoDiscoveryTest {
}