2 * ============LICENSE_START=======================================================
3 * dcaegen2-collectors-veshv
4 * ================================================================================
5 * Copyright (C) 2019 NOKIA
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
11 * http://www.apache.org/licenses/LICENSE-2.0
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=========================================================
20 package org.onap.dcae.collectors.veshv.ves.message.generator.impl.wireframe
22 import org.onap.dcae.collectors.veshv.domain.ByteData
23 import org.onap.dcae.collectors.veshv.domain.PayloadContentType
24 import org.onap.dcae.collectors.veshv.domain.WireFrameMessage
25 import org.onap.dcae.collectors.veshv.ves.message.generator.api.MessageGenerator
26 import org.onap.dcae.collectors.veshv.ves.message.generator.api.WireFrameParameters
27 import org.onap.dcae.collectors.veshv.ves.message.generator.api.WireFrameType
28 import org.onap.dcae.collectors.veshv.ves.message.generator.api.WireFrameType.INVALID_GPB_DATA
29 import org.onap.dcae.collectors.veshv.ves.message.generator.api.WireFrameType.INVALID_WIRE_FRAME
30 import org.onap.ves.VesEventOuterClass.VesEvent
31 import reactor.core.publisher.Flux
32 import reactor.core.publisher.Mono
33 import java.nio.charset.Charset
36 * @author Jakub Dudycz <jakub.dudycz@nokia.com>
37 * @since February 2019
39 class WireFrameGenerator : MessageGenerator<WireFrameParameters, WireFrameMessage>() {
41 override fun createMessageFlux(parameters: WireFrameParameters): Flux<WireFrameMessage> =
44 .fromCallable { createMessage(messageType) }
45 .let { repeatMessage(it, amount) }
48 private fun createMessage(messageType: WireFrameType): WireFrameMessage =
50 INVALID_WIRE_FRAME -> {
51 val payload = ByteData(VesEvent.getDefaultInstance().toByteArray())
56 PayloadContentType.GOOGLE_PROTOCOL_BUFFER.hexValue,
60 WireFrameMessage("invalid vesEvent".toByteArray(Charset.defaultCharset()))
64 private const val UNSUPPORTED_VERSION: Short = 2