CameraRecorder/API/WebAPI.cpp

#include "WebAPI.h"
#include "Recorder/Recorder.h"
#include "Recorder/DigooRecorder.h"
#include "Recorder/FoscamRecorder.h"
#include "Recorder/VStarCamRecorder.h"
#include "Recorder/WatchBotRecorder.h"
#include "Recorder/ZModoRecorder.h"
#include <StringAlgorithm.h>
#include <memory>


namespace CameraRecorder {
namespace API {

// API Description

// Status Query
// Goal:	Provide status information based on POST data
// Use:		DomoticaSite status update
// URL:		http://<ip>/API/<action>/<brand>/<ipaddress>/<port>/<username>/<password>

WebAPI::WebAPI()
{
}

WebAPI::~WebAPI()
{
}

Http::HttpServer::HttpReply WebAPI::ProcessQuery(ctpl::thread_pool* pThreadPool, Http::HttpClient* pHttpClient, const std::string& path, const std::string& ffmpeg, const std::string& uri, const std::vector<Http::HttpPostData>& postData)
{
	if (!StringAlgorithm::iequals(uri, "/api") && !StringAlgorithm::istarts_with(uri, "/api/"))
	{
		Http::HttpServer::HttpReply reply;
		reply.status = Http::HttpServer::HttpReply::Status::Unauthorized;
		return reply;
	}

	Http::HttpServer::HttpReply reply;
	reply.status = Http::HttpServer::HttpReply::Status::InternalServerError;
	reply.content = "{\"result\": \"error\"}\r\n";

	std::string apiURI = uri.substr(4);

	std::vector<std::string> uriTokens = StringAlgorithm::split(apiURI, '/');

	if (uriTokens.size() < 7)
			return reply;

	std::string action = uriTokens[1];
	std::string brand = uriTokens[2];

	Recorder::Settings settings;
	settings.Path = path;
	settings.IpAddress = uriTokens[3];
	settings.Port = uriTokens[4];
	settings.Username = uriTokens[5];
	settings.Password = uriTokens[6];

	int numberOfImages = 5;
	if (uriTokens.size() > 7)
		numberOfImages = stoi(uriTokens[7]);

	reply.status = Http::HttpServer::HttpReply::Status::Ok;
	if (StringAlgorithm::iequals("Digoo", brand))
	{
		auto recorder = Recorder::DigooRecorder(pHttpClient, settings);
		if (StringAlgorithm::iequals("Snapshot", action))
			reply.content = recorder.Snapshot(pThreadPool);
		else if (StringAlgorithm::iequals("MultiSnapshot", action))
			reply.content = recorder.MultiSnapshot(pThreadPool, numberOfImages);
		else if (StringAlgorithm::iequals("Video", action))
			reply.content = recorder.Video(pThreadPool, ffmpeg);
	}
	else if (StringAlgorithm::iequals("Foscam", brand))
	{
		auto recorder = Recorder::FoscamRecorder(pHttpClient, settings);
		if (StringAlgorithm::iequals("Snapshot", action))
			reply.content = recorder.Snapshot(pThreadPool);
		else if (StringAlgorithm::iequals("MultiSnapshot", action))
			reply.content = recorder.MultiSnapshot(pThreadPool, numberOfImages);
		else if (StringAlgorithm::iequals("Video", action))
			reply.content = recorder.Video(pThreadPool, ffmpeg);
	}
	else if (StringAlgorithm::iequals("VStarCam", brand))
	{
		auto recorder = Recorder::VStarCamRecorder(pHttpClient, settings);
		if (StringAlgorithm::iequals("Snapshot", action))
			reply.content = recorder.Snapshot(pThreadPool);
		else if (StringAlgorithm::iequals("MultiSnapshot", action))
			reply.content = recorder.MultiSnapshot(pThreadPool, numberOfImages);
		else if (StringAlgorithm::iequals("Video", action))
			reply.content = recorder.Video(pThreadPool, ffmpeg);
	}
	else if (StringAlgorithm::iequals("WatchBot", brand))
	{
		auto recorder = Recorder::WatchBotRecorder(pHttpClient, settings);
		if (StringAlgorithm::iequals("Snapshot", action))
			reply.content = recorder.Snapshot(pThreadPool);
		else if (StringAlgorithm::iequals("MultiSnapshot", action))
			reply.content = recorder.MultiSnapshot(pThreadPool, numberOfImages);
		else if (StringAlgorithm::iequals("Video", action))
			reply.content = recorder.Video(pThreadPool, ffmpeg);
	}
	else if (StringAlgorithm::iequals("ZModo", brand))
	{
		auto recorder = Recorder::ZModoRecorder(pHttpClient, settings);
		if (StringAlgorithm::iequals("Snapshot", action))
			reply.content = recorder.Snapshot(pThreadPool);
		else if (StringAlgorithm::iequals("MultiSnapshot", action))
			reply.content = recorder.MultiSnapshot(pThreadPool, numberOfImages);
		else if (StringAlgorithm::iequals("Video", action))
			reply.content = recorder.Video(pThreadPool, ffmpeg);
	}

	return reply;
}

} // namespace API
} // namespace CameraRecorder