fix: add source id headers (frain-dev#1715)

sweepai-dev · Jul 25, 2023 · 15444ec · 15444ec
1 parent 8fd2c23
commit 15444ec
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/api/ingest.go b/api/ingest.go
@@ -2,13 +2,14 @@ package api
 
 import (
 	"encoding/json"
-	"github.com/frain-dev/convoy/internal/pkg/dedup"
-	"github.com/go-chi/chi/v5"
-	"github.com/oklog/ulid/v2"
 	"io"
 	"net/http"
 	"time"
 
+	"github.com/frain-dev/convoy/internal/pkg/dedup"
+	"github.com/go-chi/chi/v5"
+	"github.com/oklog/ulid/v2"
+
 	"github.com/frain-dev/convoy"
 	"github.com/frain-dev/convoy/config"
 	"github.com/frain-dev/convoy/database/postgres"
@@ -164,6 +165,8 @@ func (a *ApplicationHandler) IngestEvent(w http.ResponseWriter, r *http.Request)
 		UpdatedAt:        time.Now(),
 	}
 
+	event.Headers["X-Convoy-Source-Id"] = []string{source.MaskID}
+
 	createEvent := task.CreateEvent{
 		Event: *event,
 	}