Merge pull request #8 from redbadger/rust-wasmcloud

Wasm Components in wasmCloud

.github/workflows/java-containers-k8s.yml

@@ -8,13 +8,15 @@ on:
       - "java-containers-k8s/**"
 
   pull_request:
+    types: [opened, synchronize, reopened, ready_for_review]
     branches:
       - "main"
     paths:
       - "java-containers-k8s/**"
 
 jobs:
   build-and-push:
+    if: github.event.pull_request.draft == false
     name: Build, push and deploy 🏗️🚀
     runs-on: ubuntu-latest
     defaults:

.github/workflows/rust-containers-k8s.yml

@@ -8,13 +8,15 @@ on:
       - "rust-containers-k8s/**"
 
   pull_request:
+    types: [opened, synchronize, reopened, ready_for_review]
     branches:
       - "main"
     paths:
       - "rust-containers-k8s/**"
 
 jobs:
   build-and-push:
+    if: github.event.pull_request.draft == false
     name: Build, push and deploy 🏗️🚀
     runs-on: ubuntu-latest
     defaults:

.gitignore

@@ -1 +1,6 @@
 .env
+build/
+target/
+keys/
+**/wit/deps/*
+sentinel

.vscode/settings.json

@@ -5,7 +5,11 @@
     "rust-containers-k8s/inventory-service/Cargo.toml",
     "rust-containers-k8s/notification-service/Cargo.toml",
     "rust-containers-k8s/order-service/Cargo.toml",
-    "rust-containers-k8s/product-service/Cargo.toml"
+    "rust-containers-k8s/product-service/Cargo.toml",
+    "rust-wasmcloud/products/Cargo.toml",
+    "rust-wasmcloud/inventory/Cargo.toml",
+    "rust-wasmcloud/products-http/Cargo.toml",
+    "rust-wasmcloud/platform-wasmcloud/Cargo.toml"
   ],
   "sqltools.connections": [
     {

java-containers-k8s/order-service/src/main/java/com/redbadger/orderservice/service/OrderService.java

@@ -52,7 +52,7 @@ public String placeOrder(OrderRequest orderRequest) {
 
         // Call Inventory Service, and place order if product is in
         // stock
-        InventoryResponse[] inventoryResponsArray = webClientBuilder
+        InventoryResponse[] inventoryResponseArray = webClientBuilder
                 .build()
                 .get()
                 .uri("http://inventory-service/api/inventory", uriBuilder -> uriBuilder.queryParam("skuCode", skuCodes)
@@ -61,8 +61,8 @@ public String placeOrder(OrderRequest orderRequest) {
                 .bodyToMono(InventoryResponse[].class)
                 .block();
 
-        boolean allProductsInStock = Arrays.stream(inventoryResponsArray)
-                                           .allMatch(InventoryResponse::isInStock) && inventoryResponsArray.length > 0;
+        boolean allProductsInStock = Arrays.stream(inventoryResponseArray)
+                                           .allMatch(InventoryResponse::isInStock) && inventoryResponseArray.length > 0;
 
         if (allProductsInStock) {
             log.info("All requested products are in stock");

rust-containers-k8s/notification-service/src/core.rs

@@ -0,0 +1,33 @@
+use serde::{Deserialize, Serialize};
+use uuid::Uuid;
+
+#[derive(Debug, Deserialize, Serialize)]
+#[serde(rename_all = "camelCase")]
+
+pub struct OrderPlacedEvent {
+    pub order_number: Uuid,
+}
+
+pub trait Logger {
+    fn info(&self, msg: &str);
+}
+
+pub struct Service<Logger> {
+    pub logger: Logger,
+}
+
+impl<L> Service<L>
+where
+    L: Logger,
+{
+    pub fn new(logger: L) -> Self {
+        Self { logger }
+    }
+
+    pub fn recv(&self, event: OrderPlacedEvent) {
+        self.logger.info(&format!(
+            "Received Notification for Order - {}",
+            event.order_number
+        ));
+    }
+}

rust-containers-k8s/notification-service/src/lib.rs

@@ -1,2 +1,2 @@
 pub mod config;
-pub mod types;
+pub mod core;

rust-containers-k8s/notification-service/src/main.rs

@@ -1,6 +1,9 @@
 use backoff::{retry, ExponentialBackoff};
 use dotenv::dotenv;
-use notification_service::{config::Config, types::OrderPlacedEvent};
+use notification_service::{
+    config::Config,
+    core::{Logger, OrderPlacedEvent, Service},
+};
 use rdkafka::{
     admin::{AdminClient, AdminOptions, NewTopic, TopicReplication},
     client::DefaultClientContext,
@@ -13,6 +16,14 @@ use std::time::Duration;
 use tracing::info;
 use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
 
+struct TracingLogger;
+
+impl Logger for TracingLogger {
+    fn info(&self, msg: &str) {
+        info!("{}", msg);
+    }
+}
+
 #[tokio::main]
 async fn main() -> anyhow::Result<()> {
     tracing_subscriber::registry()
@@ -53,6 +64,8 @@ async fn main() -> anyhow::Result<()> {
     let consumer = create_consumer(&kafka)?;
     consumer.subscribe(&[&config.kafka_topic])?;
 
+    let service = Service::new(TracingLogger);
+
     loop {
         let message = consumer.recv().await?;
         let payload = message.payload();
@@ -61,7 +74,7 @@ async fn main() -> anyhow::Result<()> {
         };
 
         if let Ok(order) = serde_json::from_slice::<OrderPlacedEvent>(message) {
-            info!("Received Notification for Order - {}", order.order_number);
+            service.recv(order);
         } else {
             info!(
                 "Error decoding notification order: {:?}",