PersonalPublic/gpt_chat_bot
1
0
Fork 0
mirror of https://github.com/Balshgit/gpt_chat_bot.git synced 2025-12-15 16:10:39 +03:00
Code Issues Packages Projects Releases Wiki Activity

add provider ChatAnywhere (#57)

Browse Source 
* dd provider ChatAnywhere

* update dependencies
This commit is contained in:
Dmitry Afanasyev
2023-11-17 20:34:44 +03:00
committed by GitHub
parent 31ad4e7dcb
commit f8b32fcadc
7 changed files with 245 additions and 188 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
chatgpt_microservice/include/cfg.h
View File

@@ -7,7 +7,8 @@
struct Config {
std::string client_root_path;
std::size_t interval{300};
std::size_t work_thread_num{std::thread::hardware_concurrency() * 2};
std::size_t work_thread_num{std::thread::hardware_concurrency() == 1 ? 2
: std::thread::hardware_concurrency() * 2};
std::string host{"0.0.0.0"};
std::string port{"8858"};
std::string chat_path{"/chat"};

1
chatgpt_microservice/include/free_gpt.h
View File

@@ -40,6 +40,7 @@ public:
boost::asio::awaitable<void> aivvm(std::shared_ptr<Channel>, nlohmann::json);
boost::asio::awaitable<void> berlin(std::shared_ptr<Channel>, nlohmann::json);
boost::asio::awaitable<void> chatGpt4Online(std::shared_ptr<Channel>, nlohmann::json);
boost::asio::awaitable<void> chatAnywhere(std::shared_ptr<Channel>, nlohmann::json);
private:
boost::asio::awaitable<std::expected<boost::beast::ssl_stream<boost::beast::tcp_stream>, std::string>>

113
chatgpt_microservice/src/free_gpt.cpp
View File

@@ -331,13 +331,13 @@ public:
std::optional<std::string> perform() {
auto res = curl_easy_perform(m_curl);
if (res != CURLE_OK) {
auto error_info = std::format("curl_easy_perform() failed:{}", curl_easy_strerror(res));
auto error_info = std::format("[{}] -> [{}]", m_url, curl_easy_strerror(res));
return error_info;
}
int32_t response_code;
curl_easy_getinfo(m_curl, CURLINFO_RESPONSE_CODE, &response_code);
if (m_http_status_code != response_code)
return std::format("http status code is {}", response_code);
return std::format("[{}] -> [Http Status Code:{}]", m_url, response_code);
return std::nullopt;
}
auto& clearHeaders() {
@@ -393,12 +393,12 @@ std::expected<nlohmann::json, std::string> callZeus(const std::string& host, con
.setHttpHeaders(headers)
.perform();
if (ret) {
SPDLOG_ERROR("call zeus error: {}", ret.value());
SPDLOG_ERROR("{}", ret.value());
return std::unexpected(ret.value());
}
nlohmann::json rsp = nlohmann::json::parse(recv, nullptr, false);
if (rsp.is_discarded()) {
SPDLOG_ERROR("json parse error");
SPDLOG_ERROR("json parse error: {}", recv);
return std::unexpected("parse callZeus error");
}
return rsp;
@@ -582,7 +582,7 @@ boost::asio::awaitable<void> FreeGpt::deepAi(std::shared_ptr<Channel> ch, nlohma
.setHttpHeaders(headers)
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("api.deepai.org: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
}
@@ -907,7 +907,7 @@ boost::asio::awaitable<void> FreeGpt::you(std::shared_ptr<Channel> ch, nlohmann:
.setRecvBodyCallback([&](std::string) { return; })
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("get You cookie error: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
co_return;
@@ -1098,7 +1098,7 @@ boost::asio::awaitable<void> FreeGpt::chatBase(std::shared_ptr<Channel> ch, nloh
}())
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("https://www.chatbase.co/api/fe/chat: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
co_return;
@@ -1130,7 +1130,7 @@ boost::asio::awaitable<void> FreeGpt::gptGo(std::shared_ptr<Channel> ch, nlohman
})
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("action_get_token: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
co_return;
@@ -1186,7 +1186,7 @@ boost::asio::awaitable<void> FreeGpt::gptGo(std::shared_ptr<Channel> ch, nlohman
})
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("action_ai_gpt: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
}
@@ -1327,7 +1327,7 @@ boost::asio::awaitable<void> FreeGpt::freeGpt(std::shared_ptr<Channel> ch, nlohm
}())
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("https://r.aifree.site/api/generate: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
co_return;
@@ -1381,7 +1381,7 @@ boost::asio::awaitable<void> FreeGpt::gptalk(std::shared_ptr<Channel> ch, nlohma
.setHttpHeaders(headers)
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("gptalk.net/api/chatgpt/user/login: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
co_return;
@@ -1427,7 +1427,7 @@ boost::asio::awaitable<void> FreeGpt::gptalk(std::shared_ptr<Channel> ch, nlohma
.setHttpHeaders(headers)
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("gptalk.net/api/chatgpt/chatapi/text: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
co_return;
@@ -1490,7 +1490,7 @@ boost::asio::awaitable<void> FreeGpt::gptalk(std::shared_ptr<Channel> ch, nlohma
}())
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("gptalk.net/api/chatgpt/chatapi/stream: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
}
@@ -1571,7 +1571,7 @@ boost::asio::awaitable<void> FreeGpt::gptForLove(std::shared_ptr<Channel> ch, nl
.setHttpHeaders(headers)
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("call api.gptplus.one error: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
}
@@ -1746,7 +1746,7 @@ boost::asio::awaitable<void> FreeGpt::llama2(std::shared_ptr<Channel> ch, nlohma
.perform();
if (ret) {
SPDLOG_ERROR("https://www.llama2.ai/api: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
}
@@ -1921,7 +1921,7 @@ boost::asio::awaitable<void> FreeGpt::geekGpt(std::shared_ptr<Channel> ch, nlohm
.setHttpHeaders(headers)
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("https://ai.fakeopen.com/v1/chat/completions: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
}
@@ -2191,7 +2191,7 @@ boost::asio::awaitable<void> FreeGpt::fakeGpt(std::shared_ptr<Channel> ch, nlohm
.setHttpHeaders([&] -> auto& { return headers; }())
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("auth login error: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
co_return;
@@ -2234,7 +2234,7 @@ boost::asio::awaitable<void> FreeGpt::fakeGpt(std::shared_ptr<Channel> ch, nlohm
.setHttpHeaders([&] -> auto& { return headers; }())
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("/api/auth/session: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
co_return;
@@ -2332,7 +2332,7 @@ boost::asio::awaitable<void> FreeGpt::fakeGpt(std::shared_ptr<Channel> ch, nlohm
.setHttpHeaders(headers)
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("/api/conversation: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
co_return;
@@ -2383,7 +2383,7 @@ boost::asio::awaitable<void> FreeGpt::vercel(std::shared_ptr<Channel> ch, nlohma
.setHttpHeaders(headers)
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("https://sdk.vercel.ai/openai.jpeg: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
co_return;
@@ -2446,7 +2446,7 @@ boost::asio::awaitable<void> FreeGpt::vercel(std::shared_ptr<Channel> ch, nlohma
.setHttpHeaders(headers)
.perform();
if (ret.has_value()) {
SPDLOG_WARN("https://sdk.vercel.ai/api/generate: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await timeout(std::chrono::seconds(2));
continue;
}
@@ -2636,7 +2636,7 @@ boost::asio::awaitable<void> FreeGpt::berlin(std::shared_ptr<Channel> ch, nlohma
.setHttpHeaders(headers)
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("https://ai.berlin4h.top/api/login: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
}
@@ -2703,7 +2703,7 @@ boost::asio::awaitable<void> FreeGpt::berlin(std::shared_ptr<Channel> ch, nlohma
.setHttpHeaders(headers)
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("https://ai.berlin4h.top/api/chat/completions: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
}
@@ -2721,15 +2721,15 @@ boost::asio::awaitable<void> FreeGpt::chatGpt4Online(std::shared_ptr<Channel> ch
{"Accept", "*/*"},
{"content-type", "application/x-www-form-urlencoded"},
};
Curl curl;
std::string recv;
auto ret = Curl()
.setUrl("https://chatgpt4online.org")
auto ret = curl.setUrl("https://chatgpt4online.org")
.setProxy(m_cfg.http_proxy)
.setRecvHeadersCallback([](std::string) {})
.setRecvBodyCallback([&](std::string str) mutable { recv.append(str); })
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("https://chatgpt4online.org: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
}
@@ -2757,8 +2757,7 @@ boost::asio::awaitable<void> FreeGpt::chatGpt4Online(std::shared_ptr<Channel> ch
}
auto& nonce = results[0];
SPDLOG_INFO("data_nonce: {}", nonce);
ret = Curl()
.setUrl("https://chatgpt4online.org/rizq")
ret = curl.setUrl("https://chatgpt4online.org/rizq")
.setProxy(m_cfg.http_proxy)
.setRecvHeadersCallback([](std::string) { return; })
.setRecvBodyCallback([&](std::string str) mutable {
@@ -2790,7 +2789,63 @@ boost::asio::awaitable<void> FreeGpt::chatGpt4Online(std::shared_ptr<Channel> ch
.setHttpHeaders(headers)
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("https://chatgpt4online.org/rizq: [{}]", ret.value());
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
}
co_return;
}
boost::asio::awaitable<void> FreeGpt::chatAnywhere(std::shared_ptr<Channel> ch, nlohmann::json json) {
co_await boost::asio::post(boost::asio::bind_executor(*m_thread_pool_ptr, boost::asio::use_awaitable));
ScopeExit _exit{[=] { boost::asio::post(ch->get_executor(), [=] { ch->close(); }); }};
auto prompt = json.at("meta").at("content").at("parts").at(0).at("content").get<std::string>();
boost::system::error_code err{};
std::unordered_multimap<std::string, std::string> headers{
{"Accept", "application/json, text/plain, */*"},
{"content-type", "application/json"},
{"Referer", "https://chatanywhere.cn/"},
{"Origin", "https://chatanywhere.cn"},
{"Authorization", ""},
};
std::string recv;
auto ret = Curl()
.setUrl("https://chatanywhere.cn/v1/chat/gpt/")
.setProxy(m_cfg.http_proxy)
.setRecvHeadersCallback([](std::string) { return; })
.setRecvBodyCallback([&](std::string str) mutable {
boost::system::error_code err{};
boost::asio::post(ch->get_executor(), [=] { ch->try_send(err, str); });
})
.setBody([&] {
constexpr std::string_view ask_json_str = R"({
"list":[
{
"role":"user",
"content":"hello"
}
],
"id":"s1_qYuOLXjI3rEpc7WHfQ",
"title":"hello",
"prompt":"",
"temperature":0.5,
"models":"61490748",
"continuous":true
})";
nlohmann::json ask_request = nlohmann::json::parse(ask_json_str, nullptr, false);
ask_request["title"] = prompt;
ask_request["list"] = getConversationJson(json);
std::string ask_request_str = ask_request.dump();
SPDLOG_INFO("request: [{}]", ask_request_str);
return ask_request_str;
}())
.clearHeaders()
.setHttpHeaders(headers)
.perform();
if (ret.has_value()) {
SPDLOG_ERROR("{}", ret.value());
co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
ch->try_send(err, ret.value());
}

1
chatgpt_microservice/src/main.cpp
View File

@@ -357,6 +357,7 @@ int main(int, char** argv) {
ADD_METHOD("gpt-3.5-turbo-stream-aivvm", FreeGpt::aivvm);
ADD_METHOD("gpt-3.5-turbo-stream-Berlin", FreeGpt::berlin);
ADD_METHOD("gpt-4-ChatGpt4Online", FreeGpt::chatGpt4Online);
ADD_METHOD("gpt-3.5-turbo-stream-ChatAnywhere", FreeGpt::chatAnywhere);
SPDLOG_INFO("active provider:");
for (auto& [provider, _] : gpt_function)