feat(model): add BizModelVersion to BizOperationResponse

Enhance BizOperationResponse by including BizModelVersion field to
track the version of the business model used during operations.

feat(http_tunnel): update StartBiz and StopBiz to use podKey

Refactor StartBiz and StopBiz methods to accept podKey parameter
for better tracking of business model versions during operations.

feat(mqtt_tunnel): update StartBiz and StopBiz to use podKey

Modify StartBiz and StopBiz methods to include podKey parameter
for improved business model version management in MQTT operations.

Author: Aiden2014

common/model/model.go

@@ -31,10 +31,11 @@ type BaseStatus struct {
 
 // BizOperationResponse represents the response from a business operation
 type BizOperationResponse struct {
-	Command    string                                       `json:"command"`    // Operation command executed
-	BizName    string                                       `json:"bizName"`    // ClusterName of the business
-	BizVersion string                                       `json:"bizVersion"` // Version of the business
-	Response   ark_service.ArkResponse[ark.ArkResponseData] `json:"response"`   // Response from ark service
+	Command         string                                       `json:"command"`         // Operation command executed
+	BizName         string                                       `json:"bizName"`         // ClusterName of the business
+	BizVersion      string                                       `json:"bizVersion"`      // Version of the business
+	BizModelVersion string                                       `json:"bizModelVersion"` // Version of the business model
+	Response        ark_service.ArkResponse[ark.ArkResponseData] `json:"response"`        // Response from ark service
 }
 
 type BatchInstallBizResponse struct {

module_tunnels/koupleless_http_tunnel/http_tunnel.go

@@ -324,7 +324,7 @@ func (h *HttpTunnel) QueryAllBizStatusData(nodeName string) error {
 }
 
 // StartBiz starts a container on the node
-func (h *HttpTunnel) StartBiz(nodeName, _ string, container *corev1.Container) error {
+func (h *HttpTunnel) StartBiz(nodeName, podKey string, container *corev1.Container) error {
 
 	nodeID := utils2.ExtractNodeIDFromNodeName(nodeName)
 	h.Lock()
@@ -335,14 +335,16 @@ func (h *HttpTunnel) StartBiz(nodeName, _ string, container *corev1.Container) e
 	}
 
 	bizModel := utils.TranslateCoreV1ContainerToBizModel(container)
+	bizModel.BizModelVersion = podKey
 	logger := zaplogger.FromContext(h.ctx).WithValues("bizName", bizModel.BizName, "bizVersion", bizModel.BizVersion)
 	logger.Info("InstallModule")
 
 	// install current version
 	bizOperationResponse := model.BizOperationResponse{
-		Command:    model.CommandInstallBiz,
-		BizName:    bizModel.BizName,
-		BizVersion: bizModel.BizVersion,
+		Command:         model.CommandInstallBiz,
+		BizName:         bizModel.BizName,
+		BizVersion:      bizModel.BizVersion,
+		BizModelVersion: podKey,
 	}
 
 	response, err := h.arkService.InstallBiz(h.ctx, ark_service.InstallBizRequest{
@@ -357,7 +359,7 @@ func (h *HttpTunnel) StartBiz(nodeName, _ string, container *corev1.Container) e
 }
 
 // StopBiz shuts down a container on the node
-func (h *HttpTunnel) StopBiz(nodeName, _ string, container *corev1.Container) error {
+func (h *HttpTunnel) StopBiz(nodeName, podKey string, container *corev1.Container) error {
 	nodeID := utils2.ExtractNodeIDFromNodeName(nodeName)
 	h.Lock()
 	baseStatus, ok := h.nodeIdToBaseStatusMap[nodeID]
@@ -367,13 +369,15 @@ func (h *HttpTunnel) StopBiz(nodeName, _ string, container *corev1.Container) er
 	}
 
 	bizModel := utils.TranslateCoreV1ContainerToBizModel(container)
+	bizModel.BizModelVersion = podKey
 	logger := zaplogger.FromContext(h.ctx).WithValues("bizName", bizModel.BizName, "bizVersion", bizModel.BizVersion)
 	logger.Info("UninstallModule")
 
 	bizOperationResponse := model.BizOperationResponse{
-		Command:    model.CommandUnInstallBiz,
-		BizName:    bizModel.BizName,
-		BizVersion: bizModel.BizVersion,
+		Command:         model.CommandUnInstallBiz,
+		BizName:         bizModel.BizName,
+		BizVersion:      bizModel.BizVersion,
+		BizModelVersion: podKey,
 	}
 
 	response, err := h.arkService.UninstallBiz(h.ctx, ark_service.UninstallBizRequest{

module_tunnels/koupleless_mqtt_tunnel/mqtt_tunnel.go

@@ -5,22 +5,24 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"strings"
+	"sync"
+	"time"
+
 	paho "github.com/eclipse/paho.mqtt.golang"
 	"github.com/koupleless/arkctl/v1/service/ark"
 	"github.com/koupleless/module_controller/common/model"
 	"github.com/koupleless/module_controller/common/utils"
 	"github.com/koupleless/module_controller/common/zaplogger"
 	"github.com/koupleless/module_controller/controller/module_deployment_controller"
+	"github.com/koupleless/module_controller/module_tunnels/koupleless_http_tunnel/ark_service"
 	"github.com/koupleless/module_controller/module_tunnels/koupleless_mqtt_tunnel/mqtt"
 	utils2 "github.com/koupleless/virtual-kubelet/common/utils"
 	vkModel "github.com/koupleless/virtual-kubelet/model"
 	"github.com/koupleless/virtual-kubelet/tunnel"
 	"github.com/virtual-kubelet/virtual-kubelet/log"
 	corev1 "k8s.io/api/core/v1"
 	"sigs.k8s.io/controller-runtime/pkg/client"
-	"strings"
-	"sync"
-	"time"
 )
 
 var _ tunnel.Tunnel = &MqttTunnel{}
@@ -429,18 +431,24 @@ func (mqttTunnel *MqttTunnel) QueryAllBizStatusData(nodeName string) error {
 	return mqttTunnel.mqttClient.Pub(utils.FormatArkletCommandTopic(mqttTunnel.env, nodeID, model.CommandQueryAllBiz), mqtt.Qos0, []byte("{}"))
 }
 
-func (mqttTunnel *MqttTunnel) StartBiz(nodeName, _ string, container *corev1.Container) error {
+func (mqttTunnel *MqttTunnel) StartBiz(nodeName, podKey string, container *corev1.Container) error {
 	bizModel := utils.TranslateCoreV1ContainerToBizModel(container)
 	zlogger := zaplogger.FromContext(mqttTunnel.ctx).WithValues("bizName", bizModel.BizName, "bizVersion", bizModel.BizVersion)
 	zlogger.Info("InstallModule")
-	installBizRequestBytes, _ := json.Marshal(bizModel)
+	installBizRequestBytes, _ := json.Marshal(ark_service.InstallBizRequest{
+		BizModel: bizModel,
+		PodKey:   podKey,
+	})
 	nodeID := utils2.ExtractNodeIDFromNodeName(nodeName)
 	return mqttTunnel.mqttClient.Pub(utils.FormatArkletCommandTopic(mqttTunnel.env, nodeID, model.CommandInstallBiz), mqtt.Qos0, installBizRequestBytes)
 }
 
-func (mqttTunnel *MqttTunnel) StopBiz(nodeName, _ string, container *corev1.Container) error {
+func (mqttTunnel *MqttTunnel) StopBiz(nodeName, podKey string, container *corev1.Container) error {
 	bizModel := utils.TranslateCoreV1ContainerToBizModel(container)
-	unInstallBizRequestBytes, _ := json.Marshal(bizModel)
+	unInstallBizRequestBytes, _ := json.Marshal(ark_service.UninstallBizRequest{
+		BizModel: bizModel,
+		PodKey:   podKey,
+	})
 	zlogger := zaplogger.FromContext(mqttTunnel.ctx).WithValues("bizName", bizModel.BizName, "bizVersion", bizModel.BizVersion)
 	zlogger.Info("UninstallModule")
 	nodeID := utils2.ExtractNodeIDFromNodeName(nodeName)