<junit-jupiter.version>5.3.1</junit-jupiter.version>
<junit-vintage.version>5.3.1</junit-vintage.version>
<junit-platform.version>1.3.1</junit-platform.version>
- <immutables.version>2.7.3</immutables.version>
+ <immutables.version>2.7.4</immutables.version>
<assertj-core.version>3.11.1</assertj-core.version>
<reactor.bom.version>Californium-SR4</reactor.bom.version>
<slf4j.version>1.7.25</slf4j.version>
package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.streams;
-import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.KafkaSinkParser;
-import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.KafkaSourceParser;
-import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.KafkaSink;
-import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.KafkaSource;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.*;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.*;
/**
* @author <a href="mailto:piotr.jaszczyk@nokia.com">Piotr Jaszczyk</a>
public static StreamFromGsonParser<KafkaSource> kafkaSourceParser() {
return KafkaSourceParser.create();
}
+
+ public static StreamFromGsonParser<MessageRouterSink> messageRouterSinkParser() {
+ return MessageRouterSinkParser.create();
+ }
+
+ public static StreamFromGsonParser<MessageRouterSource> messageRouterSourceParser() {
+ return MessageRouterSourceParser.create();
+ }
+
+ public static StreamFromGsonParser<DataRouterSink> dataRouterSinkParser() {
+ return DataRouterSinkParser.create();
+ }
+
+ public static StreamFromGsonParser<DataRouterSource> dataRouterSourceParser() {
+ return DataRouterSourceParser.create();
+ }
}
--- /dev/null
+/*
+ * ============LICENSE_START====================================
+ * DCAEGEN2-SERVICES-SDK
+ * =========================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * =========================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=====================================
+ */
+package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson;
+
+import com.google.gson.Gson;
+import com.google.gson.JsonElement;
+import com.google.gson.JsonObject;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.streams.StreamFromGsonParser;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.DataRouterSink;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.ImmutableDataRouterSink;
+
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.DATA_ROUTER_TYPE;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.GsonUtils.*;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.DMAAP_INFO_CHILD_NAME;
+
+/**
+ * @author <a href="mailto:kornel.janiak@nokia.com">Kornel Janiak</a>
+ */
+
+public final class DataRouterSinkParser implements StreamFromGsonParser<DataRouterSink> {
+ private final Gson gson;
+
+ public static DataRouterSinkParser create() {
+ return new DataRouterSinkParser(gsonInstance());
+ }
+
+ private DataRouterSinkParser(Gson gson) {
+ this.gson = gson;
+ }
+
+ public DataRouterSink unsafeParse(JsonObject input) {
+ assertStreamType(input, DATA_ROUTER_TYPE);
+
+ final JsonElement dmaapInfoJson = requiredChild(input, DMAAP_INFO_CHILD_NAME);
+
+ return gson.fromJson(dmaapInfoJson, ImmutableDataRouterSink.class);
+
+ }
+
+}
\ No newline at end of file
--- /dev/null
+/*
+ * ============LICENSE_START====================================
+ * DCAEGEN2-SERVICES-SDK
+ * =========================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * =========================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=====================================
+ */
+package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson;
+
+import com.google.gson.Gson;
+import com.google.gson.JsonElement;
+import com.google.gson.JsonObject;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.streams.StreamFromGsonParser;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.DataRouterSource;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.ImmutableDataRouterSource;
+
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.GsonUtils.*;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.DATA_ROUTER_TYPE;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.DMAAP_INFO_CHILD_NAME;
+
+/**
+ * @author <a href="mailto:kornel.janiak@nokia.com">Kornel Janiak</a>
+ */
+
+public final class DataRouterSourceParser implements StreamFromGsonParser<DataRouterSource> {
+ private final Gson gson;
+
+ public static DataRouterSourceParser create() {
+ return new DataRouterSourceParser(gsonInstance());
+ }
+
+ private DataRouterSourceParser(Gson gson) {
+ this.gson = gson;
+ }
+
+ public DataRouterSource unsafeParse(JsonObject input) {
+ assertStreamType(input, DATA_ROUTER_TYPE);
+
+ final JsonElement dmaapInfoJson = requiredChild(input, DMAAP_INFO_CHILD_NAME);
+
+ return gson.fromJson(dmaapInfoJson, ImmutableDataRouterSource.class);
+
+ }
+
+}
\ No newline at end of file
import org.jetbrains.annotations.Nullable;
import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.AafCredentials;
import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.Kafka;
-import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.KafkaSource;
/**
* @author <a href="mailto:piotr.jaszczyk@nokia.com">Piotr Jaszczyk</a>
--- /dev/null
+/*
+ * ============LICENSE_START====================================
+ * DCAEGEN2-SERVICES-SDK
+ * =========================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * =========================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=====================================
+ */
+package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson;
+
+import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.AafCredentials;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.MessageRouter;
+
+import java.util.Objects;
+
+/**
+ * @author <a href="mailto:kornel.janiak@nokia.com">Kornel Janiak</a>
+ */
+
+abstract class GsonMessageRouter implements MessageRouter {
+ private final MessageRouterDmaapInfo dmaapInfo;
+ private final AafCredentials aafCredentials;
+
+ GsonMessageRouter(@NotNull MessageRouterDmaapInfo dmaapInfo,
+ @Nullable AafCredentials aafCredentials) {
+ this.dmaapInfo = Objects.requireNonNull(dmaapInfo, "dmaapInfo");
+ this.aafCredentials = aafCredentials;
+ }
+
+ @Override
+ public String topicUrl() {
+ return dmaapInfo.topicUrl();
+ }
+
+ @Override
+ public @Nullable String clientRole() {
+ return dmaapInfo.clientRole();
+ }
+
+ @Override
+ public @Nullable String clientId() {
+ return dmaapInfo.clientId();
+ }
+
+ @Override
+ public @Nullable String location() {
+ return dmaapInfo.location();
+ }
+
+ @Override
+ public @Nullable AafCredentials aafCredentials() {
+ return aafCredentials;
+ }
+}
\ No newline at end of file
--- /dev/null
+/*
+ * ============LICENSE_START====================================
+ * DCAEGEN2-SERVICES-SDK
+ * =========================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * =========================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=====================================
+ */
+package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson;
+
+import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.AafCredentials;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.MessageRouterSink;
+
+/**
+ * @author <a href="mailto:kornel.janiak@nokia.com">Kornel Janiak</a>
+ */
+
+public class GsonMessageRouterSink extends GsonMessageRouter implements MessageRouterSink {
+ GsonMessageRouterSink(
+ @NotNull MessageRouterDmaapInfo dmaapInfo,
+ @Nullable AafCredentials aafCredentials) {
+ super(dmaapInfo, aafCredentials);
+ }
+}
\ No newline at end of file
--- /dev/null
+/*
+ * ============LICENSE_START====================================
+ * DCAEGEN2-SERVICES-SDK
+ * =========================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * =========================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=====================================
+ */
+package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson;
+
+import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.AafCredentials;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.MessageRouterSource;
+
+/**
+ * @author <a href="mailto:kornel.janiak@nokia.com">Kornel Janiak</a>
+ */
+
+public class GsonMessageRouterSource extends GsonMessageRouter implements MessageRouterSource {
+ GsonMessageRouterSource(
+ @NotNull MessageRouterDmaapInfo dmaapInfo,
+ @Nullable AafCredentials aafCredentials) {
+ super(dmaapInfo, aafCredentials);
+ }
+}
\ No newline at end of file
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import io.vavr.Lazy;
+
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.Reader;
import java.util.Map.Entry;
-import java.util.concurrent.atomic.AtomicReference;
import java.util.stream.Collectors;
+
+import io.vavr.control.Option;
import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.GsonAdaptersAafCredentials;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.GsonAdaptersDataRouterSink;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.GsonAdaptersDataRouterSource;
/**
* @author <a href="mailto:piotr.jaszczyk@nokia.com">Piotr Jaszczyk</a>
GsonBuilder gsonBuilder = new GsonBuilder();
gsonBuilder.registerTypeAdapterFactory(new GsonAdaptersKafkaInfo());
gsonBuilder.registerTypeAdapterFactory(new GsonAdaptersAafCredentials());
+ gsonBuilder.registerTypeAdapterFactory(new GsonAdaptersMessageRouterDmaapInfo());
+ gsonBuilder.registerTypeAdapterFactory(new GsonAdaptersDataRouterSink());
+ gsonBuilder.registerTypeAdapterFactory(new GsonAdaptersDataRouterSource());
return gsonBuilder.create();
});
return requiredChild(parent, childName).getAsString();
}
+ static Option<String> optionalString(JsonObject parent, String childName) {
+ return Option.of(parent.get(childName).getAsString());
+ }
+
static JsonElement requiredChild(JsonObject parent, String childName) {
if (parent.has(childName)) {
return parent.get(childName);
package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson;
-import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.GsonUtils.assertStreamType;
-import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.GsonUtils.gsonInstance;
-import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.GsonUtils.requiredChild;
-
import com.google.gson.Gson;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;
import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.streams.StreamFromGsonParser;
import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.KafkaSink;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.GsonUtils.*;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.KAFKA_INFO_CHILD_NAME;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.KAFKA_TYPE;
+
/**
* @author <a href="mailto:piotr.jaszczyk@nokia.com">Piotr Jaszczyk</a>
* @since 1.1.4
*/
-public class KafkaSinkParser implements StreamFromGsonParser<KafkaSink> {
-
+public final class KafkaSinkParser implements StreamFromGsonParser<KafkaSink> {
private final Gson gson;
public static KafkaSinkParser create() {
return new KafkaSinkParser(gsonInstance());
}
- KafkaSinkParser(Gson gson) {
+ private KafkaSinkParser(Gson gson) {
this.gson = gson;
}
@Override
public KafkaSink unsafeParse(JsonObject input) {
- assertStreamType(input, "kafka");
+ assertStreamType(input, KAFKA_TYPE);
- final JsonElement kafkaInfoJson = requiredChild(input, "kafka_info");
+ final JsonElement kafkaInfoJson = requiredChild(input, KAFKA_INFO_CHILD_NAME);
final KafkaInfo kafkaInfo = gson.fromJson(kafkaInfoJson, ImmutableKafkaInfo.class);
return new GsonKafkaSink(kafkaInfo, null);
package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson;
-import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.GsonUtils.assertStreamType;
-import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.GsonUtils.gsonInstance;
-import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.GsonUtils.requiredChild;
-
import com.google.gson.Gson;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;
import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.streams.StreamFromGsonParser;
import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.KafkaSource;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.GsonUtils.*;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.KAFKA_INFO_CHILD_NAME;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.KAFKA_TYPE;
+
/**
* @author <a href="mailto:piotr.jaszczyk@nokia.com">Piotr Jaszczyk</a>
* @since 1.1.4
*/
-public class KafkaSourceParser implements StreamFromGsonParser<KafkaSource> {
+public final class KafkaSourceParser implements StreamFromGsonParser<KafkaSource> {
private final Gson gson;
public static KafkaSourceParser create() {
return new KafkaSourceParser(gsonInstance());
}
- KafkaSourceParser(Gson gson) {
+ private KafkaSourceParser(Gson gson) {
this.gson = gson;
}
@Override
public KafkaSource unsafeParse(JsonObject input) {
- assertStreamType(input, "kafka");
+ assertStreamType(input, KAFKA_TYPE);
- final JsonElement kafkaInfoJson = requiredChild(input, "kafka_info");
+ final JsonElement kafkaInfoJson = requiredChild(input, KAFKA_INFO_CHILD_NAME);
final KafkaInfo kafkaInfo = gson.fromJson(kafkaInfoJson, ImmutableKafkaInfo.class);
return new GsonKafkaSource(kafkaInfo, null);
--- /dev/null
+/*
+ * ============LICENSE_START====================================
+ * DCAEGEN2-SERVICES-SDK
+ * =========================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * =========================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=====================================
+ */
+package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson;
+
+import com.google.gson.annotations.SerializedName;
+import org.immutables.gson.Gson;
+import org.immutables.value.Value;
+import org.jetbrains.annotations.Nullable;
+
+@Gson.TypeAdapters
+@Value.Immutable
+public interface MessageRouterDmaapInfo {
+
+ @SerializedName("topic_url")
+ String topicUrl();
+
+ @SerializedName("client_role")
+ @Nullable String clientRole();
+
+ @SerializedName("client_id")
+ @Nullable String clientId();
+
+ @SerializedName("location")
+ @Nullable String location();
+}
--- /dev/null
+/*
+ * ============LICENSE_START====================================
+ * DCAEGEN2-SERVICES-SDK
+ * =========================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * =========================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=====================================
+ */
+package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson;
+
+import com.google.gson.Gson;
+import com.google.gson.JsonElement;
+import com.google.gson.JsonObject;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.streams.StreamFromGsonParser;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.AafCredentials;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.ImmutableAafCredentials;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.MessageRouterSink;
+
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.DMAAP_INFO_CHILD_NAME;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.MESSAGE_ROUTER_TYPE;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.GsonUtils.*;
+
+public final class MessageRouterSinkParser implements StreamFromGsonParser<MessageRouterSink> {
+
+ private final Gson gson;
+
+ public static MessageRouterSinkParser create() {
+ return new MessageRouterSinkParser(gsonInstance());
+ }
+
+ private MessageRouterSinkParser(Gson gson) {
+ this.gson = gson;
+ }
+
+ public MessageRouterSink unsafeParse(JsonObject input) {
+ assertStreamType(input, MESSAGE_ROUTER_TYPE);
+
+ final AafCredentials aafCredentials = gson.fromJson(input, ImmutableAafCredentials.class);
+
+ final JsonElement dmaapInfoJson = requiredChild(input, DMAAP_INFO_CHILD_NAME);
+ final MessageRouterDmaapInfo dmaapInfo = gson.fromJson(dmaapInfoJson, ImmutableMessageRouterDmaapInfo.class);
+
+ return new GsonMessageRouterSink(dmaapInfo, aafCredentials);
+
+ }
+}
--- /dev/null
+/*
+ * ============LICENSE_START====================================
+ * DCAEGEN2-SERVICES-SDK
+ * =========================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * =========================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=====================================
+ */
+package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson;
+
+import com.google.gson.Gson;
+import com.google.gson.JsonElement;
+import com.google.gson.JsonObject;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.streams.StreamFromGsonParser;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.AafCredentials;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.ImmutableAafCredentials;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.MessageRouterSource;
+
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.GsonUtils.*;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.DMAAP_INFO_CHILD_NAME;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.MESSAGE_ROUTER_TYPE;
+
+/**
+ * @author <a href="mailto:kornel.janiak@nokia.com">Kornel Janiak</a>
+ */
+
+public final class MessageRouterSourceParser implements StreamFromGsonParser<MessageRouterSource> {
+ private final Gson gson;
+
+ public static MessageRouterSourceParser create() {
+ return new MessageRouterSourceParser(gsonInstance());
+ }
+
+ private MessageRouterSourceParser(Gson gson) {
+ this.gson = gson;
+ }
+
+ public MessageRouterSource unsafeParse(JsonObject input) {
+ assertStreamType(input, MESSAGE_ROUTER_TYPE);
+
+ final AafCredentials aafCredentials = gson.fromJson(input, ImmutableAafCredentials.class);
+
+ final JsonElement dmaapInfoJson = requiredChild(input, DMAAP_INFO_CHILD_NAME);
+ final MessageRouterDmaapInfo dmaapInfo = gson.fromJson(dmaapInfoJson, ImmutableMessageRouterDmaapInfo.class);
+
+ return new GsonMessageRouterSource(dmaapInfo, aafCredentials);
+
+ }
+
+}
\ No newline at end of file
--- /dev/null
+/*
+ * ============LICENSE_START====================================
+ * DCAEGEN2-SERVICES-SDK
+ * =========================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * =========================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=====================================
+ */
+package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson;
+
+/**
+ * @author <a href="mailto:kornel.janiak@nokia.com">Kornel Janiak</a>
+ */
+
+public final class StreamsConstants {
+
+ public static final String DATA_ROUTER_TYPE = "data_router";
+
+ public static final String MESSAGE_ROUTER_TYPE = "message_router";
+
+ public static final String KAFKA_TYPE = "kafka";
+
+ public static final String DMAAP_INFO_CHILD_NAME = "dmaap_info";
+
+ public static final String KAFKA_INFO_CHILD_NAME = "kafka_info";
+
+}
\ No newline at end of file
package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams;
+import com.google.gson.annotations.SerializedName;
import org.immutables.gson.Gson;
import org.immutables.value.Value;
import org.jetbrains.annotations.Nullable;
@Gson.TypeAdapters
public interface AafCredentials {
+ @SerializedName("aaf_username")
@Nullable String username();
+ @SerializedName("aaf_password")
@Nullable String password();
}
package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap;
+import com.google.gson.annotations.SerializedName;
import org.jetbrains.annotations.Nullable;
import org.onap.dcaegen2.services.sdk.rest.services.annotations.ExperimentalApi;
@ExperimentalApi
public interface DataRouter {
- String location();
+ @SerializedName("location")
+ @Nullable String location();
+ @SerializedName("username")
@Nullable String username();
+ @SerializedName("password")
@Nullable String password();
}
package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap;
+import com.google.gson.annotations.SerializedName;
+import org.immutables.gson.Gson;
import org.immutables.value.Value;
import org.jetbrains.annotations.Nullable;
import org.onap.dcaegen2.services.sdk.rest.services.annotations.ExperimentalApi;
* @author <a href="mailto:piotr.jaszczyk@nokia.com">Piotr Jaszczyk</a>
* @version 1.2.1
*/
+@Gson.TypeAdapters
@ExperimentalApi
@Value.Immutable
-public abstract class DataRouterSink implements DataRouter, SinkStream {
+public interface DataRouterSink extends DataRouter, SinkStream {
- abstract String publisherUrl();
+ @SerializedName("publish_url")
+ String publishUrl();
- abstract String publisherId();
+ @SerializedName("publisher_id")
+ @Nullable String publisherId();
- abstract @Nullable String logUrl();
+ @SerializedName("log_url")
+ @Nullable String logUrl();
}
package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap;
+import com.google.gson.annotations.SerializedName;
+import org.immutables.gson.Gson;
import org.immutables.value.Value;
+import org.jetbrains.annotations.Nullable;
import org.onap.dcaegen2.services.sdk.rest.services.annotations.ExperimentalApi;
import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.SourceStream;
* @author <a href="mailto:piotr.jaszczyk@nokia.com">Piotr Jaszczyk</a>
* @version 1.2.1
*/
+@Gson.TypeAdapters
@ExperimentalApi
@Value.Immutable
-public abstract class DataRouterSource implements DataRouter, SourceStream {
+public interface DataRouterSource extends DataRouter, SourceStream {
- abstract String deliveryUrl();
+ // in future, since crucial need to be verified if could be nullable
+ @SerializedName("delivery_url")
+ @Nullable String deliveryUrl();
- abstract String subscriberId();
+ @SerializedName("subscriber_id")
+ @Nullable String subscriberId();
}
*/
@ExperimentalApi
@Value.Immutable
-public abstract interface KafkaSink extends Kafka, SinkStream {
+public interface KafkaSink extends Kafka, SinkStream {
}
package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap;
+import com.google.gson.annotations.SerializedName;
import org.jetbrains.annotations.Nullable;
import org.onap.dcaegen2.services.sdk.rest.services.annotations.ExperimentalApi;
import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.AafCredentials;
@ExperimentalApi
public interface MessageRouter {
+ @SerializedName("topic_url")
String topicUrl();
+ @SerializedName("client_role")
@Nullable String clientRole();
+ @SerializedName("client_id")
@Nullable String clientId();
+ @SerializedName("location")
@Nullable String location();
+ @SerializedName("aaf_credentials")
@Nullable AafCredentials aafCredentials();
}
package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap;
+import org.immutables.gson.Gson;
import org.immutables.value.Value;
import org.onap.dcaegen2.services.sdk.rest.services.annotations.ExperimentalApi;
import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.SinkStream;
*/
@ExperimentalApi
@Value.Immutable
-public abstract class MessageRouterSink implements MessageRouter, SinkStream {
+public interface MessageRouterSink extends MessageRouter, SinkStream {
}
package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap;
+import org.immutables.gson.Gson;
import org.immutables.value.Value;
import org.onap.dcaegen2.services.sdk.rest.services.annotations.ExperimentalApi;
import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.SourceStream;
*/
@ExperimentalApi
@Value.Immutable
-public abstract class MessageRouterSource implements MessageRouter, SourceStream {
+public interface MessageRouterSource extends MessageRouter, SourceStream {
}
--- /dev/null
+/*
+ * ============LICENSE_START====================================
+ * DCAEGEN2-SERVICES-SDK
+ * =========================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * =========================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=====================================
+ */
+package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson;
+
+import com.google.gson.Gson;
+import com.google.gson.JsonObject;
+import io.vavr.control.Either;
+import org.junit.jupiter.api.Test;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.exceptions.StreamParserError;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.streams.StreamFromGsonParser;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.streams.StreamFromGsonParsers;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.DataRouterSink;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.ImmutableDataRouterSink;
+
+import java.io.IOException;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.DATA_ROUTER_TYPE;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.MESSAGE_ROUTER_TYPE;
+
+
+class DataRouterSinkParserTest {
+ private static final String SAMPLE_LOCATION = "mtc00";
+ private static final String SAMPLE_PUBLISH_URL = "https://we-are-data-router.us/feed/xyz";
+ private static final String SAMPLE_LOG_URL = "https://we-are-data-router.us/feed/xyz/logs";
+ private static final String SAMPLE_USER = "some-user";
+ private static final String SAMPLE_PASSWORD = "some-password";
+ private static final String SAMPLE_PUBLISHER_ID = "123456";
+
+ private static final Gson gson = new Gson();
+
+ private final StreamFromGsonParser<DataRouterSink> streamParser = StreamFromGsonParsers.dataRouterSinkParser();
+
+ private static final DataRouterSink fullConfigurationStream = ImmutableDataRouterSink.builder()
+ .location(SAMPLE_LOCATION)
+ .publishUrl(SAMPLE_PUBLISH_URL)
+ .logUrl(SAMPLE_LOG_URL)
+ .username(SAMPLE_USER)
+ .password(SAMPLE_PASSWORD)
+ .publisherId(SAMPLE_PUBLISHER_ID)
+ .build();
+
+ private static final DataRouterSink minimalConfigurationStream = ImmutableDataRouterSink.builder()
+ .publishUrl(SAMPLE_PUBLISH_URL)
+ .build();
+
+ @Test
+ void fullConfiguration_shouldGenerateDataRouterSinkObject() throws IOException {
+ // given
+ JsonObject input = GsonUtils.readObjectFromResource("/streams/data_router_sink_full.json");
+ // when
+ DataRouterSink result = streamParser.unsafeParse(input);
+ // then
+ assertThat(result).isEqualTo(fullConfigurationStream);
+ }
+
+ @Test
+ void minimalConfiguration_shouldGenerateDataRouterSinkObject() throws IOException {
+ //given
+ JsonObject input = GsonUtils.readObjectFromResource("/streams/data_router_sink_minimal.json");
+ // when
+ DataRouterSink result = streamParser.unsafeParse(input);
+ // then
+ assertThat(result).isEqualTo(minimalConfigurationStream);
+ }
+
+ @Test
+ void incorrectConfiguration_shouldParseToStreamParserError() throws IOException {
+ // given
+ JsonObject input = GsonUtils.readObjectFromResource("/streams/message_router_full.json");
+ // when
+ Either<StreamParserError, DataRouterSink> result = streamParser.parse(input);
+ // then
+ assertThat(result.getLeft()).isInstanceOf(StreamParserError.class);
+ result.peekLeft(error -> {
+ assertThat(error.message()).contains("Invalid stream type");
+ assertThat(error.message()).contains("Expected '" + DATA_ROUTER_TYPE + "', but was '"
+ + MESSAGE_ROUTER_TYPE + "'");
+ }
+ );
+ }
+
+ @Test
+ void emptyConfiguration_shouldParseToStreamParserError() {
+ // given
+ JsonObject input = gson.fromJson("{}", JsonObject.class);
+ // when
+ Either<StreamParserError, DataRouterSink> result = streamParser.parse(input);
+ // then
+ assertThat(result.getLeft()).isInstanceOf(StreamParserError.class);
+ }
+
+}
\ No newline at end of file
--- /dev/null
+/*
+ * ============LICENSE_START====================================
+ * DCAEGEN2-SERVICES-SDK
+ * =========================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * =========================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=====================================
+ */
+package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson;
+
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+import com.google.gson.JsonObject;
+import io.vavr.control.Either;
+import org.junit.jupiter.api.Test;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.exceptions.StreamParserError;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.streams.StreamFromGsonParser;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.streams.StreamFromGsonParsers;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.streams.StreamParser;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.DataStream;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.*;
+
+import java.io.IOException;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.DATA_ROUTER_TYPE;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.MESSAGE_ROUTER_TYPE;
+
+public class DataRouterSourceParserTest {
+ private static final String SAMPLE_LOCATION = "mtc00";
+ private static final String SAMPLE_DELIVERY_URL = "https://my-subscriber-app.dcae:8080/target-path";
+ private static final String SAMPLE_USER = "some-user";
+ private static final String SAMPLE_PASSWORD = "some-password";
+ private static final String SAMPLE_SUBSCRIBER_ID = "789012";
+
+ private static final Gson gson = new Gson();
+
+ private static final DataRouterSource fullConfigurationStream = ImmutableDataRouterSource.builder()
+ .location(SAMPLE_LOCATION)
+ .deliveryUrl(SAMPLE_DELIVERY_URL)
+ .username(SAMPLE_USER)
+ .password(SAMPLE_PASSWORD)
+ .subscriberId(SAMPLE_SUBSCRIBER_ID)
+ .build();
+
+ private static final DataRouterSource minimalConfigurationStream = ImmutableDataRouterSource.builder()
+ .build();
+
+
+ private final StreamFromGsonParser<DataRouterSource> streamParser = StreamFromGsonParsers.dataRouterSourceParser();
+
+ @Test
+ void fullConfiguration_shouldGenerateDataRouterSinkObject() throws IOException {
+ // given
+ JsonObject input = GsonUtils.readObjectFromResource("/streams/data_router_source_full.json");
+ // when
+ DataRouterSource result = streamParser.unsafeParse(input);
+ // then
+ assertThat(result).isEqualTo(fullConfigurationStream);
+ }
+
+ @Test
+ void minimalConfiguration_shouldGenerateDataRouterSinkObject() throws IOException {
+ // given
+ JsonObject input = GsonUtils.readObjectFromResource("/streams/data_router_source_minimal.json");
+ // when
+ DataRouterSource result = streamParser.unsafeParse(input);
+ // then
+ assertThat(result).isEqualTo(minimalConfigurationStream);
+ }
+
+ @Test
+ void incorrectConfiguration_shouldParseToStreamParserError() throws IOException {
+ // given
+ JsonObject input = GsonUtils.readObjectFromResource("/streams/message_router_full.json");
+ // when
+ Either<StreamParserError, DataRouterSource> result = streamParser.parse(input);
+ // then
+ assertThat(result.getLeft()).isInstanceOf(StreamParserError.class);
+ result.peekLeft(error -> {
+ assertThat(error.message()).contains("Invalid stream type");
+ assertThat(error.message()).contains("Expected '" + DATA_ROUTER_TYPE + "', but was '"
+ + MESSAGE_ROUTER_TYPE + "'");
+ }
+ );
+ }
+
+ @Test
+ void emptyConfiguration_shouldBeParsedToStreamParserError() {
+ // given
+ JsonObject input = gson.fromJson("{}", JsonObject.class);
+ // when
+ Either<StreamParserError, DataRouterSource> result = streamParser.parse(input);
+ // then
+ assertThat(result.getLeft()).isInstanceOf(StreamParserError.class);
+ }
+}
--- /dev/null
+/*
+ * ============LICENSE_START====================================
+ * DCAEGEN2-SERVICES-SDK
+ * =========================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * =========================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=====================================
+ */
+package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson;
+
+import com.google.gson.Gson;
+import com.google.gson.JsonObject;
+import io.vavr.control.Either;
+import org.junit.jupiter.api.Test;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.exceptions.StreamParserError;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.streams.StreamFromGsonParser;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.streams.StreamFromGsonParsers;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.DataRouterSink;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.MessageRouterSink;
+
+import java.io.IOException;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.DATA_ROUTER_TYPE;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.MESSAGE_ROUTER_TYPE;
+
+/**
+ * @author <a href="mailto:kornel.janiak@nokia.com">Kornel Janiak</a>
+ */
+
+public class MessageRouterSinkParserTest {
+
+ private static final String SAMPLE_AAF_USERNAME = "some-user";
+ private static final String SAMPLE_AAF_PASSWORD = "some-password";
+ private static final String SAMPLE_LOCATION = "mtc00";
+ private static final String SAMPLE_CLIENT_ROLE = "com.dcae.member";
+ private static final String SAMPLE_CLIENT_ID = "1500462518108";
+ private static final String SAMPLE_TOPIC_URL = "https://we-are-message-router.us:3905/events/some-topic";
+
+ private static final Gson gson = new Gson();
+
+ private final StreamFromGsonParser<MessageRouterSink> streamParser = StreamFromGsonParsers.messageRouterSinkParser();
+
+ @Test
+ void fullConfiguration_shouldGenerateDataRouterSinkObject() throws IOException {
+ // given
+ JsonObject input = GsonUtils.readObjectFromResource("/streams/message_router_full.json");
+ // when
+ MessageRouterSink result = streamParser.unsafeParse(input);
+ // then
+ assertThat(result).isInstanceOf(MessageRouterSink.class);
+ assertThat(result.aafCredentials().username()).isEqualTo(SAMPLE_AAF_USERNAME);
+ assertThat(result.aafCredentials().password()).isEqualTo(SAMPLE_AAF_PASSWORD);
+ assertThat(result.location()).isEqualTo(SAMPLE_LOCATION);
+ assertThat(result.clientRole()).isEqualTo(SAMPLE_CLIENT_ROLE);
+ assertThat(result.clientId()).isEqualTo(SAMPLE_CLIENT_ID);
+ assertThat(result.topicUrl()).isEqualTo(SAMPLE_TOPIC_URL);
+ }
+
+ @Test
+ void minimalConfiguration_shouldGenerateDataRouterSinkObject() throws IOException {
+ // given
+ JsonObject input = GsonUtils.readObjectFromResource("/streams/message_router_minimal.json");
+
+ // when
+ MessageRouterSink result = streamParser.unsafeParse(input);
+ // then
+ assertThat(result).isInstanceOf(MessageRouterSink.class);
+ assertThat(result.topicUrl()).isEqualTo(SAMPLE_TOPIC_URL);
+ assertThat(result.aafCredentials().username()).isNull();
+ assertThat(result.aafCredentials().password()).isNull();
+ assertThat(result.clientId()).isNull();
+ }
+
+ @Test
+ void incorrectConfiguration_shouldParseToStreamParserError() throws IOException {
+ // given
+ JsonObject input = GsonUtils.readObjectFromResource("/streams/data_router_sink_full.json");
+ // when
+ Either<StreamParserError, MessageRouterSink> result = streamParser.parse(input);
+ // then
+ assertThat(result.getLeft()).isInstanceOf(StreamParserError.class);
+ result.peekLeft(error -> {
+ assertThat(error.message()).contains("Invalid stream type");
+ assertThat(error.message()).contains("Expected '" + MESSAGE_ROUTER_TYPE + "', but was '"
+ + DATA_ROUTER_TYPE + "'");
+ }
+ );
+ }
+
+ @Test
+ void emptyConfiguration_shouldParseToStreamParserError() {
+ // given
+ JsonObject input = gson.fromJson("{}", JsonObject.class);
+ // when
+ Either<StreamParserError, MessageRouterSink> result = streamParser.parse(input);
+ // then
+ assertThat(result.getLeft()).isInstanceOf(StreamParserError.class);
+ }
+
+
+}
\ No newline at end of file
--- /dev/null
+/*
+ * ============LICENSE_START====================================
+ * DCAEGEN2-SERVICES-SDK
+ * =========================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * =========================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=====================================
+ */
+package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson;
+
+import com.google.gson.Gson;
+import com.google.gson.JsonObject;
+import io.vavr.control.Either;
+import org.junit.jupiter.api.Test;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.exceptions.StreamParserError;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.streams.StreamFromGsonParser;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.streams.StreamFromGsonParsers;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.MessageRouterSink;
+import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.MessageRouterSource;
+
+import java.io.IOException;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.DATA_ROUTER_TYPE;
+import static org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.StreamsConstants.MESSAGE_ROUTER_TYPE;
+
+/**
+ * @author <a href="mailto:kornel.janiak@nokia.com">Kornel Janiak</a>
+ */
+
+public class MessageRouterSourceParserTest {
+
+ private static final String SAMPLE_AAF_USERNAME = "some-user";
+ private static final String SAMPLE_AAF_PASSWORD = "some-password";
+ private static final String SAMPLE_LOCATION = "mtc00";
+ private static final String SAMPLE_CLIENT_ROLE = "com.dcae.member";
+ private static final String SAMPLE_CLIENT_ID = "1500462518108";
+ private static final String SAMPLE_TOPIC_URL = "https://we-are-message-router.us:3905/events/some-topic";
+
+ private static final Gson gson = new Gson();
+
+ private final StreamFromGsonParser<MessageRouterSource> streamParser = StreamFromGsonParsers.messageRouterSourceParser();
+
+ @Test
+ void fullConfiguration_shouldGenerateDataRouterSourceObject() throws IOException {
+ // given
+ JsonObject input = GsonUtils.readObjectFromResource("/streams/message_router_full.json");
+ // when
+ MessageRouterSource result = streamParser.unsafeParse(input);
+ // then
+ assertThat(result.aafCredentials().username()).isEqualTo(SAMPLE_AAF_USERNAME);
+ assertThat(result.aafCredentials().password()).isEqualTo(SAMPLE_AAF_PASSWORD);
+ assertThat(result.location()).isEqualTo(SAMPLE_LOCATION);
+ assertThat(result.clientRole()).isEqualTo(SAMPLE_CLIENT_ROLE);
+ assertThat(result.clientId()).isEqualTo(SAMPLE_CLIENT_ID);
+ assertThat(result.topicUrl()).isEqualTo(SAMPLE_TOPIC_URL);
+ }
+
+ @Test
+ void minimalConfiguration_shouldGenerateDataRouterSourceObject() throws IOException {
+ // given
+ JsonObject input = GsonUtils.readObjectFromResource("/streams/message_router_minimal.json");
+
+ // when
+ MessageRouterSource result = streamParser.unsafeParse(input);
+ // then
+ assertThat(result.topicUrl()).isEqualTo(SAMPLE_TOPIC_URL);
+ assertThat(result.aafCredentials().username()).isNull();
+ assertThat(result.aafCredentials().password()).isNull();
+ assertThat(result.clientId()).isNull();
+ }
+
+ @Test
+ void incorrectConfiguration_shouldParseToStreamParserError() throws IOException {
+ // given
+ JsonObject input = GsonUtils.readObjectFromResource("/streams/data_router_sink_full.json");
+ // when
+ Either<StreamParserError, MessageRouterSource> result = streamParser.parse(input);
+ // then
+ assertThat(result.getLeft()).isInstanceOf(StreamParserError.class);
+ result.peekLeft(error -> {
+ assertThat(error.message()).contains("Invalid stream type");
+ assertThat(error.message()).contains("Expected '" + MESSAGE_ROUTER_TYPE + "', but was '"
+ + DATA_ROUTER_TYPE + "'");
+ }
+ );
+ }
+
+ @Test
+ void emptyConfiguration_shouldParseToStreamParserError() {
+ // given
+ JsonObject input = gson.fromJson("{}", JsonObject.class);
+ // when
+ Either<StreamParserError, MessageRouterSource> result = streamParser.parse(input);
+ // then
+ assertThat(result.getLeft()).isInstanceOf(StreamParserError.class);
+ }
+
+
+}
\ No newline at end of file
--- /dev/null
+{
+ "type": "data_router",
+ "dmaap_info": {
+ "location": "mtc00",
+ "publish_url": "https://we-are-data-router.us/feed/xyz",
+ "log_url": "https://we-are-data-router.us/feed/xyz/logs",
+ "username": "some-user",
+ "password": "some-password",
+ "publisher_id": "123456"
+ }
+}
\ No newline at end of file
--- /dev/null
+{
+ "type": "data_router",
+ "dmaap_info": {
+ "publish_url": "https://we-are-data-router.us/feed/xyz"
+ }
+}
\ No newline at end of file
--- /dev/null
+{
+ "type": "data_router",
+ "dmaap_info": {
+ "location": "mtc00",
+ "delivery_url": "https://my-subscriber-app.dcae:8080/target-path",
+ "username": "some-user",
+ "password": "some-password",
+ "subscriber_id": "789012"
+ }
+}
\ No newline at end of file
--- /dev/null
+{
+ "type": "data_router",
+ "dmaap_info": {
+ }
+}
\ No newline at end of file
--- /dev/null
+{
+ "type": "message_router",
+ "aaf_username": "some-user",
+ "aaf_password": "some-password",
+ "dmaap_info": {
+ "client_role": "com.dcae.member",
+ "client_id": "1500462518108",
+ "location": "mtc00",
+ "topic_url": "https://we-are-message-router.us:3905/events/some-topic"
+ }
+}
\ No newline at end of file
--- /dev/null
+{
+ "type": "message_router",
+ "dmaap_info": {
+ "topic_url": "https://we-are-message-router.us:3905/events/some-topic"
+ }
+}
\ No newline at end of file
Code Review / dcaegen2 / services / sdk.git / commitdiff