fix: working server

Author: jayy-lmao

gleam.toml

@@ -1,6 +1,6 @@
 name = "fddd_library"
 version = "0.1.0"
-gleam = ">= 0.32.0"
+gleam = ">= 1.0.0"
 
 # Fill out these fields if you intend to generate HTML documentation or publish
 # your project to the Hex package manager.
@@ -13,7 +13,10 @@ 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"
+gleam_json = "1.0.1"
+mist = ">= 1.2.0 and < 2.0.0"
+gleam_erlang = ">= 0.25.0 and < 1.0.0"
+logging = ">= 1.1.0 and < 2.0.0"
 
 [dev-dependencies]
 gleeunit = "~> 1.0.2"

manifest.toml

@@ -2,14 +2,28 @@
 # You typically do not need to edit this file
 
 packages = [
+  { name = "birl", version = "1.7.0", build_tools = ["gleam"], requirements = ["gleam_stdlib", "ranger"], otp_app = "birl", source = "hex", outer_checksum = "B1FA529E7BE3FF12CADF32814AB8EC7294E74CEDEE8CC734505707B929A98985" },
+  { name = "gleam_crypto", version = "1.3.0", build_tools = ["gleam"], requirements = ["gleam_stdlib"], otp_app = "gleam_crypto", source = "hex", outer_checksum = "ADD058DEDE8F0341F1ADE3AAC492A224F15700829D9A3A3F9ADF370F875C51B7" },
+  { name = "gleam_erlang", version = "0.25.0", build_tools = ["gleam"], requirements = ["gleam_stdlib"], otp_app = "gleam_erlang", source = "hex", outer_checksum = "054D571A7092D2A9727B3E5D183B7507DAB0DA41556EC9133606F09C15497373" },
   { 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_json", version = "1.0.1", build_tools = ["gleam"], requirements = ["gleam_stdlib", "thoas"], otp_app = "gleam_json", source = "hex", outer_checksum = "9063D14D25406326C0255BDA0021541E797D8A7A12573D849462CAFED459F6EB" },
+  { name = "gleam_otp", version = "0.10.0", build_tools = ["gleam"], requirements = ["gleam_erlang", "gleam_stdlib"], otp_app = "gleam_otp", source = "hex", outer_checksum = "0B04FE915ACECE539B317F9652CAADBBC0F000184D586AAAF2D94C100945D72B" },
   { 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" },
+  { name = "glisten", version = "2.0.0", build_tools = ["gleam"], requirements = ["gleam_erlang", "gleam_otp", "gleam_stdlib"], otp_app = "glisten", source = "hex", outer_checksum = "CF3A9383E9BA4A8CBAF2F7B799716290D02F2AC34E7A77556B49376B662B9314" },
+  { name = "gramps", version = "2.0.3", build_tools = ["gleam"], requirements = ["gleam_crypto", "gleam_erlang", "gleam_http", "gleam_stdlib"], otp_app = "gramps", source = "hex", outer_checksum = "3CCAA6E081225180D95C79679D383BBF51C8D1FDC1B84DA1DA444F628C373793" },
+  { name = "hpack_erl", version = "0.3.0", build_tools = ["rebar3"], requirements = [], otp_app = "hpack", source = "hex", outer_checksum = "D6137D7079169D8C485C6962DFE261AF5B9EF60FBC557344511C1E65E3D95FB0" },
+  { name = "logging", version = "1.1.0", build_tools = ["gleam"], requirements = ["gleam_stdlib"], otp_app = "logging", source = "hex", outer_checksum = "A996064F04EF6E67F0668FD0ACFB309830B05D0EE3A0C11BBBD2D4464334F792" },
+  { name = "mist", version = "1.2.0", build_tools = ["gleam"], requirements = ["birl", "gleam_erlang", "gleam_http", "gleam_otp", "gleam_stdlib", "glisten", "gramps", "hpack_erl", "logging"], otp_app = "mist", source = "hex", outer_checksum = "109B4D64E68C104CC23BB3CC5441ECD479DD7444889DA01113B75C6AF0F0E17B" },
+  { name = "ranger", version = "1.2.0", build_tools = ["gleam"], requirements = ["gleam_stdlib"], otp_app = "ranger", source = "hex", outer_checksum = "1566C272B1D141B3BBA38B25CB761EF56E312E79EC0E2DFD4D3C19FB0CC1F98C" },
+  { name = "thoas", version = "1.2.1", build_tools = ["rebar3"], requirements = [], otp_app = "thoas", source = "hex", outer_checksum = "E38697EDFFD6E91BD12CEA41B155115282630075C2A727E7A6B2947F5408B86A" },
 ]
 
 [requirements]
+gleam_erlang = { version = ">= 0.25.0 and < 1.0.0" }
 gleam_http = { version = ">= 3.6.0 and < 4.0.0" }
-gleam_json = { version = ">= 2.0.0 and < 3.0.0"}
+gleam_json = { version = "1.0.1" }
 gleam_stdlib = { version = "~> 0.38" }
 gleeunit = { version = "~> 1.0.2" }
+logging = { version = ">= 1.1.0 and < 2.0.0" }
+mist = { version = ">= 1.2.0 and < 2.0.0" }

src/fddd_library.gleam

@@ -1,43 +1,49 @@
-import gleam/io
+import gleam/bytes_builder
+import gleam/dict
+import gleam/erlang/atom
+import gleam/erlang/process
+import gleam/http/request
+import gleam/http/response
+import logging
+import mist
+import order_taking/place_order/api.{place_order_api}
+
+@external(erlang, "logger", "update_primary_config")
+fn logger_update_primary_config(
+  config: dict.Dict(atom.Atom, atom.Atom),
+) -> Result(Nil, any)
 
-pub type OrderEvents {
-  OrderPlaced
-}
-
-pub type UnvalidatedOrder {
-  UnvalidatedOrder(id: String)
-}
-
-pub type ValidatedOrder {
-  ValidatedOrder(id: String)
-}
-
-pub type PlacedOrder {
-  PlacedOrder(id: String)
-}
-
-pub type Validate =
-  fn(UnvalidatedOrder) -> ValidatedOrder
-
-pub type SendOrder =
-  fn(ValidatedOrder) -> PlacedOrder
-
-pub type ExtractEvents =
-  fn(PlacedOrder) -> List(OrderEvents)
-
-pub fn create_place_order(
-  validate: Validate,
-  send_order: SendOrder,
-  extract_events: ExtractEvents,
-) -> fn(UnvalidatedOrder) -> List(OrderEvents) {
-  fn(order) {
-    order
-    |> validate
-    |> send_order
-    |> extract_events
-  }
+pub fn main() {
+  logging.configure()
+  let _ =
+    logger_update_primary_config(
+      dict.from_list([
+        #(atom.create_from_string("level"), atom.create_from_string("debug")),
+      ]),
+    )
+
+  let not_found =
+    response.new(404)
+    |> response.set_body(mist.Bytes(bytes_builder.new()))
+
+  let assert Ok(_) =
+    fn(req: request.Request(mist.Connection)) -> response.Response(
+      mist.ResponseData,
+    ) {
+      case request.path_segments(req) {
+        ["order"] -> submit_order(req)
+        _ -> not_found
+      }
+    }
+    |> mist.new
+    |> mist.port(8000)
+    |> mist.start_http
+
+  process.sleep_forever()
 }
 
-pub fn main() {
-  io.println("Hello from fddd_library! ")
+fn submit_order(
+  request: request.Request(mist.Connection),
+) -> response.Response(mist.ResponseData) {
+  place_order_api(request)
 }

src/order_taking/place_order/api.gleam

@@ -6,11 +6,17 @@
 // 3) The output is turned into a DTO which is turned into a HttpResponse
 // ======================================================
 
+import gleam/bit_array
+import gleam/bytes_builder
+import gleam/dynamic
 import gleam/http/request
 import gleam/http/response
+import gleam/io
 import gleam/json
 import gleam/list
 import gleam/result
+import gleam/string
+import mist
 import order_taking/common/simple_types/price
 import order_taking/place_order/dto/order_form_dto
 import order_taking/place_order/dto/place_order_error_dto
@@ -62,7 +68,9 @@ pub fn send_order_acknowledgment(_order_acknowledgement) {
 // // -------------------------------
 
 /// This function converts the workflow output into a HttpResponse
-pub fn workflow_result_to_http_reponse(result) -> response.Response(String) {
+pub fn workflow_result_to_http_reponse(
+  result,
+) -> response.Response(mist.ResponseData) {
   case result {
     Ok(events) -> {
       // turn domain events into dtos
@@ -81,30 +89,40 @@ pub fn workflow_result_to_http_reponse(result) -> response.Response(String) {
           |> json.to_string
         }
 
-      let response =
-        response.Response(body: json, status: 200, headers: [
-          #("Content-Type", "application/json"),
-        ])
-      response
+      // let response =
+      //   response.Response(body: json, status: 200, headers: [
+      //     #("Content-Type", "application/json"),
+      //   ])
+      // response
+      response.new(200)
+      |> response.prepend_header("content-type", "application/json")
+      |> response.set_body(mist.Bytes(bytes_builder.from_string(json)))
     }
     Error(err) -> {
       // turn domain errors into a dto
       let dto = place_order_error_dto.from_domain(err)
       // and serialize to JSON
       let json = dto |> place_order_error_dto.to_json |> json.to_string
-      let response = response.Response(status: 401, body: json, headers: [])
-      response
+      response.new(401)
+      |> response.prepend_header("content-type", "application/json")
+      |> response.set_body(mist.Bytes(bytes_builder.from_string(json)))
     }
   }
 }
 
 pub fn place_order_api(
-  request: request.Request(String),
-) -> response.Response(String) {
+  request: request.Request(mist.Connection),
+) -> response.Response(mist.ResponseData) {
   // following the approach in "A Complete Serialization Pipeline" in chapter 11
 
   // start with a string
-  let order_form_json = request.body
+  let order_form_json =
+    mist.read_body(request, 300_000)
+    |> result.map(fn(req) { req.body })
+    |> result.map(bit_array.to_string)
+    |> result.unwrap(Ok(""))
+    |> result.unwrap("")
+
   let order_form =
     json.decode(from: order_form_json, using: order_form_dto.decoder())
 
@@ -135,14 +153,32 @@ pub fn place_order_api(
       result
       |> workflow_result_to_http_reponse
     }
-    Error(_json_error) -> {
-      let response =
-        response.Response(
-          status: 403,
-          body: "JSON deserialisation error",
-          headers: [],
+    Error(json_error) -> {
+      io.debug(json_error)
+      let message = case json_error {
+        json.UnexpectedFormat(decode_errors) -> {
+          decode_errors
+          |> list.map(fn(err) {
+            let dynamic.DecodeError(_, _, err_path) = err
+            string.join(err_path, ".")
+          })
+          |> string.join(", ")
+        }
+        _ -> "Json deser error"
+      }
+
+      // response.new(401)
+      // |> response.set_body(mist.Bytes(bytes_builder.from_string(message)))
+      let json =
+        place_order_error_dto.PlaceOrderErrorDto(
+          code: "DeserialisationError",
+          message: message,
         )
-      response
+        |> place_order_error_dto.to_json
+        |> json.to_string
+      response.new(401)
+      |> response.prepend_header("content-type", "application/json")
+      |> response.set_body(mist.Bytes(bytes_builder.from_string(json)))
     }
   }
 }

src/order_taking/place_order/dto/address_dto.gleam

@@ -24,9 +24,9 @@ pub fn decoder() {
     dynamic.decode6(
       AddressDto,
       dynamic.field("address_line_1", of: dynamic.string),
-      dynamic.field("address_line_2", of: dynamic.optional(dynamic.string)),
-      dynamic.field("address_line_3", of: dynamic.optional(dynamic.string)),
-      dynamic.field("address_line_4", of: dynamic.optional(dynamic.string)),
+      dynamic.optional_field("address_line_2", of: dynamic.string),
+      dynamic.optional_field("address_line_3", of: dynamic.string),
+      dynamic.optional_field("address_line_4", of: dynamic.string),
       dynamic.field("city", of: dynamic.string),
       dynamic.field("zip_code", of: dynamic.string),
     )

src/order_taking/place_order/dto/customer_info_dto.gleam

@@ -15,7 +15,7 @@ pub type CustomerInfoDto {
 }
 
 /// For deserialising
-pub fn decoder(json_string: String) {
+pub fn decoder() {
   let decoder =
     dynamic.decode3(
       CustomerInfoDto,