include/History/HistoryController.cpp - main - quantvector/backend-core

include/History/HistoryController.cpp

48 строк2 KB

YRM

Feature: added interaction with the BINANCE platform

24 апр 2026, 21:15

24 апр 2026, 21:15bd9c206

#include "HistoryController.h"
#include <boost/beast/version.hpp>
#include <boost/json.hpp>
#include <pqxx/pqxx>
#include <iostream>

boost::beast::http::response<boost::beast::http::string_body> HistoryController::getUserHistory(const boost::beast::http::request<boost::beast::http::string_body> &req) {
	boost::beast::http::response<boost::beast::http::string_body> res{boost::beast::http::status::ok, req.version()};
	res.set(boost::beast::http::field::content_type, "application/json");
	boost::json::object res_obj;
	try {
		boost::json::value parsed = boost::json::parse(req.body());
		boost::json::object parse_obj = parsed.as_object();
		std::string platform = parse_obj.at("platform").as_string().c_str();
		std::string vk_user_id = "";
		std::string token = "";
		if(platform == "vk") 
			 vk_user_id = parse_obj.at("vk_user_id").as_string().c_str();
		if(platform == "mobile" || platform == "web")
			token = parse_obj.at("token").as_string().c_str();
		long long limit = parse_obj.at("limit").as_int64();

		pqxx::connection db_conn("dbname=quant_db user=postgres password=12345 host=127.0.0.1 port=5432");
		pqxx::work txn(db_conn);
		std::string sql = "SELECT * FROM history WHERE owner_token = " + token + ";";
		pqxx::result result = txn.exec(sql);

		boost::json::array data;
		while (!result.empty()) {
			std::string raw_json = result[0][0].as<std::string>();
			boost::json::value json_data = boost::json::parse(raw_json);
			data = json_data.get_array();
		}

		res_obj["status"] = "success";
		res_obj["data"] = data;
		res.body() = boost::json::serialize(res_obj);
	}
	catch(std::exception &e) {
		std::cerr << "[ERROR] Parsing history error: " << e.what() << std::endl;
		boost::json::object err_obj;
		err_obj["status"] = "error";
		err_obj["message"] = "Parsing history error.";
		res.body() = boost::json::serialize(err_obj);
	}
	res.prepare_payload();
	return res;
}