Stream: crash at startup if Sentry DSN is not correct (close #399)

snowplow · Nov 20, 2020 · 9b61f7c · 9b61f7c
1 parent 562280e
commit 9b61f7c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/modules/stream/src/main/scala/com.snowplowanalytics.snowplow.enrich.stream/model.scala b/modules/stream/src/main/scala/com.snowplowanalytics.snowplow.enrich.stream/model.scala
@@ -19,6 +19,7 @@
 package com.snowplowanalytics.snowplow.enrich.stream
 
 import java.text.SimpleDateFormat
+import java.net.URI
 
 import cats.syntax.either._
 
@@ -166,7 +167,7 @@ object model {
     readTimeout: Option[Long],
     url: String
   )
-  final case class SentryConfig(dsn: String)
+  final case class SentryConfig(dsn: URI)
   final case class EnrichConfig(
     streams: StreamsConfig,
     remoteAdapters: Option[List[RemoteAdapterConfig]],

diff --git a/...s/stream/src/main/scala/com.snowplowanalytics.snowplow.enrich.stream/sources/Source.scala b/...s/stream/src/main/scala/com.snowplowanalytics.snowplow.enrich.stream/sources/Source.scala
@@ -122,7 +122,7 @@ abstract class Source(
   sentryConfig: Option[SentryConfig]
 ) {
 
-  val sentryClient: Option[SentryClient] = sentryConfig.map(_.dsn).map(Sentry.init)
+  val sentryClient: Option[SentryClient] = sentryConfig.map(_.dsn.toString).map(Sentry.init)
 
   val MaxRecordSize: Option[Int]