feat: change endpoint to config/versions

crates/context_aware_config/src/api.rs

@@ -1,6 +1,5 @@
 pub mod audit_log;
 pub mod config;
-pub mod config_versions;
 pub mod context;
 pub mod default_config;
 pub mod dimension;

crates/context_aware_config/src/api/config/handlers.rs

@@ -8,12 +8,13 @@ use crate::api::context::{
     delete_context_api, hash, put, validate_dimensions_and_calculate_priority, PutReq,
 };
 use crate::api::dimension::get_all_dimension_schema_map;
+use crate::db::models::ConfigVersion;
 use crate::{
     db::schema::{config_versions::dsl as config_versions, event_log::dsl as event_log},
     helpers::generate_cac,
 };
 use actix_http::header::HeaderValue;
-use actix_web::web::Data;
+use actix_web::web::{Data, Json, Query};
 use actix_web::{get, put, web, HttpRequest, HttpResponse, HttpResponseBuilder, Scope};
 use cac_client::{eval_cac, eval_cac_with_reasoning, MergeStrategy};
 use chrono::{DateTime, NaiveDateTime, TimeZone, Timelike, Utc};
@@ -25,7 +26,10 @@ use diesel::{
 use serde_json::{json, Map, Value};
 use service_utils::service::types::{AppState, Tenant};
 use superposition_macros::{bad_argument, db_error, unexpected_error};
-use superposition_types::{result as superposition, Cac, Condition, Overrides, User};
+use superposition_types::{
+    result as superposition, Cac, Condition, Overrides, PaginatedResponse, QueryFilters,
+    User,
+};
 
 use itertools::Itertools;
 use jsonschema::JSONSchema;
@@ -40,6 +44,7 @@ pub fn endpoints() -> Scope {
         .service(get)
         .service(get_resolved_config)
         .service(reduce_config)
+        .service(get_config_versions)
 }
 
 fn validate_version_in_params(
@@ -656,3 +661,33 @@ async fn get_resolved_config(
 
     Ok(resp.json(response))
 }
+
+#[get("/versions")]
+async fn get_config_versions(
+    db_conn: DbConnection,
+    filters: Query<QueryFilters>,
+) -> superposition::Result<Json<PaginatedResponse<ConfigVersion>>> {
+    let DbConnection(mut conn) = db_conn;
+
+    let n_version: i64 = config_versions::config_versions
+        .count()
+        .get_result(&mut conn)?;
+    let mut builder = config_versions::config_versions
+        .into_boxed()
+        .order(config_versions::created_at.desc());
+    if let Some(limit) = filters.count {
+        builder = builder.limit(limit);
+    }
+    if let Some(page) = filters.page {
+        let offset = (page - 1) * filters.count.unwrap_or(10);
+        builder = builder.offset(offset);
+    }
+    let limit = filters.count.unwrap_or(10);
+    let config_versions: Vec<ConfigVersion> = builder.load(&mut conn)?;
+    let total_pages = (n_version as f64 / limit as f64).ceil() as i64;
+    Ok(Json(PaginatedResponse {
+        total_pages,
+        total_items: n_version,
+        data: config_versions,
+    }))
+}

crates/context_aware_config/src/lib.rs

@@ -3,5 +3,4 @@ pub mod api;
 pub mod db;
 pub mod helpers;
 pub mod middlewares;
-pub mod types;
 pub mod validation_functions;

crates/superposition/src/main.rs

@@ -250,11 +250,6 @@ async fn main() -> Result<()> {
                             .wrap(AppExecutionScopeMiddlewareFactory::new(AppScope::CAC))
                             .service(type_templates::endpoints()),
                     )
-                    .service(
-                        scope("/config-versions")
-                            .wrap(AppExecutionScopeMiddlewareFactory::new(AppScope::CAC))
-                            .service(config_versions::endpoints()),
-                    )
                     .service(
                         experiments::endpoints(scope("/experiments")).wrap(
                             AppExecutionScopeMiddlewareFactory::new(AppScope::EXPERIMENTATION),

crates/superposition_types/src/lib.rs

@@ -9,7 +9,7 @@ use actix_web::{dev::Payload, error, FromRequest, HttpMessage, HttpRequest};
 use derive_more::{AsRef, Deref, DerefMut, Into};
 use log::error;
 use regex::Regex;
-use serde::{Deserialize, Deserializer, Serialize};
+use serde::{de, Deserialize, Deserializer, Serialize};
 use serde_json::{json, Map, Value};
 
 #[derive(Debug, Clone)]
@@ -419,3 +419,48 @@ mod tests {
         );
     }
 }
+
+#[derive(Debug, Clone)]
+pub struct QueryFilters {
+    pub count: Option<i64>,
+    pub page: Option<i64>,
+}
+
+impl<'de> Deserialize<'de> for QueryFilters {
+    fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
+    where
+        D: Deserializer<'de>,
+    {
+        #[derive(Deserialize)]
+        struct Helper {
+            count: Option<i64>,
+            page: Option<i64>,
+        }
+
+        let helper = Helper::deserialize(deserializer)?;
+
+        if let Some(count) = helper.count {
+            if count <= 0 {
+                return Err(de::Error::custom("Count should be greater than 0."));
+            }
+        }
+
+        if let Some(page) = helper.page {
+            if page <= 0 {
+                return Err(de::Error::custom("Page should be greater than 0."));
+            }
+        }
+
+        Ok(QueryFilters {
+            count: helper.count,
+            page: helper.page,
+        })
+    }
+}
+
+#[derive(Serialize, Debug, Clone, Deserialize)]
+pub struct PaginatedResponse<T> {
+    pub total_pages: i64,
+    pub total_items: i64,
+    pub data: Vec<T>,
+}