Internal change

PiperOrigin-RevId: 850272462

Author: DeviceInfra

src/devtools/mobileharness/fe/v6/angular/app/core/services/host/fake_host_service.ts

@@ -64,4 +64,24 @@ export class FakeHostService extends HostService {
       );
     }
   }
+
+  override decommissionMissingDevices(
+    hostName: string,
+    deviceControlIds: string[],
+  ): Observable<void> {
+    const scenario = MOCK_HOST_SCENARIOS.find((s) => s.hostName === hostName);
+    if (scenario && scenario.deviceSummaries) {
+      scenario.deviceSummaries = scenario.deviceSummaries.filter(
+        (d) => !deviceControlIds.includes(d.id),
+      );
+      return of(undefined);
+    } else {
+      return throwError(
+        () =>
+          new Error(
+            `Host with '${hostName}' not found or has no devices in mock data.`,
+          ),
+      );
+    }
+  }
 }

src/devtools/mobileharness/fe/v6/angular/app/core/services/host/host_service.ts

@@ -31,4 +31,15 @@ export abstract class HostService {
     hostName: string,
     flags: string,
   ): Observable<void>;
+
+  /**
+   * Decommissions missing devices on a specific host.
+   * @param hostName The name of the host.
+   * @param deviceControlIds The list of device control IDs to decommission.
+   * @return An Observable emitting when the operation is complete.
+   */
+  abstract decommissionMissingDevices(
+    hostName: string,
+    deviceControlIds: string[],
+  ): Observable<void>;
 }

src/devtools/mobileharness/fe/v6/angular/app/core/services/host/http_host_service.ts

@@ -36,4 +36,16 @@ export class HttpHostService extends HostService {
       flags,
     });
   }
+
+  override decommissionMissingDevices(
+    hostName: string,
+    deviceControlIds: string[],
+  ): Observable<void> {
+    return this.http.post<void>(
+      `${this.apiUrl}/${hostName}/decommissionMissingDevices`,
+      {
+        deviceControlIds,
+      },
+    );
+  }
 }

src/devtools/mobileharness/fe/v6/service/proto/host/host_service.proto

@@ -50,6 +50,15 @@ service HostService {
       body: "*"
     };
   }
+
+  // Decommissions missing devices on a specific host.
+  rpc DecommissionMissingDevices(DecommissionMissingDevicesRequest)
+      returns (DecommissionMissingDevicesResponse) {
+    option (google.api.http) = {
+      post: "/v6/hosts/{host_name}/decommission_missing_devices"
+      body: "*"
+    };
+  }
 }
 
 // Request message for GetHostOverview.
@@ -80,3 +89,14 @@ message UpdatePassThroughFlagsRequest {
 
 // Response message for UpdatePassThroughFlags.
 message UpdatePassThroughFlagsResponse {}
+
+// Request message for DecommissionMissingDevices.
+message DecommissionMissingDevicesRequest {
+  // The unique name of the host.
+  string host_name = 1;
+  // The list of device control IDs to decommission.
+  repeated string device_control_ids = 2;
+}
+
+// Response message for DecommissionMissingDevices.
+message DecommissionMissingDevicesResponse {}

src/java/com/google/devtools/mobileharness/fe/v6/service/host/HostServiceGrpcImpl.java

@@ -18,6 +18,8 @@
 
 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.host.DecommissionMissingDevicesRequest;
+import com.google.devtools.mobileharness.fe.v6.service.proto.host.DecommissionMissingDevicesResponse;
 import com.google.devtools.mobileharness.fe.v6.service.proto.host.GetHostDeviceSummariesRequest;
 import com.google.devtools.mobileharness.fe.v6.service.proto.host.GetHostDeviceSummariesResponse;
 import com.google.devtools.mobileharness.fe.v6.service.proto.host.GetHostOverviewRequest;
@@ -77,4 +79,17 @@ public void updatePassThroughFlags(
         HostServiceGrpc.getServiceDescriptor(),
         HostServiceGrpc.getUpdatePassThroughFlagsMethod());
   }
+
+  @Override
+  public void decommissionMissingDevices(
+      DecommissionMissingDevicesRequest request,
+      StreamObserver<DecommissionMissingDevicesResponse> responseObserver) {
+    GrpcServiceUtil.invokeAsync(
+        request,
+        responseObserver,
+        logic::decommissionMissingDevices,
+        executor,
+        HostServiceGrpc.getServiceDescriptor(),
+        HostServiceGrpc.getDecommissionMissingDevicesMethod());
+  }
 }

src/java/com/google/devtools/mobileharness/fe/v6/service/host/HostServiceLogic.java

@@ -17,6 +17,8 @@
 package com.google.devtools.mobileharness.fe.v6.service.host;
 
 import com.google.common.util.concurrent.ListenableFuture;
+import com.google.devtools.mobileharness.fe.v6.service.proto.host.DecommissionMissingDevicesRequest;
+import com.google.devtools.mobileharness.fe.v6.service.proto.host.DecommissionMissingDevicesResponse;
 import com.google.devtools.mobileharness.fe.v6.service.proto.host.GetHostDeviceSummariesRequest;
 import com.google.devtools.mobileharness.fe.v6.service.proto.host.GetHostDeviceSummariesResponse;
 import com.google.devtools.mobileharness.fe.v6.service.proto.host.GetHostOverviewRequest;
@@ -33,4 +35,7 @@ ListenableFuture<GetHostDeviceSummariesResponse> getHostDeviceSummaries(
 
   ListenableFuture<UpdatePassThroughFlagsResponse> updatePassThroughFlags(
       UpdatePassThroughFlagsRequest request);
+
+  ListenableFuture<DecommissionMissingDevicesResponse> decommissionMissingDevices(
+      DecommissionMissingDevicesRequest request);
 }

src/java/com/google/devtools/mobileharness/fe/v6/service/host/HostServiceLogicImpl.java

@@ -20,6 +20,8 @@
 
 import com.google.common.util.concurrent.ListenableFuture;
 import com.google.devtools.mobileharness.fe.v6.service.host.handlers.GetHostOverviewHandler;
+import com.google.devtools.mobileharness.fe.v6.service.proto.host.DecommissionMissingDevicesRequest;
+import com.google.devtools.mobileharness.fe.v6.service.proto.host.DecommissionMissingDevicesResponse;
 import com.google.devtools.mobileharness.fe.v6.service.proto.host.GetHostDeviceSummariesRequest;
 import com.google.devtools.mobileharness.fe.v6.service.proto.host.GetHostDeviceSummariesResponse;
 import com.google.devtools.mobileharness.fe.v6.service.proto.host.GetHostOverviewRequest;
@@ -58,4 +60,11 @@ public ListenableFuture<UpdatePassThroughFlagsResponse> updatePassThroughFlags(
     // TODO: Implement this method.
     return immediateFuture(UpdatePassThroughFlagsResponse.getDefaultInstance());
   }
+
+  @Override
+  public ListenableFuture<DecommissionMissingDevicesResponse> decommissionMissingDevices(
+      DecommissionMissingDevicesRequest request) {
+    // TODO: Implement this method.
+    return immediateFuture(DecommissionMissingDevicesResponse.getDefaultInstance());
+  }
 }