#include "DebugNetwork.h"

#include <stdio.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <netinet/in.h>

#include "pthread.h"

#include <logger.h>
#include <MaterialBuffer.h>

#include "ev_proto.h"
#include "face_daemon_proto.h"

#define STFACE_SERVER_IP "52.79.232.163"
#define STFACE_SERVER_PORT "15432"
#define STFACE_RECV_BUFFER_SIZE 1024
#define STFACE_DEBUG_NETWORK_SYNC false

std::string g_dbgLog;

struct SocketClientContext
{
    pthread_t daemon_thid;
    uint8_t* buffer;
    size_t buffSize;

    SocketClientContext() : daemon_thid(0), buffer(nullptr), buffSize(0)
    {
    }

    ~SocketClientContext()
    {
        //pthread_join(daemon_thid, NULL);

        delete[] buffer;
        buffer = nullptr;
        buffSize = 0;
    }

    static void* daemon_thd(void* arg)
    {
        SocketClientContext* ctx = (SocketClientContext*)arg;

        //g_dbgLog = "";

        int clientfd = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
        if (clientfd < 0)
        {
            LOG_WARN << "socket create error errno=" << errno << LOG_ENDL;
            delete ctx;
            return nullptr;
        }

        struct sockaddr_in servaddr;
        memset(&servaddr, 0, sizeof(servaddr));
        servaddr.sin_family = AF_INET;
        servaddr.sin_addr.s_addr = inet_addr(STFACE_SERVER_IP);
        servaddr.sin_port = htons(atoi(STFACE_SERVER_PORT));
        /* Establish connection */
        if (connect(clientfd, (struct sockaddr *) &servaddr, sizeof(servaddr)) < 0)
        {
            LOG_WARN << "socket connect error errno=" << errno << LOG_ENDL;
            close(clientfd);
            delete ctx;
            return nullptr;
        }

        if (send(clientfd, ctx->buffer, ctx->buffSize, 0) != ctx->buffSize)
        {
            LOG_WARN << "Mismatch in number of sent bytes" << LOG_ENDL;
        }

        int recvSize = recv(clientfd, ctx->buffer, STFACE_RECV_BUFFER_SIZE, 0);

        ctx->buffer[recvSize] = '\0';
        g_dbgLog = (char*)ctx->buffer;
        LOG_NOTICE << "face detect result: " << ctx->buffer << LOG_ENDL;

        close(clientfd);
        delete ctx;
    }

    void sendBuff(uint8_t* _buffer, size_t _buffSize)
    {
        if (_buffer != nullptr)
        {
            buffer = new uint8_t[_buffSize + STFACE_RECV_BUFFER_SIZE]; // more for receive
            memcpy(buffer, _buffer, _buffSize);
            buffSize = _buffSize;
        }

        if(STFACE_DEBUG_NETWORK_SYNC)
        {

        }
        else
        {
            int ret = pthread_create(&daemon_thid, NULL, daemon_thd, this);
            if(ret != 0)
            {
                LOGP(ERROR, "pthread_create: %s/n", strerror(ret));
                delete this;
                return;
            }
        }
    }
};

void dbgSendFaceDetect(uint8_t* buffer, size_t buffSize)
{
    SocketClientContext* ctx = new SocketClientContext;
    ctx->sendBuff(buffer, buffSize);
    // delete ctx itself
}

void dbgSendFaceAdd(const NativeImgIdx& imgidx, uint8_t* buffImg)
{
    SocketClientContext* ctx = new SocketClientContext;

    ctx->buffer = new uint8_t[sizeof(EVPHeader) + sizeof(FDP_Image) + imgidx.size + STFACE_RECV_BUFFER_SIZE]; // more for receive

    EVPHeader* evpHeader = new (ctx->buffer) EVPHeader;
    FDP_Image* fdpImage = new (ctx->buffer + sizeof(EVPHeader)) FDP_Image;

    evpHeader->proto = EVPProto::EVPP_RAW_BIN;
    evpHeader->cmd = FaceDaemonCommand::FDC_SENSETIMEFACEDETECT_SAVE;
    evpHeader->size = sizeof(EVPHeader) + sizeof(FDP_Image) + imgidx.size;

    fdpImage->db_id = 1001;
    fdpImage->mb_type = imgidx.type;
    fdpImage->width = imgidx.width;
    fdpImage->height = imgidx.height;
    fdpImage->size = 0;//#todo

    memcpy(fdpImage->buff, buffImg, imgidx.size);
    ctx->buffSize = evpHeader->size;

    evpHeader->hton();
    fdpImage->hton();

    ctx->sendBuff(nullptr, 0);
    // delete ctx itself
}