chore: remove processing layer references from http lambda

Author: jacobtread

cspell.json

@@ -9,6 +9,7 @@
     "dotenvy",
     "dotenv",
     "onlyoffice",
-    "dtolnay"
+    "dtolnay",
+    "poppler"
   ]
 }

lambdas/http/src/main.rs

@@ -8,10 +8,6 @@ use docbox_core::{
     tenant::tenant_cache::TenantCache,
 };
 use docbox_database::{DatabasePoolCache, DatabasePoolCacheConfig};
-use docbox_processing::{
-    ProcessingLayer, ProcessingLayerConfig,
-    office::{OfficeConverter, OfficeConverterConfig, OfficeProcessingLayer},
-};
 use docbox_search::{SearchIndexFactory, SearchIndexFactoryConfig};
 use docbox_secrets::{SecretManager, SecretsManagerConfig};
 use docbox_storage::{StorageLayerFactory, StorageLayerFactoryConfig};
@@ -52,19 +48,6 @@ async fn app() -> Result<Router, Box<dyn std::error::Error + Send + Sync>> {
         Err(_) => 100 * 1000 * 1024,
     };
 
-    // Create the converter
-    let converter_config = OfficeConverterConfig::from_env();
-    let converter = OfficeConverter::from_config(converter_config)?;
-
-    // Load the config for the processing layer
-    let processing_layer_config = ProcessingLayerConfig::from_env()?;
-
-    // Setup processing layer
-    let processing = ProcessingLayer {
-        office: OfficeProcessingLayer { converter },
-        config: processing_layer_config,
-    };
-
     // Create website scraping service
     let website_meta_service_config = WebsiteMetaServiceConfig::from_env()?;
     let website_meta_service = Arc::new(WebsiteMetaService::from_config(
@@ -116,7 +99,6 @@ async fn app() -> Result<Router, Box<dyn std::error::Error + Send + Sync>> {
         .layer(Extension(db_cache.clone()))
         .layer(Extension(website_meta_service))
         .layer(Extension(events))
-        .layer(Extension(processing))
         .layer(Extension(tenant_cache))
         .layer(Extension(MaxFileSizeBytes(max_file_size_bytes)))
         .layer(TraceLayer::new_for_http());

lambdas/http/src/routes/admin.rs

@@ -2,7 +2,7 @@
 
 use crate::{
     error::{HttpCommonError, HttpErrorResponse, HttpResult, HttpStatusResult},
-    middleware::tenant::{TenantDb, TenantParams, TenantSearch, TenantStorage},
+    middleware::tenant::{TenantDb, TenantParams, TenantSearch},
     models::admin::{TenantDocumentBoxesRequest, TenantDocumentBoxesResponse, TenantStatsResponse},
 };
 use axum::{Extension, Json, http::StatusCode};
@@ -242,26 +242,8 @@ pub async fn search_tenant(
     params(TenantParams)
 )]
 #[tracing::instrument(skip_all)]
-pub async fn reprocess_octet_stream_files_tenant(
-    TenantDb(_db): TenantDb,
-    TenantSearch(_search): TenantSearch,
-    TenantStorage(_storage): TenantStorage,
-    // Extension(processing): Extension<ProcessingLayer>,
-) -> HttpStatusResult {
-    // TODO: This is a heavy and long running operation, should be moved to client side only
-    // docbox_core::files::reprocess_octet_stream_files::reprocess_octet_stream_files(
-    //     &db,
-    //     &search,
-    //     &storage,
-    //     &processing,
-    // )
-    // .await
-    // .map_err(|error| {
-    //     tracing::error!(?error, "failed to reprocess octet-stream files");
-    //     HttpCommonError::ServerError
-    // })?;
-
-    Ok(StatusCode::NO_CONTENT)
+pub async fn reprocess_octet_stream_files_tenant() -> HttpStatusResult {
+    Err(HttpCommonError::Unsupported.into())
 }
 
 /// Rebuild search index
@@ -280,19 +262,8 @@ pub async fn reprocess_octet_stream_files_tenant(
     params(TenantParams)
 )]
 #[tracing::instrument(skip_all)]
-pub async fn rebuild_search_index_tenant(// TenantDb(db): TenantDb,
-    // TenantSearch(search): TenantSearch,
-    // TenantStorage(storage): TenantStorage,
-) -> HttpStatusResult {
-    // TODO: This is a heavy and long running operation, should be moved to client side only
-    // docbox_core::tenant::rebuild_tenant_index::rebuild_tenant_index(&db, &search, &storage)
-    //     .await
-    //     .map_err(|error| {
-    //         tracing::error!(?error, "failed to rebuilt tenant search index");
-    //         HttpCommonError::ServerError
-    //     })?;
-
-    Ok(StatusCode::NO_CONTENT)
+pub async fn rebuild_search_index_tenant() -> HttpStatusResult {
+    Err(HttpCommonError::Unsupported.into())
 }
 
 /// Flush database cache