Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
41 changes: 28 additions & 13 deletions hhss/rust/Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion hhss/rust/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -8,4 +8,4 @@ name = "hhss"
path = "hhss.rs"

[dependencies]
rand = "0.8"
rand = "0.9"
91 changes: 52 additions & 39 deletions hhss/rust/hhss.rs
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
use rand::seq::IndexedRandom;
use rand::seq::SliceRandom;
use std::env;
use std::fs;
use std::io;
use std::process;
use rand::seq::SliceRandom;
use rand::thread_rng;

const MIN_SENTENCE_NUM: usize = 5;
const MIN_USER_NUM: usize = 1;
Expand All @@ -13,56 +13,67 @@ const USER_TEMPLATE: &str = "${user}";

fn main() {
let args: Vec<String> = env::args().collect();

if args.len() != 2 {
eprintln!("hhss: argc != 2.");
process::exit(1);
}

let num_sentences = match parse_num_sentences(&args[1]) {
Ok(n) => n,
Err(e) => {
eprintln!("hhss: {}", e);
process::exit(1);
}
};

let sentences = match read_data_file(SENTENCE_FILE) {
Ok(lines) => lines,
Err(e) => {
eprintln!("hhss: failed to open {} as mode \"r\": {}", SENTENCE_FILE, e);
eprintln!(
"hhss: failed to open {} as mode \"r\": {}",
SENTENCE_FILE, e
);
process::exit(1);
}
};

let users = match read_data_file(USER_FILE) {
Ok(lines) => lines,
Err(e) => {
eprintln!("hhss: failed to open {} as mode \"r\": {}", USER_FILE, e);
process::exit(1);
}
};

if sentences.len() < MIN_SENTENCE_NUM {
eprintln!("hhss: it is required for {} to have valid lines more than or equal to {}.",
SENTENCE_FILE, MIN_SENTENCE_NUM);
eprintln!(
"hhss: it is required for {} to have valid lines more than or equal to {}.",
SENTENCE_FILE, MIN_SENTENCE_NUM
);
process::exit(1);
}

if users.len() < MIN_USER_NUM {
eprintln!("hhss: it is required for {} to have valid lines more than or equal to {}.",
USER_FILE, MIN_USER_NUM);
eprintln!(
"hhss: it is required for {} to have valid lines more than or equal to {}.",
USER_FILE, MIN_USER_NUM
);
process::exit(1);
}

if num_sentences > sentences.len() {
eprintln!("hhss: argv[1] = {} needs to be <= {}, the number of valid lines in {}.",
num_sentences, sentences.len(), SENTENCE_FILE);
eprintln!(
"hhss: argv[1] = {} needs to be <= {}, the number of valid lines in {}.",
num_sentences,
sentences.len(),
SENTENCE_FILE
);
process::exit(1);
}

let selected_sentences = select_random_sentences(&sentences, num_sentences);

for sentence in selected_sentences {
let processed_sentence = replace_templates(&sentence, &users);
println!("{}", processed_sentence);
Expand All @@ -73,39 +84,42 @@ fn parse_num_sentences(arg: &str) -> Result<usize, String> {
match arg.parse::<usize>() {
Ok(n) => {
if n < MIN_SENTENCE_NUM {
Err(format!("argv[1] = {} needs to be >= {}.", n, MIN_SENTENCE_NUM))
Err(format!(
"argv[1] = {} needs to be >= {}.",
n, MIN_SENTENCE_NUM
))
} else {
Ok(n)
}
}
Err(_) => Err("no conversion can be performed.".to_string())
Err(_) => Err("no conversion can be performed.".to_string()),
}
}

fn read_data_file(filename: &str) -> Result<Vec<String>, io::Error> {
let contents = fs::read_to_string(filename)?;
let mut valid_lines = Vec::new();

for line in contents.lines() {
let trimmed = line.trim();
// Skip empty lines and comments
if !trimmed.is_empty() && !trimmed.starts_with('#') {
valid_lines.push(trimmed.to_string());
}
}

Ok(valid_lines)
}

fn select_random_sentences(sentences: &[String], count: usize) -> Vec<String> {
let mut indices: Vec<usize> = (0..sentences.len()).collect();
let mut rng = thread_rng();


// Fisher-Yates shuffle
indices.shuffle(&mut rng);
indices.shuffle(&mut rand::rng());

// Take first 'count' indices and get corresponding sentences
indices.into_iter()
indices
.into_iter()
.take(count)
.map(|i| sentences[i].clone())
.collect()
Expand All @@ -114,30 +128,29 @@ fn select_random_sentences(sentences: &[String], count: usize) -> Vec<String> {
fn replace_templates(sentence: &str, users: &[String]) -> String {
let mut result = String::new();
let mut last_user: Option<String> = None;
let mut rng = thread_rng();


let parts: Vec<&str> = sentence.split(USER_TEMPLATE).collect();

for (i, part) in parts.iter().enumerate() {
result.push_str(part);

// If this is not the last part, we need to add a user name
if i < parts.len() - 1 {
let mut available_users = users.to_vec();

// If we have more than one user and we used one before, remove it to avoid repetition
if users.len() > 1 {
if let Some(last) = &last_user {
available_users.retain(|u| u != last);
}
}
let selected_user = available_users.choose(&mut rng).unwrap();

let selected_user = available_users.choose(&mut rand::rng()).unwrap();
result.push_str(selected_user);
last_user = Some(selected_user.clone());
}
}

result
}

Expand All @@ -158,7 +171,7 @@ mod tests {
let users = vec!["Alice".to_string(), "Bob".to_string()];
let sentence = "Hello ${user}, how are you ${user}?";
let result = replace_templates(sentence, &users);

// Should contain both users and they should be different
assert!(result.contains("Alice") || result.contains("Bob"));
assert!(result.contains("Hello"));
Expand All @@ -175,13 +188,13 @@ mod tests {
"Fourth".to_string(),
"Fifth".to_string(),
];

let selected = select_random_sentences(&sentences, 3);
assert_eq!(selected.len(), 3);

// All selected sentences should be from the original list
for sentence in &selected {
assert!(sentences.contains(sentence));
}
}
}
}
Loading