multipart wip

src/rabbitmq/publisher.rs

@@ -0,0 +1,60 @@
+use lapin::{
+    options::*, publisher_confirm::Confirmation, BasicProperties,    
+};
+use crate::models::ingress::IngressContent;
+
+use super::{RabbitMQCommon, RabbitMQConfig, RabbitMQError};
+use tracing::{info, error};
+
+pub struct RabbitMQProducer {
+    common: RabbitMQCommon,
+    exchange_name: String,
+    routing_key: String,
+}
+
+impl RabbitMQProducer {
+    pub async fn new(config: &RabbitMQConfig) -> Result<Self, RabbitMQError> {
+        let common = RabbitMQCommon::new(config).await?;
+        common.declare_exchange(config, false).await?;
+        
+        Ok(Self { 
+            common,
+            exchange_name: config.exchange.clone(),
+            routing_key: config.routing_key.clone(),
+        })
+    }
+
+    /// Publishes an IngressContent object to RabbitMQ after serializing it to JSON.
+    pub async fn publish(&self, ingress: &IngressContent) -> Result<Confirmation, RabbitMQError> {
+        // Serialize IngressContent to JSON
+        let payload = serde_json::to_vec(ingress)
+            .map_err(|e| {
+                error!("Serialization Error: {}", e);
+                RabbitMQError::PublishError(format!("Serialization Error: {}", e))
+            })?;
+        
+        // Publish the serialized payload to RabbitMQ
+        let confirmation = self.common.channel
+            .basic_publish(
+                &self.exchange_name,
+                &self.routing_key,
+                BasicPublishOptions::default(),
+                &payload,
+                BasicProperties::default(),
+            )
+            .await
+            .map_err(|e| {
+                error!("Publish Error: {}", e);
+                RabbitMQError::PublishError(format!("Publish Error: {}", e))
+            })?
+            .await
+            .map_err(|e| {
+                error!("Publish Confirmation Error: {}", e);
+                RabbitMQError::PublishError(format!("Publish Confirmation Error: {}", e))
+            })?;
+        
+        info!("Published message to exchange '{}' with routing key '{}'", self.exchange_name, self.routing_key);
+        
+        Ok(confirmation)
+    }
+}