add traceid into context details

cmd/producer/main.go

@@ -68,9 +68,11 @@ func scanEvent(scanner *bufio.Scanner) *models.ContentPublished {
 	fmt.Println("Please type the URI")
 	fmt.Printf("$ ")
 	scanner.Scan()
-	name := scanner.Text()
+	uri := scanner.Text()
 
 	return &models.ContentPublished{
-		URI: name,
+		URI:      uri,
+		DataType: "Reviewed-uris",
+		TraceID:  "054435ded",
 	}
 }

event/consumer.go

@@ -4,7 +4,6 @@ import (
 	"context"
 
 	kafka "github.com/ONSdigital/dp-kafka/v2"
-	dprequest "github.com/ONSdigital/dp-net/request"
 	"github.com/ONSdigital/dp-search-data-extractor/config"
 	"github.com/ONSdigital/dp-search-data-extractor/models"
 	"github.com/ONSdigital/dp-search-data-extractor/schema"
@@ -56,8 +55,11 @@ func processMessage(ctx context.Context, message kafka.Message, handler Handler,
 		return
 	}
 
+	//nolint: revive, staticcheck, gocritic
+	//TODO: This needs to be looked into log library for customised context details
+	ctx = context.WithValue(ctx, "request-id", event.TraceID)
+
 	log.Info(ctx, "event received", log.Data{"event": event})
-	ctx = dprequest.WithRequestId(ctx, event.TraceID)
 
 	// handle - commit on failure (implement error handling to not commit if message needs to be consumed again)
 	err = handler.Handle(ctx, &event, *cfg)