{"header":{"message":"refactor (close #9 and #7)","description":null,"timestamp":"2023-12-13T11:09:15Z","authors":[{"email":"syobon@syobon.net","name":"SyoBoN"}]},"hash":"KCUGRTO54BZLPQJPUZNJGKM3TZOR2K3Z7SZN5SR7IZQAEOYWL4WQC","authors":[],"deps":{"hashes":[["KCUGRTO54BZLPQJPUZNJGKM3TZOR2K3Z7SZN5SR7IZQAEOYWL4WQC","refactor (close #9 and #7)"],["AA",null],["RUZW6T62JOBNDOJPHP5BGN4DIISXEFG554WHWWSJSHBL3AWUXB6AC","fix syntax in README"],["EISCAJ3CFVMGPWZQGFI7RZ2A7J4QJ6MN2IRZINV77QMHSESCMO3AC","refactor"],["H7H2NJQAHUY4A5DF2IQLVB5ESJUWYOITYVCDPABMXQ5BRMAZJ7AQC","refactor"],["3BHGSDHUR4TLFVXR74U6BA4HZLLHDAWY3JABHZHBC6RXCZZUUVNQC","add check if token is valid"],["VVETADYZOWCU4IYTJVLKZR2X5HWH6FUKIVLWQNQIAUG4LKTONL6QC","add support for regex (still need some improvement)"],["73ETI54RGG3MRHZ6SCFMBVJ6FU7WPY2HYEYNDFW4KK4K6CIRE4CAC","ignore repeats(boosts) (close #6)"],["OJJEHMKWEKCCM6J5KKAEUGWRAWPZZVSGCXDSCZRZNJ2NQFPLTI3AC","make clippy happy"],["3ZV7EZ26UNQJJM2LW22M7YONNLIQDQVMYJSKQZ5B7SXEMQ4IKHOAC","add CASE_SENSITIVE option (close #3)"],["Q2NINZCW6KJVDFJTS6NQ7DTSSWPPU4DG34GGZLEJPK4U6KQAJYWAC","空リプならぬ空プルリクエストをマージ"],["YMW2RSKMODRBEHP5ZGBQQ3ZKZQCKLGUT3F6MXSI73AK446LRNFKAC","publish"],["2KXFHTS3VTQWWMOUVONFJ7GYSX4DCHQ6RQ2LGV6TH5R6X7MH7RNAC","Support extra timeline"],["JLRU6XLFRAA7IVLF2GRU6UF5HJIKE3MCN566TIG7UQGIY7MZSCMQC","treat hiragana and katakana as the same char when CASE_SENSITIVE is false"],["HFHOMADVK6SIRUFUUZOQC3XGNSOETNRELZ3RDMZFY3RIBVAYCKIAC","make use of lexical_bool"],["RTRMLNTU262CQDXRF5YALSHUT2XXCOG6NPKFTF767PJ4Q2BYQ72QC","now you can monitor The Whole Known Network (a.k.a. GTL)"]],"deps":["RUZW6T62JOBNDOJPHP5BGN4DIISXEFG554WHWWSJSHBL3AWUXB6AC","EISCAJ3CFVMGPWZQGFI7RZ2A7J4QJ6MN2IRZINV77QMHSESCMO3AC","H7H2NJQAHUY4A5DF2IQLVB5ESJUWYOITYVCDPABMXQ5BRMAZJ7AQC","3BHGSDHUR4TLFVXR74U6BA4HZLLHDAWY3JABHZHBC6RXCZZUUVNQC","VVETADYZOWCU4IYTJVLKZR2X5HWH6FUKIVLWQNQIAUG4LKTONL6QC","73ETI54RGG3MRHZ6SCFMBVJ6FU7WPY2HYEYNDFW4KK4K6CIRE4CAC"],"known":["YMW2RSKMODRBEHP5ZGBQQ3ZKZQCKLGUT3F6MXSI73AK446LRNFKAC","Q2NINZCW6KJVDFJTS6NQ7DTSSWPPU4DG34GGZLEJPK4U6KQAJYWAC","RTRMLNTU262CQDXRF5YALSHUT2XXCOG6NPKFTF767PJ4Q2BYQ72QC","2KXFHTS3VTQWWMOUVONFJ7GYSX4DCHQ6RQ2LGV6TH5R6X7MH7RNAC","OJJEHMKWEKCCM6J5KKAEUGWRAWPZZVSGCXDSCZRZNJ2NQFPLTI3AC","3ZV7EZ26UNQJJM2LW22M7YONNLIQDQVMYJSKQZ5B7SXEMQ4IKHOAC","JLRU6XLFRAA7IVLF2GRU6UF5HJIKE3MCN566TIG7UQGIY7MZSCMQC","HFHOMADVK6SIRUFUUZOQC3XGNSOETNRELZ3RDMZFY3RIBVAYCKIAC"]},"hunks":[{"Edit":{"inode":{"change":8,"pos":21},"path":"src/streamer.rs","line":1,"atom":{"NewVertex":{"up_context":[{"change":8,"pos":21}],"down_context":[{"change":8,"pos":22}],"flag":"BLOCK","start":2,"end":40,"inode":{"change":8,"pos":21}}},"contents":[{"Add":"use crate::filter;"},{"Add":"use crate::logger;"}]}},{"Replacement":{"inode":{"change":8,"pos":21},"path":"src/streamer.rs","line":7,"ins":{"up_context":[{"change":8,"pos":27}],"down_context":[{"change":8,"pos":64}],"flag":"BLOCK","start":41,"end":71,"inode":{"change":8,"pos":21}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":27},"to":{"change":8,"start":27,"end":64},"introduced_by":8}],"inode":{"change":8,"pos":21}},"ins_contents":[{"Add":"pub enum Timeline {"},{"Add":" Home,"}],"del_contents":[{"Del":"pub enum ExtraTimeline {\n Public,\n"}]}},{"Edit":{"inode":{"change":8,"pos":21},"path":"src/streamer.rs","line":10,"atom":{"NewVertex":{"up_context":[{"change":8,"pos":75}],"down_context":[{"change":8,"pos":75}],"flag":"BLOCK","start":72,"end":84,"inode":{"change":8,"pos":21}}},"contents":[{"Add":" Public,"}]}},{"Replacement":{"inode":{"change":8,"pos":21},"path":"src/streamer.rs","line":13,"ins":{"up_context":[{"change":8,"pos":87}],"down_context":[{"change":5,"pos":24}],"flag":"BLOCK","start":85,"end":388,"inode":{"change":8,"pos":21}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":87},"to":{"change":8,"start":87,"end":136},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":136},"to":{"change":8,"start":78,"end":114},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":29},"to":{"change":8,"start":170,"end":263},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":114},"to":{"change":8,"start":170,"end":263},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":170},"to":{"change":8,"start":170,"end":263},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":263},"to":{"change":8,"start":115,"end":146},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":146},"to":{"change":8,"start":263,"end":267},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":263},"to":{"change":8,"start":263,"end":267},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":267},"to":{"change":8,"start":147,"end":227},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":227},"to":{"change":5,"start":2,"end":24},"introduced_by":5}],"inode":{"change":8,"pos":21}},"ins_contents":[{"Add":"pub async fn streaming(tl: Timeline) {"},{"Add":" let config = crate::config::CONFIG.get().unwrap();"},{"Add":""},{"Add":" let client = generator("},{"Add":" config.software.clone(),"},{"Add":" format!(\"https://{}\", config.instance_url),"},{"Add":" Some(config.token.clone()),"},{"Add":" None,"},{"Add":" );"},{"Add":" if matches!(tl, Timeline::Home) {"}],"del_contents":[{"Del":"pub async fn streaming(\n sns: megalodon::SNS,\n"},{"Del":" url: String,\n token: String,\n"},{"Del":" output_dest: String,\n logging_url: Option,\n filter: crate::logger::Filter,\n"},{"Del":" tl: Option,\n"},{"Del":") {\n"},{"Del":" let client = generator(sns, format!(\"https://{}\", url), Some(token), None);\n"},{"Del":" if tl.is_none() {\n"}]}},{"Replacement":{"inode":{"change":8,"pos":21},"path":"src/streamer.rs","line":32,"ins":{"up_context":[{"change":8,"pos":259}],"down_context":[{"change":8,"pos":281}],"flag":"BLOCK","start":389,"end":668,"inode":{"change":8,"pos":21}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":259},"to":{"change":8,"start":259,"end":502},"introduced_by":8}],"inode":{"change":8,"pos":21}},"ins_contents":[{"Add":" Timeline::Public => client.public_streaming(format!(\"wss://{}\", config.instance_url)),"},{"Add":" Timeline::Local => client.local_streaming(format!(\"wss://{}\", config.instance_url)),"},{"Add":" Timeline::Home => client.user_streaming(format!(\"wss://{}\", config.instance_url)),"}],"del_contents":[{"Del":" Some(ExtraTimeline::Public) => client.public_streaming(format!(\"wss://{}\", url)),\n Some(ExtraTimeline::Local) => client.local_streaming(format!(\"wss://{}\", url)),\n None => client.user_streaming(format!(\"wss://{}\", url)),\n"}]}},{"Edit":{"inode":{"change":8,"pos":21},"path":"src/streamer.rs","line":36,"atom":{"EdgeMap":{"edges":[{"previous":"","flag":"DELETED","from":{"change":8,"pos":288},"to":{"change":8,"start":417,"end":489},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":417},"to":{"change":8,"start":417,"end":489},"introduced_by":8}],"inode":{"change":8,"pos":21}}},"contents":[{"Del":"\n let logger = crate::logger::Logger::new(output_dest, logging_url);\n"}]}},{"Replacement":{"inode":{"change":8,"pos":21},"path":"src/streamer.rs","line":40,"ins":{"up_context":[{"change":8,"pos":598}],"down_context":[{"change":8,"pos":731}],"flag":"BLOCK","start":669,"end":785,"inode":{"change":8,"pos":21}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":598},"to":{"change":8,"start":503,"end":586},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":586},"to":{"change":8,"start":669,"end":731},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":669},"to":{"change":8,"start":669,"end":731},"introduced_by":8}],"inode":{"change":8,"pos":21}},"ins_contents":[{"Add":" if filter::filter(mes.clone(), tl.clone()) {"},{"Add":" if let Err(e) = logger::log(mes) {"}],"del_contents":[{"Del":" if crate::logger::egosa(mes.clone(), filter.clone(), tl.clone()) {\n"},{"Del":" if let Err(e) = logger.clone().log(mes) {\n"}]}},{"Replacement":{"inode":{"change":8,"pos":2644},"path":"src/main.rs","line":1,"ins":{"up_context":[{"change":8,"pos":2644}],"down_context":[{"change":8,"pos":2680}],"flag":"BLOCK","start":787,"end":811,"inode":{"change":8,"pos":2644}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":2644},"to":{"change":8,"start":3,"end":25},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":25},"to":{"change":8,"start":3,"end":32},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":2644},"to":{"change":8,"start":3,"end":32},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":32},"to":{"change":8,"start":26,"end":57},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":32},"to":{"change":8,"start":2645,"end":2680},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":57},"to":{"change":8,"start":2645,"end":2680},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":2644},"to":{"change":8,"start":2645,"end":2680},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":2680},"to":{"change":8,"start":588,"end":617},"introduced_by":8}],"inode":{"change":8,"pos":2644}},"ins_contents":[{"Add":"use streamer::Timeline;"}],"del_contents":[{"Del":"use std::ops::Deref;\n\n"},{"Del":"use kanaria::string::UCSStr;\n"},{"Del":"use lexical_bool::LexicalBool;\n"},{"Del":"use log::info;\nuse megalodon::SNS;\n"},{"Del":"use streamer::ExtraTimeline;\n"}]}},{"Edit":{"inode":{"change":8,"pos":2644},"path":"src/main.rs","line":3,"atom":{"NewVertex":{"up_context":[{"change":8,"pos":2681}],"down_context":[{"change":8,"pos":2681}],"flag":"BLOCK","start":812,"end":836,"inode":{"change":8,"pos":2644}}},"contents":[{"Add":"mod config;"},{"Add":"mod filter;"}]}},{"Replacement":{"inode":{"change":8,"pos":2644},"path":"src/main.rs","line":11,"ins":{"up_context":[{"change":8,"pos":2765}],"down_context":[{"change":8,"pos":978}],"flag":"BLOCK","start":837,"end":915,"inode":{"change":8,"pos":2644}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":2765},"to":{"change":8,"start":2765,"end":3668},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":3668},"to":{"change":8,"start":618,"end":886},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":886},"to":{"change":3,"start":3,"end":153},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":153},"to":{"change":8,"start":3668,"end":3807},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":8,"pos":977},"to":{"change":8,"start":3668,"end":3807},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":3668},"to":{"change":8,"start":3668,"end":3807},"introduced_by":8}],"inode":{"change":8,"pos":2644}},"ins_contents":[{"Add":" if let Err(e) = config::load_config().await {"},{"Add":" eprintln!(\"{}\", e);"}],"del_contents":[{"Del":"\n // Read options from .env file\n let sns = match dotenvy::var(\"SOFTWARE\") {\n Err(_) => {\n eprintln!(\"* SOFTWARE is not set; Please specify SOFTWARE to listen to.\");\n return;\n }\n Ok(software) => match software.to_lowercase().as_str() {\n \"pleroma\" => SNS::Pleroma,\n \"mastodon\" => {\n eprintln!(\"* Software other than Pleroma is not tested!\");\n SNS::Mastodon\n }\n \"firefish\" => {\n eprintln!(\"* Software other than Pleroma is not tested!\");\n SNS::Firefish\n }\n \"friendica\" => {\n eprintln!(\"* Software other than Pleroma is not tested!\");\n SNS::Friendica\n }\n unsupported => {\n eprintln!(\"* Software {} is unknown!\", unsupported);\n return;\n }\n"},{"Del":" },\n };\n\n let extra_tl = match dotenvy::var(\"EXTRA_TIMELINE\") {\n Err(_) => None,\n Ok(tl_type) => match tl_type.to_lowercase().as_str() {\n \"public\" => Some(ExtraTimeline::Public),\n \"local\" => Some(ExtraTimeline::Local),\n"},{"Del":" _ => {\n eprintln!(\"* EXTRA_TIMELINE is invalid. Valid values are Public or Local.\");\n return;\n }\n"},{"Del":" },\n };\n\n let Ok(url) = dotenvy::var(\"INSTANCE_URL\") else {\n eprintln!(\"* Please specify INSTANCE_URL to listen to.\");\n"}]}},{"Replacement":{"inode":{"change":8,"pos":2644},"path":"src/main.rs","line":16,"ins":{"up_context":[{"change":8,"pos":3830}],"down_context":[{"change":8,"pos":4073}],"flag":"BLOCK","start":916,"end":970,"inode":{"change":8,"pos":2644}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":3830},"to":{"change":3,"start":154,"end":338},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":338},"to":{"change":8,"start":4066,"end":4073},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":8,"pos":664},"to":{"change":8,"start":4066,"end":4073},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":4066},"to":{"change":8,"start":4066,"end":4073},"introduced_by":8}],"inode":{"change":8,"pos":2644}},"ins_contents":[{"Add":" let timelines = config::TIMELINES.get().unwrap();"}],"del_contents":[{"Del":" let Ok(token) = dotenvy::var(\"ACCESS_TOKEN\") else {\n eprintln!(\"* ACCESS_TOKEN is not set. Generating...\");\n streamer::oath(sns, url.as_str()).await;\n return;\n"},{"Del":" };\n"}]}},{"Replacement":{"inode":{"change":8,"pos":2644},"path":"src/main.rs","line":18,"ins":{"up_context":[{"change":8,"pos":4074}],"down_context":[{"change":8,"pos":4284}],"flag":"BLOCK","start":971,"end":1139,"inode":{"change":8,"pos":2644}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":4074},"to":{"change":8,"start":4074,"end":4284},"introduced_by":8}],"inode":{"change":8,"pos":2644}},"ins_contents":[{"Add":" // Home Timeline"},{"Add":" let home_tl_handle = if timelines.home {"},{"Add":" tokio::spawn(streamer::streaming(Timeline::Home))"},{"Add":" } else {"},{"Add":" tokio::spawn(async {})"}],"del_contents":[{"Del":" let logging_method = match dotenvy::var(\"LOGGER\") {\n Ok(l) => l,\n Err(_) => {\n eprintln!(\"* LOGGER is not set. Falling back to stdout.\");\n \"stdout\".to_string()\n }\n"}]}},{"Replacement":{"inode":{"change":8,"pos":2644},"path":"src/main.rs","line":25,"ins":{"up_context":[{"change":8,"pos":4292}],"down_context":[{"change":8,"pos":578}],"flag":"BLOCK","start":1140,"end":1268,"inode":{"change":8,"pos":2644}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":4292},"to":{"change":8,"start":3,"end":58},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":58},"to":{"change":8,"start":3,"end":4},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":4},"to":{"change":6,"start":3,"end":130},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":6,"pos":130},"to":{"change":8,"start":122,"end":163},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":122},"to":{"change":8,"start":122,"end":163},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":163},"to":{"change":6,"start":131,"end":214},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":6,"pos":214},"to":{"change":8,"start":251,"end":271},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":251},"to":{"change":8,"start":251,"end":271},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":271},"to":{"change":8,"start":568,"end":578},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":568},"to":{"change":8,"start":568,"end":578},"introduced_by":8}],"inode":{"change":8,"pos":2644}},"ins_contents":[{"Add":" // Local Timeline"},{"Add":" let local_tl_handle = if timelines.local {"},{"Add":" tokio::spawn(streamer::streaming(Timeline::Local))"}],"del_contents":[{"Del":" let logging_url = dotenvy::var(\"LOGGER_URL\").ok();\n"},{"Del":"\n"},{"Del":" let is_regex: bool = if let Ok(regex) = dotenvy::var(\"USE_REGEX\") {\n if let Ok(lb) = regex.parse::() {\n"},{"Del":" *lb.deref()\n } else {\n"},{"Del":" eprintln!(\"* The value of USE_REGEX doesn't match expected pattern!\");\n"},{"Del":" return;\n"},{"Del":" }\n"}]}},{"Replacement":{"inode":{"change":8,"pos":2644},"path":"src/main.rs","line":29,"ins":{"up_context":[{"change":8,"pos":591}],"down_context":[{"change":8,"pos":604}],"flag":"BLOCK","start":1269,"end":1300,"inode":{"change":8,"pos":2644}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":591},"to":{"change":6,"start":215,"end":229},"introduced_by":6}],"inode":{"change":8,"pos":2644}},"ins_contents":[{"Add":" tokio::spawn(async {})"}],"del_contents":[{"Del":" false\n"}]}},{"Replacement":{"inode":{"change":8,"pos":2644},"path":"src/main.rs","line":32,"ins":{"up_context":[{"change":6,"pos":231}],"down_context":[{"change":8,"pos":1500}],"flag":"BLOCK","start":1301,"end":1432,"inode":{"change":8,"pos":2644}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":231},"to":{"change":6,"start":231,"end":639},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":8,"pos":58},"to":{"change":8,"start":4426,"end":4490},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":611},"to":{"change":8,"start":4426,"end":4490},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":6,"pos":639},"to":{"change":8,"start":4426,"end":4490},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":4426},"to":{"change":8,"start":4426,"end":4490},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":4490},"to":{"change":8,"start":612,"end":817},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":817},"to":{"change":8,"start":33,"end":119},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":119},"to":{"change":8,"start":876,"end":931},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":876},"to":{"change":8,"start":876,"end":931},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":931},"to":{"change":8,"start":4566,"end":4663},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":4566},"to":{"change":8,"start":4566,"end":4663},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":4663},"to":{"change":8,"start":932,"end":1137},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":1137},"to":{"change":8,"start":120,"end":206},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":206},"to":{"change":8,"start":1196,"end":1251},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":1196},"to":{"change":8,"start":1196,"end":1251},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":1251},"to":{"change":8,"start":4739,"end":5139},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":4739},"to":{"change":8,"start":4739,"end":5139},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":5139},"to":{"change":6,"start":640,"end":682},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":6,"pos":682},"to":{"change":8,"start":1062,"end":1166},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":1062},"to":{"change":8,"start":1062,"end":1166},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":1166},"to":{"change":8,"start":1252,"end":1279},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":1279},"to":{"change":6,"start":683,"end":783},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":6,"pos":783},"to":{"change":8,"start":5223,"end":5224},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":8,"pos":1173},"to":{"change":8,"start":5223,"end":5224},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":5223},"to":{"change":8,"start":5223,"end":5224},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":5224},"to":{"change":8,"start":665,"end":691},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":691},"to":{"change":8,"start":5224,"end":5252},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":5224},"to":{"change":8,"start":5224,"end":5252},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":5252},"to":{"change":8,"start":1174,"end":1500},"introduced_by":8}],"inode":{"change":8,"pos":2644}},"ins_contents":[{"Add":" // Public Timeline"},{"Add":" let public_tl_handle = if timelines.local {"},{"Add":" tokio::spawn(streamer::streaming(Timeline::Public))"}],"del_contents":[{"Del":" let is_case_sensitive: bool = !is_regex\n && if let Ok(case_sensitive) = dotenvy::var(\"CASE_SENSITIVE\") {\n if let Ok(lb) = case_sensitive.parse::() {\n *lb.deref()\n } else {\n eprintln!(\"* The value of CASE_SENSITIVE doesn't match expected pattern!\");\n return;\n }\n } else {\n true\n };\n"},{"Del":"\n let include: Vec = match dotenvy::var(\"INCLUDE\") {\n"},{"Del":" Ok(include) => {\n if is_case_sensitive {\n include.split(',').map(|x| x.to_string()).collect()\n } else {\n include\n .split(',')\n"},{"Del":" .map(|x| UCSStr::from_str(x).lower_case().hiragana().to_string())\n"},{"Del":" .collect()\n }\n }\n"},{"Del":" Err(_) => vec![],\n };\n\n let exclude: Vec = match dotenvy::var(\"EXCLUDE\") {\n"},{"Del":" Ok(exclude) => {\n if is_case_sensitive {\n exclude.split(',').map(|x| x.to_string()).collect()\n } else {\n exclude\n .split(',')\n"},{"Del":" .map(|x| UCSStr::from_str(x).lower_case().hiragana().to_string())\n"},{"Del":" .collect()\n }\n }\n"},{"Del":" Err(_) => vec![],\n };\n\n let user_include: Vec = match dotenvy::var(\"USER_INCLUDE\") {\n Ok(include) => include.split(',').map(|x| x.to_string()).collect(),\n Err(_) => vec![],\n };\n\n let user_exclude: Vec = match dotenvy::var(\"USER_EXCLUDE\") {\n Ok(exclude) => exclude.split(',').map(|x| x.to_string()).collect(),\n Err(_) => vec![],\n };\n\n"},{"Del":" let Ok(filter) = logger::Filter::new(\n"},{"Del":" extra_tl.clone(),\n include,\n exclude,\n user_include,\n user_exclude,\n"},{"Del":" is_case_sensitive,\n"},{"Del":" is_regex,\n ) else {\n eprintln!(\"* Invalid regex syntax!\");\n return;\n };\n"},{"Del":"\n"},{"Del":" info!(\"{:?}\", token);\n"},{"Del":" info!(\"{:?}\", filter);\n\n"},{"Del":" // Extra Timeline\n let extra_tl_handle = if let Some(tl) = extra_tl {\n tokio::spawn(streamer::streaming(\n sns.clone(),\n url.clone(),\n token.clone(),\n logging_method.clone(),\n logging_url.clone(),\n filter.clone(),\n Some(tl),\n ))\n"}]}},{"Edit":{"inode":{"change":8,"pos":2644},"path":"src/main.rs","line":38,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":1551},"to":{"change":8,"start":1551,"end":1803},"introduced_by":8}],"inode":{"change":8,"pos":2644}}},"contents":[{"Del":" // Home Timeline\n let home_tl_handle = tokio::spawn(streamer::streaming(\n sns.clone(),\n url.clone(),\n token.clone(),\n logging_method.clone(),\n logging_url.clone(),\n filter.clone(),\n None,\n ));\n"}]}},{"Replacement":{"inode":{"change":8,"pos":2644},"path":"src/main.rs","line":39,"ins":{"up_context":[{"change":8,"pos":1804}],"down_context":[{"change":8,"pos":5406}],"flag":"BLOCK","start":1433,"end":1510,"inode":{"change":8,"pos":2644}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":1804},"to":{"change":8,"start":1804,"end":1863},"introduced_by":8}],"inode":{"change":8,"pos":2644}},"ins_contents":[{"Add":" let _ = tokio::join!(home_tl_handle, local_tl_handle, public_tl_handle);"}],"del_contents":[{"Del":" let _ = tokio::join!(home_tl_handle, extra_tl_handle);\n"}]}},{"Replacement":{"inode":{"change":8,"pos":5442},"path":"src/logger.rs","line":1,"ins":{"up_context":[{"change":8,"pos":5442}],"down_context":[{"change":8,"pos":5443}],"flag":"BLOCK","start":1512,"end":1555,"inode":{"change":8,"pos":5442}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":5442},"to":{"change":8,"start":1865,"end":1901},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":1901},"to":{"change":8,"start":208,"end":237},"introduced_by":8}],"inode":{"change":8,"pos":5442}},"ins_contents":[{"Add":"use megalodon::entities::StatusVisibility;"}],"del_contents":[{"Del":"use crate::streamer::ExtraTimeline;\n"},{"Del":"use kanaria::string::UCSStr;\n"}]}},{"Edit":{"inode":{"change":8,"pos":5442},"path":"src/logger.rs","line":3,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":5473},"to":{"change":6,"start":785,"end":803},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":6,"pos":803},"to":{"change":8,"start":5473,"end":5556},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":5473},"to":{"change":8,"start":5473,"end":5556},"introduced_by":8}],"inode":{"change":8,"pos":5442}}},"contents":[{"Del":"use regex::Regex;\n"},{"Del":"\n#[derive(Clone)]\npub struct Logger {\n dest: String,\n url: Option,\n}\n"}]}},{"Replacement":{"inode":{"change":8,"pos":5442},"path":"src/logger.rs","line":4,"ins":{"up_context":[{"change":8,"pos":5557}],"down_context":[{"change":8,"pos":5668}],"flag":"BLOCK","start":1556,"end":1698,"inode":{"change":8,"pos":5442}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":5557},"to":{"change":8,"start":5557,"end":5668},"introduced_by":8}],"inode":{"change":8,"pos":5442}},"ins_contents":[{"Add":"pub fn log(message: megalodon::entities::status::Status) -> Result<(), &'static str> {"},{"Add":" let logger = crate::config::LOGGER.get().unwrap();"}],"del_contents":[{"Del":"impl Logger {\n pub fn new(dest: String, url: Option) -> Logger {\n Logger { dest, url }\n }\n"}]}},{"Replacement":{"inode":{"change":8,"pos":5442},"path":"src/logger.rs","line":7,"ins":{"up_context":[{"change":8,"pos":5669}],"down_context":[{"change":8,"pos":6457}],"flag":"BLOCK","start":1699,"end":2324,"inode":{"change":8,"pos":5442}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":5669},"to":{"change":8,"start":5669,"end":6271},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":6271},"to":{"change":4,"start":4,"end":54},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":54},"to":{"change":8,"start":6341,"end":6457},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":6341},"to":{"change":8,"start":6341,"end":6457},"introduced_by":8}],"inode":{"change":8,"pos":5442}},"ins_contents":[{"Add":" match logger.logger_type.to_lowercase().as_str() {"},{"Add":" \"stdout\" => {"},{"Add":" log::debug!(\"{:?}\", message);"},{"Add":" println!(\"==========\");"},{"Add":" println!("},{"Add":" \"Name: {} ({})\","},{"Add":" message.account.display_name, message.account.acct"},{"Add":" );"},{"Add":" println!(\"Content:\");"},{"Add":" println!("},{"Add":" \"{}\","},{"Add":" message.plain_content.unwrap_or(html2text(&message.content))"},{"Add":" );"},{"Add":" println!(\"URL: {}\", message.uri);"},{"Add":" Ok(())"},{"Add":" }"},{"Add":" \"discord\" => {"},{"Add":" let Some(webhook) = logger.logger_url.clone() else {"}],"del_contents":[{"Del":" pub fn log(self, message: megalodon::entities::status::Status) -> Result<(), &'static str> {\n match self.dest.to_lowercase().as_str() {\n \"stdout\" => {\n log::debug!(\"{:?}\", message);\n println!(\"==========\");\n println!(\n \"Name: {} ({})\",\n message.account.display_name, message.account.acct\n );\n println!(\"Content:\");\n println!(\n \"{}\",\n message.plain_content.unwrap_or(html2text(&message.content))\n );\n"},{"Del":" println!(\"URL: {}\", message.uri);\n"},{"Del":" Ok(())\n }\n \"discord\" => {\n let Some(webhook) = self.url else {\n"}]}},{"Replacement":{"inode":{"change":8,"pos":5442},"path":"src/logger.rs","line":27,"ins":{"up_context":[{"change":8,"pos":6551}],"down_context":[{"change":8,"pos":7123}],"flag":"BLOCK","start":2325,"end":3077,"inode":{"change":8,"pos":5442}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":6551},"to":{"change":8,"start":6551,"end":6867},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":6867},"to":{"change":4,"start":55,"end":103},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":103},"to":{"change":8,"start":6915,"end":7123},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":6915},"to":{"change":8,"start":6915,"end":7123},"introduced_by":8}],"inode":{"change":8,"pos":5442}},"ins_contents":[{"Add":" let json = if message.visibility == StatusVisibility::Private"},{"Add":" || message.visibility == StatusVisibility::Direct"},{"Add":" {"},{"Add":" ureq::json!({"},{"Add":" \"username\": message.account.display_name,"},{"Add":" \"avatar_url\": message.account.avatar,"},{"Add":" \"content\": format!(\"{}\\nLink: {}\", message.plain_content.unwrap_or(html2text(&message.content)), message.uri),"},{"Add":" })"},{"Add":" } else {"},{"Add":" ureq::json!({"},{"Add":" \"content\": message.uri,"},{"Add":" })"},{"Add":" };"},{"Add":" if ureq::post(&webhook).send_json(json).is_err() {"},{"Add":" Err(\"* Something happend executing Webhook.\")"},{"Add":" } else {"},{"Add":" Ok(())"}],"del_contents":[{"Del":" if ureq::post(&webhook)\n .send_json(ureq::json!({\n //\"username\": message.account.display_name,\n //\"avatar_url\": message.account.avatar,\n //\"content\": message.plain_content.unwrap_or(html2text(&message.content)),\n"},{"Del":" \"content\": message.uri,\n"},{"Del":" }))\n .is_err()\n {\n Err(\"* Something happend executing Webhook.\")\n } else {\n Ok(())\n }\n"}]}},{"Edit":{"inode":{"change":8,"pos":5442},"path":"src/logger.rs","line":45,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7137},"to":{"change":8,"start":7137,"end":7179},"introduced_by":8}],"inode":{"change":8,"pos":5442}}},"contents":[{"Del":" _ => Err(\"* Unkown logger.\"),\n"}]}},{"Edit":{"inode":{"change":8,"pos":5442},"path":"src/logger.rs","line":46,"atom":{"NewVertex":{"up_context":[{"change":8,"pos":7189}],"down_context":[{"change":8,"pos":7189}],"flag":"BLOCK","start":3078,"end":3116,"inode":{"change":8,"pos":5442}}},"contents":[{"Add":" _ => Err(\"* Unkown logger.\"),"}]}},{"Edit":{"inode":{"change":8,"pos":5442},"path":"src/logger.rs","line":48,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7195},"to":{"change":8,"start":7195,"end":7242},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7242},"to":{"change":8,"start":1902,"end":1939},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":1939},"to":{"change":8,"start":7242,"end":7294},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7242},"to":{"change":8,"start":7242,"end":7294},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7294},"to":{"change":6,"start":804,"end":866},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":6,"pos":866},"to":{"change":8,"start":7294,"end":7356},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7294},"to":{"change":8,"start":7294,"end":7356},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7356},"to":{"change":8,"start":1281,"end":1310},"introduced_by":8}],"inode":{"change":8,"pos":5442}}},"contents":[{"Del":"}\n\n#[derive(Clone, Debug)]\npub struct Filter {\n"},{"Del":" extra_tl: Option,\n"},{"Del":" include: Vec,\n exclude: Vec,\n"},{"Del":" include_regex: Vec,\n exclude_regex: Vec,\n"},{"Del":" user_include: Vec,\n user_exclude: Vec,\n"},{"Del":" is_case_sensitive: bool,\n"}]}},{"Edit":{"inode":{"change":8,"pos":5442},"path":"src/logger.rs","line":49,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7358},"to":{"change":8,"start":7358,"end":7389},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7389},"to":{"change":8,"start":1940,"end":1981},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":1981},"to":{"change":8,"start":7389,"end":7519},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7389},"to":{"change":8,"start":7389,"end":7519},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7519},"to":{"change":8,"start":1311,"end":1344},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":1344},"to":{"change":6,"start":867,"end":1880},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":6,"pos":1880},"to":{"change":8,"start":1982,"end":2004},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7554},"to":{"change":8,"start":1982,"end":2004},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":2004},"to":{"change":6,"start":1881,"end":2007},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":6,"pos":2007},"to":{"change":8,"start":7596,"end":7648},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7596},"to":{"change":8,"start":7596,"end":7648},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7648},"to":{"change":8,"start":1345,"end":1376},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":1376},"to":{"change":6,"start":2008,"end":2019},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":6,"pos":2019},"to":{"change":8,"start":7658,"end":7667},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7658},"to":{"change":8,"start":7658,"end":7667},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7667},"to":{"change":8,"start":2005,"end":2134},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":2134},"to":{"change":7,"start":4,"end":118},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":118},"to":{"change":8,"start":2134,"end":2177},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":2134},"to":{"change":8,"start":2134,"end":2177},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":2177},"to":{"change":4,"start":104,"end":404},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":404},"to":{"change":8,"start":2619,"end":2626},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":2619},"to":{"change":8,"start":2619,"end":2626},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":2626},"to":{"change":8,"start":7754,"end":7974},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7754},"to":{"change":8,"start":7754,"end":7974},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":7974},"to":{"change":8,"start":1377,"end":1464},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":1464},"to":{"change":8,"start":238,"end":364},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":364},"to":{"change":8,"start":1503,"end":1510},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":1503},"to":{"change":8,"start":1503,"end":1510},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":1510},"to":{"change":8,"start":8042,"end":8469},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":8042},"to":{"change":8,"start":8042,"end":8469},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":8469},"to":{"change":6,"start":2020,"end":2465},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":6,"pos":2465},"to":{"change":8,"start":8469,"end":8480},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":8469},"to":{"change":8,"start":8469,"end":8480},"introduced_by":8}],"inode":{"change":8,"pos":5442}}},"contents":[{"Del":"\nimpl Filter {\n pub fn new(\n"},{"Del":" extra_tl: Option,\n"},{"Del":" include: Vec,\n exclude: Vec,\n user_include: Vec,\n user_exclude: Vec,\n"},{"Del":" is_case_sensitive: bool,\n"},{"Del":" is_regex: bool,\n ) -> Result {\n let include_plain: Vec;\n let exclude_plain: Vec;\n let mut include_regex: Vec;\n let mut exclude_regex: Vec;\n if is_regex {\n include_plain = vec![];\n exclude_plain = vec![];\n include_regex = vec![];\n exclude_regex = vec![];\n for i in include {\n let Ok(re) = Regex::new(i.as_str()) else {\n return Err(\"Invalid Regex\");\n };\n include_regex.push(re);\n }\n for i in exclude {\n let Ok(re) = Regex::new(i.as_str()) else {\n return Err(\"Invalid Regex\");\n };\n exclude_regex.push(re);\n }\n } else {\n include_plain = include;\n exclude_plain = exclude;\n include_regex = vec![];\n exclude_regex = vec![];\n }\n Ok(Filter {\n"},{"Del":" extra_tl,\n"},{"Del":" include: include_plain,\n exclude: exclude_plain,\n include_regex,\n exclude_regex,\n"},{"Del":" user_include,\n user_exclude,\n"},{"Del":" is_case_sensitive,\n"},{"Del":" })\n"},{"Del":" }\n}\n\n"},{"Del":"pub fn egosa(\n message: megalodon::entities::status::Status,\n settings: Filter,\n tl: Option,\n) -> bool {\n"},{"Del":" // Remove Repeats (a.k.a. Boosts)\n if message.reblogged.unwrap_or_default() {\n return false;\n }\n\n"},{"Del":" // Remove dupicates from Home Timeline\n"},{"Del":" if tl.is_none() && message.visibility == megalodon::entities::StatusVisibility::Public {\n match settings.extra_tl {\n Some(ExtraTimeline::Public) => return false,\n Some(ExtraTimeline::Local) => return message.account.acct.contains('@'),\n _ => {}\n };\n"},{"Del":" }\n\n"},{"Del":" if !settings.user_include.is_empty() && !settings.user_include.contains(&message.account.acct) {\n return false;\n }\n if settings.user_exclude.contains(&message.account.acct) {\n return false;\n }\n"},{"Del":" let content = if settings.is_case_sensitive {\n message.content\n } else {\n"},{"Del":" UCSStr::from_str(message.content.as_str())\n .lower_case()\n .hiragana()\n .to_string()\n"},{"Del":" };\n"},{"Del":" if !settings.include.is_empty()\n && settings\n .include\n .into_iter()\n .filter(|x| content.contains(x))\n .collect::>()\n .is_empty()\n {\n return false;\n }\n if !settings\n .exclude\n .into_iter()\n .filter(|x| content.contains(x))\n .collect::>()\n .is_empty()\n {\n return false;\n }\n"},{"Del":" if !settings.include_regex.is_empty()\n && settings\n .include_regex\n .into_iter()\n .filter(|x| x.is_match(&content))\n .collect::>()\n .is_empty()\n {\n return false;\n }\n if !settings\n .exclude_regex\n .into_iter()\n .filter(|x| x.is_match(&content))\n .collect::>()\n .is_empty()\n {\n return false;\n }\n"},{"Del":" true\n}\n"}]}},{"FileAdd":{"meta":{"basename":"filter.rs","metadata":0},"context":[{"change":8,"pos":4}],"contents":[{"Add":"use crate::config::TimelineSetting;"},{"Add":"use crate::streamer::Timeline;"},{"Add":"use kanaria::string::UCSStr;"},{"Add":"use megalodon::entities::StatusVisibility;"},{"Add":"use regex::Regex;"},{"Add":""},{"Add":"pub fn filter(message: megalodon::entities::status::Status, tl: Timeline) -> bool {"},{"Add":" let filter = crate::config::FILTER.get().unwrap();"},{"Add":" let timeline_setting = crate::config::TIMELINES.get().unwrap();"},{"Add":""},{"Add":" // Remove Repeats (a.k.a. Boosts)"},{"Add":" if message.reblogged.unwrap_or_default() {"},{"Add":" return false;"},{"Add":" }"},{"Add":""},{"Add":" // Remove dupicates from Home Timeline"},{"Add":" if matches!(tl, Timeline::Home) && message.visibility == StatusVisibility::Public {"},{"Add":" match timeline_setting {"},{"Add":" TimelineSetting { public: true, .. } => return false,"},{"Add":" TimelineSetting { local: true, .. } => return message.account.acct.contains('@'),"},{"Add":" _ => {}"},{"Add":" };"},{"Add":" }"},{"Add":""},{"Add":" if !filter.user_include.is_empty() && !filter.user_include.contains(&message.account.acct) {"},{"Add":" return false;"},{"Add":" }"},{"Add":" if filter.user_exclude.contains(&message.account.acct) {"},{"Add":" return false;"},{"Add":" }"},{"Add":" let content = if filter.is_case_sensitive {"},{"Add":" message.content"},{"Add":" } else {"},{"Add":" UCSStr::from_str(message.content.as_str())"},{"Add":" .lower_case()"},{"Add":" .hiragana()"},{"Add":" .to_string()"},{"Add":" };"},{"Add":" if !filter.include.is_empty()"},{"Add":" && filter"},{"Add":" .include"},{"Add":" .clone()"},{"Add":" .into_iter()"},{"Add":" .filter(|x| content.contains(x))"},{"Add":" .collect::>()"},{"Add":" .is_empty()"},{"Add":" {"},{"Add":" return false;"},{"Add":" }"},{"Add":" if !filter"},{"Add":" .exclude"},{"Add":" .clone()"},{"Add":" .into_iter()"},{"Add":" .filter(|x| content.contains(x))"},{"Add":" .collect::>()"},{"Add":" .is_empty()"},{"Add":" {"},{"Add":" return false;"},{"Add":" }"},{"Add":" if !filter.include_regex.is_empty()"},{"Add":" && filter"},{"Add":" .include_regex"},{"Add":" .clone()"},{"Add":" .into_iter()"},{"Add":" .filter(|x| x.is_match(&content))"},{"Add":" .collect::>()"},{"Add":" .is_empty()"},{"Add":" {"},{"Add":" return false;"},{"Add":" }"},{"Add":" if !filter"},{"Add":" .exclude_regex"},{"Add":" .clone()"},{"Add":" .into_iter()"},{"Add":" .filter(|x| x.is_match(&content))"},{"Add":" .collect::>()"},{"Add":" .is_empty()"},{"Add":" {"},{"Add":" return false;"},{"Add":" }"},{"Add":" true"},{"Add":"}"}]}},{"FileAdd":{"meta":{"basename":"config.rs","metadata":0},"context":[{"change":8,"pos":4}],"contents":[{"Add":"use kanaria::string::UCSStr;"},{"Add":"use lexical_bool::LexicalBool;"},{"Add":"use megalodon::SNS;"},{"Add":"use regex::Regex;"},{"Add":"use std::ops::Deref;"},{"Add":"use std::sync::OnceLock;"},{"Add":""},{"Add":"pub struct Config {"},{"Add":" pub software: SNS,"},{"Add":" pub instance_url: String,"},{"Add":" pub token: String,"},{"Add":"}"},{"Add":""},{"Add":"impl Config {"},{"Add":" pub fn new(software: SNS, instance_url: String, token: String) -> Self {"},{"Add":" Config {"},{"Add":" software,"},{"Add":" instance_url,"},{"Add":" token,"},{"Add":" }"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"#[derive(Clone, Debug)]"},{"Add":"pub struct Filter {"},{"Add":" pub include: Vec,"},{"Add":" pub exclude: Vec,"},{"Add":" pub include_regex: Vec,"},{"Add":" pub exclude_regex: Vec,"},{"Add":" pub user_include: Vec,"},{"Add":" pub user_exclude: Vec,"},{"Add":" pub is_case_sensitive: bool,"},{"Add":"}"},{"Add":""},{"Add":"impl Filter {"},{"Add":" pub fn new("},{"Add":" include: Vec,"},{"Add":" exclude: Vec,"},{"Add":" user_include: Vec,"},{"Add":" user_exclude: Vec,"},{"Add":" is_case_sensitive: bool,"},{"Add":" is_regex: bool,"},{"Add":" ) -> Result {"},{"Add":" let include_plain: Vec;"},{"Add":" let exclude_plain: Vec;"},{"Add":" let mut include_regex: Vec;"},{"Add":" let mut exclude_regex: Vec;"},{"Add":" if is_regex {"},{"Add":" include_plain = vec![];"},{"Add":" exclude_plain = vec![];"},{"Add":" include_regex = vec![];"},{"Add":" exclude_regex = vec![];"},{"Add":" for i in include {"},{"Add":" let Ok(re) = Regex::new(i.as_str()) else {"},{"Add":" return Err(\"Invalid Regex\");"},{"Add":" };"},{"Add":" include_regex.push(re);"},{"Add":" }"},{"Add":" for i in exclude {"},{"Add":" let Ok(re) = Regex::new(i.as_str()) else {"},{"Add":" return Err(\"Invalid Regex\");"},{"Add":" };"},{"Add":" exclude_regex.push(re);"},{"Add":" }"},{"Add":" } else {"},{"Add":" include_plain = include;"},{"Add":" exclude_plain = exclude;"},{"Add":" include_regex = vec![];"},{"Add":" exclude_regex = vec![];"},{"Add":" }"},{"Add":" Ok(Filter {"},{"Add":" include: include_plain,"},{"Add":" exclude: exclude_plain,"},{"Add":" include_regex,"},{"Add":" exclude_regex,"},{"Add":" user_include,"},{"Add":" user_exclude,"},{"Add":" is_case_sensitive,"},{"Add":" })"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"pub struct Logger {"},{"Add":" pub logger_type: String,"},{"Add":" pub logger_url: Option,"},{"Add":"}"},{"Add":""},{"Add":"impl Logger {"},{"Add":" pub fn new(logger_type: String, logger_url: Option) -> Self {"},{"Add":" Logger {"},{"Add":" logger_type,"},{"Add":" logger_url,"},{"Add":" }"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"pub struct TimelineSetting {"},{"Add":" pub home: bool,"},{"Add":" pub local: bool,"},{"Add":" pub public: bool,"},{"Add":"}"},{"Add":""},{"Add":"impl TimelineSetting {"},{"Add":" pub fn new(home: bool, local: bool, public: bool) -> Self {"},{"Add":" TimelineSetting {"},{"Add":" home,"},{"Add":" local,"},{"Add":" public,"},{"Add":" }"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"pub static CONFIG: OnceLock = OnceLock::new();"},{"Add":"pub static FILTER: OnceLock = OnceLock::new();"},{"Add":"pub static LOGGER: OnceLock = OnceLock::new();"},{"Add":"pub static TIMELINES: OnceLock = OnceLock::new();"},{"Add":""},{"Add":"// Read options from .env file"},{"Add":"pub async fn load_config() -> Result<(), String> {"},{"Add":" let software = match dotenvy::var(\"SOFTWARE\") {"},{"Add":" Err(_) => {"},{"Add":" return Err(\"* SOFTWARE is not set; Please specify SOFTWARE to listen to.\".to_string());"},{"Add":" }"},{"Add":" Ok(software) => match software.to_lowercase().as_str() {"},{"Add":" \"pleroma\" => SNS::Pleroma,"},{"Add":" \"mastodon\" => {"},{"Add":" eprintln!(\"* Software other than Pleroma is not tested!\");"},{"Add":" SNS::Mastodon"},{"Add":" }"},{"Add":" \"firefish\" => {"},{"Add":" eprintln!(\"* Software other than Pleroma is not tested!\");"},{"Add":" SNS::Firefish"},{"Add":" }"},{"Add":" \"friendica\" => {"},{"Add":" eprintln!(\"* Software other than Pleroma is not tested!\");"},{"Add":" SNS::Friendica"},{"Add":" }"},{"Add":" unsupported => {"},{"Add":" return Err(format!(\"* Software {} is unknown!\", unsupported));"},{"Add":" }"},{"Add":" },"},{"Add":" };"},{"Add":""},{"Add":" let Ok(instance_url) = dotenvy::var(\"INSTANCE_URL\") else {"},{"Add":" return Err(\"* Please specify INSTANCE_URL to listen to.\".to_string());"},{"Add":" };"},{"Add":""},{"Add":" let Ok(token) = dotenvy::var(\"ACCESS_TOKEN\") else {"},{"Add":" eprintln!(\"* ACCESS_TOKEN is not set. Generating...\");"},{"Add":" crate::streamer::oath(software, instance_url.as_str()).await;"},{"Add":" return Err(String::new());"},{"Add":" };"},{"Add":""},{"Add":" let logging_method = match dotenvy::var(\"LOGGER\") {"},{"Add":" Ok(l) => l,"},{"Add":" Err(_) => {"},{"Add":" eprintln!(\"* LOGGER is not set. Falling back to stdout.\");"},{"Add":" \"stdout\".to_string()"},{"Add":" }"},{"Add":" };"},{"Add":""},{"Add":" let logging_url = dotenvy::var(\"LOGGER_URL\").ok();"},{"Add":""},{"Add":" let is_regex: bool = if let Ok(regex) = dotenvy::var(\"USE_REGEX\") {"},{"Add":" if let Ok(lb) = regex.parse::() {"},{"Add":" *lb.deref()"},{"Add":" } else {"},{"Add":" return Err(\"* The value of USE_REGEX doesn't match expected pattern!\".to_string());"},{"Add":" }"},{"Add":" } else {"},{"Add":" false"},{"Add":" };"},{"Add":""},{"Add":" let is_case_sensitive: bool = !is_regex"},{"Add":" && if let Ok(case_sensitive) = dotenvy::var(\"CASE_SENSITIVE\") {"},{"Add":" if let Ok(lb) = case_sensitive.parse::() {"},{"Add":" *lb.deref()"},{"Add":" } else {"},{"Add":" return Err("},{"Add":" \"* the value of case_sensitive doesn't match expected pattern!\".to_string(),"},{"Add":" );"},{"Add":" }"},{"Add":" } else {"},{"Add":" true"},{"Add":" };"},{"Add":""},{"Add":" let timelines = match dotenvy::var(\"TIMELINES\") {"},{"Add":" Ok(tl) => {"},{"Add":" let mut home = false;"},{"Add":" let mut local = false;"},{"Add":" let mut public = false;"},{"Add":" for tl in tl.split(',') {"},{"Add":" match tl.to_lowercase().as_str() {"},{"Add":" \"home\" => home = true,"},{"Add":" \"local\" => local = true,"},{"Add":" \"public\" => public = true,"},{"Add":" invalid => {"},{"Add":" eprintln!(\"* Timeline type {} is unkown!\", invalid);"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":" if !(home || local || public) {"},{"Add":" eprintln!(\"* No valid timeline type found. Falling back to Home...\");"},{"Add":" TimelineSetting::new(true, false, false)"},{"Add":" } else {"},{"Add":" TimelineSetting::new(home, local, public)"},{"Add":" }"},{"Add":" }"},{"Add":" Err(_) => {"},{"Add":" eprintln!(\"* No timelines specified. Falling back to Home...\");"},{"Add":""},{"Add":" TimelineSetting::new(true, false, false)"},{"Add":" }"},{"Add":" };"},{"Add":""},{"Add":" let include: Vec = match dotenvy::var(\"INCLUDE\") {"},{"Add":" Ok(include) => {"},{"Add":" if is_case_sensitive {"},{"Add":" include.split(',').map(|x| x.to_string()).collect()"},{"Add":" } else {"},{"Add":" include"},{"Add":" .split(',')"},{"Add":" .map(|x| UCSStr::from_str(x).lower_case().hiragana().to_string())"},{"Add":" .collect()"},{"Add":" }"},{"Add":" }"},{"Add":" Err(_) => vec![],"},{"Add":" };"},{"Add":""},{"Add":" let exclude: Vec = match dotenvy::var(\"EXCLUDE\") {"},{"Add":" Ok(exclude) => {"},{"Add":" if is_case_sensitive {"},{"Add":" exclude.split(',').map(|x| x.to_string()).collect()"},{"Add":" } else {"},{"Add":" exclude"},{"Add":" .split(',')"},{"Add":" .map(|x| UCSStr::from_str(x).lower_case().hiragana().to_string())"},{"Add":" .collect()"},{"Add":" }"},{"Add":" }"},{"Add":" Err(_) => vec![],"},{"Add":" };"},{"Add":""},{"Add":" let user_include: Vec = match dotenvy::var(\"USER_INCLUDE\") {"},{"Add":" Ok(include) => include.split(',').map(|x| x.to_string()).collect(),"},{"Add":" Err(_) => vec![],"},{"Add":" };"},{"Add":""},{"Add":" let user_exclude: Vec = match dotenvy::var(\"USER_EXCLUDE\") {"},{"Add":" Ok(exclude) => exclude.split(',').map(|x| x.to_string()).collect(),"},{"Add":" Err(_) => vec![],"},{"Add":" };"},{"Add":""},{"Add":" let Ok(filter) = Filter::new("},{"Add":" include,"},{"Add":" exclude,"},{"Add":" user_include,"},{"Add":" user_exclude,"},{"Add":" is_case_sensitive,"},{"Add":" is_regex,"},{"Add":" ) else {"},{"Add":" return Err(\"* invalid regex syntax!\".to_string());"},{"Add":" };"},{"Add":""},{"Add":" if CONFIG"},{"Add":" .set(Config::new(software, instance_url, token))"},{"Add":" .is_err()"},{"Add":" {"},{"Add":" return Err(\"* Failed to load config file!\".to_string());"},{"Add":" }"},{"Add":""},{"Add":" if FILTER.set(filter).is_err() {"},{"Add":" return Err(\"* Failed to load config file!\".to_string());"},{"Add":" }"},{"Add":""},{"Add":" if LOGGER"},{"Add":" .set(Logger::new(logging_method, logging_url))"},{"Add":" .is_err()"},{"Add":" {"},{"Add":" return Err(\"* Failed to load config file!\".to_string());"},{"Add":" }"},{"Add":""},{"Add":" if TIMELINES.set(timelines).is_err() {"},{"Add":" return Err(\"* Failed to load config file!\".to_string());"},{"Add":" }"},{"Add":""},{"Add":" Ok(())"},{"Add":"}"}]}},{"Replacement":{"inode":{"change":8,"pos":8516},"path":"README.md","line":18,"ins":{"up_context":[{"change":8,"pos":9492}],"down_context":[{"change":8,"pos":366}],"flag":"BLOCK","start":13781,"end":13881,"inode":{"change":8,"pos":8516}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":9492},"to":{"change":8,"start":2628,"end":2714},"introduced_by":8}],"inode":{"change":8,"pos":8516}},"ins_contents":[{"Add":"TIMELINES=監視対象にするタイムライン(Home、PublicまたはLocalから複数選択可)"}],"del_contents":[{"Del":"EXTRA_TIMELINE=追加で監視対象にするタイムライン(PublicまたはLocal)\n"}]}},{"Edit":{"inode":{"change":8,"pos":8516},"path":"README.md","line":26,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":9895},"to":{"change":8,"start":2715,"end":2754},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":2754},"to":{"change":8,"start":822,"end":823},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":9895},"to":{"change":8,"start":822,"end":823},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":823},"to":{"change":8,"start":2755,"end":2810},"introduced_by":8}],"inode":{"change":8,"pos":8516}}},"contents":[{"Del":"\n`EXTRA_TIMELINE`の挙動について\n"},{"Del":"\n"},{"Del":"1. 未設定の場合、HTLのみを監視します。\n"}]}},{"Edit":{"inode":{"change":8,"pos":8516},"path":"README.md","line":27,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":9896},"to":{"change":8,"start":2811,"end":3024},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":3024},"to":{"change":8,"start":981,"end":982},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":981},"to":{"change":8,"start":981,"end":982},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":982},"to":{"change":8,"start":3025,"end":3188},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":8,"pos":3188},"to":{"change":8,"start":1177,"end":1178},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":1177},"to":{"change":8,"start":1177,"end":1178},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":1308},"to":{"change":8,"start":1308,"end":1309},"introduced_by":8}],"inode":{"change":8,"pos":8516}}},"contents":[{"Del":"2. Publicが指定されている場合、HTLに加えてGTL(「すべてのネットワーク」(Pleroma)、「連合タイムライン」(Mastodon))も監視します。(GTLが使用できるサーバーのみ)\n"},{"Del":"\n"},{"Del":"3. Localが指定されている場合、HTLに加えてLTL(「公開タイムライン」(Pleroma))も監視します。(LTLが使用できるサーバーのみ)\n"},{"Del":"\n"},{"Del":"\n"}]}},{"Edit":{"inode":{"change":8,"pos":8516},"path":"README.md","line":28,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":9911},"to":{"change":8,"start":9911,"end":9912},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":9912},"to":{"change":2,"start":5,"end":72},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":72},"to":{"change":8,"start":9977,"end":10025},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":9977},"to":{"change":8,"start":9977,"end":10025},"introduced_by":8}],"inode":{"change":8,"pos":8516}}},"contents":[{"Del":"\n"},{"Del":"- リピート(ブースト)のユーザー表記がおかしい \n"},{"Del":" 対処法がわからなかったので放置\n"}]}},{"Replacement":{"inode":{"change":8,"pos":8516},"path":"README.md","line":30,"ins":{"up_context":[{"change":2,"pos":105}],"down_context":[{"change":8,"pos":10070}],"flag":"BLOCK","start":13882,"end":14050,"inode":{"change":8,"pos":8516}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":2,"pos":105},"to":{"change":8,"start":10058,"end":10070},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":10058},"to":{"change":8,"start":10058,"end":10070},"introduced_by":8}],"inode":{"change":8,"pos":8516}},"ins_contents":[{"Add":" ちょっとずつマシになっているようないないような…"},{"Add":""},{"Add":"- 設定ファイルの破壊的変更大杉 "},{"Add":" もうちょっとしたら安定します"}],"del_contents":[{"Del":" はい…\n"}]}}],"owner":"syobon","repo":"plegosa","token":"BlsSTwXGDaaAz2sYzttBRqml153OtgLXgVl43cJBSl8=","login":null}

…

Dependencies

Change contents