E2E Instantiation of a Closed Loop
##########################################


.. code:: Python

    #Service already created in this case

    logger = logging.getLogger("")
    logger.setLevel(logging.INFO)
    fh = logging.StreamHandler()
    fh_formatter = logging.Formatter('%(asctime)s %(levelname)s %(lineno)d:%(filename)s(%(process)d) - %(message)s')
    fh.setFormatter(fh_formatter)
    logger.addHandler(fh)


    #Constants
    SERVICE_NAME = "Test_SDK"
    POLICY_NAME = ["MinMax", "FrequencyLimiter"]
    LOOP_INSTANCE_NAME = "instance01"
    CERT = (PEM, KEY) # you must add clamp cert for AUTHENTIFICATION

    Clamp.set_proxy({ 'http': 'socks5h://127.0.0.1:8080', 'https': 'socks5h://127.0.0.1:8080'})
    Service.set_proxy({ 'http': 'socks5h://127.0.0.1:8080', 'https': 'socks5h://127.0.0.1:8080'})

    logger.info("*******************************")
    logger.info("******** SERVICE FETCH *******")
    logger.info("*******************************")

    svc = Service(name=SERVICE_NAME)

    logger.info("***************************************")
    logger.info("******** CLAMP AUTHENTIFICATION *******")
    logger.info("***************************************")

    Clamp(cert=CERT)

    logger.info("*************************************")
    logger.info("******** LOOP TEMPLATES CHECK *******")
    logger.info("*************************************")

    loop_template = Clamp.check_loop_template(service=svc)
    if not loop_template:
        logger.error("Loop template for the service %s not found", svc.name)
        exit(1)

    logger.info("*******************************")
    logger.info("******** POLICIES CHECK *******")
    logger.info("*******************************")

    minmax_exists = Clamp.check_policies(policy_name=POLICY_NAME[0],
                                            req_policies=30)
    frequency_exists = Clamp.check_policies(policy_name=POLICY_NAME[1],
                                            req_policies=30)
    policy_exists = (minmax_exists and frequency_exists)
    if not policy_exists:
        logger.error("Couldn't load the policy %s", POLICY_NAME)
        exit(1)

    logger.info("***********************************")
    logger.info("******** LOOP INSTANTIATION *******")
    logger.info("***********************************")

    loop = LoopInstance(template=loop_template, name=LOOP_INSTANCE_NAME, details={}, cert=CERT)
    loop.create()
    if loop.details:
        logger.info("Loop instance %s successfully created !!", LOOP_INSTANCE_NAME)
    else:
        logger.error("An error occured while creating the loop instance")

    logger.info("******** UPDATE MICROSERVICE POLICY *******")
    loop._update_loop_details()
    loop.update_microservice_policy()

    logger.info("******** ADD OPERATIONAL POLICY MINMAX *******")
    added = loop.add_operational_policy(policy_type="onap.policies.controlloop.guard.common.MinMax",
                                        policy_version="1.0.0")

    logger.info("******** CONFIGURE OPERATIONAL POLICY MINMAX *******")
    loop.add_op_policy_config(loop.add_minmax_config)

    logger.info("******** ADD FREQUENCY POLICY *******")
    added = loop.add_operational_policy(policy_type="onap.policies.controlloop.guard.common.FrequencyLimiter",
                                        policy_version="1.0.0")

    logger.info("******** CONFIGURE FREQUENCY POLICY *******")
    loop.add_op_policy_config(loop.add_frequency_limiter)

    logger.info("******** SUBMIT POLICIES TO PE *******")
    submit = loop.act_on_loop_policy(loop.submit)

    logger.info("******** CHECK POLICIES SUBMITION *******")
    if submit :
        logger.info("Policies successfully submited to PE")
    else:
        logger.error("An error occured while submitting the loop instance")
        exit(1)

    logger.info("******** DEPLOY LOOP INSTANCE *******")
    deploy = loop.deploy_microservice_to_dcae()
    if deploy:
        logger.info("Loop instance %s successfully deployed on DCAE !!", LOOP_INSTANCE_NAME)
    else:
        logger.error("An error occured while deploying the loop instance")
        exit(2)

    logger.info("******** DELETE LOOP INSTANCE *******")
    loop.delete()