X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=test%2Fexec_test.go;h=e7992d60870112fd7906deb87b73bfab25a93c44;hb=5dc2ff003106f0ced38caadb06033f24c792f9b9;hp=8fb6519ff7d9af0eada6c88f1e514931fdbf6d47;hpb=8b84b5cac636d639040fc9a7da485263ffbc9a09;p=src%2Fxds%2Fxds-server.git diff --git a/test/exec_test.go b/test/exec_test.go index 8fb6519..e7992d6 100644 --- a/test/exec_test.go +++ b/test/exec_test.go @@ -17,68 +17,105 @@ package xdsservertest import ( - "log" + "bytes" "os" + "os/exec" "path" "testing" - "time" - "gerrit.automotivelinux.org/gerrit/src/xds/xds-server/lib/xsapiv1" - git "github.com/libgit2/git2go" - "github.com/stretchr/testify/assert" + "gerrit.automotivelinux.org/gerrit/src/xds/xds-server.git/lib/xsapiv1" + "github.com/stretchr/testify/require" ) -func TestExec(t *testing.T) { - cloneRepo := "https://github.com/iotbzh/helloworld-service.git" - cloneDir := path.Join(os.Getenv(envRootCfgDir), "testExec") - t.Logf("Cloning repo %v in %v\n...\n", cloneRepo, cloneDir) - var cloneOptions git.CloneOptions - repository, err := git.Clone(cloneRepo, cloneDir, &cloneOptions) - if err != nil { - t.Fatal(err) - } - - repository.Submodules.Foreach(func(sub *git.Submodule, name string) int { - sub.Init(true) - err := sub.Update(true, &git.SubmoduleUpdateOptions{ - &git.CheckoutOpts{ - Strategy: git.CheckoutForce | git.CheckoutUpdateSubmodules, - }, - &git.FetchOptions{}, - }) - if err != nil { - log.Fatal(err) - } - return 0 +func InitExec(t *testing.T) string { + Debugf(t, "Create helloworld directory with app-templates") + /*copy helloworld from fixtures to envRootCfgDir*/ + helloworldDir := path.Join(os.Getenv(envRootCfgDir), "helloworld") + cmd := exec.Command("cp", "-r", helloworldFixturesDir, helloworldDir) + var out bytes.Buffer + cmd.Stdout = &out + require.Nil(t, cmd.Run()) - }) + /*clone submodules app templates into helloworld*/ + subHelloworldAppTemplateDir := path.Join(helloworldDir, "conf.d", "app-templates") + cmd = exec.Command("git", "clone", "-b", "flounder", + "https://gerrit.automotivelinux.org/gerrit/p/apps/app-templates.git", + subHelloworldAppTemplateDir) + require.Nil(t, cmd.Run()) + return helloworldDir +} - t.Logf("repo cloned\n") +func TestExec(t *testing.T) { + helloworldDir := InitExec(t) + /*channel for SDK events*/ + chSdks := make(chan xsapiv1.SDK) + defer close(chSdks) + sdk := xsapiv1.SDKInstallArgs{ + ID: "", + Filename: sdkFileName, + Force: false, + } + ConnectSDKStateChange(t, sCli, chSdks) + sdkRes := installFakeSdk(t, sdk, chSdks) + /*check there is no project*/ var cfgArray []xsapiv1.FolderConfig - assert.Nil(t, HTTPCli.Get("/folders", &cfgArray)) - assert.Equal(t, len(cfgArray), 0) + require.Nil(t, HTTPCli.Get("/folders", &cfgArray)) + require.Equal(t, len(cfgArray), 0) fPrj := xsapiv1.FolderConfig{ Label: "testproject", - ClientPath: cloneDir, + ClientPath: helloworldDir, Type: xsapiv1.TypePathMap, ClientData: "clientdatatest", DataPathMap: xsapiv1.PathMapConfig{ - ServerPath: cloneDir, + ServerPath: helloworldDir, }, } + /*create project*/ var cfg xsapiv1.FolderConfig - assert.Nil(t, HTTPCli.Post("/folders", fPrj, &cfg)) - assert.NotNil(t, cfg) - _, err = NewIoSocketClient(prefixURL, HTTPCli.GetClientID()) - if err != nil { - t.Fatal(err) + require.Nil(t, HTTPCli.Post("/folders", fPrj, &cfg)) + require.NotNil(t, cfg) + + /*channel for ExecExitMsg*/ + chExec := make(chan xsapiv1.ExecExitMsg) + defer close(chExec) + sCli.Conn.On(xsapiv1.ExecExitEvent, func(ev xsapiv1.ExecExitMsg) { + chExec <- ev + }) + + /*Collect commands output in */ + cmdOut := "" + sCli.Conn.On(xsapiv1.ExecOutEvent, func(ev xsapiv1.ExecOutMsg) { + cmdOut += ev.Stdout + ev.Stderr + }) + /*error when exec with fakeid*/ + var execRes xsapiv1.ExecArgs + cmd := "pwd && echo \"SDKTARGETSYSROOT=<$SDKTARGETSYSROOT>\"" + exec := xsapiv1.ExecArgs{ + ID: cfg.ID, + Cmd: cmd, + SdkID: "11111-invalid", } + Debugf(t, "exec cmake cmd(%v)", cmd) + cmdOut = "" + require.NotNil(t, HTTPCli.Post("/exec", exec, &execRes)) - cmd := "export PKG_CONFIG_PATH=/usr/local/lib64/pkgconfig/" - cmd = cmd + " && " - cmd = cmd + "cd " + fPrj.ClientPath + /*basic check: verify that environment is set correctly (use the right sdk)*/ + cmd = "pwd && echo \"SDKTARGETSYSROOT=<$SDKTARGETSYSROOT>\"" + exec = xsapiv1.ExecArgs{ + ID: cfg.ID, + Cmd: cmd, + SdkID: sdkRes.ID, + } + Debugf(t, "exec cmake cmd(%v)", cmd) + cmdOut = "" + require.Nil(t, HTTPCli.Post("/exec", exec, &execRes)) + exitMsg := <-chExec + require.Equal(t, exitMsg.Code, 0) + + /*cmake helloworld project with fake sdk*/ + cmd = "cd " + fPrj.ClientPath cmd = cmd + " && " cmd = cmd + "mkdir -p build" cmd = cmd + " && " @@ -86,28 +123,36 @@ func TestExec(t *testing.T) { cmd = cmd + " && " cmd = cmd + "cmake .." - exec := xsapiv1.ExecArgs{ + /*post exec cmd cmake*/ + exec = xsapiv1.ExecArgs{ ID: cfg.ID, Cmd: cmd, } - var execRes xsapiv1.ExecArgs - assert.Nil(t, HTTPCli.Post("/exec", exec, &execRes)) - time.Sleep(3 * time.Second) //maybe waiting for an event would be better + Debugf(t, "exec cmake cmd(%v)", cmd) + require.Nil(t, HTTPCli.Post("/exec", exec, &execRes)) + exitMsg = <-chExec + require.Equal(t, exitMsg.Code, 0) - cmd = "export PKG_CONFIG_PATH=/usr/local/lib64/pkgconfig/" - cmd = cmd + "&&" - cmd = cmd + "cd " + fPrj.ClientPath + /*make helloworld project with fake sdk*/ + cmd = "cd " + fPrj.ClientPath cmd = cmd + "&&" cmd = cmd + "cd build" cmd = cmd + "&&" cmd = cmd + "make" exec.Cmd = cmd - assert.Nil(t, HTTPCli.Post("/exec", exec, &execRes)) - time.Sleep(3 * time.Second) //maybe waiting for an event would be better + /*post exec cmd make*/ + Debugf(t, "exec make cmd(%v)", cmd) + require.Nil(t, HTTPCli.Post("/exec", exec, &execRes)) + exitMsg = <-chExec + require.Equal(t, exitMsg.Code, 0) - /*check afb-helloworld.so exists*/ - _, err = os.Stat(path.Join(fPrj.ClientPath, "build/helloworld-afb/afb-helloworld.so")) - assert.Nil(t, err) + /*check if helloworld.so exists*/ + Debug(t, "check that helloworld.so exists") + _, err := os.Stat(path.Join(fPrj.ClientPath, "build/helloworld/helloworld.so")) + require.Nil(t, err) - assert.Nil(t, HTTPCli.Delete("/folders/"+cfg.ID, &cfg)) + /*deinit*/ + require.Nil(t, HTTPCli.Delete("/folders/"+cfg.ID, &cfg)) + RemoveSdk(t, sdkRes, chSdks) + DisconnectSDKStateChange(t, sCli) }