{"header":{"message":"Simplifying pijul::commands::log, and fixing Broken Pipe errors","description":null,"timestamp":"2021-09-15T08:29:04.714663882Z","authors":[{}]},"hash":"6F6AAHK4M2IVS23TVISR5OJSTZXUSEKLOP5BMM7SUHYG2FQNTSGQC","authors":[{"login":"pmeunier","key":"FZQ2g7VfnzLYM4mtTVDk9HAZjA8Jk9ndkwN1icgbtWUr"}],"deps":{"hashes":[["6F6AAHK4M2IVS23TVISR5OJSTZXUSEKLOP5BMM7SUHYG2FQNTSGQC","Simplifying pijul::commands::log, and fixing Broken Pipe errors"],["AA",null],["6O43WXDAXZX3H5XDE6KOANIJXYVCK2HAC247H7PCENJT3IFURTWQC","Version bump"],["TYAKEAJLABCZQDYAI4YBGIJNQ7HJS4DVULEGPCZOGJPJUYYNR6TAC","A better estimate of the maximum number of open patches we can keep (Unix-only at the moment)"],["F2S6XETO6DQ4447O4WPAHISGTBRVWW2WZYJ633KKYWWYKW5GXBPQC","Fixing log --hash-only"],["5OGOE4VWS5AIG4U2UYLLIGA3HY6UB7SNQOSESHNXBLET3VQXFBZAC","Store the current channel in the pristine"],["2K7JLB4Z7BS5VFNWD4DO3MKYU7VNPA5MTVHVSDI3FQZ5ICM6XM6QC","No pager on Windows"],["6XDVUSBMBXM4LKKKR7YPJ5PF4ISOZNT465GSOFR2GF7NTL5SNLZAC","Version bump"],["YN63NUZO4LVJ7XPMURDULTXBVJKW5MVCTZ24R7Z52QMHO3HPDUVQC","Sanakirja 1.0"],["QJXNUQFJOAPQT3GUXRDTVKMJZCKFONSXUZMAZB7VC7OHDCGAVCOQC","Solving conflicts"],["23LVKATNTT74YKHG7KJM6SBO2IVZEV24TQ46ZJIHQ2IXONWNVXJAC","Use pager crate for log output"],["YMWMWFA54PUELJI4YX77ZXEBQLHFM3DBJVQYQEP3DBO3GF7T4PCAC","Version bumps"],["OU6JOR3CDZTH2H3NTGMV3WDIAWPD3VEJI7JRY3VJ7LPDR3QOA52QC","Add path filtering for log, add json output for log"],["XF3FRWJ6MFZAMR2NFEBICRCG42QEPSKSWJSBOJYLA3LX2UYJ5FMQC","Version bump (including clap 3.0.0-beta.4)"],["CCLLB7OIFNFYJZTG3UCI7536TOCWSCSXR67VELSB466R24WLJSDAC","Upgrading to Sanakirja 0.15 + version bump"],["I52XSRUH5RVHQBFWVMAQPTUSPAJ4KNVID2RMI3UGCVKFLYUO6WZAC","Massive cleanup, and simplification"],["TNN56XYKX4QRHA4FWCF5F3JVG52FIAC76EEYYANDKEE4IAWQKPEQC","libpijul alpha.43"],["FYUDBQ3C5GWIFKITBAKEXTK4AFZXZOH7DHI7QFXQOQ3HYUIYDEVAC","Formatting changes + version bump"],["RUBBHYZ7MCLKJIHZ3EWEC3JR3FSKOU4T2NH7KRBG7ECAU4JF3LUAC","Removing unnecessary async/await"],["I7VL7VPZV2NKOZRKBWWEHFOGNGGTYLPONHABVJ767D6HPJJNY5RAC","Minor cleanup"],["NWYJJHDFVCDR34NC6VYI4S2ZT4Q6KV4JWIBJDHOZEFZVEGO2J72AC","Version bump"],["SXEYMYF7P4RZMZ46WPL4IZUTSQ2ATBWYZX7QNVMS3SGOYXYOHAGQC","Fixing the bad changes in history (unfortunately, by rebooting)."],["Y6EVFMTA6FOH3OQH6QCSWMI3F6SYZT2FSHO6GF4M3ICENDCWFM4QC","Don't output files if they aren't in the current channel"],["L4JXJHWXYNCL4QGJXNKKTOKKTAXKKXBJUUY7HFZGEUZ5A2V5H34QC","pijul/*: reorganize imports and remove extern crate"],["SMMBFECLGSUKRZW5YPOQPOQCOY2CH2OTZXBSZ3KG2N3J3HQZ5PSAC","Converting to the new patch format \"online\""],["VIHXB7SGRETFPHPYZFSRGOFRXEO4RZY57WDZSU6IAUEJRU3HPKQAC","commands: set up pager for diff, change, and credit"],["JL4WKA5PBKXRNAMETYO4I52QKASQ3COYHH2JKGA7W5YLIRZZH53AC","Implement the Sanakirja concurrency model in a cross-process way"],["BECIRKR2RW76DBVF4TR6MU7VDQNPK2XWE6QJUM2VTISSPENKAXWQC","Avoid a double formatting"],["A3RM526Y7LUXNYW4TL56YKQ5GVOK2R5D7JJVTSQ6TT5MEXIR6YAAC","Integrating identity malleability"],["V4T4SC7OL6WEZNV4XSFBSXY5HPB7VXPSXWSK4Z63QXKQD4JSFNCQC","Testing binary diff"]],"deps":["6O43WXDAXZX3H5XDE6KOANIJXYVCK2HAC247H7PCENJT3IFURTWQC","TYAKEAJLABCZQDYAI4YBGIJNQ7HJS4DVULEGPCZOGJPJUYYNR6TAC","F2S6XETO6DQ4447O4WPAHISGTBRVWW2WZYJ633KKYWWYKW5GXBPQC"],"known":["SXEYMYF7P4RZMZ46WPL4IZUTSQ2ATBWYZX7QNVMS3SGOYXYOHAGQC","L4JXJHWXYNCL4QGJXNKKTOKKTAXKKXBJUUY7HFZGEUZ5A2V5H34QC","23LVKATNTT74YKHG7KJM6SBO2IVZEV24TQ46ZJIHQ2IXONWNVXJAC","VIHXB7SGRETFPHPYZFSRGOFRXEO4RZY57WDZSU6IAUEJRU3HPKQAC","I52XSRUH5RVHQBFWVMAQPTUSPAJ4KNVID2RMI3UGCVKFLYUO6WZAC","2K7JLB4Z7BS5VFNWD4DO3MKYU7VNPA5MTVHVSDI3FQZ5ICM6XM6QC","CCLLB7OIFNFYJZTG3UCI7536TOCWSCSXR67VELSB466R24WLJSDAC","JL4WKA5PBKXRNAMETYO4I52QKASQ3COYHH2JKGA7W5YLIRZZH53AC","I7VL7VPZV2NKOZRKBWWEHFOGNGGTYLPONHABVJ767D6HPJJNY5RAC","YN63NUZO4LVJ7XPMURDULTXBVJKW5MVCTZ24R7Z52QMHO3HPDUVQC","Y6EVFMTA6FOH3OQH6QCSWMI3F6SYZT2FSHO6GF4M3ICENDCWFM4QC","5OGOE4VWS5AIG4U2UYLLIGA3HY6UB7SNQOSESHNXBLET3VQXFBZAC","SMMBFECLGSUKRZW5YPOQPOQCOY2CH2OTZXBSZ3KG2N3J3HQZ5PSAC","A3RM526Y7LUXNYW4TL56YKQ5GVOK2R5D7JJVTSQ6TT5MEXIR6YAAC","QJXNUQFJOAPQT3GUXRDTVKMJZCKFONSXUZMAZB7VC7OHDCGAVCOQC","FYUDBQ3C5GWIFKITBAKEXTK4AFZXZOH7DHI7QFXQOQ3HYUIYDEVAC","YMWMWFA54PUELJI4YX77ZXEBQLHFM3DBJVQYQEP3DBO3GF7T4PCAC","TNN56XYKX4QRHA4FWCF5F3JVG52FIAC76EEYYANDKEE4IAWQKPEQC","V4T4SC7OL6WEZNV4XSFBSXY5HPB7VXPSXWSK4Z63QXKQD4JSFNCQC","NWYJJHDFVCDR34NC6VYI4S2ZT4Q6KV4JWIBJDHOZEFZVEGO2J72AC","RUBBHYZ7MCLKJIHZ3EWEC3JR3FSKOU4T2NH7KRBG7ECAU4JF3LUAC","6XDVUSBMBXM4LKKKR7YPJ5PF4ISOZNT465GSOFR2GF7NTL5SNLZAC","XF3FRWJ6MFZAMR2NFEBICRCG42QEPSKSWJSBOJYLA3LX2UYJ5FMQC","OU6JOR3CDZTH2H3NTGMV3WDIAWPD3VEJI7JRY3VJ7LPDR3QOA52QC","BECIRKR2RW76DBVF4TR6MU7VDQNPK2XWE6QJUM2VTISSPENKAXWQC"]},"hunks":[{"Replacement":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":11,"ins":{"up_context":[{"change":5,"pos":134460}],"down_context":[{"change":5,"pos":3357}],"flag":"BLOCK","start":0,"end":93,"inode":{"change":5,"pos":134376}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":134460},"to":{"change":5,"start":139,"end":224},"introduced_by":5}],"inode":{"change":5,"pos":134376}},"ins_contents":[{"Add":"use libpijul::pristine::{sanakirja::Txn, ChannelRef, DepsTxnT, GraphTxnT, TreeTxnT, TxnErr};"}],"del_contents":[{"Del":"use libpijul::pristine::{sanakirja::Txn, ChannelRef, DepsTxnT, GraphTxnT, TreeTxnT};\n"}]}},{"Edit":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":15,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":291}],"down_context":[{"change":5,"pos":134559}],"flag":"BLOCK","start":94,"end":112,"inode":{"change":5,"pos":134376}}},"contents":[{"Add":"use thiserror::*;"}]}},{"Edit":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":51,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":134884}],"down_context":[{"change":5,"pos":723}],"flag":"BLOCK","start":113,"end":2751,"inode":{"change":5,"pos":134376}}},"contents":[{"Add":"impl TryFrom for LogIterator {"},{"Add":" type Error = anyhow::Error;"},{"Add":" fn try_from(cmd: Log) -> Result {"},{"Add":" let repo = Repository::find_root(cmd.repo_path.clone())?;"},{"Add":" let repo_path = repo.path.clone();"},{"Add":" let txn = repo.pristine.txn_begin()?;"},{"Add":" let channel_name = if let Some(ref c) = cmd.channel {"},{"Add":" c"},{"Add":" } else {"},{"Add":" txn.current_channel().unwrap_or(crate::DEFAULT_CHANNEL)"},{"Add":" };"},{"Add":" // The only situation that's disallowed is if the user's trying to apply"},{"Add":" // path filters AND get the logs for a channel other than the one they're"},{"Add":" // currently using (where using means the one that comprises the working copy)"},{"Add":" if !cmd.filters.is_empty()"},{"Add":" && !(channel_name == txn.current_channel().unwrap_or(crate::DEFAULT_CHANNEL))"},{"Add":" {"},{"Add":" bail!(\"Currently, log filters can only be applied to the channel currently in use.\")"},{"Add":" }"},{"Add":""},{"Add":" let channel_ref = if let Some(channel) = txn.load_channel(channel_name)? {"},{"Add":" channel"},{"Add":" } else {"},{"Add":" bail!(\"No such channel: {:?}\", channel_name)"},{"Add":" };"},{"Add":" let changes = repo.changes;"},{"Add":" let limit = cmd.limit.unwrap_or(std::usize::MAX);"},{"Add":" let offset = cmd.offset.unwrap_or(0);"},{"Add":""},{"Add":" let mut id_path = repo.path.join(libpijul::DOT_DIR);"},{"Add":" id_path.push(\"identities\");"},{"Add":" Ok(Self {"},{"Add":" txn,"},{"Add":" cmd,"},{"Add":" changes,"},{"Add":" repo_path,"},{"Add":" id_path,"},{"Add":" channel_ref,"},{"Add":" limit,"},{"Add":" offset,"},{"Add":" })"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"#[derive(Debug, Error)]"},{"Add":"pub enum Error {"},{"Add":" #[error(\"pijul log couldn't find a file or directory corresponding to `{}`\", 0)]"},{"Add":" NotFound(String),"},{"Add":" #[error(transparent)]"},{"Add":" Txn(#[from] libpijul::pristine::sanakirja::SanakirjaError),"},{"Add":" #[error(transparent)]"},{"Add":" TxnErr(#[from] TxnErr),"},{"Add":" #[error(transparent)]"},{"Add":" Fs(#[from] libpijul::FsError),"},{"Add":" #[error(transparent)]"},{"Add":" Io(#[from] std::io::Error),"},{"Add":" #[error(\"pijul log couldn't assemble file prefix for pattern `{}`: {} was not a file in the repository at {}\", pat, canon_path.display(), repo_path.display())]"},{"Add":" FilterPath {"},{"Add":" pat: String,"},{"Add":" canon_path: PathBuf,"},{"Add":" repo_path: PathBuf,"},{"Add":" },"},{"Add":" #[error(\"pijul log couldn't assemble file prefix for pattern `{}`: the path contained invalid UTF-8\", 0)]"},{"Add":" InvalidUtf8(String),"},{"Add":" #[error(transparent)]"},{"Add":" E(E),"},{"Add":" #[error(transparent)]"},{"Add":" Filesystem(#[from] libpijul::changestore::filesystem::Error),"},{"Add":"}"},{"Add":""}]}},{"Replacement":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":124,"ins":{"up_context":[{"change":5,"pos":906}],"down_context":[{"change":5,"pos":966}],"flag":"BLOCK","start":2752,"end":2804,"inode":{"change":5,"pos":134376}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":906},"to":{"change":5,"start":906,"end":966},"introduced_by":5}],"inode":{"change":5,"pos":134376}},"ins_contents":[{"Add":"fn get_inodes("},{"Add":" txn: &Txn,"}],"del_contents":[{"Del":"fn get_inodes(\n txn: &impl libpijul::pristine::TreeTxnT,\n"}]}},{"Replacement":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":128,"ins":{"up_context":[{"change":5,"pos":1009}],"down_context":[{"change":5,"pos":1060}],"flag":"BLOCK","start":2805,"end":2851,"inode":{"change":5,"pos":134376}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":1009},"to":{"change":5,"start":1009,"end":1060},"introduced_by":5}],"inode":{"change":5,"pos":134376}},"ins_contents":[{"Add":") -> Result, Error> {"}],"del_contents":[{"Del":") -> Result, anyhow::Error> {\n"}]}},{"Replacement":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":133,"ins":{"up_context":[{"change":5,"pos":1254}],"down_context":[{"change":5,"pos":1408}],"flag":"BLOCK","start":2852,"end":2913,"inode":{"change":5,"pos":134376}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":1254},"to":{"change":5,"start":1254,"end":1408},"introduced_by":5}],"inode":{"change":5,"pos":134376}},"ins_contents":[{"Add":" return Err(Error::NotFound(pat.to_string()))"}],"del_contents":[{"Del":" bail!(\n \"pijul log couldn't find a file or directory corresponding to `{}`\",\n pat\n )\n"}]}},{"Replacement":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":143,"ins":{"up_context":[{"change":5,"pos":1769}],"down_context":[{"change":5,"pos":2045}],"flag":"BLOCK","start":2914,"end":3148,"inode":{"change":5,"pos":134376}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":1769},"to":{"change":5,"start":1769,"end":2045},"introduced_by":5}],"inode":{"change":5,"pos":134376}},"ins_contents":[{"Add":" Err(_) => {"},{"Add":" return Err(Error::FilterPath {"},{"Add":" pat: pat.to_string(),"},{"Add":" canon_path,"},{"Add":" repo_path: repo_path.to_path_buf(),"},{"Add":" })"},{"Add":" }"}],"del_contents":[{"Del":" Err(_) => bail!(\n \"pijul log couldn't assemble file prefix for pattern `{}`; \\\n {} was not a file in the repository at {}\",\n pat,\n canon_path.display(),\n repo_path.display()\n ),\n"}]}},{"Replacement":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":151,"ins":{"up_context":[{"change":5,"pos":2127}],"down_context":[{"change":5,"pos":2759}],"flag":"BLOCK","start":3149,"end":3297,"inode":{"change":5,"pos":134376}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":2127},"to":{"change":5,"start":2127,"end":2759},"introduced_by":5}],"inode":{"change":5,"pos":134376}},"ins_contents":[{"Add":" Ok(None) => return Err(Error::InvalidUtf8(pat.to_string())),"},{"Add":" Ok(Some(s)) => inodes.push(libpijul::fs::find_inode(txn, s)?),"}],"del_contents":[{"Del":" Ok(None) => bail!(\n \"pijul log couldn't assemble file prefix for pattern `{}`; \\\n the path contained invalid UTF-8\",\n pat\n ),\n Ok(Some(s)) => match libpijul::fs::find_inode(txn, s) {\n Err(e) => bail!(\n \"pijul log couldn't assemble file prefix for pattern `{}`; \\\n no Inode found for the corresponding path. Internal error: {:?}\",\n pat,\n e\n ),\n Ok(inode) => {\n inodes.push(inode);\n }\n },\n"}]}},{"Replacement":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":161,"ins":{"up_context":[{"change":5,"pos":3001}],"down_context":[{"change":5,"pos":3070}],"flag":"BLOCK","start":3298,"end":3355,"inode":{"change":5,"pos":134376}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":3001},"to":{"change":5,"start":3001,"end":3070},"introduced_by":5}],"inode":{"change":5,"pos":134376}},"ins_contents":[{"Add":"fn filtered_hashes("},{"Add":" txn: &Txn,"}],"del_contents":[{"Del":"fn filtered_hashes(\n txn: &T,\n"}]}},{"Replacement":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":165,"ins":{"up_context":[{"change":5,"pos":3111}],"down_context":[{"change":5,"pos":3165}],"flag":"BLOCK","start":3356,"end":3405,"inode":{"change":5,"pos":134376}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":3111},"to":{"change":5,"start":3111,"end":3165},"introduced_by":5}],"inode":{"change":5,"pos":134376}},"ins_contents":[{"Add":") -> Result, Error> {"}],"del_contents":[{"Del":") -> Result, anyhow::Error> {\n"}]}},{"Replacement":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":171,"ins":{"up_context":[{"change":5,"pos":3417}],"down_context":[{"change":5,"pos":3489}],"flag":"BLOCK","start":3406,"end":3436,"inode":{"change":5,"pos":134376}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":3417},"to":{"change":5,"start":3417,"end":3489},"introduced_by":5}],"inode":{"change":5,"pos":134376}},"ins_contents":[{"Add":" None => continue,"}],"del_contents":[{"Del":" None => bail!(\"Failed to get matching inode: {:?}\", inode),\n"}]}},{"Replacement":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":178,"ins":{"up_context":[{"change":5,"pos":3787}],"down_context":[{"change":5,"pos":4336}],"flag":"BLOCK","start":3437,"end":3573,"inode":{"change":5,"pos":134376}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":3787},"to":{"change":5,"start":3787,"end":4336},"introduced_by":5}],"inode":{"change":5,"pos":134376}},"ins_contents":[{"Add":" let ser_h = txn.get_external(touched_change_id)?.unwrap();"},{"Add":" hashes.insert(libpijul::Hash::from(*ser_h));"}],"del_contents":[{"Del":" match txn.get_external(touched_change_id)? {\n Some(ser_h) => {\n hashes.insert(libpijul::Hash::from(*ser_h));\n }\n _ => {\n log::error!(\n \"`get_external` failed to retrieve full hash for ChangeId {:?}\",\n touched_change_id\n );\n bail!(\"Failed to retrieve full hash for {:?}\", touched_change_id)\n }\n }\n"}]}},{"Edit":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":317,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":8452},"to":{"change":5,"start":8452,"end":8694},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":7169},"to":{"change":5,"start":135006,"end":135052},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":8694},"to":{"change":5,"start":135006,"end":135052},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":12911},"to":{"change":5,"start":135006,"end":135052},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":21108},"to":{"change":5,"start":135006,"end":135052},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":135006},"to":{"change":5,"start":135006,"end":135052},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":135052},"to":{"change":5,"start":8695,"end":8757},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":8757},"to":{"change":5,"start":2523,"end":2633},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":2523},"to":{"change":5,"start":2523,"end":2633},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":2633},"to":{"change":5,"start":8758,"end":9250},"introduced_by":5}],"inode":{"change":5,"pos":134376}}},"contents":[{"Del":"\nimpl TryFrom for LogIterator {\n type Error = anyhow::Error;\n fn try_from(cmd: Log) -> Result {\n let repo = Repository::find_root(cmd.repo_path.clone())?;\n let repo_path = repo.path.clone();\n"},{"Del":" let txn = repo.pristine.txn_begin()?;\n"},{"Del":" let channel_name = if let Some(ref c) = cmd.channel {\n"},{"Del":" c\n } else {\n txn.current_channel().unwrap_or(crate::DEFAULT_CHANNEL)\n };\n"},{"Del":" // The only situation that's disallowed is if the user's trying to apply\n // path filters AND get the logs for a channel other than the one they're\n // currently using (where using means the one that comprises the working copy)\n if !cmd.filters.is_empty()\n && !(channel_name == txn.current_channel().unwrap_or(crate::DEFAULT_CHANNEL))\n {\n bail!(\"Currently, log filters can only be applied to the channel currently in use.\")\n }\n"}]}},{"Edit":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":318,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":9251},"to":{"change":5,"start":9251,"end":9334},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":9334},"to":{"change":5,"start":135251,"end":135288},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":17023},"to":{"change":5,"start":135251,"end":135288},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":135251},"to":{"change":5,"start":135251,"end":135288},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":135288},"to":{"change":5,"start":17024,"end":17081},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":17081},"to":{"change":5,"start":135423,"end":135434},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":135423},"to":{"change":5,"start":135423,"end":135434},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":46},"to":{"change":5,"start":135434,"end":135470},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":66},"to":{"change":5,"start":135434,"end":135470},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":187},"to":{"change":5,"start":135434,"end":135470},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":135434},"to":{"change":5,"start":135434,"end":135470},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":135470},"to":{"change":5,"start":9335,"end":9737},"introduced_by":5}],"inode":{"change":5,"pos":134376}}},"contents":[{"Del":" let channel_ref = if let Some(channel) = txn.load_channel(channel_name)? {\n"},{"Del":" channel\n } else {\n"},{"Del":" bail!(\"No such channel: {:?}\", channel_name)\n"},{"Del":" };\n"},{"Del":" let changes = repo.changes;\n"},{"Del":" let limit = cmd.limit.unwrap_or(std::usize::MAX);\n let offset = cmd.offset.unwrap_or(0);\n\n let mut id_path = repo.path.join(libpijul::DOT_DIR);\n id_path.push(\"identities\");\n Ok(Self {\n txn,\n cmd,\n changes,\n repo_path,\n id_path,\n channel_ref,\n limit,\n offset,\n })\n }\n}\n"}]}},{"Replacement":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":324,"ins":{"up_context":[{"change":5,"pos":10027}],"down_context":[{"change":5,"pos":10050}],"flag":"BLOCK","start":3574,"end":3616,"inode":{"change":5,"pos":134376}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":10027},"to":{"change":5,"start":10027,"end":10050},"introduced_by":5}],"inode":{"change":5,"pos":134376}},"ins_contents":[{"Add":" fn for_each("}],"del_contents":[{"Del":" fn for_each(\n"}]}},{"Replacement":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":327,"ins":{"up_context":[{"change":5,"pos":10118}],"down_context":[{"change":5,"pos":10199}],"flag":"BLOCK","start":3617,"end":3649,"inode":{"change":5,"pos":134376}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":10118},"to":{"change":5,"start":10118,"end":10199},"introduced_by":5}],"inode":{"change":5,"pos":134376}},"ins_contents":[{"Add":" ) -> Result<(), Error> {"}],"del_contents":[{"Del":" ) -> Result<(), anyhow::Error>\n where\n E: std::fmt::Display,\n {\n"}]}},{"Replacement":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":359,"ins":{"up_context":[{"change":5,"pos":11547}],"down_context":[{"change":5,"pos":11678}],"flag":"BLOCK","start":3650,"end":3695,"inode":{"change":5,"pos":134376}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":11547},"to":{"change":5,"start":11547,"end":11678},"introduced_by":5}],"inode":{"change":5,"pos":134376}},"ins_contents":[{"Add":" f(entry).map_err(Error::E)?;"}],"del_contents":[{"Del":" if let Err(e) = f(entry) {\n return Err(anyhow::Error::msg(format!(\"{}\", e)));\n }\n"}]}},{"Replacement":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":378,"ins":{"up_context":[{"change":5,"pos":12281}],"down_context":[{"change":5,"pos":12306}],"flag":"BLOCK","start":3696,"end":3743,"inode":{"change":5,"pos":134376}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":12281},"to":{"change":5,"start":12281,"end":12306},"introduced_by":5}],"inode":{"change":5,"pos":134376}},"ins_contents":[{"Add":" fn mk_log_entry<'x, E: std::error::Error>("}],"del_contents":[{"Del":" fn mk_log_entry<'x>(\n"}]}},{"Replacement":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":384,"ins":{"up_context":[{"change":5,"pos":12469}],"down_context":[{"change":4,"pos":2180}],"flag":"BLOCK","start":3744,"end":3782,"inode":{"change":5,"pos":134376}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":12469},"to":{"change":5,"start":12469,"end":12512},"introduced_by":5}],"inode":{"change":5,"pos":134376}},"ins_contents":[{"Add":" ) -> Result> {"}],"del_contents":[{"Del":" ) -> Result {\n"}]}},{"Replacement":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":431,"ins":{"up_context":[{"change":5,"pos":14053}],"down_context":[{"change":5,"pos":14212}],"flag":"BLOCK","start":3783,"end":3949,"inode":{"change":5,"pos":134376}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":14053},"to":{"change":5,"start":14053,"end":14212},"introduced_by":5}],"inode":{"change":5,"pos":134376}},"ins_contents":[{"Add":" // In order to accommodate both pretty-printing and efficient"},{"Add":" // serialization to a serde target format, this now delegates"},{"Add":" // mostly to [`LogIterator`]."}],"del_contents":[{"Del":" // In order to accommodate both pretty-printing and efficient serialization to a serde\n // target format, this now delegates mostly to [`LogIterator`].\n"}]}},{"Replacement":{"inode":{"change":5,"pos":134376},"path":"\"pijul/src/commands/log.rs\"","line":442,"ins":{"up_context":[{"change":5,"pos":14586}],"down_context":[{"change":5,"pos":136485}],"flag":"BLOCK","start":3950,"end":4288,"inode":{"change":5,"pos":134376}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":14586},"to":{"change":5,"start":14586,"end":14683},"introduced_by":5}],"inode":{"change":5,"pos":134376}},"ins_contents":[{"Add":" LogIterator::try_from(self)?.for_each(|entry| {"},{"Add":" match write!(&mut stdout, \"{}\", entry) {"},{"Add":" Ok(_) => Ok(()),"},{"Add":" Err(e) if e.kind() == std::io::ErrorKind::BrokenPipe => Ok(()),"},{"Add":" Err(e) => Err(e),"},{"Add":" }"},{"Add":" })?"}],"del_contents":[{"Del":" LogIterator::try_from(self)?.for_each(|entry| write!(&mut stdout, \"{}\", entry))?\n"}]}},{"Edit":{"inode":{"change":5,"pos":196374},"path":"\"pijul/Cargo.toml\"","line":93,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":1355}],"down_context":[{"change":5,"pos":309}],"flag":"BLOCK","start":4289,"end":4307,"inode":{"change":5,"pos":196374}}},"contents":[{"Add":"thiserror = \"1.0\""}]}},{"Replacement":{"inode":{"change":5,"pos":1030385},"path":"\"Cargo.lock\"","line":1063,"ins":{"up_context":[{"change":5,"pos":22930}],"down_context":[{"change":5,"pos":22957}],"flag":"BLOCK","start":4308,"end":4335,"inode":{"change":5,"pos":1030385}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":22930},"to":{"change":2,"start":28,"end":55},"introduced_by":2}],"inode":{"change":5,"pos":1030385}},"ins_contents":[{"Add":"version = \"1.0.0-alpha.48\""}],"del_contents":[{"Del":"version = \"1.0.0-alpha.47\"\n"}]}},{"Edit":{"inode":{"change":5,"pos":1030385},"path":"\"Cargo.lock\"","line":1520,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":33986}],"down_context":[{"change":5,"pos":33986}],"flag":"BLOCK","start":4336,"end":4350,"inode":{"change":5,"pos":1030385}}},"contents":[{"Add":" \"thiserror\","}]}},{"Edit":{"inode":{"change":5,"pos":1030385},"path":"\"Cargo.lock\"","line":2109,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":49058},"to":{"change":5,"start":49058,"end":49284},"introduced_by":5}],"inode":{"change":5,"pos":1030385}}},"contents":[{"Del":"name = \"threadpool\"\nversion = \"1.8.1\"\nsource = \"registry+https://github.com/rust-lang/crates.io-index\"\nchecksum = \"d050e60b33d41c19108b32cea32164033a9013fe3b46cbd4457559bfbf77afaa\"\ndependencies = [\n \"num_cpus\",\n]\n\n[[package]]\n"}]}},{"Edit":{"inode":{"change":5,"pos":1030385},"path":"\"Cargo.lock\"","line":2599,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":61252}],"down_context":[{"change":5,"pos":61252}],"flag":"BLOCK","start":4351,"end":4546,"inode":{"change":5,"pos":1030385}}},"contents":[{"Add":"name = \"xxhash-rust\""},{"Add":"version = \"0.8.2\""},{"Add":"source = \"registry+https://github.com/rust-lang/crates.io-index\""},{"Add":"checksum = \"e575e15bedf6e57b5c2d763ffc6c3c760143466cbd09d762d539680ab5992ded\""},{"Add":""},{"Add":"[[package]]"}]}},{"Replacement":{"inode":{"change":5,"pos":1030385},"path":"\"Cargo.lock\"","line":2637,"ins":{"up_context":[{"change":5,"pos":62007}],"down_context":[{"change":5,"pos":62025}],"flag":"BLOCK","start":4547,"end":4565,"inode":{"change":5,"pos":1030385}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":62007},"to":{"change":5,"start":62007,"end":62025},"introduced_by":5}],"inode":{"change":5,"pos":1030385}},"ins_contents":[{"Add":"version = \"0.2.0\""}],"del_contents":[{"Del":"version = \"0.1.7\"\n"}]}},{"Replacement":{"inode":{"change":5,"pos":1030385},"path":"\"Cargo.lock\"","line":2639,"ins":{"up_context":[{"change":5,"pos":62090}],"down_context":[{"change":5,"pos":62168}],"flag":"BLOCK","start":4566,"end":4644,"inode":{"change":5,"pos":1030385}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":62090},"to":{"change":5,"start":62090,"end":62168},"introduced_by":5}],"inode":{"change":5,"pos":1030385}},"ins_contents":[{"Add":"checksum = \"62d9eace42d7bf64591d547cb727d89277e3de1c1b934e3d9d0af8c6687587ef\""}],"del_contents":[{"Del":"checksum = \"3e3b99cee88f0309ca765c6aa8c284a00394c35ef8ca012e2409485fc369bf2f\"\n"}]}},{"Edit":{"inode":{"change":5,"pos":1030385},"path":"\"Cargo.lock\"","line":2641,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":62185},"to":{"change":5,"start":62185,"end":62192},"introduced_by":5}],"inode":{"change":5,"pos":1030385}}},"contents":[{"Del":" \"cc\",\n"}]}},{"Replacement":{"inode":{"change":5,"pos":1030385},"path":"\"Cargo.lock\"","line":2644,"ins":{"up_context":[{"change":5,"pos":62230}],"down_context":[{"change":5,"pos":62245}],"flag":"BLOCK","start":4645,"end":4661,"inode":{"change":5,"pos":1030385}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":62230},"to":{"change":5,"start":62230,"end":62245},"introduced_by":5}],"inode":{"change":5,"pos":1030385}},"ins_contents":[{"Add":" \"xxhash-rust\","}],"del_contents":[{"Del":" \"threadpool\",\n"}]}}],"owner":"irevoire","repo":"pijul","token":"EmaIf2qxl5OZ3s2MfvHmbGmi0DSDcsWgjvFkh4tno00=","login":null}

…

Dependencies

Change contents