Lab: Let's Orchestrate Rules and Decisions in Aletyx Enterprise Build of Kogito and Drools 10.1.0-aletyx

​

Lab Overview

1. Get Driver information (could be from a Database)
2. Validate the driver’s license based on expiration date
3. If valid, we’ll check if the driver’s license should be suspended based on the Traffic Violation

​

Supporting Files

​

Driver.java

• Attributes include id, name, state, city, points, age, and licenseExpiration.
• Tracks whether the driver has a valid license (validLicense).
• Includes getter and setter methods for all attributes.

​

DriverService.java

• getDriver(driverId): Retrieves driver details, potentially from an external service or database.
• Mocks driver data, including randomly determining license expiration based on the driver’s ID. This could be a database access to retrieve such information.

​

Fine.java

• Attributes:
  • amount: Monetary fine imposed.
  • points: The number of penalty points added to the driver’s record.
• Includes getter and setter methods.

​

LicenseValidationService.java

• Uses SingletonStore<Driver> to manage a single driver’s data.
• Provides methods to set and retrieve driver data.
• Includes getCurrentTime() to return the current timestamp.

​

Violation.java

• Attributes:
  • code: Unique identifier for the violation.
  • date: Date when the violation occurred.
  • type: Type of violation (e.g., speeding).
  • speedLimit: Allowed speed for the road.
  • actualSpeed: Speed at which the driver was caught.
• Includes a constructor and getter/setter methods.

​

LicenseValidationService.drl

​

TrafficViolation.dmn

​

Instructions

​

Step 1: Clone the Repository

​

Step 2: Import the Project

​

Step 3: Create the BPMN file

​

Step 4: Create the process diagram

1. Start Event: Initiates the traffic rules orchestration process.
2. Get Driver Details Service Task Interface: ai.aletyx.kie.workshop.rules.orchestration.DriverService Operation: getDriver Variables - Input Mapping:

   Name	Data Type	Source
   param1	String	driverId

   Variables - Output Mapping:

   Name	Data Type	Target
   result	Driver [ai.aletyx.kie.workshop.rules.orchestration]	driver

3. LicenseValidation with DRL Business Rules Task Rule Language: DRL Rule Flow Group: unit:ai.aletyx.kie.workshop.rules.orchestration.LicenseValidationService Variables - Input Mapping:

   Name	Data Type	Source
   driver	Driver [ai.aletyx.kie.workshop.rules.orchestration]	driver

   Variables - Output Mapping:

   Name	Data Type	Target
   driver	Driver [ai.aletyx.kie.workshop.rules.orchestration]	driver

4. Exclusive Gateway: We’ll check if the Service was successful or not.
   • On Fail
     return !driver.isValidLicense();
     
     4.1. End event
   • On Success
     return driver.isValidLicense();
     
     4.2. TrafficViolation DMN Business Rules Task Rule Language: DMN Namespace: https://github.com/kiegroup/drools/kie-dmn/_A4BCA8B8-CF08-433F-93B2-A2598F19ECFF Decision Name: Traffic Violation DMN Model Name: Traffic Violation Variables - Input Mapping:

     Name	Data Type	Source
     Violation	Violation [ai.aletyx.kie.workshop.rules.orchestration]	violation
     Driver	Driver [ai.aletyx.kie.workshop.rules.orchestration]	driver

     Variables - Output Mapping:

     Name	Data Type	Target
     Suspended	String	suspended
     Fine	Fine [ai.aletyx.kie.workshop.rules.orchestration]	fine

     4.3. Script Task Script:
     System.out.println("Result for suspension: " + suspended);
     System.out.println("Result for fine: " + fine);
     
     4.4. End Event

​

Step 5: Test the Process

import java.math.BigDecimal;
import java.util.HashMap;
import java.util.Map;

import org.junit.jupiter.api.Test;

import io.quarkus.test.junit.QuarkusTest;
import io.restassured.http.ContentType;

import static io.restassured.RestAssured.given;
import static org.hamcrest.Matchers.is;

@QuarkusTest
public class TrafficProcessTest {

    public static final BigDecimal SPEED_LIMIT = new BigDecimal(100);

    @Test
    public void testTrafficViolationEmbeddedDecisionOnQuarkus() {
        testTrafficProcess("traffic", "12345", 120d, "No", true);
        testTrafficProcess("traffic", "12345", 140d, "Yes", true);
        testTrafficProcess("traffic", "1234", 140d, null, false);
    }

    private void testTrafficProcess(String processId, String driverId, Double speed, String suspended, Boolean validLicense) {
        Map<String, Object> request = new HashMap<>();
        request.put("driverId", driverId);
        request.put("violation", new Violation("speed", SPEED_LIMIT, new BigDecimal(speed)));
        given()
                .body(request)
                .contentType(ContentType.JSON)
                .when()
                .post("/" + processId)
                .then()
                .statusCode(201)
                .body("suspended", is(suspended))
                .body("driver.validLicense", is(validLicense));
    }
}