{"header":{"message":"Initial functions for using sqlite in async environment","description":null,"timestamp":"2021-12-23T20:06:11.24163Z","authors":[{"email":"quick.dudley@gmail.com","full_name":"Jeremy List","name":"quickdudley"}]},"hash":"AV73DYWQ2UVZJYTN3UIW3TDMWNAETLXZRD7VHKTQLFQGHKJ5KI6QC","authors":[],"deps":{"hashes":[["AV73DYWQ2UVZJYTN3UIW3TDMWNAETLXZRD7VHKTQLFQGHKJ5KI6QC","Initial functions for using sqlite in async environment"],["AA",null],["HMOBTVJ4FEPZWMUV2JDPZYH3EFCW6ED5M6KKNKQJQZVKTDAKTVFQC","Initialize crate and add expected dependencies"],["U7WU3PMUSV53XOBSOJV3SX3SQH3T7UTZYS4MGD4VO732EBFIFNPAC",""]],"deps":["HMOBTVJ4FEPZWMUV2JDPZYH3EFCW6ED5M6KKNKQJQZVKTDAKTVFQC"],"known":[]},"hunks":[{"FileAdd":{"meta":{"basename":"names_database.rs","metadata":0},"context":[{"change":2,"pos":15}],"contents":[{"Add":"use tokio::sync::{mpsc, oneshot};"},{"Add":""},{"Add":"fn create_tables(conn: &sqlite::Connection) -> sqlite::Result<()> {"},{"Add":" conn.execute(\"CREATE TABLE IF NOT EXISTS names (name TEXT)\")?;"},{"Add":" conn.execute("},{"Add":" \"CREATE TABLE IF NOT EXISTS preferences ("},{"Add":" better INTEGER,"},{"Add":" worse INTEGER,"},{"Add":" FOREIGN KEY (better) REFERENCES names(rowid) ON DELETE CASCADE,"},{"Add":" FOREIGN KEY (worse) REFERENCES names(rowid) ON DELETE CASCADE,"},{"Add":" UNIQUE(better,worse))\","},{"Add":" )?;"},{"Add":" Ok(())"},{"Add":"}"},{"Add":""},{"Add":"struct AsyncConnection("},{"Add":" mpsc::Sender FnOnce(&'a sqlite::Connection) + Send>>,"},{"Add":");"},{"Add":""},{"Add":"impl AsyncConnection {"},{"Add":" pub async fn open + Send + 'static>("},{"Add":" path: T,"},{"Add":" ) -> Result> {"},{"Add":" let (tx, mut rx): ("},{"Add":" _,"},{"Add":" mpsc::Receiver FnOnce(&sqlite::Connection) + Send>>,"},{"Add":" ) = mpsc::channel(1);"},{"Add":" std::thread::Builder::new()"},{"Add":" .name(format!(\"database thread: {}\", path.as_ref().display()))"},{"Add":" .spawn(move || {"},{"Add":" let conn = sqlite::open(path).unwrap();"},{"Add":" while let Some(cb) = rx.blocking_recv() {"},{"Add":" cb(&conn);"},{"Add":" }"},{"Add":" })?;"},{"Add":" let result = Self(tx);"},{"Add":" result.post(create_tables).await??;"},{"Add":" Ok(result)"},{"Add":" }"},{"Add":""},{"Add":" async fn post<"},{"Add":" F: FnOnce(&sqlite::Connection) -> U + Send + 'static,"},{"Add":" U: Send + 'static,"},{"Add":" >("},{"Add":" &self,"},{"Add":" cb: F,"},{"Add":" ) -> Result> {"},{"Add":" let (sc, rc): (_, oneshot::Receiver) = oneshot::channel();"},{"Add":" self.0"},{"Add":" .send(Box::new(move |conn: &sqlite::Connection| {"},{"Add":" sc.send(cb(conn)).unwrap_or(());"},{"Add":" })"},{"Add":" as Box FnOnce(&'a sqlite::Connection) + Send>)"},{"Add":" .await"},{"Add":" .map_err(|mpsc::error::SendError(_)| mpsc::error::SendError(()))?;"},{"Add":" Ok(rc.await?)"},{"Add":" }"},{"Add":"}"}]}},{"Replacement":{"inode":{"change":2,"pos":49},"path":"src/main.rs","line":1,"ins":{"up_context":[{"change":2,"pos":49}],"down_context":[{"change":2,"pos":62}],"flag":"BLOCK","start":1990,"end":2044,"inode":{"change":2,"pos":49}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":49},"to":{"change":2,"start":50,"end":62},"introduced_by":2}],"inode":{"change":2,"pos":49}},"ins_contents":[{"Add":"mod names_database;"},{"Add":""},{"Add":"#[tokio::main]"},{"Add":"async fn main() {"}],"del_contents":[{"Del":"fn main() {\n"}]}},{"FileAdd":{"meta":{"basename":"rustfmt.toml","metadata":0},"context":[{"change":4,"pos":1}],"contents":[{"Add":"max_width = 80"}]}},{"Replacement":{"inode":{"change":2,"pos":131},"path":"Cargo.toml","line":12,"ins":{"up_context":[{"change":2,"pos":367}],"down_context":[],"flag":"BLOCK","start":2099,"end":2178,"inode":{"change":2,"pos":131}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":367},"to":{"change":2,"start":367,"end":433},"introduced_by":2}],"inode":{"change":2,"pos":131}},"ins_contents":[{"Add":"tokio = { version = \"1.15.0\", features = [\"macros\",\"sync\",\"rt-multi-thread\"] }"}],"del_contents":[{"Del":"tokio = { version = \"1.15.0\", features = [\"macros\",\"sync\",\"rt\"] }\n"}]}},{"Edit":{"inode":{"change":2,"pos":469},"path":"Cargo.lock","line":289,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":8194}],"down_context":[{"change":2,"pos":8194}],"flag":"BLOCK","start":2179,"end":2402,"inode":{"change":2,"pos":469}}},"contents":[{"Add":""},{"Add":"[[package]]"},{"Add":"name = \"hermit-abi\""},{"Add":"version = \"0.1.19\""},{"Add":"source = \"registry+https://github.com/rust-lang/crates.io-index\""},{"Add":"checksum = \"62b467343b94ba476dcb2500d242dadbb39557df889310ac77c5d99100aaac33\""},{"Add":"dependencies = ["},{"Add":" \"libc\","},{"Add":"]"}]}},{"Edit":{"inode":{"change":2,"pos":469},"path":"Cargo.lock","line":578,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":15020}],"down_context":[{"change":2,"pos":15020}],"flag":"BLOCK","start":2403,"end":2639,"inode":{"change":2,"pos":469}}},"contents":[{"Add":"]"},{"Add":""},{"Add":"[[package]]"},{"Add":"name = \"num_cpus\""},{"Add":"version = \"1.13.1\""},{"Add":"source = \"registry+https://github.com/rust-lang/crates.io-index\""},{"Add":"checksum = \"19e64526ebdee182341572e50e9ad03965aa510cd94427a4549448f285e957a1\""},{"Add":"dependencies = ["},{"Add":" \"hermit-abi\","},{"Add":" \"libc\","}]}},{"Edit":{"inode":{"change":2,"pos":469},"path":"Cargo.lock","line":1204,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":30147}],"down_context":[{"change":2,"pos":30147}],"flag":"BLOCK","start":2640,"end":2653,"inode":{"change":2,"pos":469}}},"contents":[{"Add":" \"num_cpus\","}]}}],"owner":"quickdudley","repo":"namepick","token":"ZXlbetwpMEpmAUZxRYNsvq3SUV7/YIi95U/QhVM/JM8=","login":null}

…

Dependencies

Change contents