added jsonrpc class

server/jsonrpc.cpp

@@ -0,0 +1,161 @@
+/***
+    This file is part of snapcast
+    Copyright (C) 2015  Johannes Pohl
+
+    This program is free software: you can redistribute it and/or modify
+    it under the terms of the GNU General Public License as published by
+    the Free Software Foundation, either version 3 of the License, or
+    (at your option) any later version.
+
+    This program is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU General Public License for more details.
+
+    You should have received a copy of the GNU General Public License
+    along with this program.  If not, see <http://www.gnu.org/licenses/>.
+***/
+
+#include "jsonrpc.h"
+#include "common/log.h"
+
+
+using namespace std;
+
+
+
+JsonRequest::JsonRequest() : id(-1), method("")
+{
+}
+
+
+void JsonRequest::parse(const std::string& json)
+{
+	// http://www.jsonrpc.org/specification
+	//	code	message	meaning
+	//	-32700	Parse error	Invalid JSON was received by the server. An error occurred on the server while parsing the JSON text.
+	//	-32600	Invalid Request	The JSON sent is not a valid Request object.
+	//	-32601	Method not found	The method does not exist / is not available.
+	//	-32602	Invalid params	Invalid method parameter(s).
+	//	-32603	Internal error	Internal JSON-RPC error.
+	//	-32000 to -32099	Server error	Reserved for implementation-defined server-errors.
+	try
+	{
+		try
+		{
+			json_ = Json::parse(json);
+		}
+		catch (const exception& e)
+		{
+			throw JsonRequestException(e.what(), -32700);
+		}
+
+		id = json_["id"].get<int>();
+		string jsonrpc = json_["jsonrpc"].get<string>();
+		if (jsonrpc != "2.0")
+			throw JsonRequestException("invalid jsonrpc value: " + jsonrpc, -32600);
+		method = json_["method"].get<string>();
+		if (method.empty())
+			throw JsonRequestException("method must not be empty", -32600);
+		if (id < 0)
+			throw JsonRequestException("id must be a positive integer", -32600);
+
+		params.clear();
+		try
+		{
+			if (json_["params"] != nullptr)
+				params = json_["params"].get<vector<string>>();
+		}
+		catch (const exception& e)
+		{
+			throw JsonRequestException(e.what(), -32602);
+		}
+	}
+	catch (const JsonRequestException& e)
+	{
+		throw;
+	}
+	catch (const exception& e)
+	{
+		throw JsonRequestException(e.what(), -32603, id);
+	}
+}
+
+
+Json JsonRequest::getResponse(const Json& result)
+{
+	Json response = {
+		{"jsonrpc", "2.0"},
+		{"id", id},
+		{"result", result}
+	};
+
+	return response;
+}
+
+
+Json JsonRequest::getError(int code, const std::string& message)
+{
+	Json response = {
+		{"jsonrpc", "2.0"},
+		{"error", {
+			{"code", code},
+			{"message", message}
+		}},
+	};
+
+	return response;
+
+}
+
+
+
+/*
+
+			if ((method == "get") || (method == "set"))
+			{
+				vector<string> params;
+				try
+				{
+					params = request["params"].get<vector<string>>();
+				}
+				catch (const exception& e)
+				{
+					throw JsonRpcException(e.what(), -32602);
+				}
+				if (method == "get")
+				{
+					//{"jsonrpc": "2.0", "method": "get", "params": ["status"], "id": 2}
+					//{"jsonrpc": "2.0", "method": "get", "params": ["status", "server"], "id": 2}
+					//{"jsonrpc": "2.0", "method": "get", "params": ["status", "client"], "id": 2}
+					//{"jsonrpc": "2.0", "method": "get", "params": ["status", "client", "MAC"], "id": 2}
+					vector<string> params = request["params"].get<vector<string>>();
+					for (auto s: params)
+						logO << s << "\n";
+					response["result"] = "???";//nullptr;
+				}
+				else if (method == "set")
+				{
+					//{"jsonrpc": "2.0", "method": "set", "params": ["volume", "0.9", "client", "MAC"], "id": 2}
+					//{"jsonrpc": "2.0", "method": "set", "params": ["active", "client", "MAC"], "id": 2}
+					response["result"] = "234";//nullptr;
+				}
+			}
+			else
+				throw JsonRpcException("method not found: \"" + method + "\"", -32601);
+
+			connection->send(response.dump());
+
+*/
+
+
+
+/*
+		Json response = {
+			{"jsonrpc", "2.0"},
+			{"id", id}
+		};
+
+*/
+
+

server/jsonrpc.h

@@ -0,0 +1,129 @@
+/***
+    This file is part of snapcast
+    Copyright (C) 2015  Johannes Pohl
+
+    This program is free software: you can redistribute it and/or modify
+    it under the terms of the GNU General Public License as published by
+    the Free Software Foundation, either version 3 of the License, or
+    (at your option) any later version.
+
+    This program is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU General Public License for more details.
+
+    You should have received a copy of the GNU General Public License
+    along with this program.  If not, see <http://www.gnu.org/licenses/>.
+***/
+
+#ifndef JSON_RPC_H
+#define JSON_RPC_H
+
+#include <string>
+#include <vector>
+#include "json.hpp"
+#include "common/snapException.h"
+
+using Json = nlohmann::json;
+
+
+
+
+class JsonRequest
+{
+public:
+	/// ctor. Encoded PCM data is passed to the PipeListener
+	JsonRequest();
+
+	void parse(const std::string& json);
+	int id;
+	std::string method;
+	std::vector<std::string> params;
+
+	Json getResponse(const Json& result);
+	Json getError(int code, const std::string& message);
+
+protected:
+	Json json_;
+
+};
+
+
+
+
+class JsonRequestException : public SnapException
+{
+  int errorCode_, id_;
+public:
+	JsonRequestException(const char* text, int errorCode = 0, int id = -1) : SnapException(text), errorCode_(errorCode), id_(id)
+	{
+	}
+
+	JsonRequestException(const std::string& text, int errorCode = 0, int id = -1) : SnapException(text), errorCode_(errorCode), id_(id)
+	{
+	}
+
+	JsonRequestException(const JsonRequest& request, const std::string& text, int errorCode = 0) : SnapException(text), errorCode_(errorCode), id_(request.id)
+	{
+	}
+
+	JsonRequestException(const JsonRequestException& e) :  SnapException(e.what()), errorCode_(e.errorCode()), id_(e.id_)
+	{
+	}
+
+	virtual int errorCode() const noexcept
+	{
+		return errorCode_;
+	}
+
+	Json getResponse() const noexcept
+	{
+		int errorCode = errorCode_;
+		if (errorCode == 0)
+			errorCode = -32603;
+
+		Json response = {
+			{"jsonrpc", "2.0"},
+			{"error", {
+				{"code", errorCode},
+				{"message", what()}
+			}},
+		};
+		if (id_ == -1)
+			response["id"] = nullptr;
+		else
+			response["id"] = id_;
+
+		return response;
+	}
+};
+
+
+class JsonMethodNotFoundException : public JsonRequestException
+{
+public:
+	JsonMethodNotFoundException(const JsonRequest& request) : JsonRequestException(request, "method not found", -32601)
+	{
+	}
+
+	JsonMethodNotFoundException(const JsonRequest& request, const std::string& message) : JsonRequestException(request, message, -32601)
+	{
+	}
+};
+
+
+
+class JsonInvalidParamsException : public JsonRequestException
+{
+public:
+	JsonInvalidParamsException(const JsonRequest& request) : JsonRequestException(request, "invalid params", -32602)
+	{
+	}
+
+	JsonInvalidParamsException(const JsonRequest& request, const std::string& message) : JsonRequestException(request, message, -32602)
+	{
+	}
+};
+
+
+#endif