Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

enhancement for node_mgmt_epg_to_contract (DCNE-87) #658

Open
wants to merge 8 commits into
base: master
Choose a base branch
from
370 changes: 370 additions & 0 deletions plugins/modules/aci_node_mgmt_epg_to_contract.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,370 @@
#!/usr/bin/python
# -*- coding: utf-8 -*-

# Copyright: (c) 2025, Faiz Mohammad (@Ziaf007) <[email protected]>
# GNU General Public License v3.0+ (see LICENSE or https://www.gnu.org/licenses/gpl-3.0.txt)

from __future__ import absolute_import, division, print_function

__metaclass__ = type

ANSIBLE_METADATA = {"metadata_version": "1.1", "status": ["preview"], "supported_by": "certified"}

DOCUMENTATION = r"""
---
module: aci_node_mgmt_epg_to_contract
short_description: Bind Node Mgmt EPGs to Contracts (fv:RsCons, fv:RsProv, fv:RsProtBy, fv:RsConsIf, and mgmt:RsOoBProv)
description:
- Bind Node mgmt EPGs to Contracts on Cisco ACI fabrics.
notes:
- The C(Node Mgmt EPG), and C(Contract) used must exist before using this module in your playbook.
The M(cisco.aci.aci_node_mgmt_epg), M(cisco.aci.aci_oob_contract) and M(cisco.aci.aci_contract) modules can be used for this.
options:
contract:
description:
- The name of the contract or contract interface.
type: str
aliases: [ contract_name, contract_interface ]
contract_type:
description:
- Determines the type of the Contract.
type: str
required: true
choices: [ consumer, provider, taboo, interface ]
epg:
description:
- The name of the Node Mgmt end point group.
type: str
aliases: [ epg_name ]
priority:
description:
- Quality of Service (QoS) class.
- The APIC defaults to C(unspecified) when unset during creation.
type: str
choices: [ level1, level2, level3, level4, level5, level6, unspecified ]
provider_match:
description:
- The matching algorithm for Provided Contracts.
- The APIC defaults to C(at_least_one) when unset during creation.
type: str
choices: [ all, at_least_one, at_most_one, none ]
state:
description:
- Use C(present) or C(absent) for adding or removing.
- Use C(query) for listing an object or multiple objects.
type: str
choices: [ absent, present, query ]
default: present
extends_documentation_fragment:
- cisco.aci.aci
- cisco.aci.annotation

seealso:
- module: cisco.aci.aci_node_mgmt_epg
- module: cisco.aci.aci_contract
- module: cisco.aci.aci_oob_contract
- name: APIC Management Information Model reference
description: More information about the internal APIC classes B(fv:RsCons), B(fv:RsProv), B(fv:RsProtBy), B(fv:RsConsIf), and B(mgmt:RsOoBProv).
link: https://developer.cisco.com/docs/apic-mim-ref/
author:
- Faiz Mohammad (@Ziaf007)
"""

EXAMPLES = r"""
- name: Add a new contract to Inband EPG binding
cisco.aci.aci_node_mgmt_epg_to_contract:
host: apic
username: admin
password: SomeSecretPassword
epg: anstest
epg_type: in_band
contract: anstest_http
contract_type: consumer
priority: level2
state: present
delegate_to: localhost

- name: Add a new contract to Out-of-Band EPG binding
cisco.aci.aci_node_mgmt_epg_to_contract:
host: apic
username: admin
password: SomeSecretPassword
epg: anstest
epg_type: out_of_band
contract: anstest_http
contract_type: provider
priority: level3
provider_match: at_least_one
state: present
delegate_to: localhost

- name: Query a specific contract to EPG binding
cisco.aci.aci_inbepg_to_contract:
host: apic
username: admin
password: SomeSecretPassword
epg: anstest
epg_type: in_band
contract: anstest_http
contract_type: consumer
state: query
delegate_to: localhost
register: query_result

- name: Query all provider contract to EPG bindings
cisco.aci.aci_inbepg_to_contract:
host: apic
username: admin
password: SomeSecretPassword
contract_type: provider
state: query
delegate_to: localhost
register: query_result

- name: Remove an existing contract to Inband EPG binding
cisco.aci.aci_inbepg_to_contract:
host: apic
username: admin
password: SomeSecretPassword
epg: anstest
epg_type: in_band
contract: anstest_http
contract_type: consumer
state: absent
delegate_to: localhost
"""

RETURN = r"""
current:
description: The existing configuration from the APIC after the module has finished
returned: success
type: list
sample:
[
{
"fvTenant": {
"attributes": {
"descr": "Production environment",
"dn": "uni/tn-production",
"name": "production",
"nameAlias": "",
"ownerKey": "",
"ownerTag": ""
}
}
}
]
error:
description: The error information as returned from the APIC
returned: failure
type: dict
sample:
{
"code": "122",
"text": "unknown managed object class foo"
}
raw:
description: The raw output returned by the APIC REST API (xml or json)
returned: parse error
type: str
sample: '<?xml version="1.0" encoding="UTF-8"?><imdata totalCount="1"><error code="122" text="unknown managed object class foo"/></imdata>'
sent:
description: The actual/minimal configuration pushed to the APIC
returned: info
type: list
sample:
{
"fvTenant": {
"attributes": {
"descr": "Production environment"
}
}
}
previous:
description: The original configuration from the APIC before the module has started
returned: info
type: list
sample:
[
{
"fvTenant": {
"attributes": {
"descr": "Production",
"dn": "uni/tn-production",
"name": "production",
"nameAlias": "",
"ownerKey": "",
"ownerTag": ""
}
}
}
]
proposed:
description: The assembled configuration from the user-provided parameters
returned: info
type: dict
sample:
{
"fvTenant": {
"attributes": {
"descr": "Production environment",
"name": "production"
}
}
}
filter_string:
description: The filter string used for the request
returned: failure or debug
type: str
sample: ?rsp-prop-include=config-only
method:
description: The HTTP method used for the request to the APIC
returned: failure or debug
type: str
sample: POST
response:
description: The HTTP response from the APIC
returned: failure or debug
type: str
sample: OK (30 bytes)
status:
description: The HTTP status from the APIC
returned: failure or debug
type: int
sample: 200
url:
description: The HTTP url used for the request to the APIC
returned: failure or debug
type: str
sample: https://10.11.12.13/api/mo/uni/tn-production.json
"""

from ansible.module_utils.basic import AnsibleModule
from ansible_collections.cisco.aci.plugins.module_utils.aci import ACIModule, aci_argument_spec, aci_annotation_spec
from ansible_collections.cisco.aci.plugins.module_utils.constants import ACI_CLASS_MAPPING, CONTRACT_LABEL_MAPPING, PROVIDER_MATCH_MAPPING, SUBJ_LABEL_MAPPING


def main():
argument_spec = aci_argument_spec()
argument_spec.update(aci_annotation_spec())
argument_spec.update(
contract_type=dict(type="str", choices=["consumer", "provider", "taboo", "interface"], required=True),
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

docs do not match [ consumer, provider, taboo, interface, intra_epg ]

epg_type=dict(
type="str", aliases=["type"], choices=["in_band", "out_of_band"], required=True
), # required for querying as provider class for INB and OOB are different
epg=dict(type="str", aliases=["epg_name"]), # Not required for querying all objects
contract=dict(type="str", aliases=["contract_name", "contract_interface"]), # Not required for querying all objects
priority=dict(type="str", choices=["level1", "level2", "level3", "level4", "level5", "level6", "unspecified"]),
provider_match=dict(type="str", choices=["all", "at_least_one", "at_most_one", "none"]),
state=dict(type="str", default="present", choices=["absent", "present", "query"]),
)

module = AnsibleModule(
argument_spec=argument_spec,
supports_check_mode=True,
required_if=[
["state", "absent", ["epg", "contract"]],
["state", "present", ["epg", "contract"]],
],
)

epg_type = module.params.get("epg_type")
contract = module.params.get("contract")
contract_type = module.params.get("contract_type")
epg = module.params.get("epg")
priority = module.params.get("priority")
provider_match = module.params.get("provider_match")
if provider_match is not None:
provider_match = PROVIDER_MATCH_MAPPING[provider_match]
state = module.params.get("state")

if epg_type == "in_band":

if contract_type != "provider" and provider_match is not None:
module.fail_json(msg="the provider_match is only configurable for Provider Contracts")

aci_class = ACI_CLASS_MAPPING[contract_type]["class"]
aci_rn = ACI_CLASS_MAPPING[contract_type]["rn"]
aci_name = ACI_CLASS_MAPPING[contract_type]["name"]
class_config = {"matchT": provider_match, "prio": priority, aci_name: contract}

elif epg_type == "out_of_band":

if contract_type != "provider":
module.fail_json(msg="only provider contract_type is supported for out_of_band epg_type.")

if provider_match is not None:
module.fail_json(msg="The provider_match argument is not supported for out_of_band Provider contracts")

aci_class = "mgmtRsOoBProv"
aci_rn = "rsooBProv-"
aci_name = "tnVzOOBBrCPName"
class_config = {"prio": priority, aci_name: contract}

class_Map = {"in_band": [dict(epg_class="mgmtInB", epg_rn="inb-{0}")], "out_of_band": [dict(epg_class="mgmtOoB", epg_rn="oob-{0}")]}

aci = ACIModule(module)
aci.construct_url(
# root_class=dict(
# aci_class="fvTenant",
# aci_rn="tn-mgmt",
# module_object="mgmt",
# target_filter={"name": "mgmt"}
# ),
# subclass_1=dict(
# aci_class="mgmtMgmtP",
# aci_rn="mgmtp-default",
# module_object="default",
# target_filter={"name": "default"}
# ),
# subclass_2=dict(
# aci_class=class_Map[epg_type][0]["epg_class"],
# aci_rn=class_Map[epg_type][0]["epg_rn"].format(epg),
# module_object=epg,
# target_filter={"name": epg}
# ),
# subclass_3=dict(
# aci_class=aci_class,
# aci_rn="{0}{1}".format(aci_rn, contract),
# module_object=contract,
# target_filter={aci_name: contract}
# )
root_class=dict(
# aci_class="fvTenant",
aci_rn="tn-mgmt/mgmtp-default",
module_object=None
),
subclass_1=dict(
aci_class=class_Map[epg_type][0]["epg_class"],
aci_rn=class_Map[epg_type][0]["epg_rn"].format(epg),
module_object=epg,
target_filter={"name": epg}
),
subclass_2=dict(
aci_class=aci_class,
aci_rn="{0}{1}".format(aci_rn, contract),
module_object=contract,
target_filter={aci_name: contract}
)
)

aci.get_existing()

if state == "present":
aci.payload(
aci_class=aci_class,
class_config=class_config,
)

aci.get_diff(aci_class=aci_class)

aci.post_config()

elif state == "absent":
aci.delete_config()

aci.exit_json()


if __name__ == "__main__":
main()
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
# No ACI simulator yet, so not enabled
# unsupported
Loading
Loading