#include <chrono>
#include <format>
#include <iostream>
#include <random>
#include <ranges>
#include <regex>
#include <tuple>
#include <vector>

#include <concurrentqueue/concurrentqueue.h>
#include <curl/curl.h>
#include <openssl/md5.h>
#include <spdlog/spdlog.h>
#include <boost/algorithm/string/replace.hpp>
#include <boost/asio/as_tuple.hpp>
#include <boost/asio/experimental/channel.hpp>
#include <plusaes/plusaes.hpp>

#include "free_gpt.h"
#include "helper.hpp"

namespace {

std::string md5(const std::string& str, bool reverse = true) {
    unsigned char hash[MD5_DIGEST_LENGTH];

    MD5_CTX md5;
    MD5_Init(&md5);
    MD5_Update(&md5, str.c_str(), str.size());
    MD5_Final(hash, &md5);

    std::stringstream ss;
    for (int i = 0; i < MD5_DIGEST_LENGTH; i++)
        ss << std::hex << std::setw(2) << std::setfill('0') << static_cast<int>(hash[i]);
    auto md5_str = ss.str();
    if (reverse)
        std::ranges::reverse(md5_str);
    return md5_str;
}

auto splitString(const std::string& input, const std::string& delimiter) {
    std::vector<std::string> fields;
    std::string::size_type start = 0;
    std::string::size_type end = input.find(delimiter);

    while (end != std::string::npos) {
        fields.emplace_back(input.substr(start, end - start));
        start = end + delimiter.size();
        end = input.find(delimiter, start);
    }

    fields.emplace_back(input.substr(start));
    return fields;
}

std::vector<std::string> findAll(const std::string& pattern, const std::string& text) {
    std::regex re(pattern);
    std::sregex_iterator it(text.begin(), text.end(), re);
    std::sregex_iterator end;
    std::vector<std::string> matches;
    while (it != end) {
        matches.push_back(it->str());
        ++it;
    }
    return matches;
}

std::string paramsToQueryStr(const std::multimap<std::string, std::string>& params) {
    auto encode_query_param = [](const std::string& value) {
        std::ostringstream escaped;
        escaped.fill('0');
        escaped << std::hex;
        for (auto c : value) {
            if (std::isalnum(static_cast<uint8_t>(c)) || c == '-' || c == '_' || c == '.' || c == '!' || c == '~' ||
                c == '*' || c == '\'' || c == '(' || c == ')') {
                escaped << c;
            } else {
                escaped << std::uppercase;
                escaped << '%' << std::setw(2) << static_cast<int>(static_cast<unsigned char>(c));
                escaped << std::nouppercase;
            }
        }
        return escaped.str();
    };
    std::string query;
    for (auto it = params.begin(); it != params.end(); ++it) {
        if (it != params.begin())
            query += "&";
        query += it->first;
        query += "=";
        query += encode_query_param(it->second);
    }
    return query;
}

enum class Status : uint8_t {
    Ok,
    Close,
    HasError,
    UnexpectedHttpCode,
};

void printHttpHeader(auto& http_packet) {
    std::stringstream ss;
    ss << http_packet.base();
    SPDLOG_INFO("\n{}", ss.str());
}

std::optional<std::smatch> parse(const std::string& url) {
    static const auto url_regex =
        std::regex(R"regex((http|https)://([^/ :]+):?([^/ ]*)((/?[^ #?]*)\x3f?([^ #]*)#?([^ ]*)))regex",
                   std::regex_constants::icase | std::regex_constants::optimize);
    auto match = std::smatch();
    if (!std::regex_match(url, match, url_regex)) {
        SPDLOG_ERROR("invalid http_proxy: {}", url);
        return std::nullopt;
    }
    return match;
}

boost::asio::awaitable<Status> sendRequestRecvChunk(
    std::string& error_info, auto& stream_, auto& req, std::size_t http_code, std::function<void(std::string)> cb,
    std::function<void(const boost::beast::http::parser<false, boost::beast::http::empty_body>&)> h_cb = nullptr) {
    boost::system::error_code err{};
    auto [ec, count] = co_await boost::beast::http::async_write(stream_, req, use_nothrow_awaitable);
    if (ec) {
        SPDLOG_ERROR("{}", ec.message());
        error_info = ec.message();
        co_return Status::HasError;
    }

    boost::beast::flat_buffer buffer;
    boost::beast::http::parser<false, boost::beast::http::empty_body> p;
    std::tie(ec, count) = co_await boost::beast::http::async_read_header(stream_, buffer, p, use_nothrow_awaitable);
    if (ec == boost::beast::http::error::end_of_stream) {
        SPDLOG_INFO("server close!!!");
        co_return Status::Close;
    }
    if (ec) {
        SPDLOG_ERROR("{}", ec.message());
        error_info = ec.message();
        co_return Status::HasError;
    }

    if (h_cb)
        h_cb(p);
    auto& headers = p.get();
    printHttpHeader(headers);

    auto result_int = headers.result_int();
    if (result_int != http_code) {
        std::string reason{headers.reason()};
        SPDLOG_ERROR("http response code: {}, reason: {}", headers.result_int(), reason);
        error_info = std::format("return unexpected http status code: {}({})", result_int, reason);
        co_return Status::UnexpectedHttpCode;
    }

    boost::beast::http::chunk_extensions ce;
    std::string chunk;

    auto header_cb = [&](std::uint64_t size, std::string_view extensions, boost::beast::error_code& ev) {
        ce.parse(extensions, ev);
        if (ev)
            return;
        if (size > (std::numeric_limits<std::size_t>::max)()) {
            ev = boost::beast::http::error::body_limit;
            return;
        }
        chunk.reserve(static_cast<std::size_t>(size));
        chunk.clear();
    };
    p.on_chunk_header(header_cb);

    auto body_cb = [&](std::uint64_t remain, std::string_view body, boost::beast::error_code& ec) {
        if (remain == body.size())
            ec = boost::beast::http::error::end_of_chunk;
        chunk.append(body.data(), body.size());

        std::string chunk_str{body};
        cb(std::move(chunk_str));
        return body.size();
    };
    p.on_chunk_body(body_cb);

    while (!p.is_done()) {
        std::tie(ec, count) = co_await boost::beast::http::async_read(stream_, buffer, p, use_nothrow_awaitable);
        if (!ec)
            continue;
        else if (ec != boost::beast::http::error::end_of_chunk) {
            co_return Status::HasError;
        } else
            ec = {};
    }
    co_return Status::Ok;
}

boost::asio::awaitable<Status> sendRequestRecvChunk(
    auto& ch, auto& stream_, auto& req, std::size_t http_code, std::function<void(std::string)> cb,
    std::function<void(const boost::beast::http::parser<false, boost::beast::http::empty_body>&)> header_cb =
        nullptr) {
    std::string error_info;
    auto ret = co_await sendRequestRecvChunk(error_info, stream_, req, http_code, std::move(cb), header_cb);
    if (!error_info.empty()) {
        boost::system::error_code err{};
        co_await ch->async_send(err, std::move(error_info), use_nothrow_awaitable);
    }
    co_return ret;
}

boost::asio::awaitable<
    std::expected<std::tuple<boost::beast::http::response<boost::beast::http::string_body>, boost::asio::ssl::context,
                             boost::beast::ssl_stream<boost::beast::tcp_stream>>,
                  std::string>>
sendRequestRecvResponse(auto& req, std::string_view host, std::string_view port, auto create_http_client) {
    int recreate_num{0};
create_client:
    boost::asio::ssl::context ctx(boost::asio::ssl::context::tls);
    ctx.set_verify_mode(boost::asio::ssl::verify_none);
    auto client = co_await create_http_client(ctx, host, port);
    if (!client.has_value()) {
        SPDLOG_ERROR("createHttpClient: {}", client.error());
        co_return std::unexpected(client.error());
    }
    auto& stream_ = client.value();

    auto [ec, count] = co_await boost::beast::http::async_write(stream_, req, use_nothrow_awaitable);
    if (ec) {
        SPDLOG_ERROR("{}", ec.message());
        co_return std::unexpected(ec.message());
    }
    boost::beast::flat_buffer b;
    boost::beast::http::response<boost::beast::http::string_body> res;
    std::tie(ec, count) = co_await boost::beast::http::async_read(stream_, b, res, use_nothrow_awaitable);
    if (ec == boost::beast::http::error::end_of_stream) {
        if (recreate_num == 0) {
            recreate_num++;
            goto create_client;
        }
    }
    if (ec) {
        SPDLOG_ERROR("{}", ec.message());
        co_return std::unexpected(ec.message());
    }
    co_return std::make_tuple(res, std::move(ctx), std::move(stream_));
}

auto getConversationJson(const nlohmann::json& json) {
    auto conversation = json.at("meta").at("content").at("conversation");
    conversation.push_back(json.at("meta").at("content").at("parts").at(0));
    return conversation;
}

template <typename T = std::chrono::milliseconds>
uint64_t getTimestamp(std::chrono::time_point<std::chrono::system_clock> now = std::chrono::system_clock::now()) {
    uint64_t timestamp = std::chrono::duration_cast<T>(now.time_since_epoch()).count();
    return timestamp;
}

class Curl final {
public:
    Curl() {
        m_curl = curl_easy_init();
        if (!m_curl)
            throw std::runtime_error("curl_easy_init() failed");
        curl_easy_setopt(m_curl, CURLOPT_MAXREDIRS, 20L);
        curl_easy_setopt(m_curl, CURLOPT_FOLLOWLOCATION, 1L);
        curl_easy_setopt(m_curl, CURLOPT_TIMEOUT, 120L);
        curl_easy_setopt(m_curl, CURLOPT_CONNECTTIMEOUT, 30L);
        curl_easy_setopt(m_curl, CURLOPT_CAINFO, nullptr);
        curl_easy_setopt(m_curl, CURLOPT_SSL_VERIFYPEER, 0L);
        curl_easy_setopt(m_curl, CURLOPT_SSL_VERIFYHOST, 0L);
    }
    ~Curl() {
        if (m_headers)
            curl_slist_free_all(m_headers);
        if (m_curl)
            curl_easy_cleanup(m_curl);
    }
    Curl(const Curl&) = delete;
    Curl& operator=(const Curl&) = delete;

    auto& setUrl(std::string_view url) {
        m_url = url;
        curl_easy_setopt(m_curl, CURLOPT_URL, m_url.data());
        return *this;
    }
    auto& setBody(std::string body) {
        if (!body.empty()) {
            m_body = std::move(body);
            curl_easy_setopt(m_curl, CURLOPT_POSTFIELDS, m_body.c_str());
        }
        return *this;
    }
    auto& setProxy(std::string_view http_proxy) {
        if (!http_proxy.empty()) {
            m_http_proxy = http_proxy;
            curl_easy_setopt(m_curl, CURLOPT_PROXY, m_http_proxy.data());
        }
        return *this;
    }
    auto& setHttpHeaders(const std::unordered_multimap<std::string, std::string>& http_headers) {
        for (auto& [k, v] : http_headers)
            m_headers_list.emplace_back(std::format("{}: {}", k, v));
        for (auto& header : m_headers_list)
            m_headers = curl_slist_append(m_headers, header.c_str());
        curl_easy_setopt(m_curl, CURLOPT_HTTPHEADER, m_headers);
        return *this;
    }
    static size_t recvCallback(void* contents, size_t size, size_t nmemb, void* userp) {
        auto cb = static_cast<std::function<void(std::string)>*>(userp);
        std::string data{(char*)contents, size * nmemb};
        (*cb)(std::move(data));
        return size * nmemb;
    }
    auto& setRecvBodyCallback(std::function<void(std::string)> cb) {
        m_recv_body_cb = std::move(cb);
        curl_easy_setopt(m_curl, CURLOPT_WRITEFUNCTION, &recvCallback);
        curl_easy_setopt(m_curl, CURLOPT_WRITEDATA, &m_recv_body_cb);
        return *this;
    }
    auto& setRecvHeadersCallback(std::function<void(std::string)> cb) {
        m_recv_headers_cb = std::move(cb);
        curl_easy_setopt(m_curl, CURLOPT_HEADERFUNCTION, &recvCallback);
        curl_easy_setopt(m_curl, CURLOPT_HEADERDATA, &m_recv_headers_cb);
        return *this;
    }
    auto& setOpt(auto option, auto value) {
        curl_easy_setopt(m_curl, option, value);
        return *this;
    }
    std::optional<std::string> perform() {
        auto res = curl_easy_perform(m_curl);
        if (res != CURLE_OK) {
            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:{}]", m_url, response_code);
        return std::nullopt;
    }
    auto& clearHeaders() {
        if (m_headers)
            curl_slist_free_all(m_headers);
        m_headers_list.clear();
        m_headers = nullptr;
        return *this;
    }
    auto& setHttpStatusCode(int32_t code) {
        m_http_status_code = code;
        return *this;
    }
    static auto parseHttpHeaders(const std::string& buffer) {
        std::regex pattern(R"(([^:\r\n]+):([^\r\n]+))");
        std::smatch matches;
        auto start = buffer.cbegin();
        auto end = buffer.cend();
        std::multimap<std::string, std::string> response_header;
        while (std::regex_search(start, end, matches, pattern)) {
            std::string field_name = matches[1].str();
            std::string field_value = matches[2].str();
            response_header.insert(std::pair{field_name, field_value});
            start = matches[0].second;
        }
        return response_header;
    }

private:
    CURL* m_curl{nullptr};
    std::string_view m_url;
    std::string m_body;
    std::string_view m_http_proxy;
    struct curl_slist* m_headers{nullptr};
    std::vector<std::string> m_headers_list;
    std::function<void(std::string)> m_recv_body_cb{[](std::string) {}};
    std::function<void(std::string)> m_recv_headers_cb{[](std::string) {}};
    int32_t m_http_status_code{200};
};

std::expected<nlohmann::json, std::string> callZeus(const std::string& host, const std::string& request_body) {
    static std::unordered_multimap<std::string, std::string> headers{
        {"Accept", "*/*"},
        {"Content-Type", "application/json"},
    };
    std::string recv;
    auto ret = Curl()
                   .setUrl(host)
                   .setRecvHeadersCallback([](std::string) { return; })
                   .setRecvBodyCallback([&](std::string str) { recv.append(str); })
                   .setBody(request_body)
                   .clearHeaders()
                   .setHttpHeaders(headers)
                   .perform();
    if (ret) {
        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: {}", recv);
        return std::unexpected("parse callZeus error");
    }
    return rsp;
}

}  // namespace

FreeGpt::FreeGpt(Config& cfg)
    : m_cfg(cfg), m_thread_pool_ptr(std::make_shared<boost::asio::thread_pool>(m_cfg.work_thread_num * 2)) {}

boost::asio::awaitable<std::expected<boost::beast::ssl_stream<boost::beast::tcp_stream>, std::string>>
FreeGpt::createHttpClient(boost::asio::ssl::context& ctx, std::string_view host, std::string_view port) {
    if (m_cfg.http_proxy.empty()) {
        boost::beast::ssl_stream<boost::beast::tcp_stream> stream_{co_await boost::asio::this_coro::executor, ctx};
        boost::system::error_code err{};
        if (!SSL_set_tlsext_host_name(stream_.native_handle(), host.data())) {
            SPDLOG_ERROR("SSL_set_tlsext_host_name");
            co_return std::unexpected(std::string("SSL_set_tlsext_host_name"));
        }
        auto resolver = boost::asio::ip::tcp::resolver(co_await boost::asio::this_coro::executor);
        auto [ec, results] = co_await resolver.async_resolve(host.data(), port.data(), use_nothrow_awaitable);
        if (ec) {
            SPDLOG_INFO("async_resolve: {}", ec.message());
            co_return std::unexpected(ec.message());
        }
        for (auto& endpoint : results) {
            std::stringstream ss;
            ss << endpoint.endpoint();
            SPDLOG_INFO("resolver_results: [{}]", ss.str());
        }
        boost::beast::get_lowest_layer(stream_).expires_after(std::chrono::seconds(30));
        if (auto [ec, _] =
                co_await boost::beast::get_lowest_layer(stream_).async_connect(results, use_nothrow_awaitable);
            ec) {
            co_return std::unexpected(ec.message());
        }
        boost::beast::get_lowest_layer(stream_).expires_never();
        std::tie(ec) = co_await stream_.async_handshake(boost::asio::ssl::stream_base::client, use_nothrow_awaitable);
        if (ec) {
            SPDLOG_INFO("async_handshake: {}", ec.message());
            co_return std::unexpected(ec.message());
        }
        co_return stream_;
    }

    std::string userinfo, proxy_host, proxy_port;
    auto is_auth_proxy = [](const std::string& str) -> bool {
        std::regex pattern("^http://[^:]+:[^@]+@[^:]+:[0-9]+$");
        return std::regex_match(str, pattern);
    };
    // http://username:password@proxy.example.com:8080
    if (is_auth_proxy(m_cfg.http_proxy)) {
        static std::regex pattern("(http|https)://([^:]+):([^@]+)@([^:]+):([0-9]+)");
        std::smatch matches;
        if (!std::regex_match(m_cfg.http_proxy, matches, pattern))
            co_return std::unexpected(std::format("invalid http_proxy: {}", m_cfg.http_proxy));
        // std::string protocol = matches[1];
        std::string username = matches[2];
        std::string password = matches[3];
        proxy_host = matches[4];
        proxy_port = matches[5];
        userinfo = std::format("{}:{}", username, password);
    } else {
        auto match_opt = parse(m_cfg.http_proxy);
        if (!match_opt.has_value())
            co_return std::unexpected(std::format("invalid http_proxy: {}", m_cfg.http_proxy));
        auto& match = match_opt.value();
        // auto& protocol = match[1];
        // auto& target = match[4];
        proxy_host = match[2];
        proxy_port = match[3];
    }
    SPDLOG_INFO("CONNECT TO HTTP_PROXY [{}:{}]", proxy_host, proxy_port);

    auto resolver = boost::asio::ip::tcp::resolver(co_await boost::asio::this_coro::executor);
    auto [ec, results] = co_await resolver.async_resolve(proxy_host, proxy_port, use_nothrow_awaitable);
    if (ec) {
        SPDLOG_INFO("async_resolve: {}", ec.message());
        co_return std::unexpected(ec.message());
    }
    boost::asio::ip::tcp::socket socket_{co_await boost::asio::this_coro::executor};
    if (auto [ec, count] = co_await boost::asio::async_connect(socket_, results, use_nothrow_awaitable); ec) {
        SPDLOG_INFO("async_connect: {}", ec.message());
        co_return std::unexpected(ec.message());
    }

    boost::beast::ssl_stream<boost::beast::tcp_stream> stream_{std::move(socket_), ctx};
    int http_version = 11;
    boost::beast::http::request<boost::beast::http::string_body> connect_req{
        boost::beast::http::verb::connect, std::format("{}:{}", host, port), http_version};
    connect_req.set(boost::beast::http::field::host, host);

    if (!userinfo.empty()) {
        std::string result(boost::beast::detail::base64::encoded_size(userinfo.size()), 0);
        auto len =
            boost::beast::detail::base64::encode(static_cast<char*>(result.data()), userinfo.c_str(), userinfo.size());
        result.resize(len);
        result = "Basic " + result;
        connect_req.set(boost::beast::http::field::proxy_authorization, result);
    }

    std::size_t count;
    std::tie(ec, count) = co_await boost::beast::http::async_write(boost::beast::get_lowest_layer(stream_),
                                                                   connect_req, use_nothrow_awaitable);
    if (ec) {
        SPDLOG_ERROR("{}", ec.message());
        co_return std::unexpected(ec.message());
    }
    boost::beast::http::response<boost::beast::http::empty_body> res;
    boost::beast::http::parser<false, boost::beast::http::empty_body> http_parser(res);
    http_parser.skip(true);

    boost::beast::flat_buffer buffer;
    std::tie(ec, count) = co_await boost::beast::http::async_read(boost::beast::get_lowest_layer(stream_), buffer,
                                                                  http_parser, use_nothrow_awaitable);
    if (boost::beast::http::status::ok != res.result()) {
        SPDLOG_ERROR("Proxy response failed : {}", res.result_int());
        co_return std::unexpected(ec.message());
    }
    if (!SSL_set_tlsext_host_name(stream_.native_handle(), host.data())) {
        SPDLOG_ERROR("SSL_set_tlsext_host_name");
        co_return std::unexpected(std::string("SSL_set_tlsext_host_name"));
    }
    std::tie(ec) = co_await stream_.async_handshake(boost::asio::ssl::stream_base::client, use_nothrow_awaitable);
    if (ec) {
        SPDLOG_INFO("async_handshake: {}", ec.message());
        co_return std::unexpected(ec.message());
    }
    co_return stream_;
}

boost::asio::awaitable<void> FreeGpt::deepAi(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(); }); }};

    boost::system::error_code err{};
    auto prompt = json.at("meta").at("content").at("parts").at(0).at("content").get<std::string>();

    std::string user_agent{
        R"(Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/110.0.0.0 Safari/537.36)"};

    std::random_device rd;
    std::mt19937 mt(rd());
    std::uniform_int_distribution<uint64_t> dist(0, 100000000);
    uint64_t part1{dist(mt)};
    auto part2 = md5(user_agent + md5(user_agent + md5(std::format("{}{}x", user_agent, part1))));
    auto api_key = std::format("tryit-{}-{}", part1, part2);

    constexpr char CRLF[] = "\r\n";
    static std::string MULTI_PART_BOUNDARY = "9bc627aea4f77e150e6057f78036e73f";

    auto content_type_str = std::format("multipart/form-data; boundary={}", MULTI_PART_BOUNDARY);
    SPDLOG_INFO("content_type_str: {}", content_type_str);
    auto api_key_str = std::format("api-key: {}", api_key);

    std::unordered_multimap<std::string, std::string> headers{
        {"Content-Type", content_type_str},
        {"api-key", api_key},
    };
    auto ret = Curl()
                   .setUrl("https://api.deepai.org/hacking_is_a_crime")
                   .setProxy(m_cfg.http_proxy)
                   .setRecvHeadersCallback([&](std::string) {})
                   .setRecvBodyCallback([&](std::string str) {
                       boost::asio::post(ch->get_executor(), [=] { ch->try_send(err, str); });
                       return;
                   })
                   .setBody([&] {
                       nlohmann::json request_json{{{"role", "user"}, {"content", std::move(prompt)}}};
                       std::ostringstream payload;
                       payload << "--" << MULTI_PART_BOUNDARY << CRLF
                               << R"(Content-Disposition: form-data; name="chat_style")" << CRLF << CRLF << "chat"
                               << CRLF << "--" << MULTI_PART_BOUNDARY << CRLF
                               << R"(Content-Disposition: form-data; name="chatHistory")" << CRLF << CRLF
                               << request_json.dump() << CRLF << "--" << MULTI_PART_BOUNDARY << "--" << CRLF;
                       SPDLOG_INFO("{}", payload.str());
                       auto str = payload.str();
                       return 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());
    }
    co_return;
}

boost::asio::awaitable<void> FreeGpt::openAi(std::shared_ptr<Channel> ch, nlohmann::json json) {
    boost::system::error_code err{};
    ScopeExit auto_exit{[&] { ch->close(); }};

    constexpr std::string_view host = "api.openai.com";
    constexpr std::string_view port = "443";

    constexpr std::string_view user_agent{
        R"(Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/114.0.0.0 Safari/537.36)"};

    boost::asio::ssl::context ctx(boost::asio::ssl::context::tls);
    ctx.set_verify_mode(boost::asio::ssl::verify_none);

    auto client = co_await createHttpClient(ctx, host, port);
    if (!client.has_value()) {
        SPDLOG_ERROR("createHttpClient: {}", client.error());
        co_await ch->async_send(err, client.error(), use_nothrow_awaitable);
        co_return;
    }
    auto& stream_ = client.value();

    boost::beast::http::request<boost::beast::http::string_body> req{boost::beast::http::verb::post,
                                                                     "/v1/chat/completions", 11};
    req.set(boost::beast::http::field::host, host);
    req.set(boost::beast::http::field::user_agent, user_agent);
    req.set(boost::beast::http::field::content_type, "application/json");
    req.set(boost::beast::http::field::authorization, std::format("Bearer {}", m_cfg.api_key));

    constexpr std::string_view json_str = R"({
        "messages": [
            {
                "role": "user",
                "content": "hello"
            }
        ],
        "stream": true,
        "model": "gpt-3.5-turbo"
    })";
    nlohmann::json request = nlohmann::json::parse(json_str, nullptr, false);

    request["messages"] = getConversationJson(json);
    SPDLOG_INFO("{}", request.dump(2));

    req.body() = request.dump();
    req.prepare_payload();

    std::string recv;
    co_await sendRequestRecvChunk(ch, stream_, req, 200, [&ch, &recv](std::string chunk_str) {
        recv.append(chunk_str);
        while (true) {
            auto position = recv.find("\n");
            if (position == std::string::npos)
                break;
            auto msg = recv.substr(0, position + 1);
            recv.erase(0, position + 1);
            msg.pop_back();
            if (msg.empty() || !msg.contains("content"))
                continue;
            auto fields = splitString(msg, "data: ");
            boost::system::error_code err{};
            nlohmann::json line_json = nlohmann::json::parse(fields.back(), nullptr, false);
            if (line_json.is_discarded()) {
                SPDLOG_ERROR("json parse error: [{}]", fields.back());
                ch->try_send(err, std::format("json parse error: [{}]", fields.back()));
                continue;
            }
            auto str = line_json["choices"][0]["delta"]["content"].get<std::string>();
            if (!str.empty())
                ch->try_send(err, str);
        }
    });
    co_return;
}

boost::asio::awaitable<void> FreeGpt::yqcloud(std::shared_ptr<Channel> ch, nlohmann::json json) {
    boost::system::error_code err{};
    ScopeExit auto_exit{[&] { ch->close(); }};

    auto prompt = json.at("meta").at("content").at("parts").at(0).at("content").get<std::string>();

    constexpr std::string_view host = "api.aichatos.cloud";
    constexpr std::string_view port = "443";

    constexpr std::string_view user_agent{
        R"(Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:109.0) Gecko/20100101 Firefox/115.0)"};

    boost::beast::http::request<boost::beast::http::string_body> req{boost::beast::http::verb::post,
                                                                     "/api/generateStream", 11};
    req.set("authority", "p5.v50.ltd");
    req.set(boost::beast::http::field::host, host);
    req.set(boost::beast::http::field::user_agent, user_agent);
    req.set("accept", "application/json, text/plain, */*");
    req.set("Content-Type", "application/json");
    req.set("origin", "https://chat9.yqcloud.top");

    constexpr std::string_view json_str = R"({
        "prompt":"hello",
        "network":true,
        "system":"",
        "withoutContext":false,
        "stream":false
    })";

    nlohmann::json request = nlohmann::json::parse(json_str, nullptr, false);
    request["prompt"] = std::move(prompt);

    req.body() = request.dump();
    req.prepare_payload();

    int recreate_num{0};
create_client:
    boost::asio::ssl::context ctx(boost::asio::ssl::context::tls);
    ctx.set_verify_mode(boost::asio::ssl::verify_none);
    auto client = co_await createHttpClient(ctx, host, port);
    if (!client.has_value()) {
        SPDLOG_ERROR("createHttpClient: {}", client.error());
        co_await ch->async_send(err, client.error(), use_nothrow_awaitable);
        co_return;
    }
    auto& stream_ = client.value();

    auto ret = co_await sendRequestRecvChunk(ch, stream_, req, 200, [&ch](std::string str) {
        boost::system::error_code err{};
        ch->try_send(err, std::move(str));
    });
    if (ret == Status::Close && recreate_num == 0) {
        recreate_num++;
        goto create_client;
    }
    co_return;
}

boost::asio::awaitable<void> FreeGpt::huggingChat(std::shared_ptr<Channel> ch, nlohmann::json json) {
    boost::system::error_code err{};
    ScopeExit auto_exit{[&] { ch->close(); }};

    auto prompt = json.at("meta").at("content").at("parts").at(0).at("content").get<std::string>();

    constexpr std::string_view host = "huggingface.co";
    constexpr std::string_view port = "443";

    constexpr std::string_view user_agent{
        R"(Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:109.0) Gecko/20100101 Firefox/115.0)"};

    boost::beast::http::request<boost::beast::http::empty_body> req_init_cookie{boost::beast::http::verb::get,
                                                                                "/chat/", 11};
    req_init_cookie.set(boost::beast::http::field::host, host);
    req_init_cookie.set(boost::beast::http::field::user_agent, user_agent);

    auto ret = co_await sendRequestRecvResponse(req_init_cookie, host, port,
                                                std::bind_front(&FreeGpt::createHttpClient, *this));
    if (!ret.has_value()) {
        co_await ch->async_send(err, ret.error(), use_nothrow_awaitable);
        co_return;
    }
    auto& [response, ctx, stream_] = ret.value();
    if (boost::beast::http::status::ok != response.result()) {
        SPDLOG_ERROR("http status code: {}", response.result_int());
        co_await ch->async_send(err, response.reason(), use_nothrow_awaitable);
        co_return;
    }
    auto fields = splitString(response["Set-Cookie"], " ");
    if (fields.empty()) {
        std::stringstream ss;
        ss << response.base();
        SPDLOG_ERROR("get cookie error: {}", ss.str());
        co_await ch->async_send(err, "can't get cookie", use_nothrow_awaitable);
        co_return;
    }
    fields[0].pop_back();
    std::string cookie{std::move(fields[0])};
    SPDLOG_INFO("cookie: {}", cookie);

    boost::beast::http::request<boost::beast::http::string_body> req_init_conversation{boost::beast::http::verb::post,
                                                                                       "/chat/conversation", 11};
    req_init_conversation.set("Cookie", cookie);
    req_init_conversation.set(boost::beast::http::field::host, host);
    req_init_conversation.set(boost::beast::http::field::user_agent, user_agent);
    req_init_conversation.set("Accept", "*/*");
    req_init_conversation.set("Content-Type", "application/json");
    req_init_conversation.body() = R"({"model": "meta-llama/Llama-2-70b-chat-hf"})";
    req_init_conversation.prepare_payload();

    auto [ec, count] = co_await boost::beast::http::async_write(stream_, req_init_conversation, use_nothrow_awaitable);
    if (ec) {
        SPDLOG_ERROR("{}", ec.message());
        co_await ch->async_send(err, ec.message(), use_nothrow_awaitable);
        co_return;
    }
    boost::beast::flat_buffer b;
    boost::beast::http::response<boost::beast::http::string_body> res;
    std::tie(ec, count) = co_await boost::beast::http::async_read(stream_, b, res, use_nothrow_awaitable);
    if (ec) {
        SPDLOG_ERROR("{}", ec.message());
        co_await ch->async_send(err, ec.message(), use_nothrow_awaitable);
        co_return;
    }
    if (res.result_int() != 200) {
        std::string reason{res.reason()};
        SPDLOG_ERROR("reason: {}", reason);
        co_await ch->async_send(err,
                                std::format("return unexpected http status code: {}({})", res.result_int(), reason),
                                use_nothrow_awaitable);
        co_return;
    }
    nlohmann::json rsp_json = nlohmann::json::parse(res.body(), nullptr, false);
    if (rsp_json.is_discarded()) {
        SPDLOG_ERROR("json parse error: [{}]", fields.back());
        ch->try_send(err, std::format("json parse error: [{}]", fields.back()));
        co_return;
    }
    if (!rsp_json.contains("conversationId")) {
        SPDLOG_ERROR("not contains conversationId: {}", res.body());
        co_await ch->async_send(err, res.body(), use_nothrow_awaitable);
        co_return;
    }
    auto conversation_id = rsp_json["conversationId"].get<std::string>();
    SPDLOG_INFO("conversation_id: [{}]", conversation_id);

    constexpr std::string_view json_str = R"({
        "inputs":"hello",
        "parameters":{
            "temperature":0.2,
            "truncate":1000,
            "max_new_tokens":1024,
            "stop":[
                "</s>"
            ],
            "top_p":0.95,
            "repetition_penalty":1.2,
            "top_k":50,
            "return_full_text":false
        },
        "stream":true,
        "options":{
            "id":"9e9b8bc4-6604-40c6-994e-8eb78fa32e37",
            "response_id":"04ce2602-3bea-45e8-8efc-cef00680376a",
            "is_retry":false,
            "use_cache":false,
            "web_search_id":""
        }
    })";
    nlohmann::json request = nlohmann::json::parse(json_str, nullptr, false);
    request["inputs"] = prompt;
    request["options"]["response_id"] = createUuidString();
    request["options"]["id"] = createUuidString();

    boost::beast::http::request<boost::beast::http::string_body> req{
        boost::beast::http::verb::post, std::format("/chat/conversation/{}", conversation_id), 11};
    req.set("Cookie", cookie);
    req.set(boost::beast::http::field::host, host);
    req.set(boost::beast::http::field::user_agent, user_agent);
    req.set("Accept", "*/*");
    req.set("Content-Type", "application/json");
    req.body() = request.dump();
    req.prepare_payload();

    std::string recv;
    co_await sendRequestRecvChunk(ch, stream_, req, 200, [&ch, &recv](std::string chunk_str) {
        recv.append(chunk_str);
        while (true) {
            auto position = recv.find("\n");
            if (position == std::string::npos)
                break;
            auto msg = recv.substr(0, position + 1);
            recv.erase(0, position + 1);
            msg.pop_back();
            if (msg.empty())
                continue;
            boost::system::error_code err{};
            nlohmann::json line_json = nlohmann::json::parse(msg, nullptr, false);
            if (line_json.is_discarded()) {
                SPDLOG_ERROR("json parse error: [{}]", msg);
                ch->try_send(err, std::format("json parse error: [{}]", msg));
                continue;
            }
            if (!line_json.contains("type")) {
                SPDLOG_ERROR("invalid json format: [{}]", line_json.dump());
                continue;
            }
            auto type = line_json["type"].get<std::string>();
            if (type == "stream") {
                if (auto str = line_json["token"].get<std::string>(); !str.empty())
                    ch->try_send(err, str);
            } else if (type == "finalAnswer") {
                ch->close();
            }
        }
        return;
    });
    co_return;
}

boost::asio::awaitable<void> FreeGpt::you(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));
    boost::system::error_code err{};
    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>();

    using Tuple = std::tuple<std::chrono::time_point<std::chrono::system_clock>, std::string>;
    static moodycamel::ConcurrentQueue<Tuple> cookie_queue;
    Tuple item;
    bool found{false};
    if (cookie_queue.try_dequeue(item)) {
        auto& [time_point, cookie] = item;
        if (std::chrono::system_clock::now() - time_point < std::chrono::minutes(120))
            found = true;
    }
    if (!found) {
        std::string header_str;
        auto ret = Curl()
                       .setUrl("https://you.com")
                       .setProxy(m_cfg.http_proxy)
                       .setRecvHeadersCallback([&](std::string str) { header_str.append(str); })
                       .setRecvBodyCallback([&](std::string) { return; })
                       .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());
            co_return;
        }
        auto response_header = Curl::parseHttpHeaders(header_str);
        std::string cookie;
        auto range = response_header.equal_range("set-cookie");
        for (auto it = range.first; it != range.second; ++it) {
            if (!(it->second.contains("__cf_bm=")))
                continue;
            auto view = it->second | std::views::drop_while(isspace) | std::views::reverse |
                        std::views::drop_while(isspace) | std::views::reverse;
            auto fields = splitString(std::string{view.begin(), view.end()}, " ");
            if (fields.size() < 1) {
                co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
                ch->try_send(err, "can't get cookie");
                co_return;
            }
            cookie = std::move(fields[0]);
            break;
        }
        if (cookie.empty()) {
            co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
            ch->try_send(err, "cookie is empty");
            co_return;
        }
        item = std::make_tuple(std::chrono::system_clock::now(), std::move(cookie));
    }
    SPDLOG_INFO("cookie: {}", std::get<1>(item));
    ScopeExit auto_free([&] mutable {
        auto& [time_point, cookie] = item;
        if (std::chrono::system_clock::now() - time_point < std::chrono::minutes(120))
            cookie_queue.enqueue(std::move(item));
    });
    auto cookie_str = std::format("uuid_guest={}; safesearch_guest=Off; {}", createUuidString(), std::get<1>(item));

    std::multimap<std::string, std::string> params{
        {"q", prompt},
        {"page", "1"},
        {"count", "10"},
        {"safeSearch", "Off"},
        {"onShoppingPage", "False"},
        {"mkt", ""},
        {"responseFilter", "WebPages,Translations,TimeZone,Computation,RelatedSearches"},
        {"domain", "youchat"},
        {"queryTraceId", createUuidString()},
    };
    auto request_url = std::format("https://you.com/api/streamingSearch?{}", paramsToQueryStr(params));
    auto ret = Curl()
                   .setUrl(request_url)
                   .setProxy(m_cfg.http_proxy)
                   .setOpt(CURLOPT_COOKIE, std::get<1>(item).c_str())
                   .setRecvHeadersCallback([&](std::string) { return; })
                   .setRecvBodyCallback([&](std::string data) {
                       boost::system::error_code err{};
                       if (data.starts_with(R"(event: youChatToken)")) {
                           static std::string to_erase{"event: youChatToken\ndata: "};
                           size_t pos = data.find(to_erase);
                           if (pos != std::string::npos)
                               data.erase(pos, to_erase.length());
                           nlohmann::json line_json = nlohmann::json::parse(data, nullptr, false);
                           if (line_json.is_discarded()) {
                               SPDLOG_ERROR("json parse error: [{}]", data);
                               boost::asio::post(ch->get_executor(), [=] {
                                   ch->try_send(err, std::format("json parse error: [{}]", data));
                               });
                               return;
                           }
                           auto str = line_json["youChatToken"].get<std::string>();
                           boost::asio::post(ch->get_executor(), [=] { ch->try_send(err, str); });
                       }
                       return;
                   })
                   .clearHeaders()
                   .setHttpHeaders([&] -> auto {
                       std::unordered_multimap<std::string, std::string> headers{
                           {"referer", "https://you.com/search?q=gpt4&tbm=youchat"},
                           {"Accept", "text/event-stream"},
                           {"cookie", cookie_str},
                       };
                       return headers;
                   }())
                   .perform();
    if (ret) {
        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::binjie(std::shared_ptr<Channel> ch, nlohmann::json json) {
    boost::system::error_code err{};
    ScopeExit auto_exit{[&] { ch->close(); }};

    auto prompt = json.at("meta").at("content").at("parts").at(0).at("content").get<std::string>();

    constexpr std::string_view host = "api.binjie.fun";
    constexpr std::string_view port = "443";

    boost::beast::http::request<boost::beast::http::string_body> req{boost::beast::http::verb::post,
                                                                     "/api/generateStream", 11};
    req.set(boost::beast::http::field::host, host);
    req.set(
        boost::beast::http::field::user_agent,
        R"(Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/114.0.0.0 Safari/537.36)");
    req.set("Accept", "application/json, text/plain, */*");
    req.set("accept-language", "id-ID,id;q=0.9,en-US;q=0.8,en;q=0.7");
    req.set(boost::beast::http::field::content_type, "application/json");
    req.set("origin", "https://chat.jinshutuan.com");

    constexpr std::string_view json_str = R"({
        "prompt":"user: hello\nassistant:",
        "system": "Always talk in English.",
        "withoutContext":true,
        "stream":true
    })";
    nlohmann::json request = nlohmann::json::parse(json_str, nullptr, false);
    request["prompt"] = prompt;

    SPDLOG_INFO("{}", request.dump(2));

    req.body() = request.dump();
    req.prepare_payload();

    boost::asio::ssl::context ctx(boost::asio::ssl::context::tls);
    ctx.set_verify_mode(boost::asio::ssl::verify_none);
    auto client = co_await createHttpClient(ctx, host, port);
    if (!client.has_value()) {
        SPDLOG_ERROR("createHttpClient: {}", client.error());
        co_await ch->async_send(err, client.error(), use_nothrow_awaitable);
        co_return;
    }

    co_await sendRequestRecvChunk(ch, client.value(), req, 200, [&ch](std::string str) {
        boost::system::error_code err{};
        ch->try_send(err, std::move(str));
    });
    co_return;
}

boost::asio::awaitable<void> FreeGpt::gptGo(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(); }); }};

    boost::system::error_code err{};
    auto prompt = json.at("meta").at("content").at("parts").at(0).at("content").get<std::string>();

    std::multimap<std::string, std::string> params{
        {"q", prompt},
        {"hlgpt", "default"},
        {"hl", "en"},
    };
    auto get_token_url = std::format("https://gptgo.ai/action_get_token.php?{}", paramsToQueryStr(params));

    std::string recv;
    Curl curl;
    auto ret = curl.setUrl(get_token_url)
                   .setProxy(m_cfg.http_proxy)
                   .setRecvBodyCallback([&](std::string str) {
                       recv.append(str);
                       return;
                   })
                   .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());
        co_return;
    }
    SPDLOG_INFO("recv: [{}]", recv);
    nlohmann::json line_json = nlohmann::json::parse(recv, nullptr, false);
    if (line_json.is_discarded()) {
        SPDLOG_ERROR("json parse error: [{}]", recv);
        co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
        ch->try_send(err, std::format("json parse error:{}", recv));
        co_return;
    }
    auto status = line_json["status"].get<bool>();
    if (!status) {
        SPDLOG_ERROR("status is false: [{}]", recv);
        co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
        ch->try_send(err, recv);
        co_return;
    }
    auto token = line_json["token"].get<std::string>();
    SPDLOG_INFO("token: [{}]", token);

    recv.clear();
    auto url = std::format("https://gptgo.ai/action_ai_gpt.php?token={}", token);
    ret = curl.setUrl(url)
              .setProxy(m_cfg.http_proxy)
              .setRecvBodyCallback([&](std::string str) {
                  recv.append(str);
                  while (true) {
                      auto position = recv.find("\n");
                      if (position == std::string::npos)
                          break;
                      auto msg = recv.substr(0, position + 1);
                      recv.erase(0, position + 1);
                      msg.pop_back();
                      if (msg.empty() || !msg.contains("content"))
                          continue;
                      auto fields = splitString(msg, "data: ");
                      boost::system::error_code err{};
                      nlohmann::json line_json = nlohmann::json::parse(fields.back(), nullptr, false);
                      if (line_json.is_discarded()) {
                          SPDLOG_ERROR("json parse error: [{}]", fields.back());
                          boost::asio::post(ch->get_executor(), [=] {
                              ch->try_send(err, std::format("json parse error: [{}]", fields.back()));
                          });
                          continue;
                      }
                      auto str = line_json["choices"][0]["delta"]["content"].get<std::string>();
                      if (!str.empty() && str != "[DONE]")
                          boost::asio::post(ch->get_executor(), [=] { ch->try_send(err, str); });
                  }
                  return;
              })
              .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());
    }
    co_return;
}

boost::asio::awaitable<void> FreeGpt::chatForAi(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));

    boost::system::error_code err{};
    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>();

    auto generate_signature = [](uint64_t timestamp, const std::string& message, const std::string& id) {
        std::string s = std::to_string(timestamp) + ":" + id + ":" + message + ":7YN8z6d6";
        unsigned char hash[SHA256_DIGEST_LENGTH];
        SHA256_CTX sha256;
        if (!SHA256_Init(&sha256))
            throw std::runtime_error("SHA-256 initialization failed");
        if (!SHA256_Update(&sha256, s.c_str(), s.length()))
            throw std::runtime_error("SHA-256 update failed");
        if (!SHA256_Final(hash, &sha256))
            throw std::runtime_error("SHA-256 finalization failed");
        std::stringstream ss;
        for (int i = 0; i < SHA256_DIGEST_LENGTH; i++)
            ss << std::hex << std::setw(2) << std::setfill('0') << static_cast<int>(hash[i]);
        return ss.str();
    };
    static std::unordered_multimap<std::string, std::string> headers{
        {"Content-Type", "application/json"},
        {"Origin", "https://chatforai.store"},
        {"Referer", "https://chatforai.store/"},
    };
    auto ret = Curl()
                   .setUrl("https://chatforai.store/api/handle/provider-openai")
                   .setProxy(m_cfg.http_proxy)
                   .setRecvHeadersCallback([](std::string) { return; })
                   .setRecvBodyCallback([&](std::string str) {
                       boost::asio::post(ch->get_executor(), [=, str = std::move(str)] { ch->try_send(err, str); });
                       return;
                   })
                   .setBody([&] {
                       uint64_t timestamp = getTimestamp();
                       constexpr std::string_view request_str{R"({
                            "conversationId": "id_1696984301982",
                            "conversationType": "chat_continuous",
                            "botId": "chat_continuous",
                            "globalSettings": {
                                "baseUrl": "https://api.openai.com",
                                "model": "gpt-3.5-turbo",
                                "messageHistorySize": 5,
                                "temperature": 0.7,
                                "top_p": 1
                            },
                            "botSettings": {},
                            "prompt": "hello",
                            "messages": [{
                                "role": "user",
                                "content": "hello"
                            }],
                            "sign": "15d8e701706743ffa74f8b96c97bd1f79354c7da4a97438c81c6bb259004cd77",
                            "timestamp": 1696984302017
                        })"};
                       nlohmann::json request = nlohmann::json::parse(request_str, nullptr, false);
                       auto conversation_id = std::format("id_{}", timestamp - 35);
                       request["conversationId"] = conversation_id;
                       request["timestamp"] = timestamp;
                       request["sign"] = generate_signature(timestamp, prompt, conversation_id);
                       request["messages"] = getConversationJson(json);
                       request["prompt"] = prompt;
                       auto str = request.dump();
                       SPDLOG_INFO("request : [{}]", str);
                       return str;
                   }())
                   .setHttpHeaders(headers)
                   .perform();
    if (ret.has_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::gptalk(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(); }); }};

    boost::system::error_code err{};
    auto prompt = json.at("meta").at("content").at("parts").at(0).at("content").get<std::string>();

    auto generate_token_hex = [](int32_t length) {
        std::random_device rd;
        std::stringstream ss;
        std::mt19937 gen(rd());
        std::uniform_int_distribution<> dis(0, 15);
        for (int i = 0; i < length; ++i)
            ss << std::hex << dis(gen);
        std::string token = ss.str();
        token = std::string(length * 2 - token.length(), '0') + token;
        return token;
    };

    uint64_t timestamp = getTimestamp<std::chrono::seconds>();
    std::string recv;
    Curl curl;
    std::unordered_multimap<std::string, std::string> headers{
        {"Accept", "*/*"},           {"Content-Type", "application/json"},
        {"authority", "gptalk.net"}, {"origin", "https://gptalk.net"},
        {"x-auth-appid", "2229"},    {"x-auth-openid", ""},
        {"x-auth-platform", ""},     {"x-auth-timestamp", std::to_string(timestamp)},
    };
    auto ret = curl.setUrl("https://gptalk.net/api/chatgpt/user/login")
                   .setProxy(m_cfg.http_proxy)
                   .setRecvHeadersCallback([&](std::string) {})
                   .setRecvBodyCallback([&](std::string str) {
                       recv.append(str);
                       return;
                   })
                   .setBody([&] {
                       nlohmann::json login_json;
                       login_json["fingerprint"] = generate_token_hex(16);
                       login_json["platform"] = "fingerprint";
                       std::string request_str = login_json.dump();
                       return 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());
        co_return;
    }
    SPDLOG_INFO("login rsp: [{}]", recv);
    nlohmann::json auth_rsp = nlohmann::json::parse(recv, nullptr, false);
    auto auth_token = auth_rsp["data"]["token"].get<std::string>();
    SPDLOG_INFO("token: [{}]", auth_token);

    auto auth_str = std::format("Bearer {}", auth_token);
    headers.emplace("authorization", auth_str);

    recv.clear();
    ret = curl.setUrl("https://gptalk.net/api/chatgpt/chatapi/text")
              .setProxy(m_cfg.http_proxy)
              .setRecvHeadersCallback([&](std::string) {})
              .setRecvBodyCallback([&](std::string str) {
                  recv.append(str);
                  return;
              })
              .setBody([&] {
                  constexpr std::string_view json_str = R"({
                    "content":"hello",
                    "accept":"stream",
                    "from":1,
                    "model":"gpt-3.5-turbo",
                    "is_mobile":0,
                    "user_agent":"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/110.0.0.0 Safari/537.36",
                    "is_open_ctx":0,
                    "prompt":"",
                    "roid":111,
                    "temperature":0,
                    "ctx_msg_count":3,
                    "created_at":1696655321
                })";
                  nlohmann::json request = nlohmann::json::parse(json_str, nullptr, false);
                  request["created_at"] = timestamp;
                  request["content"] = prompt;
                  auto request_str = request.dump();
                  return 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());
        co_return;
    }
    SPDLOG_INFO("input.recv: [{}]", recv);
    nlohmann::json get_text_rsp = nlohmann::json::parse(recv, nullptr, false);
    auto token = get_text_rsp["data"]["token"].get<std::string>();
    SPDLOG_INFO("token: [{}]", token);
    recv.clear();

    std::string last_message;
    auto url = std::format("https://gptalk.net/api/chatgpt/chatapi/stream?token={}", token);
    ret = curl.setUrl(url)
              .setProxy(m_cfg.http_proxy)
              .setRecvHeadersCallback([&](std::string) {})
              .setOpt(CURLOPT_HTTPGET, 1L)
              .setRecvBodyCallback([&](std::string str) {
                  recv.append(str);
                  while (true) {
                      auto position = recv.find("\n");
                      if (position == std::string::npos)
                          break;
                      auto msg = recv.substr(0, position + 1);
                      recv.erase(0, position + 1);
                      msg.pop_back();
                      if (msg.empty() || !msg.contains("content") || !msg.starts_with("data: "))
                          continue;
                      msg.erase(0, 6);
                      boost::system::error_code err{};
                      nlohmann::json line_json = nlohmann::json::parse(msg, nullptr, false);
                      if (line_json.is_discarded()) {
                          SPDLOG_ERROR("json parse error: [{}]", msg);
                          boost::asio::post(ch->get_executor(),
                                            [=] { ch->try_send(err, std::format("json parse error: [{}]", msg)); });
                          continue;
                      }
                      auto content = line_json["content"].get<std::string>();
                      if (last_message.empty())
                          last_message = content;
                      else {
                          auto count = last_message.size();
                          last_message = content;
                          content.erase(0, count);
                      }
                      if (content.empty())
                          continue;
                      boost::asio::post(ch->get_executor(),
                                        [=, content = std::move(content)] { ch->try_send(err, content); });
                  }
              })
              .clearHeaders()
              .setHttpHeaders([] -> auto& {
                  static std::unordered_multimap<std::string, std::string> headers{
                      {"Accept", "*/*"},           {"Content-Type", "application/json"},
                      {"authority", "gptalk.net"}, {"origin", "https://gptalk.net"},
                      {"x-auth-appid", "2229"},    {"x-auth-openid", ""},
                      {"x-auth-platform", ""},
                  };
                  return 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());
    }
    co_return;
}

boost::asio::awaitable<void> FreeGpt::gptForLove(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(); }); }};

    boost::system::error_code err{};
    auto prompt = json.at("meta").at("content").at("parts").at(0).at("content").get<std::string>();

    auto secret_rsp = callZeus(std::format("{}/gptforlove", m_cfg.zeus), "{}");
    if (!secret_rsp.has_value()) {
        SPDLOG_ERROR("callZeus error: {}", secret_rsp.error());
        co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
        ch->try_send(err, secret_rsp.error());
        co_return;
    }
    SPDLOG_INFO("zeus: [{}]", secret_rsp.value().dump());
    static std::unordered_multimap<std::string, std::string> headers{
        {"Content-Type", "application/json"},
        {"referer", "https://ai18.gptforlove.com/"},
        {"origin", "https://ai18.gptforlove.com"},
        {"authority", "api.gptplus.one"},
    };
    std::string recv;
    auto ret = Curl()
                   .setUrl("https://api.gptplus.one/chat-process")
                   .setProxy(m_cfg.http_proxy)
                   .setRecvBodyCallback([&](std::string str) {
                       recv.append(str);
                       while (true) {
                           auto position = recv.find("\n");
                           if (position == std::string::npos)
                               break;
                           auto msg = recv.substr(0, position + 1);
                           recv.erase(0, position + 1);
                           msg.pop_back();
                           if (msg.contains("10分钟内提问超过了5次")) {
                               boost::asio::post(ch->get_executor(), [=] { ch->try_send(err, msg); });
                               return;
                           }
                           if (msg.empty() || !msg.contains("content"))
                               continue;
                           boost::system::error_code err{};
                           nlohmann::json line_json = nlohmann::json::parse(msg, nullptr, false);
                           if (line_json.is_discarded()) {
                               SPDLOG_ERROR("json parse error: [{}]", msg);
                               boost::asio::post(ch->get_executor(), [=] {
                                   ch->try_send(err, std::format("json parse error: [{}]", msg));
                               });
                               continue;
                           }
                           auto str = line_json["detail"]["choices"][0]["delta"]["content"].get<std::string>();
                           if (!str.empty())
                               boost::asio::post(ch->get_executor(), [=] { ch->try_send(err, str); });
                       }
                   })
                   .setBody([&] {
                       constexpr std::string_view request_str{R"({
                            "prompt": "hello",
                            "options": {},
                            "systemMessage": "You are ChatGPT, the version is GPT3.5, a large language model trained by OpenAI. Follow the user's instructions carefully.",
                            "temperature": 0.8,
                            "top_p": 1,
                            "secret": "U2FsdGVkX18vdtlMj0nP1LoUzEqJTP0is+Q2+bQJNMk=",
                            "stream": false
                        })"};
                       nlohmann::json request = nlohmann::json::parse(request_str, nullptr, false);
                       request["secret"] = secret_rsp.value()["secret"];
                       request["prompt"] = prompt;
                       auto str = request.dump();
                       SPDLOG_INFO("request : [{}]", str);
                       return str;
                   }())
                   .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());
    }
    co_return;
}

boost::asio::awaitable<void> FreeGpt::chatGptDemo(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(); }); }};

    boost::system::error_code err{};
    auto prompt = json.at("meta").at("content").at("parts").at(0).at("content").get<std::string>();

    std::unordered_multimap<std::string, std::string> http_headers{
        {"authority", "chat.chatgptdemo.net"},
        {"origin", "https://chat.chatgptdemo.net"},
        {"referer", "https://chat.chatgptdemo.net/"},
    };

    std::string recv, header_str;
    Curl curl;
    auto ret = curl.setUrl("https://chat.chatgptdemo.net/")
                   .setProxy(m_cfg.http_proxy)
                   .setRecvHeadersCallback([&](std::string str) { header_str.append(str); })
                   .setRecvBodyCallback([&](std::string str) { recv.append(str); })
                   .setHttpHeaders(http_headers)
                   .perform();
    if (ret) {
        co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
        ch->try_send(err, ret.value());
        co_return;
    }
    // auto response_header = Curl::parseHttpHeaders(header_str);
    // for (auto& [k, v] : response_header)
    //     SPDLOG_INFO("{}: {}", k, v);

    auto match_ret = findAll(R"(<div id="USERID" style="display: none">(.*)<\/div>)", recv);
    if (match_ret.empty()) {
        co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
        ch->try_send(err, std::format("not found userid"));
        co_return;
    }
    auto extract_value = [](const std::string& str) {
        size_t start = str.find('>') + 1;
        size_t end = str.find('<', start);
        std::string value = str.substr(start, end - start);
        return value;
    };
    auto user_id = extract_value(match_ret[0]);
    SPDLOG_INFO("user_id: [{}]", user_id);
    recv.clear();
    ret = curl.setUrl("https://chat.chatgptdemo.net/new_chat")
              .setProxy(m_cfg.http_proxy)
              .setRecvHeadersCallback([&](std::string) {})
              .setRecvBodyCallback([&](std::string str) { recv.append(str); })
              .clearHeaders()
              .setHttpHeaders([&] -> auto& {
                  http_headers.emplace("Content-Type", "application/json");
                  return http_headers;
              }())
              .setBody([&] -> std::string {
                  constexpr std::string_view json_str = R"({"user_id":"user_id"})";
                  nlohmann::json request = nlohmann::json::parse(json_str, nullptr, false);
                  request["user_id"] = user_id;
                  return request.dump();
              }())
              .perform();
    if (ret) {
        co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
        ch->try_send(err, ret.value());
        co_return;
    }

    SPDLOG_INFO("recv: [{}]", recv);
    nlohmann::json get_text_rsp = nlohmann::json::parse(recv, nullptr, false);
    auto chat_id = get_text_rsp["id_"].get<std::string>();
    SPDLOG_INFO("chat_id: [{}]", chat_id);

    recv.clear();
    ret = curl.setUrl("https://chat.chatgptdemo.net/chat_api_stream")
              .setProxy(m_cfg.http_proxy)
              .setRecvHeadersCallback([&](std::string) {})
              .setRecvBodyCallback([&](std::string str) {
                  recv.append(str);
                  while (true) {
                      auto position = recv.find("\n");
                      if (position == std::string::npos)
                          break;
                      auto msg = recv.substr(0, position + 1);
                      recv.erase(0, position + 1);
                      msg.pop_back();
                      if (msg.empty() || !msg.contains("content"))
                          continue;
                      if (!msg.starts_with("data: "))
                          continue;
                      msg.erase(0, 6);
                      boost::system::error_code err{};
                      nlohmann::json line_json = nlohmann::json::parse(msg, nullptr, false);
                      if (line_json.is_discarded()) {
                          SPDLOG_ERROR("json parse error: [{}]", msg);
                          boost::asio::post(ch->get_executor(),
                                            [=] { ch->try_send(err, std::format("json parse error: [{}]", msg)); });
                          continue;
                      }
                      auto str = line_json["choices"][0]["delta"]["content"].get<std::string>();
                      if (!str.empty())
                          boost::asio::post(ch->get_executor(), [=] { ch->try_send(err, str); });
                  }
              })
              .clearHeaders()
              .setHttpHeaders(http_headers)
              .setBody([&] -> std::string {
                  constexpr std::string_view ask_json_str =
                      R"({"question": "hello", "chat_id": "6524f3640d0d824902f598c1", "timestamp": 1696920420510})";
                  nlohmann::json ask_request = nlohmann::json::parse(ask_json_str, nullptr, false);
                  ask_request["question"] = prompt;
                  ask_request["chat_id"] = chat_id;
                  uint64_t timestamp = getTimestamp();
                  ask_request["timestamp"] = timestamp;
                  std::string ask_request_str = ask_request.dump();
                  SPDLOG_INFO("ask_request_str: [{}]", ask_request_str);
                  return ask_request_str;
              }())
              .perform();
    if (ret) {
        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::llama2(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(); }); }};

    boost::system::error_code err{};
    auto prompt = json.at("meta").at("content").at("parts").at(0).at("content").get<std::string>();

    static std::unordered_multimap<std::string, std::string> headers{
        {"Accept", "*/*"},
        {"origin", "https://www.llama2.ai"},
        {"referer", "https://www.llama2.ai/"},
        {"Content-Type", "text/plain;charset=UTF-8"},
    };
    auto ret = Curl()
                   .setUrl("https://www.llama2.ai/api")
                   .setProxy(m_cfg.http_proxy)
                   .setRecvHeadersCallback([](std::string) { return; })
                   .setRecvBodyCallback([&](std::string str) mutable {
                       boost::asio::post(ch->get_executor(), [=, str = std::move(str)] { ch->try_send(err, str); });
                       return;
                   })
                   .setBody([&] {
                       constexpr std::string_view ask_json_str = R"({
                            "prompt":"[INST] hello [/INST]\n[INST] hello [/INST]\n",
                            "version":"d24902e3fa9b698cc208b5e63136c4e26e828659a9f09827ca6ec5bb83014381",
                            "systemPrompt":"You are a helpful assistant.",
                            "temperature":0.75,
                            "topP":0.9,
                            "maxTokens":800,
                            "image":null,
                            "audio":null
                        })";
                       nlohmann::json ask_request = nlohmann::json::parse(ask_json_str, nullptr, false);
                       ask_request["prompt"] = std::format("[INST] {} [/INST]\n", prompt);
                       std::string ask_request_str = ask_request.dump();
                       SPDLOG_INFO("ask_request_str: [{}]", ask_request_str);
                       return ask_request_str;
                   }())
                   .clearHeaders()
                   .setHttpHeaders(headers)
                   .perform();

    if (ret) {
        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::geekGpt(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(); }); }};
    boost::system::error_code err{};
    static std::unordered_multimap<std::string, std::string> headers{
        {"Accept", "*/*"},
        {"authority", "ai.fakeopen.com"},
        {"content-type", "application/json"},
        {"referer", "https://chat.geekgpt.org/"},
        {"origin", "https://chat.geekgpt.org"},
        {"sec-ch-ua", R"("Google Chrome";v="117", "Not;A=Brand";v="8", "Chromium";v="117")"},
        {"sec-ch-ua-mobile", R"(?0)"},
        {"sec-ch-ua-platform", R"("macOS")"},
        {"cache-control", "no-cache"},
        {"pragma", "no-cache"},
        {"authorization", "Bearer pk-this-is-a-real-free-pool-token-for-everyone"},
    };
    std::string recv;
    auto ret = Curl()
                   .setUrl("https://ai.fakeopen.com/v1/chat/completions")
                   .setProxy(m_cfg.http_proxy)
                   .setRecvHeadersCallback([](std::string) { return; })
                   .setRecvBodyCallback([&](std::string str) mutable {
                       recv.append(str);
                       while (true) {
                           auto position = recv.find("\n");
                           if (position == std::string::npos)
                               break;
                           auto msg = recv.substr(0, position + 1);
                           recv.erase(0, position + 1);
                           msg.pop_back();
                           if (msg.empty() || !msg.contains("content"))
                               continue;
                           auto fields = splitString(msg, "data: ");
                           boost::system::error_code err{};
                           nlohmann::json line_json = nlohmann::json::parse(fields.back(), nullptr, false);
                           if (line_json.is_discarded()) {
                               SPDLOG_ERROR("json parse error: [{}]", fields.back());
                               boost::asio::post(ch->get_executor(), [=] {
                                   ch->try_send(err, std::format("json parse error: [{}]", fields.back()));
                               });
                               continue;
                           }
                           auto str = line_json["choices"][0]["delta"]["content"].get<std::string>();
                           if (!str.empty() && str != "[DONE]")
                               boost::asio::post(ch->get_executor(), [=] { ch->try_send(err, str); });
                       }
                       return;
                   })
                   .setBody([&] {
                       constexpr std::string_view ask_json_str = R"({
                            "messages": [{
                                "role": "user",
                                "content": "hello"
                            }],
                            "model": "gpt-3.5-turbo",
                            "temperature": 0.9,
                            "presence_penalty": 0,
                            "top_p": 1,
                            "frequency_penalty": 0,
                            "stream": true
                        })";
                       nlohmann::json ask_request = nlohmann::json::parse(ask_json_str, nullptr, false);
                       ask_request["messages"] = 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());
    }
    co_return;
}

boost::asio::awaitable<void> FreeGpt::chatGptAi(std::shared_ptr<Channel> ch, nlohmann::json json) {
    ScopeExit auto_exit{[&] { ch->close(); }};
    boost::system::error_code err{};

    constexpr std::string_view host = "chatgpt.ai";
    constexpr std::string_view port = "443";

    constexpr std::string_view user_agent{
        R"(Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/114.0.0.0 Safari/537.36)"};

    boost::beast::http::request<boost::beast::http::empty_body> req{boost::beast::http::verb::get, "/", 11};
    req.set(boost::beast::http::field::host, "chatgpt.ai");
    req.set(boost::beast::http::field::user_agent, user_agent);
    req.set("Accept", "*/*");

    int recreate_num{0};
create_client:
    boost::asio::ssl::context ctx(boost::asio::ssl::context::tls);
    ctx.set_verify_mode(boost::asio::ssl::verify_none);
    auto client = co_await createHttpClient(ctx, host, port);
    if (!client.has_value()) {
        SPDLOG_ERROR("createHttpClient: {}", client.error());
        co_await ch->async_send(err, client.error(), use_nothrow_awaitable);
        co_return;
    }
    auto& stream_ = client.value();

    std::string chunk_body;
    std::string cookie;
    auto ret = co_await sendRequestRecvChunk(
        ch, stream_, req, 200, [&ch, &chunk_body](std::string recv_str) { chunk_body.append(std::move(recv_str)); },
        [&](const boost::beast::http::parser<false, boost::beast::http::empty_body>& p) {
            auto& headers = p.get();
            for (const auto& header : headers) {
                if (boost::beast::http::to_string(header.name()) == "Set-Cookie") {
                    cookie = header.value();
                    return;
                }
            }
        });
    SPDLOG_ERROR("cookie: {}", cookie);
    if (ret == Status::Close && recreate_num == 0) {
        recreate_num++;
        goto create_client;
    }
    if (ret == Status::HasError)
        co_return;

    static std::string pattern{R"(data-system='(.*?)')"};

    std::vector<std::string> matches = findAll(pattern, chunk_body);
    if (matches.empty()) {
        SPDLOG_ERROR("parsing login failed");
        co_await ch->async_send(err, chunk_body, use_nothrow_awaitable);
        co_return;
    }

    auto html_unescape = [](const std::string& text) {
        std::string result = text;
        boost::replace_all(result, "&amp;", "&");
        boost::replace_all(result, "&lt;", "<");
        boost::replace_all(result, "&gt;", ">");
        boost::replace_all(result, "&quot;", "\"");
        boost::replace_all(result, "&#39;", "'");
        return result;
    };
    std::string html_json_str;
    std::regex regex("'(.*?)'");
    std::smatch result;
    if (std::regex_search(matches[0], result, regex))
        html_json_str = html_unescape(result[1]);
    if (html_json_str.empty()) {
        SPDLOG_ERROR("extract json fail");
        co_await ch->async_send(err, chunk_body, use_nothrow_awaitable);
        co_return;
    }
    nlohmann::json j = nlohmann::json::parse(html_json_str, nullptr, false);
    if (j.is_discarded()) {
        SPDLOG_ERROR("json parse error");
        co_await ch->async_send(err, "json parse error", use_nothrow_awaitable);
        co_return;
    }
    SPDLOG_INFO("json: {}", j.dump());

    auto prompt = json.at("meta").at("content").at("parts").at(0).at("content").get<std::string>();

    boost::beast::http::request<boost::beast::http::string_body> request{boost::beast::http::verb::post,
                                                                         "/wp-json/mwai-ui/v1/chats/submit", 11};
    request.set(boost::beast::http::field::host, host);
    request.set("authority", "chatgpt.ai");
    request.set("accept", "*/*");
    request.set("accept-language", R"(en,fr-FR;q=0.9,fr;q=0.8,es-ES;q=0.7,es;q=0.6,en-US;q=0.5,am;q=0.4,de;q=0.3)");
    request.set("cache-control", "no-cache");
    request.set("origin", "https://chatgpt.ai");
    request.set("pragma", "no-cache");
    request.set(boost::beast::http::field::referer, "https://chatgpt.ai/");
    request.set("sec-ch-ua", R"("Not.A/Brand";v="8", "Chromium";v="114", "Google Chrome";v="114")");
    request.set("sec-ch-ua-mobile", "?0");
    request.set("sec-ch-ua-platform", R"("Windows")");
    request.set("sec-fetch-dest", "empty");
    request.set("sec-fetch-mode", "cors");
    request.set("sec-fetch-site", "same-origin");
    request.set("Cookie", cookie);
    request.set(boost::beast::http::field::user_agent, user_agent);
    request.set("Content-Type", "application/json");

    constexpr std::string_view json_str = R"({
        "botId":"chatbot-9vy3t5",
        "customId":null,
        "session":"N/A",
        "chatId":"6tkwezdhivn",
        "contextId":1048,
        "messages":[
            {
                "role":"user",
                "content":"hello"
            }
        ],
        "newMessage":"hello",
        "stream":true
    })";
    nlohmann::json request_json = nlohmann::json::parse(json_str, nullptr, false);
    request_json["botId"] = j["botId"];
    request_json["customId"] = j["customId"];
    request_json["session"] = j["sessionId"];
    request_json["contextId"] = j["contextId"];
    request_json["chatId"] = [](int len) -> std::string {
        static std::string chars{"abcdefghijklmnopqrstuvwxyz0123456789"};
        static std::string letter{"abcdefghijklmnopqrstuvwxyz"};
        std::random_device rd;
        std::mt19937 gen(rd());
        std::uniform_int_distribution<> dis(0, 1000000);
        std::string random_string;
        random_string += chars[dis(gen) % letter.length()];
        len = len - 1;
        for (int i = 0; i < len; i++)
            random_string += chars[dis(gen) % chars.length()];
        return random_string;
    }(11);
    request_json["messages"] = getConversationJson(json);

    request_json["newMessage"] = prompt;

    SPDLOG_INFO("request: {}", request_json.dump());
    request.body() = request_json.dump();
    request.prepare_payload();

    std::string recv;
    co_await sendRequestRecvChunk(ch, stream_, request, 200, [&](std::string str) {
        recv.append(str);
        while (true) {
            auto position = recv.find("\n");
            if (position == std::string::npos)
                break;
            auto msg = recv.substr(0, position + 1);
            recv.erase(0, position + 1);
            msg.pop_back();
            if (msg.empty())
                continue;
            auto fields = splitString(msg, "data: ");
            boost::system::error_code err{};
            nlohmann::json line_json = nlohmann::json::parse(fields.back(), nullptr, false);
            if (line_json.is_discarded()) {
                SPDLOG_ERROR("json parse error: [{}]", fields.back());
                ch->try_send(err, std::format("json parse error: [{}]", fields.back()));
                continue;
            }
            auto type = line_json["type"].get<std::string>();
            if (type == "live")
                ch->try_send(err, line_json["data"].get<std::string>());
        }
    });
    co_return;
}

boost::asio::awaitable<void> FreeGpt::fakeGpt(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(); }); }};
    boost::system::error_code err{};

    auto prompt = json.at("meta").at("content").at("parts").at(0).at("content").get<std::string>();

    std::unordered_multimap<std::string, std::string> headers{
        {"Accept", "*/*"},
        {"referer", "https://chat-shared2.zhile.io/?v=2"},
    };

    std::multimap<std::string, std::string> api_load_params{
        {"t", std::to_string(getTimestamp<std::chrono::seconds>())},
    };
    auto api_load_url = std::format("https://chat-shared2.zhile.io/api/loads?{}", paramsToQueryStr(api_load_params));
    std::string chunk_body;

    Curl curl;
    auto ret = curl.setUrl(api_load_url)
                   .setProxy(m_cfg.http_proxy)
                   .setRecvHeadersCallback([](std::string) { return; })
                   .setRecvBodyCallback([&](std::string str) {
                       chunk_body.append(str);
                       return;
                   })
                   .setHttpHeaders([&] -> auto& { return headers; }())
                   .perform();
    if (ret.has_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;
    }
    nlohmann::json json_result = nlohmann::json::parse(chunk_body, nullptr, false);
    if (json_result.is_discarded()) {
        SPDLOG_ERROR("json parse error: [{}]", chunk_body);
        co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
        ch->try_send(err, std::format("json parse error: [{}]", chunk_body));
        co_return;
    }
    std::vector<nlohmann::json> random_j;
    for (auto& j : json_result["loads"]) {
        if (j["count"].get<int32_t>() == 0)
            random_j.emplace_back(std::move(j));
    }
    std::mt19937 g{std::random_device{}()};
    std::uniform_int_distribution<std::size_t> d{0, random_j.size()};
    auto token_id = random_j[d(g)];
    std::cout << token_id.dump() << std::endl;
    headers.emplace("Content-Type", "application/x-www-form-urlencoded");
    // send login
    std::multimap<std::string, std::string> login_params{
        {"token_key", token_id["token_id"].get<std::string>()},
        {"session_password",
         [](int len) -> std::string {
             static std::string chars{"abcdefghijklmnopqrstuvwxyz"};
             static std::string letter{"0123456789"};
             std::random_device rd;
             std::mt19937 gen(rd());
             std::uniform_int_distribution<> dis(0, 1000000);
             std::string random_string;
             random_string += letter[dis(gen) % letter.length()];
             len = len - 1;
             for (int i = 0; i < len; i++)
                 random_string += chars[dis(gen) % chars.length()];
             return random_string;
         }(10)},
    };
    chunk_body.clear();
    headers.erase("Content-Type");
    std::string header_str;
    auto body = paramsToQueryStr(login_params);

    ret = curl.setUrl("https://chat-shared2.zhile.io/auth/login")
              .setProxy(m_cfg.http_proxy)
              .setRecvHeadersCallback([&](std::string str) {
                  header_str.append(str);
                  return;
              })
              .setRecvBodyCallback([&](std::string str) {
                  chunk_body.append(str);
                  return;
              })
              .setBody(body)
              .clearHeaders()
              .setHttpHeaders([&] -> auto& { return 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());
        co_return;
    }
    auto response_header = Curl::parseHttpHeaders(header_str);
    auto range = response_header.equal_range("set-cookie");
    std::string cookie;
    for (auto it = range.first; it != range.second; ++it) {
        if (!(it->second.contains("credential=")))
            continue;
        auto view = it->second | std::views::drop_while(isspace) | std::views::reverse |
                    std::views::drop_while(isspace) | std::views::reverse;
        auto fields = splitString(std::string{view.begin(), view.end()}, " ");
        if (fields.size() < 1) {
            co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
            ch->try_send(err, "can't get cookie");
            co_return;
        }
        cookie = std::move(fields[0]);
        break;
    }
    SPDLOG_INFO("cookie: [{}]", cookie);
    SPDLOG_INFO("rsp: [{}]", chunk_body);
    chunk_body.clear();
    headers.emplace("cookie", cookie);

    // /api/auth/session
    ret = curl.setUrl("https://chat-shared2.zhile.io/api/auth/session")
              .setProxy(m_cfg.http_proxy)
              .setOpt(CURLOPT_HTTPGET, 1L)
              .setRecvHeadersCallback([](std::string str) {
                  std::cout << str << std::endl;
                  return;
              })
              .setRecvBodyCallback([&](std::string str) mutable {
                  chunk_body.append(str);
                  return;
              })
              .clearHeaders()
              .setHttpHeaders([&] -> auto& { return 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());
        co_return;
    }

    json_result.clear();
    json_result = nlohmann::json::parse(chunk_body, nullptr, false);
    if (json_result.is_discarded()) {
        SPDLOG_ERROR("/api/auth/session json parse error: [{}]", chunk_body);
        co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
        ch->try_send(err, std::format("/api/auth/session parse error: [{}]", chunk_body));
        co_return;
    }
    auto cache_token = json_result["accessToken"].get<std::string>();
    SPDLOG_INFO("accessToken: [{}]", cache_token);

    headers.erase("Accept");
    headers.emplace("Content-Type", "application/json");
    headers.emplace("Accept", "text/event-stream");
    auto auth = std::format("Bearer {}", cache_token);
    SPDLOG_INFO("auth: [{}]", auth);
    headers.emplace("X-Authorization", auth);
    std::string recv;
    std::string last_message;
    ret = curl.setUrl("https://chat-shared2.zhile.io/api/conversation")
              .setProxy(m_cfg.http_proxy)
              .setRecvHeadersCallback([](std::string) { return; })
              .setRecvBodyCallback([&](std::string str) mutable {
                  recv.append(str);
                  while (true) {
                      auto position = recv.find("\n");
                      if (position == std::string::npos)
                          break;
                      auto msg = recv.substr(0, position + 1);
                      recv.erase(0, position + 1);
                      msg.pop_back();
                      if (msg.empty() || !msg.starts_with("data: ") || !msg.contains("content"))
                          continue;
                      msg.erase(0, 6);
                      if (msg == "[DONE]")
                          break;
                      boost::system::error_code err{};
                      nlohmann::json line_json = nlohmann::json::parse(msg, nullptr, false);
                      if (line_json.is_discarded()) {
                          SPDLOG_ERROR("json parse error: [{}]", msg);
                          boost::asio::post(ch->get_executor(),
                                            [=] { ch->try_send(err, std::format("json parse error: [{}]", msg)); });
                          continue;
                      }
                      auto type = line_json["message"]["content"]["content_type"].get<std::string>();
                      if (type == "text") {
                          auto new_message = line_json["message"]["content"]["parts"][0].get<std::string>();
                          if (new_message.empty())
                              continue;
                          std::string tmp{new_message};
                          new_message.erase(0, last_message.size());
                          last_message = std::move(tmp);
                          if (!new_message.empty())
                              boost::asio::post(ch->get_executor(), [=] { ch->try_send(err, new_message); });
                      }
                  }
                  return;
              })
              .setBody([&] {
                  constexpr std::string_view json_str = R"({
                        "action":"next",
                        "messages":[
                            {
                                "id":"a68cd787-c96c-4234-8ec9-00805f73a7b8",
                                "author":{"role":"user"},
                                "content":{
                                    "content_type":"text",
                                    "parts":["hello"]
                                },
                                "metadata":{}
                            }
                        ],
                        "parent_message_id":"fdc171e6-dd0d-4494-93ce-e7d219e6ed05",
                        "model":"text-davinci-002-render-sha",
                        "plugin_ids":[],
                        "timezone_offset_min":-120,
                        "suggestions":[],
                        "history_and_training_disabled":true,
                        "arkose_token":"",
                        "force_paragen":false
                    })";
                  nlohmann::json request = nlohmann::json::parse(json_str, nullptr, false);
                  request["parent_message_id"] = createUuidString();
                  request["messages"][0]["id"] = createUuidString();
                  request["messages"][0]["content"]["parts"][0] = prompt;
                  SPDLOG_INFO("request: [{}]", request.dump(2));
                  return request.dump();
              }())
              .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());
        co_return;
    }
}

boost::asio::awaitable<void> FreeGpt::vercel(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(); }); }};

    boost::system::error_code err{};
    auto prompt = json.at("meta").at("content").at("parts").at(0).at("content").get<std::string>();

    auto create_random_number = [] {
        std::random_device rd;
        std::mt19937 mt(rd());
        std::uniform_int_distribution<int> distribution(99, 999);
        int random_number = distribution(mt);
        return random_number;
    };
    constexpr std::string_view user_agent_str{
        R"(Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/117.0.{}.{} Safari/537.36)"};

    std::unordered_multimap<std::string, std::string> headers{
        {"Accept", "*/*"},
        {"authority", "sdk.vercel.ai"},
        {"content-type", "application/json"},
        {"referer", "https://sdk.vercel.ai/"},
        {"origin", "https://sdk.vercel.ai"},
        {"sec-ch-ua", R"("Google Chrome";v="117", "Not;A=Brand";v="8", "Chromium";v="117")"},
        {"sec-ch-ua-mobile", R"(?0)"},
        {"sec-ch-ua-platform", R"("macOS")"},
        {"cache-control", "no-cache"},
        {"pragma", "no-cache"},
    };
    headers.emplace("user-agent", std::format(user_agent_str, create_random_number(), create_random_number()));

    std::string recv;
    Curl curl;
    auto ret = curl.setUrl("https://sdk.vercel.ai/openai.jpeg")
                   .setProxy(m_cfg.http_proxy)
                   .setRecvHeadersCallback([](std::string) { return; })
                   .setRecvBodyCallback([&](std::string str) mutable {
                       recv.append(str);
                       return;
                   })
                   .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());
        co_return;
    }
    nlohmann::json request;
    request["data"] = std::move(recv);
    recv.clear();
    auto vercel_rsp = callZeus(std::format("{}/vercel", m_cfg.zeus), request.dump());
    if (!vercel_rsp.has_value()) {
        SPDLOG_ERROR("callZeus vercel error: {}", vercel_rsp.error());
        co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
        ch->try_send(err, vercel_rsp.error());
        co_return;
    }

    headers.erase("custom-encoding");
    headers.erase("user-agent");
    headers.emplace("custom-encoding", vercel_rsp.value()["data"]);
    headers.emplace("user-agent", std::format(user_agent_str, create_random_number(), create_random_number()));

    for (int i = 0; i < 20; i++) {
        auto ret =
            curl.setUrl("https://sdk.vercel.ai/api/generate")
                .setProxy(m_cfg.http_proxy)
                .setRecvHeadersCallback([](std::string) { return; })
                .setRecvBodyCallback([&](std::string str) mutable {
                    if (str == "Internal Server Error" || str == "Rate limit exceeded") {
                        SPDLOG_WARN("vercel: [{}]", str);
                        return;
                    }
                    boost::asio::post(ch->get_executor(), [=, str = std::move(str)] { ch->try_send(err, str); });
                    return;
                })
                .setBody([&] {
                    constexpr std::string_view json_str = R"({
                            "model":"openai:gpt-3.5-turbo",
                            "messages":[
                                {
                                    "role":"user",
                                    "content":"hello"
                                }
                            ],
                            "playgroundId":"403bce4c-7eb6-47b0-b1b5-0cb6b2469f70",
                            "chatIndex":0,
                            "temperature":0.7,
                            "maximumLength":4096,
                            "topP":1,
                            "topK":1,
                            "presencePenalty":1,
                            "frequencyPenalty":1,
                            "stopSequences":[]
                        })";
                    nlohmann::json request = nlohmann::json::parse(json_str, nullptr, false);
                    request["messages"] = getConversationJson(json);
                    request["playgroundId"] = createUuidString();
                    SPDLOG_INFO("request: [{}]", request.dump(2));
                    return request.dump();
                }())
                .clearHeaders()
                .setHttpHeaders(headers)
                .perform();
        if (ret.has_value()) {
            SPDLOG_ERROR("{}", ret.value());
            co_await timeout(std::chrono::seconds(2));
            continue;
        }
        co_return;
    }
    co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
    ch->try_send(err, "call sdk.vercel.ai error");
    co_return;
}

boost::asio::awaitable<void> FreeGpt::aivvm(std::shared_ptr<Channel> ch, nlohmann::json json) {
    boost::system::error_code err{};
    ScopeExit auto_exit{[&] { ch->close(); }};

    using Tuple = std::tuple<std::chrono::time_point<std::chrono::system_clock>, std::string>;
    static moodycamel::ConcurrentQueue<Tuple> cookie_queue;
    Tuple item;
    bool found{false};
    if (cookie_queue.try_dequeue(item)) {
        auto& [time_point, cookie] = item;
        if (std::chrono::system_clock::now() - time_point < std::chrono::minutes(120))
            found = true;
    }
    if (!found) {
        std::string recv;
        auto get_cookiet_ret = Curl()
                                   .setUrl(m_cfg.flaresolverr)
                                   .setRecvHeadersCallback([](std::string) { return; })
                                   .setRecvBodyCallback([&](std::string str) mutable {
                                       recv.append(str);
                                       return;
                                   })
                                   .setBody([] {
                                       nlohmann::json data{
                                           {"cmd", "request.get"},
                                           {"url", "https://chat.aivvm.com/zh"},
                                           {"maxTimeout", 60000},
                                       };
                                       return data.dump();
                                   }())
                                   .setHttpHeaders([&] -> auto& {
                                       static std::unordered_multimap<std::string, std::string> headers{
                                           {"Accept", "*/*"},
                                           {"Content-Type", "application/json"},
                                       };
                                       return headers;
                                   }())
                                   .perform();
        if (get_cookiet_ret.has_value()) {
            SPDLOG_ERROR("call {}: [{}]", m_cfg.flaresolverr, get_cookiet_ret.value());
            co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
            ch->try_send(err, get_cookiet_ret.value());
            co_return;
        }

        nlohmann::json rsp = nlohmann::json::parse(recv, nullptr, false);
        if (rsp.is_discarded()) {
            SPDLOG_ERROR("json parse error");
            co_await ch->async_send(err, "json parse error", use_nothrow_awaitable);
            co_return;
        }
        SPDLOG_INFO("rsp: {}", rsp.dump());
        auto status = rsp.at("status").get<std::string>();
        if (status != "ok") {
            SPDLOG_ERROR("get cookie error");
            co_await ch->async_send(err, "get cookie error", use_nothrow_awaitable);
            co_return;
        }
        auto it =
            std::ranges::find_if(rsp["solution"]["cookies"], [](auto& p) { return p["name"] == "cf_clearance"; });
        if (it == rsp["solution"]["cookies"].end()) {
            SPDLOG_ERROR("not found cookie");
            co_await ch->async_send(err, "not found cookie", use_nothrow_awaitable);
            co_return;
        }
        auto cookie_str = std::format("cf_clearance={}", (*it)["value"].get<std::string>());
        // std::cout << rsp["solution"]["userAgent"].get<std::string>() << std::endl;
        item = std::make_tuple(std::chrono::system_clock::now(), std::move(cookie_str));
    }
    SPDLOG_INFO("cookie: {}", std::get<1>(item));
    bool return_flag{true};
    ScopeExit auto_free([&] mutable {
        if (!return_flag)
            return;
        auto& [time_point, cookie] = item;
        if (std::chrono::system_clock::now() - time_point < std::chrono::minutes(120))
            cookie_queue.enqueue(std::move(item));
    });

    constexpr std::string_view host = "chat.aivvm.com";
    constexpr std::string_view port = "443";

    constexpr std::string_view user_agent{
        R"(Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/116.0.0.0 Safari/537.36)"};

    boost::asio::ssl::context ctx1(boost::asio::ssl::context::tls);
    ctx1.set_verify_mode(boost::asio::ssl::verify_none);

    auto client = co_await createHttpClient(ctx1, host, port);
    if (!client.has_value()) {
        SPDLOG_ERROR("createHttpClient: {}", client.error());
        co_await ch->async_send(err, client.error(), use_nothrow_awaitable);
        co_return;
    }
    auto& stream_ = client.value();

    boost::beast::http::request<boost::beast::http::string_body> req{boost::beast::http::verb::post, "/api/chat", 11};
    req.set(boost::beast::http::field::host, host);
    req.set(boost::beast::http::field::user_agent, user_agent);
    req.set("Accept", "*/*");
    req.set("accept-language", "zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2");
    req.set("origin", "https://chat.aivvm.com");
    req.set("referer", "https://chat.aivvm.com/zh");
    req.set(boost::beast::http::field::content_type, "application/json");
    req.set("sec-fetch-dest", "empty");
    req.set("sec-fetch-mode", "cors");
    req.set("sec-fetch-site", "same-origin");
    req.set("DNT", "1");
    req.set("Cookie", std::get<1>(item));

    constexpr std::string_view json_str = R"({
        "model":{
            "id":"gpt-3.5-turbo",
            "name":"GPT-3.5",
            "maxLength":12000,
            "tokenLimit":4096
        },
        "messages":[
            {
                "role":"user",
                "content":"hello"
            }
        ],
        "key":"",
        "prompt":"You are ChatGPT, a large language model trained by OpenAI. Follow the user's instructions carefully. Respond using markdown.",
        "temperature":0.7
    })";
    nlohmann::json request = nlohmann::json::parse(json_str, nullptr, false);

    request["messages"] = getConversationJson(json);
    SPDLOG_INFO("{}", request.dump(2));

    req.body() = request.dump();
    req.prepare_payload();

    auto result = co_await sendRequestRecvChunk(ch, stream_, req, 200, [&ch](std::string str) {
        boost::system::error_code err{};
        if (!str.empty())
            ch->try_send(err, str);
    });
    if (result == Status::UnexpectedHttpCode)
        return_flag = false;
    co_return;
}

boost::asio::awaitable<void> FreeGpt::chatGpt4Online(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", "*/*"},
        {"content-type", "application/x-www-form-urlencoded"},
    };
    Curl curl;
    std::string recv;
    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("{}", ret.value());
        co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
        ch->try_send(err, ret.value());
    }
    static std::string pattern{R"(data-nonce=".*")"};

    std::vector<std::string> matches = findAll(pattern, recv);
    if (matches.size() != 1) {
        SPDLOG_ERROR("parsing login failed");
        co_await ch->async_send(err, recv, use_nothrow_awaitable);
        co_return;
    }

    std::regex reg("\"([^\"]*)\"");
    std::sregex_iterator iter(matches[0].begin(), matches[0].end(), reg);
    std::sregex_iterator end;
    std::vector<std::string> results;
    while (iter != end) {
        results.emplace_back(iter->str(1));
        iter++;
    }
    if (results.empty()) {
        SPDLOG_ERROR("Failed to extract content");
        co_await ch->async_send(err, "Failed to extract content", use_nothrow_awaitable);
        co_return;
    }
    auto& nonce = results[0];
    SPDLOG_INFO("data_nonce: {}", nonce);
    ret = curl.setUrl("https://chatgpt4online.org/rizq")
              .setProxy(m_cfg.http_proxy)
              .setRecvHeadersCallback([](std::string) { return; })
              .setRecvBodyCallback([&](std::string str) mutable {
                  boost::system::error_code err{};
                  nlohmann::json line_json = nlohmann::json::parse(str, nullptr, false);
                  if (line_json.is_discarded()) {
                      SPDLOG_ERROR("json parse error: [{}]", str);
                      boost::asio::post(ch->get_executor(),
                                        [=] { ch->try_send(err, std::format("json parse error: [{}]", str)); });
                      return;
                  }
                  auto message = line_json["data"].get<std::string>();
                  if (message.empty())
                      return;
                  boost::asio::post(ch->get_executor(), [=] { ch->try_send(err, message); });
              })
              .setBody([&] {
                  std::multimap<std::string, std::string> params{
                      {"_wpnonce", nonce},
                      {"post_id", "58"},
                      {"url", "https://chatgpt4online.org"},
                      {"action", "wpaicg_chat_shortcode_message"},
                      {"message", prompt},
                      {"bot_id", "3405"},
                  };
                  return paramsToQueryStr(params);
              }())
              .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());
    }
    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());
    }
    co_return;
}

boost::asio::awaitable<void> FreeGpt::chatGptNext(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));

    boost::system::error_code err{};
    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>();

    std::string recv;
    auto ret = Curl()
                   .setUrl("https://chat.fstha.com/api/openai/v1/chat/completions")
                   .setProxy(m_cfg.http_proxy)
                   .setRecvBodyCallback([&](std::string str) mutable { recv.append(str); })
                   .setHttpHeaders([&] -> auto& {
                       static std::unordered_multimap<std::string, std::string> headers{
                           {"Accept", "text/event-stream"},
                           {"origin", "https://chat.fstha.com"},
                           {"referer", "https://chat.fstha.com/"},
                           {"x-requested-with", "XMLHttpRequest"},
                           {"Authorization", "Bearer ak-chatgpt-nice"},
                           {"Alt-Used", "chat.fstha.com"},
                       };
                       return headers;
                   }())
                   .setBody([&] {
                       constexpr std::string_view request_str{R"({
                            "messages":[
                                {
                                    "role":"user",
                                    "content":"hello"
                                }
                            ],
                            "stream":false,
                            "model":"gpt-3.5-turbo",
                            "temperature":0.5,
                            "presence_penalty":0,
                            "frequency_penalty":0,
                            "top_p":1
                        })"};
                       nlohmann::json request = nlohmann::json::parse(request_str, nullptr, false);
                       request["messages"] = getConversationJson(json);
                       auto str = request.dump();
                       SPDLOG_INFO("request : [{}]", str);
                       return str;
                   }())
                   .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());
        co_return;
    }
    SPDLOG_INFO("{}", recv);
    co_await boost::asio::post(boost::asio::bind_executor(ch->get_executor(), boost::asio::use_awaitable));
    nlohmann::json rsp = nlohmann::json::parse(recv, nullptr, false);
    if (rsp.is_discarded()) {
        SPDLOG_ERROR("json parse error: {}", recv);
        ch->try_send(err, recv);
    }
    auto info = rsp["choices"][0]["message"]["content"].get<std::string>();
    ch->try_send(err, info);
    co_return;
}

boost::asio::awaitable<void> FreeGpt::gptTalkru(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://gpttalk.ru/"},
        {"Origin", "https://gpttalk.ru"},
    };
    std::string recv;
    auto ret = Curl()
                   .setUrl("https://gpttalk.ru/gpt2")
                   .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"({
                            "model":"gpt-3.5-turbo",
                            "modelType":1,
                            "prompt":[
                                {
                                    "role":"user",
                                    "content":"我的上一个问题"
                                }
                            ],
                            "responseType":"stream"
                        })";
                       nlohmann::json ask_request = nlohmann::json::parse(ask_json_str, nullptr, false);
                       ask_request["prompt"] = 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());
    }
    co_return;
}