// Path: maven-car-deploy-plugin/src/main/java/org/wso2/maven/car/artifact/impl/CAppMgtApiHelperServiceImpl.java
// public class CAppMgtApiHelperServiceImpl implements CAppMgtApiHelperService {
// 
//     private String getAsString(InputStream inputStream) throws IOException {
//         return IOUtils.toString(inputStream);
//     }
// 
//     @Override
//     public JSONObject doAuthenticate(String serverUrl, String username, String password)
//             throws CAppMgtServiceStubException {
//         try {
//             Response response = HTTPSClientUtil.doAuthenticate(serverUrl, username, password);
//             if (response.status() == 200 && response.body() != null) {
//                 return new JSONObject(getAsString(response.body().asInputStream()));
//             }
//             throw new CAppMgtServiceStubException("Failed to authenticate. " + response.reason());
//         } catch (RetryableException e) {
//             throw new CAppMgtServiceStubException (
//                     String.format("Cannot connect to the server node %s.", serverUrl), e);
//         } catch (IOException e) {
//             throw new CAppMgtServiceStubException ("Failed to read the response body.", e);
//         }
//     }
// 
//     @Override
//     public boolean deployCApp(File capp, String accessToken, String serverUrl) throws CAppMgtServiceStubException {
//         try {
//             Response response = HTTPSClientUtil.deployCApp(capp, accessToken, serverUrl);
//             if (response.status() == 200) {
//                 return true;
//             }
//             throw new CAppMgtServiceStubException("Could not deploy the capp to the server." + response.reason());
//         } catch (RetryableException e) {
//             throw new CAppMgtServiceStubException (
//                     String.format("Cannot connect to the server node %s.", serverUrl), e);
//         }
//     }
// 
//     @Override
//     public boolean unDeployCApp(String accessToken, String serverUrl, String cAppName)
//             throws CAppMgtServiceStubException {
//         try {
//             Response response = HTTPSClientUtil.unDeployCApp(accessToken, serverUrl, cAppName);
//             if (response.status() == 200) {
//                 return true;
//             }
//             throw new CAppMgtServiceStubException("Could not unDeploy the capp to the server." + response.reason());
//         } catch (RetryableException e) {
//             throw new CAppMgtServiceStubException (
//                     String.format("Cannot connect to the server node %s.", serverUrl), e);
//         }
//     }
// 
// }
// 
// Path: maven-car-deploy-plugin/src/main/java/org/wso2/maven/car/artifact/util/Constants.java
// public class Constants {
// 
//     public static final int CLIENT_CONNECTION_TIMEOUT = 5000;
//     public static final int CLIENT_READ_TIMEOUT = 5000;
//     public static final String CONFIG_OPERATION_DEPLOY = "deploy";
//     public static final String CONFIG_OPERATION_UNDEPLOY = "undeploy";
//     public static final String MI_SERVER = "mi";
//     public static final String EI_SERVER = "ei";
// 
//     public static final String AUTHORIZATION_HEADER = "Authorization";
//     public static final String BASIC = "Basic ";
//     public static final String ACCESS_TOKEN = "AccessToken";
// }


import org.apache.maven.plugin.logging.Log;
import org.apache.maven.project.MavenProject;
import org.json.JSONObject;
import org.wso2.maven.car.artifact.impl.CAppMgtApiHelperServiceImpl;
import org.wso2.maven.car.artifact.util.Constants;
import java.io.File;
/*
 *
 *  Copyright (c) 2021, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
 *
 *  WSO2 Inc. licenses this file to you 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.
 *
 */

package org.wso2.maven.car.artifact;



/**
 * This class implements CAppHandler to implement the CApp deploy/undeploy logic for MI Servers.
 */
public class MICAppHandler implements CAppHandler {

    private final CAppMgtApiHelperServiceImpl capppMgtApiHelperServiceImpl;
    private final Log logger;

    public MICAppHandler(Log logger) {

        this.logger = logger;
        this.capppMgtApiHelperServiceImpl = new CAppMgtApiHelperServiceImpl();
    }

    @Override
    public void deployCApp(String username, String password, String serverUrl, File carFile) throws Exception {

        JSONObject resObj = capppMgtApiHelperServiceImpl.doAuthenticate(serverUrl, username, password);
        if (resObj != null) {
            logger.info("Authentication to " + serverUrl + " successful.");
            String accessToken = resObj.getString(Constants.ACCESS_TOKEN);
            if (isNotBlank(accessToken)) {
                if (capppMgtApiHelperServiceImpl.deployCApp(carFile, accessToken, serverUrl)) {
                    logger.info("Uploaded " + carFile.getName() + " to " + serverUrl + " ...");
                }
            }
        }
    }

    @Override
    public void unDeployCApp(String username, String password, String serverUrl, MavenProject project)
            throws Exception {

        JSONObject resObj = capppMgtApiHelperServiceImpl.doAuthenticate(serverUrl, username, password);
        if (resObj != null) {
            logger.info("Authentication to " + serverUrl + " successful.");
// Path: maven-car-deploy-plugin/src/main/java/org/wso2/maven/car/artifact/impl/CAppMgtApiHelperServiceImpl.java
// public class CAppMgtApiHelperServiceImpl implements CAppMgtApiHelperService {
// 
//     private String getAsString(InputStream inputStream) throws IOException {
//         return IOUtils.toString(inputStream);
//     }
// 
//     @Override
//     public JSONObject doAuthenticate(String serverUrl, String username, String password)
//             throws CAppMgtServiceStubException {
//         try {
//             Response response = HTTPSClientUtil.doAuthenticate(serverUrl, username, password);
//             if (response.status() == 200 && response.body() != null) {
//                 return new JSONObject(getAsString(response.body().asInputStream()));
//             }
//             throw new CAppMgtServiceStubException("Failed to authenticate. " + response.reason());
//         } catch (RetryableException e) {
//             throw new CAppMgtServiceStubException (
//                     String.format("Cannot connect to the server node %s.", serverUrl), e);
//         } catch (IOException e) {
//             throw new CAppMgtServiceStubException ("Failed to read the response body.", e);
//         }
//     }
// 
//     @Override
//     public boolean deployCApp(File capp, String accessToken, String serverUrl) throws CAppMgtServiceStubException {
//         try {
//             Response response = HTTPSClientUtil.deployCApp(capp, accessToken, serverUrl);
//             if (response.status() == 200) {
//                 return true;
//             }
//             throw new CAppMgtServiceStubException("Could not deploy the capp to the server." + response.reason());
//         } catch (RetryableException e) {
//             throw new CAppMgtServiceStubException (
//                     String.format("Cannot connect to the server node %s.", serverUrl), e);
//         }
//     }
// 
//     @Override
//     public boolean unDeployCApp(String accessToken, String serverUrl, String cAppName)
//             throws CAppMgtServiceStubException {
//         try {
//             Response response = HTTPSClientUtil.unDeployCApp(accessToken, serverUrl, cAppName);
//             if (response.status() == 200) {
//                 return true;
//             }
//             throw new CAppMgtServiceStubException("Could not unDeploy the capp to the server." + response.reason());
//         } catch (RetryableException e) {
//             throw new CAppMgtServiceStubException (
//                     String.format("Cannot connect to the server node %s.", serverUrl), e);
//         }
//     }
// 
// }
// 
// Path: maven-car-deploy-plugin/src/main/java/org/wso2/maven/car/artifact/util/Constants.java
// public class Constants {
// 
//     public static final int CLIENT_CONNECTION_TIMEOUT = 5000;
//     public static final int CLIENT_READ_TIMEOUT = 5000;
//     public static final String CONFIG_OPERATION_DEPLOY = "deploy";
//     public static final String CONFIG_OPERATION_UNDEPLOY = "undeploy";
//     public static final String MI_SERVER = "mi";
//     public static final String EI_SERVER = "ei";
// 
//     public static final String AUTHORIZATION_HEADER = "Authorization";
//     public static final String BASIC = "Basic ";
//     public static final String ACCESS_TOKEN = "AccessToken";
// }


// Path: maven-car-deploy-plugin/src/main/java/org/wso2/maven/car/artifact/MICAppHandler.java
import org.apache.maven.plugin.logging.Log;
import org.apache.maven.project.MavenProject;
import org.json.JSONObject;
import org.wso2.maven.car.artifact.impl.CAppMgtApiHelperServiceImpl;
import org.wso2.maven.car.artifact.util.Constants;
import java.io.File;

/*
 *
 *  Copyright (c) 2021, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
 *
 *  WSO2 Inc. licenses this file to you 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.
 *
 */

package org.wso2.maven.car.artifact;



/**
 * This class implements CAppHandler to implement the CApp deploy/undeploy logic for MI Servers.
 */
public class MICAppHandler implements CAppHandler {

    private final CAppMgtApiHelperServiceImpl capppMgtApiHelperServiceImpl;
    private final Log logger;

    public MICAppHandler(Log logger) {

        this.logger = logger;
        this.capppMgtApiHelperServiceImpl = new CAppMgtApiHelperServiceImpl();
    }

    @Override
    public void deployCApp(String username, String password, String serverUrl, File carFile) throws Exception {

        JSONObject resObj = capppMgtApiHelperServiceImpl.doAuthenticate(serverUrl, username, password);
        if (resObj != null) {
            logger.info("Authentication to " + serverUrl + " successful.");
            String accessToken = resObj.getString(Constants.ACCESS_TOKEN);
            if (isNotBlank(accessToken)) {
                if (capppMgtApiHelperServiceImpl.deployCApp(carFile, accessToken, serverUrl)) {
                    logger.info("Uploaded " + carFile.getName() + " to " + serverUrl + " ...");
                }
            }
        }
    }

    @Override
    public void unDeployCApp(String username, String password, String serverUrl, MavenProject project)
            throws Exception {

        JSONObject resObj = capppMgtApiHelperServiceImpl.doAuthenticate(serverUrl, username, password);
        if (resObj != null) {
            logger.info("Authentication to " + serverUrl + " successful.");
            String accessToken = resObj.getString(Constants.ACCESS_TOKEN);