chore(cat-gateway): Remove POST /v1/document and related components (#3264)

* chore: removing post document v1

* chore: minor doc

* chore: minor

* chore: bump api version

Author: apskhem

catalyst-gateway/bin/src/db/event/signed_docs/full_signed_doc.rs

@@ -1,10 +1,8 @@
 //! `FullSignedDoc` struct implementation.
 
-use futures::{Stream, StreamExt};
-
 use super::SignedDocBody;
 use crate::{
-    db::event::{common::query_limits::QueryLimits, signed_docs::DocsQueryFilter, EventDB},
+    db::event::EventDB,
     jinja::{get_template, JinjaTemplateSource},
 };
 
@@ -17,13 +15,6 @@ pub(crate) const SELECT_SIGNED_DOCS_TEMPLATE: JinjaTemplateSource = JinjaTemplat
     source: include_str!("./sql/select_signed_documents.sql.jinja"),
 };
 
-/// Filtered select sql query jinja template
-pub(crate) const FILTERED_SELECT_FULL_SIGNED_DOCS_TEMPLATE: JinjaTemplateSource =
-    JinjaTemplateSource {
-        name: "filtered_select_full_signed_documents.sql.jinja.template",
-        source: include_str!("./sql/filtered_select_full_signed_documents.sql.jinja"),
-    };
-
 /// `FullSignedDoc::store` method error.
 #[derive(thiserror::Error, Debug)]
 #[error("Document with the same `id` and `ver` already exists")]
@@ -61,6 +52,7 @@ impl FullSignedDoc {
     }
 
     /// Returns the document metadata.
+    #[allow(dead_code)]
     pub(crate) fn metadata(&self) -> Option<&serde_json::Value> {
         self.body.metadata()
     }
@@ -139,29 +131,6 @@ impl FullSignedDoc {
         Self::from_row(id, ver, &row)
     }
 
-    /// Loads a async stream of `FullSignedDoc` from the event db based on the given
-    /// `conditions`.
-    pub(crate) async fn retrieve_conditions(
-        conditions: &DocsQueryFilter,
-        query_limits: &QueryLimits,
-    ) -> anyhow::Result<impl Stream<Item = anyhow::Result<Self>>> {
-        let query_template = get_template(&FILTERED_SELECT_FULL_SIGNED_DOCS_TEMPLATE)?;
-        let query = query_template.render(serde_json::json!({
-            "conditions": conditions.to_string(),
-            "query_limits": query_limits.to_string(),
-        }))?;
-        let rows = EventDB::query_stream(&query, &[]).await?;
-        let docs = rows.map(|res_row| {
-            res_row.and_then(|row| {
-                let id = row.try_get("id")?;
-                let ver = row.try_get("ver")?;
-
-                FullSignedDoc::from_row(&id, Some(&ver), &row)
-            })
-        });
-        Ok(docs)
-    }
-
     /// Returns all signed document fields for the event db queries
     fn postgres_db_fields(&self) -> [&(dyn tokio_postgres::types::ToSql + Sync); 7] {
         let body_fields = self.body.postgres_db_fields();

catalyst-gateway/bin/src/db/event/signed_docs/mod.rs

@@ -8,10 +8,7 @@ mod signed_doc_body;
 mod tests;
 
 pub(crate) use doc_ref::DocumentRef;
-pub(crate) use full_signed_doc::{
-    FullSignedDoc, StoreError, FILTERED_SELECT_FULL_SIGNED_DOCS_TEMPLATE,
-    SELECT_SIGNED_DOCS_TEMPLATE,
-};
+pub(crate) use full_signed_doc::{FullSignedDoc, StoreError, SELECT_SIGNED_DOCS_TEMPLATE};
 pub(crate) use query_filter::DocsQueryFilter;
 pub(crate) use signed_doc_body::{
     SignedDocBody, FILTERED_COUNT_SIGNED_DOCS_TEMPLATE, FILTERED_SELECT_SIGNED_DOCS_TEMPLATE,

catalyst-gateway/bin/src/db/event/signed_docs/sql/filtered_select_full_signed_documents.sql.jinja

@@ -5,8 +5,8 @@ use std::sync::LazyLock;
 use minijinja::{Environment, Template};
 
 use crate::db::event::signed_docs::{
-    FILTERED_COUNT_SIGNED_DOCS_TEMPLATE, FILTERED_SELECT_FULL_SIGNED_DOCS_TEMPLATE,
-    FILTERED_SELECT_SIGNED_DOCS_TEMPLATE, SELECT_SIGNED_DOCS_TEMPLATE,
+    FILTERED_COUNT_SIGNED_DOCS_TEMPLATE, FILTERED_SELECT_SIGNED_DOCS_TEMPLATE,
+    SELECT_SIGNED_DOCS_TEMPLATE,
 };
 
 /// Jinja template source struct.
@@ -33,11 +33,6 @@ static JINJA_ENV: LazyLock<Environment> = LazyLock::new(|| {
         FILTERED_SELECT_SIGNED_DOCS_TEMPLATE.source,
     )
     .unwrap();
-    env.add_template(
-        FILTERED_SELECT_FULL_SIGNED_DOCS_TEMPLATE.name,
-        FILTERED_SELECT_FULL_SIGNED_DOCS_TEMPLATE.source,
-    )
-    .unwrap();
     env.add_template(
         FILTERED_COUNT_SIGNED_DOCS_TEMPLATE.name,
         FILTERED_COUNT_SIGNED_DOCS_TEMPLATE.source,

catalyst-gateway/bin/src/jinja.rs

@@ -90,30 +90,6 @@ impl DocumentApi {
         }
     }
 
-    /// Post A Signed Document Index Query.
-    ///
-    /// This endpoint produces a summary of signed documents that meet the criteria
-    /// defined in the request body.
-    ///
-    /// It does not return the actual documents, just an index of the document identifiers
-    /// which allows the documents to be retrieved by the `GET document` endpoint.
-    #[oai(
-        path = "/v1/document/index",
-        method = "post",
-        operation_id = "postDocument"
-    )]
-    async fn post_document_v1(
-        &self,
-        /// The Query Filter Specification
-        query: Json<post_document_index_query::v1::request::DocumentIndexQueryFilterBody>,
-        page: Query<Option<Page>>,
-        limit: Query<Option<Limit>>,
-        /// No Authorization required, but Token permitted.
-        _auth: NoneOrRBAC,
-    ) -> post_document_index_query::v1::AllResponses {
-        post_document_index_query::v1::endpoint(query.0 .0, page.0, limit.0).await
-    }
-
     /// Post A Signed Document Index Query for Newer Versions of v0.04.
     ///
     /// Produces a summary of signed documents that meet the criteria

catalyst-gateway/bin/src/service/api/documents/mod.rs

@@ -1,4 +1,3 @@
 //! Document Index Query Implementation
 
-pub(crate) mod v1;
 pub(crate) mod v2;