[ccsdk/features.git] /

/*
 * ============LICENSE_START========================================================================
 * ONAP : ccsdk feature sdnr wt
 * =================================================================================================
 * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property. All rights reserved.
 * =================================================================================================
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
 * in compliance with the License. You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software distributed under the License
 * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
 * or implied. See the License for the specific language governing permissions and limitations under
 * the License.
 * ============LICENSE_END==========================================================================
 */
package org.onap.ccsdk.features.sdnr.wt.devicemanager.aaiconnector.impl;

import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.onap.ccsdk.features.sdnr.wt.common.http.BaseHTTPClient;
import org.onap.ccsdk.features.sdnr.wt.common.http.BaseHTTPResponse;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class AaiWebApiClient extends BaseHTTPClient {

    private static Logger LOG = LoggerFactory.getLogger(AaiWebApiClient.class);
    private static final String PNF_JSON_INTERFACE_TEMPLATE = "        {\n"
            + "            \"interface-name\": \"@interface@\",\n" + "            \"speed-value\": \"300\",\n"
            + "            \"speed-units\": \"MBit/s\",\n"
            + "            \"port-description\": \"Air Interface (MWPS)\",\n"
            + "            \"equipment-identifier\": \"@pnfId@-@interface@\",\n"
            + "            \"interface-role\": \"Wireless\",\n"
            + "            \"interface-type\": \"Air Interface (MWPS)\",\n"
            + "            \"resource-version\": \"@model@\",\n" + "            \"relationship-list\": [\n"
            + "                {\n"
            + "                    \"related-to\": \"A keyword provided by A&AI to indicate type of node.\",\n"
            + "                    \"related-link\": \"URL to the object in A&AI.\",\n"
            + "                    \"relationship-data\": [\n" + "                        {\n"
            + "                            \"relationship-key\": \"A keyword provided by A&AI to indicate an attribute.\",\n"
            + "                            \"relationship-value\": \"Value of the attribute\"\n"
            + "                        }\n" + "                    ],\n"
            + "                    \"related-to-property\": [\n" + "                        {\n"
            + "                            \"property-key\": \"Key part of a key/value pair\",\n"
            + "                            \"property-value\": \"Value part of a key/value pair\"\n"
            + "                        }\n" + "                    ]\n" + "                }\n" + "            ]\n"
            + "        }\n";
    private static final String PNF_JSON_TEMPLATE = "{\n" + "    \"pnf-name\": \"@pnfId@\",\n"
            + "    \"pnf-id\": \"@pnfId@\",\n" + "    \"equip-type\": \"@type@\",\n"
            + "    \"equip-model\": \"@model@\",\n" + "    \"equip-vendor\": \"@vendor@\",\n"
            + "    \"ipaddress-v4-oam\": \"@oamIp@\",\n" + "    \"in-maint\": false,\n"
            + "    \"prov-status\":\"PROV\",\n" + "    \"p-interfaces\": @interface-list@\n" + "}\n" + "";
    private static final String PNF_URI = "network/pnfs/pnf/";
    private static final String EMPTY_MESSAGE = "";

    private final Map<String, String> headerMap;


    public AaiWebApiClient(String baseUrl, Map<String, String> headers, boolean trustAllCerts) {
        this(baseUrl, headers, trustAllCerts, null, null);
    }

    public AaiWebApiClient(String baseUrl, Map<String, String> headers, boolean trustAllCerts, String certFilename,
            String passphrase) {
        super(baseUrl, trustAllCerts, certFilename, passphrase, BaseHTTPClient.getSslCertPcks());

        this.headerMap = new HashMap<>();
        this.headerMap.putAll(headers);
        this.headerMap.put("Content-Type", "application/json");
        this.headerMap.put("Accept", "application/json");
    }

    /**
     * Create and specify defition parametrs of pnf
     * 
     * @param pnfId name
     * @param type type
     * @param model model
     * @param vendor vendor
     * @param oamIp ip
     * @param ifaces interfaces
     * @return true if http response code was 200 or false if not.
     */
    public boolean pnfCreate(String pnfId, String type, String model, String vendor, String oamIp,
            List<String> ifaces) {
        LOG.debug("registering {} (type={}, model={}, vendor={},ip={})", pnfId, type, model, vendor, oamIp);
        String message = getPnfTemplateFilled(pnfId, type, model, vendor, oamIp, ifaces);
        return pnfRequest(pnfId, "PUT", message) == 200;
    }

    /**
     * Unregister
     * 
     * @param pnfId name
     * @return true if http response code was 200 or false if not.
     */
    public boolean pnfDelete(String pnfId) {
        LOG.debug("unregistering {}", pnfId);
        return pnfRequest(pnfId, "DELETE", EMPTY_MESSAGE) == 200;
    }

    /**
     * Send registration request
     * 
     * @param pnfId name
     * @return error accoring to http response code or -1
     */
    public int pnfCheckIfExists(String pnfId) {
        LOG.debug("check for {}", pnfId);
        return pnfRequest(pnfId, "GET", EMPTY_MESSAGE);
    }

    /*
     * Private classes
     */

    private int pnfRequest(String pnfId, String method, String message) {
        BaseHTTPResponse response;
        try {
            String uri = PNF_URI + URLParamEncoder.encode(pnfId);
            response = this.sendRequest(uri, method, message, headerMap);
            LOG.debug("finished with responsecode {}", response.code);
            return response.code;
        } catch (IOException e) {
            LOG.warn("problem registering {} : {}", pnfId, e.getMessage());
            return -1;
        }
    }


    private static String getPnfTemplateFilled(String pnfId, String type, String model, String vendor, String oamIp,
            List<String> ifaces) {
        return PNF_JSON_TEMPLATE.replace("@pnfId@", pnfId).replace("@type@", type).replace("@model@", model)
                .replace("@vendor@", vendor).replace("@oamIp@", oamIp)
                .replace("@interface-list@", getPnfTemplateInterfaceList(pnfId, ifaces, model));
    }

    private static String getPnfTemplateInterfaceList(String pnfId, List<String> ifaces, String model) {
        StringBuffer s = new StringBuffer();
        s.append("[");
        if (ifaces != null) {
            for (int i = 0; i < ifaces.size(); i++) {
                if (i > 0) {
                    s.append(",");
                }
                s.append(PNF_JSON_INTERFACE_TEMPLATE.replace("@interface@", ifaces.get(i)));
            }
        }
        s.append("]");

        return s.toString().replace("@pnfId@", pnfId).replace("@model@", model);
    }



}