Adição de filtro de type=out no .txt
This commit is contained in:
11
src/main.rs
11
src/main.rs
@@ -406,8 +406,6 @@ fn main() -> anyhow::Result<()> {
|
|||||||
});
|
});
|
||||||
|
|
||||||
// Find first agent message sent after the last bot message
|
// Find first agent message sent after the last bot message
|
||||||
// let (pos, transfer_message) =
|
|
||||||
// bot_transfer_message.expect("Failed to get the transfer bot message position");
|
|
||||||
|
|
||||||
let (pos, transfer_message) = match bot_transfer_message {
|
let (pos, transfer_message) = match bot_transfer_message {
|
||||||
Some((pos, msg)) => (pos, msg),
|
Some((pos, msg)) => (pos, msg),
|
||||||
@@ -507,6 +505,14 @@ 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!(
|
||||||
"{{
|
"{{
|
||||||
@@ -520,7 +526,6 @@ fn main() -> anyhow::Result<()> {
|
|||||||
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}"))
|
||||||
|
|||||||
Reference in New Issue
Block a user