// 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 image

import (
	"yunion.io/x/jsonutils"
	"yunion.io/x/pkg/errors"

	api "yunion.io/x/onecloud/pkg/apis/image"
	"yunion.io/x/onecloud/pkg/mcclient"
	modules "yunion.io/x/onecloud/pkg/mcclient/modules/image"
	"yunion.io/x/onecloud/pkg/mcclient/options"
)

func init() {

	type GuestImageCreateOptions struct {
		NAME        string   `help:"Name of guest image"`
		ImageNumber int      `help:"common image number of guest image"`
		Protected   bool     `help:"if guest image is protected"`
		Image       []string `help:"list of images"`
	}

	R(&GuestImageCreateOptions{}, "guest-image-create", "Create guest image's metadata", func(s *mcclient.ClientSession,
		args *GuestImageCreateOptions) error {

		params := jsonutils.NewDict()
		params.Add(jsonutils.NewString(args.NAME), "name")
		if args.ImageNumber > 0 {
			params.Add(jsonutils.NewInt(int64(args.ImageNumber)), "image_number")
		}
		if args.Protected {
			params.Add(jsonutils.JSONTrue, "protected")
		}
		if len(args.Image) > 0 {
			images := make([]api.GuestImageCreateInputSubimage, 0)
			for _, img := range args.Image {
				images = append(images, api.GuestImageCreateInputSubimage{
					Id: img,
				})
			}
			params.Add(jsonutils.Marshal(images), "images")
		}
		ret, err := modules.GuestImages.Create(s, params)
		if err != nil {
			return err
		}
		printObject(ret)
		return nil
	},
	)

	type GuestImageListOptions struct {
		options.BaseListOptions

		Name string `help:"Name filter"`
	}

	R(&GuestImageListOptions{}, "guest-image-list", "List guest images", func(s *mcclient.ClientSession,
		args *GuestImageListOptions) error {

		params, err := args.Params()
		if err != nil {
			return err
		}

		if len(args.Name) > 0 {
			params.Add(jsonutils.NewString(args.Name), "name")
		}
		params.Add(jsonutils.JSONTrue, "details")
		rets, err := modules.GuestImages.List(s, params)
		if err != nil {
			return err
		}
		printList(rets, modules.GuestImages.GetColumns(s))
		return nil
	},
	)

	type GuestImageDeleteOptions struct {
		ID                    []string `help:"Image ID or name"`
		OverridePendingDelete *bool    `help:"Delete image directly instead of pending delete" short-token:"f"`
	}
	R(&GuestImageDeleteOptions{}, "guest-image-delete", "Delete a image", func(s *mcclient.ClientSession,
		args *GuestImageDeleteOptions) error {
		params, err := options.StructToParams(args)
		if err != nil {
			return err
		}
		ret := modules.GuestImages.BatchDeleteWithParam(s, args.ID, params, nil)
		printBatchResults(ret, modules.GuestImages.GetColumns(s))
		return nil
	})

	type GuestImageCancelDeleteOptions struct {
		ID string `help:"Guest Image id or name"`
	}
	R(&GuestImageCancelDeleteOptions{}, "guest-image-cancel-delete", "Cancel pending delete images",
		func(s *mcclient.ClientSession,
			args *GuestImageCancelDeleteOptions) error {
			if image, e := modules.GuestImages.PerformAction(s, args.ID, "cancel-delete", nil); e != nil {
				return e
			} else {
				printObject(image)
			}
			return nil
		},
	)

	type GuestImageUpdateOptions struct {
		ID             string `help:"id of guest image"`
		Name           string `help:"new name of guest image"`
		Protected      string `help:"delete protection" choices:"enable|disable"`
		OsType         string `help:"os type"`
		OsDistribution string `help:"os distribution"`
		DiskDriver     string `help:"disk driver"`
		NetDriver      string `help:"net driver"`
	}
	R(&GuestImageUpdateOptions{}, "guest-image-update", "update guest image", func(s *mcclient.ClientSession,
		args *GuestImageUpdateOptions) error {

		params := jsonutils.NewDict()
		if len(args.Name) > 0 {
			params.Add(jsonutils.NewString(args.Name), "name")
		}
		if len(args.Protected) > 0 {
			if args.Protected == "enable" {
				params.Add(jsonutils.JSONTrue, "protected")
			} else {
				params.Add(jsonutils.JSONFalse, "protected")
			}
		}
		properties := jsonutils.NewDict()
		if len(args.OsType) > 0 {
			properties.Add(jsonutils.NewString(args.OsType), "os_type")
		}
		if len(args.OsDistribution) > 0 {
			properties.Add(jsonutils.NewString(args.OsDistribution), "os_distribution")
		}
		if len(args.DiskDriver) > 0 {
			properties.Add(jsonutils.NewString(args.DiskDriver), "disk_driver")
		}
		if len(args.NetDriver) > 0 {
			properties.Add(jsonutils.NewString(args.NetDriver), "net_driver")
		}
		params.Add(properties, "properties")
		_, err := modules.GuestImages.Update(s, args.ID, params)
		if err != nil {
			return err
		}
		return nil
	})

	type GuestImageOptions struct {
		ID string `help:"Guest Image id or name"`
	}
	R(&GuestImageOptions{}, "guest-image-mark-protected", "Mark image protected", func(s *mcclient.ClientSession,
		args *GuestImageOptions) error {

		params := jsonutils.NewDict()
		params.Add(jsonutils.JSONTrue, "protected")
		result, err := modules.GuestImages.Update(s, args.ID, params)
		if err != nil {
			return err
		}
		printObject(result)
		return nil
	})

	R(&GuestImageOptions{}, "guest-image-mark-unprotected", "Mark image protected", func(s *mcclient.ClientSession,
		args *GuestImageOptions) error {

		params := jsonutils.NewDict()
		params.Add(jsonutils.JSONFalse, "protected")
		result, err := modules.GuestImages.Update(s, args.ID, params)
		if err != nil {
			return err
		}
		printObject(result)
		return nil
	})

	type GuestImageOperationOptions struct {
		ID []string `help:"Guest Image ID or Name"`
	}

	type GuestImagePublicOptions struct {
		GuestImageOperationOptions
		Scope          string   `help:"sharing scope" choices:"system|domain"`
		ShareToProject []string `help:"Share to prject"`
	}

	R(&GuestImageOperationOptions{}, "guest-image-private", "Make a guest image private",
		func(s *mcclient.ClientSession, args *GuestImageOperationOptions) error {
			if len(args.ID) == 0 {
				return errors.Error("No guest image ID provided")
			} else if len(args.ID) == 1 {
				result, err := modules.GuestImages.PerformAction(s, args.ID[0], "private", nil)
				if err != nil {
					return err
				}
				printObject(result)
			} else {
				results := modules.GuestImages.BatchPerformAction(s, args.ID, "private", nil)
				printBatchResults(results, modules.GuestImages.GetColumns(s))
			}
			return nil
		},
	)

	R(&GuestImagePublicOptions{}, "guest-image-public", "Make a guest image public",
		func(s *mcclient.ClientSession, args *GuestImagePublicOptions) error {
			params, err := options.StructToParams(args)
			if err != nil {
				return err
			}
			if len(args.ID) == 0 {
				return errors.Error("No guest image ID provided")
			} else if len(args.ID) == 1 {
				result, err := modules.GuestImages.PerformAction(s, args.ID[0], "public", params)
				if err != nil {
					return err
				}
				printObject(result)
			} else {
				results := modules.GuestImages.BatchPerformAction(s, args.ID, "public", params)
				printBatchResults(results, modules.GuestImages.GetColumns(s))
			}
			return nil
		},
	)
}