[incubator-inlong] branch master updated: [INLONG-2743][Manager] Support getting inlong workflow error for manager-client module (#2744)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new ec322ab  [INLONG-2743][Manager] Support getting inlong workflow error 
for manager-client module (#2744)
ec322ab is described below

commit ec322ab458d1511e444671c82ac8f378499ea73b
Author: Liao Rui <liao...@users.noreply.github.com>
AuthorDate: Sat Feb 26 17:40:15 2022 +0800

    [INLONG-2743][Manager] Support getting inlong workflow error for 
manager-client module (#2744)
    
    Co-authored-by: ryanrliao <ryanrl...@tencent.com>
---
 .../client/api/inner/InnerInlongManagerClient.java | 32 ++++++++++++++++++++++
 .../manager/client/api/util/InlongParser.java      | 10 +++++++
 2 files changed, 42 insertions(+)

diff --git 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/InnerInlongManagerClient.java
 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/InnerInlongManagerClient.java
index a98af58..870adcc 100644
--- 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/InnerInlongManagerClient.java
+++ 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/InnerInlongManagerClient.java
@@ -45,6 +45,7 @@ import org.apache.inlong.manager.common.pojo.sink.SinkRequest;
 import org.apache.inlong.manager.common.pojo.stream.FullStreamResponse;
 import org.apache.inlong.manager.common.pojo.stream.InlongStreamApproveRequest;
 import org.apache.inlong.manager.common.pojo.stream.InlongStreamInfo;
+import org.apache.inlong.manager.common.pojo.workflow.EventLogView;
 import org.apache.inlong.manager.common.pojo.workflow.WorkflowResult;
 
 /**
@@ -491,6 +492,37 @@ public class InnerInlongManagerClient {
         }
     }
 
+    /**
+     * get inlong group error messages
+     *
+     * @param inlongGroupId
+     * @return
+     */
+    public List<EventLogView> getInlongGroupError(String inlongGroupId) {
+        final String path = HTTP_PATH + "/workflow/event/list";
+        String url = formatUrl(path);
+        url = url + "&inlongGroupId=" + inlongGroupId + "&status=-1";
+        Request request = new Request.Builder()
+                .get()
+                .url(url)
+                .build();
+
+        Call call = httpClient.newCall(request);
+        try {
+            Response response = call.execute();
+            assert response.body() != null;
+            String body = response.body().string();
+            AssertUtil.isTrue(response.isSuccessful(), String.format("Inlong 
request failed: %s", body));
+            org.apache.inlong.manager.common.beans.Response responseBody = 
InlongParser.parseResponse(body);
+            AssertUtil.isTrue(responseBody.getErrMsg() == null,
+                    String.format("Inlong request failed: %s", 
responseBody.getErrMsg()));
+            PageInfo<EventLogView> pageInfo = 
InlongParser.parseEventLogViewList(responseBody);
+            return pageInfo.getList();
+        } catch (Exception e) {
+            throw new RuntimeException(String.format("Get inlong group error 
messages failed: %s", e.getMessage()), e);
+        }
+    }
+
     private String formatUrl(String path) {
         return String.format("http://%s:%s/%s?username=%s&password=%s";, host, 
port, path, uname, passwd);
     }
diff --git 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongParser.java
 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongParser.java
index fce1e35..cc78c9d 100644
--- 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongParser.java
+++ 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongParser.java
@@ -31,6 +31,7 @@ import 
org.apache.inlong.manager.common.pojo.sink.SinkListResponse;
 import org.apache.inlong.manager.common.pojo.stream.FullStreamResponse;
 import org.apache.inlong.manager.common.pojo.stream.InlongStreamApproveRequest;
 import org.apache.inlong.manager.common.pojo.stream.InlongStreamInfo;
+import org.apache.inlong.manager.common.pojo.workflow.EventLogView;
 import org.apache.inlong.manager.common.pojo.workflow.WorkflowResult;
 
 /**
@@ -105,4 +106,13 @@ public class InlongParser {
                 }.getType());
         return Pair.of(groupApproveInfo, streamApproveList);
     }
+
+    public static PageInfo<EventLogView> parseEventLogViewList(Response 
response) {
+        Object data = response.getData();
+        String pageInfoJson = GsonUtil.toJson(data);
+        PageInfo<EventLogView> pageInfo = GsonUtil.fromJson(pageInfoJson,
+                new TypeToken<PageInfo<EventLogView>>() {
+                }.getType());
+        return pageInfo;
+    }
 }