CACIT-82 added datasource (#151)

* CACIT-82 added datasource

* fvCEP datasource updated

Author: nkatarmal-crest

aci/data_source_aci_fvcep.go

@@ -0,0 +1,248 @@
+package aci
+
+import (
+	"fmt"
+	"strings"
+
+	"github.com/ciscoecosystem/aci-go-client/client"
+	"github.com/ciscoecosystem/aci-go-client/container"
+	"github.com/ciscoecosystem/aci-go-client/models"
+	"github.com/hashicorp/terraform-plugin-sdk/helper/schema"
+)
+
+func dataSourceAciClientEndPoint() *schema.Resource {
+	return &schema.Resource{
+
+		Read: dataSourceAciClientEndPointRead,
+
+		SchemaVersion: 1,
+
+		Schema: AppendBaseAttrSchema(map[string]*schema.Schema{
+			"name": &schema.Schema{
+				Type:     schema.TypeString,
+				Optional: true,
+				Computed: true,
+			},
+
+			"mac": &schema.Schema{
+				Type:     schema.TypeString,
+				Optional: true,
+				Computed: true,
+			},
+
+			"ip": &schema.Schema{
+				Type:     schema.TypeString,
+				Optional: true,
+				Computed: true,
+			},
+
+			"vlan": &schema.Schema{
+				Type:     schema.TypeString,
+				Optional: true,
+				Computed: true,
+			},
+
+			"fvcep_objects": &schema.Schema{
+				Type:     schema.TypeList,
+				Optional: true,
+				Computed: true,
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"name": &schema.Schema{
+							Type:     schema.TypeString,
+							Optional: true,
+							Computed: true,
+						},
+
+						"mac": &schema.Schema{
+							Type:     schema.TypeString,
+							Optional: true,
+							Computed: true,
+						},
+
+						"ip": &schema.Schema{
+							Type:     schema.TypeString,
+							Optional: true,
+							Computed: true,
+						},
+
+						"vlan": &schema.Schema{
+							Type:     schema.TypeString,
+							Optional: true,
+							Computed: true,
+						},
+
+						"tenant_name": &schema.Schema{
+							Type:     schema.TypeString,
+							Optional: true,
+							Computed: true,
+						},
+
+						"vrf_name": &schema.Schema{
+							Type:     schema.TypeString,
+							Optional: true,
+							Computed: true,
+						},
+
+						"application_profile_name": &schema.Schema{
+							Type:     schema.TypeString,
+							Optional: true,
+							Computed: true,
+						},
+
+						"epg_name": &schema.Schema{
+							Type:     schema.TypeString,
+							Optional: true,
+							Computed: true,
+						},
+
+						"l2out_name": &schema.Schema{
+							Type:     schema.TypeString,
+							Optional: true,
+							Computed: true,
+						},
+
+						"instance_profile_name": &schema.Schema{
+							Type:     schema.TypeString,
+							Optional: true,
+							Computed: true,
+						},
+					},
+				},
+			},
+		}),
+	}
+}
+
+func extractInfo(con *container.Container) (obj map[string]interface{}, dn string) {
+	infoMap := make(map[string]interface{})
+	dnString := models.G(con, "dn")
+	infoMap["name"] = models.G(con, "name")
+	infoMap["mac"] = models.G(con, "mac")
+	infoMap["ip"] = models.G(con, "ip")
+	infoMap["vlan"] = models.G(con, "encap")
+
+	dnInfoList := strings.Split(dnString, "/")
+	tenantInfo := strings.Split(dnInfoList[1], "-")
+	if tenantInfo[0] == "tn" {
+		infoMap["tenant_name"] = tenantInfo[1]
+
+		level2Info := strings.Split(dnInfoList[2], "-")
+		if level2Info[0] == "ctx" {
+			infoMap["vrf_name"] = level2Info[1]
+
+		} else if level2Info[0] == "ap" {
+			infoMap["application_profile_name"] = level2Info[1]
+
+			level3Info := strings.Split(dnInfoList[3], "-")
+			if level3Info[0] == "epg" {
+				infoMap["epg_name"] = level3Info[1]
+			} else {
+				return nil, ""
+			}
+
+		} else if level2Info[0] == "l2out" {
+			infoMap["l2out_name"] = level2Info[1]
+
+			level3Info := strings.Split(dnInfoList[3], "-")
+			if level3Info[0] == "instP" {
+				infoMap["instance_profile_name"] = level3Info[1]
+			} else {
+				return nil, ""
+			}
+
+		} else {
+			return nil, ""
+		}
+
+	} else {
+		return nil, ""
+	}
+
+	return infoMap, dnString
+}
+
+func getRemoteClientEndPoint(client *client.Client, query string) (objMap []interface{}, objdns []string, err error) {
+	baseURL := "/api/node/class"
+
+	var duURL string
+	if query == "" {
+		duURL = fmt.Sprintf("%s/fvCEp.json", baseURL)
+	} else {
+		duURL = fmt.Sprintf("%s/fvCEp.json?query-target-filter=and(%s)", baseURL, query)
+	}
+
+	fvCEpCont, err := client.GetViaURL(duURL)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	objects := make([]interface{}, 0, 1)
+	dns := make([]string, 0, 1)
+
+	count, err := fvCEpCont.ArrayCount("imdata")
+	if err != nil {
+		return nil, nil, err
+	}
+
+	for i := 0; i < count; i++ {
+		clientEndPointCont, err := fvCEpCont.ArrayElement(i, "imdata")
+		if err != nil {
+			return nil, nil, err
+		}
+
+		objMap, dn := extractInfo(clientEndPointCont.S("fvCEp", "attributes"))
+		if dn != "" {
+			objects = append(objects, objMap)
+			dns = append(dns, dn)
+		}
+	}
+
+	return objects, dns, nil
+}
+
+func dataSourceAciClientEndPointRead(d *schema.ResourceData, m interface{}) error {
+	aciClient := m.(*client.Client)
+
+	var queryString string
+	if mac, ok := d.GetOk("mac"); ok {
+		if queryString != "" {
+			queryString = fmt.Sprintf("%s,eq(fvCEp.mac, \"%s\")", queryString, mac.(string))
+		} else {
+			queryString = fmt.Sprintf("eq(fvCEp.mac, \"%s\")", mac.(string))
+		}
+	}
+
+	if ip, ok := d.GetOk("ip"); ok {
+		if queryString != "" {
+			queryString = fmt.Sprintf("%s,eq(fvCEp.ip, \"%s\")", queryString, ip.(string))
+		} else {
+			queryString = fmt.Sprintf("eq(fvCEp.ip, \"%s\")", ip.(string))
+		}
+	}
+
+	if name, ok := d.GetOk("name"); ok {
+		if queryString != "" {
+			queryString = fmt.Sprintf("%s,eq(fvCEp.name, \"%s\")", queryString, name.(string))
+		} else {
+			queryString = fmt.Sprintf("eq(fvCEp.name, \"%s\")", name.(string))
+		}
+	}
+
+	if vlan, ok := d.GetOk("vlan"); ok {
+		if queryString != "" {
+			queryString = fmt.Sprintf("%s,eq(fvCEp.encap, \"vlan-%s\")", queryString, vlan.(string))
+		} else {
+			queryString = fmt.Sprintf("eq(fvCEp.encap, \"vlan-%s\")", vlan.(string))
+		}
+	}
+
+	objects, dns, err := getRemoteClientEndPoint(aciClient, queryString)
+	if err != nil {
+		return err
+	}
+
+	d.Set("fvcep_objects", objects)
+	d.SetId(strings.Join(dns, " "))
+	return nil
+}

aci/provider.go

@@ -255,6 +255,7 @@ func Provider() terraform.ResourceProvider {
 			"aci_fabric_path_ep":                           dataSourceAciFabricPathEndpoint(),
 			"aci_fabric_if_pol":                            dataSourceAciLinkLevelPolicy(),
 			"aci_aaa_domain":                               dataSourceAciSecurityDomain(),
+			"aci_client_end_point":                         dataSourceAciClientEndPoint(),
 		},
 
 		ConfigureFunc: configureClient,

examples/client_end_point/main.tf

@@ -0,0 +1,13 @@
+provider "aci" {
+  username = ""
+  password = ""
+  url      = ""
+  insecure = true
+}
+
+data "aci_client_end_point" "check" {
+  name               = "25:56:68:78:98:74"
+  mac                = "25:56:68:78:98:74"
+  ip                 = "0.0.0.0"
+  vlan               = "5"
+}

website/aci.erb

@@ -57,6 +57,9 @@
                       <li<%= sidebar_current("docs-aci-data-source-cdp_interface_policy") %>>
                         <a href="/docs/providers/aci/d/cdp_interface_policy.html">aci_cdp_interface_policy</a>
                       </li>
+                      <li<%= sidebar_current("docs-aci-data-source-client_end_point") %>>
+                        <a href="/docs/providers/aci/d/client_end_point.html">aci_client_end_point</a>
+                      </li>
                       <li<%= sidebar_current("docs-aci-data-source-cloud_applicationcontainer") %>>
                         <a href="/docs/providers/aci/d/cloud_applicationcontainer.html">aci_cloud_applicationcontainer</a>
                       </li>

website/docs/d/client_end_point.html.markdown

@@ -0,0 +1,48 @@
+---
+layout: "aci"
+page_title: "ACI: aci_client_end_point"
+sidebar_current: "docs-aci-data-source-client_end_point"
+description: |-
+  Data source for ACI Client End Point
+---
+
+# aci_client_end_point #
+Data source for ACI Client End Point
+
+## Example Usage ##
+
+```hcl
+
+data "aci_client_end_point" "check" {
+  application_epg_dn  = "${aci_application_epg.epg.id}"
+  mac                 = "25:56:68:78:98:74"
+  ip                  = "1.2.3.4"
+  vlan                = "5"
+}
+
+```
+
+
+## Argument Reference ##
+* `application_epg_dn` - (Required) Distinguished name of parent ApplicationEPG object.
+* `name` - (Optional) name of Object client end point.
+* `mac` - (Optional) Mac address of the object client end point.
+* `ip` - (Optional) ip address of the object client end point.
+* `vlan` - (Optional) vlan for the object client end point.
+
+
+
+## Attribute Reference
+
+* `id` - Attribute id set as all Dns for matching the Client End Point.
+* `fvcep_objects` - list of all client end point objects which matched to the given filter attributes.
+* `fvcep_objects.name` - Name of object client end point.
+* `fvcep_objects.mac` - Mac address of object client end point.
+* `fvcep_objects.ip` - IP address of object client end point.
+* `fvcep_objects.vlan` - vlan of client end point object.
+* `fvcep_objects.tenant_name` - parent Tenant name for matched client end point.
+* `fvcep_objects.vrf_name` - parent vrf name for matched client end point.
+* `fvcep_objects.application_profile_name` - parent application profile name for matched client end point.
+* `fvcep_objects.epg_name` - parent epg name for matched client end point.
+* `fvcep_objects.l2out_name` - parent l2out name for matched client end point.
+* `fvcep_objects.instance_profile_name` - parent instance profile name for matched client end point.