use super::traits::{ Decoder, Encoder, Encoding, SpecialTokens, TokenIdType, Tokenizer as TokenizerTrait, }; use crate::metrics::TokenizerMetrics; use anyhow::{Error, Result}; use std::collections::HashMap; use std::time::Instant; use tokenizers::tokenizer::Tokenizer as HfTokenizer; #[cfg(feature = "minijinja")] use super::chat_template::{ChatMessage, ChatTemplateProcessor}; /// HuggingFace tokenizer wrapper pub struct HuggingFaceTokenizer { tokenizer: HfTokenizer, special_tokens: SpecialTokens, vocab: HashMap, reverse_vocab: HashMap, #[cfg(feature = "minijinja")] chat_template: Option, } impl HuggingFaceTokenizer { /// Create a tokenizer from a HuggingFace tokenizer JSON file pub fn from_file(file_path: &str) -> Result { Self::from_file_with_chat_template(file_path, None) } /// Create a tokenizer from a HuggingFace tokenizer JSON file with an optional chat template pub fn from_file_with_chat_template( file_path: &str, chat_template_path: Option<&str>, ) -> Result { let tokenizer = HfTokenizer::from_file(file_path) .map_err(|e| Error::msg(format!("Failed to load tokenizer: {}", e)))?; // Extract special tokens let special_tokens = Self::extract_special_tokens(&tokenizer); // Build vocab mappings let vocab = tokenizer.get_vocab(false); let reverse_vocab: HashMap = vocab .iter() .map(|(token, &id)| (id, token.clone())) .collect(); // Load chat template #[cfg(feature = "minijinja")] let chat_template = if let Some(template_path) = chat_template_path { // Load from specified .jinja file Self::load_chat_template_from_file(template_path)? } else { // Try to load from tokenizer_config.json Self::load_chat_template(file_path) }; Ok(HuggingFaceTokenizer { tokenizer, special_tokens, vocab, reverse_vocab, #[cfg(feature = "minijinja")] chat_template, }) } /// Create from an existing HuggingFace tokenizer pub fn from_tokenizer(tokenizer: HfTokenizer) -> Self { let special_tokens = Self::extract_special_tokens(&tokenizer); let vocab = tokenizer.get_vocab(false); let reverse_vocab: HashMap = vocab .iter() .map(|(token, &id)| (id, token.clone())) .collect(); HuggingFaceTokenizer { tokenizer, special_tokens, vocab, reverse_vocab, #[cfg(feature = "minijinja")] chat_template: None, } } /// Extract special tokens from the tokenizer fn extract_special_tokens(tokenizer: &HfTokenizer) -> SpecialTokens { // Try to get special tokens from the tokenizer // This is a simplified version - actual implementation would need to handle various formats let vocab = tokenizer.get_vocab(true); let find_token = |patterns: &[&str]| -> Option { for pattern in patterns { if vocab.contains_key(*pattern) { return Some(pattern.to_string()); } } None }; SpecialTokens { bos_token: find_token(&["", "<|startoftext|>", "", "[CLS]"]), eos_token: find_token(&["", "<|endoftext|>", "", "[SEP]"]), unk_token: find_token(&["", "", "[UNK]"]), sep_token: find_token(&["[SEP]", "", ""]), pad_token: find_token(&["", "", "[PAD]"]), cls_token: find_token(&["[CLS]", "", ""]), mask_token: find_token(&["[MASK]", "", ""]), additional_special_tokens: vec![], } } /// Try to load chat template from tokenizer_config.json #[cfg(feature = "minijinja")] fn load_chat_template(tokenizer_path: &str) -> Option { // Try to find tokenizer_config.json in the same directory let path = std::path::Path::new(tokenizer_path); let dir = path.parent()?; let config_path = dir.join("tokenizer_config.json"); if config_path.exists() { if let Ok(template) = super::chat_template::load_chat_template_from_config(config_path.to_str()?) { return template; } } None } /// Load chat template from a .jinja file #[cfg(feature = "minijinja")] fn load_chat_template_from_file(template_path: &str) -> Result> { use std::fs; let content = fs::read_to_string(template_path) .map_err(|e| Error::msg(format!("Failed to read chat template file: {}", e)))?; // Clean up the template (similar to Python implementation) let template = content.trim().replace("\\n", "\n"); Ok(Some(template)) } /// Set or override the chat template #[cfg(feature = "minijinja")] pub fn set_chat_template(&mut self, template: String) { self.chat_template = Some(template); } /// Apply chat template if available #[cfg(feature = "minijinja")] pub fn apply_chat_template( &self, messages: &[ChatMessage], add_generation_prompt: bool, ) -> Result { if let Some(ref template) = self.chat_template { let processor = ChatTemplateProcessor::new( template.clone(), self.special_tokens.bos_token.clone(), self.special_tokens.eos_token.clone(), ); processor.apply_chat_template(messages, add_generation_prompt) } else { // Fallback to simple formatting if no template is available let mut result = String::new(); for msg in messages { result.push_str(&format!("{}: {}\n", msg.role, msg.content)); } if add_generation_prompt { result.push_str("assistant: "); } Ok(result) } } /// Apply chat template if available (without minijinja feature) #[cfg(not(feature = "minijinja"))] pub fn apply_chat_template( &self, messages: &[ChatMessage], add_generation_prompt: bool, ) -> Result { // Fallback to simple formatting let mut result = String::new(); for msg in messages { result.push_str(&format!("{}: {}\n", msg.role, msg.content)); } if add_generation_prompt { result.push_str("assistant: "); } Ok(result) } } impl Encoder for HuggingFaceTokenizer { fn encode(&self, input: &str) -> Result { let start = Instant::now(); TokenizerMetrics::record_encode_request("huggingface"); TokenizerMetrics::record_chars_per_encode(input.len()); self.tokenizer .encode(input, false) .map_err(|e| { TokenizerMetrics::record_encode_error("encoding_failed"); Error::msg(format!("Encoding failed: {}", e)) }) .map(|encoding| { TokenizerMetrics::record_tokens_per_encode(encoding.get_ids().len()); TokenizerMetrics::record_encode_duration(start.elapsed()); Encoding::Hf(Box::new(encoding)) }) } fn encode_batch(&self, inputs: &[&str]) -> Result> { let start = Instant::now(); let encodings = self .tokenizer .encode_batch(inputs.to_vec(), false) .map_err(|e| { TokenizerMetrics::record_encode_error("batch_encoding_failed"); Error::msg(format!("Batch encoding failed: {}", e)) })?; TokenizerMetrics::record_encode_batch_duration(start.elapsed(), inputs.len()); Ok(encodings .into_iter() .map(|e| Encoding::Hf(Box::new(e))) .collect()) } } impl Decoder for HuggingFaceTokenizer { fn decode(&self, token_ids: &[TokenIdType], skip_special_tokens: bool) -> Result { let start = Instant::now(); TokenizerMetrics::record_decode_request("huggingface"); TokenizerMetrics::record_tokens_per_decode(token_ids.len()); self.tokenizer .decode(token_ids, skip_special_tokens) .map_err(|e| { TokenizerMetrics::record_decode_error("decoding_failed"); Error::msg(format!("Decoding failed: {}", e)) }) .inspect(|_| { TokenizerMetrics::record_decode_duration(start.elapsed()); }) } } impl TokenizerTrait for HuggingFaceTokenizer { fn vocab_size(&self) -> usize { self.tokenizer.get_vocab_size(false) } fn get_special_tokens(&self) -> &SpecialTokens { &self.special_tokens } fn token_to_id(&self, token: &str) -> Option { self.vocab.get(token).copied() } fn id_to_token(&self, id: TokenIdType) -> Option { self.reverse_vocab.get(&id).cloned() } } #[cfg(test)] mod tests { #[cfg(feature = "minijinja")] use super::ChatMessage; #[cfg(feature = "minijinja")] #[test] fn test_chat_message_creation() { let msg = ChatMessage::system("You are a helpful assistant"); assert_eq!(msg.role, "system"); assert_eq!(msg.content, "You are a helpful assistant"); let user_msg = ChatMessage::user("Hello!"); assert_eq!(user_msg.role, "user"); let assistant_msg = ChatMessage::assistant("Hi there!"); assert_eq!(assistant_msg.role, "assistant"); } // Note: Actual tokenizer tests would require a real tokenizer file // These would be integration tests rather than unit tests }