fix: fixed wrong source name showing in event log

frain-dev · Oct 26, 2023 · 7df5a17 · 7df5a17
1 parent 899f542
commit 7df5a17
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/internal/pkg/pubsub/source_loader.go b/internal/pkg/pubsub/source_loader.go
@@ -144,6 +144,7 @@ func (s *SourceLoader) handler(ctx context.Context, source *datastore.Source, ms
 	ce := task.CreateEvent{
 		Params: task.CreateEventTaskParams{
 			UID:            ulid.Make().String(),
+			SourceID:       source.UID,
 			ProjectID:      source.ProjectID,
 			EndpointID:     ev.EndpointID,
 			EventType:      ev.EventType,

diff --git a/worker/task/process_event_creation.go b/worker/task/process_event_creation.go
@@ -5,9 +5,10 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"time"
+
 	"github.com/frain-dev/convoy/pkg/msgpack"
 	"github.com/frain-dev/convoy/util"
-	"time"
 
 	"github.com/frain-dev/convoy"
 	"github.com/frain-dev/convoy/datastore"
@@ -411,6 +412,7 @@ func buildEvent(ctx context.Context, eventRepo datastore.EventRepository, endpoi
 		CreatedAt:        time.Now(),
 		UpdatedAt:        time.Now(),
 		Endpoints:        endpointIDs,
+		SourceID:         eventParams.SourceID,
 		ProjectID:        project.UID,
 	}