Add grpc 1.26.0->1.58.0 test case

support usePlaintext differential calling

Author: huicunjun

test/plugin/scenarios/grpc-scenario/src/main/java/org/apache/skywalking/apm/testcase/grpc/controller/CaseController.java

@@ -23,6 +23,8 @@
 import io.grpc.ManagedChannelBuilder;
 import io.grpc.stub.ClientCallStreamObserver;
 import io.grpc.stub.ClientResponseObserver;
+
+import java.lang.reflect.Method;
 import java.util.Arrays;
 import java.util.Iterator;
 import java.util.List;
@@ -35,6 +37,8 @@
 import org.apache.skywalking.apm.testcase.grpc.proto.GreeterGrpc;
 import org.apache.skywalking.apm.testcase.grpc.proto.HelloRequest;
 import org.apache.skywalking.apm.testcase.grpc.proto.HelloReply;
+import org.springframework.cglib.core.ReflectUtils;
+import org.springframework.util.ReflectionUtils;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.ResponseBody;
 import org.springframework.web.bind.annotation.RestController;
@@ -56,7 +60,17 @@ public class CaseController {
 
     @PostConstruct
     public void up() {
-        channel = ManagedChannelBuilder.forAddress(grpcProviderHost, grpcProviderPort).usePlaintext(true).build();
+        ManagedChannelBuilder<?> managedChannelBuilder = ManagedChannelBuilder.forAddress(grpcProviderHost, grpcProviderPort);
+        Method usePlaintext = ReflectionUtils.findMethod(managedChannelBuilder.getClass(), "usePlaintext");
+        if (usePlaintext != null) {
+            int paramCount = usePlaintext.getParameterCount();
+            if (paramCount == 0) {// no parame method usePlaintext()
+                ReflectionUtils.invokeMethod(usePlaintext, managedChannelBuilder);
+            } else if (paramCount == 1 && usePlaintext.getParameterTypes()[0] == boolean.class) {// boolean method usePlaintext(true)
+                ReflectionUtils.invokeMethod(usePlaintext, managedChannelBuilder, true);
+            }
+        }
+        channel = managedChannelBuilder.build();
         greeterStub = GreeterGrpc.newStub(ClientInterceptors.intercept(channel, new ConsumerInterceptor()));
         greeterBlockingStub = GreeterBlockingGrpc.newBlockingStub(ClientInterceptors.intercept(channel, new ConsumerInterceptor()));
         greeterBlockingErrorStub = GreeterBlockingErrorGrpc.newBlockingStub(ClientInterceptors.intercept(channel, new ConsumerInterceptor()));

test/plugin/scenarios/grpc-scenario/support-version.list

@@ -19,6 +19,40 @@
 
 # Contains only the last version number of each minor version
 
+1.58.0
+1.57.0
+1.57.0
+1.56.0
+1.55.1
+1.54.0
+1.53.0
+1.52.0
+1.51.0
+1.50.0
+1.49.0
+1.48.0
+1.47.0
+1.46.0
+1.45.0
+1.44.0
+1.43.0
+1.42.0
+1.41.0
+1.40.0
+1.39.0
+1.38.0
+1.37.0
+1.36.0
+1.35.0
+1.34.0
+1.33.0
+1.32.1
+1.31.0
+1.30.0
+1.29.0
+1.28.0
+1.27.0
+1.26.0
 1.25.0
 1.24.2
 1.23.1