From 291dd742431a778c15cc569c2208dce5588d8916 Mon Sep 17 00:00:00 2001
From: Neil Alexander <neilalexander@users.noreply.github.com>
Date: Tue, 5 Jul 2022 15:57:01 +0100
Subject: [PATCH] Add some NATS breadcrumbs

---
 setup/jetstream/helpers.go | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/setup/jetstream/helpers.go b/setup/jetstream/helpers.go
index 1c07583e9..fef2faa4c 100644
--- a/setup/jetstream/helpers.go
+++ b/setup/jetstream/helpers.go
@@ -3,6 +3,7 @@ package jetstream
 import (
 	"context"
 	"fmt"
+	"time"
 
 	"github.com/getsentry/sentry-go"
 	"github.com/nats-io/nats.go"
@@ -75,6 +76,17 @@ func JetStreamConsumer(
 				continue
 			}
 			msg := msgs[0]
+			sentry.AddBreadcrumb(&sentry.Breadcrumb{
+				Type:     "nats",
+				Category: "jetstream",
+				Data: map[string]interface{}{
+					"subject": subj,
+					"durable": durable,
+					"header":  msg.Header,
+				},
+				Message:   string(msg.Data),
+				Timestamp: time.Now(),
+			})
 			if err = msg.InProgress(nats.Context(ctx)); err != nil {
 				logrus.WithContext(ctx).WithField("subject", subj).Warn(fmt.Errorf("msg.InProgress: %w", err))
 				sentry.CaptureException(err)