Implement GetTest + GetTestLog RPC handlers for FE v6 Test Detail.

PiperOrigin-RevId: 948840520

Author: OmniLab Team

src/java/com/google/devtools/mobileharness/fe/v6/service/test/BUILD

@@ -0,0 +1,35 @@
+# Copyright 2022 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#    https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+load("@rules_java//java:java_library.bzl", "java_library")
+
+package(
+    default_applicable_licenses = ["//:license"],
+    default_visibility = ["//src/devtools/mobileharness/fe/v6:visibility"],
+)
+
+java_library(
+    name = "test",
+    srcs = glob(["*.java"]),
+    deps = [
+        "//src/devtools/mobileharness/fe/v6/service/proto/test:test_service_java_grpc",
+        "//src/devtools/mobileharness/fe/v6/service/proto/test:test_service_java_proto",
+        "//src/java/com/google/devtools/common/metrics/stability/rpc/grpc:service_util",
+        "@grpc-java//stub",
+        "@maven//:com_google_guava_guava",
+        "@maven//:com_google_inject_guice",
+        "@maven//:javax_inject_jsr330_api",
+    ],
+)

src/java/com/google/devtools/mobileharness/fe/v6/service/test/TestServiceGrpcImpl.java

@@ -0,0 +1,63 @@
+/*
+ * Copyright 2022 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.devtools.mobileharness.fe.v6.service.test;
+
+import com.google.common.util.concurrent.ListeningExecutorService;
+import com.google.devtools.common.metrics.stability.rpc.grpc.GrpcServiceUtil;
+import com.google.devtools.mobileharness.fe.v6.service.proto.test.GetTestLogRequest;
+import com.google.devtools.mobileharness.fe.v6.service.proto.test.GetTestLogResponse;
+import com.google.devtools.mobileharness.fe.v6.service.proto.test.GetTestRequest;
+import com.google.devtools.mobileharness.fe.v6.service.proto.test.GetTestResponse;
+import com.google.devtools.mobileharness.fe.v6.service.proto.test.TestServiceGrpc;
+import io.grpc.stub.StreamObserver;
+import javax.inject.Inject;
+
+/** gRPC implementation of the TestService. */
+public final class TestServiceGrpcImpl extends TestServiceGrpc.TestServiceImplBase {
+
+  private final TestServiceLogic logic;
+  private final ListeningExecutorService executor;
+
+  @Inject
+  TestServiceGrpcImpl(TestServiceLogic logic, ListeningExecutorService executor) {
+    this.logic = logic;
+    this.executor = executor;
+  }
+
+  @Override
+  public void getTest(GetTestRequest request, StreamObserver<GetTestResponse> responseObserver) {
+    GrpcServiceUtil.invokeAsync(
+        request,
+        responseObserver,
+        logic::getTest,
+        executor,
+        TestServiceGrpc.getServiceDescriptor(),
+        TestServiceGrpc.getGetTestMethod());
+  }
+
+  @Override
+  public void getTestLog(
+      GetTestLogRequest request, StreamObserver<GetTestLogResponse> responseObserver) {
+    GrpcServiceUtil.invokeAsync(
+        request,
+        responseObserver,
+        logic::getTestLog,
+        executor,
+        TestServiceGrpc.getServiceDescriptor(),
+        TestServiceGrpc.getGetTestLogMethod());
+  }
+}

src/java/com/google/devtools/mobileharness/fe/v6/service/test/TestServiceLogic.java

@@ -0,0 +1,33 @@
+/*
+ * Copyright 2022 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.devtools.mobileharness.fe.v6.service.test;
+
+import com.google.common.util.concurrent.ListenableFuture;
+import com.google.devtools.mobileharness.fe.v6.service.proto.test.GetTestLogRequest;
+import com.google.devtools.mobileharness.fe.v6.service.proto.test.GetTestLogResponse;
+import com.google.devtools.mobileharness.fe.v6.service.proto.test.GetTestRequest;
+import com.google.devtools.mobileharness.fe.v6.service.proto.test.GetTestResponse;
+
+/** Logic interface for the Test Detail service. */
+public interface TestServiceLogic {
+
+  /** Gets the full test detail (overview, execution details, troubleshooting, sub-tests). */
+  ListenableFuture<GetTestResponse> getTest(GetTestRequest request);
+
+  /** Gets a paginated chunk of the test log. */
+  ListenableFuture<GetTestLogResponse> getTestLog(GetTestLogRequest request);
+}