95 lines
3.5 KiB
Rust
95 lines
3.5 KiB
Rust
/*
|
|
* LIST OF ROUTES
|
|
* /domain/register (add a new domain and get back the TSIG key for subsequent updating with nsupdate)
|
|
* /domain/check-available (check if given domain is available)
|
|
* /user/register sends an email verification to create a new account) NOT IMPLEMENTED
|
|
* /user/verify (for clicking the link in the email) NOT IMPLEMENTED
|
|
*/
|
|
use crate::generate_zone::{check_domain_available, generate_zone, validate_domain};
|
|
use rocket_contrib::json::{Json, JsonValue};
|
|
use serde::{Deserialize, Serialize};
|
|
|
|
#[get("/")]
|
|
pub fn index() -> &'static str {
|
|
"This is the peach-dyndns server."
|
|
}
|
|
|
|
#[derive(Serialize)]
|
|
pub struct JsonResponse {
|
|
pub status: String,
|
|
#[serde(skip_serializing_if = "Option::is_none")]
|
|
pub data: Option<JsonValue>,
|
|
#[serde(skip_serializing_if = "Option::is_none")]
|
|
pub msg: Option<String>,
|
|
}
|
|
|
|
// helper function to build a JsonResponse object
|
|
pub fn build_json_response(
|
|
status: String,
|
|
data: Option<JsonValue>,
|
|
msg: Option<String>,
|
|
) -> JsonResponse {
|
|
JsonResponse { status, data, msg }
|
|
}
|
|
|
|
#[derive(Deserialize, Debug)]
|
|
pub struct RegisterDomainPost {
|
|
domain: String,
|
|
}
|
|
|
|
#[post("/domain/register", data = "<data>")]
|
|
pub async fn register_domain(data: Json<RegisterDomainPost>) -> Json<JsonResponse> {
|
|
info!("++ post request to register new domain: {:?}", data);
|
|
// TODO: grab/create a mutex, so that only one rocket thread is calling register_domain at a time
|
|
// check if its a valid domain
|
|
if !validate_domain(&data.domain) {
|
|
let status = "error".to_string();
|
|
let msg = "domain is not in a valid format".to_string();
|
|
Json(build_json_response(status, None, Some(msg)))
|
|
} else {
|
|
// check if the domain is available
|
|
let is_domain_available = check_domain_available(&data.domain);
|
|
if !is_domain_available {
|
|
let status = "error".to_string();
|
|
let msg = "can't register a domain that is already registered".to_string();
|
|
Json(build_json_response(status, None, Some(msg)))
|
|
} else {
|
|
// generate configs for the zone
|
|
let result = generate_zone(&data.domain);
|
|
match result {
|
|
Ok(key_file_text) => {
|
|
let status = "success".to_string();
|
|
let msg = key_file_text.to_string();
|
|
Json(build_json_response(status, None, Some(msg)))
|
|
}
|
|
Err(_err) => {
|
|
let status = "error".to_string();
|
|
let msg = "there was an error creating the zone file".to_string();
|
|
Json(build_json_response(status, None, Some(msg)))
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
#[derive(Deserialize, Debug)]
|
|
pub struct CheckAvailableDomainPost {
|
|
domain: String,
|
|
}
|
|
|
|
// route which returns a msg of "true" if the domain is available and "false" if it is already taken
|
|
#[post("/domain/check-available", data = "<data>")]
|
|
pub async fn check_available(data: Json<CheckAvailableDomainPost>) -> Json<JsonResponse> {
|
|
info!("post request to check if domain is available {:?}", data);
|
|
if !validate_domain(&data.domain) {
|
|
let status = "error".to_string();
|
|
let msg = "domain is not in a valid format".to_string();
|
|
Json(build_json_response(status, None, Some(msg)))
|
|
} else {
|
|
let status = "success".to_string();
|
|
let is_available = check_domain_available(&data.domain);
|
|
let msg = is_available.to_string();
|
|
Json(build_json_response(status, None, Some(msg)))
|
|
}
|
|
}
|