Merge pull request #3 from MiSArch/missing-event-subscriptions

Added missing event subsciptions
MiSArch · Mar 30, 2024 · b94d088 · b94d088
2 parents 3628dd9 + 0380ad5
commit b94d088
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 1 deletion.
diff --git a/src/http_event_service.rs b/src/http_event_service.rs
@@ -106,6 +106,7 @@ pub struct ShipmentStatusUpdatedEventData {
 }
 
 #[derive(Deserialize, Debug)]
+/// Shipment status of order.
 pub enum ShipmentStatus {
     Pending,
     InProgress,
@@ -141,6 +142,11 @@ pub async fn list_topic_subscriptions() -> Result<Json<Vec<Pubsub>>, StatusCode>
         topic: "catalog/product-variant-version/created".to_string(),
         route: "/on-product-variant-version-creation-event".to_string(),
     };
+    let pubsub_product_variant_updated = Pubsub {
+        pubsubname: "pubsub".to_string(),
+        topic: "catalog/product-variant/updated".to_string(),
+        route: "/on-product-variant-updated-event".to_string(),
+    };
     let pubsub_coupon = Pubsub {
         pubsubname: "pubsub".to_string(),
         topic: "discount/coupon/created".to_string(),
@@ -166,13 +172,20 @@ pub async fn list_topic_subscriptions() -> Result<Json<Vec<Pubsub>>, StatusCode>
         topic: "address/user-address/created".to_string(),
         route: "/on-user-address-creation-event".to_string(),
     };
+    let pubsub_user_address_archived = Pubsub {
+        pubsubname: "pubsub".to_string(),
+        topic: "address/user-address/archived".to_string(),
+        route: "/on-user-address-archived-event".to_string(),
+    };
     Ok(Json(vec![
+        pubsub_product_variant_updated,
         pubsub_product_variant_version,
         pubsub_coupon,
         pubsub_tax_rate_version,
         pubsub_shipment_method,
         pubsub_user,
         pubsub_user_address,
+        pubsub_user_address_archived,
     ]))
 }
 

diff --git a/src/main.rs b/src/main.rs
@@ -107,7 +107,7 @@ async fn build_dapr_router(db_client: Database) -> Router {
             post(on_product_variant_version_creation_event),
         )
         .route(
-            "/on-product-variant-update-event",
+            "/on-product-variant-updated-event",
             post(on_product_variant_update_event),
         )
         .route(