Skip to content

Commit

Permalink
change to make test clearer
Browse files Browse the repository at this point in the history
  • Loading branch information
galiri committed May 31, 2018
1 parent e346bc1 commit a8d684a
Showing 1 changed file with 12 additions and 10 deletions.
22 changes: 12 additions & 10 deletions service/message_handler_test.go
Expand Up @@ -187,9 +187,8 @@ func TestHandleWriteMessage(t *testing.T) {
func TestHandleWriteMessageSparkHeader(t *testing.T) {
assert := assert.New(t)

inputJSON, err := ioutil.ReadFile("testdata/exampleEnrichedContentModel.json")
input, err :=modifyTestInputAuthority("invalid")
assert.NoError(err, "Unexpected error")
input := strings.Replace(string(inputJSON), "FTCOM-METHODE", "invalid", 1)

serviceMock := &esServiceMock{}
serviceMock.On("WriteData", "FTCom", "aae9611e-f66c-4fe4-a6c6-2e2bdea69060", mock.Anything).Return(&elastic.IndexResult{}, nil)
Expand All @@ -206,9 +205,8 @@ func TestHandleWriteMessageSparkHeader(t *testing.T) {
func TestHandleWriteMessageBlog(t *testing.T) {
assert := assert.New(t)

inputJSON, err := ioutil.ReadFile("testdata/exampleEnrichedContentModel.json")
input, err :=modifyTestInputAuthority("FT-LABS-WP1234")
assert.NoError(err, "Unexpected error")
input := strings.Replace(string(inputJSON), "FTCOM-METHODE", "FT-LABS-WP1234", 1)

serviceMock := &esServiceMock{}
serviceMock.On("WriteData", "FTBlogs", "aae9611e-f66c-4fe4-a6c6-2e2bdea69060", mock.Anything).Return(&elastic.IndexResult{}, nil)
Expand All @@ -225,9 +223,8 @@ func TestHandleWriteMessageBlog(t *testing.T) {
func TestHandleWriteMessageBlogWithHeader(t *testing.T) {
assert := assert.New(t)

inputJSON, err := ioutil.ReadFile("testdata/exampleEnrichedContentModel.json")
input, err :=modifyTestInputAuthority("invalid")
assert.NoError(err, "Unexpected error")
input := strings.Replace(string(inputJSON), "FTCOM-METHODE", "invalid", 1)

serviceMock := &esServiceMock{}
serviceMock.On("WriteData", "FTBlogs", "aae9611e-f66c-4fe4-a6c6-2e2bdea69060", mock.Anything).Return(&elastic.IndexResult{}, nil)
Expand All @@ -244,9 +241,8 @@ func TestHandleWriteMessageBlogWithHeader(t *testing.T) {
func TestHandleWriteMessageVideo(t *testing.T) {
assert := assert.New(t)

inputJSON, err := ioutil.ReadFile("testdata/exampleEnrichedContentModel.json")
input, err :=modifyTestInputAuthority("NEXT-VIDEO-EDITOR")
assert.NoError(err, "Unexpected error")
input := strings.Replace(string(inputJSON), "FTCOM-METHODE", "NEXT-VIDEO-EDITOR", 1)

serviceMock := &esServiceMock{}
serviceMock.On("WriteData", "FTVideos", "aae9611e-f66c-4fe4-a6c6-2e2bdea69060", mock.Anything).Return(&elastic.IndexResult{}, nil)
Expand Down Expand Up @@ -303,9 +299,8 @@ func TestHandleWriteMessageNoType(t *testing.T) {

hook := logTest.NewTestHook("content-rw-elasticsearch")

inputJSON, err := ioutil.ReadFile("testdata/exampleEnrichedContentModel.json")
input, err :=modifyTestInputAuthority("invalid")
assert.NoError(err, "Unexpected error")
input := strings.Replace(string(inputJSON), "FTCOM-METHODE", "invalid", 1)

serviceMock := &esServiceMock{}

Expand Down Expand Up @@ -408,3 +403,10 @@ func TestHandleSyntheticMessage(t *testing.T) {
serviceMock.AssertNotCalled(t, "WriteData", mock.Anything, mock.Anything, mock.Anything)
serviceMock.AssertNotCalled(t, "DeleteData", mock.Anything, mock.Anything)
}

func modifyTestInputAuthority(replacement string) (string, error) {

inputJSON, err := ioutil.ReadFile("testdata/exampleEnrichedContentModel.json")
input := strings.Replace(string(inputJSON), "FTCOM-METHODE", replacement, 1)
return input, err
}

0 comments on commit a8d684a

Please sign in to comment.