Cloudpods/backend/cmd/climc/shell/compute/cloudregions.go

// Copyright 2019 Yunion
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package compute

import (
	"fmt"

	"yunion.io/x/jsonutils"
	"yunion.io/x/pkg/util/printutils"

	"yunion.io/x/onecloud/cmd/climc/shell"
	"yunion.io/x/onecloud/pkg/mcclient"
	modules "yunion.io/x/onecloud/pkg/mcclient/modules/compute"
	"yunion.io/x/onecloud/pkg/mcclient/options"
	"yunion.io/x/onecloud/pkg/mcclient/options/compute"
)

func init() {
	cmd := shell.NewResourceCmd(&modules.Cloudregions).WithKeyword("cloud-region")
	cmd.PerformClass("sync-skus", &compute.CloudregionSkuSyncOptions{})
	cmd.Perform("sync-images", &compute.CloudregionIdOptions{})
	cmd.Perform("purge", &compute.CloudregionPurgeOptions{})

	type CloudregionListOptions struct {
		options.BaseListOptions

		Usable    *bool  `help:"List regions where networks are usable"`
		UsableVpc *bool  `help:"List regions where VPC are usable"`
		Service   string `help:"List regions which service has available skus" choices:"dbinstances|servers|elasticcaches"`

		City string `help:"List regions in the specified city"`

		Capability []string `help:"capability filter" choices:"project|compute|network|loadbalancer|objectstore|rds|cache|event"`

		DistinctField string `help:"list the specified distinct field, e.g. city, region"`

		OrderByZoneCount  string
		OrderByVpcCount   string
		OrderByGuestCount string
	}
	R(&CloudregionListOptions{}, "cloud-region-list", "List cloud regions", func(s *mcclient.ClientSession, opts *CloudregionListOptions) error {
		params, err := options.ListStructToParams(opts)
		if err != nil {
			return err
		}
		if len(opts.DistinctField) > 0 {
			params.Add(jsonutils.NewString(opts.DistinctField), "extra_field")
			result, err := modules.Cloudregions.Get(s, "distinct-field", params)
			if err != nil {
				return err
			}
			fmt.Println(result)
			return nil
		}
		result, err := modules.Cloudregions.List(s, params)
		if err != nil {
			return err
		}
		printList(result, modules.Cloudregions.GetColumns(s))
		return nil
	})

	type CloudregionCityListOptions struct {
		Manager  string `help:"List objects belonging to the cloud provider"`
		Account  string `help:"List objects belonging to the cloud account"`
		Provider string `help:"List objects from the provider" choices:"VMware|Aliyun|Qcloud|Azure|Aws|Huawei|Openstack|Ucloud|ZStack|Google|Ctyun"`
		City     string `help:"List regions in the specified city"`

		PublicCloud  *bool `help:"List objects belonging to public cloud" json:"public_cloud"`
		PrivateCloud *bool `help:"List objects belonging to private cloud" json:"private_cloud"`

		Usable    *bool `help:"List regions where networks are usable"`
		UsableVpc *bool `help:"List regions where VPC are usable"`

		Scope         string `help:"query scope" choices:"system|domain"`
		ProjectDomain string `help:"query domain"`
	}
	R(&CloudregionCityListOptions{}, "cloud-region-cities", "List cities where cloud region resides", func(s *mcclient.ClientSession, args *CloudregionCityListOptions) error {
		params, err := options.StructToParams(args)
		if err != nil {
			return err
		}
		results, err := modules.Cloudregions.GetRegionCities(s, params)
		if err != nil {
			return err
		}
		listResult := printutils.ListResult{}
		listResult.Data, err = results.GetArray()
		if err != nil {
			return err
		}
		printList(&listResult, nil)
		return nil
	})

	R(&CloudregionCityListOptions{}, "cloud-region-providers", "List cities where cloud region resides", func(s *mcclient.ClientSession, args *CloudregionCityListOptions) error {
		params, err := options.StructToParams(args)
		if err != nil {
			return err
		}
		results, err := modules.Cloudregions.GetRegionProviders(s, params)
		if err != nil {
			return err
		}
		listResult := printutils.ListResult{}
		listResult.Data, err = results.GetArray()
		if err != nil {
			return err
		}
		printList(&listResult, nil)
		return nil
	})

	R(&CloudregionCityListOptions{}, "cloud-city-servers", "List cities where cloud region resides", func(s *mcclient.ClientSession, args *CloudregionCityListOptions) error {
		params, err := options.StructToParams(args)
		if err != nil {
			return err
		}
		results, err := modules.Cloudregions.GetCityServers(s, params)
		if err != nil {
			return err
		}
		listResult := printutils.ListResult{}
		listResult.Data, err = results.GetArray()
		if err != nil {
			return err
		}
		printList(&listResult, nil)
		return nil
	})

	type CloudregionCreateOptions struct {
		Id          string  `help:"ID of the region"`
		NAME        string  `help:"Name of the region"`
		Provider    string  `help:"Cloud provider"`
		Desc        string  `help:"Description" json:"description" token:"desc"`
		Latitude    float32 `help:"region geographical location - latitude"`
		Longitude   float32 `help:"region geographical location - longitude"`
		City        string  `help:"region geograpical location - city, e.g. Beijing, Frankfurt"`
		CountryCode string  `help:"region geographical location - ISO country code, e.g. CN"`
	}
	R(&CloudregionCreateOptions{}, "cloud-region-create", "Create a cloud region", func(s *mcclient.ClientSession, args *CloudregionCreateOptions) error {
		params, err := options.StructToParams(args)
		if err != nil {
			return err
		}
		results, err := modules.Cloudregions.Create(s, params)
		if err != nil {
			return err
		}
		printObject(results)
		return nil
	})

	type CloudregionShowOptions struct {
		ID string `help:"ID or name of the region"`
	}
	R(&CloudregionShowOptions{}, "cloud-region-show", "Show a cloud region", func(s *mcclient.ClientSession, args *CloudregionShowOptions) error {
		results, err := modules.Cloudregions.Get(s, args.ID, nil)
		if err != nil {
			return err
		}
		printObject(results)
		return nil
	})

	R(&CloudregionShowOptions{}, "cloud-region-delete", "Delete a cloud region", func(s *mcclient.ClientSession, args *CloudregionShowOptions) error {
		results, err := modules.Cloudregions.Delete(s, args.ID, nil)
		if err != nil {
			return err
		}
		printObject(results)
		return nil
	})

	type CloudregionUpdateOptions struct {
		ID          string  `help:"ID or name of the region to update" json:"-"`
		Name        string  `help:"New name of the region"`
		Desc        string  `help:"Description of the region" json:"description" token:"desc"`
		Latitude    float32 `help:"region geographical location - latitude"`
		Longitude   float32 `help:"region geographical location - longitude"`
		City        string  `help:"region geograpical location - city, e.g. Beijing, Frankfurt"`
		CountryCode string  `help:"region geographical location - ISO country code, e.g. CN"`
	}
	R(&CloudregionUpdateOptions{}, "cloud-region-update", "Update a cloud region", func(s *mcclient.ClientSession, args *CloudregionUpdateOptions) error {
		params, err := options.StructToParams(args)
		if err != nil {
			return err
		}
		results, err := modules.Cloudregions.Update(s, args.ID, params)
		if err != nil {
			return err
		}
		printObject(results)
		return nil
	})

	type CloudregionSetDefaultVpcOptions struct {
		ID  string `help:"ID or name of the region"`
		VPC string `help:"ID or name of VPC to make default"`
	}
	R(&CloudregionSetDefaultVpcOptions{}, "cloud-region-set-default-vpc", "Set default vpc for a region", func(s *mcclient.ClientSession, args *CloudregionSetDefaultVpcOptions) error {
		params := jsonutils.NewDict()
		params.Add(jsonutils.NewString(args.VPC), "vpc")
		result, err := modules.Cloudregions.PerformAction(s, args.ID, "default-vpc", params)
		if err != nil {
			return err
		}
		printObject(result)
		return nil
	})

	type CloudregionCapabiltyOptions struct {
		ID     string `help:"ID or name of cloud region to check" json:"-"`
		Domain string `help:"cloud region domain"`

		ShowEmulated bool `help:"show emulated cloud region"`
	}
	R(&CloudregionCapabiltyOptions{}, "cloud-region-capability", "Show region's capacibilities", func(s *mcclient.ClientSession, args *CloudregionCapabiltyOptions) error {
		query, err := options.StructToParams(args)
		result, err := modules.Cloudregions.GetSpecific(s, args.ID, "capability", query)
		if err != nil {
			return err
		}
		printObject(result)
		return nil
	})
}