data type updates

ONSdigital · Mar 4, 2022 · 5868cf6 · 5868cf6
1 parent 3049b73
commit 5868cf6
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 7 deletions.
diff --git a/cmd/producer/main.go b/cmd/producer/main.go
@@ -72,7 +72,7 @@ func scanEvent(scanner *bufio.Scanner) *models.ContentPublished {
 
 	return &models.ContentPublished{
 		URI:      uri,
-		DataType: "Reviewed-uris",
+		DataType: "legacy",
 		TraceID:  "054435ded",
 	}
 }
diff --git a/features/publish_data.feature b/features/publish_data.feature
@@ -2,6 +2,6 @@ Feature: Data extractor should listen to the relevant topic and publish extracte
     Scenario: When searching for the extracted data I get the expected result
         Given I send a kafka event to content published topic
          | URI                | DataType             |   CollectionID  |
-         | some_uri           | Reviewed-uris        |    123          |
+         | some_uri           | legacy               |    123          |
         When The kafka event is processed
         Then I should receive the published data
diff --git a/features/steps/steps.go b/features/steps/steps.go
@@ -43,7 +43,7 @@ func (c *Component) sendKafkafkaEvent(table *godog.Table) error {
 
 func (c *Component) processKafkaEvent() error {
 	c.inputData = models.ZebedeeData{
-		DataType: "Reviewed-uris",
+		DataType: "legacy",
 		Description: models.Description{
 			CDID:      "123",
 			DatasetID: "456",

diff --git a/handler/handler.go b/handler/handler.go
@@ -17,8 +17,8 @@ import (
 
 const (
 	OnsSearchIndex  = "ONS"
-	ZebedeeDataType = "Reviewed-uris"
-	DatasetDataType = "Dataset-uris"
+	ZebedeeDataType = "legacy"
+	DatasetDataType = "datasets"
 )
 
 // ContentPublishedHandler struct to hold handle for config with zebedee, datasetAPI client and the producer

diff --git a/handler/handler_test.go b/handler/handler_test.go
@@ -26,13 +26,13 @@ var (
 
 	testZebedeeEvent = models.ContentPublished{
 		URI:          "testZebdeeUri",
-		DataType:     "Reviewed-uris",
+		DataType:     "legacy",
 		CollectionID: "testZebdeeCollectionID",
 	}
 
 	testDatasetEvent = models.ContentPublished{
 		URI:          "/datasets/cphi01/editions/timeseries/versions/version/metadata",
-		DataType:     "Dataset-uris",
+		DataType:     "datasets",
 		CollectionID: "testDatasetApiCollectionID",
 	}