feat: Add Address List and Traffic Matching Criteria functionality

cmd/addresslist_example/example.go

@@ -0,0 +1,113 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"os"
+	"time"
+
+	"github.com/f5devcentral/go-bigip"
+)
+
+func main() {
+	// Connect to the BIG-IP system.
+	config := bigip.Config{
+		Address:  os.Getenv("BIG_IP_HOST"),
+		Username: os.Getenv("BIG_IP_USER"),
+		Password: os.Getenv("BIG_IP_PASSWORD"),
+	}
+
+	f5 := bigip.NewSession(&config)
+
+	ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
+	defer cancel()
+
+	// Create an Address List
+	addressList := &bigip.AddressList{
+		Name: "addresslist-example",
+		Partition: "Common",
+		Addresses: []bigip.AddressListAddress{
+			{ Name: "1.2.3.4" },
+		},
+	}
+
+	err := f5.AddAddressList(ctx, addressList)
+
+	if err != nil {
+    log.Fatalf("Failed to create address list: %v", err)
+	}
+
+	// Get the address list
+	addressListGet, err := f5.GetAddressList(ctx, addressList.Name)
+	if err != nil {
+		log.Fatalf("Failed to get address list: %v", err)
+	}
+	fmt.Printf("%+v\n", addressListGet)
+
+	// Create a traffic matching criteria
+	trafficMatchingCriteria := &bigip.TrafficMatchingCriteria{
+		Name: "tmc-example",
+		Partition: "Common",
+		DestinationAddressInline: "192.168.1.150",
+		DestinationPortInline: "443",
+		SourceAddressList: fmt.Sprintf("/%s/%s", addressList.Partition, addressList.Name),
+		SourcePortInline: 0,
+	}
+
+	err = f5.AddTrafficMatchingCriteria(ctx, trafficMatchingCriteria)
+
+	if err != nil {
+		log.Fatalf("Failed to create traffic matching criteria: %v", err)
+	}
+
+	// Get the traffic matching criteria
+	trafficMatchingCriteriaGet, err := f5.GetTrafficMatchingCriteria(ctx, trafficMatchingCriteria.Name)
+	if err != nil {
+		log.Fatalf("Failed to get traffic matching criteria: %v", err)
+	}
+	fmt.Printf("%+v\n", trafficMatchingCriteriaGet)
+
+	// Create a virtual server using the address list and traffic matching criteria
+	virtualServer := &bigip.VirtualServer{
+		Name: "virtualserver-example",
+		Partition: "Common",
+		Destination: ":0",
+		Source: "0.0.0.0/0",
+		IPProtocol: "tcp",
+		Mask: "255.255.255.255",
+		TrafficMatchingCriteria: fmt.Sprintf("/%s/%s", trafficMatchingCriteria.Partition, trafficMatchingCriteria.Name),
+	}
+
+	err = f5.AddVirtualServer(virtualServer)
+	if err != nil {
+		log.Fatalf("Failed to create virtual server: %v", err)
+	}
+
+	// Get the virtual server
+	virtualServerGet, err := f5.GetVirtualServer(virtualServer.Name)
+	if err != nil {
+		log.Fatalf("Failed to get virtual server: %v", err)
+	}
+	fmt.Printf("%+v\n", virtualServerGet)
+
+	fmt.Println("Virtual server with address list created")
+
+	err = f5.DeleteVirtualServer(virtualServer.Name)
+	if err != nil {
+		log.Fatalf("Failed to delete virtual server: %v", err)
+	}
+
+	err = f5.DeleteTrafficMatchingCriteria(ctx, trafficMatchingCriteria.Name)
+	if err != nil {
+		log.Fatalf("Failed to delete traffic matching criteria: %v", err)
+	}
+
+	err = f5.DeleteAddressList(ctx, addressList.Name)
+	if err != nil {
+		log.Fatalf("Failed to delete address list: %v", err)
+	}
+
+	fmt.Println("virutal server, traffic matching criteria, and address list deleted.")
+}
+

ltm.go

@@ -11,6 +11,7 @@ See the License for the specific language governing permissions and limitations
 package bigip
 
 import (
+	"context"
 	"encoding/json"
 	"fmt"
 	"log"
@@ -2167,65 +2168,89 @@ type ResponseAdaptProfile struct {
 	Timeout           int    `json:"timeout,omitempty"`
 }
 
+// TrafficMatchingCriteria contains a list of TrafficMatchingCriteria objects.
+type TrafficMatchingCriterias struct {
+	TrafficMatchingCriterias []TrafficMatchingCriteria `json:"items"`
+}
+
+// TrafficMatchingCriteria contains information about each Traffic-Matching-Criteria.
+type TrafficMatchingCriteria struct {
+	Name                     string   `json:"name,omitempty"`
+	Partition                string   `json:"partition,omitempty"`
+	FullPath                 string   `json:"fullPath,omitempty"`
+	Generation               int      `json:"generation,omitempty"`
+	Description              string   `json:"description,omitempty"`
+	Protocol                 string   `json:"protocol,omitempty"`
+	RouteDomain              string   `json:"routeDomain,omitempty"`
+	DestinationAddressList   string   `json:"destinationAddressList,omitempty"`
+	DestinationAddressInline string   `json:"destinationAddressInline,omitempty"`
+	DestinationPortList      string   `json:"destinationPortList,omitempty"`
+	DestinationPortInline    string   `json:"destinationPortInline,omitempty"`
+	SourceAddressList        string   `json:"sourceAddressList,omitempty"`
+	SourceAddressInline      string   `json:"sourceAddressInline,omitempty"`
+	SourcePortInline         int      `json:"sourcePortInline,omitempty"`
+}
+
 const (
-	uriLtm             = "ltm"
-	uriNode            = "node"
-	uriPool            = "pool"
-	uriPoolMember      = "members"
-	uriProfile         = "profile"
-	uriCipher          = "cipher"
-	uriServerSSL       = "server-ssl"
-	uriClientSSL       = "client-ssl"
-	uriVirtual         = "virtual"
-	uriVirtualAddress  = "virtual-address"
-	uriSnatPool        = "snatpool"
-	uriMonitor         = "monitor"
-	uriIRule           = "rule"
-	uriDatagroup       = "data-group"
-	uriInternal        = "internal"
-	uriExternal        = "external"
-	uriPolicy          = "policy"
-	uriOneconnect      = "one-connect"
-	uriPersistence     = "persistence"
-	ENABLED            = "enable"
-	DISABLED           = "disable"
-	CONTEXT_SERVER     = "serverside"
-	CONTEXT_CLIENT     = "clientside"
-	CONTEXT_ALL        = "all"
-	uriRewrite         = "rewrite"
-	uriRewriteRules    = "uri-rules"
-	uriTcp             = "tcp"
-	uriUDP             = "udp"
-	uriFtp             = "ftp"
-	uriFasthttp        = "fasthttp"
-	uriFastl4          = "fastl4"
-	uriHttpcompress    = "http-compression"
-	uriHttp2           = "http2"
-	uriSnat            = "snat"
-	uriSnatpool        = "snatpool"
-	uriCookie          = "cookie"
-	uriDestAddr        = "dest-addr"
-	uriHash            = "hash"
-	uriHost            = "host"
-	uriMSRDP           = "msrdp"
-	uriSIP             = "sip"
-	uriSourceAddr      = "source-addr"
-	uriSSL             = "ssl"
-	uriUniversal       = "universal"
-	uriCreateDraft     = "?options=create-draft"
-	uriRule            = "rule"
-	uriWebAcceleration = "web-acceleration"
-	uriHttp            = "http"
-	uriRequestLog      = "request-log"
-	uriSecurity        = "security"
-	uriBotDefense      = "bot-defense"
-	uriSaas            = "saas"
-	uriSaasBotDefense  = "bd"
-	uriRequestAdapt    = "request-adapt"
-	uriResponseAdapt   = "response-adapt"
-	uriWebsocket       = "websocket"
-	uriHTML            = "html"
-	uriAnalytics       = "analytics"
+	uriLtm                     = "ltm"
+	uriNode                    = "node"
+	uriPool                    = "pool"
+	uriPoolMember              = "members"
+	uriProfile                 = "profile"
+	uriCipher                  = "cipher"
+	uriServerSSL               = "server-ssl"
+	uriClientSSL               = "client-ssl"
+	uriVirtual                 = "virtual"
+	uriVirtualAddress          = "virtual-address"
+	uriSnatPool                = "snatpool"
+	uriMonitor                 = "monitor"
+	uriIRule                   = "rule"
+	uriDatagroup               = "data-group"
+	uriInternal                = "internal"
+	uriExternal                = "external"
+	uriPolicy                  = "policy"
+	uriOneconnect              = "one-connect"
+	uriPersistence             = "persistence"
+	uriTrafficMatchingCriteria = "traffic-matching-criteria"
+	ENABLED                    = "enable"
+	DISABLED                   = "disable"
+	CONTEXT_SERVER             = "serverside"
+	CONTEXT_CLIENT             = "clientside"
+	CONTEXT_ALL                = "all"
+	uriRewrite                 = "rewrite"
+	uriRewriteRules            = "uri-rules"
+	uriTcp                     = "tcp"
+	uriUDP                     = "udp"
+	uriFtp                     = "ftp"
+	uriFasthttp                = "fasthttp"
+	uriFastl4                  = "fastl4"
+	uriHttpcompress            = "http-compression"
+	uriHttp2                   = "http2"
+	uriSnat                    = "snat"
+	uriSnatpool                = "snatpool"
+	uriCookie                  = "cookie"
+	uriDestAddr                = "dest-addr"
+	uriHash                    = "hash"
+	uriHost                    = "host"
+	uriMSRDP                   = "msrdp"
+	uriSIP                     = "sip"
+	uriSourceAddr              = "source-addr"
+	uriSSL                     = "ssl"
+	uriUniversal               = "universal"
+	uriCreateDraft             = "?options=create-draft"
+	uriRule                    = "rule"
+	uriWebAcceleration         = "web-acceleration"
+	uriHttp                    = "http"
+	uriRequestLog              = "request-log"
+	uriSecurity                = "security"
+	uriBotDefense              = "bot-defense"
+	uriSaas                    = "saas"
+	uriSaasBotDefense          = "bd"
+	uriRequestAdapt            = "request-adapt"
+	uriResponseAdapt           = "response-adapt"
+	uriWebsocket               = "websocket"
+	uriHTML                    = "html"
+	uriAnalytics               = "analytics"
 )
 
 var cidr = map[string]string{
@@ -4942,3 +4967,70 @@ func (b *BigIP) DeleteAnalyticsProfile(name string) error {
 func (b *BigIP) ModifyAnalyticsProfile(name string, config *AnalyticsProfile) error {
 	return b.patch(config, uriLtm, uriProfile, uriAnalytics, name)
 }
+
+// GetTrafficMatchingCriteria returns all TrafficMatchingCriteria objects on the Big-IP system.
+func (b *BigIP) TrafficMatchingCriterias(ctx context.Context) (*TrafficMatchingCriterias, error) {
+	if ctx.Err() != nil {
+		return nil, ctx.Err()
+	}
+
+	var trafficMatchingCriterias TrafficMatchingCriterias
+	err, ok := b.getForEntity(&trafficMatchingCriterias, uriLtm, uriTrafficMatchingCriteria)
+	if err != nil {
+		return nil, err
+	}
+
+	if !ok {
+		return nil, nil
+	}
+
+	return &trafficMatchingCriterias, nil
+}
+
+// GetTrafficMatchingCriteria returns a single named TrafficMatchingCriteria.
+// Returns nil if the Traffic Matching Criteria does not exist.
+func (b *BigIP) GetTrafficMatchingCriteria(ctx context.Context, name string) (*TrafficMatchingCriteria, error) {
+	if ctx.Err() != nil {
+		return nil, ctx.Err()
+	}
+
+	var trafficMatchingCriteria TrafficMatchingCriteria
+	err, ok := b.getForEntity(&trafficMatchingCriteria, uriLtm, uriTrafficMatchingCriteria, name)
+
+	if err != nil {
+		return nil, err
+	}
+
+	if !ok {
+		return nil, nil
+	}
+
+	return &trafficMatchingCriteria, nil
+}
+
+// AddTrafficMatchingCritera creates a Traffic Matching Criteria object on the Big-IP system.
+func (b *BigIP) AddTrafficMatchingCriteria(ctx context.Context, config *TrafficMatchingCriteria) error {
+	if ctx.Err() != nil {
+		return ctx.Err()
+	}
+
+	return b.post(config, uriLtm, uriTrafficMatchingCriteria)
+}
+
+// ModifyTrafficMatchingCriteria modifies a Traffic Matching Criteria object on the Big-IP system.
+func (b *BigIP) ModifyTrafficMatchingCriteria(ctx context.Context, name string, config *TrafficMatchingCriteria) error {
+	if ctx.Err() != nil {
+		return ctx.Err()
+	}
+
+	return b.patch(config, uriLtm, uriTrafficMatchingCriteria, name)
+}
+
+// DeleteTrafficMatchingCriteria removes a Traffic Matching Criteria object from the Big-IP system.
+func (b *BigIP) DeleteTrafficMatchingCriteria (ctx context.Context, name string) error {
+	if ctx.Err() != nil {
+		return ctx.Err()
+	}
+
+	return b.delete(uriLtm, uriTrafficMatchingCriteria, name)
+}