Avoid leaking sensitive data in logs

lensesio · Oct 24, 2024 · f79a1cd · f79a1cd
1 parent bff785f
commit f79a1cd
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...-connect-http/src/main/scala/io/lenses/streamreactor/connect/http/sink/RecordsQueue.scala b/...-connect-http/src/main/scala/io/lenses/streamreactor/connect/http/sink/RecordsQueue.scala
@@ -49,7 +49,7 @@ class RecordsQueue(
   def enqueueAll(records: NonEmptySeq[RenderedRecord]): IO[Unit] =
     for {
       _ <- IO.delay(logger.debug(s"${records.length} records added to $recordsQueue"))
-      _ <- IO(recordsQueue.getAndUpdate(q => q ++ records.toSeq).void)
+      _ <- recordsQueue.getAndUpdate(q => q ++ records.toSeq).void
     } yield ()
 
   /**

diff --git a/...ect-http/src/main/scala/io/lenses/streamreactor/connect/http/sink/tpl/TemplateTypes.scala b/...ect-http/src/main/scala/io/lenses/streamreactor/connect/http/sink/tpl/TemplateTypes.scala
@@ -72,7 +72,7 @@ case class SimpleTemplate(
     records.head match {
       case RenderedRecord(_, _, recordRendered, headersRendered, endpointRendered) =>
         logger.debug(
-          s"Processed template with endpoint=${records.head.endpointRendered}, tidyJson=$tidyJson, recordRendered=$recordRendered",
+          s"Processed template with tidyJson=$tidyJson",
         )
         ProcessedTemplate(endpointRendered, recordRendered, headersRendered).asRight
     }
@@ -111,7 +111,7 @@ case class TemplateWithInnerLoop(
     }
     val contentOrError = fnContextFix(prefixContent + replaceWith + suffixContent)
     logger.debug(
-      s"Processed template with endpoint=${records.head.endpointRendered} prefixContent=$prefixContent, suffixContent=$suffixContent, replaceWith=$replaceWith, tidyJson=$tidyJson, contentOrError=$contentOrError",
+      s"Processed template with prefixContent=$prefixContent, suffixContent=$suffixContent, tidyJson=$tidyJson",
     )
     ProcessedTemplate(
       endpoint = records.head.endpointRendered,