{"header":{"message":"Restart and rewind the server during failover (requires policykit)","description":null,"timestamp":"2022-01-17T15:48:13.195925648Z","authors":[{}]},"hash":"ENEREHTW2UEXJGIOSSKZA2FQKFDLWQEIOAD6NIT2EH6BJW6E3AZQC","authors":[{"login":"pmeunier","key":"FZQ2g7VfnzLYM4mtTVDk9HAZjA8Jk9ndkwN1icgbtWUr"}],"deps":{"hashes":[["ENEREHTW2UEXJGIOSSKZA2FQKFDLWQEIOAD6NIT2EH6BJW6E3AZQC","Restart and rewind the server during failover (requires policykit)"],["AA",null],["424R2VFMTHIPTPPNCGFBKHQUD3UO2CBNA3KNL3PQ5IKEJUGIJJTQC","description, license, versions"],["6Z6PYXTSU3DYKZKXWSZ5JZXAO2MO4KJADTYNDLUYMD4LROXRREZAC","Testing and debugging"],["NPSWSVZNDMXYBVCBFSHZ2PVLUSX45LZVUMD6ROS3KLHNMBTYASZQC","Init"],["QISO3HXB5IMBL4FPEYONMIBBD4XMF65UBDQZKFTRH2QH62G7ZDTAC","Debug++"],["DSKXOP5Q6NRJDD5NNEX7G3L3NHZFJZJE3TZFX25HC7ZHW2T3V6NAC","README + formatting + argument checking"]],"deps":["424R2VFMTHIPTPPNCGFBKHQUD3UO2CBNA3KNL3PQ5IKEJUGIJJTQC","6Z6PYXTSU3DYKZKXWSZ5JZXAO2MO4KJADTYNDLUYMD4LROXRREZAC"],"known":["NPSWSVZNDMXYBVCBFSHZ2PVLUSX45LZVUMD6ROS3KLHNMBTYASZQC","DSKXOP5Q6NRJDD5NNEX7G3L3NHZFJZJE3TZFX25HC7ZHW2T3V6NAC","QISO3HXB5IMBL4FPEYONMIBBD4XMF65UBDQZKFTRH2QH62G7ZDTAC"]},"hunks":[{"Edit":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":27,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":741}],"down_context":[{"change":4,"pos":741}],"flag":"BLOCK","start":0,"end":74,"inode":{"change":4,"pos":17}}},"contents":[{"Add":" .arg(clap::Arg::with_name(\"port\").long(\"port\").takes_value(true))"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":29,"ins":{"up_context":[{"change":4,"pos":755}],"down_context":[{"change":4,"pos":153}],"flag":"BLOCK","start":75,"end":210,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":755},"to":{"change":4,"start":755,"end":888},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":85},"to":{"change":4,"start":85,"end":153},"introduced_by":4}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" clap::Arg::with_name(\"db\")"},{"Add":" .long(\"db\")"},{"Add":" .takes_value(true)"},{"Add":" .required(true),"}],"del_contents":[{"Del":" clap::Arg::with_name(\"signal\")\n .long(\"signal\")\n .help(\"Path to the postgres signal file\")\n"},{"Del":" .required(true)\n .takes_value(true),\n"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":34,"ins":{"up_context":[{"change":4,"pos":163}],"down_context":[{"change":4,"pos":163}],"flag":"BLOCK","start":211,"end":374,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":163},"to":{"change":4,"start":15,"end":89},"introduced_by":4}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" .arg("},{"Add":" clap::Arg::with_name(\"path\")"},{"Add":" .long(\"path\")"},{"Add":" .takes_value(true)"},{"Add":" .required(true),"},{"Add":" )"}],"del_contents":[{"Del":" .arg(clap::Arg::with_name(\"port\").long(\"port\").takes_value(true))\n"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":49,"ins":{"up_context":[{"change":4,"pos":1545}],"down_context":[{"change":4,"pos":1611}],"flag":"BLOCK","start":375,"end":505,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1545},"to":{"change":4,"start":1545,"end":1611},"introduced_by":4}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" let port: u16 = if let Some(port) = matches.value_of(\"port\") {"},{"Add":" port.parse().unwrap()"},{"Add":" } else {"},{"Add":" 5432"},{"Add":" };"}],"del_contents":[{"Del":" let signal = matches.value_of(\"signal\").unwrap().to_string();\n"}]}},{"Edit":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":55,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":1681}],"down_context":[{"change":4,"pos":1681}],"flag":"BLOCK","start":506,"end":631,"inode":{"change":4,"pos":17}}},"contents":[{"Add":" let path = matches.value_of(\"path\").unwrap().to_string();"},{"Add":" let db_name = matches.value_of(\"db\").unwrap().to_string();"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":58,"ins":{"up_context":[{"change":4,"pos":1682}],"down_context":[{"change":4,"pos":1726}],"flag":"BLOCK","start":632,"end":684,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1682},"to":{"change":4,"start":1682,"end":1726},"introduced_by":4}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" let (lead, is_leader) = channel(String::new());"}],"del_contents":[{"Del":" let (lead, is_leader) = channel(false);\n"}]}},{"Edit":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":65,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":128},"to":{"change":3,"start":128,"end":163},"introduced_by":3}],"inode":{"change":4,"pos":17}}},"contents":[{"Del":" let mut is_normal = false;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":67,"ins":{"up_context":[{"change":3,"pos":211}],"down_context":[{"change":3,"pos":338}],"flag":"BLOCK","start":685,"end":807,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":211},"to":{"change":3,"start":211,"end":338},"introduced_by":3}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" match tokio_postgres::connect(\"host=localhost user=postgres connect_timeout=1\", NoTls)"},{"Add":" .await"}],"del_contents":[{"Del":" if let Ok((db, connection)) =\n tokio_postgres::connect(\"host=localhost user=postgres\", NoTls).await\n"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":70,"ins":{"up_context":[{"change":3,"pos":352}],"down_context":[{"change":3,"pos":422}],"flag":"BLOCK","start":808,"end":1003,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":352},"to":{"change":3,"start":352,"end":422},"introduced_by":3}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" Ok((db, connection)) => {"},{"Add":" *db_.lock().await = Some(db);"},{"Add":" let e = connection.await;"},{"Add":" debug!(\"connection ended: {:?}\", e);"}],"del_contents":[{"Del":" if is_normal {\n is_normal = false;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":75,"ins":{"up_context":[{"change":3,"pos":440}],"down_context":[{"change":3,"pos":946}],"flag":"BLOCK","start":1004,"end":1127,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":440},"to":{"change":3,"start":440,"end":946},"introduced_by":3}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" Err(e) => {"},{"Add":" error!(\"{:?}\", e);"},{"Add":" lead_.send(String::new()).unwrap();"}],"del_contents":[{"Del":" *db_.lock().await = Some(db);\n let e = connection.await;\n eprintln!(\"connection ended: {:?}\", e);\n // Ignore \"normal\" restarts (i.e. promotes).\n let db = db_.lock().await.take();\n if db.is_some() {\n lead_.send(false).unwrap();\n *db_.lock().await = None;\n } else {\n debug!(\"normal restart, reconnecting\");\n is_normal = true;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":86,"ins":{"up_context":[{"change":4,"pos":1843}],"down_context":[{"change":4,"pos":1867}],"flag":"BLOCK","start":1128,"end":1142,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1843},"to":{"change":4,"start":1843,"end":1867},"introduced_by":4}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" port,"}],"del_contents":[{"Del":" signal.clone(),\n"}]}},{"Edit":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":88,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":1893}],"down_context":[{"change":4,"pos":1893}],"flag":"BLOCK","start":1143,"end":1190,"inode":{"change":4,"pos":17}}},"contents":[{"Add":" db_name.clone(),"},{"Add":" path.clone(),"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":93,"ins":{"up_context":[{"change":4,"pos":1943}],"down_context":[{"change":3,"pos":1366}],"flag":"BLOCK","start":1191,"end":1263,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1943},"to":{"change":3,"start":1075,"end":1366},"introduced_by":3}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" let mut race = tokio::spawn(race(host.clone(), is_leader.clone()));"}],"del_contents":[{"Del":" let mut race = tokio::spawn(race(host.clone(), signal.clone(), is_leader.clone()));\n // let addr = SocketAddr::from((\n // [0, 0, 0, 0],\n // matches\n // .value_of(\"port\")\n // .and_then(|x| x.parse().ok())\n // .unwrap_or(8008),\n // ));\n"}]}},{"Edit":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":101,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":2266}],"down_context":[{"change":4,"pos":2266}],"flag":"BLOCK","start":1264,"end":1295,"inode":{"change":4,"pos":17}}},"contents":[{"Add":" let host = Arc::new(host);"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":104,"ins":{"up_context":[{"change":4,"pos":2363}],"down_context":[{"change":4,"pos":2461}],"flag":"BLOCK","start":1296,"end":1530,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2363},"to":{"change":4,"start":2363,"end":2461},"introduced_by":4}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" let host = host.clone();"},{"Add":" async move {"},{"Add":" let host = host.clone();"},{"Add":" Ok::<_, Infallible>(service_fn(move |req| {"},{"Add":" handle(req, host.clone(), is_leader.clone())"},{"Add":" }))"},{"Add":" }"}],"del_contents":[{"Del":" async move { Ok::<_, Infallible>(service_fn(move |req| handle(req, is_leader.clone()))) }\n"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":133,"ins":{"up_context":[{"change":4,"pos":3797}],"down_context":[{"change":4,"pos":3828}],"flag":"BLOCK","start":1531,"end":1587,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":3797},"to":{"change":4,"start":3797,"end":3828},"introduced_by":4}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" name: Arc,"},{"Add":" is_leader: Receiver,"}],"del_contents":[{"Del":" is_leader: Receiver,\n"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":136,"ins":{"up_context":[{"change":4,"pos":3870}],"down_context":[{"change":4,"pos":3899}],"flag":"BLOCK","start":1588,"end":1642,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":3870},"to":{"change":4,"start":3870,"end":3899},"introduced_by":4}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" if is_leader.borrow().as_str() == name.as_str() {"}],"del_contents":[{"Del":" if *is_leader.borrow() {\n"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":145,"ins":{"up_context":[{"change":4,"pos":4094}],"down_context":[{"change":3,"pos":1697}],"flag":"BLOCK","start":1643,"end":1732,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4094},"to":{"change":4,"start":4094,"end":4147},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4176},"to":{"change":4,"start":4176,"end":4244},"introduced_by":4}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":"async fn race(host: String, mut leader: Receiver) -> Result<(), anyhow::Error> {"}],"del_contents":[{"Del":"async fn race(\n host: String,\n signal: String,\n"},{"Del":" mut is_leader: Receiver,\n) -> Result<(), anyhow::Error> {\n"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":170,"ins":{"up_context":[{"change":4,"pos":4591}],"down_context":[{"change":4,"pos":234}],"flag":"BLOCK","start":1733,"end":1787,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":5242},"to":{"change":4,"start":5242,"end":5292},"introduced_by":4}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" let leader_key = lock.take_leader().unwrap();"}],"del_contents":[{"Del":" let leader = lock.take_leader().unwrap();\n"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":173,"ins":{"up_context":[{"change":4,"pos":289}],"down_context":[{"change":4,"pos":383}],"flag":"BLOCK","start":1788,"end":1890,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":289},"to":{"change":4,"start":289,"end":383},"introduced_by":4}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" std::str::from_utf8(leader_key.name()),"},{"Add":" std::str::from_utf8(leader_key.key())"}],"del_contents":[{"Del":" std::str::from_utf8(leader.name()),\n std::str::from_utf8(leader.key())\n"}]}},{"Edit":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":176,"atom":{"EdgeMap":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":394},"to":{"change":4,"start":5338,"end":5391},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":5338},"to":{"change":4,"start":5338,"end":5391},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":5425},"to":{"change":4,"start":5425,"end":5486},"introduced_by":4}],"inode":{"change":4,"pos":17}}},"contents":[{"Del":" std::fs::remove_file(&signal).unwrap_or(());\n"},{"Del":" debug!(\"waiting for instance to become non-leader\");\n"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":177,"ins":{"up_context":[{"change":4,"pos":5501}],"down_context":[{"change":4,"pos":5644}],"flag":"BLOCK","start":1891,"end":2039,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":5501},"to":{"change":4,"start":5501,"end":5644},"introduced_by":4}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" leader.changed().await.unwrap();"},{"Add":" debug!(\"leader: {:?}\", leader.borrow());"},{"Add":" if leader.borrow().as_str() != host {"}],"del_contents":[{"Del":" is_leader.changed().await.unwrap();\n debug!(\"changed: {:?}\", is_leader.borrow());\n if !*is_leader.borrow() {\n"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":182,"ins":{"up_context":[{"change":4,"pos":5795}],"down_context":[{"change":4,"pos":5884}],"flag":"BLOCK","start":2040,"end":2180,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":5795},"to":{"change":4,"start":5795,"end":5884},"introduced_by":4}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" .resign(Some("},{"Add":" etcd_client::ResignOptions::new().with_leader(leader_key),"},{"Add":" ))"}],"del_contents":[{"Del":" .resign(Some(etcd_client::ResignOptions::new().with_leader(leader)))\n"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":194,"ins":{"up_context":[{"change":4,"pos":6015}],"down_context":[{"change":4,"pos":6035}],"flag":"BLOCK","start":2181,"end":2196,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":6015},"to":{"change":4,"start":6015,"end":6035},"introduced_by":4}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" port: u16,"}],"del_contents":[{"Del":" signal: String,\n"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":196,"ins":{"up_context":[{"change":4,"pos":6057}],"down_context":[{"change":3,"pos":2422}],"flag":"BLOCK","start":2197,"end":2267,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":6057},"to":{"change":4,"start":6057,"end":6086},"introduced_by":4}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" db_name: String,"},{"Add":" path: String,"},{"Add":" lead: Arc>,"}],"del_contents":[{"Del":" lead: Arc>,\n"}]}},{"Edit":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":203,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":6288}],"down_context":[{"change":4,"pos":6288}],"flag":"BLOCK","start":2268,"end":2659,"inode":{"change":4,"pos":17}}},"contents":[{"Add":" let mut was_leader = {"},{"Add":" if let Some(pool_) = pool.lock().await.take() {"},{"Add":" let row = pool_.query_one(\"SELECT pg_is_in_recovery()\", &[]).await?;"},{"Add":" let is_in_recovery: bool = row.get(0);"},{"Add":" *pool.lock().await = Some(pool_);"},{"Add":" Some(!is_in_recovery)"},{"Add":" } else {"},{"Add":" None"},{"Add":" }"},{"Add":" };"},{"Add":" debug!(\"was_leader = {:?}\", was_leader);"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":218,"ins":{"up_context":[{"change":3,"pos":2518}],"down_context":[{"change":4,"pos":6446}],"flag":"BLOCK","start":2660,"end":2724,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":2518},"to":{"change":4,"start":6418,"end":6446},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":6418},"to":{"change":4,"start":6418,"end":6446},"introduced_by":4}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" let is_leader = leader == host;"},{"Add":""},{"Add":" if is_leader {"}],"del_contents":[{"Del":" if leader != host {\n"}]}},{"Edit":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":222,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":6495},"to":{"change":4,"start":6495,"end":6589},"introduced_by":4}],"inode":{"change":4,"pos":17}}},"contents":[{"Del":" std::fs::write(&signal, \"\").unwrap_or(());\n lead.send(false).unwrap();\n"}]}},{"Edit":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":224,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":6700},"to":{"change":4,"start":6700,"end":6738},"introduced_by":4}],"inode":{"change":4,"pos":17}}},"contents":[{"Del":" lead.send(true).unwrap();\n"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":225,"ins":{"up_context":[{"change":4,"pos":6748}],"down_context":[{"change":3,"pos":2602}],"flag":"BLOCK","start":2725,"end":2830,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":6748},"to":{"change":3,"start":2519,"end":2602},"introduced_by":3}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" lead.send(leader.to_string()).unwrap();"},{"Add":""},{"Add":" if let Some(pool_) = pool.lock().await.take() {"}],"del_contents":[{"Del":" let pool_ = pool.lock().await.take();\n if let Some(pool_) = pool_ {\n"}]}},{"Replacement":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":229,"ins":{"up_context":[{"change":3,"pos":2763}],"down_context":[{"change":3,"pos":3173}],"flag":"BLOCK","start":2831,"end":3088,"inode":{"change":4,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2763},"to":{"change":3,"start":2763,"end":3173},"introduced_by":3}],"inode":{"change":4,"pos":17}},"ins_contents":[{"Add":" *pool.lock().await = Some(pool_);"},{"Add":" }"},{"Add":""},{"Add":" if is_leader && was_leader != Some(true) {"},{"Add":" promote(&path).await"},{"Add":" } else if !is_leader && was_leader == Some(true) {"},{"Add":" rewind(&path, port, &db_name, &leader).await"}],"del_contents":[{"Del":" if leader == host {\n info!(\"promoting\");\n pool_.execute(\"SELECT pg_promote()\", &[]).await.unwrap_or(0);\n // Don't replace pool_ into *pool, since the server might restart.\n *pool.lock().await = Some(pool_)\n } else {\n *pool.lock().await = Some(pool_)\n }\n } else {\n lead.send(false)?;\n"}]}},{"Edit":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":237,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":3183}],"down_context":[{"change":4,"pos":6942}],"flag":"BLOCK","start":3089,"end":3133,"inode":{"change":4,"pos":17}}},"contents":[{"Add":""},{"Add":" was_leader = Some(leader == host);"}]}},{"Edit":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":241,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":6959}],"down_context":[{"change":4,"pos":6959}],"flag":"BLOCK","start":3134,"end":3346,"inode":{"change":4,"pos":17}}},"contents":[{"Add":"}"},{"Add":""},{"Add":"async fn promote(path: &str) {"},{"Add":" use tokio::process::Command;"},{"Add":" Command::new(\"pg_ctl\")"},{"Add":" .args([\"promote\", \"-D\", path])"},{"Add":" .output()"},{"Add":" .await"},{"Add":" .expect(\"failed to execute process\");"}]}},{"Edit":{"inode":{"change":4,"pos":17},"path":"src/main.rs","line":251,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":6961}],"down_context":[],"flag":"BLOCK","start":3347,"end":4114,"inode":{"change":4,"pos":17}}},"contents":[{"Add":""},{"Add":"async fn rewind(path: &str, port: u16, db_name: &str, leader: &str) {"},{"Add":" use tokio::process::Command;"},{"Add":" Command::new(\"systemctl\")"},{"Add":" .args([\"stop\", \"postgresql-repl\"])"},{"Add":" .output()"},{"Add":" .await"},{"Add":" .expect(\"failed to execute process\");"},{"Add":" Command::new(\"pg_rewind\")"},{"Add":" .args(["},{"Add":" \"-D\","},{"Add":" &path,"},{"Add":" \"-R\","},{"Add":" \"--source-server\","},{"Add":" &format!("},{"Add":" \"port={} user=postgres dbname={} host={}\","},{"Add":" port, db_name, leader"},{"Add":" ),"},{"Add":" ])"},{"Add":" .output()"},{"Add":" .await"},{"Add":" .expect(\"failed to execute process\");"},{"Add":" Command::new(\"systemctl\")"},{"Add":" .args([\"start\", \"postgresql-repl\"])"},{"Add":" .output()"},{"Add":" .await"},{"Add":" .expect(\"failed to execute process\");"},{"Add":"}"}]}},{"Edit":{"inode":{"change":4,"pos":7109},"path":"README.md","line":10,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":773}],"down_context":[],"flag":"BLOCK","start":4115,"end":4583,"inode":{"change":4,"pos":7109}}},"contents":[{"Add":""},{"Add":"### Cooperation from the OS"},{"Add":""},{"Add":"The same user must run the PostgreSQL server and this tool. If that user is called `postgres`, here is a possible PolicyKit rule to make it work:"},{"Add":""},{"Add":"``` js"},{"Add":" polkit.addRule(function(action, subject) {"},{"Add":" if (action.id == \"org.freedesktop.systemd1.manage-units\" &&"},{"Add":" action.lookup(\"unit\") == \"postgresql-repl.service\" &&"},{"Add":" subject.user == \"postgres\"){"},{"Add":" return polkit.Result.YES;"},{"Add":" }"},{"Add":" });"},{"Add":"```"}]}},{"Replacement":{"inode":{"change":4,"pos":7335},"path":"Cargo.toml","line":14,"ins":{"up_context":[{"change":2,"pos":128}],"down_context":[{"change":2,"pos":250}],"flag":"BLOCK","start":4584,"end":4717,"inode":{"change":4,"pos":7335}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":128},"to":{"change":2,"start":128,"end":250},"introduced_by":2}],"inode":{"change":4,"pos":7335}},"ins_contents":[{"Add":"tokio = { version = \"1.6\", features = [ \"net\", \"time\", \"rt-multi-thread\", \"macros\", \"io-util\", \"fs\", \"sync\", \"signal\", \"process\" ] }"}],"del_contents":[{"Del":"tokio = { version = \"1.6\", features = [ \"net\", \"time\", \"rt-multi-thread\", \"macros\", \"io-util\", \"fs\", \"sync\", \"signal\" ] }\n"}]}}],"owner":"pmeunier","repo":"postrep","token":"efCMLczFXf94ci9/1tLghAmCFSJ9PdDP1FirJ/rIzUk=","login":null}

…

Dependencies

Change contents