working ratatui frontend

src/server/mod.rs

@@ -1,49 +1,35 @@
 // src/server/mod.rs
 use tonic::{Request, Response, Status};
 use crate::db;
+use crate::adresar::handlers::create_adresar;
 use crate::proto::multieko2::{
-    data_processor_server::{DataProcessor, DataProcessorServer},
-    DataRequest, DataResponse
+    AdresarRequest, AdresarResponse,
+    adresar_server::{Adresar, AdresarServer},
 };
 
-pub struct DataProcessorService {
+pub struct AdresarService {
     db_pool: sqlx::PgPool,
 }
 
 #[tonic::async_trait]
-impl DataProcessor for DataProcessorService {
-    async fn process_data(
+impl Adresar for AdresarService {
+    async fn create_adresar(
         &self,
-        request: Request<DataRequest>,
-    ) -> Result<Response<DataResponse>, Status> {
-        let data = request.into_inner().data;
-        
-        // Store data in database
-        let stored_data = sqlx::query!(
-            "INSERT INTO processed_data (content) VALUES ($1) RETURNING id",
-            data
-        )
-        .fetch_one(&self.db_pool)
-        .await
-        .map_err(|e| Status::internal(e.to_string()))?;
-
-        // Simple processing: convert to uppercase
-        let processed_data = data.to_uppercase();
-        
-        Ok(Response::new(DataResponse {
-            processed_data: format!("Processed data with ID: {}", stored_data.id)
-        }))
+        request: Request<AdresarRequest>,
+    ) -> Result<Response<AdresarResponse>, Status> {
+        let response = create_adresar(&self.db_pool, request.into_inner()).await?;
+        Ok(Response::new(response))
     }
 }
 
 pub async fn run_server(db_pool: sqlx::PgPool) -> Result<(), Box<dyn std::error::Error>> {
     let addr = "[::1]:50051".parse()?;
-    let service = DataProcessorService { db_pool };
+    let adresar_service = AdresarService { db_pool: db_pool.clone() };
 
     println!("Server listening on {}", addr);
 
     tonic::transport::Server::builder()
-        .add_service(DataProcessorServer::new(service))
+        .add_service(AdresarServer::new(adresar_service))
         .serve(addr)
         .await?;