CoffeeShop on Spin with Dapr

[thangchung]

Refs: https://www.thorsten-hans.com/how-to-blog-backends-with-spin-and-fermyon-cloud/

#[http_component]
fn handle_blog_apis_rust(req: Request) -> Result<Response> {
  let mut router = spin_sdk::http::Router::default();
  router.post("/contact", requests::process_contact_request);
  router.post("/sponsor", requests::process_sponsor_request);
  router.post("/subscriptions", newsletter::subscribe);
  router.get("/search", search::search);
  router.add("/...", http::Method::OPTIONS, cors::process_preflight);
  router.handle(req)
}

pub(crate) fn search(req: Request, _params: Params) -> Result<Response>{
  println!("[SEARCH]: Endpoint invoked");
  let Some(search_term) = get_query_string_parameter(req.uri(), "query") else {
    println!("[Error]: Could not find search term");
    return Ok(http::Response::builder()
      .status(http::StatusCode::BAD_REQUEST)
      .body(None)?);
  };
  println!("[SEARCH]: Endpoint invoked with '{}'", &search_term);

  let Ok(search_url) = config::get(CFG_NAME_SEARCH_URL) else {
    println!("[Error]: Could not find Azure Search Service URL");
    return Ok(http::Response::builder()
      .status(http::StatusCode::INTERNAL_SERVER_ERROR)
      .body(None)?);
  };

  let Ok(search_api_key) = config::get(CFG_NAME_SEARCH_API_TOKEN) else {
    println!("[Error]: Could not find Azure Search API Key");
    return Ok(http::Response::builder()
      .status(http::StatusCode::INTERNAL_SERVER_ERROR)
      .body(None)?);
  };

  let query_string = build_azure_search_query_string(search_term.as_str());

  let req = http::Request::builder()
    .method(http::Method::GET)
    .header(http::header::ACCEPT, "application/json")
    .header(http::header::CONTENT_TYPE, "application/json")
    .header("api-key", search_api_key)
    .uri(format!("{}{}", search_url, query_string))
    .body(None)?;

  match spin_sdk::outbound_http::send_request(req) {
    Ok(r) => {
      println!("[SEARCH]: Will respond with search results");
      Ok(builder_with_cors(r.status())
      .body(r.body().clone())?)
    },
    Err(e) => {
      println!("[Error]: Did not receive successful response from Azure Search Service ({})", e);
      Ok(http::Response::builder()
      .status(http::StatusCode::INTERNAL_SERVER_ERROR)
      .body(None)?)
    },
  }
}

[thangchung]

• https://github.com/fermyon/spin/blob/main/examples/rust-outbound-pg/src/lib.rs
• https://github.com/ThorstenHans/spin_book_api
• https://github.com/Liquid-Reply/kwasm-demos <= book-info with Spin
• https://github.com/dicej/spin-webrtc

[thangchung]

Refs https://github.com/thangchung/try-nomad-dapr/pull/6

[thangchung]

Deploy on Kubernetes:

• aks => https://github.com/Archisman-Mridha/spin-with-k8s-demo (k3d)
  • enable node-pool with wasi => https://github.com/deislabs/kc-eu-2023-k8s-wasm-microservices/blob/main/workshop/05-azure-kubernetes-service.md
  • .NET 7 aks => https://github.com/tpeczek/demo-dotnet-on-aks-wasi-node-pool
• kwasm on minikube=> https://github.com/mikkelhegn/kwasm-spin-minikube
• aks with pulumi => https://github.com/dirien/pulumi-aks-wasm-spin

And might apply ArgoCD => https://github.com/Archisman-Mridha/kubernetes-cicd-with-argo

[thangchung]

• devcontainer => https://github.com/fermyon/workshops/tree/main/.devcontainer
• Init database and seed data => https://github.com/fermyon/code-things/blob/feature/deploy-to-cloud/scripts/db/up.sh => https://github.com/jpflueger/spin-todo/blob/main/db/docker-up.sh

[thangchung]

Cannot run 2 different runtimes on a sidecar model with dapr (spin run wasm runtime, but daprd runs normal workload, so when you run it as a sidecar, it will be failed when started daprd). 2 solutions here:

• Using nomad, see => https://github.com/thangchung/dapr-labs/blob/main/build/hashicorp/nomad/jobs/counter-api-dapr.nomad.hcl#L60
• Use Dapr Ambient (sidecar on DeamonSet which means only one agent of daprd on each node, and deployment + svc is just traditional deploy so we can run spin there)
  • https://github.com/dapr-sandbox/dapr-ambient/blob/main/README.md
  • https://github.com/salaboy/dapr-ambient-examples/blob/main/apps.yaml

[thangchung]

POC: uuid -> text, and map it into Rust code (Spin doesn't support uuid right now)

• UUID: https://gist.github.com/cdmckay/a82261e48a42a3bbd78a
• ULID: https://blog.daveallie.com/ulid-primary-keys
• https://www.reddit.com/r/mariadb/comments/rlcylh/ulid_an_primary_key_in_the_tables_do_you_have_any/

[thangchung]

Run mixed workload in k8s => https://github.com/suneetnangia/wasm-orchestration-with-spin