#![cfg_attr(debug_assertions, allow(unused_variables, unused_imports, dead_code))]
-use std::{ fmt::format, fs::File, net::{ IpAddr, Ipv4Addr }, thread, time };
+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<T> = std::result::Result<T, Box<dyn std::error::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<String>,
+ ttl: i32
}
impl Config {
fn default() -> Self {
- Config { delay_between_check: time::Duration::from_secs(60), api_key: String::from(""), domains: Vec::new() }
+ 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<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();
- if let Err(err) = check_and_update_dns(&config.api_key, &config.domains) {
+ if let Err(err) = check_and_update_dns(&config.api_key, &config.fqdn, &config.domains, config.ttl) {
println!("!! Error: {}", err);
}
}
}
-fn check_and_update_dns(api_key: &str, domains: &Vec<String>) -> Result<()> {
+fn check_and_update_dns(api_key: &str, fqdn: &str, domains: &Vec<String>, ttl: i32) -> Result<()> {
let real_ip = get_real_ip()?;
- dbg!(&real_ip);
for domain in domains {
- let current_ip = get_current_record_ip(api_key, domain)?;
- dbg!(domain, current_ip);
+ 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()?;
+ update_record_ip(api_key, domain, fqdn, real_ip, ttl)?;
println!("Renewing of {} successfully", domain);
}
}
}
}
-fn request_livedns_gandi(api_key: &str, url_fragment: &str) -> Result<Value> {
+enum Method {
+ Put(String),
+ Get
+}
+
+fn request_livedns_gandi(api_key: &str, url_fragment: &str, method: Method) -> Result<Value> {
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();
}
}
-fn get_current_record_ip(api_key: &str, name: &str) -> Result<Ipv4Addr> {
- let json_value = request_livedns_gandi(api_key, &format!("domains/euphorik.ch/records/{}/A", name))?;
+fn get_current_record_ip(api_key: &str, name: &str, fqdn: &str) -> Result<Ipv4Addr> {
+ let json_value = request_livedns_gandi(api_key, &format!("domains/{}/records/{}/A", fqdn, name), Method::Get)?;
match &json_value["rrset_values"][0] {
Value::String(ip_str) =>
}
}
-fn update_record_ip() -> Result<()> {
- // TODO.
+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 = request_livedns_gandi(api_key, &format!("domains/{}/records/{}/A", fqdn, name), Method::Put(json_body.to_string()))?;
+
+ println!("Update response: {}", json_value);
+
Ok(())
}