better throw exception

snowplow · Aug 17, 2021 · abd6c67 · abd6c67
1 parent 3e17d7c
commit abd6c67
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/...s/common-fs2/src/main/scala/com/snowplowanalytics/snowplow/enrich/common/fs2/Enrich.scala b/...s/common-fs2/src/main/scala/com/snowplowanalytics/snowplow/enrich/common/fs2/Enrich.scala
@@ -112,9 +112,14 @@ object Enrich {
     val payload = ThriftLoader.toCollectorPayload(row, processor)
     val collectorTstamp = payload.toOption.flatMap(_.flatMap(_.context.timestamp).map(_.getMillis))
 
-    System.out.println("Going to crash")
-    throw new IllegalArgumentException("TEST CRASH")
-    System.out.println("Crashed")
+    payload.toOption match {
+      case Some(Some(p)) =>
+        p.body match {
+          case Some(b) if b.contains("crash") => throw new RuntimeException("TEST CRASH")
+          case _ => System.out.println("foo")
+        }
+      case _ => System.out.println("bar")
+    }
 
     val result =
       for {