/*******************************************************************************
 *  ============LICENSE_START=======================================================
 *  son-handler
 *  ================================================================================
 *   Copyright (C) 2019-2020 Wipro Limited.
 *   ==============================================================================
 *     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.dcaegen2.services.sonhms.restclient;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;

import org.onap.dcaegen2.services.sonhms.Configuration;
import org.onap.dcaegen2.services.sonhms.exceptions.OofNotFoundException;
import org.onap.dcaegen2.services.sonhms.model.AnrInput;
import org.onap.dcaegen2.services.sonhms.utils.SonHandlerRestTemplate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.core.ParameterizedTypeReference;
import org.springframework.http.ResponseEntity;

public class OofRestClient {
    private static Logger log = LoggerFactory.getLogger(OofRestClient.class);

    private OofRestClient() {

    }

    /**
     * rest client that pci uses to query the OOF for pci solutions.
     * 
     * @throws OofNotFoundException
     *             when request to oof fails
     */

    public static String queryOof(int numSolutions, String transactionId, String requestType, List<String> cellIdList,
            String networkId, List<String> optimizers, List<AnrInput> anrInputList, List<String> fixedPciCells) throws OofNotFoundException {
        log.debug("inside queryoof");

        Configuration configuration = Configuration.getInstance();
        UUID requestUuid = UUID.randomUUID();
        String requestId = requestUuid.toString();
        String callbackUrl = configuration.getCallbackUrl();
        RequestInfo requestInfo = new RequestInfo();
        requestInfo.setTransactionId(transactionId);
        requestInfo.setRequestId(requestId);
        requestInfo.setCallbackUrl(callbackUrl);
        String sourceId = configuration.getSourceId();
        requestInfo.setSourceId(sourceId);
        requestInfo.setRequestType(requestType);
        requestInfo.setNumSolutions(numSolutions);
        requestInfo.setOptimizers(optimizers);
        Map<String, String> callbackHeader = new HashMap<>();
        callbackHeader.put("Content-Type", "application/json");
        requestInfo.setCallbackHeader(callbackHeader);
        int timeout = 60;
        requestInfo.setTimeout(timeout);

        CellInfo cellInfo = new CellInfo();
        cellInfo.setCellIdList(cellIdList);
        cellInfo.setNetworkId(networkId);
        cellInfo.setTrigger("NbrListChange");
        if (!anrInputList.isEmpty()) {
            cellInfo.setAnrInputList(anrInputList);
        }
        if(!fixedPciCells.isEmpty()) {
        cellInfo.setFixedPCICells(fixedPciCells); 
        }
        OofRequestBody oofRequestBody = new OofRequestBody();
        oofRequestBody.setRequestInfo(requestInfo);
        oofRequestBody.setCellInfo(cellInfo);

        ObjectMapper mapper = new ObjectMapper();
        String requestBody = "";
        try {
            requestBody = mapper.writeValueAsString(oofRequestBody);
        } catch (JsonProcessingException e) {
            log.error("Exception when forming JSON String {}", e);

        }
        log.info("requestBody{}", requestBody);

        String requestUrl = configuration.getOofService() + configuration.getOofEndpoint();
        log.info("requestUrl {}", requestUrl);
        ResponseEntity<String> response = null; 
        response = SonHandlerRestTemplate.sendPostRequestToOof(requestUrl, requestBody,
                new ParameterizedTypeReference<String>() {
                });
        
        if (response == null) {
            throw new OofNotFoundException("Request to oof failed");
        }
        else if (response.getStatusCodeValue() != 202) {
            throw new OofNotFoundException("Request to oof failed with status code" + response.getStatusCodeValue());
        }
        log.info("response {}", response);

        return response.getBody();
    }
}