Improve xml consumer syntax, introduce missing extension (#246)

improve xml consumer syntax, introduce missing extension
ocadotechnology · Feb 28, 2023 · 256b463 · 256b463
1 parent e04b8f2
commit 256b463
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/addons/phobos/src/main/scala/com/ocadotechnology/pass4s/phobos/syntax.scala b/addons/phobos/src/main/scala/com/ocadotechnology/pass4s/phobos/syntax.scala
@@ -16,10 +16,12 @@
 
 package com.ocadotechnology.pass4s.phobos
 
+import cats.MonadError
 import cats.MonadThrow
 import cats.syntax.all._
 import com.ocadotechnology.pass4s.core.Destination
 import com.ocadotechnology.pass4s.core.Message
+import com.ocadotechnology.pass4s.core.Message.Payload
 import com.ocadotechnology.pass4s.core.groupId.GroupIdMeta
 import com.ocadotechnology.pass4s.core.groupId.MessageGroup
 import com.ocadotechnology.pass4s.kernel.Consumer
@@ -100,4 +102,14 @@ object syntax {
       consumer.mapM(XmlDecoder[A].decode(_).liftTo[F])
   }
 
+  implicit final class ConsumeXmlGenericMessageSyntax[F[_], A](private val consumer: Consumer[F, A]) {
+
+    def asXmlConsumer[B: XmlDecoder](
+      implicit M: MonadError[F, _ >: ru.tinkoff.phobos.decoding.DecodingError],
+      ev: A <:< Payload
+    ): Consumer[F, B] =
+      consumer.mapM(msg => XmlDecoder[B].decode(msg.text).liftTo[F])
+
+  }
+
 }