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

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

RemoteServer<RtspFaceDetectImpl> remoteServer("127.0.0.1", 8111);
static RtspFaceViewClient* rtspFaceViewClient = nullptr;

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

RtspFaceViewClient* getRtspFaceViewClient()
{
	if (rtspFaceViewClient != nullptr)
	{
		try
		{
			rtspFaceViewClient = new RtspFaceViewClient;
		}
		catch(...)
		{
			delete rtspFaceViewClient;
			rtspFaceViewClient = nullptr;
			LOG_ERROR << "aaaaaaaa"<<LOG_ENDL;//#todo
		}
	}
	return rtspFaceViewClient;
}

RtspFaceViewClient::RtspFaceViewClient() :
		rpcClient("127.0.0.1", 8112), RtspFaceView::Client(rpcClient.getMain<RtspFaceView>())
{}

::kj::WaitScope &RtspFaceViewClient::getWaitScope()
{
	return rpcClient.getWaitScope();
}

::kj::Promise<void> RtspFaceDetectImpl::fireFaceCountListener(FireFaceCountListenerContext context)
{
	auto results = context.getResults();
	remoteFireFaceCountListener(context.getParams(), results);
	context.setResults(results);
}