diff --git a/src/http_event_service.rs b/src/http_event_service.rs index d99f5d2..d069467 100644 --- 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>, 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>, 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 index bbb31b6..8674800 100644 --- 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(