1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
package org.onap.ccsdk.cds.blueprintsprocessor.core.utils
import org.junit.Assert
import org.junit.Test
import org.junit.runner.RunWith
import org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.Flags
import org.onap.ccsdk.cds.controllerblueprints.common.api.ActionIdentifiers
import org.onap.ccsdk.cds.controllerblueprints.common.api.CommonHeader
import org.onap.ccsdk.cds.controllerblueprints.common.api.EventType
import org.onap.ccsdk.cds.controllerblueprints.common.api.Flag
import org.onap.ccsdk.cds.controllerblueprints.core.utils.currentTimestamp
import org.springframework.test.context.junit4.SpringRunner
import java.text.SimpleDateFormat
@RunWith(SpringRunner::class)
class BluePrintMappingsTest {
val formatter = SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'")
val dateString = "2019-01-16T18:25:43.511Z"
val dateForTest = formatter.parse(dateString)
val flag = Flag.newBuilder().setIsForce(false).setTtl(1).build()
fun createFlag(): Flags {
val flag = Flags()
flag.isForce = false
flag.ttl = 1
return flag
}
@Test
fun flagToJavaTest() {
val flag2 = flag.toJava()
Assert.assertEquals(flag.isForce, flag2.isForce)
Assert.assertEquals(flag.ttl, flag2.ttl)
}
@Test
fun flagToProtoTest() {
val flag = createFlag()
val flag2 = flag.toProto()
Assert.assertEquals(flag.isForce, flag2.isForce)
Assert.assertEquals(flag.ttl, flag2.ttl)
}
fun createStatus(): org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.Status {
val status = org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.Status()
status.code = 400
status.errorMessage = "Concurrent modification exception"
status.eventType = EventType.EVENT_COMPONENT_PROCESSING.name
status.message = "Error uploading data"
status.timestamp = dateForTest
return status
}
@Test
fun statusToProtoTest() {
val status = createStatus()
val status2 = status.toProto()
Assert.assertEquals(status.code, status2.code)
Assert.assertEquals(status.errorMessage, status2.errorMessage)
Assert.assertEquals(status.eventType, status2.eventType.name)
Assert.assertEquals(status.message, status2.message)
Assert.assertEquals(status.timestamp.toString(), status2.timestamp)
}
@Test
fun commonHeaderToJavaTest() {
val flag = Flag.newBuilder().setIsForce(true).setTtl(2).build()
val commonHeader =
CommonHeader.newBuilder().setOriginatorId("Origin").setRequestId("requestID").setSubRequestId("subRequestID").setTimestamp(dateString)
.setFlag(flag).build()
val commonHeader2 = commonHeader.toJava()
Assert.assertEquals(commonHeader.originatorId, commonHeader2.originatorId)
Assert.assertEquals(commonHeader.requestId, commonHeader2.requestId)
Assert.assertEquals(commonHeader.subRequestId, commonHeader2.subRequestId)
Assert.assertEquals(commonHeader.timestamp, formatter.format(commonHeader2.timestamp))
}
fun createCommonHeader(): org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.CommonHeader {
val commonHeader = org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.CommonHeader()
commonHeader.flags = createFlag()
commonHeader.originatorId = "1234"
commonHeader.requestId = "2345"
commonHeader.subRequestId = "0123"
commonHeader.timestamp = dateForTest
return commonHeader
}
@Test
fun commonHeaderToProtoTest() {
val commonHeader = createCommonHeader()
val commonHeader2 = commonHeader.toProto()
Assert.assertEquals(commonHeader.originatorId, commonHeader2.originatorId)
Assert.assertEquals(commonHeader.requestId, commonHeader2.requestId)
Assert.assertEquals(commonHeader.subRequestId, commonHeader2.subRequestId)
Assert.assertEquals(commonHeader.timestamp.currentTimestamp(), commonHeader2.timestamp)
}
@Test
fun actionIdentifierToJavaTest() {
val actionIdentifiers =
ActionIdentifiers.newBuilder().setActionName("Process Action").setBlueprintName("BlueprintName").setBlueprintVersion("3.0")
.setMode("Execution").build()
val actionIdentifiers2 = actionIdentifiers.toJava()
Assert.assertEquals(actionIdentifiers.actionName, actionIdentifiers2.actionName)
Assert.assertEquals(actionIdentifiers.blueprintName, actionIdentifiers2.blueprintName)
Assert.assertEquals(actionIdentifiers.blueprintVersion, actionIdentifiers2.blueprintVersion)
Assert.assertEquals(actionIdentifiers.mode, actionIdentifiers2.mode)
}
fun createActionIdentifier(): org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.ActionIdentifiers {
val ac = org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.ActionIdentifiers()
ac.mode = "mode"
ac.blueprintVersion = "version"
ac.blueprintName = "name"
ac.actionName = "action"
return ac
}
@Test
fun actionIdentifierToProtoTest() {
val actionIdentifiers = createActionIdentifier()
val actionIdentifiers2 = actionIdentifiers.toProto()
Assert.assertEquals(actionIdentifiers.actionName, actionIdentifiers2.actionName)
Assert.assertEquals(actionIdentifiers.blueprintName, actionIdentifiers2.blueprintName)
Assert.assertEquals(actionIdentifiers.blueprintVersion, actionIdentifiers2.blueprintVersion)
Assert.assertEquals(actionIdentifiers.mode, actionIdentifiers2.mode)
}
}
|
