#include <iostream>
#include "update.h"
#include "deviceInfo.h"
#include "log.h"
#include <string>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>

#include <pthread.h>
#include <stdlib.h>
#include <errno.h>

#include "download.h"
#include "tomcat.h"
#include "rkimage.h"
#include "partition.h"
#include "rkboot_control.h"

double processvalue = 0;
static char * _url = NULL;
/*
static pthread_t a_thread;
static void *thread_function(void *arg){
    *((int*)arg) = -1;
    int res;
    res = pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
    if(res != 0){
        LOGE("Thread pthread_setcancelstate failed.\n");
        exit(EXIT_FAILURE);
    }
    //res = pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL);
    res = pthread_setcanceltype(PTHREAD_CANCEL_DEFERRED, NULL);
    if(res != 0){
        LOGE("Thread pthread_setcanceltype failed");
        exit(EXIT_FAILURE);
    }
    LOGI("thread_function is running\n");
    res = getDataFromUrl(_url);
    if(res == 0){
        *((int*)arg) = 0;
    }
    LOGI("thread_function is stop\n");
    pthread_exit(0);
}*/

void RK_ota_set_url(char *url){
    if(url == NULL){
        LOGE("RK_ota_set_url : url is NULL.\n");
        return ;

    }
    _url = url;
}

void RK_ota_start(RK_upgrade_callback cb){
    LOGI("start RK_ota_start.\n");
    cb(NULL, RK_UPGRADE_START);
    if(_url == NULL){
        LOGE("url is NULL\n");
        cb(NULL, RK_UPGRADE_ERR);
        return ;
    }
#if 0
    if(getDataFromUrl(_url) != 0){
        LOGE("getDataFromUrl failed.\n");
        cb(NULL, RK_UPGRADE_ERR);
        return ;
    }
#endif

    download_file(_url, "/tmp/update.img");
    if(!writeImageToPartition("/tmp/update.img")){
        LOGE("writeImageToPartition failed.\n");
        cb(NULL, RK_UPGRADE_ERR);
        return ;
    }
    if(setSlotActivity() != 0){
        LOGE("setSlotActivity error.\n");
        cb(NULL, RK_UPGRADE_ERR);
        return ;
    }
    //CheckImageFile_2(_url);
    //RKIMAGE_HDR hdr;
    //CheckImageFile(_url, &hdr);

/*
    int res;
    int update_result = 0;
    void *thread_result;

    res = pthread_create(&a_thread, NULL, thread_function, &update_result);
    if(res != 0){
        LOGE("Thread creation failed.");
        cb(NULL, RK_UPGRADE_ERR);
        return ;
    }

    LOGI("waiting for thread to finish...\n");

    res = pthread_join(a_thread, &thread_result);
    if(update_result != 0){
        LOGE("update_result return failed.\n");
        cb(NULL, RK_UPGRADE_ERR);
        return ;
    }
    if(res != 0){
        LOGE("Thread join failed.\n");
        cb(NULL, RK_UPGRADE_ERR);
        exit(EXIT_FAILURE);
    }
*/
    LOGI("RK_ota_start is ok!");
    cb(NULL, RK_UPGRADE_FINISHED);
}

void RK_ota_stop(){
    int res;
    LOGI("start RK_ota_stop.\n");
	/*
    res = pthread_cancel(a_thread);
    if(res != 0){
        LOGE("Thread cancelation failed");
        exit(EXIT_FAILURE);
    }*/
}


int RK_ota_get_progress(){
#if 0
    return showProgressValue();
#endif
    return processvalue;
}

void RK_ota_get_sw_version(char *buffer, int maxLength){
    DeviceInfoInternel info;
    info.setCurrentConfig();

    std::string ver = info.getCurrentVersion();
    if(ver.size() <= maxLength){
        memcpy(buffer, ver.c_str(), ver.size());
    }
}

bool RK_ota_check_version(const char *url){
    DeviceInfoInternel info;
    info.setHost(url);
    info.setCurrentConfig();
    info.setTargetConfig();
    return info.compareVersion();
}