// ***************************************************************** -*- C++ -*-

// con-test.cpp

// Tester application for testing the http/https/ftp/ssh/sftp connection

#include <exiv2/exiv2.hpp>

#ifdef EXV_USE_CURL

    #include <curl/curl.h>

#endif

#include <iostream>

#include <cstdlib>

void httpcon(const std::string& url, bool useHttp1_0 = false) {

    Exiv2::Dictionary response;

    Exiv2::Dictionary request;

    std::string       errors;

    Exiv2::Uri uri = Exiv2::Uri::Parse(url);

    Exiv2::Uri::Decode(uri);

    request["server"] = uri.Host;

    request["page"]   = uri.Path;

    request["port"]   = uri.Port;

    if (!useHttp1_0) request["version"] = "1.1";

    int serverCode = Exiv2::http(request,response,errors);

    if (serverCode < 0 || serverCode >= 400 || errors.compare("") != 0) {

        throw Exiv2::Error(Exiv2::kerTiffDirectoryTooLarge, "Server", serverCode);

    }

}

#ifdef EXV_USE_CURL

void curlcon(const std::string& url, bool useHttp1_0 = false) {

    CURL* curl = curl_easy_init();

    if(!curl) {

        throw Exiv2::Error(Exiv2::kerErrorMessage, "Uable to init libcurl.");

    }

    // get the timeout value

    std::string timeoutStr = Exiv2::getEnv(Exiv2::envTIMEOUT);

    long timeout = atol(timeoutStr.c_str());

    if (timeout == 0) {

        throw Exiv2::Error(Exiv2::kerErrorMessage, "Timeout Environmental Variable must be a positive integer.");

    }

    std::string response;

    curl_easy_setopt(curl, CURLOPT_URL, url.c_str());

    curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, Exiv2::curlWriter);

    curl_easy_setopt(curl, CURLOPT_WRITEDATA, &response);

    curl_easy_setopt(curl, CURLOPT_SSL_VERIFYPEER, 0L);

    curl_easy_setopt(curl, CURLOPT_SSL_VERIFYHOST, 0L);

    curl_easy_setopt(curl, CURLOPT_CONNECTTIMEOUT, timeout);

    //curl_easy_setopt(curl, CURLOPT_VERBOSE, 1); // debug

    if (useHttp1_0) curl_easy_setopt(curl, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_0);

    else            curl_easy_setopt(curl, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);

    /* Perform the request, res will get the return code */

    CURLcode res = curl_easy_perform(curl);

    if(res != CURLE_OK) { // error happends

        throw Exiv2::Error(Exiv2::kerErrorMessage, curl_easy_strerror(res));

    }

    // get return code

    long returnCode;

    curl_easy_getinfo (curl, CURLINFO_RESPONSE_CODE, &returnCode); // get code

    curl_easy_cleanup(curl);

    if (returnCode >= 400 || returnCode < 0) {

        throw Exiv2::Error(Exiv2::kerTiffDirectoryTooLarge, "Server", returnCode);

    }

}

#endif

#ifdef EXV_USE_SSH

void sshcon(const std::string& url) {

    Exiv2::Uri uri = Exiv2::Uri::Parse(url);

    Exiv2::Uri::Decode(uri);

    std::string page = uri.Path;

    // remove / at the beginning of the path

    if (page[0] == '/') {

        page = page.substr(1);

    }

    Exiv2::SSH ssh(uri.Host, uri.Username, uri.Password, uri.Port);

    std::string response = "";

    std::string cmd = "declare -a x=($(ls -alt " + page + ")); echo ${x[4]}";

    if (ssh.runCommand(cmd, &response) != 0) {

        throw Exiv2::Error(Exiv2::kerErrorMessage, "Unable to get file length.");

    } else {

        long length = atol(response.c_str());

        if (length == 0) {

            throw Exiv2::Error(Exiv2::kerErrorMessage, "File is empty or not found.");

        }

    }

}

void sftpcon(const std::string& url) {

    Exiv2::Uri uri = Exiv2::Uri::Parse(url);

    Exiv2::Uri::Decode(uri);

    std::string page = uri.Path;

    // remove / at the beginning of the path

    if (page[0] == '/') {

        page = page.substr(1);

    }

    Exiv2::SSH ssh(uri.Host, uri.Username, uri.Password, uri.Port);

    sftp_file handle;

    ssh.getFileSftp(page, handle);

    if (handle == NULL) throw Exiv2::Error(Exiv2::kerErrorMessage, "Unable to open the file");

    else sftp_close(handle);

}

#endif

int main(int argc,const char** argv)

{

    Exiv2::XmpParser::initialize();

    ::atexit(Exiv2::XmpParser::terminate);

    if (argc < 2) {

        std::cout << "Usage: " << argv[0] << " url {-http1_0}" << std::endl;

        return 1;

    }

    std::string url(argv[1]);

    Exiv2::Protocol prot = Exiv2::fileProtocol(url);

    bool useHttp1_0 = false;

    for ( int a = 1 ; a < argc ; a++ ) {

        std::string arg(argv[a]);

        if (arg == "-http1_0") useHttp1_0 = true;

    }

    bool isOk = false;

    try {

        #ifdef EXV_USE_SSH

            if (prot == Exiv2::pSsh) {

                sshcon(url);

                isOk = true;

            } else if (prot == Exiv2::pSftp){

                sftpcon(url);

                isOk = true;

            }

        #endif

        #ifdef EXV_USE_CURL

            if (prot == Exiv2::pHttp || prot == Exiv2::pHttps || prot == Exiv2::pFtp) {

                curlcon(url, useHttp1_0);

                isOk = true;

            }

        #endif

        if (!isOk && prot == Exiv2::pHttp) {

            httpcon(url, useHttp1_0);

            isOk = true;

        }

    } catch (const Exiv2::AnyError& e) {

        std::cout << "Error: '" << e << "'" << std::endl;

        return -1;

    }

    if (!isOk)  std::cout << "The protocol is unsupported." << std::endl;

    else        std::cout << "OK." << std::endl;

    return 0;

}

// That's all Folks!