Forward action output to sinks

kubeshop · Jan 10, 2024 · 6eedab3 · 6eedab3
1 parent 28ef1c7
commit 6eedab3
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/internal/source/dispatcher.go b/internal/source/dispatcher.go
@@ -259,7 +259,16 @@ func (d *Dispatcher) dispatchMsg(ctx context.Context, event source.Event, dispat
 				defer analytics.ReportPanicIfOccurs(d.log, d.reporter)
 				err := n.SendMessage(ctx, genericMsg, sources)
 				if err != nil {
-					d.log.Errorf("while sending action result message: %s", err.Error())
+					d.log.Errorf("while sending action result to %q bot: %s", n.IntegrationName(), err.Error())
+				}
+			}(n)
+		}
+
+		for _, n := range d.getSinkNotifiers(dispatch) {
+			go func(n notifier.Sink) {
+				err := n.SendEvent(ctx, genericMsg, sources)
+				if err != nil {
+					d.log.Errorf("while sending action result to %q sink: %s", n.IntegrationName(), err.Error())
 				}
 			}(n)
 		}