change docker server

operate/client.go

 package operate
 
 import (
-	"example.com/m/conf"
 	"example.com/m/log"
 	"github.com/docker/docker/client"
 	nodemanagerV1 "github.com/odysseus/odysseus-protocol/gen/proto/go/nodemanager/v1"
@@ -27,7 +26,7 @@ func ConnValidatorGrpc(endpoint string) witnessv1.WitnessServiceClient {
 }
 
 func GetDockerClient() (*client.Client, error) {
-	dockerClient, err := client.NewClientWithOpts(client.WithAPIVersionNegotiation(), client.WithHost(conf.GetConfig().DockerServer))
+	dockerClient, err := client.NewClientWithOpts(client.FromEnv)
 	if err != nil {
 		log.WithField("error", err).Error("create docker client failed")
 		return nil, err

test/rootcmd_test.go

+package test
+
+import (
+	"fmt"
+	"github.com/ethereum/go-ethereum/common"
+	"github.com/ethereum/go-ethereum/crypto"
+	"testing"
+)
+
+func Test_initConfig(t *testing.T) {
+	prvKey, _ := crypto.HexToECDSA("e3b097b0c171e2489973a277b1546392db97e359505cd64b9b52966cb87a0f08")
+	fmt.Println("prvKey:", prvKey)
+	pubKey := common.Bytes2Hex(crypto.FromECDSAPub(&prvKey.PublicKey))
+	fmt.Println("pubKey:", pubKey)
+	address := crypto.PubkeyToAddress(prvKey.PublicKey)
+	fmt.Println("address:", address)
+}

test/task_msg_test.go

@@ -7,7 +7,6 @@ import (
 	"example.com/m/operate"
 	"fmt"
 	"github.com/golang/groupcache/lru"
-	basev1 "github.com/odysseus/odysseus-protocol/gen/proto/go/base/v1"
 	nodeManagerV1 "github.com/odysseus/odysseus-protocol/gen/proto/go/nodemanager/v1"
 	"net/http"
 	"sync"
@@ -63,7 +62,6 @@ func TestTaskHandler_computeTaskHandler(t1 *testing.T) {
 	m := &models.TaskCmd{
 		ImageName: "llm-server:latest",
 		DockerCmd: &models.DockerCmd{
-			ContainerPort: "8888",
 			HostIp:   "0.0.0.0",
 			HostPort: "",
 		},
@@ -85,8 +83,6 @@ func TestTaskHandler_computeTaskHandler(t1 *testing.T) {
 	}
 	n := args{
 		taskMsg: &nodeManagerV1.PushTaskMessage{
-			TaskUuid:  "1111",
-			TaskType:  basev1.TaskType_ComputeTask,
 			Workload:  111,
 			TaskCmd:   string(marshal),
 			TaskParam: taskParamBytes,