<fix>[kvm]: remove TPM when VM deleted from DB

Implement VmJustBeforeDeleteFromDbExtensionPoint to clean up
TPM resources when VM is removed from database. This prevents
TPM resource leakage and ensures proper cleanup.

Related: ZSV-11310

Change-Id: I647a6d676377646b6f7773757363646b6977766b

Author: Zhang Wenhao

plugin/kvm/src/main/java/org/zstack/kvm/tpm/KvmTpmExtensions.java

@@ -33,9 +33,12 @@
 import org.zstack.header.tpm.entity.TpmVO;
 import org.zstack.header.tpm.entity.TpmVO_;
 import org.zstack.header.secret.SecretHostDefineReply;
+import org.zstack.header.tpm.message.RemoveTpmMsg;
 import org.zstack.header.vm.PreVmInstantiateResourceExtensionPoint;
+import org.zstack.header.vm.VmInstanceInventory;
 import org.zstack.header.vm.VmInstanceSpec;
 import org.zstack.header.vm.VmInstantiateResourceException;
+import org.zstack.header.vm.VmJustBeforeDeleteFromDbExtensionPoint;
 import org.zstack.header.vm.additions.VmHostBackupFileVO;
 import org.zstack.header.vm.additions.VmHostBackupFileVO_;
 import org.zstack.header.vm.additions.VmHostFileType;
@@ -54,11 +57,13 @@
 import java.time.Instant;
 import java.util.Map;
 
+import static org.zstack.header.tpm.TpmConstants.SERVICE_ID;
 import static org.zstack.kvm.KVMConstant.*;
 import static org.zstack.core.Platform.operr;
 
 public class KvmTpmExtensions implements KVMStartVmExtensionPoint,
-        PreVmInstantiateResourceExtensionPoint {
+        PreVmInstantiateResourceExtensionPoint,
+        VmJustBeforeDeleteFromDbExtensionPoint {
     private static final CLogger logger = Utils.getLogger(KvmTpmExtensions.class);
 
     @Autowired
@@ -373,6 +378,27 @@ public void fail(ErrorCode errorCode) {
         });
     }
 
+    @Override
+    public void vmJustBeforeDeleteFromDb(VmInstanceInventory inv) {
+        String tpmUuid = Q.New(TpmVO.class)
+                .eq(TpmVO_.vmInstanceUuid, inv.getUuid())
+                .select(TpmVO_.uuid)
+                .findValue();
+        if (tpmUuid == null) {
+            return;
+        }
+
+        RemoveTpmMsg removeMsg = new RemoveTpmMsg();
+        removeMsg.setVmInstanceUuid(inv.getUuid());
+        removeMsg.setTpmUuid(tpmUuid);
+        bus.makeTargetServiceIdByResourceUuid(removeMsg, SERVICE_ID, removeMsg.getTpmUuid());
+        MessageReply reply = bus.call(removeMsg);
+        if (!reply.isSuccess()) {
+            logger.warn(String.format("failed to remove TPM[uuid:%s] of VM[uuid:%s], error: %s",
+                    tpmUuid, inv.getUuid(), reply.getError()));
+        }
+    }
+
     private void clearRollbackInfo(VmInstanceSpec spec) {
         if (spec.getDevicesSpec() == null || spec.getDevicesSpec().getTpm() == null) {
             return;