Format

Author: renatillas

test/cli_error_handling_generated/proto.gleam

@@ -9,14 +9,12 @@ import protozoa/decode
 import protozoa/encode
 
 pub type ProblematicMessage {
-  ProblematicMessage(
-    import_: String,
-    type_: String,
-    fn_: String,
-  )
+  ProblematicMessage(import_: String, type_: String, fn_: String)
 }
 
-pub fn encode_problematicmessage(problematicmessage: ProblematicMessage) -> BitArray {
+pub fn encode_problematicmessage(
+  problematicmessage: ProblematicMessage,
+) -> BitArray {
   encode.message([
     encode.string_field(1, problematicmessage.import_),
     encode.string_field(2, problematicmessage.type_),
@@ -31,6 +29,8 @@ pub fn problematicmessage_decoder() -> decode.Decoder(ProblematicMessage) {
   decode.success(ProblematicMessage(import_: import_, type_: type_, fn_: fn_))
 }
 
-pub fn decode_problematicmessage(data: BitArray) -> Result(ProblematicMessage, List(decode.DecodeError)) {
+pub fn decode_problematicmessage(
+  data: BitArray,
+) -> Result(ProblematicMessage, List(decode.DecodeError)) {
   decode.run(data, problematicmessage_decoder())
-}
+}

test/validation_output/proto.gleam

@@ -27,42 +27,42 @@ pub type ServiceResponseResponse {
 }
 
 pub type ServiceResponse {
-  ServiceResponse(
-    response: option.Option(ServiceResponseResponse),
-  )
+  ServiceResponse(response: option.Option(ServiceResponseResponse))
 }
 
 pub type Duration {
-  Duration(
-    seconds: Int,
-    nanos: Int,
-  )
+  Duration(seconds: Int, nanos: Int)
 }
 
 pub type Empty {
   Empty
 }
 
 pub type FieldMask {
-  FieldMask(
-    paths: List(String),
-  )
+  FieldMask(paths: List(String))
 }
 
 pub type Timestamp {
-  Timestamp(
-    seconds: Int,
-    nanos: Int,
-  )
+  Timestamp(seconds: Int, nanos: Int)
 }
 
 pub fn encode_serviceresponse(serviceresponse: ServiceResponse) -> BitArray {
   encode.message([
     case serviceresponse.response {
       Some(oneof_value) -> {
         case oneof_value {
-      Data(value) -> encode.field(1, wire.LengthDelimited, encode.length_delimited(encode_eventmessage(value)))
-      EmptyData(value) -> encode.field(2, wire.LengthDelimited, encode.length_delimited(encode_empty(value)))
+          Data(value) ->
+            encode.field(
+              1,
+              wire.LengthDelimited,
+              encode.length_delimited(encode_eventmessage(value)),
+            )
+          EmptyData(value) ->
+            encode.field(
+              2,
+              wire.LengthDelimited,
+              encode.length_delimited(encode_empty(value)),
+            )
         }
       }
       None -> <<>>
@@ -73,9 +73,21 @@ pub fn encode_serviceresponse(serviceresponse: ServiceResponse) -> BitArray {
 pub fn encode_eventmessage(eventmessage: EventMessage) -> BitArray {
   encode.message([
     encode.string_field(1, eventmessage.event_name),
-    encode.field(2, wire.LengthDelimited, encode.length_delimited(encode_timestamp(eventmessage.occurred_at))),
-    encode.field(3, wire.LengthDelimited, encode.length_delimited(encode_duration(eventmessage.duration))),
-    encode.field(4, wire.LengthDelimited, encode.length_delimited(encode_fieldmask(eventmessage.update_mask))),
+    encode.field(
+      2,
+      wire.LengthDelimited,
+      encode.length_delimited(encode_timestamp(eventmessage.occurred_at)),
+    ),
+    encode.field(
+      3,
+      wire.LengthDelimited,
+      encode.length_delimited(encode_duration(eventmessage.duration)),
+    ),
+    encode.field(
+      4,
+      wire.LengthDelimited,
+      encode.length_delimited(encode_fieldmask(eventmessage.update_mask)),
+    ),
   ])
 }
 
@@ -91,7 +103,8 @@ pub fn encode_empty(_empty: Empty) -> BitArray {
 }
 
 pub fn encode_fieldmask(fieldmask: FieldMask) -> BitArray {
-  let paths_fields = list.map(fieldmask.paths, fn(v) { encode.string_field(1, v) })
+  let paths_fields =
+    list.map(fieldmask.paths, fn(v) { encode.string_field(1, v) })
   encode.message(paths_fields)
 }
 
@@ -102,36 +115,38 @@ pub fn encode_timestamp(timestamp: Timestamp) -> BitArray {
   ])
 }
 
-fn oneof_response_decoder() -> decode.Decoder(option.Option(ServiceResponseResponse)) {
+fn oneof_response_decoder() -> decode.Decoder(
+  option.Option(ServiceResponseResponse),
+) {
   decode.from_field_dict(fn(fields) {
     case dict.get(fields, 1) {
       Ok([field, ..]) -> {
         case decode.message_field(_, eventmessage_decoder())(field) {
           Ok(value) -> Ok(option.Some(Data(value)))
           Error(_) -> {
-    case dict.get(fields, 2) {
-      Ok([field, ..]) -> {
-        case decode.message_field(_, empty_decoder())(field) {
-          Ok(value) -> Ok(option.Some(EmptyData(value)))
-          Error(_) -> Ok(option.None)
-        }
-      }
-      _ -> Ok(option.None)
-    }
+            case dict.get(fields, 2) {
+              Ok([field, ..]) -> {
+                case decode.message_field(_, empty_decoder())(field) {
+                  Ok(value) -> Ok(option.Some(EmptyData(value)))
+                  Error(_) -> Ok(option.None)
+                }
+              }
+              _ -> Ok(option.None)
+            }
           }
         }
       }
       _ -> {
-    case dict.get(fields, 2) {
-      Ok([field, ..]) -> {
-        case decode.message_field(_, empty_decoder())(field) {
-          Ok(value) -> Ok(option.Some(EmptyData(value)))
-          Error(_) -> Ok(option.None)
+        case dict.get(fields, 2) {
+          Ok([field, ..]) -> {
+            case decode.message_field(_, empty_decoder())(field) {
+              Ok(value) -> Ok(option.Some(EmptyData(value)))
+              Error(_) -> Ok(option.None)
+            }
+          }
+          _ -> Ok(option.None)
         }
       }
-      _ -> Ok(option.None)
-    }
-      }
     }
   })
 }
@@ -141,7 +156,9 @@ pub fn serviceresponse_decoder() -> decode.Decoder(ServiceResponse) {
   decode.success(ServiceResponse(response: response))
 }
 
-pub fn decode_serviceresponse(data: BitArray) -> Result(ServiceResponse, List(decode.DecodeError)) {
+pub fn decode_serviceresponse(
+  data: BitArray,
+) -> Result(ServiceResponse, List(decode.DecodeError)) {
   decode.run(data, serviceresponse_decoder())
 }
 
@@ -150,10 +167,17 @@ pub fn eventmessage_decoder() -> decode.Decoder(EventMessage) {
   use occurred_at <- decode.then(decode.nested_message(2, timestamp_decoder()))
   use duration <- decode.then(decode.nested_message(3, duration_decoder()))
   use update_mask <- decode.then(decode.nested_message(4, fieldmask_decoder()))
-  decode.success(EventMessage(event_name: event_name, occurred_at: occurred_at, duration: duration, update_mask: update_mask))
+  decode.success(EventMessage(
+    event_name: event_name,
+    occurred_at: occurred_at,
+    duration: duration,
+    update_mask: update_mask,
+  ))
 }
 
-pub fn decode_eventmessage(data: BitArray) -> Result(EventMessage, List(decode.DecodeError)) {
+pub fn decode_eventmessage(
+  data: BitArray,
+) -> Result(EventMessage, List(decode.DecodeError)) {
   decode.run(data, eventmessage_decoder())
 }
 
@@ -163,7 +187,9 @@ pub fn duration_decoder() -> decode.Decoder(Duration) {
   decode.success(Duration(seconds: seconds, nanos: nanos))
 }
 
-pub fn decode_duration(data: BitArray) -> Result(Duration, List(decode.DecodeError)) {
+pub fn decode_duration(
+  data: BitArray,
+) -> Result(Duration, List(decode.DecodeError)) {
   decode.run(data, duration_decoder())
 }
 
@@ -180,7 +206,9 @@ pub fn fieldmask_decoder() -> decode.Decoder(FieldMask) {
   decode.success(FieldMask(paths: paths))
 }
 
-pub fn decode_fieldmask(data: BitArray) -> Result(FieldMask, List(decode.DecodeError)) {
+pub fn decode_fieldmask(
+  data: BitArray,
+) -> Result(FieldMask, List(decode.DecodeError)) {
   decode.run(data, fieldmask_decoder())
 }
 
@@ -190,6 +218,8 @@ pub fn timestamp_decoder() -> decode.Decoder(Timestamp) {
   decode.success(Timestamp(seconds: seconds, nanos: nanos))
 }
 
-pub fn decode_timestamp(data: BitArray) -> Result(Timestamp, List(decode.DecodeError)) {
+pub fn decode_timestamp(
+  data: BitArray,
+) -> Result(Timestamp, List(decode.DecodeError)) {
   decode.run(data, timestamp_decoder())
-}
+}