Introduce basic service endpoint

src/http.rs

@@ -14,6 +14,7 @@ pub async fn serve(state: GlobalState) {
     let app = Router::new()
         .route("/", get(root))
         .route("/gateway", post(crate::gateway::endpoint::route))
+        .route("/update", post(crate::selfservice::endpoint::route))
         .with_state(Arc::new(state))
         .layer(CorsLayer::very_permissive());
 

src/main.rs

@@ -4,12 +4,13 @@ use dotenvy::dotenv;
 use ethers::signers::{LocalWallet, Signer};
 use tracing::info;
 
-pub mod ccip;
-pub mod database;
-pub mod gateway;
 mod http;
+pub mod ccip;
 pub mod state;
 pub mod utils;
+pub mod gateway;
+pub mod database;
+pub mod selfservice;
 
 #[tokio::main]
 async fn main() {

src/selfservice/endpoint.rs

@@ -0,0 +1,44 @@
+use std::{collections::HashMap, sync::Arc};
+
+use axum::{
+    extract::{Path, State},
+    response::IntoResponse,
+    Json,
+};
+use ethers::providers::namehash;
+use tracing::info;
+
+use crate::state::GlobalState;
+use serde::{Deserialize, Serialize};
+
+#[derive(Debug, Serialize, Deserialize)]
+pub struct UpdateNamePayload {
+    name: String,
+    records: HashMap<String, Option<String>>,
+    addresses: HashMap<String, Option<String>>,
+    // Arbitrary auth payload
+    auth: String,
+}
+
+pub async fn route(
+    State(state): State<Arc<GlobalState>>,
+    Json(payload): Json<UpdateNamePayload>,
+) -> impl IntoResponse {
+    info!("Update name: {:?}", payload);
+
+    if payload.auth != "yes" {
+        return "auth error";
+    }
+
+    let hash = namehash(&payload.name);
+
+    state
+        .db
+        .upsert(&hash.to_fixed_bytes().to_vec(), &payload.records, &payload.addresses)
+        .await;
+
+    // handle(request_payload, state)
+    //     .await
+    //     .map_err(|x| x.into_response())
+    "ok"
+}

src/selfservice/mod.rs

@@ -0,0 +1 @@
+pub mod endpoint;