RSM/handlers/rmrmsghandlers/resource_status_failure_handler_test.go

   1 //
   2 // Copyright 2019 AT&T Intellectual Property
   3 // Copyright 2019 Nokia
   4 //
   5 // Licensed under the Apache License, Version 2.0 (the "License");
   6 // you may not use this file except in compliance with the License.
   7 // You may obtain a copy of the License at
   8 //
   9 //      http://www.apache.org/licenses/LICENSE-2.0
  10 //
  11 // Unless required by applicable law or agreed to in writing, software
  12 // distributed under the License is distributed on an "AS IS" BASIS,
  13 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14 // See the License for the specific language governing permissions and
  15 // limitations under the License.
  16
  17 //  This source code is part of the near-RT RIC (RAN Intelligent Controller)
  18 //  platform project (RICP).
  19
  20
  21 package rmrmsghandlers
  22
  23 // Verify UnpackX2apPduAsString() and Convert() are called
  24 /*
  25 func TestResourceStatusFailureHandlerConvertFailure(t *testing.T) {
  26         logger, err := logger.InitLogger(logger.InfoLevel)
  27         if err != nil {
  28                 t.Errorf("#... - failed to initialize logger, error: %s", err)
  29         }
  30         payload := []byte("aaa")
  31         req := models.RmrRequest{RanName: "test", StartTime: time.Now(), Payload: payload, Len: len(payload)}
  32         converterMock := mocks.ResourceStatusFailureConverterMock{}
  33         //converterMock.On("UnpackX2apPduAsString", req.Payload, e2pdus.MaxAsn1CodecMessageBufferSize).Return(string(payload), nil)
  34         converterMock.On("Convert", req.Payload).Return((*models.ResourceStatusResponse)(nil), fmt.Errorf("error"))
  35         h := NewResourceStatusFailureHandler(logger, &converterMock)
  36
  37         h.Handle(&req)
  38
  39         //converterMock.AssertNumberOfCalls(t, "UnpackX2apPduAsString", 1)
  40         converterMock.AssertNumberOfCalls(t, "Convert", 1)
  41 }
  42
  43
  44 func TestResourceStatusFailureHandlerUnpackFailure(t *testing.T) {
  45         logger, err := logger.InitLogger(logger.DebugLevel)
  46         if err != nil {
  47                 t.Errorf("#... - failed to initialize logger, error: %s", err)
  48         }
  49         payload := []byte("aaa")
  50         req := models.RmrRequest{RanName: "test", StartTime: time.Now(), Payload: payload, Len: len(payload)}
  51         converterMock := mocks.ResourceStatusFailureConverterMock{}
  52
  53         err = fmt.Errorf("error")
  54         var payloadAsString string
  55         converterMock.On("UnpackX2apPduAsString", req.Payload, e2pdus.MaxAsn1CodecMessageBufferSize).Return(payloadAsString, err)
  56         converterMock.On("Convert", req.Payload).Return((*models.ResourceStatusResponse)(nil), fmt.Errorf("error"))
  57         h := NewResourceStatusFailureHandler(logger, &converterMock)
  58
  59         h.Handle(&req)
  60
  61         converterMock.AssertNumberOfCalls(t, "UnpackX2apPduAsString", 1)
  62         converterMock.AssertNumberOfCalls(t, "Convert", 0)
  63 }
  64 */
  65
  66 /*
  67 func TestResourceStatusFailureHandler(t *testing.T) {
  68         logger, err := logger.InitLogger(logger.InfoLevel)
  69         if err != nil {
  70                 t.Errorf("#... - failed to initialize logger, error: %s", err)
  71         }
  72         unpacker := converters.NewX2apPduUnpacker(logger, e2pdus.MaxAsn1CodecMessageBufferSize)
  73         converter := converters.NewResourceStatusFailureConverter(unpacker)
  74         var payload []byte
  75         fmt.Sscanf("400900320000040027000300000e0028000300000c00054001620044401800004540130002f8290007ab500000434006000000000740", "%x", &payload)
  76         req := models.RmrRequest{RanName: "test", StartTime: time.Now(), Payload: payload, Len: len(payload)}
  77         h := NewResourceStatusFailureHandler(logger, converter)
  78
  79         h.Handle(&req)
  80 }
  81
  82 func TestResourceStatusFailureHandlerMinimalPdu(t *testing.T) {
  83         logger, err := logger.InitLogger(logger.InfoLevel)
  84         if err != nil {
  85                 t.Errorf("#... - failed to initialize logger, error: %s", err)
  86         }
  87         unpacker := converters.NewX2apPduUnpacker(logger, e2pdus.MaxAsn1CodecMessageBufferSize)
  88         converter := converters.NewResourceStatusFailureConverter(unpacker)
  89         var payload []byte
  90         fmt.Sscanf("400900170000030027000300000000280003000049000540020a80", "%x", &payload)
  91         req := models.RmrRequest{RanName: "test", StartTime: time.Now(), Payload: payload, Len: len(payload)}
  92         h := NewResourceStatusFailureHandler(logger, converter)
  93
  94         h.Handle(&req)
  95 }
  96 */