Skip to content

Commit 56b0433

Browse files
committed
Bump libraries to address security vulnerabilities
1 parent 92faa99 commit 56b0433

File tree

2 files changed

+16
-9
lines changed

2 files changed

+16
-9
lines changed

modules/common/src/main/scala/com.snowplowanalytics.snowplow.enrich/common/enrichments/registry/pii/PiiPseudonymizerEnrichment.scala

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -358,10 +358,11 @@ private final case class ScrambleMapFunction(
358358
) extends MapFunction {
359359
override def map(currentValue: AnyRef, configuration: Configuration): AnyRef =
360360
currentValue match {
361-
case s: String =>
362-
val newValue = strategy.scramble(s)
363-
val _ = modifiedFields += JsonModifiedField(fieldName, s, newValue, jsonPath, schema.toSchemaUri)
364-
newValue
361+
case t: TextNode =>
362+
val originalValue = t.asText()
363+
val newValue = strategy.scramble(originalValue)
364+
val _ = modifiedFields += JsonModifiedField(fieldName, originalValue, newValue, jsonPath, schema.toSchemaUri)
365+
new TextNode(newValue)
365366
case a: ArrayNode =>
366367
val mapper = new ObjectMapper()
367368
val arr = mapper.createArrayNode()

project/Dependencies.scala

Lines changed: 11 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ object Dependencies {
3939
val postgresDriver = "42.7.2"
4040
val mysqlClient = "3.4.0"
4141
val hikariCP = "5.0.1"
42-
val jaywayJsonpath = "2.7.0"
42+
val jaywayJsonpath = "2.10.0"
4343
val jsonsmart = "2.5.2"
4444
val iabClient = "0.2.0"
4545
val ipaddress = "5.5.1"
@@ -50,7 +50,7 @@ object Dependencies {
5050
val thrift = "0.15.0"
5151
val httpclient = "4.5.13"
5252
val sprayJson = "1.3.6"
53-
val netty = "4.1.125.Final"
53+
val netty = "4.2.7.Final"
5454
val protobuf = "4.28.3"
5555
val nashorn = "15.6"
5656
val zstd = "1.5.7-4"
@@ -73,7 +73,7 @@ object Dependencies {
7373

7474
val gcpSdk = "2.60.0"
7575
val awsSdk = "2.33.1"
76-
val kafka = "3.9.1"
76+
val kafka = "4.1.1"
7777
val jackson = "2.18.1"
7878

7979
val decline = "2.4.1"
@@ -82,6 +82,8 @@ object Dependencies {
8282
val azureIdentity = "1.12.2"
8383
val azureStorageBlob = "12.25.1"
8484
val nimbusJoseJwt = "10.0.2"
85+
val lz4 = "1.8.1"
86+
val reactorNetty = "1.2.8"
8587
val http4s = "0.23.25"
8688

8789
val streams = "0.18.0"
@@ -174,6 +176,8 @@ object Dependencies {
174176
val azureStorageBlob = "com.azure" % "azure-storage-blob" % V.azureStorageBlob
175177
val nimbusJoseJwt = "com.nimbusds" % "nimbus-jose-jwt" % V.nimbusJoseJwt
176178
val jacksonDfXml = "com.fasterxml.jackson.dataformat" % "jackson-dataformat-xml" % V.jackson
179+
val lz4 = "org.lz4" % "lz4-java" % V.lz4
180+
val reactorNetty = "io.projectreactor.netty" % "reactor-netty-http" % V.reactorNetty
177181
val http4sClient = "org.http4s" %% "http4s-ember-client" % V.http4s
178182
val http4sDsl = "org.http4s" %% "http4s-dsl" % V.http4s % Test
179183

@@ -265,7 +269,8 @@ object Dependencies {
265269
azureStorageBlob,
266270
circeGeneric,
267271
jacksonDfXml, // for security vulnerabilities
268-
nimbusJoseJwt // for security vulnerabilities
272+
nimbusJoseJwt, // for security vulnerabilities
273+
lz4 // for security vulnerabilities
269274
)
270275

271276
val pubsubDependencies = Seq(
@@ -284,7 +289,8 @@ object Dependencies {
284289
)
285290

286291
val nsqDependencies = Seq(
287-
nsqSnowplow
292+
nsqSnowplow,
293+
reactorNetty // for security vulnerabilities
288294
)
289295

290296
val itDependencies = Seq(

0 commit comments

Comments
 (0)