nicolas.borges/sup_piperun-bot
1
0
Fork 0
forked from jelson.rodrigues/piperun-bot
Code Pull Requests Activity

Adição de filtro de type=out no .txt

Browse Source
This commit is contained in:
nicolas.borges
2026-05-08 11:32:02 -03:00
parent cef16d7590
commit 1b59d1eba6
1 changed files with 13 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
src/main.rs
View File

@@ -373,10 +373,6 @@ fn main() -> anyhow::Result<()> {
let json = messages.unwrap(); let json = messages.unwrap();
let talk_histories = &json["talk_histories"]; let talk_histories = &json["talk_histories"];
// dbg!(&talk_histories);
// talk_histories.as_array().unwrap().into_iter().enumerate().for_each(|(pos, message_obj)|{println!("{}: {}", pos, message_obj["message"])});
// find the bot transfer message // find the bot transfer message
let bot_transfer_message = talk_histories let bot_transfer_message = talk_histories
.as_array() .as_array()
@@ -490,20 +486,27 @@ fn main() -> anyhow::Result<()> {
.expect("Wrong message type received from talk histories") .expect("Wrong message type received from talk histories")
.iter() .iter()
.rev() .rev()
//filtro para escrever somente as mensagens out no .txt
.filter(|(message_object)| {
let message_type = message_object["type"]
.as_str()
.expect("Failed to decode message as string");
message_type == "out".to_string()
})
//fim do filtro
.map(|message_object| { .map(|message_object| {
let new_json_filtered = format!( let new_json_filtered = format!(
"{{ "{{
message: {}, message: {},
sent_at: {}, sent_at: {},
type: {}, type: {},
user_name: {} user_name: {}
}}", }}",
message_object["message"], message_object["message"],
message_object["sent_at"], message_object["sent_at"],
message_object["type"], message_object["type"],
message_object["user"]["name"] message_object["user"]["name"]
); );
// println!("{}", new_json_filtered);
new_json_filtered new_json_filtered
}) })
.reduce(|acc, e| format!("{acc}\n{e}")) .reduce(|acc, e| format!("{acc}\n{e}"))