From 9b61f7c6461983124b9b02617525ea5a7165c2e8 Mon Sep 17 00:00:00 2001 From: Benjamin Benoist Date: Fri, 20 Nov 2020 10:27:30 +0100 Subject: [PATCH] Stream: crash at startup if Sentry DSN is not correct (close #399) --- .../com.snowplowanalytics.snowplow.enrich.stream/model.scala | 3 ++- .../sources/Source.scala | 2 +- 2 files changed, 3 insertions(+), 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 index 85339ad32..a46e7fb29 100644 --- 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/modules/stream/src/main/scala/com.snowplowanalytics.snowplow.enrich.stream/sources/Source.scala b/modules/stream/src/main/scala/com.snowplowanalytics.snowplow.enrich.stream/sources/Source.scala index 7df744db2..fa4f040ba 100644 --- a/modules/stream/src/main/scala/com.snowplowanalytics.snowplow.enrich.stream/sources/Source.scala +++ b/modules/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]