Bogdan-Ștefan Neacşu
29f95febe9
* Include ephemera node code in repo * Upgrade deps * Bump minor version of cosmwasm-std * Include ephemera in nym-api dep and downgrade rusqlite * Fix clippy and ephemera docs code * More clippy on ephemera --------- Co-authored-by: Andrus Salumets <andrus@nymtech.net>
89 lines
3.0 KiB
Rust
89 lines
3.0 KiB
Rust
use actix_web::{post, web, HttpResponse};
|
|
use log::{debug, error};
|
|
|
|
use crate::api::types::ApiVerifyMessageInBlock;
|
|
use crate::api::{
|
|
types::{ApiDhtStoreRequest, ApiEphemeraMessage},
|
|
ApiError, CommandExecutor,
|
|
};
|
|
|
|
#[utoipa::path(
|
|
request_body = ApiEphemeraMessage,
|
|
responses(
|
|
(status = 200, description = "Send a message to an Ephemera node which will be broadcast to the network"),
|
|
(status = 500, description = "Server failed to process request")),
|
|
params(("message", description = "Message to send"))
|
|
)]
|
|
#[post("/ephemera/broadcast/submit_message")]
|
|
pub(crate) async fn submit_message(
|
|
message: web::Json<ApiEphemeraMessage>,
|
|
api: web::Data<CommandExecutor>,
|
|
) -> HttpResponse {
|
|
match api.send_ephemera_message(message.into_inner()).await {
|
|
Ok(_) => HttpResponse::Ok().json("Message submitted"),
|
|
Err(err) => {
|
|
if let ApiError::DuplicateMessage = err {
|
|
debug!("Message already submitted {err:?}");
|
|
HttpResponse::BadRequest().json("Message already submitted")
|
|
} else {
|
|
error!("Error submitting message: {}", err);
|
|
HttpResponse::InternalServerError().json("Server failed to process request")
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
#[utoipa::path(
|
|
request_body = ApiDhtStoreRequest,
|
|
responses(
|
|
(status = 200, description = "Request to store a value in the DHT"),
|
|
(status = 500, description = "Server failed to process request")),
|
|
params(
|
|
("request", description = "Dht store request")
|
|
)
|
|
)]
|
|
#[post("/ephemera/dht/store")]
|
|
pub(crate) async fn store_in_dht(
|
|
request: web::Json<ApiDhtStoreRequest>,
|
|
api: web::Data<CommandExecutor>,
|
|
) -> HttpResponse {
|
|
let request = request.into_inner();
|
|
|
|
let key = request.key();
|
|
let value = request.value();
|
|
|
|
match api.store_in_dht(key, value).await {
|
|
Ok(_) => HttpResponse::Ok().json("Store request submitted"),
|
|
Err(err) => {
|
|
error!("Error storing in dht: {}", err);
|
|
HttpResponse::InternalServerError().json("Server failed to process request")
|
|
}
|
|
}
|
|
}
|
|
|
|
#[utoipa::path(
|
|
request_body = ApiVerifyMessageInBlock,
|
|
responses(
|
|
(status = 200, description = "Verifies if given message is in block identified by block hash.\
|
|
Returns true if message is in block, false otherwise. False can also mean that block or message \
|
|
does not exist in that block."),
|
|
(status = 500, description = "Server failed to process request")),
|
|
params(
|
|
("request", description = "Verify message request")
|
|
)
|
|
)]
|
|
#[post("/ephemera/messages/verify")]
|
|
pub(crate) async fn verify_message_in_block(
|
|
request: web::Json<ApiVerifyMessageInBlock>,
|
|
api: web::Data<CommandExecutor>,
|
|
) -> HttpResponse {
|
|
let request = request.into_inner();
|
|
match api.verify_message_in_block(request).await {
|
|
Ok(valid) => HttpResponse::Ok().json(valid),
|
|
Err(err) => {
|
|
error!("Error verifying message: {}", err);
|
|
HttpResponse::InternalServerError().json("Server failed to process request")
|
|
}
|
|
}
|
|
}
|