llama-cpp-bindings-sys 0.8.0

#include "wrapper_reasoning.h"

#include "llama.cpp/common/chat-auto-parser.h"
#include "llama.cpp/common/chat.h"
#include "llama.cpp/include/llama.h"
#include "marker_probes/marker_probe.h"

#include <exception>
#include <new>
#include <nlohmann/json.hpp>
#include <string>

namespace {

std::string token_text_or_empty(const llama_vocab * vocab, llama_token token) {
    if (token == LLAMA_TOKEN_NULL) {
        return {};
    }

    const char * text = llama_vocab_get_text(vocab, token);
    if (!text) {
        return {};
    }

    return std::string(text);
}

}  // namespace

extern "C" llama_rs_detect_reasoning_markers_status llama_rs_detect_reasoning_markers(
    const struct llama_model * model,
    char ** out_open,
    char ** out_close,
    char ** out_error) {
    if (out_open) {
        *out_open = nullptr;
    }
    if (out_close) {
        *out_close = nullptr;
    }
    if (out_error) {
        *out_error = nullptr;
    }
    if (!model) {
        return LLAMA_RS_DETECT_REASONING_MARKERS_NULL_MODEL_ARG;
    }
    if (!out_open) {
        return LLAMA_RS_DETECT_REASONING_MARKERS_NULL_OUT_OPEN_ARG;
    }
    if (!out_close) {
        return LLAMA_RS_DETECT_REASONING_MARKERS_NULL_OUT_CLOSE_ARG;
    }
    if (!out_error) {
        return LLAMA_RS_DETECT_REASONING_MARKERS_NULL_OUT_ERROR_ARG;
    }

    try {
        const char * tmpl_src = llama_model_chat_template(model, nullptr);
        if (!tmpl_src) {
            return LLAMA_RS_DETECT_REASONING_MARKERS_OK;
        }

        const llama_vocab * vocab = llama_model_get_vocab(model);
        if (!vocab) {
            return LLAMA_RS_DETECT_REASONING_MARKERS_OK;
        }

        std::string bos_token = token_text_or_empty(vocab, llama_vocab_bos(vocab));
        std::string eos_token = token_text_or_empty(vocab, llama_vocab_eos(vocab));

        common_chat_template tmpl(tmpl_src, bos_token, eos_token);

        std::string detected_start;
        std::string detected_end;
        bool detected = false;

        autoparser::generation_params probe_params;
        probe_params.add_generation_prompt = true;
        probe_params.enable_thinking = true;
        probe_params.is_inference = false;
        probe_params.add_inference = false;
        probe_params.mark_input = false;
        probe_params.messages = nlohmann::ordered_json::array({
            nlohmann::ordered_json{ { "role", "user" }, { "content", "ping" } },
        });

        const std::string tmpl_src_str = tmpl_src;
        if (auto specialized = common_chat_try_specialized_template(tmpl, tmpl_src_str, probe_params)) {
            if (specialized->supports_thinking
                && !specialized->thinking_start_tag.empty()
                && !specialized->thinking_end_tag.empty()) {
                detected_start = std::move(specialized->thinking_start_tag);
                detected_end = std::move(specialized->thinking_end_tag);
                detected = true;
            }
        }

        if (!detected) {
            autoparser::autoparser parser;
            parser.analyze_template(tmpl);

            if (parser.reasoning.mode != autoparser::reasoning_mode::NONE
                && !parser.reasoning.start.empty()
                && !parser.reasoning.end.empty()) {
                detected_start = std::move(parser.reasoning.start);
                detected_end = std::move(parser.reasoning.end);
                detected = true;
            }
        }

        if (!detected) {
            for (auto probe : marker_probes::registered()) {
                auto fallback = probe(tmpl);
                if (fallback.found) {
                    detected_start = std::move(fallback.start);
                    detected_end = std::move(fallback.end);
                    detected = true;
                    break;
                }
            }
        }

        if (!detected) {
            return LLAMA_RS_DETECT_REASONING_MARKERS_OK;
        }

        char * open_dup = llama_rs_dup_string(detected_start);
        char * close_dup = llama_rs_dup_string(detected_end);

        if (!open_dup || !close_dup) {
            std::free(open_dup);
            std::free(close_dup);

            return LLAMA_RS_DETECT_REASONING_MARKERS_ERROR_STRING_ALLOCATION_FAILED;
        }

        *out_open = open_dup;
        *out_close = close_dup;

        return LLAMA_RS_DETECT_REASONING_MARKERS_OK;
    } catch (const std::bad_alloc &) {
        return LLAMA_RS_DETECT_REASONING_MARKERS_ERROR_STRING_ALLOCATION_FAILED;
    } catch (const std::exception & ex) {
        *out_error = llama_rs_dup_string(std::string(ex.what()));
        if (!*out_error) {
            return LLAMA_RS_DETECT_REASONING_MARKERS_ERROR_STRING_ALLOCATION_FAILED;
        }
        return LLAMA_RS_DETECT_REASONING_MARKERS_VENDORED_THREW_CXX_EXCEPTION;
    } catch (...) {
        *out_error = llama_rs_dup_string(std::string("unknown c++ exception"));
        if (!*out_error) {
            return LLAMA_RS_DETECT_REASONING_MARKERS_ERROR_STRING_ALLOCATION_FAILED;
        }
        return LLAMA_RS_DETECT_REASONING_MARKERS_VENDORED_THREW_CXX_EXCEPTION;
    }
}