fix: fix bk autorecovery request error (#26)

Signed-off-by: moxiaoying <[email protected]>

Author: CennyMo

bookkeeper-admin/src/main/java/io/github/protocol/bookkeeper/admin/jdk/AutoRecoveryImpl.java

@@ -30,7 +30,10 @@ public AutoRecoveryStatus autoRecoveryStatus() throws BookkeeperAdminException {
     @Override
     public void recoveryBookie(RecoveryBookieReqData reqData) throws BookkeeperAdminException {
         try {
-            innerHttpClient.put(UrlConst.AUTO_RECOVERY, reqData);
+            HttpResponse resp = innerHttpClient.put(UrlConst.AUTO_RECOVERY_BOOKIE, reqData);
+            if (resp.statusCode() < 200 || resp.statusCode() >= 300) {
+                throw new BookkeeperAdminException(resp.bodyAsString());
+            }
         } catch (IOException | InterruptedException | ExecutionException e) {
             throw new BookkeeperAdminException(e);
         }

bookkeeper-admin/src/main/java/io/github/protocol/bookkeeper/admin/jdk/RecoveryBookieReqData.java

@@ -1,23 +1,22 @@
 package io.github.protocol.bookkeeper.admin.jdk;
 
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Getter;
+
 import java.util.List;
 
+@Getter
 public class RecoveryBookieReqData {
+    @JsonProperty("bookie_src")
     private List<String> bookieSrc;
-    private boolean deleteCookie;
 
-    public List<String> getBookieSrc() {
-        return bookieSrc;
-    }
+    @JsonProperty("delete_cookie")
+    private boolean deleteCookie;
 
     public void setBookieSrc(List<String> bookieSrc) {
         this.bookieSrc = bookieSrc;
     }
 
-    public boolean isDeleteCookie() {
-        return deleteCookie;
-    }
-
     public void setDeleteCookie(boolean deleteCookie) {
         this.deleteCookie = deleteCookie;
     }

bookkeeper-admin/src/test/java/io/github/protocol/bookkeeper/admin/jdk/AutoRecoveryImplTest.java

@@ -44,6 +44,15 @@ public void testRecoveryBookie() throws BookkeeperAdminException {
         autoRecovery.recoveryBookie(reqData);
     }
 
+    @Test
+    public void testRecoveryBookieError() {
+        RecoveryBookieReqData reqData = new RecoveryBookieReqData();
+        // bookie src is required
+        reqData.setBookieSrc(null);
+        reqData.setDeleteCookie(false);
+        Assertions.assertThrows(BookkeeperAdminException.class, () -> autoRecovery.recoveryBookie(reqData));
+    }
+
     @Test
     public void testListUnderReplicatedLedger() {
         ListUnderReplicatedLedgerReqData reqData = new ListUnderReplicatedLedgerReqData();