Merge pull request #7 from opensergo/app-detail

app detail page

Author: robberphex

opensergo-dashboard-distribution/pom.xml

@@ -12,12 +12,6 @@
     <artifactId>opensergo-dashboard-distribution</artifactId>
 
     <dependencies>
-        <dependency>
-            <groupId>io.opensergo</groupId>
-            <artifactId>opensergo-dashboard-ui</artifactId>
-            <version>${project.version}</version>
-            <type>pom</type>
-        </dependency>
         <dependency>
             <groupId>io.opensergo</groupId>
             <artifactId>opensergo-dashboard-server</artifactId>

opensergo-dashboard-server/src/main/java/com/alibaba/csp/sentinel/dashboard/controller/MachineRegistryController.java

@@ -20,7 +20,6 @@
 import com.alibaba.csp.sentinel.dashboard.domain.Result;
 import com.alibaba.csp.sentinel.util.StringUtil;
 import com.google.common.net.InetAddresses;
-import io.opensergo.dashboard.repository.application.ApplicationRepository;
 import io.opensergo.dashboard.service.application.ApplicationService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -83,7 +82,7 @@ public Result<?> receiveHeartBeat(String app,
             machineInfo.setVersion(sentinelVersion);
             appManagement.addMachine(machineInfo);
 
-            applicationService.createApplication(app);
+            applicationService.createApplication(app, "");
 
             return Result.ofSuccessMsg("success");
         } catch (Exception e) {

opensergo-dashboard-server/src/main/java/io/opensergo/dashboard/controller/application/ApplicationController.java

@@ -1,6 +1,7 @@
 package io.opensergo.dashboard.controller.application;
 
 import com.alibaba.csp.sentinel.dashboard.domain.PagedResult;
+import com.alibaba.csp.sentinel.dashboard.domain.Result;
 import io.opensergo.dashboard.domain.application.ApplicationEntity;
 import io.opensergo.dashboard.repository.application.ApplicationRepository;
 import io.opensergo.dashboard.vo.application.ApplicationItem;
@@ -13,6 +14,7 @@
 import javax.servlet.http.HttpServletRequest;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Optional;
 
 /**
  * @author luyanbo
@@ -38,4 +40,19 @@ public PagedResult<List<ApplicationItem>> getApplicationList(
         }
         return PagedResult.ofSuccess(appItemList);
     }
+
+    @GetMapping("/describeApplication")
+    public Result<ApplicationItem> describeApplication(
+            HttpServletRequest request,
+            String appName
+    ) {
+        Optional<ApplicationEntity> appEntity = applicationRepository.findByName(appName);
+        if (appEntity.isPresent()) {
+            ApplicationItem appItem = new ApplicationItem();
+            appItem.setAppName(appEntity.get().getName());
+            appItem.setSha256(appEntity.get().getSha256());
+            return Result.ofSuccess(appItem);
+        }
+        return Result.ofSuccess(null);
+    }
 }

opensergo-dashboard-server/src/main/java/io/opensergo/dashboard/controller/service/ServiceController.java

@@ -0,0 +1,105 @@
+package io.opensergo.dashboard.controller.service;
+
+import com.alibaba.csp.sentinel.dashboard.domain.PagedResult;
+import com.alibaba.csp.sentinel.dashboard.domain.Result;
+import com.google.protobuf.InvalidProtocolBufferException;
+import com.google.protobuf.util.JsonFormat;
+import io.opensergo.dashboard.domain.application.MetadataEntity;
+import io.opensergo.dashboard.repository.application.ApplicationRepository;
+import io.opensergo.dashboard.repository.application.MetadataRepository;
+import io.opensergo.dashboard.vo.service.MethodItem;
+import io.opensergo.dashboard.vo.service.ServiceItem;
+import io.opensergo.proto.service_contract.v1.MethodDescriptor;
+import io.opensergo.proto.service_contract.v1.ReportMetadataRequest;
+import io.opensergo.proto.service_contract.v1.ServiceDescriptor;
+import io.opensergo.proto.service_contract.v1.ServiceMetadata;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.Pageable;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.*;
+
+/**
+ * @author luyanbo
+ */
+@RestController
+@RequestMapping(value = "/api/service/")
+public class ServiceController {
+
+    @Autowired
+    private ApplicationRepository applicationRepository;
+
+    @Autowired
+    private MetadataRepository metadataRepository;
+
+    @GetMapping("/queryService")
+    public PagedResult<List<ServiceItem>> queryService(
+            String appName,
+            String protocol,
+            Pageable pageable
+    ) throws InvalidProtocolBufferException {
+        Optional<MetadataEntity> metadataOptional = metadataRepository.findByAppName(appName);
+        if (!metadataOptional.isPresent()) {
+            return PagedResult.ofSuccess(new ArrayList<>());
+        }
+        MetadataEntity appEntity = metadataOptional.get();
+        String metadataStr = appEntity.getMetadata();
+        ReportMetadataRequest.Builder reqBuilder = ReportMetadataRequest.newBuilder();
+        JsonFormat.parser().merge(metadataStr, reqBuilder);
+
+        List<ServiceItem> serviceItems = new ArrayList<>();
+        for (ServiceMetadata serviceMetadata : reqBuilder.getServiceMetadataList()) {
+            if (!serviceMetadata.getProtocolsList().contains(protocol)) {
+                continue;
+            }
+            for (ServiceDescriptor serviceDescriptor : serviceMetadata.getServiceContract().getServicesList()) {
+                ServiceItem serviceItem = new ServiceItem();
+                serviceItem.setAppName(reqBuilder.getAppName());
+                serviceItem.setServiceName(serviceDescriptor.getName());
+                serviceItems.add(serviceItem);
+            }
+        }
+        return PagedResult.ofSuccess(serviceItems);
+    }
+
+    @GetMapping("/queryServiceMethod")
+    public Result<List<MethodItem>> queryServiceMethod(
+            String appName,
+            String serviceName,
+            String protocol,
+            Pageable pageable
+    ) throws InvalidProtocolBufferException {
+        Optional<MetadataEntity> metadataOptional = metadataRepository.findByAppName(appName);
+        if (!metadataOptional.isPresent()) {
+            return Result.ofSuccess(null);
+        }
+        MetadataEntity appEntity = metadataOptional.get();
+        String metadataStr = appEntity.getMetadata();
+        ReportMetadataRequest.Builder reqBuilder = ReportMetadataRequest.newBuilder();
+        JsonFormat.parser().merge(metadataStr, reqBuilder);
+
+        List<MethodItem> methodItems = new ArrayList<>();
+        Set<String> methodNames = new HashSet<>();
+        for (ServiceMetadata serviceMetadata : reqBuilder.getServiceMetadataList()) {
+            if (!serviceMetadata.getProtocolsList().contains(protocol)) {
+                continue;
+            }
+            for (ServiceDescriptor serviceDescriptor : serviceMetadata.getServiceContract().getServicesList()) {
+                if (serviceName.equals(serviceDescriptor.getName())) {
+                    for (MethodDescriptor methodDescriptor : serviceDescriptor.getMethodsList()) {
+                        if (methodNames.contains(methodDescriptor.getName())) {
+                            continue;
+                        }
+                        methodNames.add(methodDescriptor.getName());
+                        MethodItem methodItem = new MethodItem();
+                        methodItem.setMethodName(methodDescriptor.getName());
+                        methodItems.add(methodItem);
+                    }
+                }
+            }
+        }
+        return Result.ofSuccess(methodItems);
+    }
+}

opensergo-dashboard-server/src/main/java/io/opensergo/dashboard/domain/application/ApplicationEntity.java

@@ -17,4 +17,6 @@ public class ApplicationEntity {
     private Long id;
 
     private String name;
+
+    private String sha256;
 }

opensergo-dashboard-server/src/main/java/io/opensergo/dashboard/domain/application/MetadataEntity.java

@@ -16,7 +16,7 @@ public class MetadataEntity {
     @Id
     private Long id;
 
-    private String sha512;
+    private String sha256;
 
     private String appName;
 

opensergo-dashboard-server/src/main/java/io/opensergo/dashboard/grpc/service/GrpcMetadataService.java

@@ -2,7 +2,6 @@
 
 import com.google.protobuf.util.JsonFormat;
 import io.grpc.stub.StreamObserver;
-import io.opensergo.dashboard.domain.application.ApplicationEntity;
 import io.opensergo.dashboard.domain.application.MetadataEntity;
 import io.opensergo.dashboard.repository.application.MetadataRepository;
 import io.opensergo.dashboard.service.application.ApplicationService;
@@ -43,17 +42,17 @@ public void reportMetadata(ReportMetadataRequest request, StreamObserver<ReportM
 
         log.info("reportMetadata request: {}", metadata);
 
-        applicationService.createApplication(appName);
-        recordMetadata(appName, metadataEntity, metadata);
+        metadataEntity = recordMetadata(appName, metadataEntity, metadata);
+        applicationService.createApplication(appName, metadataEntity.getSha256());
 
         responseObserver.onNext(ReportMetadataReply.newBuilder().build());
         responseObserver.onCompleted();
     }
 
-    private void recordMetadata(String appName, MetadataEntity metadataEntity, String metadata) {
+    private MetadataEntity recordMetadata(String appName, MetadataEntity metadataEntity, String metadata) {
         metadataEntity.setAppName(appName);
         metadataEntity.setMetadata(metadata);
-        metadataEntity.setSha512(DigestUtils.sha512Hex(metadata));
-        metadataRepository.save(metadataEntity);
+        metadataEntity.setSha256(DigestUtils.sha256Hex(metadata));
+        return metadataRepository.save(metadataEntity);
     }
 }

opensergo-dashboard-server/src/main/java/io/opensergo/dashboard/repository/application/MetadataRepository.java

@@ -9,4 +9,6 @@ public interface MetadataRepository extends Repository<MetadataEntity, String> {
     MetadataEntity save(MetadataEntity entity);
 
     Optional<MetadataEntity> findByAppName(String appName);
+
+    Optional<MetadataEntity> findBySha256(String sha256);
 }

opensergo-dashboard-server/src/main/java/io/opensergo/dashboard/service/application/ApplicationService.java

@@ -13,10 +13,11 @@ public class ApplicationService {
     @Autowired
     private ApplicationRepository applicationRepository;
 
-    public void createApplication(String appName) {
+    public void createApplication(String appName, String sha256) {
         ApplicationEntity app = applicationRepository.findByName(appName).orElseGet(() ->
                 ApplicationEntity.builder()
                         .name(appName)
+                        .sha256(sha256)
                         .build()
         );
         applicationRepository.save(app);

opensergo-dashboard-server/src/main/java/io/opensergo/dashboard/vo/application/ApplicationItem.java

@@ -7,4 +7,6 @@
 @NoArgsConstructor
 public class ApplicationItem {
     String appName;
+
+    String sha256;
 }