2017-11-14 00:02:46 +03:00
|
|
|
package driver
|
|
|
|
|
|
|
|
import (
|
2020-08-31 16:26:48 +02:00
|
|
|
"context"
|
|
|
|
"crypto/tls"
|
2017-11-14 00:02:46 +03:00
|
|
|
"fmt"
|
2018-11-01 00:42:24 +03:00
|
|
|
"math/rand"
|
2020-08-31 16:26:48 +02:00
|
|
|
"net/http"
|
|
|
|
"net/url"
|
2018-10-31 01:10:57 +03:00
|
|
|
"os"
|
2017-11-14 00:02:46 +03:00
|
|
|
"testing"
|
|
|
|
"time"
|
2020-08-31 16:26:48 +02:00
|
|
|
|
|
|
|
"github.com/vmware/govmomi"
|
|
|
|
"github.com/vmware/govmomi/find"
|
|
|
|
"github.com/vmware/govmomi/session"
|
|
|
|
"github.com/vmware/govmomi/simulator"
|
|
|
|
"github.com/vmware/govmomi/vapi/rest"
|
|
|
|
"github.com/vmware/govmomi/vim25"
|
|
|
|
"github.com/vmware/govmomi/vim25/soap"
|
2017-11-14 00:02:46 +03:00
|
|
|
)
|
|
|
|
|
|
|
|
// Defines whether acceptance tests should be run
|
2018-01-24 16:35:04 +03:00
|
|
|
const TestHostName = "esxi-1.vsphere65.test"
|
2017-11-14 00:02:46 +03:00
|
|
|
|
2020-08-31 10:34:41 +02:00
|
|
|
func newTestDriver(t *testing.T) Driver {
|
2018-10-31 01:10:57 +03:00
|
|
|
username := os.Getenv("VSPHERE_USERNAME")
|
|
|
|
if username == "" {
|
|
|
|
username = "root"
|
|
|
|
}
|
|
|
|
password := os.Getenv("VSPHERE_PASSWORD")
|
|
|
|
if password == "" {
|
|
|
|
password = "jetbrains"
|
|
|
|
}
|
|
|
|
|
2020-07-14 11:45:19 +02:00
|
|
|
d, err := NewDriver(&ConnectConfig{
|
2018-01-23 22:51:05 +03:00
|
|
|
VCenterServer: "vcenter.vsphere65.test",
|
2018-10-31 01:10:57 +03:00
|
|
|
Username: username,
|
|
|
|
Password: password,
|
2017-11-14 00:02:46 +03:00
|
|
|
InsecureConnection: true,
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
t.Fatalf("Cannot connect: %v", err)
|
|
|
|
}
|
|
|
|
return d
|
|
|
|
}
|
|
|
|
|
|
|
|
func newVMName() string {
|
|
|
|
rand.Seed(time.Now().UTC().UnixNano())
|
|
|
|
return fmt.Sprintf("test-%v", rand.Intn(1000))
|
|
|
|
}
|
2020-08-31 16:26:48 +02:00
|
|
|
|
|
|
|
func NewSimulatorServer(model *simulator.Model) (*simulator.Server, error) {
|
|
|
|
err := model.Create()
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
model.Service.RegisterEndpoints = true
|
|
|
|
model.Service.TLS = new(tls.Config)
|
|
|
|
model.Service.ServeMux = http.NewServeMux()
|
|
|
|
return model.Service.NewServer(), nil
|
|
|
|
}
|
|
|
|
|
2020-09-02 10:19:57 +02:00
|
|
|
func NewSimulatorDriver(s *simulator.Server) (*VCenterDriver, error) {
|
2020-08-31 16:26:48 +02:00
|
|
|
ctx := context.TODO()
|
|
|
|
user := &url.Userinfo{}
|
|
|
|
s.URL.User = user
|
|
|
|
|
|
|
|
soapClient := soap.NewClient(s.URL, true)
|
|
|
|
vimClient, err := vim25.NewClient(ctx, soapClient)
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
vimClient.RoundTripper = session.KeepAlive(vimClient.RoundTripper, 10*time.Minute)
|
|
|
|
client := &govmomi.Client{
|
|
|
|
Client: vimClient,
|
|
|
|
SessionManager: session.NewManager(vimClient),
|
|
|
|
}
|
|
|
|
|
|
|
|
err = client.SessionManager.Login(ctx, user)
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
finder := find.NewFinder(client.Client, false)
|
|
|
|
datacenter, err := finder.DatacenterOrDefault(ctx, "")
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
finder.SetDatacenter(datacenter)
|
|
|
|
|
|
|
|
d := &VCenterDriver{
|
|
|
|
ctx: ctx,
|
|
|
|
client: client,
|
|
|
|
vimClient: vimClient,
|
|
|
|
restClient: &RestClient{
|
|
|
|
client: rest.NewClient(vimClient),
|
|
|
|
credentials: user,
|
|
|
|
},
|
|
|
|
datacenter: datacenter,
|
|
|
|
finder: finder,
|
|
|
|
}
|
|
|
|
return d, nil
|
|
|
|
}
|