{"header":{"message":"Should be all the database functions I need","description":null,"timestamp":"2022-01-14T00:48:51.026867Z","authors":[{"email":"quick.dudley@gmail.com","full_name":"Jeremy List","name":"quickdudley"}]},"hash":"LLFG625ISXV7P2LUOFUMFIM5V5RJDKWCL47XX43X2CGILVAUQPVQC","authors":[],"deps":{"hashes":[["LLFG625ISXV7P2LUOFUMFIM5V5RJDKWCL47XX43X2CGILVAUQPVQC","Should be all the database functions I need"],["AA",null],["AVLXUT3ROXQ2PLLTB5XHPBY2BI5PQRRFJTG2GGZTL7K4VEZZXF3AC","Make the boxed errors Send"],["G5YNDTPHPYRZZIGWLX2ZLVFRJ3B2NGAPVESSMTO7YEABDFIIE66AC","Cargo clippy"],["AV73DYWQ2UVZJYTN3UIW3TDMWNAETLXZRD7VHKTQLFQGHKJ5KI6QC","Initial functions for using sqlite in async environment"],["LPVC545KD6R5KNOTDPFDOD5FVA3KFBZARKVOLLXJXW3YK3RMNZKQC","Get the scraper part of this program working"],["RNW6D77774CYWWM7JIFXI5TGKBOU6ADJIEZB5N2FXGDCTLUXEQZQC","Minor tidy"],["5Y7ZXB53EMG34VZI5VQIZ77TZKBB4V6BGIILFZ5ZY73QYK4V2YHQC","Start picker UI"],["YCWYAX6K2DJKT7FO4IAYL6HJOIJLYFKAPGLFJ5XMYSYAS42LP3FQC","Functions for scraping names integrated enough to test (they don't work yet)"],["KUANIPWFDXDFKJ2LH4FQ6APYOPLNYJ5LVGLSBSC75WUUZPFHILCAC","Add function for adding name to database"],["HMOBTVJ4FEPZWMUV2JDPZYH3EFCW6ED5M6KKNKQJQZVKTDAKTVFQC","Initialize crate and add expected dependencies"]],"deps":["AVLXUT3ROXQ2PLLTB5XHPBY2BI5PQRRFJTG2GGZTL7K4VEZZXF3AC","G5YNDTPHPYRZZIGWLX2ZLVFRJ3B2NGAPVESSMTO7YEABDFIIE66AC"],"known":["AV73DYWQ2UVZJYTN3UIW3TDMWNAETLXZRD7VHKTQLFQGHKJ5KI6QC","RNW6D77774CYWWM7JIFXI5TGKBOU6ADJIEZB5N2FXGDCTLUXEQZQC","KUANIPWFDXDFKJ2LH4FQ6APYOPLNYJ5LVGLSBSC75WUUZPFHILCAC","YCWYAX6K2DJKT7FO4IAYL6HJOIJLYFKAPGLFJ5XMYSYAS42LP3FQC","LPVC545KD6R5KNOTDPFDOD5FVA3KFBZARKVOLLXJXW3YK3RMNZKQC","5Y7ZXB53EMG34VZI5VQIZ77TZKBB4V6BGIILFZ5ZY73QYK4V2YHQC"]},"hunks":[{"Replacement":{"inode":{"change":4,"pos":32},"path":"src/pick.rs","line":7,"ins":{"up_context":[{"change":4,"pos":138}],"down_context":[{"change":4,"pos":160}],"flag":"BLOCK","start":0,"end":41,"inode":{"change":4,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":138},"to":{"change":4,"start":138,"end":160},"introduced_by":4}],"inode":{"change":4,"pos":32}},"ins_contents":[{"Add":" ExecutableCommand, QueueableCommand,"}],"del_contents":[{"Del":" QueueableCommand,\n"}]}},{"Replacement":{"inode":{"change":4,"pos":32},"path":"src/pick.rs","line":11,"ins":{"up_context":[{"change":4,"pos":278}],"down_context":[{"change":4,"pos":348}],"flag":"BLOCK","start":42,"end":262,"inode":{"change":4,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":278},"to":{"change":4,"start":278,"end":348},"introduced_by":4}],"inode":{"change":4,"pos":32}},"ins_contents":[{"Add":"pub async fn pick(db: &AsyncConnection, count: u16) -> DynResult<()> {"},{"Add":" let mut stderr = std::io::stderr();"},{"Add":" stderr.execute(cursor::Hide)?;"},{"Add":" let (mut input, done) = events();"},{"Add":""},{"Add":" stderr.execute(cursor::Show)?;"}],"del_contents":[{"Del":"pub async fn pick(db: AsyncConnection, count: u16) -> DynResult<()> {\n"}]}},{"Edit":{"inode":{"change":4,"pos":42},"path":"src/names_database.rs","line":18,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":523}],"down_context":[{"change":4,"pos":523}],"flag":"BLOCK","start":263,"end":468,"inode":{"change":4,"pos":42}}},"contents":[{"Add":" )?;"},{"Add":" conn.execute("},{"Add":" \"CREATE INDEX IF NOT EXISTS prefs_index ON preferences(better,worse)\","},{"Add":" )?;"},{"Add":" conn.execute("},{"Add":" \"CREATE INDEX IF NOT EXISTS prefs_better ON preferences(better)\","}]}},{"Edit":{"inode":{"change":4,"pos":42},"path":"src/names_database.rs","line":25,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":531}],"down_context":[{"change":4,"pos":531}],"flag":"BLOCK","start":469,"end":567,"inode":{"change":4,"pos":42}}},"contents":[{"Add":" conn.execute("},{"Add":" \"CREATE INDEX IF NOT EXISTS prefs_worse ON preferences(worse)\","},{"Add":" )?;"}]}},{"Replacement":{"inode":{"change":4,"pos":42},"path":"src/names_database.rs","line":31,"ins":{"up_context":[{"change":4,"pos":545}],"down_context":[{"change":4,"pos":646}],"flag":"BLOCK","start":568,"end":663,"inode":{"change":4,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":545},"to":{"change":4,"start":0,"end":74},"introduced_by":4}],"inode":{"change":4,"pos":42}},"ins_contents":[{"Add":"type DBFunction ="},{"Add":" Box FnOnce(&'a sqlite::Connection) + Send + Sync + 'static>;"}],"del_contents":[{"Del":"type DBFunction = Box FnOnce(&'a sqlite::Connection) + Send>;\n"}]}},{"Edit":{"inode":{"change":4,"pos":42},"path":"src/names_database.rs","line":34,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":647}],"down_context":[{"change":4,"pos":75}],"flag":"BLOCK","start":664,"end":681,"inode":{"change":4,"pos":42}}},"contents":[{"Add":"#[derive(Clone)]"}]}},{"Replacement":{"inode":{"change":4,"pos":42},"path":"src/names_database.rs","line":55,"ins":{"up_context":[{"change":4,"pos":171}],"down_context":[{"change":4,"pos":305}],"flag":"BLOCK","start":682,"end":773,"inode":{"change":4,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":171},"to":{"change":2,"start":51,"end":118},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":118},"to":{"change":4,"start":286,"end":305},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":286},"to":{"change":4,"start":286,"end":305},"introduced_by":4}],"inode":{"change":4,"pos":42}},"ins_contents":[{"Add":" pub async fn add_name(&self, name: String) -> DynResult<(i64, bool)> {"},{"Add":" Ok(self"}],"del_contents":[{"Del":" pub async fn add_name(&self, name: String) -> DynResult {\n"},{"Del":" match self\n"}]}},{"Replacement":{"inode":{"change":4,"pos":42},"path":"src/names_database.rs","line":61,"ins":{"up_context":[{"change":4,"pos":496}],"down_context":[{"change":4,"pos":531}],"flag":"BLOCK","start":774,"end":825,"inode":{"change":4,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":496},"to":{"change":4,"start":496,"end":531},"introduced_by":4}],"inode":{"change":4,"pos":42}},"ins_contents":[{"Add":" let is_new = stmnt.next().is_ok();"}],"del_contents":[{"Del":" stmnt.next().ok();\n"}]}},{"Replacement":{"inode":{"change":4,"pos":42},"path":"src/names_database.rs","line":66,"ins":{"up_context":[{"change":4,"pos":740}],"down_context":[{"change":4,"pos":809}],"flag":"BLOCK","start":826,"end":905,"inode":{"change":4,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":740},"to":{"change":4,"start":740,"end":809},"introduced_by":4}],"inode":{"change":4,"pos":42}},"ins_contents":[{"Add":" sqlite::State::Row => Ok((stmnt.read::(0)?, is_new)),"}],"del_contents":[{"Del":" sqlite::State::Row => Ok(stmnt.read::(0)?),\n"}]}},{"Edit":{"inode":{"change":4,"pos":42},"path":"src/names_database.rs","line":73,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":1063}],"down_context":[{"change":4,"pos":1063}],"flag":"BLOCK","start":906,"end":2656,"inode":{"change":4,"pos":42}}},"contents":[{"Add":" }"},{"Add":" })"},{"Add":" .await??)"},{"Add":" }"},{"Add":""},{"Add":" pub async fn compare("},{"Add":" &self,"},{"Add":" a: i64,"},{"Add":" b: i64,"},{"Add":" ) -> DynResult> {"},{"Add":" if a == b {"},{"Add":" return Ok(Some(std::cmp::Ordering::Equal));"},{"Add":" }"},{"Add":" Ok(self.post(move |conn| -> DynResult> {"},{"Add":" let mut stmnt = conn.prepare(\"SELECT better, worse FROM preferences WHERE (better = ? AND worse = ?) OR (better = ? AND worse = ?)\")?;"},{"Add":" stmnt.bind::(1,a)?;"},{"Add":" stmnt.bind::(2,b)?;"},{"Add":" stmnt.bind::(3,b)?;"},{"Add":" stmnt.bind::(4,a)?;"},{"Add":" match stmnt.next()? {"},{"Add":" sqlite::State::Done => Ok(None),"},{"Add":" sqlite::State::Row => {"},{"Add":" let better = stmnt.read::(0)?;"},{"Add":" let worse = stmnt.read::(1)?;"},{"Add":" if better == a && worse == b {"},{"Add":" Ok(Some(std::cmp::Ordering::Greater))"},{"Add":" } else if better == b && worse == a {"},{"Add":" Ok(Some(std::cmp::Ordering::Less))"},{"Add":" } else {"},{"Add":" Ok(Some(std::cmp::Ordering::Equal))"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":" }).await??)"},{"Add":" }"},{"Add":""},{"Add":" pub async fn list_names(&self) -> DynResult> {"},{"Add":" match self"},{"Add":" .post(|conn| {"},{"Add":" let mut stmnt ="},{"Add":" conn.prepare(\"SELECT name, rowid FROM names\")?;"},{"Add":" let mut rows = Vec::new();"},{"Add":" while let sqlite::State::Row = stmnt.next()? {"},{"Add":" rows.push(("},{"Add":" stmnt.read::(0)?,"},{"Add":" stmnt.read::(1)?,"},{"Add":" ));"}]}},{"Edit":{"inode":{"change":4,"pos":42},"path":"src/names_database.rs","line":121,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":1081}],"down_context":[{"change":4,"pos":1081}],"flag":"BLOCK","start":2657,"end":2682,"inode":{"change":4,"pos":42}}},"contents":[{"Add":" Ok(rows)"}]}},{"Replacement":{"inode":{"change":4,"pos":42},"path":"src/names_database.rs","line":126,"ins":{"up_context":[{"change":4,"pos":1155}],"down_context":[{"change":4,"pos":1229}],"flag":"BLOCK","start":2683,"end":2717,"inode":{"change":4,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1155},"to":{"change":2,"start":119,"end":182},"introduced_by":2}],"inode":{"change":4,"pos":42}},"ins_contents":[{"Add":" Ok(Err(e)) => Err(e),"}],"del_contents":[{"Del":" Ok(Err(e)) => Err(Box::new(e) as crate::DynError),\n"}]}},{"Edit":{"inode":{"change":4,"pos":42},"path":"src/names_database.rs","line":128,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":1261}],"down_context":[{"change":4,"pos":1261}],"flag":"BLOCK","start":2718,"end":4938,"inode":{"change":4,"pos":42}}},"contents":[{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" async fn insert_preference("},{"Add":" &self,"},{"Add":" better: i64,"},{"Add":" worse: i64,"},{"Add":" ) -> DynResult<()> {"},{"Add":" self.insert_one_preference(better, worse).await?;"},{"Add":" self.make_transitive().await"},{"Add":" }"},{"Add":""},{"Add":" async fn insert_one_preference("},{"Add":" &self,"},{"Add":" better: i64,"},{"Add":" worse: i64,"},{"Add":" ) -> DynResult<()> {"},{"Add":" self.post(move |db| -> DynResult<_> {"},{"Add":" let mut stmnt = db.prepare("},{"Add":" \"INSERT INTO preferences(better, worse) VALUES(?, ?)\","},{"Add":" )?;"},{"Add":" stmnt.bind::(1, better)?;"},{"Add":" stmnt.bind::(2, worse)?;"},{"Add":" stmnt.next()?;"},{"Add":" Ok(())"},{"Add":" })"},{"Add":" .await?"},{"Add":" }"},{"Add":""},{"Add":" pub async fn make_transitive(&self) -> DynResult<()> {"},{"Add":" loop {"},{"Add":" let todo = self"},{"Add":" .post(|db| -> DynResult<_> {"},{"Add":" let mut stmnt = db.prepare("},{"Add":" \"SELECT a.better, b.worse"},{"Add":" FROM preferences AS a"},{"Add":" INNER JOIN preferences as b ON a.worse = b.better"},{"Add":" WHERE NOT EXISTS ("},{"Add":" SELECT rowid FROM preferences AS x"},{"Add":" WHERE x.better = a.better"},{"Add":" AND x.worse = b.worse"},{"Add":" )"},{"Add":" \","},{"Add":" )?;"},{"Add":" let mut rows = Vec::new();"},{"Add":" while let sqlite::State::Row = stmnt.next()? {"},{"Add":" rows.push(("},{"Add":" stmnt.read::(0)?,"},{"Add":" stmnt.read::(1)?,"},{"Add":" ));"},{"Add":" }"},{"Add":" Ok(rows)"},{"Add":" })"},{"Add":" .await??;"},{"Add":" if todo.is_empty() {"},{"Add":" return Ok(());"},{"Add":" } else {"},{"Add":" let handles: Vec<_> = todo"},{"Add":" .into_iter()"},{"Add":" .map(|(better, worse)| {"},{"Add":" let target = self.clone();"},{"Add":" tokio::spawn(async move {"},{"Add":" target.insert_one_preference(better, worse).await"},{"Add":" })"},{"Add":" })"},{"Add":" .collect();"},{"Add":" for handle in handles {"},{"Add":" handle.await??;"},{"Add":" }"},{"Add":" }"}]}},{"Replacement":{"inode":{"change":4,"pos":42},"path":"src/names_database.rs","line":202,"ins":{"up_context":[{"change":4,"pos":1400}],"down_context":[{"change":4,"pos":1462}],"flag":"BLOCK","start":4939,"end":4991,"inode":{"change":4,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1400},"to":{"change":4,"start":1400,"end":1462},"introduced_by":4}],"inode":{"change":4,"pos":42}},"ins_contents":[{"Add":" F: FnOnce(&sqlite::Connection) -> U + Send,"}],"del_contents":[{"Del":" F: FnOnce(&sqlite::Connection) -> U + Send + 'static,\n"}]}},{"Edit":{"inode":{"change":4,"pos":42},"path":"src/names_database.rs","line":209,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":1645}],"down_context":[{"change":4,"pos":1645}],"flag":"BLOCK","start":4992,"end":5099,"inode":{"change":4,"pos":42}}},"contents":[{"Add":" let h = move |conn: &sqlite::Connection| {"},{"Add":" sc.send(cb(conn)).unwrap_or(());"},{"Add":" };"}]}},{"Replacement":{"inode":{"change":4,"pos":42},"path":"src/names_database.rs","line":213,"ins":{"up_context":[{"change":4,"pos":1660}],"down_context":[{"change":4,"pos":1771}],"flag":"BLOCK","start":5100,"end":5271,"inode":{"change":4,"pos":42}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1660},"to":{"change":4,"start":1660,"end":1771},"introduced_by":4}],"inode":{"change":4,"pos":42}},"ins_contents":[{"Add":" .send(unsafe {"},{"Add":" std::mem::transmute::<_, DBFunction>(Box::new(h)"},{"Add":" as Box FnOnce(&'a sqlite::Connection) + Send>)"}],"del_contents":[{"Del":" .send(Box::new(move |conn: &sqlite::Connection| {\n sc.send(cb(conn)).unwrap_or(());\n"}]}},{"Edit":{"inode":{"change":4,"pos":42},"path":"src/names_database.rs","line":217,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1786},"to":{"change":4,"start":1786,"end":1861},"introduced_by":4}],"inode":{"change":4,"pos":42}}},"contents":[{"Del":" as Box FnOnce(&'a sqlite::Connection) + Send>)\n"}]}},{"Replacement":{"inode":{"change":11,"pos":49},"path":"src/main.rs","line":47,"ins":{"up_context":[{"change":4,"pos":779}],"down_context":[{"change":4,"pos":1643}],"flag":"BLOCK","start":5272,"end":5371,"inode":{"change":11,"pos":49}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":779},"to":{"change":3,"start":129,"end":168},"introduced_by":3}],"inode":{"change":11,"pos":49}},"ins_contents":[{"Add":" Self::Pick { count } => {"},{"Add":" pick::pick(db, *count).await?;"},{"Add":" }"}],"del_contents":[{"Del":" Self::Pick { count } => {}\n"}]}}],"owner":"quickdudley","repo":"namepick","token":"Ym0MFjovD0KmATGnYoCPdzPA6TQSbsBx0JqFdWtyTP4=","login":null}

…

Dependencies

Change contents