chat.cpp 106 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480
  1. #include "chat.h"
  2. #include "chat-parser.h"
  3. #include "common.h"
  4. #include "json-partial.h"
  5. #include "json-schema-to-grammar.h"
  6. #include "log.h"
  7. #include "regex-partial.h"
  8. #include <minja/chat-template.hpp>
  9. #include <minja/minja.hpp>
  10. #include <cstdio>
  11. #include <exception>
  12. #include <iostream>
  13. #include <optional>
  14. #include <stdexcept>
  15. #include <string>
  16. #include <vector>
  17. using json = nlohmann::ordered_json;
  18. static std::string format_time(const std::chrono::system_clock::time_point & now, const std::string & format) {
  19. auto time = std::chrono::system_clock::to_time_t(now);
  20. auto local_time = *std::localtime(&time);
  21. std::ostringstream ss;
  22. ss << std::put_time(&local_time, format.c_str());
  23. auto res = ss.str();
  24. return res;
  25. }
  26. static std::string string_diff(const std::string & last, const std::string & current) {
  27. if (last.empty()) {
  28. return current;
  29. }
  30. if (!string_starts_with(current, last)) {
  31. if (string_starts_with(last, current)) {
  32. // This happens if the last generation ended on a partial stop word (not erased),
  33. // and the current ended on a stop word (erased).
  34. return "";
  35. }
  36. throw std::runtime_error("Invalid diff: '" + last + "' not found at start of '" + current + "'");
  37. }
  38. return current.substr(last.size());
  39. }
  40. static bool has_content_or_tool_calls(const common_chat_msg & msg) {
  41. return !msg.content.empty() || !msg.tool_calls.empty();
  42. }
  43. template <>
  44. json common_chat_msg::to_json_oaicompat() const
  45. {
  46. json message {
  47. {"role", "assistant"},
  48. };
  49. if (!reasoning_content.empty()) {
  50. message["reasoning_content"] = reasoning_content;
  51. }
  52. if (content.empty() && !tool_calls.empty()) {
  53. message["content"] = json();
  54. } else {
  55. message["content"] = content;
  56. }
  57. if (!tool_calls.empty()) {
  58. auto arr = json::array();
  59. for (const auto & tc : tool_calls) {
  60. arr.push_back({
  61. {"type", "function"},
  62. {"function", {
  63. {"name", tc.name},
  64. {"arguments", tc.arguments},
  65. }},
  66. {"id", tc.id},
  67. // // Some templates generate and require an id (sometimes in a very specific format, e.g. Mistral Nemo).
  68. // // We only generate a random id for the ones that don't generate one by themselves
  69. // // (they also won't get to see it as their template likely doesn't use it, so it's all for the client)
  70. // {"id", tc.id.empty() ? gen_tool_call_id() : tc.id},
  71. });
  72. }
  73. message["tool_calls"] = arr;
  74. }
  75. return message;
  76. }
  77. std::vector<common_chat_msg_diff> common_chat_msg_diff::compute_diffs(const common_chat_msg & previous_msg, const common_chat_msg & new_msg) {
  78. std::vector<common_chat_msg_diff> diffs;
  79. if (previous_msg.reasoning_content != new_msg.reasoning_content) {
  80. auto & diff = diffs.emplace_back();
  81. diff.reasoning_content_delta = string_diff(previous_msg.reasoning_content, new_msg.reasoning_content);
  82. }
  83. if (previous_msg.content != new_msg.content) {
  84. auto & diff = diffs.emplace_back();
  85. diff.content_delta = string_diff(previous_msg.content, new_msg.content);
  86. }
  87. if (new_msg.tool_calls.size() < previous_msg.tool_calls.size()) {
  88. throw std::runtime_error("Invalid diff: now finding less tool calls!");
  89. }
  90. if (!previous_msg.tool_calls.empty()) {
  91. auto idx = previous_msg.tool_calls.size() - 1;
  92. const auto & pref = previous_msg.tool_calls[idx];
  93. const auto & newf = new_msg.tool_calls[idx];
  94. if (pref.name != newf.name) {
  95. throw std::runtime_error("Invalid diff: tool call mismatch!");
  96. }
  97. auto args_diff = string_diff(pref.arguments, newf.arguments);
  98. if (!args_diff.empty() || pref.id != newf.id) {
  99. auto & diff = diffs.emplace_back();
  100. diff.tool_call_index = idx;
  101. if (pref.id != newf.id) {
  102. diff.tool_call_delta.id = newf.id;
  103. diff.tool_call_delta.name = newf.name;
  104. }
  105. diff.tool_call_delta.arguments = args_diff;
  106. }
  107. }
  108. for (size_t idx = previous_msg.tool_calls.size(); idx < new_msg.tool_calls.size(); ++idx) {
  109. auto & diff = diffs.emplace_back();
  110. diff.tool_call_index = idx;
  111. diff.tool_call_delta = new_msg.tool_calls[idx];
  112. }
  113. return diffs;
  114. }
  115. typedef minja::chat_template common_chat_template;
  116. struct common_chat_templates {
  117. bool add_bos;
  118. bool add_eos;
  119. bool has_explicit_template; // Model had builtin template or template overridde was specified.
  120. std::unique_ptr<common_chat_template> template_default; // always set (defaults to chatml)
  121. std::unique_ptr<common_chat_template> template_tool_use;
  122. };
  123. struct templates_params {
  124. json messages;
  125. json tools;
  126. common_chat_tool_choice tool_choice;
  127. json json_schema;
  128. bool parallel_tool_calls;
  129. bool stream;
  130. std::string grammar;
  131. bool add_generation_prompt = true;
  132. bool enable_thinking = true;
  133. std::chrono::system_clock::time_point now = std::chrono::system_clock::now();
  134. json extra_context;
  135. bool add_bos;
  136. bool add_eos;
  137. bool is_inference = true;
  138. };
  139. common_chat_tool_choice common_chat_tool_choice_parse_oaicompat(const std::string & tool_choice) {
  140. if (tool_choice == "auto") {
  141. return COMMON_CHAT_TOOL_CHOICE_AUTO;
  142. }
  143. if (tool_choice == "none") {
  144. return COMMON_CHAT_TOOL_CHOICE_NONE;
  145. }
  146. if (tool_choice == "required") {
  147. return COMMON_CHAT_TOOL_CHOICE_REQUIRED;
  148. }
  149. throw std::runtime_error("Invalid tool_choice: " + tool_choice);
  150. }
  151. template <>
  152. std::vector<common_chat_msg> common_chat_msgs_parse_oaicompat(const json & messages) {
  153. std::vector<common_chat_msg> msgs;
  154. try {
  155. if (!messages.is_array()) {
  156. throw std::runtime_error("Expected 'messages' to be an array, got " + messages.dump());
  157. }
  158. for (const auto & message : messages) {
  159. if (!message.is_object()) {
  160. throw std::runtime_error("Expected 'message' to be an object, got " + message.dump());
  161. }
  162. common_chat_msg msg;
  163. if (!message.contains("role")) {
  164. throw std::runtime_error("Missing 'role' in message: " + message.dump());
  165. }
  166. msg.role = message.at("role");
  167. auto has_content = message.contains("content");
  168. auto has_tool_calls = message.contains("tool_calls");
  169. if (has_content) {
  170. const auto & content = message.at("content");
  171. if (content.is_string()) {
  172. msg.content = content;
  173. } else if (content.is_array()) {
  174. for (const auto & part : content) {
  175. if (!part.contains("type")) {
  176. throw std::runtime_error("Missing content part type: " + part.dump());
  177. }
  178. const auto & type = part.at("type");
  179. if (type != "text") {
  180. throw std::runtime_error("Unsupported content part type: " + type.dump());
  181. }
  182. common_chat_msg_content_part msg_part;
  183. msg_part.type = type;
  184. msg_part.text = part.at("text");
  185. msg.content_parts.push_back(msg_part);
  186. }
  187. } else if (!content.is_null()) {
  188. throw std::runtime_error("Invalid 'content' type: expected string or array, got " + content.dump() + " (ref: https://github.com/ggml-org/llama.cpp/issues/8367)");
  189. }
  190. }
  191. if (has_tool_calls) {
  192. for (const auto & tool_call : message.at("tool_calls")) {
  193. common_chat_tool_call tc;
  194. if (!tool_call.contains("type")) {
  195. throw std::runtime_error("Missing tool call type: " + tool_call.dump());
  196. }
  197. const auto & type = tool_call.at("type");
  198. if (type != "function") {
  199. throw std::runtime_error("Unsupported tool call type: " + tool_call.dump());
  200. }
  201. if (!tool_call.contains("function")) {
  202. throw std::runtime_error("Missing tool call function: " + tool_call.dump());
  203. }
  204. const auto & fc = tool_call.at("function");
  205. if (!fc.contains("name")) {
  206. throw std::runtime_error("Missing tool call name: " + tool_call.dump());
  207. }
  208. tc.name = fc.at("name");
  209. tc.arguments = fc.at("arguments");
  210. if (tool_call.contains("id")) {
  211. tc.id = tool_call.at("id");
  212. }
  213. msg.tool_calls.push_back(tc);
  214. }
  215. }
  216. if (!has_content && !has_tool_calls) {
  217. throw std::runtime_error("Expected 'content' or 'tool_calls' (ref: https://github.com/ggml-org/llama.cpp/issues/8367 & https://github.com/ggml-org/llama.cpp/issues/12279)");
  218. }
  219. if (message.contains("reasoning_content")) {
  220. msg.reasoning_content = message.at("reasoning_content");
  221. }
  222. if (message.contains("name")) {
  223. msg.tool_name = message.at("name");
  224. }
  225. if (message.contains("tool_call_id")) {
  226. msg.tool_call_id = message.at("tool_call_id");
  227. }
  228. msgs.push_back(msg);
  229. }
  230. } catch (const std::exception & e) {
  231. // @ngxson : disable otherwise it's bloating the API response
  232. // printf("%s\n", std::string("; messages = ") + messages.dump(2));
  233. throw std::runtime_error("Failed to parse messages: " + std::string(e.what()));
  234. }
  235. return msgs;
  236. }
  237. template <>
  238. json common_chat_msgs_to_json_oaicompat(const std::vector<common_chat_msg> & msgs, bool concat_typed_text) {
  239. json messages = json::array();
  240. for (const auto & msg : msgs) {
  241. if (!msg.content.empty() && !msg.content_parts.empty()) {
  242. throw std::runtime_error("Cannot specify both content and content_parts");
  243. }
  244. json jmsg {
  245. {"role", msg.role},
  246. };
  247. if (!msg.content.empty()) {
  248. jmsg["content"] = msg.content;
  249. } else if (!msg.content_parts.empty()) {
  250. if (concat_typed_text) {
  251. std::string text;
  252. for (const auto & part : msg.content_parts) {
  253. if (part.type != "text") {
  254. LOG_WRN("Ignoring content part type: %s\n", part.type.c_str());
  255. continue;
  256. }
  257. if (!text.empty()) {
  258. text += '\n';
  259. }
  260. text += part.text;
  261. }
  262. jmsg["content"] = text;
  263. } else {
  264. auto & parts = jmsg["content"] = json::array();
  265. for (const auto & part : msg.content_parts) {
  266. parts.push_back({
  267. {"type", part.type},
  268. {"text", part.text},
  269. });
  270. }
  271. }
  272. } else {
  273. jmsg["content"] = json(); // null
  274. }
  275. if (!msg.reasoning_content.empty()) {
  276. jmsg["reasoning_content"] = msg.reasoning_content;
  277. jmsg["thinking"] = msg.reasoning_content; // gpt-oss
  278. }
  279. if (!msg.tool_name.empty()) {
  280. jmsg["name"] = msg.tool_name;
  281. }
  282. if (!msg.tool_call_id.empty()) {
  283. jmsg["tool_call_id"] = msg.tool_call_id;
  284. }
  285. if (!msg.tool_calls.empty()) {
  286. auto & tool_calls = jmsg["tool_calls"] = json::array();
  287. for (const auto & tool_call : msg.tool_calls) {
  288. json tc {
  289. {"type", "function"},
  290. {"function", {
  291. {"name", tool_call.name},
  292. {"arguments", tool_call.arguments},
  293. }},
  294. };
  295. if (!tool_call.id.empty()) {
  296. tc["id"] = tool_call.id;
  297. }
  298. tool_calls.push_back(tc);
  299. }
  300. }
  301. messages.push_back(jmsg);
  302. }
  303. return messages;
  304. }
  305. template <>
  306. std::vector<common_chat_msg> common_chat_msgs_parse_oaicompat(const std::string & messages) {
  307. return common_chat_msgs_parse_oaicompat(json::parse(messages));
  308. }
  309. template <>
  310. std::vector<common_chat_tool> common_chat_tools_parse_oaicompat(const json & tools) {
  311. std::vector<common_chat_tool> result;
  312. try {
  313. if (!tools.is_null()) {
  314. if (!tools.is_array()) {
  315. throw std::runtime_error("Expected 'tools' to be an array, got " + tools.dump());
  316. }
  317. for (const auto & tool : tools) {
  318. if (!tool.contains("type")) {
  319. throw std::runtime_error("Missing tool type: " + tool.dump());
  320. }
  321. const auto & type = tool.at("type");
  322. if (!type.is_string() || type != "function") {
  323. throw std::runtime_error("Unsupported tool type: " + tool.dump());
  324. }
  325. if (!tool.contains("function")) {
  326. throw std::runtime_error("Missing tool function: " + tool.dump());
  327. }
  328. const auto & function = tool.at("function");
  329. result.push_back({
  330. /* .name = */ function.at("name"),
  331. /* .description = */ function.at("description"),
  332. /* .parameters = */ function.at("parameters").dump(),
  333. });
  334. }
  335. }
  336. } catch (const std::exception & e) {
  337. throw std::runtime_error("Failed to parse tools: " + std::string(e.what()) + "; tools = " + tools.dump(2));
  338. }
  339. return result;
  340. }
  341. template <>
  342. std::vector<common_chat_tool> common_chat_tools_parse_oaicompat(const std::string & tools) {
  343. return common_chat_tools_parse_oaicompat(json::parse(tools));
  344. }
  345. template <>
  346. json common_chat_tools_to_json_oaicompat(const std::vector<common_chat_tool> & tools) {
  347. if (tools.empty()) {
  348. return json();
  349. }
  350. auto result = json::array();
  351. for (const auto & tool : tools) {
  352. result.push_back({
  353. {"type", "function"},
  354. {"function", {
  355. {"name", tool.name},
  356. {"description", tool.description},
  357. {"parameters", json::parse(tool.parameters)},
  358. }},
  359. });
  360. }
  361. return result;
  362. }
  363. template <> json common_chat_msg_diff_to_json_oaicompat(const common_chat_msg_diff & diff) {
  364. json delta = json::object();
  365. if (!diff.reasoning_content_delta.empty()) {
  366. delta["reasoning_content"] = diff.reasoning_content_delta;
  367. }
  368. if (!diff.content_delta.empty()) {
  369. delta["content"] = diff.content_delta;
  370. }
  371. if (diff.tool_call_index != std::string::npos) {
  372. json tool_call;
  373. tool_call["index"] = diff.tool_call_index;
  374. if (!diff.tool_call_delta.id.empty()) {
  375. tool_call["id"] = diff.tool_call_delta.id;
  376. tool_call["type"] = "function";
  377. }
  378. json function = json::object();
  379. if (!diff.tool_call_delta.name.empty()) {
  380. function["name"] = diff.tool_call_delta.name;
  381. }
  382. function["arguments"] = diff.tool_call_delta.arguments;
  383. tool_call["function"] = function;
  384. delta["tool_calls"] = json::array({tool_call});
  385. }
  386. return delta;
  387. }
  388. bool common_chat_verify_template(const std::string & tmpl, bool use_jinja) {
  389. if (use_jinja) {
  390. try {
  391. common_chat_msg msg;
  392. msg.role = "user";
  393. msg.content = "test";
  394. auto tmpls = common_chat_templates_init(/* model= */ nullptr, tmpl);
  395. common_chat_templates_inputs inputs;
  396. inputs.messages = {msg};
  397. common_chat_templates_apply(tmpls.get(), inputs);
  398. return true;
  399. } catch (const std::exception & e) {
  400. LOG_ERR("%s: failed to apply template: %s\n", __func__, e.what());
  401. return false;
  402. }
  403. }
  404. llama_chat_message chat[] = {{"user", "test"}};
  405. const int res = llama_chat_apply_template(tmpl.c_str(), chat, 1, true, nullptr, 0);
  406. return res >= 0;
  407. }
  408. std::string common_chat_format_single(
  409. const struct common_chat_templates * tmpls,
  410. const std::vector<common_chat_msg> & past_msg,
  411. const common_chat_msg & new_msg,
  412. bool add_ass,
  413. bool use_jinja) {
  414. common_chat_templates_inputs inputs;
  415. inputs.use_jinja = use_jinja;
  416. inputs.add_bos = tmpls->add_bos;
  417. inputs.add_eos = tmpls->add_eos;
  418. std::string fmt_past_msg;
  419. if (!past_msg.empty()) {
  420. inputs.messages = past_msg;
  421. inputs.add_generation_prompt = false;
  422. fmt_past_msg = common_chat_templates_apply(tmpls, inputs).prompt;
  423. }
  424. std::ostringstream ss;
  425. // if the past_msg ends with a newline, we must preserve it in the formatted version
  426. if (add_ass && !fmt_past_msg.empty() && fmt_past_msg.back() == '\n') {
  427. ss << "\n";
  428. };
  429. // format chat with new_msg
  430. inputs.messages.push_back(new_msg);
  431. inputs.add_generation_prompt = add_ass;
  432. auto fmt_new_msg = common_chat_templates_apply(tmpls, inputs).prompt;
  433. // get the diff part
  434. ss << fmt_new_msg.substr(fmt_past_msg.size(), fmt_new_msg.size() - fmt_past_msg.size());
  435. return ss.str();
  436. }
  437. std::string common_chat_format_example(const struct common_chat_templates * tmpls, bool use_jinja, const std::map<std::string, std::string> & chat_template_kwargs) {
  438. common_chat_templates_inputs inputs;
  439. inputs.use_jinja = use_jinja;
  440. inputs.add_bos = tmpls->add_bos;
  441. inputs.add_eos = tmpls->add_eos;
  442. inputs.chat_template_kwargs = chat_template_kwargs;
  443. auto add_simple_msg = [&](auto role, auto content) {
  444. common_chat_msg msg;
  445. msg.role = role;
  446. msg.content = content;
  447. inputs.messages.push_back(msg);
  448. };
  449. add_simple_msg("system", "You are a helpful assistant");
  450. add_simple_msg("user", "Hello");
  451. add_simple_msg("assistant", "Hi there");
  452. add_simple_msg("user", "How are you?");
  453. return common_chat_templates_apply(tmpls, inputs).prompt;
  454. }
  455. #define CHATML_TEMPLATE_SRC \
  456. "{%- for message in messages -%}\n" \
  457. " {{- '<|im_start|>' + message.role + '\n' + message.content + '<|im_end|>\n' -}}\n" \
  458. "{%- endfor -%}\n" \
  459. "{%- if add_generation_prompt -%}\n" \
  460. " {{- '<|im_start|>assistant\n' -}}\n" \
  461. "{%- endif -%}"
  462. void common_chat_templates_free(struct common_chat_templates * tmpls) {
  463. delete tmpls;
  464. }
  465. bool common_chat_templates_was_explicit(const struct common_chat_templates * tmpls) {
  466. return tmpls->has_explicit_template;
  467. }
  468. const char * common_chat_templates_source(const struct common_chat_templates * tmpls, const char * variant) {
  469. if (variant != nullptr) {
  470. if (strcmp(variant, "tool_use") == 0) {
  471. if (tmpls->template_tool_use) {
  472. return tmpls->template_tool_use->source().c_str();
  473. }
  474. return nullptr;
  475. } else {
  476. LOG_DBG("%s: unknown template variant: %s\n", __func__, variant);
  477. }
  478. }
  479. return tmpls->template_default->source().c_str();
  480. }
  481. common_chat_templates_ptr common_chat_templates_init(
  482. const struct llama_model * model,
  483. const std::string & chat_template_override,
  484. const std::string & bos_token_override,
  485. const std::string & eos_token_override)
  486. {
  487. std::string default_template_src;
  488. std::string template_tool_use_src;
  489. bool has_explicit_template = !chat_template_override.empty();
  490. if (chat_template_override.empty()) {
  491. GGML_ASSERT(model != nullptr);
  492. const auto * str = llama_model_chat_template(model, /* name */ nullptr);
  493. if (str) {
  494. default_template_src = str;
  495. has_explicit_template = true;
  496. }
  497. str = llama_model_chat_template(model, /* name */ "tool_use");
  498. if (str) {
  499. template_tool_use_src = str;
  500. has_explicit_template = true;
  501. }
  502. } else {
  503. default_template_src = chat_template_override;
  504. }
  505. if (default_template_src.empty() || default_template_src == "chatml") {
  506. if (!template_tool_use_src.empty()) {
  507. default_template_src = template_tool_use_src;
  508. } else {
  509. default_template_src = CHATML_TEMPLATE_SRC;
  510. }
  511. }
  512. // TODO @ngxson : this is a temporary hack to prevent chat template from throwing an error
  513. // Ref: https://github.com/ggml-org/llama.cpp/pull/15230#issuecomment-3173959633
  514. if (default_template_src.find("<|channel|>") != std::string::npos
  515. // search for the error message and patch it
  516. && default_template_src.find("in message.content or") != std::string::npos) {
  517. string_replace_all(default_template_src,
  518. "{%- if \"<|channel|>analysis<|message|>\" in message.content or \"<|channel|>final<|message|>\" in message.content %}",
  519. "{%- if false %}");
  520. }
  521. std::string token_bos = bos_token_override;
  522. std::string token_eos = eos_token_override;
  523. bool add_bos = false;
  524. bool add_eos = false;
  525. if (model) {
  526. const auto * vocab = llama_model_get_vocab(model);
  527. const auto get_token = [&](llama_token token, const char * name, const char * jinja_variable_name) {
  528. if (token == LLAMA_TOKEN_NULL) {
  529. if (default_template_src.find(jinja_variable_name) != std::string::npos
  530. || template_tool_use_src.find(jinja_variable_name) != std::string::npos) {
  531. LOG_WRN("common_chat_templates_init: warning: vocab does not have a %s token, jinja template won't work as intended.\n", name);
  532. }
  533. return std::string();
  534. }
  535. return common_token_to_piece(vocab, token, true);
  536. };
  537. token_bos = get_token(llama_vocab_bos(vocab), "BOS", "bos_token");
  538. token_eos = get_token(llama_vocab_eos(vocab), "EOS", "eos_token");
  539. add_bos = llama_vocab_get_add_bos(vocab);
  540. add_eos = llama_vocab_get_add_eos(vocab);
  541. }
  542. common_chat_templates_ptr tmpls(new common_chat_templates());
  543. tmpls->has_explicit_template = has_explicit_template;
  544. tmpls->add_bos = add_bos;
  545. tmpls->add_eos = add_eos;
  546. try {
  547. tmpls->template_default = std::make_unique<minja::chat_template>(default_template_src, token_bos, token_eos);
  548. } catch (const std::exception & e) {
  549. LOG_ERR("%s: failed to parse chat template (defaulting to chatml): %s \n", __func__, e.what());
  550. tmpls->template_default = std::make_unique<minja::chat_template>(CHATML_TEMPLATE_SRC, token_bos, token_eos);
  551. }
  552. if (!template_tool_use_src.empty()) {
  553. try {
  554. tmpls->template_tool_use = std::make_unique<minja::chat_template>(template_tool_use_src, token_bos, token_eos);
  555. } catch (const std::exception & e) {
  556. LOG_ERR("%s: failed to parse tool use chat template (ignoring it): %s\n", __func__, e.what());
  557. }
  558. }
  559. return tmpls;
  560. }
  561. const char * common_chat_format_name(common_chat_format format) {
  562. switch (format) {
  563. case COMMON_CHAT_FORMAT_CONTENT_ONLY: return "Content-only";
  564. case COMMON_CHAT_FORMAT_GENERIC: return "Generic";
  565. case COMMON_CHAT_FORMAT_MISTRAL_NEMO: return "Mistral Nemo";
  566. case COMMON_CHAT_FORMAT_LLAMA_3_X: return "Llama 3.x";
  567. case COMMON_CHAT_FORMAT_LLAMA_3_X_WITH_BUILTIN_TOOLS: return "Llama 3.x with builtin tools";
  568. case COMMON_CHAT_FORMAT_DEEPSEEK_R1: return "DeepSeek R1";
  569. case COMMON_CHAT_FORMAT_FIREFUNCTION_V2: return "FireFunction v2";
  570. case COMMON_CHAT_FORMAT_FUNCTIONARY_V3_2: return "Functionary v3.2";
  571. case COMMON_CHAT_FORMAT_FUNCTIONARY_V3_1_LLAMA_3_1: return "Functionary v3.1 Llama 3.1";
  572. case COMMON_CHAT_FORMAT_HERMES_2_PRO: return "Hermes 2 Pro";
  573. case COMMON_CHAT_FORMAT_COMMAND_R7B: return "Command R7B";
  574. case COMMON_CHAT_FORMAT_GRANITE: return "Granite";
  575. case COMMON_CHAT_FORMAT_GPT_OSS: return "GPT-OSS";
  576. case COMMON_CHAT_FORMAT_SEED_OSS: return "Seed-OSS";
  577. default:
  578. throw std::runtime_error("Unknown chat format");
  579. }
  580. }
  581. const char * common_reasoning_format_name(common_reasoning_format format) {
  582. switch (format) {
  583. case COMMON_REASONING_FORMAT_NONE: return "none";
  584. case COMMON_REASONING_FORMAT_AUTO: return "auto";
  585. case COMMON_REASONING_FORMAT_DEEPSEEK: return "deepseek";
  586. case COMMON_REASONING_FORMAT_DEEPSEEK_LEGACY: return "deepseek-legacy";
  587. default:
  588. throw std::runtime_error("Unknown reasoning format");
  589. }
  590. }
  591. common_reasoning_format common_reasoning_format_from_name(const std::string & format) {
  592. if (format == "none") {
  593. return COMMON_REASONING_FORMAT_NONE;
  594. } else if (format == "auto") {
  595. return COMMON_REASONING_FORMAT_AUTO;
  596. } else if (format == "deepseek") {
  597. return COMMON_REASONING_FORMAT_DEEPSEEK;
  598. } else if (format == "deepseek-legacy") {
  599. return COMMON_REASONING_FORMAT_DEEPSEEK_LEGACY;
  600. }
  601. throw std::runtime_error("Unknown reasoning format: " + format);
  602. }
  603. static std::string wrap_code_as_arguments(common_chat_msg_parser & builder, const std::string & code) {
  604. std::string arguments;
  605. if (builder.is_partial()) {
  606. arguments = (json {{"code", code + builder.healing_marker()}}).dump();
  607. auto idx = arguments.find(builder.healing_marker());
  608. if (idx != std::string::npos) {
  609. arguments.resize(idx);
  610. }
  611. } else {
  612. arguments = (json {{"code", code}}).dump();
  613. }
  614. return arguments;
  615. }
  616. /**
  617. * Takes a prefix regex that must have 1 group to capture the function name, a closing suffix, and expects json parameters in between.
  618. * Aggregates the prefix, suffix and in-between text into the content.
  619. */
  620. static void parse_json_tool_calls(
  621. common_chat_msg_parser & builder,
  622. const std::optional<common_regex> & block_open,
  623. const std::optional<common_regex> & function_regex_start_only,
  624. const std::optional<common_regex> & function_regex,
  625. const common_regex & close_regex,
  626. const std::optional<common_regex> & block_close,
  627. bool allow_raw_python = false,
  628. const std::function<std::string(const common_chat_msg_parser::find_regex_result & fres)> & get_function_name = nullptr) {
  629. auto parse_tool_calls = [&]() {
  630. size_t from = std::string::npos;
  631. auto first = true;
  632. while (true) {
  633. auto res = function_regex_start_only && first
  634. ? builder.try_consume_regex(*function_regex_start_only)
  635. : function_regex
  636. ? builder.try_find_regex(*function_regex, from)
  637. : std::nullopt;
  638. if (res) {
  639. std::string name;
  640. if (get_function_name) {
  641. name = get_function_name(*res);
  642. } else {
  643. GGML_ASSERT(res->groups.size() == 2);
  644. name = builder.str(res->groups[1]);
  645. }
  646. first = false;
  647. if (name.empty()) {
  648. // get_function_name signalled us that we should skip this match and treat it as content.
  649. from = res->groups[0].begin + 1;
  650. continue;
  651. }
  652. from = std::string::npos;
  653. auto maybe_raw_python = name == "python" && allow_raw_python;
  654. if (builder.input()[builder.pos()] == '{' || !maybe_raw_python) {
  655. if (auto arguments = builder.try_consume_json_with_dumped_args({{}})) {
  656. if (!builder.add_tool_call(name, "", arguments->value) || arguments->is_partial) {
  657. throw common_chat_msg_partial_exception("incomplete tool call");
  658. }
  659. builder.consume_regex(close_regex);
  660. }
  661. continue;
  662. }
  663. if (maybe_raw_python) {
  664. auto arguments = wrap_code_as_arguments(builder, builder.consume_rest());
  665. if (!builder.add_tool_call(name, "", arguments)) {
  666. throw common_chat_msg_partial_exception("incomplete tool call");
  667. }
  668. return;
  669. }
  670. throw common_chat_msg_partial_exception("incomplete tool call");
  671. }
  672. break;
  673. }
  674. if (block_close) {
  675. builder.consume_regex(*block_close);
  676. }
  677. builder.consume_spaces();
  678. builder.add_content(builder.consume_rest());
  679. };
  680. if (block_open) {
  681. if (auto res = builder.try_find_regex(*block_open)) {
  682. parse_tool_calls();
  683. } else {
  684. builder.add_content(builder.consume_rest());
  685. }
  686. } else {
  687. parse_tool_calls();
  688. }
  689. }
  690. static void parse_prefixed_json_tool_call_array(common_chat_msg_parser & builder, const common_regex & prefix, size_t rstrip_prefix = 0) {
  691. static const std::vector<std::vector<std::string>> args_paths = {{"arguments"}};
  692. if (auto res = builder.try_find_regex(prefix)) {
  693. builder.move_back(rstrip_prefix);
  694. auto tool_calls = builder.consume_json_with_dumped_args(args_paths);
  695. if (!builder.add_tool_calls(tool_calls.value) || tool_calls.is_partial) {
  696. throw common_chat_msg_partial_exception("incomplete tool call array");
  697. }
  698. } else {
  699. builder.add_content(builder.consume_rest());
  700. }
  701. }
  702. static void foreach_function(const json & tools, const std::function<void(const json &)> & fn) {
  703. for (const auto & tool : tools) {
  704. if (!tool.contains("type") || tool.at("type") != "function" || !tool.contains("function")) {
  705. LOG_INF("Skipping tool without function: %s", tool.dump(2).c_str());
  706. continue;
  707. }
  708. fn(tool);
  709. }
  710. }
  711. static std::string apply(
  712. const common_chat_template & tmpl,
  713. const struct templates_params & inputs,
  714. const std::optional<json> & messages_override = std::nullopt,
  715. const std::optional<json> & tools_override = std::nullopt,
  716. const std::optional<json> & additional_context = std::nullopt)
  717. {
  718. minja::chat_template_inputs tmpl_inputs;
  719. tmpl_inputs.messages = messages_override ? *messages_override : inputs.messages;
  720. if (tools_override) {
  721. tmpl_inputs.tools = *tools_override;
  722. } else {
  723. tmpl_inputs.tools = inputs.tools.empty() ? json() : inputs.tools;
  724. }
  725. tmpl_inputs.add_generation_prompt = inputs.add_generation_prompt;
  726. tmpl_inputs.extra_context = inputs.extra_context;
  727. if (additional_context) {
  728. tmpl_inputs.extra_context.merge_patch(*additional_context);
  729. }
  730. // TODO: add flag to control date/time, if only for testing purposes.
  731. // tmpl_inputs.now = std::chrono::system_clock::now();
  732. minja::chat_template_options tmpl_opts;
  733. // To avoid double BOS / EOS tokens, we're manually removing begining / trailing tokens
  734. // instead of using `chat_template_options.use_bos_token = false`, since these tokens
  735. // may be needed inside the template / between messages too.
  736. auto result = tmpl.apply(tmpl_inputs, tmpl_opts);
  737. if (inputs.add_bos && string_starts_with(result, tmpl.bos_token())) {
  738. result = result.substr(tmpl.bos_token().size());
  739. }
  740. if (inputs.add_eos && string_ends_with(result, tmpl.eos_token())) {
  741. result = result.substr(0, result.size() - tmpl.eos_token().size());
  742. }
  743. return result;
  744. }
  745. static common_chat_params common_chat_params_init_generic(const common_chat_template & tmpl, const struct templates_params & inputs) {
  746. common_chat_params data;
  747. auto tool_call_schemas = json::array();
  748. foreach_function(inputs.tools, [&](const json & tool) {
  749. const auto & function = tool.at("function");
  750. auto tool_schema = json {
  751. {"type", "object"},
  752. {"properties", {
  753. {"name", {
  754. {"type", "string"},
  755. {"const", function.at("name")},
  756. }},
  757. {"arguments", function.at("parameters")},
  758. }},
  759. {"required", json::array({"name", "arguments"})},
  760. };
  761. if (function.contains("description")) {
  762. tool_schema["description"] = function.at("description");
  763. }
  764. if (inputs.parallel_tool_calls) {
  765. tool_schema.at("properties")["id"] = {
  766. {"type", "string"},
  767. {"minLength", 4},
  768. };
  769. tool_schema.at("required").push_back("id");
  770. }
  771. tool_call_schemas.emplace_back(tool_schema);
  772. });
  773. const auto tool_call =
  774. inputs.parallel_tool_calls
  775. ? json {
  776. {"type", "object"},
  777. {"properties", {
  778. {"tool_calls", {
  779. {"type", "array"},
  780. {"items", tool_call_schemas.size() == 1 ? tool_call_schemas[0] : json {
  781. {"anyOf", tool_call_schemas},
  782. }},
  783. {"minItems", 1},
  784. }},
  785. }},
  786. {"required", json::array({"tool_calls"})},
  787. }
  788. : json {
  789. {"type", "object"},
  790. {"properties", {
  791. {"tool_call", tool_call_schemas.size() == 1 ? tool_call_schemas[0] : json {
  792. {"anyOf", tool_call_schemas},
  793. }},
  794. }},
  795. {"required", json::array({"tool_call"})},
  796. };
  797. const auto schema =
  798. inputs.tool_choice != COMMON_CHAT_TOOL_CHOICE_REQUIRED
  799. ? json {
  800. {"anyOf", json::array({
  801. tool_call,
  802. {
  803. {"type", "object"},
  804. {"properties", {
  805. {"response", inputs.json_schema.is_null()
  806. ? json {{"type", "string"}}
  807. : inputs.json_schema
  808. },
  809. }},
  810. {"required", json::array({"response"})},
  811. },
  812. })}
  813. }
  814. : tool_call;
  815. data.grammar_lazy = false;
  816. data.grammar = build_grammar([&](const common_grammar_builder & builder) {
  817. builder.add_schema("root", schema);
  818. });
  819. auto tweaked_messages = common_chat_template::add_system(
  820. inputs.messages,
  821. "Respond in JSON format, either with `tool_call` (a request to call tools) or with `response` reply to the user's request");
  822. data.prompt = apply(tmpl, inputs, /* messages_override= */ tweaked_messages);
  823. data.format = COMMON_CHAT_FORMAT_GENERIC;
  824. return data;
  825. }
  826. static void common_chat_parse_generic(common_chat_msg_parser & builder) {
  827. if (!builder.syntax().parse_tool_calls) {
  828. builder.add_content(builder.consume_rest());
  829. return;
  830. }
  831. static const std::vector<std::vector<std::string>> content_paths = {
  832. {"response"},
  833. };
  834. static const std::vector<std::vector<std::string>> args_paths = {
  835. {"tool_call", "arguments"},
  836. {"tool_calls", "arguments"},
  837. };
  838. auto data = builder.consume_json_with_dumped_args(args_paths, content_paths);
  839. if (data.value.contains("tool_calls")) {
  840. if (!builder.add_tool_calls(data.value.at("tool_calls")) || data.is_partial) {
  841. throw common_chat_msg_partial_exception("incomplete tool calls");
  842. }
  843. } else if (data.value.contains("tool_call")) {
  844. if (!builder.add_tool_call(data.value.at("tool_call")) || data.is_partial) {
  845. throw common_chat_msg_partial_exception("incomplete tool call");
  846. }
  847. } else if (data.value.contains("response")) {
  848. const auto & response = data.value.at("response");
  849. builder.add_content(response.is_string() ? response.template get<std::string>() : response.dump(2));
  850. if (data.is_partial) {
  851. throw common_chat_msg_partial_exception("incomplete response");
  852. }
  853. } else {
  854. throw common_chat_msg_partial_exception("Expected 'tool_call', 'tool_calls' or 'response' in JSON");
  855. }
  856. }
  857. static common_chat_params common_chat_params_init_mistral_nemo(const common_chat_template & tmpl, const struct templates_params & inputs) {
  858. common_chat_params data;
  859. data.grammar_lazy = inputs.tool_choice != COMMON_CHAT_TOOL_CHOICE_REQUIRED;
  860. data.grammar = build_grammar([&](const common_grammar_builder & builder) {
  861. auto schemas = json::array();
  862. foreach_function(inputs.tools, [&](const json & tool) {
  863. const auto & function = tool.at("function");
  864. schemas.push_back({
  865. {"type", "object"},
  866. {"properties", {
  867. // Important note: the model is probably trained to take a JSON stringified arguments value.
  868. // It's hard to constrain that for now (while reusing the JSON schema conversion), so we're just expecting a plain object.
  869. {"name", {
  870. {"type", "string"},
  871. {"const", function.at("name")},
  872. }},
  873. {"arguments", function.at("parameters")},
  874. {"id", {
  875. {"type", "string"},
  876. // Nemo's template expects a 9-character alphanumeric ID.
  877. {"pattern", "^[a-zA-Z0-9]{9}$"},
  878. }},
  879. }},
  880. {"required", json::array({"name", "arguments", "id"})},
  881. });
  882. });
  883. auto schema = json {
  884. {"type", "array"},
  885. {"items", schemas.size() == 1 ? schemas[0] : json {{"anyOf", schemas}}},
  886. {"minItems", 1},
  887. };
  888. if (!inputs.parallel_tool_calls) {
  889. schema["maxItems"] = 1;
  890. }
  891. builder.add_rule("root", "\"[TOOL_CALLS]\" " + builder.add_schema("tool_calls", schema));
  892. });
  893. data.grammar_triggers.push_back({COMMON_GRAMMAR_TRIGGER_TYPE_WORD, "[TOOL_CALLS]"});
  894. data.preserved_tokens = {
  895. "[TOOL_CALLS]",
  896. };
  897. data.prompt = apply(tmpl, inputs);
  898. data.format = COMMON_CHAT_FORMAT_MISTRAL_NEMO;
  899. return data;
  900. }
  901. static void common_chat_parse_mistral_nemo(common_chat_msg_parser & builder) {
  902. if (!builder.syntax().parse_tool_calls) {
  903. builder.add_content(builder.consume_rest());
  904. return;
  905. }
  906. static const common_regex prefix(regex_escape("[TOOL_CALLS]"));
  907. parse_prefixed_json_tool_call_array(builder, prefix);
  908. }
  909. static common_chat_params common_chat_params_init_command_r7b(const common_chat_template & tmpl, const struct templates_params & inputs) {
  910. common_chat_params data;
  911. auto adjusted_messages = json::array();
  912. for (const auto & msg : inputs.messages) {
  913. auto has_reasoning_content = msg.contains("reasoning_content") && msg.at("reasoning_content").is_string();
  914. auto has_tool_calls = msg.contains("tool_calls") && msg.at("tool_calls").is_array();
  915. if (has_reasoning_content && has_tool_calls) {
  916. auto adjusted_message = msg;
  917. adjusted_message["tool_plan"] = msg.at("reasoning_content");
  918. adjusted_message.erase("reasoning_content");
  919. adjusted_messages.push_back(adjusted_message);
  920. } else {
  921. adjusted_messages.push_back(msg);
  922. }
  923. }
  924. data.prompt = apply(tmpl, inputs, /* messages_override= */ adjusted_messages);
  925. data.format = COMMON_CHAT_FORMAT_COMMAND_R7B;
  926. if (string_ends_with(data.prompt, "<|START_THINKING|>")) {
  927. if (!inputs.enable_thinking) {
  928. data.prompt += "<|END_THINKING|>";
  929. } else {
  930. data.thinking_forced_open = true;
  931. }
  932. } else if (!inputs.enable_thinking && string_ends_with(data.prompt, "<|CHATBOT_TOKEN|>")) {
  933. data.prompt += "<|START_THINKING|><|END_THINKING|>";
  934. }
  935. data.grammar_lazy = inputs.tool_choice != COMMON_CHAT_TOOL_CHOICE_REQUIRED;
  936. data.grammar = build_grammar([&](const common_grammar_builder & builder) {
  937. auto schemas = json::array();
  938. foreach_function(inputs.tools, [&](const json & tool) {
  939. const auto & function = tool.at("function");
  940. schemas.push_back({
  941. {"type", "object"},
  942. {"properties", {
  943. {"tool_call_id", {
  944. {"type", "string"},
  945. // Command-R's template expects an integer string.
  946. {"pattern", "^[0-9]{1,10}$"},
  947. }},
  948. {"tool_name", {
  949. {"type", "string"},
  950. {"const", function.at("name")},
  951. }},
  952. {"parameters", function.at("parameters")},
  953. }},
  954. {"required", json::array({"tool_call_id", "tool_name", "parameters"})},
  955. });
  956. });
  957. auto schema = json {
  958. {"type", "array"},
  959. {"items", schemas.size() == 1 ? schemas[0] : json {{"anyOf", schemas}}},
  960. {"minItems", 1},
  961. };
  962. if (!inputs.parallel_tool_calls) {
  963. schema["maxItems"] = 1;
  964. }
  965. builder.add_rule("root",
  966. std::string(data.thinking_forced_open ? "( \"<|END_THINKING|>\" space )? " : "") +
  967. "\"<|START_ACTION|>\" " + builder.add_schema("tool_calls", schema) + " \"<|END_ACTION|>\"");
  968. });
  969. data.grammar_triggers.push_back({
  970. COMMON_GRAMMAR_TRIGGER_TYPE_PATTERN_FULL,
  971. // If thinking_forced_open, then we capture the </think> tag in the grammar,
  972. // (important for required tool choice) and in the trigger's first capture (decides what is sent to the grammar)
  973. std::string(data.thinking_forced_open ? "[\\s\\S]*?(<\\|END_THINKING\\|>\\s*)" : "(?:<\\|START_THINKING\\|>[\\s\\S]*?<\\|END_THINKING\\|>\\s*)?") +
  974. "(<\\|START_ACTION\\|>)[\\s\\S]*"
  975. });
  976. data.preserved_tokens = {
  977. "<|START_ACTION|>",
  978. "<|END_ACTION|>",
  979. "<|START_RESPONSE|>",
  980. "<|END_RESPONSE|>",
  981. "<|START_THINKING|>",
  982. "<|END_THINKING|>",
  983. };
  984. return data;
  985. }
  986. static void common_chat_parse_command_r7b(common_chat_msg_parser & builder) {
  987. builder.try_parse_reasoning("<|START_THINKING|>", "<|END_THINKING|>");
  988. static const common_regex start_action_regex("<\\|START_ACTION\\|>");
  989. static const common_regex end_action_regex("<\\|END_ACTION\\|>");
  990. static const common_regex start_response_regex("<\\|START_RESPONSE\\|>");
  991. static const common_regex end_response_regex("<\\|END_RESPONSE\\|>");
  992. if (auto res = builder.try_find_regex(start_action_regex)) {
  993. // If we didn't extract thoughts, prelude includes them.
  994. auto tool_calls = builder.consume_json_with_dumped_args({{"parameters"}});
  995. for (const auto & tool_call : tool_calls.value) {
  996. std::string name = tool_call.contains("tool_name") ? tool_call.at("tool_name") : "";
  997. std::string id = tool_call.contains("tool_call_id") ? tool_call.at("tool_call_id") : "";
  998. std::string arguments = tool_call.contains("parameters") ? tool_call.at("parameters") : "";
  999. if (!builder.add_tool_call(name, id, arguments) || tool_calls.is_partial) {
  1000. throw common_chat_msg_partial_exception("incomplete tool call");
  1001. }
  1002. }
  1003. if (tool_calls.is_partial) {
  1004. throw common_chat_msg_partial_exception("incomplete tool call");
  1005. }
  1006. builder.consume_regex(end_action_regex);
  1007. } else if (auto res = builder.try_find_regex(start_response_regex)) {
  1008. if (!builder.try_find_regex(end_response_regex)) {
  1009. builder.add_content(builder.consume_rest());
  1010. throw common_chat_msg_partial_exception(end_response_regex.str());
  1011. }
  1012. } else {
  1013. builder.add_content(builder.consume_rest());
  1014. }
  1015. }
  1016. static void expect_tool_parameters(const std::string & name, const json & parameters, const std::vector<std::string> & expected_properties) {
  1017. if (!parameters.is_object() || !parameters.contains("type") || parameters.at("type") != "object" || !parameters.contains("properties") || !parameters.contains("required")) {
  1018. throw std::runtime_error("Parameters of tool " + name + " must be an object w/ required properties");
  1019. }
  1020. const auto & parameters_properties = parameters.at("properties");
  1021. const auto & parameters_required = parameters.at("required");
  1022. for (const auto & prop : expected_properties) {
  1023. if (!parameters_properties.contains(prop)) {
  1024. throw std::runtime_error("Parameters of tool " + name + " is missing property: " + prop); // NOLINT
  1025. }
  1026. if (std::find(parameters_required.begin(), parameters_required.end(), json(prop)) == parameters_required.end()) {
  1027. throw std::runtime_error("Parameters of tool " + name + " must have property marked as required: " + prop); // NOLINT
  1028. }
  1029. }
  1030. if (parameters_properties.size() != expected_properties.size()) {
  1031. throw std::runtime_error("Parameters of tool " + name + " must only have these properties:" + string_join(expected_properties, ", "));
  1032. }
  1033. }
  1034. static common_chat_params common_chat_params_init_llama_3_x(const common_chat_template & tmpl, const struct templates_params & inputs, bool allow_python_tag_builtin_tools) {
  1035. auto builtin_tools = json::array();
  1036. common_chat_params data;
  1037. if (!inputs.tools.is_null()) {
  1038. data.grammar_lazy = inputs.tool_choice != COMMON_CHAT_TOOL_CHOICE_REQUIRED;
  1039. data.grammar = build_grammar([&](const common_grammar_builder & builder) {
  1040. std::vector<std::string> tool_rules;
  1041. auto handle_builtin_tool = [&](const std::string & name, const json & parameters) {
  1042. if (name == "wolfram_alpha" || name == "web_search" || name == "brave_search") {
  1043. // https://github.com/meta-llama/llama-stack/blob/main/llama_stack/providers/remote/tool_runtime/wolfram_alpha/wolfram_alpha.py
  1044. // https://github.com/meta-llama/llama-stack/blob/main/llama_stack/providers/remote/tool_runtime/brave_search/brave_search.py
  1045. expect_tool_parameters(name, parameters, {"query"});
  1046. } else if (name == "python" || name == "code_interpreter") {
  1047. // https://github.com/meta-llama/llama-stack/blob/main/llama_stack/providers/inline/tool_runtime/code_interpreter/code_interpreter.py
  1048. expect_tool_parameters(name, parameters, {"code"});
  1049. } else {
  1050. return false;
  1051. }
  1052. std::vector<std::string> kvs;
  1053. for (const auto & [key, value] : parameters.at("properties").items()) {
  1054. kvs.push_back("\"" + key + "=\" " + builder.add_schema(name + "-args-" + key, value)); // NOLINT
  1055. }
  1056. tool_rules.push_back(
  1057. builder.add_rule(
  1058. name + "-call",
  1059. "\"<|python_tag|>" + name + ".call(\" " + string_join(kvs, " \", \" ") + " \")\""));
  1060. builtin_tools.push_back(name);
  1061. return true;
  1062. };
  1063. foreach_function(inputs.tools, [&](const json & tool) {
  1064. const auto & function = tool.at("function");
  1065. std::string name = function.at("name");
  1066. auto parameters = function.at("parameters");
  1067. builder.resolve_refs(parameters);
  1068. // https://github.com/meta-llama/llama-stack/tree/main/llama_stack/providers/remote/tool_runtime
  1069. if (allow_python_tag_builtin_tools) {
  1070. handle_builtin_tool(name, parameters);
  1071. }
  1072. tool_rules.push_back(
  1073. builder.add_rule(
  1074. name + "-call",
  1075. "\"{\" space "
  1076. "( \"\\\"type\\\"\" space \":\" space \"\\\"function\\\"\" space \",\" space )? "
  1077. " \"\\\"name\\\"\" space \":\" space \"\\\"" + name + "\\\"\" space \",\" space "
  1078. " \"\\\"parameters\\\"\" space \":\" space " + builder.add_schema(name + "-args", parameters) + " "
  1079. "\"}\" space"));
  1080. });
  1081. // Small models may hallucinate function names so we match anything (*at the start*) that looks like the JSON of a function call, regardless of the name.
  1082. data.grammar_triggers.push_back({
  1083. COMMON_GRAMMAR_TRIGGER_TYPE_PATTERN_FULL,
  1084. "(\\{\\s*(?:\"type\"\\s*:\\s*\"function\"\\s*,\\s*)?\"name\"\\s*:\\s*\")[\\s\\S]*", // + name + "\"[\\s\\S]*",
  1085. });
  1086. if (!builtin_tools.empty()) {
  1087. data.grammar_triggers.push_back({COMMON_GRAMMAR_TRIGGER_TYPE_WORD, "<|python_tag|>"});
  1088. data.preserved_tokens.push_back("<|python_tag|>");
  1089. }
  1090. // Allow a few empty lines on top of the usual constrained json schema space rule.
  1091. builder.add_rule("root", string_join(tool_rules, " | "));
  1092. data.additional_stops.push_back("<|eom_id|>");
  1093. });
  1094. data.format = allow_python_tag_builtin_tools && !builtin_tools.empty()
  1095. ? COMMON_CHAT_FORMAT_LLAMA_3_X_WITH_BUILTIN_TOOLS
  1096. : COMMON_CHAT_FORMAT_LLAMA_3_X;
  1097. } else {
  1098. data.format = COMMON_CHAT_FORMAT_CONTENT_ONLY;
  1099. }
  1100. data.prompt = apply(tmpl, inputs, /* messages_override =*/ std::nullopt, /* tools_override= */ std::nullopt, json {
  1101. {"date_string", format_time(inputs.now, "%d %b %Y")},
  1102. {"tools_in_user_message", false},
  1103. {"builtin_tools", builtin_tools.empty() ? json() : builtin_tools},
  1104. });
  1105. return data;
  1106. }
  1107. static void common_chat_parse_llama_3_1(common_chat_msg_parser & builder, bool with_builtin_tools = false) {
  1108. if (!builder.syntax().parse_tool_calls) {
  1109. builder.add_content(builder.consume_rest());
  1110. return;
  1111. }
  1112. static const common_regex function_regex(
  1113. "\\s*\\{\\s*(?:\"type\"\\s*:\\s*\"function\"\\s*,\\s*)?\"name\"\\s*:\\s*\"([^\"]+)\"\\s*,\\s*\"parameters\"\\s*: ");
  1114. static const common_regex close_regex("\\}\\s*");
  1115. static const common_regex function_name_regex("\\s*(\\w+)\\s*\\.\\s*call\\(");
  1116. static const common_regex arg_name_regex("\\s*(\\w+)\\s*=\\s*");
  1117. if (with_builtin_tools) {
  1118. static const common_regex builtin_call_regex("<\\|python_tag\\|>");
  1119. if (auto res = builder.try_find_regex(builtin_call_regex)) {
  1120. auto fun_res = builder.consume_regex(function_name_regex);
  1121. auto function_name = builder.str(fun_res.groups[1]);
  1122. common_healing_marker healing_marker;
  1123. json args = json::object();
  1124. while (true) {
  1125. if (auto arg_res = builder.try_consume_regex(arg_name_regex)) {
  1126. auto arg_name = builder.str(arg_res->groups[1]);
  1127. auto partial = builder.consume_json();
  1128. args[arg_name] = partial.json;
  1129. healing_marker.marker = partial.healing_marker.marker;
  1130. healing_marker.json_dump_marker = partial.healing_marker.json_dump_marker;
  1131. builder.consume_spaces();
  1132. if (!builder.try_consume_literal(",")) {
  1133. break;
  1134. }
  1135. } else {
  1136. break;
  1137. }
  1138. }
  1139. builder.consume_literal(")");
  1140. builder.consume_spaces();
  1141. auto arguments = args.dump();
  1142. if (!builder.add_tool_call(function_name, "", arguments)) {
  1143. throw common_chat_msg_partial_exception("Incomplete tool call");
  1144. }
  1145. return;
  1146. }
  1147. }
  1148. parse_json_tool_calls(
  1149. builder,
  1150. /* block_open= */ std::nullopt,
  1151. /* function_regex_start_only= */ function_regex,
  1152. /* function_regex= */ std::nullopt,
  1153. close_regex,
  1154. std::nullopt);
  1155. }
  1156. static common_chat_params common_chat_params_init_deepseek_r1(const common_chat_template & tmpl, const struct templates_params & inputs) {
  1157. common_chat_params data;
  1158. auto prompt = apply(tmpl, inputs);
  1159. // Hacks to fix the official (broken) prompt.
  1160. // It is advisable to use --chat-template-file models/templates/llama-cpp-deepseek-r1.jinja instead,
  1161. // until the official template is fixed.
  1162. if (tmpl.source().find("{% if ns.is_tool %}{{'<|tool▁outputs▁end|>'}}") != std::string::npos) {
  1163. // Don't leave the chat dangling after tool results
  1164. if (string_ends_with(prompt, "<|tool▁outputs▁end|>")) {
  1165. prompt += "<|end▁of▁sentence|>";
  1166. if (inputs.add_generation_prompt) {
  1167. prompt += "<|Assistant|>";
  1168. }
  1169. }
  1170. // Fix up tool call delta example added by Minja
  1171. prompt = std::regex_replace(
  1172. prompt,
  1173. std::regex("(<|tool▁call▁end|>)[\\s\\r\\n]*(<|tool▁outputs▁begin|>|<|User|>)"),
  1174. "$1<|tool▁calls▁end|><|end▁of▁sentence|>$2");
  1175. }
  1176. data.prompt = prompt;
  1177. data.format = COMMON_CHAT_FORMAT_DEEPSEEK_R1;
  1178. if (string_ends_with(data.prompt, "<think>\n")) {
  1179. if (!inputs.enable_thinking) {
  1180. data.prompt += "</think>";
  1181. } else {
  1182. data.thinking_forced_open = true;
  1183. }
  1184. }
  1185. if (inputs.tools.is_array() && !inputs.tools.empty()) {
  1186. data.grammar_lazy = inputs.tool_choice != COMMON_CHAT_TOOL_CHOICE_REQUIRED && inputs.json_schema.is_null();
  1187. data.grammar = build_grammar([&](const common_grammar_builder & builder) {
  1188. std::vector<std::string> tool_rules;
  1189. foreach_function(inputs.tools, [&](const json & tool) {
  1190. const auto & function = tool.at("function");
  1191. std::string name = function.at("name");
  1192. auto parameters = function.at("parameters");
  1193. builder.resolve_refs(parameters);
  1194. tool_rules.push_back(builder.add_rule(name + "-call",
  1195. "( \"<|tool▁call▁begin|>\" )? \"function<|tool▁sep|>" + name + "\\n"
  1196. "```json\\n\" " + builder.add_schema(name + "-args", parameters) + " "
  1197. "\"```<|tool▁call▁end|>\""));
  1198. });
  1199. // Distill Qwen 7B & 32B models seem confused re/ syntax of their tool call opening tag,
  1200. // so we accept common variants (then it's all constrained)
  1201. builder.add_rule("root",
  1202. std::string(data.thinking_forced_open ? "( \"</think>\" space )? " : "") +
  1203. "( \"<|tool▁calls▁begin|>\" | \"<|tool_calls_begin|>\" | \"<|tool calls begin|>\" | \"<|tool\\\\_calls\\\\_begin|>\" | \"<|tool▁calls|>\" ) "
  1204. "(" + string_join(tool_rules, " | ") + ")" + (inputs.parallel_tool_calls ? "*" : "") + " "
  1205. "\"<|tool▁calls▁end|>\""
  1206. " space");
  1207. data.grammar_triggers.push_back({
  1208. COMMON_GRAMMAR_TRIGGER_TYPE_PATTERN_FULL,
  1209. // If thinking_forced_open, then we capture the </think> tag in the grammar,
  1210. // (important for required tool choice) and in the trigger's first capture (decides what is sent to the grammar)
  1211. std::string(data.thinking_forced_open ? "[\\s\\S]*?(</think>\\s*)" : "(?:<think>[\\s\\S]*?</think>\\s*)?") +
  1212. "(<|tool▁calls▁begin|>|<|tool_calls_begin|>|<|tool calls begin|>|<|tool\\\\_calls\\\\_begin|>|<|tool▁calls|>)[\\s\\S]*"
  1213. });
  1214. data.preserved_tokens = {
  1215. "<think>",
  1216. "</think>",
  1217. "<|tool▁calls▁begin|>",
  1218. "<|tool▁call▁begin|>",
  1219. "<|tool▁sep|>",
  1220. "<|tool▁call▁end|>",
  1221. "<|tool▁calls▁end|",
  1222. };
  1223. });
  1224. }
  1225. return data;
  1226. }
  1227. static void common_chat_parse_deepseek_r1(common_chat_msg_parser & builder) {
  1228. builder.try_parse_reasoning("<think>", "</think>");
  1229. if (!builder.syntax().parse_tool_calls) {
  1230. builder.add_content(builder.consume_rest());
  1231. return;
  1232. }
  1233. static const common_regex tool_calls_begin("(?:<|tool▁calls▁begin|>|<|tool_calls_begin|>|<|tool calls begin|>|<|tool\\\\_calls\\\\_begin|>|<|tool▁calls|>)");
  1234. static const common_regex tool_calls_end("<|tool▁calls▁end|>");
  1235. static const common_regex function_regex("(?:<|tool▁call▁begin|>)?function<|tool▁sep|>([^\n]+)\n```json\n");
  1236. static const common_regex close_regex("```[\\s\\r\\n]*<|tool▁call▁end|>");
  1237. parse_json_tool_calls(
  1238. builder,
  1239. /* block_open= */ tool_calls_begin,
  1240. /* function_regex_start_only= */ std::nullopt,
  1241. function_regex,
  1242. close_regex,
  1243. tool_calls_end);
  1244. }
  1245. static common_chat_params common_chat_params_init_gpt_oss(const common_chat_template & tmpl, const struct templates_params & inputs) {
  1246. common_chat_params data;
  1247. auto prompt = apply(tmpl, inputs);
  1248. // Check if we need to replace the return token with end token during
  1249. // inference and without generation prompt. For more details see:
  1250. // https://github.com/ggml-org/llama.cpp/issues/15417
  1251. if (inputs.is_inference && !inputs.add_generation_prompt) {
  1252. static constexpr std::string_view return_token = "<|return|>";
  1253. static constexpr std::string_view end_token = "<|end|>";
  1254. if (size_t pos = prompt.rfind(return_token); pos != std::string::npos) {
  1255. prompt.replace(pos, return_token.length(), end_token);
  1256. }
  1257. }
  1258. data.prompt = prompt;
  1259. data.format = COMMON_CHAT_FORMAT_GPT_OSS;
  1260. // These special tokens are required to parse properly, so we include them
  1261. // even if parse_tool_calls is false.
  1262. data.preserved_tokens = {
  1263. "<|channel|>",
  1264. "<|constrain|>",
  1265. "<|message|>",
  1266. "<|start|>",
  1267. "<|end|>",
  1268. };
  1269. if (!inputs.json_schema.is_null()) {
  1270. data.grammar_lazy = false;
  1271. data.grammar = build_grammar([&](const common_grammar_builder & builder) {
  1272. auto schema = inputs.json_schema;
  1273. builder.resolve_refs(schema);
  1274. auto not_end = builder.add_rule("not-end",
  1275. "[^<] | \"<\" [^|] | \"<|\" [^e] | \"<|e\" [^n] | \"<|en\" [^d] | \"<|end\" [^|] | \"<|end|\" [^>]");
  1276. auto analysis = builder.add_rule("analysis",
  1277. "\"<|channel|>analysis<|message|>\" ( " + not_end + " )* \"<|end|>\"");
  1278. auto constraint = builder.add_rule("constraint", "\"<|constrain|>\"? [a-zA-Z0-9_-]+");
  1279. auto final = builder.add_rule("final",
  1280. "\"<|channel|>final\" ( \" \" " + constraint + " )? \"<|message|>\" " +
  1281. builder.add_schema("response", schema)
  1282. );
  1283. builder.add_rule("root", "( " + analysis + " \"<|start|>assistant\" )? " + final);
  1284. });
  1285. }
  1286. if (inputs.tools.is_array() && !inputs.tools.empty()) {
  1287. data.grammar_lazy = inputs.tool_choice != COMMON_CHAT_TOOL_CHOICE_REQUIRED;
  1288. data.grammar = build_grammar([&](const common_grammar_builder & builder) {
  1289. // tool calls can appear in commentary or analysis channels
  1290. auto channel = builder.add_rule("channel", "\"<|channel|>\" ( \"commentary\" | \"analysis\" )");
  1291. std::vector<std::string> tool_rules_recipient_in_role;
  1292. std::vector<std::string> tool_rules_recipient_in_channel;
  1293. foreach_function(inputs.tools, [&](const json & tool) {
  1294. const auto & function = tool.at("function");
  1295. std::string name = function.at("name");
  1296. auto parameters = function.at("parameters");
  1297. builder.resolve_refs(parameters);
  1298. tool_rules_recipient_in_role.push_back(
  1299. builder.add_rule(name + "-call",
  1300. "\"" + name + "\"" + channel + " \" <|constrain|>json\"? \"<|message|>\" " +
  1301. builder.add_schema(name + "-args", parameters)
  1302. )
  1303. );
  1304. tool_rules_recipient_in_channel.push_back(
  1305. builder.add_rule(name + "-call",
  1306. "\"" + name + "\"" + " \" <|constrain|>json\"? \"<|message|>\" " +
  1307. builder.add_schema(name + "-args", parameters)
  1308. )
  1309. );
  1310. });
  1311. auto recipient_in_role = builder.add_rule("recipient_in_role",
  1312. "\"<|start|>assistant\"? \" to=functions.\" ( " +
  1313. string_join(tool_rules_recipient_in_role, " | ") + " )"
  1314. );
  1315. auto recipient_in_channel = builder.add_rule("recipient_in_channel",
  1316. channel + " \" to=functions.\" ( " +
  1317. string_join(tool_rules_recipient_in_channel, " | ") + " )"
  1318. );
  1319. builder.add_rule("root", recipient_in_role + " | " + recipient_in_channel);
  1320. // Trigger on tool calls that appear in the commentary channel
  1321. data.grammar_triggers.push_back({
  1322. COMMON_GRAMMAR_TRIGGER_TYPE_PATTERN,
  1323. "<\\|channel\\|>(commentary|analysis) to"
  1324. });
  1325. // Trigger tool calls that appear in the role section, either at the
  1326. // start or in the middle.
  1327. data.grammar_triggers.push_back({
  1328. COMMON_GRAMMAR_TRIGGER_TYPE_PATTERN_FULL,
  1329. "^ to"
  1330. });
  1331. data.grammar_triggers.push_back({
  1332. COMMON_GRAMMAR_TRIGGER_TYPE_PATTERN,
  1333. "<\\|start\\|>assistant to"
  1334. });
  1335. });
  1336. }
  1337. return data;
  1338. }
  1339. static void common_chat_parse_gpt_oss(common_chat_msg_parser & builder) {
  1340. static const std::string constraint = "(?: (<\\|constrain\\|>)?([a-zA-Z0-9_-]+))";
  1341. static const std::string recipient("(?: to=functions\\.([^<\\s]+))");
  1342. static const common_regex start_regex("<\\|start\\|>assistant");
  1343. static const common_regex analysis_regex("<\\|channel\\|>analysis");
  1344. static const common_regex final_regex("<\\|channel\\|>final" + constraint + "?");
  1345. static const common_regex preamble_regex("<\\|channel\\|>commentary");
  1346. static const common_regex tool_call1_regex(recipient + "<\\|channel\\|>(analysis|commentary)" + constraint + "?");
  1347. static const common_regex tool_call2_regex("<\\|channel\\|>(analysis|commentary)" + recipient + constraint + "?");
  1348. auto consume_end = [&](bool include_end = false) {
  1349. if (auto res = builder.try_find_literal("<|end|>")) {
  1350. return res->prelude + (include_end ? builder.str(res->groups[0]) : "");
  1351. }
  1352. return builder.consume_rest();
  1353. };
  1354. auto handle_tool_call = [&](const std::string & name) {
  1355. if (auto args = builder.try_consume_json_with_dumped_args({{}})) {
  1356. if (builder.syntax().parse_tool_calls) {
  1357. if (!builder.add_tool_call(name, "", args->value) || args->is_partial) {
  1358. throw common_chat_msg_partial_exception("incomplete tool call");
  1359. }
  1360. } else if (args->is_partial) {
  1361. throw common_chat_msg_partial_exception("incomplete tool call");
  1362. }
  1363. }
  1364. };
  1365. auto regex_match = [](const common_regex & regex, const std::string & input) -> std::optional<common_regex_match> {
  1366. auto match = regex.search(input, 0, true);
  1367. if (match.type == COMMON_REGEX_MATCH_TYPE_FULL) {
  1368. return match;
  1369. }
  1370. return std::nullopt;
  1371. };
  1372. do {
  1373. auto header_start_pos = builder.pos();
  1374. auto content_start = builder.try_find_literal("<|message|>");
  1375. if (!content_start) {
  1376. throw common_chat_msg_partial_exception("incomplete header");
  1377. }
  1378. auto header = content_start->prelude;
  1379. if (auto match = regex_match(tool_call1_regex, header)) {
  1380. auto group = match->groups[1];
  1381. auto name = header.substr(group.begin, group.end - group.begin);
  1382. handle_tool_call(name);
  1383. continue;
  1384. }
  1385. if (auto match = regex_match(tool_call2_regex, header)) {
  1386. auto group = match->groups[2];
  1387. auto name = header.substr(group.begin, group.end - group.begin);
  1388. handle_tool_call(name);
  1389. continue;
  1390. }
  1391. if (regex_match(analysis_regex, header)) {
  1392. builder.move_to(header_start_pos);
  1393. if (builder.syntax().reasoning_format == COMMON_REASONING_FORMAT_NONE || builder.syntax().reasoning_in_content) {
  1394. builder.add_content(consume_end(true));
  1395. } else {
  1396. builder.try_parse_reasoning("<|channel|>analysis<|message|>", "<|end|>");
  1397. }
  1398. continue;
  1399. }
  1400. if(regex_match(final_regex, header) || regex_match(preamble_regex, header)) {
  1401. builder.add_content(consume_end());
  1402. continue;
  1403. }
  1404. // Possibly a malformed message, attempt to recover by rolling
  1405. // back to pick up the next <|start|>
  1406. LOG_DBG("%s: unknown header from message: %s\n", __func__, header.c_str());
  1407. builder.move_to(header_start_pos);
  1408. } while (builder.try_find_regex(start_regex, std::string::npos, false));
  1409. auto remaining = builder.consume_rest();
  1410. if (!remaining.empty()) {
  1411. LOG_DBG("%s: content after last message: %s\n", __func__, remaining.c_str());
  1412. }
  1413. }
  1414. static common_chat_params common_chat_params_init_firefunction_v2(const common_chat_template & tmpl, const struct templates_params & inputs) {
  1415. LOG_DBG("%s\n", __func__);
  1416. common_chat_params data;
  1417. data.prompt = apply(tmpl, inputs, /* messages_override =*/ std::nullopt, /* tools_override= */ json(), json {
  1418. {"datetime", format_time(inputs.now, "%b %d %Y %H:%M:%S GMT")},
  1419. {"functions", json(inputs.tools.empty() ? "" : inputs.tools.dump(2))},
  1420. });
  1421. if (inputs.tools.is_array() && !inputs.tools.empty()) {
  1422. data.grammar_lazy = inputs.tool_choice != COMMON_CHAT_TOOL_CHOICE_REQUIRED;
  1423. data.grammar = build_grammar([&](const common_grammar_builder & builder) {
  1424. auto schemas = json::array();
  1425. foreach_function(inputs.tools, [&](const json & tool) {
  1426. const auto & function = tool.at("function");
  1427. schemas.push_back({
  1428. {"type", "object"},
  1429. {"properties", {
  1430. {"name", {
  1431. {"type", "string"},
  1432. {"const", function.at("name")},
  1433. }},
  1434. {"arguments", function.at("parameters")},
  1435. }},
  1436. {"required", json::array({"name", "arguments", "id"})},
  1437. });
  1438. });
  1439. auto schema = json {
  1440. {"type", "array"},
  1441. {"items", schemas.size() == 1 ? schemas[0] : json {{"anyOf", schemas}}},
  1442. {"minItems", 1},
  1443. };
  1444. if (!inputs.parallel_tool_calls) {
  1445. schema["maxItems"] = 1;
  1446. }
  1447. builder.add_rule("root", "\" functools\"? " + builder.add_schema("tool_calls", schema));
  1448. });
  1449. data.grammar_triggers.push_back({COMMON_GRAMMAR_TRIGGER_TYPE_WORD, " functools["});
  1450. data.preserved_tokens = {
  1451. " functools[",
  1452. };
  1453. data.format = COMMON_CHAT_FORMAT_FIREFUNCTION_V2;
  1454. } else {
  1455. data.format = COMMON_CHAT_FORMAT_CONTENT_ONLY;
  1456. }
  1457. return data;
  1458. }
  1459. static void common_chat_parse_firefunction_v2(common_chat_msg_parser & builder) {
  1460. if (!builder.syntax().parse_tool_calls) {
  1461. builder.add_content(builder.consume_rest());
  1462. return;
  1463. }
  1464. static const common_regex prefix(regex_escape(" functools["));
  1465. parse_prefixed_json_tool_call_array(builder, prefix, /* rstrip_prefix= */ 1);
  1466. }
  1467. static common_chat_params common_chat_params_init_functionary_v3_2(const common_chat_template & tmpl, const struct templates_params & inputs) {
  1468. // >>>all\nlet's call functions>>>fn1\n{"arg1": 1...}\n>>>fn2\n{"arg1": 1...}...
  1469. // Using ">>>f1\n", ">>>f2\n"... as trigger words for the grammar
  1470. // If the function is python, we also allow raw python code (if the line after `python\n` doesn't start w/ opening `{`), which the model seems to prefer for multiline code.
  1471. common_chat_params data;
  1472. data.prompt = apply(tmpl, inputs);
  1473. data.format = COMMON_CHAT_FORMAT_FUNCTIONARY_V3_2;
  1474. if (inputs.tools.is_array() && !inputs.tools.empty()) {
  1475. data.grammar_lazy = inputs.tool_choice != COMMON_CHAT_TOOL_CHOICE_REQUIRED;
  1476. data.grammar = build_grammar([&](const common_grammar_builder & builder) {
  1477. std::vector<std::string> first_tool_rules;
  1478. std::vector<std::string> subsequent_tool_rules;
  1479. foreach_function(inputs.tools, [&](const json & tool) {
  1480. const auto & function = tool.at("function");
  1481. std::string name = function.at("name");
  1482. auto parameters = function.at("parameters");
  1483. builder.resolve_refs(parameters);
  1484. std::string args_pattern = "[\\s\\S]*";
  1485. auto args_rule = builder.add_schema(name + "-args", parameters);
  1486. if (name == "python") {
  1487. args_rule = builder.add_rule(name + "-maybe-raw-args", args_rule + " | [^{] .*");
  1488. } else {
  1489. args_pattern = "\\{" + args_pattern;
  1490. }
  1491. auto call_rule = builder.add_rule(name + "-call", "\"" + name + "\\n\" " + args_rule);
  1492. first_tool_rules.push_back(call_rule);
  1493. if (inputs.parallel_tool_calls) {
  1494. subsequent_tool_rules.push_back(builder.add_rule(name + "-call2", "\">>>\" " + call_rule));
  1495. }
  1496. data.grammar_triggers.push_back({
  1497. COMMON_GRAMMAR_TRIGGER_TYPE_PATTERN_FULL,
  1498. "((?:[\\s\\S]+?>>>)?" + regex_escape(name) + "\n)" + args_pattern,
  1499. });
  1500. });
  1501. data.preserved_tokens = {
  1502. "<|end_header_id|>",
  1503. };
  1504. auto first_rule = first_tool_rules.empty() ? "" : builder.add_rule("first_tool_call", string_join(first_tool_rules, " | ")) + " space";
  1505. if (inputs.parallel_tool_calls) {
  1506. auto subsequent_rule = builder.add_rule("subsequent_tool_call", string_join(subsequent_tool_rules, " | ")) + " space";
  1507. builder.add_rule("root", first_rule + " (" + subsequent_rule + ")*");
  1508. } else {
  1509. builder.add_rule("root", first_rule);
  1510. }
  1511. });
  1512. }
  1513. return data;
  1514. }
  1515. static void common_chat_parse_functionary_v3_2(common_chat_msg_parser & builder) {
  1516. static const common_regex function_regex_start_only(R"((\w+\n\{|python\n|all\n))");
  1517. static const common_regex function_regex(R"(>>>(\w+\n\{|python\n|all\n))");
  1518. static const common_regex close_regex(R"(\s*)");
  1519. parse_json_tool_calls(
  1520. builder,
  1521. std::nullopt,
  1522. function_regex_start_only,
  1523. function_regex,
  1524. close_regex,
  1525. std::nullopt,
  1526. /* allow_raw_python= */ true,
  1527. /* get_function_name= */ [&](const auto & res) -> std::string {
  1528. auto at_start = res.groups[0].begin == 0;
  1529. auto name = builder.str(res.groups[1]);
  1530. if (!name.empty() && name.back() == '{') {
  1531. // Unconsume the opening brace '{' to ensure the JSON parsing goes well.
  1532. builder.move_back(1);
  1533. }
  1534. auto idx = name.find_last_not_of("\n{");
  1535. name = name.substr(0, idx + 1);
  1536. if (at_start && name == "all") {
  1537. return "";
  1538. }
  1539. return name;
  1540. });
  1541. }
  1542. static common_chat_params common_chat_params_init_functionary_v3_1_llama_3_1(const common_chat_template & tmpl, const struct templates_params & inputs) {
  1543. // https://github.com/MeetKai/functionary/blob/main/tests/prompt_test_v3-llama3.1.txt
  1544. common_chat_params data;
  1545. if (!inputs.tools.is_null()) {
  1546. std::string python_code_argument_name;
  1547. auto has_raw_python = false;
  1548. data.grammar_lazy = inputs.tool_choice != COMMON_CHAT_TOOL_CHOICE_REQUIRED;
  1549. data.grammar = build_grammar([&](const common_grammar_builder & builder) {
  1550. std::vector<std::string> tool_rules;
  1551. foreach_function(inputs.tools, [&](const json & tool) {
  1552. const auto & function = tool.at("function");
  1553. const auto & parameters = function.at("parameters");
  1554. std::string name = function.at("name");
  1555. if (name == "python" || name == "ipython") {
  1556. if (!parameters.contains("type")) {
  1557. throw std::runtime_error("Missing type in python tool");
  1558. }
  1559. has_raw_python = true;
  1560. const auto & type = parameters.at("type");
  1561. if (type == "object") {
  1562. auto properties = parameters.at("properties");
  1563. for (auto it = properties.begin(); it != properties.end(); ++it) {
  1564. if (it.value().at("type") == "string") {
  1565. if (!python_code_argument_name.empty()) {
  1566. throw std::runtime_error("Multiple string arguments found in python tool");
  1567. }
  1568. python_code_argument_name = it.key();
  1569. }
  1570. }
  1571. if (python_code_argument_name.empty()) {
  1572. throw std::runtime_error("No string argument found in python tool");
  1573. }
  1574. } else if (type != "string") {
  1575. throw std::runtime_error("Invalid type in python tool: " + type.dump());
  1576. }
  1577. }
  1578. tool_rules.push_back(builder.add_rule(name + "-call", "\"<function=" + name + ">\" " + builder.add_schema(name + "-args", parameters) + " \"</function>\" space"));
  1579. });
  1580. if (has_raw_python) {
  1581. tool_rules.push_back(builder.add_rule("python-call", "\"<|python_tag|>\" .*"));
  1582. data.grammar_triggers.push_back({COMMON_GRAMMAR_TRIGGER_TYPE_WORD, "<|python_tag|>"});
  1583. data.preserved_tokens.push_back("<|python_tag|>");
  1584. }
  1585. auto tool_call = builder.add_rule("tool_call", string_join(tool_rules, " | ")) + " space";
  1586. builder.add_rule("root", inputs.parallel_tool_calls ? "(" + tool_call + ")+" : tool_call);
  1587. data.grammar_triggers.push_back({COMMON_GRAMMAR_TRIGGER_TYPE_WORD, "<function="});
  1588. });
  1589. data.format = COMMON_CHAT_FORMAT_FUNCTIONARY_V3_1_LLAMA_3_1;
  1590. } else {
  1591. data.format = COMMON_CHAT_FORMAT_CONTENT_ONLY;
  1592. }
  1593. data.prompt = apply(tmpl, inputs);
  1594. // TODO: if (has_raw_python)
  1595. return data;
  1596. }
  1597. static void common_chat_parse_functionary_v3_1_llama_3_1(common_chat_msg_parser & builder) {
  1598. if (!builder.syntax().parse_tool_calls) {
  1599. builder.add_content(builder.consume_rest());
  1600. return;
  1601. }
  1602. // This version of Functionary still supports the llama 3.1 tool call format for the python tool.
  1603. static const common_regex python_tag_regex(regex_escape("<|python_tag|>"));
  1604. static const common_regex function_regex(R"(<function=(\w+)>)");
  1605. static const common_regex close_regex(R"(</function>)");
  1606. parse_json_tool_calls(
  1607. builder,
  1608. /* block_open= */ std::nullopt,
  1609. /* function_regex_start_only= */ std::nullopt,
  1610. function_regex,
  1611. close_regex,
  1612. std::nullopt);
  1613. if (auto res = builder.try_find_regex(python_tag_regex)) {
  1614. auto arguments = wrap_code_as_arguments(builder, builder.consume_rest());
  1615. builder.add_tool_call("python", "", arguments);
  1616. return;
  1617. }
  1618. }
  1619. static common_chat_params common_chat_params_init_hermes_2_pro(const common_chat_template & tmpl, const struct templates_params & inputs) {
  1620. common_chat_params data;
  1621. json extra_context = json {
  1622. {"enable_thinking", inputs.enable_thinking},
  1623. };
  1624. extra_context.update(inputs.extra_context);
  1625. data.prompt = apply(tmpl, inputs, /* messages_override =*/ std::nullopt, /* tools_override= */ std::nullopt, extra_context);
  1626. data.format = COMMON_CHAT_FORMAT_HERMES_2_PRO;
  1627. if (string_ends_with(data.prompt, "<think>\n")) {
  1628. if (!extra_context["enable_thinking"]) {
  1629. data.prompt += "</think>";
  1630. } else {
  1631. data.thinking_forced_open = true;
  1632. }
  1633. }
  1634. if (!inputs.tools.is_null()) {
  1635. // (content)?(<tool_call>{"name": "foo", "arguments": {"a": 1}}</tool_call>)*
  1636. data.grammar_lazy = inputs.tool_choice != COMMON_CHAT_TOOL_CHOICE_REQUIRED;
  1637. data.grammar = build_grammar([&](const common_grammar_builder & builder) {
  1638. std::vector<std::string> tool_rules;
  1639. std::vector<std::string> tool_call_alts;
  1640. std::vector<std::string> escaped_names;
  1641. foreach_function(inputs.tools, [&](const json & tool) {
  1642. const auto & function = tool.at("function");
  1643. std::string name = function.at("name");
  1644. auto parameters = function.at("parameters");
  1645. builder.resolve_refs(parameters);
  1646. tool_rules.push_back(builder.add_schema(name + "-call", {
  1647. {"type", "object"},
  1648. {"properties", json {
  1649. {"name", json {{"const", name}}},
  1650. {"arguments", parameters},
  1651. }},
  1652. {"required", json::array({"name", "arguments"})},
  1653. }));
  1654. tool_call_alts.push_back(builder.add_rule(
  1655. name + "-function-tag",
  1656. "\"<function\" ( \"=" + name + "\" | \" name=\\\"" + name + "\\\"\" ) \">\" space " +
  1657. builder.add_schema(name + "-args", parameters) + " "
  1658. "\"</function>\" space"));
  1659. data.grammar_triggers.push_back({
  1660. COMMON_GRAMMAR_TRIGGER_TYPE_WORD,
  1661. "<function=" + name + ">",
  1662. });
  1663. auto escaped_name = regex_escape(name);
  1664. data.grammar_triggers.push_back({
  1665. COMMON_GRAMMAR_TRIGGER_TYPE_PATTERN,
  1666. "<function\\s+name\\s*=\\s*\"" + escaped_name + "\"",
  1667. });
  1668. escaped_names.push_back(escaped_name);
  1669. });
  1670. auto any_tool_call = builder.add_rule("any_tool_call", "( " + string_join(tool_rules, " | ") + " ) space");
  1671. std::vector<std::string> alt_tags {
  1672. any_tool_call,
  1673. "\"<tool_call>\" space " + any_tool_call + " \"</tool_call>\"",
  1674. // The rest is just to accommodate common "good bad" outputs.
  1675. "\"<function_call>\" space " + any_tool_call + " \"</function_call>\"",
  1676. "\"<response>\" space " + any_tool_call + " \"</response>\"",
  1677. "\"<tools>\" space " + any_tool_call + " \"</tools>\"",
  1678. "\"<json>\" space " + any_tool_call + " \"</json>\"",
  1679. "\"<xml>\" space " + any_tool_call + " \"</xml>\"",
  1680. "\"<JSON>\" space " + any_tool_call + " \"</JSON>\"",
  1681. };
  1682. auto wrappable_tool_call = builder.add_rule("wrappable_tool_call", "( " + string_join(alt_tags, " | ") + " ) space");
  1683. tool_call_alts.push_back(wrappable_tool_call);
  1684. tool_call_alts.push_back(
  1685. "( \"```\\n\" | \"```json\\n\" | \"```xml\\n\" ) space " + wrappable_tool_call + " space \"```\" space ");
  1686. auto tool_call = builder.add_rule("tool_call", string_join(tool_call_alts, " | "));
  1687. builder.add_rule("root",
  1688. std::string(data.thinking_forced_open ? "( \"</think>\" space )? " : "") +
  1689. (inputs.parallel_tool_calls ? "(" + tool_call + ")+" : tool_call));
  1690. // Trigger on some common known "good bad" outputs (only from the start and with a json that's about a specific argument name to avoid false positives)
  1691. data.grammar_triggers.push_back({
  1692. COMMON_GRAMMAR_TRIGGER_TYPE_PATTERN_FULL,
  1693. // If thinking_forced_open, then we capture the </think> tag in the grammar,
  1694. // (important for required tool choice) and in the trigger's first capture (decides what is sent to the grammar)
  1695. std::string(data.thinking_forced_open ? "[\\s\\S]*?(</think>\\s*)" : "(?:<think>[\\s\\S]*?</think>\\s*)?") + (
  1696. "(\\s*"
  1697. "(?:<tool_call>"
  1698. "|<function"
  1699. "|(?:```(?:json|xml)?\n\\s*)?(?:<function_call>|<tools>|<xml><json>|<response>)?"
  1700. "\\s*\\{\\s*\"name\"\\s*:\\s*\"(?:" + string_join(escaped_names, "|") + ")\""
  1701. ")"
  1702. ")[\\s\\S]*"
  1703. ),
  1704. });
  1705. data.preserved_tokens = {
  1706. "<think>",
  1707. "</think>",
  1708. "<tool_call>",
  1709. "</tool_call>",
  1710. "<function",
  1711. "<tools>",
  1712. "</tools>",
  1713. "<response>",
  1714. "</response>",
  1715. "<function_call>",
  1716. "</function_call>",
  1717. "<json>",
  1718. "</json>",
  1719. "<JSON>",
  1720. "</JSON>",
  1721. "```",
  1722. "```json",
  1723. "```xml",
  1724. };
  1725. });
  1726. }
  1727. return data;
  1728. }
  1729. static void common_chat_parse_hermes_2_pro(common_chat_msg_parser & builder) {
  1730. builder.try_parse_reasoning("<think>", "</think>");
  1731. if (!builder.syntax().parse_tool_calls) {
  1732. builder.add_content(builder.consume_rest());
  1733. return;
  1734. }
  1735. static const common_regex open_regex(
  1736. "(?:"
  1737. "(```(?:xml|json)?\\n\\s*)?" // match 1 (block_start)
  1738. "(" // match 2 (open_tag)
  1739. "<tool_call>"
  1740. "|<function_call>"
  1741. "|<tool>"
  1742. "|<tools>"
  1743. "|<response>"
  1744. "|<json>"
  1745. "|<xml>"
  1746. "|<JSON>"
  1747. ")?"
  1748. "(\\s*\\{\\s*\"name\")" // match 3 (named tool call)
  1749. ")"
  1750. "|<function=([^>]+)>" // match 4 (function name)
  1751. "|<function name=\"([^\"]+)\">" // match 5 (function name again)
  1752. );
  1753. while (auto res = builder.try_find_regex(open_regex)) {
  1754. const auto & block_start = res->groups[1];
  1755. std::string block_end = block_start.empty() ? "" : "```";
  1756. const auto & open_tag = res->groups[2];
  1757. std::string close_tag;
  1758. if (!res->groups[3].empty()) {
  1759. builder.move_to(res->groups[3].begin);
  1760. close_tag = open_tag.empty() ? "" : "</" + builder.str(open_tag).substr(1);
  1761. if (auto tool_call = builder.try_consume_json_with_dumped_args({{"arguments"}})) {
  1762. if (!builder.add_tool_call(tool_call->value) || tool_call->is_partial) {
  1763. throw common_chat_msg_partial_exception("incomplete tool call");
  1764. }
  1765. builder.consume_spaces();
  1766. builder.consume_literal(close_tag);
  1767. builder.consume_spaces();
  1768. if (!block_end.empty()) {
  1769. builder.consume_literal(block_end);
  1770. builder.consume_spaces();
  1771. }
  1772. } else {
  1773. throw common_chat_msg_partial_exception("failed to parse tool call");
  1774. }
  1775. } else {
  1776. auto function_name = builder.str(res->groups[4]);
  1777. if (function_name.empty()) {
  1778. function_name = builder.str(res->groups[5]);
  1779. }
  1780. GGML_ASSERT(!function_name.empty());
  1781. close_tag = "</function>";
  1782. if (auto arguments = builder.try_consume_json_with_dumped_args({{}})) {
  1783. if (!builder.add_tool_call(function_name, "", arguments->value) || arguments->is_partial) {
  1784. throw common_chat_msg_partial_exception("incomplete tool call");
  1785. }
  1786. builder.consume_spaces();
  1787. builder.consume_literal(close_tag);
  1788. builder.consume_spaces();
  1789. if (!block_end.empty()) {
  1790. builder.consume_literal(block_end);
  1791. builder.consume_spaces();
  1792. }
  1793. }
  1794. }
  1795. }
  1796. builder.add_content(builder.consume_rest());
  1797. }
  1798. static common_chat_params common_chat_params_init_granite(const common_chat_template & tmpl, const struct templates_params & inputs) {
  1799. common_chat_params data;
  1800. // Pass thinking context for Granite template
  1801. json additional_context = {
  1802. {"thinking", inputs.enable_thinking},
  1803. };
  1804. data.prompt = apply(tmpl, inputs, /* messages_override= */ std::nullopt, /* tools_override= */ std::nullopt, additional_context);
  1805. data.format = COMMON_CHAT_FORMAT_GRANITE;
  1806. if (string_ends_with(data.prompt, "<think>\n") || string_ends_with(data.prompt, "<think>")) {
  1807. if (!inputs.enable_thinking) {
  1808. data.prompt += "</think>";
  1809. } else {
  1810. data.thinking_forced_open = true;
  1811. }
  1812. }
  1813. if (!inputs.tools.is_null()) {
  1814. // Granite uses <|tool_call|> followed by JSON list
  1815. data.grammar_lazy = inputs.tool_choice != COMMON_CHAT_TOOL_CHOICE_REQUIRED;
  1816. data.grammar = build_grammar([&](const common_grammar_builder & builder) {
  1817. std::vector<std::string> tool_rules;
  1818. foreach_function(inputs.tools, [&](const json & tool) {
  1819. const auto & function = tool.at("function");
  1820. std::string name = function.at("name");
  1821. auto parameters = function.at("parameters");
  1822. builder.resolve_refs(parameters);
  1823. tool_rules.push_back(builder.add_rule(name + "-call", builder.add_schema(name +
  1824. "-args", {
  1825. {"type", "object"},
  1826. {"properties", {
  1827. {"name", {{"const", name}}},
  1828. {"arguments", parameters},
  1829. }},
  1830. {"required", json::array({"name", "arguments"})},
  1831. })));
  1832. });
  1833. auto tool_call = builder.add_rule("tool_call", string_join(tool_rules, " | "));
  1834. auto tool_list = builder.add_rule("tool_list", "\"[\" space " + tool_call + " (\",\" space " + tool_call + ")* space \"]\"");
  1835. if (data.thinking_forced_open) {
  1836. builder.add_rule("root", "\"</think>\" space \"<response>\" space [^<]* \"</response>\" space \"<|tool_call|>\" space " + tool_list);
  1837. } else {
  1838. builder.add_rule("root", "\"<|tool_call|>\" space " + tool_list);
  1839. }
  1840. data.grammar_triggers.push_back({
  1841. COMMON_GRAMMAR_TRIGGER_TYPE_WORD,
  1842. "<|tool_call|>"
  1843. });
  1844. data.preserved_tokens = {
  1845. "<think>",
  1846. "</think>",
  1847. "<response>",
  1848. "</response>",
  1849. "<|tool_call|>",
  1850. };
  1851. });
  1852. } else {
  1853. // Handle thinking tags for non-tool responses
  1854. if (data.thinking_forced_open && inputs.enable_thinking) {
  1855. data.grammar_lazy = false;
  1856. data.grammar = build_grammar([&](const common_grammar_builder & builder) {
  1857. builder.add_rule("root", "\"</think>\" space \"<response>\" space .* \"</response>\" space");
  1858. });
  1859. data.preserved_tokens = {
  1860. "<think>",
  1861. "</think>",
  1862. "<response>",
  1863. "</response>",
  1864. };
  1865. }
  1866. }
  1867. return data;
  1868. }
  1869. static void common_chat_parse_granite(common_chat_msg_parser & builder) {
  1870. // Parse thinking tags
  1871. builder.try_parse_reasoning("<think>", "</think>");
  1872. // Parse response tags using regex
  1873. static const common_regex response_regex("<response>([\\s\\S]*?)</response>");
  1874. if (auto res = builder.try_find_regex(response_regex)) {
  1875. // Extract the content between the tags (capture group 1)
  1876. auto content = builder.str(res->groups[1]);
  1877. builder.add_content(content);
  1878. builder.move_to(res->groups[0].end);
  1879. }
  1880. if (!builder.syntax().parse_tool_calls) {
  1881. builder.add_content(builder.consume_rest());
  1882. return;
  1883. }
  1884. // Look for tool calls
  1885. static const common_regex tool_call_regex(regex_escape("<|tool_call|>"));
  1886. if (auto res = builder.try_find_regex(tool_call_regex)) {
  1887. builder.move_to(res->groups[0].end);
  1888. // Expect JSON array of tool calls
  1889. auto tool_calls_data = builder.consume_json();
  1890. if (tool_calls_data.json.is_array()) {
  1891. if (!builder.add_tool_calls(tool_calls_data.json)) {
  1892. builder.add_content("<|tool_call|>" + tool_calls_data.json.dump());
  1893. }
  1894. } else {
  1895. builder.add_content("<|tool_call|>" + tool_calls_data.json.dump());
  1896. }
  1897. } else {
  1898. builder.add_content(builder.consume_rest());
  1899. }
  1900. }
  1901. static void common_chat_parse_seed_oss(common_chat_msg_parser & builder) {
  1902. // Parse thinking tags first - this handles the main reasoning content
  1903. builder.try_parse_reasoning("<seed:think>", "</seed:think>");
  1904. if (!builder.syntax().parse_tool_calls) {
  1905. builder.add_content(builder.consume_rest());
  1906. return;
  1907. }
  1908. // Parse tool calls - Seed-OSS uses <seed:tool_call> format
  1909. static const common_regex tool_call_begin_regex("<seed:tool_call>");
  1910. static const common_regex tool_call_end_regex("</seed:tool_call>");
  1911. static const common_regex function_regex("<function=([^>]+)>");
  1912. static const common_regex param_regex("<parameter=([^>]+)>");
  1913. while (auto tool_res = builder.try_find_regex(tool_call_begin_regex)) {
  1914. builder.consume_spaces(); // Consume whitespace after <seed:tool_call>
  1915. // Look for function call inside tool call, ignore any content before it
  1916. if (auto func_res = builder.try_find_regex(function_regex, std::string::npos, false)) {
  1917. auto function_name = builder.str(func_res->groups[1]);
  1918. // Parse Seed-OSS parameters <parameter=name>value</parameter>
  1919. json args = json::object();
  1920. // Parse all parameters
  1921. while (auto param_res = builder.try_find_regex(param_regex, std::string::npos, false)) {
  1922. // again, ignore noise around parameters
  1923. auto param_name = builder.str(param_res->groups[1]);
  1924. builder.move_to(param_res->groups[0].end);
  1925. builder.consume_spaces(); // Consume whitespace after parameter
  1926. auto savedPos = builder.pos();
  1927. if (auto param_parse = builder.try_find_literal("</parameter>")) {
  1928. auto param = param_parse->prelude;
  1929. builder.move_to(savedPos);
  1930. try {
  1931. if (auto param_res = builder.try_consume_json()) {
  1932. args[param_name] = param_res->json;
  1933. } else {
  1934. args[param_name] = param;
  1935. }
  1936. } catch (json::exception &) {
  1937. args[param_name] = param;
  1938. }
  1939. } else {
  1940. throw common_chat_msg_partial_exception("Incomplete tool parameter");
  1941. }
  1942. }
  1943. // Look for closing function tag
  1944. auto end_func = builder.try_find_literal("</function>");
  1945. if (end_func) {
  1946. builder.move_to(end_func->groups[0].end);
  1947. builder.consume_spaces(); // Consume whitespace after </function>
  1948. // Add the tool call with parsed arguments, but only if we REALLY got the literal
  1949. auto eaten_fragment = builder.input().substr(end_func->groups[0].begin, end_func->groups[0].end);
  1950. auto funlen = std::string("</function>").length();
  1951. if (eaten_fragment.length() >= funlen && eaten_fragment.substr(0, funlen) == std::string("</function>")) {
  1952. if (!builder.add_tool_call(function_name, "", args.dump())) {
  1953. throw common_chat_msg_partial_exception("Incomplete tool call");
  1954. }
  1955. } else {
  1956. throw common_chat_msg_partial_exception("Incomplete tool call");
  1957. }
  1958. } else {
  1959. throw common_chat_msg_partial_exception("Incomplete tool call");
  1960. }
  1961. // Look for closing tool call tag
  1962. if (auto end_tool = builder.try_find_regex(tool_call_end_regex, std::string::npos, false)) {
  1963. builder.move_to(end_tool->groups[0].end);
  1964. builder.consume_spaces(); // Consume trailing whitespace after tool call
  1965. } else {
  1966. throw common_chat_msg_partial_exception("Incomplete tool call");
  1967. }
  1968. } else {
  1969. // No function found - don't consume content here, let it be handled at the end
  1970. break;
  1971. }
  1972. }
  1973. // Consume any remaining whitespace after all tool call processing
  1974. builder.consume_spaces();
  1975. auto remaining = builder.consume_rest();
  1976. // If there's any non-whitespace content remaining, add it as content
  1977. if (!string_strip(remaining).empty()) {
  1978. builder.add_content(remaining);
  1979. }
  1980. }
  1981. static common_chat_params common_chat_params_init_without_tools(const common_chat_template & tmpl, const struct templates_params & inputs) {
  1982. common_chat_params data;
  1983. data.prompt = apply(tmpl, inputs);
  1984. data.format = COMMON_CHAT_FORMAT_CONTENT_ONLY;
  1985. data.grammar_lazy = false;
  1986. if (!inputs.json_schema.is_null()) {
  1987. if (!inputs.grammar.empty()) {
  1988. throw std::runtime_error("Either \"json_schema\" or \"grammar\" can be specified, but not both");
  1989. }
  1990. data.grammar = json_schema_to_grammar(inputs.json_schema);
  1991. } else {
  1992. data.grammar = inputs.grammar;
  1993. }
  1994. return data;
  1995. }
  1996. static common_chat_params common_chat_params_init_seed_oss(
  1997. const common_chat_template & tmpl,
  1998. templates_params & params,
  1999. const common_chat_templates_inputs & inputs)
  2000. {
  2001. common_chat_params data;
  2002. data.prompt = apply(tmpl, params);
  2003. data.format = COMMON_CHAT_FORMAT_SEED_OSS;
  2004. if (string_ends_with(data.prompt, "<seed:think>")) {
  2005. if (!inputs.enable_thinking) {
  2006. data.prompt += "</seed:think>";
  2007. } else {
  2008. data.thinking_forced_open = true;
  2009. }
  2010. }
  2011. if (params.tools.is_array() && !params.tools.empty()) {
  2012. data.grammar_lazy = inputs.tool_choice != COMMON_CHAT_TOOL_CHOICE_REQUIRED;
  2013. data.grammar = build_grammar([&](const common_grammar_builder & builder) {
  2014. std::vector<std::string> tool_rules;
  2015. foreach_function(params.tools, [&](const json & tool) {
  2016. const auto & function = tool.at("function");
  2017. std::string name = function.at("name");
  2018. auto parameters = function.at("parameters");
  2019. builder.resolve_refs(parameters);
  2020. // Create rule for Seed-OSS function call format
  2021. std::string param_rules;
  2022. if (parameters.contains("properties")) {
  2023. for (const auto & [key, value] : parameters.at("properties").items()) {
  2024. param_rules += "\"<parameter=" + key + ">\"" + builder.add_schema(name + "-arg-" + key, value) +
  2025. "\"</parameter>\"";
  2026. }
  2027. }
  2028. tool_rules.push_back(builder.add_rule(name + "-call",
  2029. "\"<seed:tool_call>\" space \"<function=" + name + ">\" space " +
  2030. param_rules +
  2031. " \"</function>\" space \"</seed:tool_call>\""));
  2032. });
  2033. data.grammar_triggers.push_back({ COMMON_GRAMMAR_TRIGGER_TYPE_WORD, "<seed:tool_call>" });
  2034. data.preserved_tokens = {
  2035. "<seed:think>", "</seed:think>", "<seed:tool_call>", "</seed:tool_call>",
  2036. "<function=", "</function>", "<parameter=", "</parameter>",
  2037. };
  2038. builder.add_rule("root", string_join(tool_rules, " | "));
  2039. });
  2040. }
  2041. return data;
  2042. }
  2043. static common_chat_params common_chat_templates_apply_jinja(
  2044. const struct common_chat_templates * tmpls,
  2045. const struct common_chat_templates_inputs & inputs)
  2046. {
  2047. templates_params params;
  2048. params.tools = common_chat_tools_to_json_oaicompat<json>(inputs.tools);
  2049. const auto & tmpl = params.tools.is_array() && tmpls->template_tool_use
  2050. ? *tmpls->template_tool_use
  2051. : *tmpls->template_default;
  2052. const auto & src = tmpl.source();
  2053. const auto & caps = tmpl.original_caps();
  2054. params.messages = common_chat_msgs_to_json_oaicompat<json>(inputs.messages, /* concat_text= */ !tmpl.original_caps().requires_typed_content);
  2055. params.add_generation_prompt = inputs.add_generation_prompt;
  2056. params.tool_choice = inputs.tool_choice;
  2057. params.enable_thinking = inputs.enable_thinking;
  2058. params.grammar = inputs.grammar;
  2059. params.now = inputs.now;
  2060. params.add_bos = tmpls->add_bos;
  2061. params.add_eos = tmpls->add_eos;
  2062. params.extra_context = json::object();
  2063. for (auto el : inputs.chat_template_kwargs) {
  2064. params.extra_context[el.first] = json::parse(el.second);
  2065. }
  2066. if (!inputs.json_schema.empty()) {
  2067. params.json_schema = json::parse(inputs.json_schema);
  2068. }
  2069. if (inputs.parallel_tool_calls && !tmpl.original_caps().supports_parallel_tool_calls) {
  2070. LOG_DBG("Disabling parallel_tool_calls because the template does not support it\n");
  2071. params.parallel_tool_calls = false;
  2072. } else {
  2073. params.parallel_tool_calls = inputs.parallel_tool_calls;
  2074. }
  2075. if (params.tools.is_array()) {
  2076. if (params.tool_choice != COMMON_CHAT_TOOL_CHOICE_NONE && !params.grammar.empty()) {
  2077. throw std::runtime_error("Cannot specify grammar with tools");
  2078. }
  2079. if (caps.supports_tool_calls && !caps.supports_tools) {
  2080. LOG_WRN("Template supports tool calls but does not natively describe tools. The fallback behaviour used may produce bad results, inspect prompt w/ --verbose & consider overriding the template.\n");
  2081. }
  2082. }
  2083. // DeepSeek R1: use handler in all cases except json schema (thinking / tools).
  2084. if (src.find("<|tool▁calls▁begin|>") != std::string::npos && params.json_schema.is_null()) {
  2085. return common_chat_params_init_deepseek_r1(tmpl, params);
  2086. }
  2087. // Command R7B: : use handler in all cases except json schema (thinking / tools).
  2088. if (src.find("<|END_THINKING|><|START_ACTION|>") != std::string::npos && params.json_schema.is_null()) {
  2089. return common_chat_params_init_command_r7b(tmpl, params);
  2090. }
  2091. // Granite (IBM) - detects thinking / tools support
  2092. if (src.find("elif thinking") != std::string::npos && src.find("<|tool_call|>") != std::string::npos) {
  2093. return common_chat_params_init_granite(tmpl, params);
  2094. }
  2095. // Hermes 2/3 Pro, Qwen 2.5 Instruct (w/ tools)
  2096. if (src.find("<tool_call>") != std::string::npos && params.json_schema.is_null()) {
  2097. return common_chat_params_init_hermes_2_pro(tmpl, params);
  2098. }
  2099. // GPT-OSS
  2100. if (src.find("<|channel|>") != std::string::npos) {
  2101. return common_chat_params_init_gpt_oss(tmpl, params);
  2102. }
  2103. // Seed-OSS
  2104. if (src.find("<seed:think>") != std::string::npos) {
  2105. return common_chat_params_init_seed_oss(tmpl, params, inputs);
  2106. }
  2107. // Use generic handler when mixing tools + JSON schema.
  2108. // TODO: support that mix in handlers below.
  2109. if ((params.tools.is_array() && params.json_schema.is_object())) {
  2110. return common_chat_params_init_generic(tmpl, params);
  2111. }
  2112. // Functionary prepends "all\n" to plain content outputs, so we use its handler in all cases.
  2113. if (src.find(">>>all") != std::string::npos) {
  2114. return common_chat_params_init_functionary_v3_2(tmpl, params);
  2115. }
  2116. // Firefunction v2 requires datetime and functions in the context even w/o tools, so we also use its handler in all cases.
  2117. if (src.find(" functools[") != std::string::npos) {
  2118. return common_chat_params_init_firefunction_v2(tmpl, params);
  2119. }
  2120. // Functionary v3.1 (w/ tools)
  2121. if (src.find("<|start_header_id|>") != std::string::npos
  2122. && src.find("<function=") != std::string::npos) {
  2123. return common_chat_params_init_functionary_v3_1_llama_3_1(tmpl, params);
  2124. }
  2125. // Llama 3.1, 3.2, 3.3 (also requires date_string so using it even w/o tools)
  2126. if (src.find("<|start_header_id|>ipython<|end_header_id|>") != std::string::npos) {
  2127. auto allow_python_tag_builtin_tools = src.find("<|python_tag|>") != std::string::npos;
  2128. return common_chat_params_init_llama_3_x(tmpl, params, allow_python_tag_builtin_tools);
  2129. }
  2130. // Plain handler (no tools)
  2131. if (params.tools.is_null() || inputs.tool_choice == COMMON_CHAT_TOOL_CHOICE_NONE) {
  2132. return common_chat_params_init_without_tools(tmpl, params);
  2133. }
  2134. // Mistral Nemo (w/ tools)
  2135. if (src.find("[TOOL_CALLS]") != std::string::npos) {
  2136. return common_chat_params_init_mistral_nemo(tmpl, params);
  2137. }
  2138. // Generic fallback
  2139. return common_chat_params_init_generic(tmpl, params);
  2140. }
  2141. // Legacy template route (adhoc C++ implementation of known templates), forward to llama_chat_apply_template.
  2142. static common_chat_params common_chat_templates_apply_legacy(
  2143. const struct common_chat_templates * tmpls,
  2144. const struct common_chat_templates_inputs & inputs)
  2145. {
  2146. int alloc_size = 0;
  2147. std::vector<llama_chat_message> chat;
  2148. std::vector<std::string> contents;
  2149. for (const auto & msg : inputs.messages) {
  2150. auto content = msg.content;
  2151. for (const auto & part : msg.content_parts) {
  2152. if (part.type != "text") {
  2153. LOG_WRN("Ignoring non-text content part: %s\n", part.type.c_str());
  2154. continue;
  2155. }
  2156. if (!content.empty()) {
  2157. content += "\n";;
  2158. }
  2159. content += part.text;
  2160. }
  2161. contents.emplace_back(std::move(content));
  2162. }
  2163. for (size_t i = 0; i < contents.size(); ++i) {
  2164. const auto & msg = inputs.messages[i];
  2165. const auto & content = contents[i];
  2166. chat.push_back({msg.role.c_str(), content.c_str()});
  2167. alloc_size += (msg.role.size() + content.size()) * 1.25;
  2168. }
  2169. std::vector<char> buf(alloc_size);
  2170. // run the first time to get the total output length
  2171. const auto & src = tmpls->template_default->source();
  2172. int32_t res = llama_chat_apply_template(src.c_str(), chat.data(), chat.size(), inputs.add_generation_prompt, buf.data(), buf.size());
  2173. // error: chat template is not supported
  2174. if (res < 0) {
  2175. // if the custom "tmpl" is not supported, we throw an error
  2176. // this is a bit redundant (for good), since we're not sure if user validated the custom template with llama_chat_verify_template()
  2177. throw std::runtime_error("this custom template is not supported, try using --jinja");
  2178. }
  2179. // if it turns out that our buffer is too small, we resize it
  2180. if ((size_t) res > buf.size()) {
  2181. buf.resize(res);
  2182. res = llama_chat_apply_template(src.c_str(), chat.data(), chat.size(), inputs.add_generation_prompt, buf.data(), buf.size());
  2183. }
  2184. common_chat_params params;
  2185. params.prompt = std::string(buf.data(), res);
  2186. if (!inputs.json_schema.empty()) {
  2187. params.grammar = json_schema_to_grammar(json::parse(inputs.json_schema));
  2188. } else {
  2189. params.grammar = inputs.grammar;
  2190. }
  2191. return params;
  2192. }
  2193. common_chat_params common_chat_templates_apply(
  2194. const struct common_chat_templates * tmpls,
  2195. const struct common_chat_templates_inputs & inputs)
  2196. {
  2197. GGML_ASSERT(tmpls != nullptr);
  2198. return inputs.use_jinja
  2199. ? common_chat_templates_apply_jinja(tmpls, inputs)
  2200. : common_chat_templates_apply_legacy(tmpls, inputs);
  2201. }
  2202. static void common_chat_parse_content_only(common_chat_msg_parser & builder) {
  2203. builder.add_content(builder.consume_rest());
  2204. }
  2205. static void common_chat_parse(common_chat_msg_parser & builder) {
  2206. LOG_DBG("Parsing input with format %s: %s\n", common_chat_format_name(builder.syntax().format), builder.input().c_str());
  2207. switch (builder.syntax().format) {
  2208. case COMMON_CHAT_FORMAT_CONTENT_ONLY:
  2209. common_chat_parse_content_only(builder);
  2210. break;
  2211. case COMMON_CHAT_FORMAT_GENERIC:
  2212. common_chat_parse_generic(builder);
  2213. break;
  2214. case COMMON_CHAT_FORMAT_MISTRAL_NEMO:
  2215. common_chat_parse_mistral_nemo(builder);
  2216. break;
  2217. case COMMON_CHAT_FORMAT_LLAMA_3_X:
  2218. common_chat_parse_llama_3_1(builder);
  2219. break;
  2220. case COMMON_CHAT_FORMAT_LLAMA_3_X_WITH_BUILTIN_TOOLS:
  2221. common_chat_parse_llama_3_1(builder, /* with_builtin_tools= */ true);
  2222. break;
  2223. case COMMON_CHAT_FORMAT_DEEPSEEK_R1:
  2224. common_chat_parse_deepseek_r1(builder);
  2225. break;
  2226. case COMMON_CHAT_FORMAT_FUNCTIONARY_V3_2:
  2227. common_chat_parse_functionary_v3_2(builder);
  2228. break;
  2229. case COMMON_CHAT_FORMAT_FUNCTIONARY_V3_1_LLAMA_3_1:
  2230. common_chat_parse_functionary_v3_1_llama_3_1(builder);
  2231. break;
  2232. case COMMON_CHAT_FORMAT_HERMES_2_PRO:
  2233. common_chat_parse_hermes_2_pro(builder);
  2234. break;
  2235. case COMMON_CHAT_FORMAT_FIREFUNCTION_V2:
  2236. common_chat_parse_firefunction_v2(builder);
  2237. break;
  2238. case COMMON_CHAT_FORMAT_COMMAND_R7B:
  2239. common_chat_parse_command_r7b(builder);
  2240. break;
  2241. case COMMON_CHAT_FORMAT_GRANITE:
  2242. common_chat_parse_granite(builder);
  2243. break;
  2244. case COMMON_CHAT_FORMAT_GPT_OSS:
  2245. common_chat_parse_gpt_oss(builder);
  2246. break;
  2247. case COMMON_CHAT_FORMAT_SEED_OSS:
  2248. common_chat_parse_seed_oss(builder);
  2249. break;
  2250. default:
  2251. throw std::runtime_error(std::string("Unsupported format: ") + common_chat_format_name(builder.syntax().format));
  2252. }
  2253. builder.finish();
  2254. }
  2255. common_chat_msg common_chat_parse(const std::string & input, bool is_partial, const common_chat_syntax & syntax) {
  2256. common_chat_msg_parser builder(input, is_partial, syntax);
  2257. try {
  2258. common_chat_parse(builder);
  2259. } catch (const common_chat_msg_partial_exception & ex) {
  2260. LOG_DBG("Partial parse: %s\n", ex.what());
  2261. if (!is_partial) {
  2262. builder.clear_tools();
  2263. builder.move_to(0);
  2264. common_chat_parse_content_only(builder);
  2265. }
  2266. }
  2267. auto msg = builder.result();
  2268. if (!is_partial) {
  2269. LOG_DBG("Parsed message: %s\n", common_chat_msgs_to_json_oaicompat<json>({msg}).at(0).dump().c_str());
  2270. }
  2271. return msg;
  2272. }