ms/blueprintsprocessor/modules/commons/processor-core/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/core/utils/BlueprintMappingsTest.kt

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