From f9bc2660f6dc67db61cacf52541856557b05c8fa Mon Sep 17 00:00:00 2001
From: Robin Han <hanxvdovehx@gmail.com>
Date: Sat, 25 Nov 2023 22:24:02 +0800
Subject: [PATCH] fix(s3stream): update to 0.5.6 and fix serveless cmd (#730)

Signed-off-by: Robin Han <hanxvdovehx@gmail.com>
---
 pom.xml                                                   | 2 +-
 s3stream/pom.xml                                          | 2 +-
 .../com/automq/stream/s3/failover/DefaultServerless.java  | 8 ++++----
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/pom.xml b/pom.xml
index 225b9fa9b..c382e9610 100644
--- a/pom.xml
+++ b/pom.xml
@@ -53,7 +53,7 @@
         <guava.version>32.0.1-jre</guava.version>
         <slf4j.version>2.0.9</slf4j.version>
         <snakeyaml.version>2.2</snakeyaml.version>
-        <s3stream.version>0.5.5-SNAPSHOT</s3stream.version>
+        <s3stream.version>0.5.6-SNAPSHOT</s3stream.version>
 
         <!-- Flat buffers related -->
         <flatbuffers.version>23.5.26</flatbuffers.version>
diff --git a/s3stream/pom.xml b/s3stream/pom.xml
index 77b2d436e..0e414cec3 100644
--- a/s3stream/pom.xml
+++ b/s3stream/pom.xml
@@ -22,7 +22,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.automq.elasticstream</groupId>
     <artifactId>s3stream</artifactId>
-    <version>0.5.5-SNAPSHOT</version>
+    <version>0.5.6-SNAPSHOT</version>
     <properties>
         <mockito-core.version>5.5.0</mockito-core.version>
         <junit-jupiter.version>5.10.0</junit-jupiter.version>
diff --git a/s3stream/src/main/java/com/automq/stream/s3/failover/DefaultServerless.java b/s3stream/src/main/java/com/automq/stream/s3/failover/DefaultServerless.java
index c49d2ae4e..e6b88d31e 100644
--- a/s3stream/src/main/java/com/automq/stream/s3/failover/DefaultServerless.java
+++ b/s3stream/src/main/java/com/automq/stream/s3/failover/DefaultServerless.java
@@ -33,7 +33,7 @@ public class DefaultServerless implements Serverless {
     @Override
     public String attach(String volumeId, int nodeId) throws ExecutionException {
         String[] cmd = new String[]{SERVERLESS_CMD, "volume", "attach", "-v", volumeId, "-n", Integer.toString(nodeId)};
-        CommandResult result = CommandUtils.run();
+        CommandResult result = CommandUtils.run(cmd);
         check(cmd, result);
         return jsonParse(result.stdout(), AttachResult.class).getDeviceName();
     }
@@ -41,21 +41,21 @@ public String attach(String volumeId, int nodeId) throws ExecutionException {
     @Override
     public void delete(String volumeId) throws ExecutionException {
         String[] cmd = new String[]{SERVERLESS_CMD, "volume", "delete", "-v", volumeId};
-        CommandResult result = CommandUtils.run();
+        CommandResult result = CommandUtils.run(cmd);
         check(cmd, result);
     }
 
     @Override
     public void fence(String volumeId) throws ExecutionException {
         String[] cmd = new String[]{SERVERLESS_CMD, "volume", "fence", "-v", volumeId};
-        CommandResult result = CommandUtils.run();
+        CommandResult result = CommandUtils.run(cmd);
         check(cmd, result);
     }
 
     @Override
     public List<FailedNode> scan() throws ExecutionException {
         String[] cmd = new String[]{SERVERLESS_CMD, "volume", "query"};
-        CommandResult result = CommandUtils.run();
+        CommandResult result = CommandUtils.run(cmd);
         check(cmd, result);
         QueryFailedNode[] nodes = jsonParse(result.stdout(), QueryFailedNode[].class);
         return Arrays.stream(nodes).map(n -> {