[APIGW] api version switch (#649)

[APIGW] api version switch

Added missing endpoints

What this PR does / why we need it
Which issue this PR fixes

Special notes for your reviewer

Reviewed-by: Artem Lifshits
Reviewed-by: Aloento

Author: anton-sidelnikov

acceptance/openstack/apigw/v2/api_test.go

@@ -78,6 +78,12 @@ func TestApiLifecycle(t *testing.T) {
 	th.AssertEquals(t, manageResp.EnvID, envResp.ID)
 	th.AssertEquals(t, manageResp.Description, manageOpts.Description)
 
+	history, err := api.GetHistory(client, gatewayID, createResp.ID, api.ListHistoryOpts{
+		EnvID: envResp.ID,
+	})
+	th.AssertNoErr(t, err)
+	th.AssertEquals(t, len(history), 1)
+
 	getResp, err := api.Get(client, gatewayID, createResp.ID)
 	th.AssertNoErr(t, err)
 

openstack/apigw/v2/api/GetApiHistory.go

@@ -0,0 +1,60 @@
+package api
+
+import (
+	"bytes"
+
+	golangsdk "github.com/opentelekomcloud/gophertelekomcloud"
+	"github.com/opentelekomcloud/gophertelekomcloud/internal/extract"
+	"github.com/opentelekomcloud/gophertelekomcloud/pagination"
+)
+
+type ListHistoryOpts struct {
+	Offset  int64  `q:"offset"`
+	Limit   int    `q:"limit"`
+	EnvID   string `q:"env_id"`
+	EnvName string `q:"env_name"`
+}
+
+func GetHistory(client *golangsdk.ServiceClient, gatewayID, apiID string, opts ListHistoryOpts) ([]VersionResp, error) {
+	url, err := golangsdk.NewURLBuilder().
+		WithEndpoints("apigw", "instances", gatewayID, "apis", "publish", apiID).
+		WithQueryParams(&opts).Build()
+	if err != nil {
+		return nil, err
+	}
+	pages, err := pagination.Pager{
+		Client:     client,
+		InitialURL: client.ServiceURL(url.String()),
+		CreatePage: func(r pagination.NewPageResult) pagination.NewPage {
+			return VersionPage{NewSinglePageBase: pagination.NewSinglePageBase{NewPageResult: r}}
+		},
+	}.NewAllPages()
+
+	if err != nil {
+		return nil, err
+	}
+	return ExtractVersions(pages)
+}
+
+type VersionPage struct {
+	pagination.NewSinglePageBase
+}
+
+func ExtractVersions(r pagination.NewPage) ([]VersionResp, error) {
+	var s struct {
+		Versions []VersionResp `json:"api_versions"`
+	}
+	err := extract.Into(bytes.NewReader((r.(VersionPage)).Body), &s)
+	return s.Versions, err
+}
+
+type VersionResp struct {
+	VersionID   string `json:"version_id"`
+	Version     string `json:"version_no"`
+	ApiID       string `json:"api_id"`
+	EnvID       string `json:"env_id"`
+	EnvName     string `json:"env_name"`
+	Description string `json:"remark"`
+	PublishTime string `json:"publish_time"`
+	Status      int    `json:"status"`
+}

openstack/apigw/v2/api/SwitchApiVersion.go

@@ -0,0 +1,32 @@
+package api
+
+import (
+	golangsdk "github.com/opentelekomcloud/gophertelekomcloud"
+	"github.com/opentelekomcloud/gophertelekomcloud/internal/build"
+	"github.com/opentelekomcloud/gophertelekomcloud/internal/extract"
+)
+
+type VersionApiOpts struct {
+	GatewayID string `json:"-"`
+	ApiID     string `json:"-"`
+	VersionID string `json:"version_id" required:"true"`
+}
+
+func SwitchVersion(client *golangsdk.ServiceClient, opts VersionApiOpts) (*ManageApiResp, error) {
+	b, err := build.RequestBody(opts, "")
+	if err != nil {
+		return nil, err
+	}
+
+	raw, err := client.Put(client.ServiceURL("apigw", "instances", opts.GatewayID, "apis", "publish", opts.ApiID), b, nil, &golangsdk.RequestOpts{
+		OkCodes: []int{200},
+	})
+	if err != nil {
+		return nil, err
+	}
+
+	var res ManageApiResp
+
+	err = extract.Into(raw.Body, &res)
+	return &res, err
+}