{"header":{"message":"Read processors from config","description":null,"timestamp":"2021-10-04T02:02:25.54136471Z","authors":[{}]},"hash":"5GJRHBKCSWISBPJOAXWMXY3LMMD5GFOEHM3AEUKI5J7D4M3XM5GQC","authors":[{"login":"isagalaev","key":"GGyJA92mZf4oyvR5S2XWq6i2USZKkrxmabqwBcQpBwSe"}],"deps":{"hashes":[["5GJRHBKCSWISBPJOAXWMXY3LMMD5GFOEHM3AEUKI5J7D4M3XM5GQC","Read processors from config"],["AA",null],["FVJQ6OJYLCXGPDNHCP56JXZ44VQKFIOC7NC3S42D3JPQSZ2F7R4AC","Support multiple processors"],["SY4Q66QFFEQ2BPMJ5G7MSZPX52HM6QTHZXJWL2VVFB2JMWZQLJBQC","First draft"]],"deps":["FVJQ6OJYLCXGPDNHCP56JXZ44VQKFIOC7NC3S42D3JPQSZ2F7R4AC"],"known":["SY4Q66QFFEQ2BPMJ5G7MSZPX52HM6QTHZXJWL2VVFB2JMWZQLJBQC"]},"hunks":[{"Edit":{"inode":{"change":3,"pos":48},"path":"src/main.rs","line":7,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":175}],"down_context":[{"change":3,"pos":176}],"flag":"BLOCK","start":0,"end":19,"inode":{"change":3,"pos":48}}},"contents":[{"Add":"use std::io::Read;"}]}},{"Edit":{"inode":{"change":3,"pos":48},"path":"src/main.rs","line":10,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":224}],"down_context":[{"change":3,"pos":224}],"flag":"BLOCK","start":20,"end":134,"inode":{"change":3,"pos":48}}},"contents":[{"Add":""},{"Add":"#[derive(serde::Deserialize)]"},{"Add":"struct Processor {"},{"Add":" path: String,"},{"Add":" command: String,"},{"Add":" args: Vec,"},{"Add":"}"}]}},{"Replacement":{"inode":{"change":3,"pos":48},"path":"src/main.rs","line":18,"ins":{"up_context":[{"change":3,"pos":225}],"down_context":[{"change":2,"pos":174}],"flag":"BLOCK","start":135,"end":213,"inode":{"change":3,"pos":48}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":225},"to":{"change":2,"start":84,"end":174},"introduced_by":2}],"inode":{"change":3,"pos":48}},"ins_contents":[{"Add":"#[derive(serde::Deserialize)]"},{"Add":"struct Config {"},{"Add":" processors: Vec,"}],"del_contents":[{"Del":"struct Processor<'a> {\n path: &'a Path,\n command: &'a str,\n args: &'a [&'a str],\n"}]}},{"Replacement":{"inode":{"change":3,"pos":48},"path":"src/main.rs","line":23,"ins":{"up_context":[{"change":2,"pos":177}],"down_context":[{"change":3,"pos":285}],"flag":"BLOCK","start":214,"end":306,"inode":{"change":3,"pos":48}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":177},"to":{"change":2,"start":177,"end":267},"introduced_by":2}],"inode":{"change":3,"pos":48}},"ins_contents":[{"Add":"fn process(filename: &Path, command: &str, args: &[String]) -> Result<(), Box> {"}],"del_contents":[{"Del":"fn process(filename: &Path, command: &str, args: &[&str]) -> Result<(), Box> {\n"}]}},{"Replacement":{"inode":{"change":3,"pos":48},"path":"src/main.rs","line":38,"ins":{"up_context":[{"change":3,"pos":748}],"down_context":[{"change":2,"pos":467}],"flag":"BLOCK","start":307,"end":388,"inode":{"change":3,"pos":48}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":748},"to":{"change":2,"start":378,"end":467},"introduced_by":2}],"inode":{"change":3,"pos":48}},"ins_contents":[{"Add":"fn register_processor("},{"Add":" processors: &mut HashMap,"}],"del_contents":[{"Del":"fn register_processor<'a>(\n processors: &mut HashMap>,\n"}]}},{"Replacement":{"inode":{"change":3,"pos":48},"path":"src/main.rs","line":41,"ins":{"up_context":[{"change":2,"pos":494}],"down_context":[{"change":2,"pos":561}],"flag":"BLOCK","start":389,"end":415,"inode":{"change":3,"pos":48}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":494},"to":{"change":2,"start":494,"end":561},"introduced_by":2}],"inode":{"change":3,"pos":48}},"ins_contents":[{"Add":" processor: Processor,"}],"del_contents":[{"Del":" path: &'a Path,\n command: &'a str,\n args: &'a [&'a str],\n"}]}},{"Replacement":{"inode":{"change":3,"pos":48},"path":"src/main.rs","line":45,"ins":{"up_context":[{"change":2,"pos":645}],"down_context":[{"change":2,"pos":717}],"flag":"BLOCK","start":416,"end":500,"inode":{"change":3,"pos":48}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":645},"to":{"change":2,"start":645,"end":717},"introduced_by":2}],"inode":{"change":3,"pos":48}},"ins_contents":[{"Add":" processor.path,"},{"Add":" processor.command,"},{"Add":" processor.args.join(\" \")"}],"del_contents":[{"Del":" path.to_string_lossy(),\n command,\n args.join(\" \")\n"}]}},{"Replacement":{"inode":{"change":3,"pos":48},"path":"src/main.rs","line":49,"ins":{"up_context":[{"change":2,"pos":724}],"down_context":[{"change":2,"pos":879}],"flag":"BLOCK","start":501,"end":583,"inode":{"change":3,"pos":48}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":724},"to":{"change":2,"start":724,"end":879},"introduced_by":2}],"inode":{"change":3,"pos":48}},"ins_contents":[{"Add":" let descriptor = inotify.add_watch(&processor.path, WatchMask::CLOSE_WRITE)?;"}],"del_contents":[{"Del":" let descriptor = inotify.add_watch(path, WatchMask::CLOSE_WRITE)?;\n let processor = Processor {\n path,\n command,\n args,\n };\n"}]}},{"Edit":{"inode":{"change":3,"pos":48},"path":"src/main.rs","line":55,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":790}],"down_context":[{"change":2,"pos":940}],"flag":"BLOCK","start":584,"end":773,"inode":{"change":3,"pos":48}}},"contents":[{"Add":" let mut config_str = String::new();"},{"Add":" fs::File::open(\"/home/maniac/.config/nfp/config.toml\")?.read_to_string(&mut config_str)?;"},{"Add":" let config: Config = toml::from_str(&config_str)?;"}]}},{"Replacement":{"inode":{"change":3,"pos":48},"path":"src/main.rs","line":60,"ins":{"up_context":[{"change":3,"pos":871}],"down_context":[{"change":3,"pos":926}],"flag":"BLOCK","start":774,"end":892,"inode":{"change":3,"pos":48}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":871},"to":{"change":2,"start":982,"end":1243},"introduced_by":2}],"inode":{"change":3,"pos":48}},"ins_contents":[{"Add":" for processor in config.processors {"},{"Add":" register_processor(&mut processors, &mut inotify, processor)?;"},{"Add":" }"}],"del_contents":[{"Del":" register_processor(\n &mut processors,\n &mut inotify,\n Path::new(\"/tmp/flickr\"),\n \"/home/maniac/.cache/pypoetry/virtualenvs/flickr-upload-AGKUL9KW-py3.9/bin/python\",\n &[\"/home/maniac/code/flickr-upload/upload.py\"],\n )?;\n"}]}},{"Replacement":{"inode":{"change":3,"pos":48},"path":"src/main.rs","line":66,"ins":{"up_context":[{"change":3,"pos":970}],"down_context":[{"change":3,"pos":1030}],"flag":"BLOCK","start":893,"end":925,"inode":{"change":3,"pos":48}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":970},"to":{"change":2,"start":1244,"end":1277},"introduced_by":2}],"inode":{"change":3,"pos":48}},"ins_contents":[{"Add":" println!(\"Waiting...\");"}],"del_contents":[{"Del":" println!(\"Watching...\");\n"}]}},{"Replacement":{"inode":{"change":3,"pos":48},"path":"src/main.rs","line":70,"ins":{"up_context":[{"change":2,"pos":1330}],"down_context":[{"change":2,"pos":1399}],"flag":"BLOCK","start":926,"end":1007,"inode":{"change":3,"pos":48}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":1330},"to":{"change":2,"start":1330,"end":1399},"introduced_by":2}],"inode":{"change":3,"pos":48}},"ins_contents":[{"Add":" let filename = Path::new(&processor.path).join(event.name.unwrap());"}],"del_contents":[{"Del":" let filename = processor.path.join(event.name.unwrap());\n"}]}},{"Replacement":{"inode":{"change":3,"pos":48},"path":"src/main.rs","line":72,"ins":{"up_context":[{"change":2,"pos":1450}],"down_context":[{"change":3,"pos":1286}],"flag":"BLOCK","start":1008,"end":1095,"inode":{"change":3,"pos":48}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":1450},"to":{"change":2,"start":1450,"end":1525},"introduced_by":2}],"inode":{"change":3,"pos":48}},"ins_contents":[{"Add":" let _ = process(&filename, &processor.command, processor.args.as_slice());"}],"del_contents":[{"Del":" let _ = process(&filename, processor.command, processor.args);\n"}]}},{"Edit":{"inode":{"change":3,"pos":1340},"path":"Cargo.toml","line":10,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":1531}],"down_context":[],"flag":"BLOCK","start":1096,"end":1166,"inode":{"change":3,"pos":1340}}},"contents":[{"Add":"toml = \"0.5.8\""},{"Add":"serde = { version = \"1.0.130\", features = [\"derive\"] }"}]}}],"owner":"isagalaev","repo":"nfp","token":"zAC13xPmohg+RjEN2k3KVznOZJ59JMg9I9szuz61uX4=","login":null}

…

Dependencies

Change contents