移除多余的 taskflow VM 信息查询

Author: yokowu

backend/biz/host/usecase/host.go

@@ -479,21 +479,13 @@ func (h *HostUsecase) VMInfo(ctx context.Context, uid uuid.UUID, id string) (*do
 		return nil, err
 	}
 
-	reportedStatus := taskflow.VirtualMachineStatusUnknown
-	if info, err := h.taskflow.VirtualMachiner().Info(ctx, taskflow.VirtualMachineInfoReq{
-		ID:     vm.ID,
-		UserID: vm.UserID.String(),
-	}); err == nil && info != nil && info.Status != taskflow.VirtualMachineStatusUnknown {
-		reportedStatus = info.Status
-	}
 	dvm := cvt.From(vm, &domain.VirtualMachine{
 		Status: vmstatus.Resolve(vmstatus.Input{
-			ReportedStatus: reportedStatus,
-			Online:         vmonline.OnlineMap[vm.ID],
-			Conditions:     vm.Conditions.Conditions,
-			IsRecycled:     vm.IsRecycled,
-			CreatedAt:      vm.CreatedAt,
-			Now:            time.Now(),
+			Online:     vmonline.OnlineMap[vm.ID],
+			Conditions: vm.Conditions.Conditions,
+			IsRecycled: vm.IsRecycled,
+			CreatedAt:  vm.CreatedAt,
+			Now:        time.Now(),
 		}),
 	})
 

backend/pkg/vmstatus/status.go

@@ -10,23 +10,18 @@ import (
 const readyTimeout = 3 * time.Minute
 
 type Input struct {
-	ReportedStatus taskflow.VirtualMachineStatus
-	Online         bool
-	Conditions     []*etypes.Condition
-	IsRecycled     bool
-	CreatedAt      time.Time
-	Now            time.Time
+	Online     bool
+	Conditions []*etypes.Condition
+	IsRecycled bool
+	CreatedAt  time.Time
+	Now        time.Time
 }
 
 func Resolve(input Input) taskflow.VirtualMachineStatus {
 	if input.IsRecycled {
 		return taskflow.VirtualMachineStatusOffline
 	}
 
-	if input.ReportedStatus != "" && input.ReportedStatus != taskflow.VirtualMachineStatusUnknown {
-		return input.ReportedStatus
-	}
-
 	if input.Online {
 		return taskflow.VirtualMachineStatusOnline
 	}

backend/pkg/vmstatus/status_test.go

@@ -1,13 +1,20 @@
 package vmstatus
 
 import (
+	"reflect"
 	"testing"
 	"time"
 
 	etypes "github.com/chaitin/MonkeyCode/backend/ent/types"
 	"github.com/chaitin/MonkeyCode/backend/pkg/taskflow"
 )
 
+func TestInputDoesNotExposeReportedStatus(t *testing.T) {
+	if _, ok := reflect.TypeOf(Input{}).FieldByName("ReportedStatus"); ok {
+		t.Fatal("Input should not expose ReportedStatus")
+	}
+}
+
 func TestResolve(t *testing.T) {
 	now := time.Date(2026, 4, 15, 12, 0, 0, 0, time.UTC)
 
@@ -19,29 +26,27 @@ func TestResolve(t *testing.T) {
 		{
 			name: "is recycled overrides everything",
 			input: Input{
-				ReportedStatus: taskflow.VirtualMachineStatusOnline,
-				Online:         true,
-				IsRecycled:     true,
-				CreatedAt:      now.Add(-10 * time.Minute),
-				Now:            now,
+				Online:     true,
+				IsRecycled: true,
+				CreatedAt:  now.Add(-10 * time.Minute),
+				Now:        now,
 			},
 			want: taskflow.VirtualMachineStatusOffline,
 		},
 		{
-			name: "reported status wins over online and conditions",
+			name: "online returns online before conditions",
 			input: Input{
-				ReportedStatus: taskflow.VirtualMachineStatusHibernated,
-				Online:         true,
+				Online: true,
 				Conditions: []*etypes.Condition{
 					{Type: etypes.ConditionTypeFailed},
 				},
 				CreatedAt: now.Add(-10 * time.Minute),
 				Now:       now,
 			},
-			want: taskflow.VirtualMachineStatusHibernated,
+			want: taskflow.VirtualMachineStatusOnline,
 		},
 		{
-			name: "online returns online when no reported status",
+			name: "online returns online",
 			input: Input{
 				Online:    true,
 				CreatedAt: now.Add(-10 * time.Minute),