Merge pull request #43 from innodreamer/main

Add Routing Table and Internet Gateway management features

Author: innodreamer

openstack/errors.go

@@ -2,10 +2,30 @@ package openstack
 
 import (
 	"fmt"
+	"errors"
+	"net/http"
 
 	"github.com/cloud-barista/nhncloud-sdk-go"
 )
 
+// BaseError is an error type that all other error types embed.
+type BaseError struct {
+	DefaultErrString string
+	Info             string
+}
+
+func (e BaseError) Error() string {
+	e.DefaultErrString = "An error occurred while executing a Gophercloud request."
+	return e.choseErrString()
+}
+
+func (e BaseError) choseErrString() string {
+	if e.Info != "" {
+		return e.Info
+	}
+	return e.DefaultErrString
+}
+
 // ErrEndpointNotFound is the error when no suitable endpoint can be found
 // in the user's catalog
 type ErrEndpointNotFound struct{ gophercloud.BaseError }
@@ -45,3 +65,43 @@ type ErrNoPassword struct{ gophercloud.ErrInvalidInput }
 func (e ErrNoPassword) Error() string {
 	return "Environment variable OS_PASSWORD needs to be set."
 }
+
+// ErrUnexpectedResponseCode is returned by the Request method when a response code other than
+// those listed in OkCodes is encountered.
+type ErrUnexpectedResponseCode struct {
+	BaseError
+	URL            string
+	Method         string
+	Expected       []int
+	Actual         int
+	Body           []byte
+	ResponseHeader http.Header
+}
+
+// ResponseCodeIs returns true if this error is or contains an ErrUnexpectedResponseCode reporting
+// that the request failed with the given response code. For example, this checks if a request
+// failed because of a 404 error:
+//
+//	allServers, err := servers.List(client, servers.ListOpts{})
+//	if gophercloud.ResponseCodeIs(err, http.StatusNotFound) {
+//		handleNotFound()
+//	}
+//
+// It is safe to pass a nil error, in which case this function always returns false.
+func ResponseCodeIs(err error, status int) bool {
+	var codeError ErrUnexpectedResponseCode
+	if errors.As(err, &codeError) {
+		return codeError.Actual == status
+	}
+	return false
+}
+
+// ErrTimeOut is the error type returned when an operations times out.
+type ErrTimeOut struct {
+	BaseError
+}
+
+func (e ErrTimeOut) Error() string {
+	e.DefaultErrString = "A time out occurred"
+	return e.choseErrString()
+}

openstack/networking/v2/extensions/layer3/internetgateways/requests.go

@@ -0,0 +1,91 @@
+// Proof of Concepts of NHN Cloud SDK Go
+// NHN Cloud SDK Go is an SDK for developing NHN Cloud connection drivers that connect NHN Cloud to CB-Spider, a sub-framework of the Cloud-Barista multi-cloud project.
+//
+// * Cloud-Barista: https://github.com/cloud-barista
+//
+// Created by ETRI, 2025.08
+
+package internetgateways
+
+import (
+	"github.com/cloud-barista/nhncloud-sdk-go"
+	"github.com/cloud-barista/nhncloud-sdk-go/pagination"
+)
+
+// ListOpts allows filtering and sorting of Internet Gateway collections
+type ListOpts struct {
+	// TenantID filters by the tenant ID
+	TenantID string `q:"tenant_id"`
+	
+	// ID filters by the Internet Gateway ID
+	ID string `q:"id"`
+	
+	// Name filters by the Internet Gateway name
+	Name string `q:"name"`
+	
+	// ExternalNetworkID filters by the external network ID
+	ExternalNetworkID string `q:"external_network_id"`
+	
+	// RoutingTableID filters by the routing table ID
+	RoutingTableID string `q:"routingtable_id"`
+}
+
+// List returns a Pager which allows you to iterate over Internet Gateways
+func List(client *gophercloud.ServiceClient, opts ListOpts) pagination.Pager {
+	q, err := gophercloud.BuildQueryString(&opts)
+	if err != nil {
+		return pagination.Pager{Err: err}
+	}
+	
+	return pagination.NewPager(client, listURL(client)+q.String(), func(r pagination.PageResult) pagination.Page {
+		return InternetGatewayPage{pagination.LinkedPageBase{PageResult: r}}
+	})
+}
+
+// Get returns details about a specific Internet Gateway
+func Get(client *gophercloud.ServiceClient, id string) (r GetResult) {
+	resp, err := client.Get(getURL(client, id), &r.Body, nil)
+	_, r.Header, r.Err = gophercloud.ParseResponse(resp, err)
+	return
+}
+
+// CreateOpts represents options for creating an Internet Gateway
+type CreateOpts struct {
+	// Name is the name of the Internet Gateway
+	Name string `json:"name" required:"true"`
+	
+	// ExternalNetworkID is the ID of the external network to connect to
+	ExternalNetworkID string `json:"external_network_id" required:"true"`
+}
+
+// ToInternetGatewayCreateMap builds a request body from CreateOpts
+func (opts CreateOpts) ToInternetGatewayCreateMap() (map[string]interface{}, error) {
+	return gophercloud.BuildRequestBody(opts, "internetgateway")
+}
+
+// CreateOptsBuilder allows extensions to add additional attributes to the Create request
+type CreateOptsBuilder interface {
+	ToInternetGatewayCreateMap() (map[string]interface{}, error)
+}
+
+// Create creates a new Internet Gateway
+func Create(client *gophercloud.ServiceClient, opts CreateOptsBuilder) (r CreateResult) {
+	b, err := opts.ToInternetGatewayCreateMap()
+	if err != nil {
+		r.Err = err
+		return
+	}
+	
+	resp, err := client.Post(createURL(client), b, &r.Body, nil)
+	_, r.Header, r.Err = gophercloud.ParseResponse(resp, err)
+	return
+}
+
+// Delete deletes an Internet Gateway
+func Delete(client *gophercloud.ServiceClient, id string) (r DeleteResult) {
+	resp, err := client.Delete(deleteURL(client, id), &gophercloud.RequestOpts{
+		OkCodes: []int{200, 204},
+	})
+	_, r.Header, r.Err = gophercloud.ParseResponse(resp, err)
+	return
+}

openstack/networking/v2/extensions/layer3/internetgateways/results.go

@@ -0,0 +1,176 @@
+// Proof of Concepts of NHN Cloud SDK Go
+// NHN Cloud SDK Go is an SDK for developing NHN Cloud connection drivers that connect NHN Cloud to CB-Spider, a sub-framework of the Cloud-Barista multi-cloud project.
+//
+// * Cloud-Barista: https://github.com/cloud-barista
+//
+// Created by ETRI, 2025.08
+
+package internetgateways
+
+import (
+	"encoding/json"
+	"time"
+
+	"github.com/cloud-barista/nhncloud-sdk-go"
+	"github.com/cloud-barista/nhncloud-sdk-go/pagination"
+)
+
+// InternetGatewayState represents possible states of an Internet Gateway
+type InternetGatewayState string
+
+const (
+	// StateAvailable indicates the gateway is in normal operational state
+	StateAvailable InternetGatewayState = "available"
+	
+	// StateUnavailable indicates the gateway is not connected to any routing table
+	StateUnavailable InternetGatewayState = "unavailable"
+	
+	// StateMigrating indicates the gateway is being moved to another server for maintenance
+	StateMigrating InternetGatewayState = "migrating"
+	
+	// StateError indicates the gateway is connected to a routing table but not functioning properly
+	StateError InternetGatewayState = "error"
+)
+
+// MigrateStatus represents possible migration statuses during maintenance
+type MigrateStatus string
+
+const (
+	// MigrateStatusNone indicates no migration in progress or migration completed
+	MigrateStatusNone MigrateStatus = "none"
+	
+	// MigrateStatusUnbindingProgress indicates removal from old server in progress
+	MigrateStatusUnbindingProgress MigrateStatus = "unbinding_progress"
+	
+	// MigrateStatusUnbindingError indicates error occurred during removal from old server
+	MigrateStatusUnbindingError MigrateStatus = "unbinding_error"
+	
+	// MigrateStatusBindingProgress indicates setup on new server in progress
+	MigrateStatusBindingProgress MigrateStatus = "binding_progress"
+	
+	// MigrateStatusBindingError indicates error occurred during setup on new server
+	MigrateStatusBindingError MigrateStatus = "binding_error"
+)
+
+// InternetGateway represents an Internet Gateway
+type InternetGateway struct {
+	// ID is the unique identifier for the Internet Gateway
+	ID string `json:"id"`
+
+	// Name is the name of the Internet Gateway
+	Name string `json:"name"`
+
+	// ExternalNetworkID is the ID of the external network connected to this gateway
+	ExternalNetworkID string `json:"external_network_id"`
+
+	// RoutingTableID is the ID of the routing table connected to this gateway (may be null)
+	RoutingTableID *string `json:"routingtable_id"`
+
+	// State represents the current state of the Internet Gateway
+	// Possible values: available, unavailable, migrating, error
+	State string `json:"state"`
+
+	// CreateTime is the creation time of the Internet Gateway in UTC
+	CreateTime time.Time `json:"-"`
+
+	// TenantID is the tenant ID that owns this Internet Gateway
+	TenantID string `json:"tenant_id"`
+
+	// MigrateStatus represents the migration status during maintenance
+	// Possible values: none, unbinding_progress, unbinding_error, binding_progress, binding_error
+	MigrateStatus string `json:"migrate_status"`
+
+	// MigrateError contains error message if migration fails
+	MigrateError *string `json:"migrate_error"`
+}
+
+// UnmarshalJSON implements custom JSON unmarshaling for InternetGateway
+func (r *InternetGateway) UnmarshalJSON(b []byte) error {
+	type tmp InternetGateway
+	var s struct {
+		tmp
+		CreateTime string `json:"create_time"`
+	}
+	
+	err := json.Unmarshal(b, &s)
+	if err != nil {
+		return err
+	}
+	
+	*r = InternetGateway(s.tmp)
+	
+	if s.CreateTime != "" {
+		t, err := time.Parse("2006-01-02 15:04:05", s.CreateTime)
+		if err != nil {
+			return err
+		}
+		r.CreateTime = t
+	}
+	
+	return nil
+}
+
+// InternetGatewayPage represents a single page of Internet Gateway results
+type InternetGatewayPage struct {
+	pagination.LinkedPageBase
+}
+
+// NextPageURL extracts the next page URL from the response
+func (r InternetGatewayPage) NextPageURL() (string, error) {
+	var s struct {
+		Links []gophercloud.Link `json:"internetgateways_links"`
+	}
+	err := r.ExtractInto(&s)
+	if err != nil {
+		return "", err
+	}
+	return gophercloud.ExtractNextURL(s.Links)
+}
+
+// IsEmpty determines if an InternetGatewayPage contains any results
+func (r InternetGatewayPage) IsEmpty() (bool, error) {
+	internetgateways, err := ExtractInternetGateways(r)
+	return len(internetgateways) == 0, err
+}
+
+// ExtractInternetGateways extracts Internet Gateways from a List result
+func ExtractInternetGateways(r pagination.Page) ([]InternetGateway, error) {
+	var s struct {
+		InternetGateways []InternetGateway `json:"internetgateways"`
+	}
+	err := (r.(InternetGatewayPage)).ExtractInto(&s)
+	return s.InternetGateways, err
+}
+
+// GetResult represents the result of a get operation
+type GetResult struct {
+	gophercloud.Result
+}
+
+// Extract extracts an InternetGateway from a GetResult
+func (r GetResult) Extract() (*InternetGateway, error) {
+	var s struct {
+		InternetGateway *InternetGateway `json:"internetgateway"`
+	}
+	err := r.ExtractInto(&s)
+	return s.InternetGateway, err
+}
+
+// CreateResult represents the result of a create operation
+type CreateResult struct {
+	gophercloud.Result
+}
+
+// Extract extracts an InternetGateway from a CreateResult
+func (r CreateResult) Extract() (*InternetGateway, error) {
+	var s struct {
+		InternetGateway *InternetGateway `json:"internetgateway"`
+	}
+	err := r.ExtractInto(&s)
+	return s.InternetGateway, err
+}
+
+// DeleteResult represents the result of a delete operation
+type DeleteResult struct {
+	gophercloud.ErrResult
+}

openstack/networking/v2/extensions/layer3/internetgateways/urls.go

@@ -0,0 +1,29 @@
+package internetgateways
+
+import "github.com/cloud-barista/nhncloud-sdk-go"
+
+const resourcePath = "internetgateways"
+
+func rootURL(c *gophercloud.ServiceClient) string {
+	return c.ServiceURL(resourcePath)
+}
+
+func resourceURL(c *gophercloud.ServiceClient, id string) string {
+	return c.ServiceURL(resourcePath, id)
+}
+
+func listURL(c *gophercloud.ServiceClient) string {
+	return rootURL(c)
+}
+
+func getURL(c *gophercloud.ServiceClient, id string) string {
+	return resourceURL(c, id)
+}
+
+func createURL(c *gophercloud.ServiceClient) string {
+	return rootURL(c)
+}
+
+func deleteURL(c *gophercloud.ServiceClient, id string) string {
+	return resourceURL(c, id)
+}