iaas

var CheckNetService = func(openstack iaasaccessor.IaaS) error {
	_, err := openstack.GetNetwork("this-is-a-error-uuid-for-auth")
	if err != nil && strings.Contains(err.Error(), "GetNetwork: socket-error") {
		return err
	}
	return nil
}

var CheckOpenstackConfig = func(conf *openstack.OpenStackConf) (*gophercloud.ProviderClient, error) {
	var config gophercloud.AuthOptions
	config.Username = conf.Username
	config.Password = conf.Password
	config.TenantName = conf.TenantName
	config.TenantID = conf.Tenantid
	config.IdentityEndpoint = conf.Url + "/tokens"
	c, err := openstack.AuthenticatedClientV2(config)
	if err != nil {
		klog.Error("CheckOpenstackConfig call AuthenticatedClient Error:", err)
		return nil, err
	}

	if c.TenantID == "" || c.TenantName == "" {
		klog.Error("openstack user info input error TenantID[", c.TenantID, "]TenantName[", c.TenantName, "]")
		return nil, errors.New("openstack user info input error")
	}

	return c, nil
}

var GetDefaultPhysnet = func() (string, error) {
	key := dbaccessor.GetKeyOfDefaultPhysnet()
	physnet, errR := common.GetDataBase().ReadLeaf(key)
	if errR != nil {
		klog.Errorf("ReadLeaf:key[%v] Err: %v", key, errR)
		return "", errR
	}
	return physnet, nil
}

var GetIaaS = func(paasTenantID string) iaasaccessor.IaaS {
	iaasTenantID, _ := GetIaasTenantIDByPaasTenantID(paasTenantID)
	if iaasTenantID == "" {
		iaasObj, err := InitIaasForDefault(paasTenantID)
		if err != nil {
			return nil
		}
		return iaasObj.IaaSInterface
	}
	timeNow := time.Now().Unix()
	iaasObj, err := GetIaasObjMgrSingleton().Get(iaasTenantID)
	if err == nil {
		return iaasObj.IaaSInterface
	}
	isInitIaas := (err.Error() == constvalue.ErrOfIaasTenantNotExist) ||
		(err.Error() == constvalue.ErrOfIaasInterfaceNil && timeNow-iaasObj.TimeLastGetIaas >= authIntenal)
	if isInitIaas {
		err := InitIaasByKnitterJSON(iaasTenantID)
		if err != nil {
			return nil
		}
		iaasObjAfterInit, _ := GetIaasObjMgrSingleton().Get(iaasTenantID)
		return iaasObjAfterInit.IaaSInterface
	}
	return nil
}

var GetSceneByKnitterJSON = func() (string, error) {
	return constvalue.EMBEDDED, nil
}

var InitIaaS = func() error {
	var err error

	cfg := common.GetOpenstackCfg()
	klog.Info("OpenStack Configration:", cfg)
	openstack := openstack.NewOpenstack()
	err = openstack.SetOpenstackConfig(cfg)
	if err != nil {
		klog.Warning("IaaS-SetOpenstackConfig-ERROR")
		return err
	}
	err = openstack.Auth()
	if err != nil {
		klog.Warning("IaaS-auth-ERROR")
		return err
	}
	err = CheckNetService(openstack)
	if err != nil {
		klog.Error("NetService-check-ERROR")
		return err
	}
	klog.Info("IaaS-auth-OK")
	SetIaaS(openstack.GetTenantID(), openstack)

	return nil
}

var SaveDefaultPhysnet = func(defaultPhysnet string) error {
	key := dbaccessor.GetKeyOfDefaultPhysnet()
	klog.Infof("DefaultPhysnet: %v", defaultPhysnet)
	errE := common.GetDataBase().SaveLeaf(key, defaultPhysnet)
	if errE != nil {
		klog.Errorf("SaveLeaf:key[%v],value[%v]: %v", key, defaultPhysnet, errE)
		return errE
	}
	return nil
}