fix: wip json serial

Author: jayy-lmao

gleam.toml

@@ -12,6 +12,8 @@ gleam = ">= 0.32.0"
 
 [dependencies]
 gleam_stdlib = "~> 0.38"
+gleam_http = ">= 3.6.0 and < 4.0.0"
+gleam_json = ">= 2.0.0 and < 3.0.0"
 
 [dev-dependencies]
 gleeunit = "~> 1.0.2"

manifest.toml

@@ -2,10 +2,14 @@
 # You typically do not need to edit this file
 
 packages = [
+  { name = "gleam_http", version = "3.6.0", build_tools = ["gleam"], requirements = ["gleam_stdlib"], otp_app = "gleam_http", source = "hex", outer_checksum = "8C07DF9DF8CC7F054C650839A51C30A7D3C26482AC241C899C1CEA86B22DBE51" },
+  { name = "gleam_json", version = "2.0.0", build_tools = ["gleam"], requirements = ["gleam_stdlib"], otp_app = "gleam_json", source = "hex", outer_checksum = "CB10B0E7BF44282FB25162F1A24C1A025F6B93E777CCF238C4017E4EEF2CDE97" },
   { name = "gleam_stdlib", version = "0.38.0", build_tools = ["gleam"], requirements = [], otp_app = "gleam_stdlib", source = "hex", outer_checksum = "663CF11861179AF415A625307447775C09404E752FF99A24E2057C835319F1BE" },
   { name = "gleeunit", version = "1.0.2", build_tools = ["gleam"], requirements = ["gleam_stdlib"], otp_app = "gleeunit", source = "hex", outer_checksum = "D364C87AFEB26BDB4FB8A5ABDE67D635DC9FA52D6AB68416044C35B096C6882D" },
 ]
 
 [requirements]
+gleam_http = { version = ">= 3.6.0 and < 4.0.0" }
+gleam_json = { version = ">= 2.0.0 and < 3.0.0"}
 gleam_stdlib = { version = "~> 0.38" }
 gleeunit = { version = "~> 1.0.2" }

src/order_taking/place_order/api.gleam

@@ -0,0 +1,118 @@
+// ======================================================
+// This file contains the JSON API interface to the PlaceOrder workflow
+//
+// 1) The HttpRequest is turned into a DTO, which is then turned into a Domain object
+// 2) The main workflow function is called
+// 3) The output is turned into a DTO which is turned into a HttpResponse
+// ======================================================
+
+import gleam/http/request
+import gleam/http/response
+import gleam/json
+import gleam/list
+import gleam/result
+import order_taking/common/public_types
+import order_taking/common/simple_types/price
+import order_taking/place_order/dto/place_order_event_dto
+import order_taking/place_order/implementation
+
+pub type JsonString =
+  String
+
+// pub type PlaceOrderApi =
+//   fn(request.Request) -> response.Response
+
+// =============================
+// Implementation
+// =============================
+
+/// Very simplified version!
+/// An API takes a HttpRequest as input and returns a async response
+/// setup dummy dependencies
+pub fn check_product_exists(_product_code) {
+  True
+}
+
+/// dummy implementation
+pub fn check_address_exists(unvalidated_address) {
+  let checked_address = implementation.CheckedAddress(unvalidated_address)
+
+  checked_address
+}
+
+/// dummy implementation
+pub fn get_product_price(_product_code) {
+  price.from_int(1)
+}
+
+/// dummy implementation
+pub fn create_order_acknowledgment_letter(_priced_order) {
+  let letter_test = implementation.HtmlString("some text")
+  letter_test
+}
+
+/// dummy implementation
+pub fn send_order_acknowledgment(_order_acknowledgement) {
+  implementation.Sent
+}
+
+// // -------------------------------
+// // workflow
+// // -------------------------------
+
+/// This function converts the workflow output into a HttpResponse
+pub fn workflow_result_to_http_reponse(result) -> response.Response(String) {
+  case result {
+    Ok(events) -> {
+      // turn domain events into dtos
+      let dtos =
+        events
+        |> list.map(place_order_event_dto.from_domain)
+
+      // and serialize to JSON
+      let json =
+        dtos
+        |> list.map(fn(event) { todo })
+
+      let response = response.Response()
+      response
+    }
+    Error(err) ->
+      // // turn domain errors into a dto
+      // let dto = err |> PlaceOrderErrorDto.fromDomain
+      // // and serialize to JSON
+      // let json = serializeJson(dto )
+      // let response =
+      //     {
+      //     HttpStatusCode = 401
+      //     Body = json
+      //     }
+      // response
+      todo
+  }
+}
+// let placeOrderApi : PlaceOrderApi =
+//     fun request ->
+//         // following the approach in "A Complete Serialization Pipeline" in chapter 11
+
+//         // start with a string
+//         let orderFormJson = request.Body
+//         let orderForm = deserializeJson<OrderFormDto>(orderFormJson)
+//         // convert to domain object
+//         let unvalidatedOrder = orderForm |> OrderFormDto.toUnvalidatedOrder
+
+//         // setup the dependencies. See "Injecting Dependencies" in chapter 9
+//         let workflow =
+//             Implementation.placeOrder
+//                 checkProductExists // dependency
+//                 checkAddressExists // dependency
+//                 getProductPrice    // dependency
+//                 createOrderAcknowledgmentLetter  // dependency
+//                 sendOrderAcknowledgment // dependency
+
+//         // now we are in the pure domain
+//         let asyncResult = workflow unvalidatedOrder
+
+//         // now convert from the pure domain back to a HttpResponse
+//         asyncResult
+//         |> Async.map (workflowResultToHttpReponse)

src/order_taking/place_order/dto/address_dto.gleam

@@ -1,4 +1,5 @@
-import gleam/option.{type Option, None}
+import gleam/json
+import gleam/option
 import gleam/result.{try}
 import order_taking/common/compound_types
 import order_taking/common/public_types
@@ -8,14 +9,38 @@ import order_taking/common/simple_types/zip_code
 pub type AddressDto {
   AddressDto(
     address_line_1: String,
-    address_line_2: Option(String),
-    address_line_3: Option(String),
-    address_line_4: Option(String),
+    address_line_2: option.Option(String),
+    address_line_3: option.Option(String),
+    address_line_4: option.Option(String),
     city: String,
     zip_code: String,
   )
 }
 
+pub fn to_json(dto: AddressDto) {
+  json.object([
+    #("address_line_1", json.string(dto.address_line_1)),
+    #(
+      "address_line_2",
+      dto.address_line_2
+        |> option.map(json.string)
+        |> option.unwrap(json.null()),
+    ),
+    #(
+      "address_line_3",
+      dto.address_line_3
+        |> option.map(json.string)
+        |> option.unwrap(json.null()),
+    ),
+    #(
+      "address_line_4",
+      dto.address_line_4
+        |> option.map(json.string)
+        |> option.unwrap(json.null()),
+    ),
+  ])
+}
+
 /// This always succeeds because there is no validation.
 /// Used when importing an OrderForm from the outside world into the domain.
 pub fn to_unvalidated_address(
@@ -43,17 +68,17 @@ pub fn to_address(dto: AddressDto) -> Result(compound_types.Address, String) {
   use address_line_2 <- try(
     dto.address_line_2
     |> option.map(fn(addr) { string50.create_option(addr, "address_line_2") })
-    |> option.unwrap(Ok(None)),
+    |> option.unwrap(Ok(option.None)),
   )
   use address_line_3 <- try(
     dto.address_line_3
     |> option.map(fn(addr) { string50.create_option(addr, "address_line_3") })
-    |> option.unwrap(Ok(None)),
+    |> option.unwrap(Ok(option.None)),
   )
   use address_line_4 <- try(
     dto.address_line_4
     |> option.map(fn(addr) { string50.create_option(addr, "address_line_4") })
-    |> option.unwrap(Ok(None)),
+    |> option.unwrap(Ok(option.None)),
   )
   use city <- try(dto.city |> string50.create("city"))
   use zip_code <- try(dto.zip_code |> zip_code.create("zip_code"))