rackspace/rackconnect/v3/cloudnetworks/results.go

package cloudnetworks

import (
	"fmt"
	"reflect"
	"time"

	"github.com/mitchellh/mapstructure"
	"github.com/rackspace/gophercloud"
	"github.com/rackspace/gophercloud/pagination"
)

// CloudNetwork represents a network associated with a RackConnect configuration.
type CloudNetwork struct {
	// Specifies the ID of the newtork.
	ID string `mapstructure:"id"`
	// Specifies the user-provided name of the network.
	Name string `mapstructure:"name"`
	// Specifies the IP range for this network.
	CIDR string `mapstructure:"cidr"`
	// Specifies the time the network was created.
	CreatedAt time.Time `mapstructure:"-"`
	// Specifies the time the network was last updated.
	UpdatedAt time.Time `mapstructure:"-"`
}

// CloudNetworkPage is the page returned by a pager when traversing over a
// collection of CloudNetworks.
type CloudNetworkPage struct {
	pagination.SinglePageBase
}

// IsEmpty returns true if a CloudNetworkPage contains no CloudNetworks.
func (r CloudNetworkPage) IsEmpty() (bool, error) {
	cns, err := ExtractCloudNetworks(r)
	if err != nil {
		return true, err
	}
	return len(cns) == 0, nil
}

// ExtractCloudNetworks extracts and returns CloudNetworks. It is used while iterating over
// a cloudnetworks.List call.
func ExtractCloudNetworks(page pagination.Page) ([]CloudNetwork, error) {
	var res []CloudNetwork
	casted := page.(CloudNetworkPage).Body

	err := mapstructure.Decode(casted, &res)

	var rawNets []interface{}
	switch casted.(type) {
	case interface{}:
		rawNets = casted.([]interface{})
	default:
		return res, fmt.Errorf("Unknown type: %v", reflect.TypeOf(casted))
	}

	for i := range rawNets {
		thisNet := (rawNets[i]).(map[string]interface{})

		if t, ok := thisNet["created"].(string); ok && t != "" {
			creationTime, err := time.Parse(time.RFC3339, t)
			if err != nil {
				return res, err
			}
			res[i].CreatedAt = creationTime
		}

		if t, ok := thisNet["updated"].(string); ok && t != "" {
			updatedTime, err := time.Parse(time.RFC3339, t)
			if err != nil {
				return res, err
			}
			res[i].UpdatedAt = updatedTime
		}
	}

	return res, err
}

// GetResult represents the result of a Get operation.
type GetResult struct {
	gophercloud.Result
}

// Extract is a function that extracts a CloudNetwork from a GetResult.
func (r GetResult) Extract() (*CloudNetwork, error) {
	if r.Err != nil {
		return nil, r.Err
	}
	var res CloudNetwork

	err := mapstructure.Decode(r.Body, &res)

	b := r.Body.(map[string]interface{})

	if date, ok := b["created"]; ok && date != nil {
		t, err := time.Parse(time.RFC3339, date.(string))
		if err != nil {
			return nil, err
		}
		res.CreatedAt = t
	}

	if date, ok := b["updated"]; ok && date != nil {
		t, err := time.Parse(time.RFC3339, date.(string))
		if err != nil {
			return nil, err
		}
		res.UpdatedAt = t
	}

	return &res, err
}