Adding functions
sender Build / Test Suite (pull_request) Failing after 31s
sender Build / build (pull_request) Failing after 1m8s
sender Build / Check (pull_request) Failing after 33s
sender Build / Rustfmt (pull_request) Failing after 26s
sender Build / Clippy (pull_request) Failing after 40s
sender Build / Test Suite (pull_request) Failing after 31s
sender Build / build (pull_request) Failing after 1m8s
sender Build / Check (pull_request) Failing after 33s
sender Build / Rustfmt (pull_request) Failing after 26s
sender Build / Clippy (pull_request) Failing after 40s
This commit is contained in:
@@ -40,3 +40,37 @@ pub async fn send_messages(
|
|||||||
count += 1;
|
count += 1;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub fn parse_numbers(filepath: &str) -> Vec<Contact> {
|
||||||
|
match std::fs::File::open(filepath) {
|
||||||
|
Ok(file) => {
|
||||||
|
let reader = std::io::BufReader::new(file);
|
||||||
|
let contacts: Vec<Contact> = match serde_json::from_reader(reader) {
|
||||||
|
Ok(va) => {
|
||||||
|
va
|
||||||
|
}
|
||||||
|
Err(err) => {
|
||||||
|
Vec::new()
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
contacts
|
||||||
|
}
|
||||||
|
Err(err) => {
|
||||||
|
Vec::new()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn parse_message(filepath: &str) -> Result<Message, std::io::Error> {
|
||||||
|
match std::fs::File::open(filepath) {
|
||||||
|
Ok(file) => {
|
||||||
|
let reader = std::io::BufReader::new(file);
|
||||||
|
let message: Message = serde_json::from_reader(reader)?;
|
||||||
|
Ok(message)
|
||||||
|
}
|
||||||
|
Err(err) => {
|
||||||
|
Err(err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user