Merge "Update documentation for DMaaP Mediator Producer"
authorHenrik Andersson <henrik.b.andersson@est.tech>
Wed, 19 Jan 2022 11:49:10 +0000 (11:49 +0000)
committerGerrit Code Review <gerrit@o-ran-sc.org>
Wed, 19 Jan 2022 11:49:10 +0000 (11:49 +0000)
1  2 
dmaap-mediator-producer/internal/jobs/jobs_test.go

@@@ -38,7 -38,7 +38,7 @@@ import 
        "oransc.org/nonrtric/dmaapmediatorproducer/mocks"
  )
  
- func TestJobsManagerGetTypes_shouldReturnSliceOfTypesAndProvideSupportedTypes(t *testing.T) {
+ func TestJobsManagerLoadTypesFromConfiguration_shouldReturnSliceOfTypesAndProvideSupportedTypes(t *testing.T) {
        assertions := require.New(t)
  
        managerUnderTest := NewJobsManagerImpl(nil, "", kafkaclient.KafkaFactoryImpl{}, nil)
@@@ -388,7 -388,7 +388,7 @@@ func TestJobWithBufferedParameters_shou
        distributeClientMock := NewTestClient(func(req *http.Request) *http.Response {
                if req.URL.String() == "http://consumerHost/target" {
                        assertions.Equal(req.Method, "POST")
 -                      assertions.Equal(`"[{\"data\": 1},{\"data\": 2}]"`, getBodyAsString(req, t))
 +                      assertions.Equal(`["{\"data\": 1}","{\"data\": 2}","ABCDEFGH"]`, getBodyAsString(req, t))
                        assertions.Equal("application/json", req.Header.Get("Content-Type"))
                        wg.Done()
                        return &http.Response{
        go func() {
                jobUnderTest.messagesChannel <- []byte(`{"data": 1}`)
                jobUnderTest.messagesChannel <- []byte(`{"data": 2}`)
 +              jobUnderTest.messagesChannel <- []byte("ABCDEFGH")
        }()
  
        if waitTimeout(&wg, 2*time.Second) {
@@@ -443,7 -442,7 +443,7 @@@ func TestJobReadMoreThanBufferSizeMessa
                MaxTimeMiliseconds: 200,
        })
  
 -      assertions.Equal([]byte("\"[0,1]\""), msgs)
 +      assertions.Equal([]byte("[\"0\",\"1\"]"), msgs)
  }
  func TestJobReadBufferedWhenTimeout_shouldOnlyReturnMessagesSentBeforeTimeout(t *testing.T) {
        assertions := require.New(t)
                MaxTimeMiliseconds: 30,
        })
  
 -      assertions.Equal([]byte("\"[0,1]\""), msgs)
 +      assertions.Equal([]byte("[\"0\",\"1\"]"), msgs)
  }
  
  func fillMessagesBuffer(mc chan []byte) {