//
// Created by pansen on 2017/8/4.
//

#include "RemoteFuncClient.h"
#include "RemoteFunc.h"
#include "RtspNativeCodecJNIClient.h"
#include "AppConfig.h"

#include <string>
#include <iostream>
using namespace std;

AppConfig config("data/config.cfg");
RemoteServer<RtspFaceDetectImpl> remoteServer(config.getStringValue("local_ip"), config.getIntValue("local_port"));
//RemoteServer<RtspFaceDetectImpl> remoteServer("192.168.1.97", 8111);
static RtspFaceViewClient* rtspFaceViewClient = nullptr;

void startRemoteServer()
{
	remoteServer.start();
}

RtspFaceViewClient * getRtspFaceViewClient()
{
    if(rtspFaceViewClient == nullptr)
        rtspFaceViewClient = new RtspFaceViewClient;
	return rtspFaceViewClient;
}

RtspFaceViewClient::RtspFaceViewClient() :
        rpcClient(nullptr)
{}

RtspFaceView::Client& RtspFaceViewClient::getClient()
{
    if (client == nullptr) {
        try
        {
            client = new RtspFaceView::Client(getEzRpcClient()->getMain<RtspFaceView>());
        }
        catch (const kj::Exception& e)
        {
            delete client;
            client = nullptr;
            throw e;
        }
    }
    return *client;
}

::kj::WaitScope &RtspFaceViewClient::getWaitScope()
{
    return getEzRpcClient()->getWaitScope();
}

capnp::EzRpcClient * RtspFaceViewClient::getEzRpcClient()
{
    if (rpcClient == nullptr) {
        try
        {
            //rpcClient = new capnp::EzRpcClient("192.168.1.116", 8112);
            rpcClient = new capnp::EzRpcClient(config.getStringValue("server_ip"), config.getIntValue("server_port"));
        }
        catch (const kj::Exception& e)
        {
            delete rpcClient;
            rpcClient = nullptr;
            throw e;
        }
    }
    return rpcClient;
}

::kj::Promise<void> RtspFaceDetectImpl::fireFaceCountListener(FireFaceCountListenerContext context)
{
	auto results = context.getResults();
    LOG_ERROR << "!!!!!!!!!!!!!!!!!!!!!WHO  find face!!!!!!!" << LOG_ENDL;
	remoteFireFaceCountListener(context.getParams(), results);
    //context.setResults(results);
    return kj::READY_NOW;
}