Fix /deliveryservices/{{ID}}/servers and /deliveryservices/{{ID}}/servers/eligible to use RFC3339 timestamps

CHANGELOG.md

@@ -139,6 +139,7 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/).
 - [#7575](https://github.com/apache/trafficcontrol/pull/7575) *Traffic Ops* Fixes `types` v5 apis to respond with `RFC3339` date/time Format.
 - [#7628](https://github.com/apache/trafficcontrol/pull/7628) *Traffic Ops* Fixes an issue where certificate chain validation failed based on leading or trailing whitespace.
 - [#7596](https://github.com/apache/trafficcontrol/pull/7596) *Traffic Ops* Fixes `federation_resolvers` v5 apis to respond with `RFC3339` date/time Format.
+- [#7660](https://github.com/apache/trafficcontrol/pull/7660) *Traffic Ops* Fixes `deliveryServices` v5 apis to respond with `RFC3339` date/time Format.
 
 ### Removed
 - [#7271](https://github.com/apache/trafficcontrol/pull/7271) Remove components in `infrastructre/docker/`, not in use as cdn-in-a-box performs the same functionality.

docs/source/api/v5/deliveryservices_id_servers.rst

@@ -70,7 +70,7 @@ Response Structure
 		:gateway:       The IPv4 or IPv6 gateway address of the server - applicable for the interface ``name``
 		:service_address:  A boolean determining if content will be routed to the IP address
 
-:lastUpdated:    The time and date at which this server was last updated, in :ref:`non-rfc-datetime`
+:lastUpdated:    The time and date at which this server was last updated, in :rfc:`3339`
 :mgmtIpAddress:  The IPv4 address of the server's management port
 :mgmtIpGateway:  The IPv4 gateway of the server's management port
 :mgmtIpNetmask:  The IPv4 subnet mask of the server's management port
@@ -125,7 +125,7 @@ Response Structure
 			"iloIpNetmask": "",
 			"iloPassword": "",
 			"iloUsername": "",
-			"lastUpdated": "2018-11-14 21:08:44+00",
+			"lastUpdated": "2018-11-14T15:18:14.952814+05:30",
 			"mgmtIpAddress": "",
 			"mgmtIpGateway": "",
 			"mgmtIpNetmask": "",

docs/source/api/v5/deliveryservices_id_servers_eligible.rst

@@ -76,7 +76,7 @@ Response Structure
 		:gateway:       The IPv4 or IPv6 gateway address of the server - applicable for the interface ``name``
 		:service_address:  A boolean determining if content will be routed to the IP address
 
-:lastUpdated:    The time and date at which this server was last updated, in :ref:`non-rfc-datetime`
+:lastUpdated:    The time and date at which this server was last updated, in :rfc:`3339`
 :mgmtIpAddress:  The IPv4 address of the server's management port
 :mgmtIpGateway:  The IPv4 gateway of the server's management port
 :mgmtIpNetmask:  The IPv4 subnet mask of the server's management port
@@ -121,7 +121,7 @@ Response Structure
 			"iloIpNetmask": "",
 			"iloPassword": "",
 			"iloUsername": "",
-			"lastUpdated": "2018-10-30 16:01:12+00",
+			"lastUpdated": "2018-10-30T15:18:14.952814+05:30",
 			"mgmtIpAddress": "",
 			"mgmtIpGateway": "",
 			"mgmtIpNetmask": "",

lib/go-tc/deliveryservice_servers.go

@@ -168,6 +168,44 @@
 	DeliveryServiceCapabilities []string             `json:"-" db:"deliveryservice_capabilities"`
 }
 
+// DSServerBaseV5 contains the base information for a Delivery Service Server associated with APIv5.
+type DSServerBaseV5 struct {
+	Cachegroup                  *string              `json:"cachegroup" db:"cachegroup"`
+	CachegroupID                *int                 `json:"cachegroupId" db:"cachegroup_id"`
+	CDNID                       *int                 `json:"cdnId" db:"cdn_id"`
+	CDNName                     *string              `json:"cdnName" db:"cdn_name"`
+	DeliveryServices            *map[string][]string `json:"deliveryServices,omitempty"`
+	DomainName                  *string              `json:"domainName" db:"domain_name"`
+	FQDN                        *string              `json:"fqdn,omitempty"`
+	FqdnTime                    time.Time            `json:"-"`
+	GUID                        *string              `json:"guid" db:"guid"`
+	HostName                    *string              `json:"hostName" db:"host_name"`
+	HTTPSPort                   *int                 `json:"httpsPort" db:"https_port"`
+	ID                          *int                 `json:"id" db:"id"`
+	ILOIPAddress                *string              `json:"iloIpAddress" db:"ilo_ip_address"`
+	ILOIPGateway                *string              `json:"iloIpGateway" db:"ilo_ip_gateway"`
+	ILOIPNetmask                *string              `json:"iloIpNetmask" db:"ilo_ip_netmask"`
+	ILOPassword                 *string              `json:"iloPassword" db:"ilo_password"`
+	ILOUsername                 *string              `json:"iloUsername" db:"ilo_username"`
+	LastUpdated                 *time.Time           `json:"lastUpdated" db:"last_updated"`
+	MgmtIPAddress               *string              `json:"mgmtIpAddress" db:"mgmt_ip_address"`
+	MgmtIPGateway               *string              `json:"mgmtIpGateway" db:"mgmt_ip_gateway"`
+	MgmtIPNetmask               *string              `json:"mgmtIpNetmask" db:"mgmt_ip_netmask"`
+	OfflineReason               *string              `json:"offlineReason" db:"offline_reason"`
+	PhysLocation                *string              `json:"physLocation" db:"phys_location"`
+	PhysLocationID              *int                 `json:"physLocationId" db:"phys_location_id"`
+	ProfileNames                []string             `json:"profileNames" db:"profile_name"`
+	Rack                        *string              `json:"rack" db:"rack"`
+	Status                      *string              `json:"status" db:"status"`
+	StatusID                    *int                 `json:"statusId" db:"status_id"`
+	TCPPort                     *int                 `json:"tcpPort" db:"tcp_port"`
+	Type                        string               `json:"type" db:"server_type"`
+	TypeID                      *int                 `json:"typeId" db:"server_type_id"`
+	UpdPending                  *bool                `json:"updPending" db:"upd_pending"`
+	ServerCapabilities          []string             `json:"-" db:"server_capabilities"`
+	DeliveryServiceCapabilities []string             `json:"-" db:"deliveryservice_capabilities"`
+}
+
 // DSServerV11 contains the legacy format for a Delivery Service Server.
 type DSServerV11 struct {
 	DSServerBase
@@ -205,6 +243,24 @@
 // API version 4.
 type DSServerResponseV4 = DSServerResponseV40
 
+// DSServerResponseV50 is response from Traffic Ops to a request for servers assigned to a Delivery Service - in  the latest minor version APIv50.
+type DSServerResponseV50 struct {
+	Response []DSServerV50 `json:"response"`
+	Alerts
+}
+
+// DSServerV5 is an alias for the latest minor version of the major version 5.
+type DSServerV5 = DSServerV50
+
+// DSServerV50 contains information for a Delivery Service Server.
+type DSServerV50 struct {
+	DSServerBaseV5
+	ServerInterfaces *[]ServerInterfaceInfo `json:"interfaces" db:"interfaces"`
+}
+
+// DSServerResponseV5 is an alias for the latest minor version of the major version 5.
+type DSServerResponseV5 = DSServerResponseV50
+
 // ToDSServerBaseV4 upgrades the DSServerBase to the structure used by the
 // latest minor version of version 4 of Traffic Ops's API.
 func (oldBase DSServerBase) ToDSServerBaseV4() DSServerBaseV4 {
@@ -290,3 +346,48 @@
 	dsServerBase.RouterPortName = routerPort
 	return dsServerBase
 }
+
+// ToDSServerV5 convert DSServerV4 lastUpdated time format to RFC3339 for DSServerV5
+// and also assign V4 values to V5
+func ToDSServerV5(serverList []DSServerV4) []DSServerV5 {
+	updatedServerList := make([]DSServerV5, len(serverList))
+
+	for i, server := range serverList {
+		r := time.Unix(server.LastUpdated.Unix(), 0)
+		updatedServerList[i].LastUpdated = &r
+		updatedServerList[i].Cachegroup = server.Cachegroup
+		updatedServerList[i].CachegroupID = server.CachegroupID
+		updatedServerList[i].CDNID = server.CDNID
+		updatedServerList[i].CDNName = server.CDNName
+		updatedServerList[i].DeliveryServices = server.DeliveryServices
+		updatedServerList[i].DomainName = server.DomainName
+		updatedServerList[i].FQDN = server.FQDN
+		updatedServerList[i].FqdnTime = server.FqdnTime
+		updatedServerList[i].GUID = server.GUID
+		updatedServerList[i].HostName = server.HostName
+		updatedServerList[i].HTTPSPort = server.HTTPSPort
+		updatedServerList[i].ID = server.ID
+		updatedServerList[i].ILOIPAddress = server.ILOIPAddress
+		updatedServerList[i].ILOIPGateway = server.ILOIPGateway
+		updatedServerList[i].ILOIPNetmask = server.ILOIPNetmask
+		updatedServerList[i].ILOPassword = server.ILOPassword
+		updatedServerList[i].ILOUsername = server.ILOUsername
+		updatedServerList[i].MgmtIPAddress = server.MgmtIPAddress
+		updatedServerList[i].MgmtIPGateway = server.MgmtIPGateway
+		updatedServerList[i].MgmtIPNetmask = server.MgmtIPNetmask
+		updatedServerList[i].OfflineReason = server.OfflineReason
+		updatedServerList[i].PhysLocation = server.PhysLocation
+		updatedServerList[i].PhysLocationID = server.PhysLocationID
+		updatedServerList[i].ProfileNames = server.ProfileNames
+		updatedServerList[i].Rack = server.Rack
+		updatedServerList[i].Status = server.Status
+		updatedServerList[i].StatusID = server.StatusID
+		updatedServerList[i].TCPPort = server.TCPPort
+		updatedServerList[i].Type = server.Type
+		updatedServerList[i].TypeID = server.TypeID
+		updatedServerList[i].UpdPending = server.UpdPending
+		updatedServerList[i].ServerCapabilities = server.ServerCapabilities
+		updatedServerList[i].DeliveryServiceCapabilities = server.DeliveryServiceCapabilities
+	}
+	return updatedServerList
+}

lib/go-tc/federation_resolver.go

@@ -72,7 +72,7 @@
 	Response []FederationResolverV5 `json:"response"`
 }
 
-// FederationResolverResponseV50 - represents struct response used for the latest minor version associated with APIv5.
+// FederationResolverResponseV5 - represents struct response used for the latest minor version associated with APIv5.
 type FederationResolverResponseV5 = FederationResolverResponseV50
 
 // FederationResolverResponseV50 - POST request to its /federation_resolvers endpoint APIv50.
@@ -105,16 +105,16 @@
 
 // UpgradeToFederationResolverV5 upgrades an APIv4 Federal Resolver into an APIv5 Federal Resolver of
 // the latest minor version.
 func UpgradeToFederationResolverV5(fr FederationResolver) *FederationResolverV5 {
 	upgraded := FederationResolverV5{
 		ID:        fr.ID,
 		IPAddress: fr.IPAddress,
 		LastUpdated: func() *time.Time {
 			lastUpdated := time.Unix(fr.LastUpdated.Unix(), 0)
 			return &lastUpdated
 		}(),
 		Type: fr.Type,
 	}
 
 	return &upgraded
 }

traffic_ops/traffic_ops_golang/deliveryservice/eligible.go

@@ -96,6 +96,16 @@
 		api.WriteResp(w, r, v3ServerList)
 		return
 	}
+
+	// Based on version we load Delivery Service Eligible Server - for version 5 and above we use DSServerV5
+	if inf.Version.GreaterThanOrEqualTo(&api.Version{Major: 5, Minor: 0}) {
+
+		newServerList := tc.ToDSServerV5(servers)
+
+		api.WriteResp(w, r, newServerList)
+		return
+	}
+
 	api.WriteResp(w, r, servers)
 }
 

traffic_ops/traffic_ops_golang/deliveryservice/servers/servers.go

@@ -724,6 +724,16 @@
 		api.WriteAlertsObj(w, r, http.StatusOK, alerts, v3ServerList)
 		return
 	}
+
+	// Based on version we load Delivery Service Server - for version 5 and above we use DSServerV5
+	if inf.Version.GreaterThanOrEqualTo(&api.Version{Major: 5, Minor: 0}) {
+
+		newServerList := tc.ToDSServerV5(servers)
+
+		api.WriteAlertsObj(w, r, http.StatusOK, alerts, newServerList)
+		return
+	}
+
 	api.WriteAlertsObj(w, r, http.StatusOK, alerts, servers)
 }
 

traffic_ops/v5-client/deliveryservice.go

@@ -282,8 +282,8 @@ func (to *Session) GetDeliveryServiceSSLKeys(xmlid string, opts RequestOptions)
 
 // GetDeliveryServicesEligible returns the servers eligible for assignment to the Delivery
 // Service identified by the integral, unique identifier 'dsID'.
-func (to *Session) GetDeliveryServicesEligible(dsID int, opts RequestOptions) (tc.DSServerResponseV4, toclientlib.ReqInf, error) {
-	var resp tc.DSServerResponseV4
+func (to *Session) GetDeliveryServicesEligible(dsID int, opts RequestOptions) (tc.DSServerResponseV5, toclientlib.ReqInf, error) {
+	var resp tc.DSServerResponseV5
 	reqInf, err := to.get(fmt.Sprintf(apiDeliveryServiceEligibleServers, dsID), opts, &resp)
 	return resp, reqInf, err
 }