From 169386c08e7d54862624104172246aea7bbc48b6 Mon Sep 17 00:00:00 2001
From: ZhangJian He <shoothzj@gmail.com>
Date: Fri, 30 Aug 2024 11:46:30 +0800
Subject: [PATCH] feat: add reactor module (#23)

Signed-off-by: ZhangJian He <shoothzj@gmail.com>
---
 ci/spotbugs/exclude.xml                       |  8 +++
 pom.xml                                       | 63 +++++++++++++------
 pulsar-admin-api/pom.xml                      | 14 +++++
 .../protocol/pulsar/admin/api/TlsConfig.java  | 29 +++++++++
 .../pulsar/admin/api/package-info.java        |  1 +
 pulsar-admin-jdk/pom.xml                      | 10 ++-
 .../pulsar/admin/jdk/Configuration.java       |  2 +-
 .../pulsar/admin/jdk/InnerHttpClient.java     |  2 +-
 .../admin/jdk/PulsarAdminBuilderImpl.java     |  2 +-
 pulsar-admin-reactor/pom.xml                  | 27 ++++++++
 .../admin/reactive/InnerReactorClient.java    |  4 ++
 .../pulsar/admin/reactive/package-info.java   |  1 +
 12 files changed, 140 insertions(+), 23 deletions(-)
 create mode 100644 pulsar-admin-api/pom.xml
 create mode 100644 pulsar-admin-api/src/main/java/io/github/protocol/pulsar/admin/api/TlsConfig.java
 create mode 100644 pulsar-admin-api/src/main/java/io/github/protocol/pulsar/admin/api/package-info.java
 create mode 100644 pulsar-admin-reactor/pom.xml
 create mode 100644 pulsar-admin-reactor/src/main/java/io/github/protocol/pulsar/admin/reactive/InnerReactorClient.java
 create mode 100644 pulsar-admin-reactor/src/main/java/io/github/protocol/pulsar/admin/reactive/package-info.java

diff --git a/ci/spotbugs/exclude.xml b/ci/spotbugs/exclude.xml
index 9d17990..cb8ec7e 100644
--- a/ci/spotbugs/exclude.xml
+++ b/ci/spotbugs/exclude.xml
@@ -15,4 +15,12 @@
         <Bug pattern="EI_EXPOSE_REP2"/>
     </Match>
 
+    <Match>
+        <Bug pattern="PA_PUBLIC_PRIMITIVE_ATTRIBUTE"/>
+    </Match>
+
+    <Match>
+        <Bug pattern="URF_UNREAD_PUBLIC_OR_PROTECTED_FIELD"/>
+    </Match>
+
 </FindBugsFilter>
diff --git a/pom.xml b/pom.xml
index fed27fc..5b304bf 100644
--- a/pom.xml
+++ b/pom.xml
@@ -6,11 +6,13 @@
 
     <groupId>io.github.protocol-laboratory</groupId>
     <artifactId>pulsar-admin-parent</artifactId>
-    <version>0.0.1</version>
+    <version>0.0.2</version>
     <packaging>pom</packaging>
 
     <modules>
+        <module>pulsar-admin-api</module>
         <module>pulsar-admin-jdk</module>
+        <module>pulsar-admin-reactor</module>
     </modules>
 
     <properties>
@@ -25,19 +27,22 @@
         <junit.version>5.11.0</junit.version>
         <log4j.version>2.20.0</log4j.version>
         <lombok.version>1.18.34</lombok.version>
+        <puppycrawl.version>10.18.0</puppycrawl.version>
+        <reactor-netty.version>1.1.22</reactor-netty.version>
         <!-- plugin -->
-        <compiler-plugin.version>3.10.1</compiler-plugin.version>
-        <checkstyle-plugin.version>3.2.0</checkstyle-plugin.version>
-        <javadoc-plugin.version>3.4.1</javadoc-plugin.version>
         <lombok-maven-plugin.version>1.18.20.0</lombok-maven-plugin.version>
-        <maven-gpg-plugin.version>3.2.4</maven-gpg-plugin.version>
-        <nexus-staging-maven-plugin.version>1.6.13</nexus-staging-maven-plugin.version>
-        <puppycrawl.version>10.18.0</puppycrawl.version>
-        <release-plugin.version>3.0.0-M6</release-plugin.version>
-        <scm-provider-gitexe.version>2.1.0</scm-provider-gitexe.version>
-        <source-plugin.version>3.2.1</source-plugin.version>
-        <spotbugs-maven-plugin.version>4.7.2.0</spotbugs-maven-plugin.version>
-        <surefire-plugin.version>3.0.0-M9</surefire-plugin.version>
+        <maven-compiler-plugin.version>3.13.0</maven-compiler-plugin.version>
+        <maven-checkstyle-plugin.version>3.5.0</maven-checkstyle-plugin.version>
+        <maven-enforcer-plugin.version>3.5.0</maven-enforcer-plugin.version>
+        <maven-enforce-plugin-maven.version>3.8.0</maven-enforce-plugin-maven.version>
+        <maven-gpg-plugin.version>3.2.5</maven-gpg-plugin.version>
+        <maven-javadoc-plugin.version>3.10.0</maven-javadoc-plugin.version>
+        <maven-release-plugin.version>3.1.1</maven-release-plugin.version>
+        <maven-scm-provider-gitexe.version>2.1.0</maven-scm-provider-gitexe.version>
+        <maven-source-plugin.version>3.3.1</maven-source-plugin.version>
+        <maven-surefire-plugin.version>3.5.0</maven-surefire-plugin.version>
+        <nexus-staging-maven-plugin.version>1.7.0</nexus-staging-maven-plugin.version>
+        <spotbugs-maven-plugin.version>4.8.6.2</spotbugs-maven-plugin.version>
         <spotless-maven-plugi.version>2.43.0</spotless-maven-plugi.version>
     </properties>
 
@@ -92,10 +97,30 @@
     <build>
         <sourceDirectory>${src.dir}</sourceDirectory>
         <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-enforcer-plugin</artifactId>
+                <version>${maven-enforcer-plugin.version}</version>
+                <executions>
+                    <execution>
+                        <id>enforce-versions</id>
+                        <goals>
+                            <goal>enforce</goal>
+                        </goals>
+                        <configuration>
+                            <rules>
+                                <requireMavenVersion>
+                                    <version>${maven-enforce-plugin-maven.version}</version>
+                                </requireMavenVersion>
+                            </rules>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-compiler-plugin</artifactId>
-                <version>${compiler-plugin.version}</version>
+                <version>${maven-compiler-plugin.version}</version>
                 <configuration>
                     <source>${maven.compiler.source}</source>
                     <target>${maven.compiler.target}</target>
@@ -104,7 +129,7 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-checkstyle-plugin</artifactId>
-                <version>${checkstyle-plugin.version}</version>
+                <version>${maven-checkstyle-plugin.version}</version>
                 <dependencies>
                     <dependency>
                         <groupId>com.puppycrawl.tools</groupId>
@@ -141,7 +166,7 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-surefire-plugin</artifactId>
-                <version>${surefire-plugin.version}</version>
+                <version>${maven-surefire-plugin.version}</version>
                 <extensions>true</extensions>
                 <configuration>
                     <useFile>false</useFile>
@@ -169,7 +194,7 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-release-plugin</artifactId>
-                <version>${release-plugin.version}</version>
+                <version>${maven-release-plugin.version}</version>
                 <configuration>
                     <localCheckout>true</localCheckout>
                     <pushChanges>false</pushChanges>
@@ -180,14 +205,14 @@
                     <dependency>
                         <groupId>org.apache.maven.scm</groupId>
                         <artifactId>maven-scm-provider-gitexe</artifactId>
-                        <version>${scm-provider-gitexe.version}</version>
+                        <version>${maven-scm-provider-gitexe.version}</version>
                     </dependency>
                 </dependencies>
             </plugin>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-javadoc-plugin</artifactId>
-                <version>${javadoc-plugin.version}</version>
+                <version>${maven-javadoc-plugin.version}</version>
                 <configuration>
                     <sourcepath>${src.dir}</sourcepath>
                     <doclint>all,-missing</doclint>
@@ -204,7 +229,7 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-source-plugin</artifactId>
-                <version>${source-plugin.version}</version>
+                <version>${maven-source-plugin.version}</version>
                 <executions>
                     <execution>
                         <id>attach-sources</id>
diff --git a/pulsar-admin-api/pom.xml b/pulsar-admin-api/pom.xml
new file mode 100644
index 0000000..5deb56a
--- /dev/null
+++ b/pulsar-admin-api/pom.xml
@@ -0,0 +1,14 @@
+<?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">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>io.github.protocol-laboratory</groupId>
+        <artifactId>pulsar-admin-parent</artifactId>
+        <version>0.0.2</version>
+    </parent>
+
+    <artifactId>pulsar-admin-api</artifactId>
+
+</project>
diff --git a/pulsar-admin-api/src/main/java/io/github/protocol/pulsar/admin/api/TlsConfig.java b/pulsar-admin-api/src/main/java/io/github/protocol/pulsar/admin/api/TlsConfig.java
new file mode 100644
index 0000000..97d3230
--- /dev/null
+++ b/pulsar-admin-api/src/main/java/io/github/protocol/pulsar/admin/api/TlsConfig.java
@@ -0,0 +1,29 @@
+package io.github.protocol.pulsar.admin.api;
+
+import lombok.AllArgsConstructor;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import lombok.ToString;
+
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+public class TlsConfig {
+    public String keyStorePath;
+
+    @ToString.Exclude
+    public char[] keyStorePassword;
+
+    public String trustStorePath;
+
+    @ToString.Exclude
+    public char[] trustStorePassword;
+
+    public boolean verifyDisabled;
+
+    public boolean hostnameVerifyDisabled;
+
+    public String[] versions;
+
+    public String[] cipherSuites;
+}
diff --git a/pulsar-admin-api/src/main/java/io/github/protocol/pulsar/admin/api/package-info.java b/pulsar-admin-api/src/main/java/io/github/protocol/pulsar/admin/api/package-info.java
new file mode 100644
index 0000000..f2c20bc
--- /dev/null
+++ b/pulsar-admin-api/src/main/java/io/github/protocol/pulsar/admin/api/package-info.java
@@ -0,0 +1 @@
+package io.github.protocol.pulsar.admin.api;
diff --git a/pulsar-admin-jdk/pom.xml b/pulsar-admin-jdk/pom.xml
index 351ccfa..0334324 100644
--- a/pulsar-admin-jdk/pom.xml
+++ b/pulsar-admin-jdk/pom.xml
@@ -6,11 +6,19 @@
     <parent>
         <groupId>io.github.protocol-laboratory</groupId>
         <artifactId>pulsar-admin-parent</artifactId>
-        <version>0.0.1</version>
+        <version>0.0.2</version>
     </parent>
 
     <artifactId>pulsar-admin-jdk</artifactId>
 
+    <dependencies>
+        <dependency>
+            <groupId>io.github.protocol-laboratory</groupId>
+            <artifactId>pulsar-admin-api</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+    </dependencies>
+
     <build>
         <testResources>
             <testResource>
diff --git a/pulsar-admin-jdk/src/main/java/io/github/protocol/pulsar/admin/jdk/Configuration.java b/pulsar-admin-jdk/src/main/java/io/github/protocol/pulsar/admin/jdk/Configuration.java
index 78452b1..167954d 100644
--- a/pulsar-admin-jdk/src/main/java/io/github/protocol/pulsar/admin/jdk/Configuration.java
+++ b/pulsar-admin-jdk/src/main/java/io/github/protocol/pulsar/admin/jdk/Configuration.java
@@ -29,7 +29,7 @@ public class Configuration {
 
     private int port;
 
-    public boolean useSsl = false;
+    public boolean tlsEnabled;
 
     public String keyStorePath;
 
diff --git a/pulsar-admin-jdk/src/main/java/io/github/protocol/pulsar/admin/jdk/InnerHttpClient.java b/pulsar-admin-jdk/src/main/java/io/github/protocol/pulsar/admin/jdk/InnerHttpClient.java
index c758523..d746a12 100644
--- a/pulsar-admin-jdk/src/main/java/io/github/protocol/pulsar/admin/jdk/InnerHttpClient.java
+++ b/pulsar-admin-jdk/src/main/java/io/github/protocol/pulsar/admin/jdk/InnerHttpClient.java
@@ -39,7 +39,7 @@ public InnerHttpClient(Configuration conf) {
         this.conf = conf;
         HttpClient.Builder builder = HttpClient.newBuilder()
                 .version(HttpClient.Version.HTTP_1_1);
-        if (conf.isUseSsl()) {
+        if (conf.isTlsEnabled()) {
             builder = builder
                     .sslContext(SslContextUtil.buildFromJks(conf.keyStorePath, conf.keyStorePassword,
                             conf.trustStorePath, conf.trustStorePassword, conf.disableSslVerify,
diff --git a/pulsar-admin-jdk/src/main/java/io/github/protocol/pulsar/admin/jdk/PulsarAdminBuilderImpl.java b/pulsar-admin-jdk/src/main/java/io/github/protocol/pulsar/admin/jdk/PulsarAdminBuilderImpl.java
index 90ba84c..13bfa2a 100644
--- a/pulsar-admin-jdk/src/main/java/io/github/protocol/pulsar/admin/jdk/PulsarAdminBuilderImpl.java
+++ b/pulsar-admin-jdk/src/main/java/io/github/protocol/pulsar/admin/jdk/PulsarAdminBuilderImpl.java
@@ -44,7 +44,7 @@ public PulsarAdminBuilder port(int port) {
 
     @Override
     public PulsarAdminBuilder useSsl(boolean useSsl) {
-        this.conf.setUseSsl(useSsl);
+        this.conf.setTlsEnabled(useSsl);
         return this;
     }
 
diff --git a/pulsar-admin-reactor/pom.xml b/pulsar-admin-reactor/pom.xml
new file mode 100644
index 0000000..66fdff6
--- /dev/null
+++ b/pulsar-admin-reactor/pom.xml
@@ -0,0 +1,27 @@
+<?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">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>io.github.protocol-laboratory</groupId>
+        <artifactId>pulsar-admin-parent</artifactId>
+        <version>0.0.2</version>
+    </parent>
+
+    <artifactId>pulsar-admin-reactor</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>io.github.protocol-laboratory</groupId>
+            <artifactId>pulsar-admin-api</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>io.projectreactor.netty</groupId>
+            <artifactId>reactor-netty-http</artifactId>
+            <version>${reactor-netty.version}</version>
+        </dependency>
+    </dependencies>
+
+</project>
diff --git a/pulsar-admin-reactor/src/main/java/io/github/protocol/pulsar/admin/reactive/InnerReactorClient.java b/pulsar-admin-reactor/src/main/java/io/github/protocol/pulsar/admin/reactive/InnerReactorClient.java
new file mode 100644
index 0000000..463d79c
--- /dev/null
+++ b/pulsar-admin-reactor/src/main/java/io/github/protocol/pulsar/admin/reactive/InnerReactorClient.java
@@ -0,0 +1,4 @@
+package io.github.protocol.pulsar.admin.reactive;
+
+public class InnerReactorClient {
+}
diff --git a/pulsar-admin-reactor/src/main/java/io/github/protocol/pulsar/admin/reactive/package-info.java b/pulsar-admin-reactor/src/main/java/io/github/protocol/pulsar/admin/reactive/package-info.java
new file mode 100644
index 0000000..e17acf4
--- /dev/null
+++ b/pulsar-admin-reactor/src/main/java/io/github/protocol/pulsar/admin/reactive/package-info.java
@@ -0,0 +1 @@
+package io.github.protocol.pulsar.admin.reactive;