snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2024-11-23 10:37:41 +08:00
Code Issues Actions 8 Packages Projects Releases Wiki Activity

update stats routes

Browse Source
This commit is contained in:
marin postma 2021-06-24 15:54:51 +02:00
parent 549b489c8a
commit 561596d8bc
No known key found for this signature in database
GPG Key ID: 6088B7721C3E39F9
1 changed files with 8 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
meilisearch-http/src/routes/stats.rs
View File

@ -1,23 +1,20 @@
use actix_web::get;
use actix_web::web;
use actix_web::HttpResponse;
use log::debug; use log::debug;
use actix_web::{web, HttpResponse};
use serde::Serialize; use serde::Serialize;
use crate::error::ResponseError; use crate::error::ResponseError;
use crate::helpers::Authentication; use crate::extractors::authentication::{GuardedData, policies::*};
use crate::routes::IndexParam; use crate::routes::IndexParam;
use crate::Data; use crate::Data;
pub fn services(cfg: &mut web::ServiceConfig) { pub fn services(cfg: &mut web::ServiceConfig) {
cfg.service(get_index_stats) cfg.route("/indexes/{index_uid}/stats", web::get().to(get_index_stats))
.service(get_stats) .route("/stats", web::get().to(get_stats))
.service(get_version); .route("/version", web::get().to(get_version));
} }
#[get("/indexes/{index_uid}/stats", wrap = "Authentication::Private")]
async fn get_index_stats( async fn get_index_stats(
data: web::Data<Data>, data: GuardedData<Private, Data>,
path: web::Path<IndexParam>, path: web::Path<IndexParam>,
) -> Result<HttpResponse, ResponseError> { ) -> Result<HttpResponse, ResponseError> {
let response = data.get_index_stats(path.index_uid.clone()).await?; let response = data.get_index_stats(path.index_uid.clone()).await?;
@ -26,8 +23,7 @@ async fn get_index_stats(
Ok(HttpResponse::Ok().json(response)) Ok(HttpResponse::Ok().json(response))
} }
#[get("/stats", wrap = "Authentication::Private")] async fn get_stats(data: GuardedData<Private, Data>) -> Result<HttpResponse, ResponseError> {
async fn get_stats(data: web::Data<Data>) -> Result<HttpResponse, ResponseError> {
let response = data.get_all_stats().await?; let response = data.get_all_stats().await?;
debug!("returns: {:?}", response); debug!("returns: {:?}", response);
@ -42,8 +38,7 @@ struct VersionResponse {
pkg_version: String, pkg_version: String,
} }
#[get("/version", wrap = "Authentication::Private")] async fn get_version(_data: GuardedData<Private, Data>) -> HttpResponse {
async fn get_version() -> HttpResponse {
let commit_sha = match option_env!("COMMIT_SHA") { let commit_sha = match option_env!("COMMIT_SHA") {
Some("") | None => env!("VERGEN_SHA"), Some("") | None => env!("VERGEN_SHA"),
Some(commit_sha) => commit_sha, Some(commit_sha) => commit_sha,