4602eaae2faa05fc57281d2613c442b96d877d8c
[nonrtric/rapp/ransliceassurance.git] / messageHandler_test.go
1 // -
2 //   ========================LICENSE_START=================================
3 //   O-RAN-SC
4 //   %%
5 //   Copyright (C) 2022: Nordix Foundation
6 //   %%
7 //   Licensed under the Apache License, Version 2.0 (the "License");
8 //   you may not use this file except in compliance with the License.
9 //   You may obtain a copy of the License at
10 //
11 //        http://www.apache.org/licenses/LICENSE-2.0
12 //
13 //   Unless required by applicable law or agreed to in writing, software
14 //   distributed under the License is distributed on an "AS IS" BASIS,
15 //   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 //   See the License for the specific language governing permissions and
17 //   limitations under the License.
18 //   ========================LICENSE_END===================================
19 //
20
21 package sliceassurance
22
23 import (
24         "reflect"
25         "testing"
26
27         "oransc.org/usecase/oduclosedloop/icsversion/messages"
28 )
29
30 func TestGetStdDefinedMessages(t *testing.T) {
31         type args struct {
32                 messageStrings *[]string
33         }
34         tests := []struct {
35                 name string
36                 args args
37                 want []messages.StdDefinedMessage
38         }{
39                 {
40                         name: "",
41                         args: args{
42                                 messageStrings: &[]string{
43                                         `{"event":{"commonEventHeader":{"domain":"stnd","eventId":"pm-1","eventName":"stndDefined","eventType":"performanceMeasurementStreaming","sequence":825,"priority":"Low","reportingEntityId":"","reportingEntityName":"O-DU-1122","sourceId":"","sourceName":"O-DU-1122","stndDefinedNamespace":"o-ran-sc-du-hello-world","version":"4.1","vesEventListenerVersion":"7.2.1"},"stndDefinedFields":{"stndDefinedFieldsVersion":"1.0","schemaReference":"o-ran-sc-du-hello-world","data":{"id":"pm-1_123","administrative-state":"unlocked","operational-state":"enabled","user-label":"pm","job-tag":"my-job-tag","granularity-period":30,"measurements":[{"measurement-type-instance-reference":"reference","value":5861,"unit":"kbit/s"}]}}}}`,
44                                 },
45                         },
46                         want: []messages.StdDefinedMessage{{
47                                 Event: messages.Event{
48                                         CommonEventHeader: messages.CommonEventHeader{
49                                                 Domain:                  "stnd",
50                                                 EventId:                 "pm-1",
51                                                 EventName:               "stndDefined",
52                                                 EventType:               "performanceMeasurementStreaming",
53                                                 Sequence:                825,
54                                                 Priority:                "Low",
55                                                 ReportingEntityName:     "O-DU-1122",
56                                                 SourceName:              "O-DU-1122",
57                                                 StndDefinedNamespace:    "o-ran-sc-du-hello-world",
58                                                 Version:                 "4.1",
59                                                 VesEventListenerVersion: "7.2.1",
60                                         },
61                                         StndDefinedFields: messages.StndDefinedFields{
62                                                 StndDefinedFieldsVersion: "1.0",
63                                                 SchemaReference:          "o-ran-sc-du-hello-world",
64                                                 Data: messages.Data{
65                                                         DataId:              "pm-1_123",
66                                                         AdministrativeState: "unlocked",
67                                                         OperationalState:    "enabled",
68                                                         UserLabel:           "pm",
69                                                         JobTag:              "my-job-tag",
70                                                         GranularityPeriod:   30,
71                                                         Measurements: []messages.Measurement{{
72                                                                 MeasurementTypeInstanceReference: "reference",
73                                                                 Value:                            5861,
74                                                                 Unit:                             "kbit/s",
75                                                         }},
76                                                 },
77                                         },
78                                 },
79                         }},
80                 },
81         }
82         for _, tt := range tests {
83                 t.Run(tt.name, func(t *testing.T) {
84                         if got := getStdMessages(tt.args.messageStrings); !reflect.DeepEqual(got, tt.want) {
85                                 t.Errorf("getStdMessages() = %v, want %v", got, tt.want)
86                         }
87                 })
88         }
89 }