Job module

blibli-backend-framework-job/pom.xml

@@ -0,0 +1,42 @@
+<?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/xsd/maven-4.0.0.xsd">
+  <parent>
+    <artifactId>blibli-backend-framework</artifactId>
+    <groupId>com.blibli.oss</groupId>
+    <version>0.0.6-SNAPSHOT</version>
+  </parent>
+  <modelVersion>4.0.0</modelVersion>
+
+  <artifactId>blibli-backend-framework-job</artifactId>
+
+  <dependencies>
+    <dependency>
+      <groupId>io.projectreactor</groupId>
+      <artifactId>reactor-test</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.projectlombok</groupId>
+      <artifactId>lombok</artifactId>
+      <optional>true</optional>
+    </dependency>
+    <dependency>
+      <groupId>com.blibli.oss</groupId>
+      <artifactId>blibli-backend-framework-reactor</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-test</artifactId>
+      <scope>test</scope>
+      <exclusions>
+        <exclusion>
+          <groupId>org.junit.vintage</groupId>
+          <artifactId>junit-vintage-engine</artifactId>
+        </exclusion>
+      </exclusions>
+    </dependency>
+  </dependencies>
+
+</project>

blibli-backend-framework-job/src/main/java/com/blibli/oss/backend/job/Job.java

@@ -0,0 +1,9 @@
+package com.blibli.oss.backend.job;
+
+import reactor.core.publisher.Mono;
+
+public interface Job<T> {
+
+  Mono<Void> execute(T request);
+
+}

blibli-backend-framework-job/src/main/java/com/blibli/oss/backend/job/JobManager.java

@@ -0,0 +1,9 @@
+package com.blibli.oss.backend.job;
+
+import reactor.core.publisher.Mono;
+
+public interface JobManager {
+
+  Mono<Void> execute(String command);
+
+}

blibli-backend-framework-job/src/test/java/com/blibli/oss/backend/job/JobTest.java

@@ -0,0 +1,57 @@
+package com.blibli.oss.backend.job;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.cli.*;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+@Slf4j
+class JobTest {
+
+  private ObjectMapper objectMapper;
+
+  @BeforeEach
+  void setUp() {
+    objectMapper = new ObjectMapper();
+  }
+
+  @Test
+  void testFirst() {
+    String[] arguments = "reindex --start=100 --from=200".split("\\s+");
+
+    String command = arguments[0];
+    Map<String, String> map = new HashMap<>();
+
+    for (int i = 1; i < arguments.length; i++) {
+      String[] split = arguments[i].split("=");
+      if (split.length == 2 && split[0].startsWith("--")) {
+        map.put(split[0].substring(2), split[1]);
+      }
+    }
+
+    Request request = objectMapper.convertValue(map, Request.class);
+    log.info(request.toString());
+  }
+
+  @Data
+  @Builder
+  @AllArgsConstructor
+  @NoArgsConstructor
+  public static class Request {
+
+    private Integer start;
+
+    private Integer from;
+
+  }
+}

pom.xml

@@ -18,6 +18,7 @@
     <module>blibli-backend-framework-validation</module>
     <module>blibli-backend-framework-sleuth</module>
     <module>blibli-backend-framework-external-api</module>
+    <module>blibli-backend-framework-job</module>
   </modules>
 
   <parent>
@@ -114,6 +115,11 @@
         <artifactId>blibli-backend-framework-version</artifactId>
         <version>${blibli-framework.version}</version>
       </dependency>
+      <dependency>
+        <groupId>com.blibli.oss</groupId>
+        <artifactId>blibli-backend-framework-job</artifactId>
+        <version>${blibli-framework.version}</version>
+      </dependency>
       <dependency>
         <groupId>com.blibli.oss</groupId>
         <artifactId>blibli-backend-framework-json</artifactId>