so-simulator/src/main/java/org/onap/so/simulator/actions/aai/ProcessNetwork.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

package org.onap.so.simulator.actions.aai;

import org.onap.aai.domain.yang.L3Network;
import org.onap.aaiclient.client.aai.AAIResourcesClient;
import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri;
import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory;
import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.consol.citrus.actions.AbstractTestAction;
import com.consol.citrus.context.TestContext;


public class ProcessNetwork extends AbstractTestAction {

    @Override
    public void doExecute(TestContext context) {
        final Logger logger = LoggerFactory.getLogger(ProcessNetwork.class);
        try {
            int random = (int) (Math.random() * 50 + 1);

            AAIResourcesClient aaiResourceClient = new AAIResourcesClient();

            if (context.getVariable("action").equals("assign")) {
                String networkId = context.getVariable("generatedNetworkId");
                AAIResourceUri networkURI =
                        AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.network().l3Network(networkId));
                L3Network network = new L3Network();
                network.setNetworkId(networkId);
                network.setNetworkName(context.getVariable("networkName"));
                network.setNetworkType(context.getVariable("networkType"));
                network.setNetworkTechnology("SR_IOV");
                network.setPhysicalNetworkName("PhysicalNetwork" + random);
                aaiResourceClient.create(networkURI, network);
            } else if (context.getVariable("action").equals("delete")) {
                String networkId = context.getVariable("networkId");
                AAIResourceUri networkURI =
                        AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.network().l3Network(networkId));
                aaiResourceClient.delete(networkURI);
            }
        } catch (Exception e) {
            logger.debug("Exception in ProcessNetwork.doExecute", e);
        }

    }
}