Skip to content

Commit

Permalink
fix(ci): copy provider config in test
Browse files Browse the repository at this point in the history
  • Loading branch information
leonarliu committed May 17, 2023
1 parent 3c580f6 commit eb62725
Showing 1 changed file with 26 additions and 1 deletion.
27 changes: 26 additions & 1 deletion test/e2e_installer/node/node_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,10 @@ package node_test
import (
"context"
"errors"
"io/ioutil"
"log"
"os"
"path"
"strings"
"time"

Expand All @@ -31,7 +34,9 @@ import (
platformv1 "tkestack.io/tke/api/platform/v1"
"tkestack.io/tke/pkg/platform/apiserver/cluster"
baremetalcluster "tkestack.io/tke/pkg/platform/provider/baremetal/cluster"
baremetalconstants "tkestack.io/tke/pkg/platform/provider/baremetal/constants"
baremetalmachine "tkestack.io/tke/pkg/platform/provider/baremetal/machine"
clusterprovider "tkestack.io/tke/pkg/platform/provider/cluster"
importedcluster "tkestack.io/tke/pkg/platform/provider/imported/cluster"
tke2 "tkestack.io/tke/test/tke"
testclient "tkestack.io/tke/test/util/client"
Expand All @@ -46,8 +51,26 @@ var (
err error
)

func copyProviderConfig() {
wd, _ := os.Getwd()
log.Printf("current test dir is %v", wd)
err := os.MkdirAll(path.Dir(baremetalconstants.ConfDir), 0755)
if err != nil {
log.Fatalf("create dir failed: %v", err)
}
input, err := ioutil.ReadFile("../../../pkg/platform/" + baremetalconstants.ConfigFile)
if err != nil {
log.Fatalf("read config failed: %v", err)
}
err = ioutil.WriteFile(baremetalconstants.ConfigFile, input, 0755)
if err != nil {
log.Fatalf("write config failed: %v", err)
}
}

var _ = Describe("node", func() {
baremetalcluster.RegisterProvider()
copyProviderConfig()
bp, _ := baremetalcluster.NewProvider()
baremetalmachine.RegisterProvider()
importedcluster.RegisterProvider()

Expand All @@ -73,6 +96,8 @@ var _ = Describe("node", func() {
testTKE := tke2.Init(tkeClient, provider)
cls, err := testTKE.CreateCluster()
Expect(err).To(BeNil(), "Create cluster failed")
bp.PlatformClient = testTKE.TkeClient.PlatformV1()
clusterprovider.Register(bp.Name(), bp)

return []byte(cls.Name + ";" + kubeconfig)
}, func(data []byte) {
Expand Down

0 comments on commit eb62725

Please sign in to comment.