fix: handle null email in notifications (#17648)

Author: abuchanan-airbyte

airbyte-notification/src/main/kotlin/io/airbyte/notification/CustomerioNotificationClient.kt

@@ -99,8 +99,11 @@ class CustomerioNotificationClient(
 
   override fun notifyJobFailure(
     summary: SyncSummary,
-    receiverEmail: String,
+    receiverEmail: String?,
   ): Boolean {
+    if (receiverEmail == null) {
+      return false
+    }
     val node = buildSyncCompletedJson(summary, receiverEmail, SYNC_FAILURE_MESSAGE_ID)
     val payload = Jsons.serialize(node)
     return try {
@@ -113,8 +116,11 @@ class CustomerioNotificationClient(
 
   override fun notifyJobSuccess(
     summary: SyncSummary,
-    receiverEmail: String,
+    receiverEmail: String?,
   ): Boolean {
+    if (receiverEmail == null) {
+      return false
+    }
     val node = buildSyncCompletedJson(summary, receiverEmail, SYNC_SUCCEED_MESSAGE_ID)
     val payload = Jsons.serialize(node)
     return try {
@@ -130,8 +136,11 @@ class CustomerioNotificationClient(
   // instead of being passed in
   override fun notifyConnectionDisabled(
     summary: SyncSummary,
-    receiverEmail: String,
+    receiverEmail: String?,
   ): Boolean {
+    if (receiverEmail == null) {
+      return false
+    }
     val node = buildSyncCompletedJson(summary, receiverEmail, AUTO_DISABLE_TRANSACTION_MESSAGE_ID)
     val payload = Jsons.serialize(node)
     return try {
@@ -144,8 +153,11 @@ class CustomerioNotificationClient(
 
   override fun notifyConnectionDisableWarning(
     summary: SyncSummary,
-    receiverEmail: String,
+    receiverEmail: String?,
   ): Boolean {
+    if (receiverEmail == null) {
+      return false
+    }
     val node = buildSyncCompletedJson(summary, receiverEmail, AUTO_DISABLE_WARNING_TRANSACTION_MESSAGE_ID)
     val payload = Jsons.serialize(node)
     return try {

airbyte-notification/src/main/kotlin/io/airbyte/notification/NotificationClient.kt

@@ -17,22 +17,22 @@ import java.util.UUID
 abstract class NotificationClient {
   abstract fun notifyJobFailure(
     summary: SyncSummary,
-    receiverEmail: String,
+    receiverEmail: String?,
   ): Boolean
 
   abstract fun notifyJobSuccess(
     summary: SyncSummary,
-    receiverEmail: String,
+    receiverEmail: String?,
   ): Boolean
 
   abstract fun notifyConnectionDisabled(
     summary: SyncSummary,
-    receiverEmail: String,
+    receiverEmail: String?,
   ): Boolean
 
   abstract fun notifyConnectionDisableWarning(
     summary: SyncSummary,
-    receiverEmail: String,
+    receiverEmail: String?,
   ): Boolean
 
   abstract fun notifyBreakingChangeWarning(

airbyte-notification/src/main/kotlin/io/airbyte/notification/SlackNotificationClient.kt

@@ -58,7 +58,7 @@ class SlackNotificationClient : NotificationClient {
 
   override fun notifyJobFailure(
     summary: SyncSummary,
-    receiverEmail: String,
+    receiverEmail: String?,
   ): Boolean {
     val legacyMessage: String
     try {
@@ -97,7 +97,7 @@ class SlackNotificationClient : NotificationClient {
 
   override fun notifyJobSuccess(
     summary: SyncSummary,
-    receiverEmail: String,
+    receiverEmail: String?,
   ): Boolean {
     val legacyMessage: String
     try {
@@ -136,7 +136,7 @@ class SlackNotificationClient : NotificationClient {
 
   override fun notifyConnectionDisabled(
     summary: SyncSummary,
-    receiverEmail: String,
+    receiverEmail: String?,
   ): Boolean {
     val legacyMessage: String
     try {
@@ -179,7 +179,7 @@ class SlackNotificationClient : NotificationClient {
 
   override fun notifyConnectionDisableWarning(
     summary: SyncSummary,
-    receiverEmail: String,
+    receiverEmail: String?,
   ): Boolean {
     val legacyMessage: String
     try {