X-Git-Url: http://git.euphorik.ch/?a=blobdiff_plain;f=src%2Fmain.rs;h=67c251a9b668376c6eaf081fa6151b63160bedbd;hb=f66ea654402cb0a44d075466a1a55a89b5512e4a;hp=e6eadc837839132256a59d9a69d29947e3b7cf44;hpb=a741015a5979b2a18e997b1efe39f604c98812ca;p=gandi_dns_update.git diff --git a/src/main.rs b/src/main.rs index e6eadc8..67c251a 100644 --- a/src/main.rs +++ b/src/main.rs @@ -1,13 +1,22 @@ /* * API Reference: https://api.gandi.net/docs/livedns/ - * Some inspiration: https://github.com/rmarchant/gandi-ddns/blob/master/gandi_ddns.py + * Some similar implementations: + * - https://github.com/rmarchant/gandi-ddns/blob/master/gandi_ddns.py + * - https://github.com/brianhp2/gandi-automatic-dns + * + * TODO: + * - Log to stdout with (at least) timestamps. + * - Renew function. */ -use std::{fmt::format, fs::File, net::{ IpAddr, Ipv4Addr }, thread, time}; +#![cfg_attr(debug_assertions, allow(unused_variables, unused_imports, dead_code))] + +use std::{ fs::File, net::{ IpAddr, Ipv4Addr }, thread, time }; use ron::{ de::from_reader, ser::to_writer }; use serde::{ Deserialize, Serialize }; -use serde_json::{ Value }; +use serde_json::{ Value, json }; +// A generic result of type 'T'. type Result = std::result::Result>; #[derive(Debug)] @@ -17,21 +26,24 @@ struct Error { impl std::fmt::Display for Error { fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { - f.write_str(&self.message) + write!(f, "Error: {}", &self.message) } } -impl std::error::Error for Error {} +impl std::error::Error for Error { } -#[derive(Debug, Deserialize, Serialize)] +#[derive(Debug, Clone, Deserialize, Serialize)] struct Config { delay_between_check: time::Duration, api_key: String, + fqdn: String, + domains: Vec, + ttl: i32 } impl Config { fn default() -> Self { - Config { delay_between_check: time::Duration::from_secs(60), api_key: String::from("") } + Config { delay_between_check: time::Duration::from_secs(120), api_key: String::from(""), fqdn: String::from(""), domains: Vec::new(), ttl: 300 } } fn read(file_path: &str) -> Result { @@ -51,16 +63,19 @@ impl Config { const FILE_CONF: &str = "config.ron"; fn main() -> Result<()> { + println!("GANDI DynDNS"); let config = Config::read(FILE_CONF)?; - println!("Configuration: {:?}", config); + println!("Configuration: {:?}", Config { api_key: String::from("*****"), ..config.clone() }); loop { let time_beginning_loop = time::Instant::now(); - check_and_update_dns(&config.api_key); + if let Err(err) = check_and_update_dns(&config.api_key, &config.fqdn, &config.domains, config.ttl) { + println!("!! Error: {}", err); + } let elapsed = time::Instant::now() - time_beginning_loop; @@ -68,16 +83,23 @@ fn main() -> Result<()> { let to_wait = config.delay_between_check - elapsed; thread::sleep(to_wait); } - } } -fn check_and_update_dns(api_key: &str) { - /* - */ - //dbg!(get_real_ip()); +fn check_and_update_dns(api_key: &str, fqdn: &str, domains: &Vec, ttl: i32) -> Result<()> { + let real_ip = get_real_ip()?; + + for domain in domains { + let current_ip = get_current_record_ip(api_key, domain, fqdn)?; + + if real_ip != current_ip { + println!("IP addresses don't match for domain {}: real = {}, dns = {}. Renewing DNS...", domain, real_ip, current_ip); + update_record_ip(api_key, domain, fqdn, real_ip, ttl)?; + println!("Renewing of {} successfully", domain); + } + } - get_current_record_ip(api_key); + Ok(()) } fn get_real_ip() -> Result { @@ -91,26 +113,34 @@ fn get_real_ip() -> Result { let content = resp.text().unwrap(); match content.parse::() { Ok(IpAddr::V4(ip_v4)) => Ok(ip_v4), - /*Err(_)*/ _ => Err(Box::new(Error { message: String::from("Can't parse IPv4 from ipify") })) + _ => Err(Box::new(Error { message: String::from("Can't parse IPv4 from ipify") })) } - //println!("Content:\n{:?}", content); } else { - //println!("Request unsuccessful:\n{:#?}", resp); Err(Box::new(Error { message: format!("Request unsuccessful: {:#?}", resp) })) }, Err(error) => { - //println!("Error during request: {:?}", error); Err(Box::new(Error { message: format!("Error during request: {:?}", error) })) } } } -fn request_livedns_gandi(api_key: &str, url_fragment: &str) -> Result { +enum Method { + Put(String), + Get +} + +fn request_livedns_gandi(api_key: &str, url_fragment: &str, method: Method) -> Result { let url = format!("https://api.gandi.net/v5/livedns/{}", url_fragment); let client = reqwest::blocking::Client::new(); - match client.get(&url).header("Authorization", format!("Apikey {}", api_key)).send() { + let request_builder = + match method { + Method::Put(body) => client.put(url).body(body), + Method::Get => client.get(url) + }; + + match request_builder.header("Authorization", format!("Apikey {}", api_key)).send() { Ok(resp) => if resp.status().is_success() { let content = resp.text().unwrap(); @@ -123,40 +153,29 @@ fn request_livedns_gandi(api_key: &str, url_fragment: &str) -> Result { } } -fn get_current_record_ip(api_key: &str) -> Result { - - request_livedns_gandi(api_key, "domains/euphorik.ch/records/home/A"); // TODO... - // .map() - //.map(|json_value| json_value["rrset_values"][0].as_str().unwrap()) - - +fn get_current_record_ip(api_key: &str, name: &str, fqdn: &str) -> Result { + let json_value = request_livedns_gandi(api_key, &format!("domains/{}/records/{}/A", fqdn, name), Method::Get)?; - //let url = "https://api.gandi.net/v5/livedns/domains/euphorik.ch/records"; - //let url = "https://api.gandi.net/v5/livedns/domains"; // ?sharing_id=" - //let url = "https://api.gandi.net/v5/organization/organizations"; - //let url = "https://api.gandi.net/v5/livedns/domains/euphorik.ch/records/home/A"; - - /* - let client = reqwest::blocking::Client::new(); + match &json_value["rrset_values"][0] { + Value::String(ip_str) => + Ok(ip_str.parse()?), + _ => + Result::Err(Box::new(Error { message: format!("Unable to extract the IP from the JSON answer: {}", json_value) })) + } +} - match client.get(url).header("Authorization", format!("Apikey {}", api_key)).send() { - Ok(resp) => - if resp.status().is_success() { - let content = resp.text().unwrap(); +fn update_record_ip(api_key: &str, name: &str, fqdn: &str, ip: Ipv4Addr, ttl: i32) -> Result<()> { + let json_body = + json!( + { + "rrset_values": [ format!("{}", ip) ], + "rrset_ttl": ttl + } + ); - let json: Value = serde_json::from_str(&content).unwrap(); - let prout = json["rrset_values"][0].as_str().unwrap(); - println!("IP: {}", prout); + let json_value = request_livedns_gandi(api_key, &format!("domains/{}/records/{}/A", fqdn, name), Method::Put(json_body.to_string()))?; - println!("Content:\n{}", serde_json::to_string_pretty(&json).unwrap()); - } else { - println!("Request unsuccessful:\n{:#?}", resp); - }, - Err(error) => - println!("Error during request: {:?}", error) - } - */ -} + println!("Update response: {}", json_value); -fn update_record_ip() { + Ok(()) }