package main

import (
	"context"
	"fmt"
	"log"
	"os"
	"time"

	"github.com/gophercloud/gophercloud/v2"
	"github.com/gophercloud/gophercloud/v2/openstack"
	"github.com/gophercloud/gophercloud/v2/openstack/blockstorage/v3/manageablevolumes"
	"github.com/gophercloud/gophercloud/v2/openstack/blockstorage/v3/volumes"
	"github.com/gophercloud/gophercloud/v2/openstack/config"
)

func main() {
	ctx := context.Background()

	authOpts := gophercloud.AuthOptions{
		IdentityEndpoint: os.Getenv("OS_AUTH_URL"),
		Username:         os.Getenv("OS_USERNAME"),
		Password:         os.Getenv("OS_PASSWORD"),
		DomainName:       os.Getenv("OS_USER_DOMAIN_NAME"),
		Scope: &gophercloud.AuthScope{
			ProjectID: os.Getenv("OS_PROJECT_ID"),
		},
	}
	endpointOpts := gophercloud.EndpointOpts{
		Region: os.Getenv("OS_REGION_NAME"),
	}
	providerClient, err := config.NewProviderClient(ctx, authOpts)
	if err != nil {
		log.Fatal(err)
	}
	client, err := openstack.NewBlockStorageV3(providerClient, endpointOpts)
	if err != nil {
		log.Fatal(err)
	}
	// Manage existing volume requires microversion at least 3.8
	client.Microversion = "3.8"

	createOpts := volumes.CreateOpts{
		Name:             "New Volume",
		Size:             8,
		AvailabilityZone: "nova",
		Description:      "Volume newly created",
		VolumeType:       "lvm",
		Metadata:         map[string]string{"key1": "value1"},
	}
	created, err := volumes.Create(ctx, client, createOpts, nil).Extract()
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("Created volume: %+v\n", created)

	time.Sleep(3 * time.Second)

	if err := volumes.Unmanage(ctx, client, created.ID).ExtractErr(); err != nil {
		log.Fatal(err)
	}
	fmt.Println("Unmanaged volume")

	time.Sleep(3 * time.Second)

	manageOpts := manageablevolumes.ManageExistingOpts{
		Host:             "storage01@lvm#LVM",
		Ref:              map[string]string{"source-name": fmt.Sprintf("volume-%s", created.ID)},
		Name:             "Managed Volume",
		AvailabilityZone: "nova",
		Description:      "Volume imported from existingLV",
		VolumeType:       "lvm",
		Bootable:         false,
		Metadata:         map[string]string{"key1": "value1"},
	}
	managed, err := manageablevolumes.ManageExisting(ctx, client, manageOpts).Extract()
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("Managed volume: %+v\n", managed)
}