154b5be45d7d6d83470ad174e9d18136fe335808
[smo/teiv.git] /
1 /*
2  *  ============LICENSE_START=======================================================
3  *  Modifications Copyright (C) 2025 OpenInfra Foundation Europe
4  *  ================================================================================
5  *  Licensed under the Apache License, Version 2.0 (the "License");
6  *  you may not use this file except in compliance with the License.
7  *  You may obtain a copy of the License at
8  *
9  *        http://www.apache.org/licenses/LICENSE-2.0
10  *
11  *  Unless required by applicable law or agreed to in writing, software
12  *  distributed under the License is distributed on an "AS IS" BASIS,
13  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14  *  See the License for the specific language governing permissions and
15  *  limitations under the License.
16  *
17  *  SPDX-License-Identifier: Apache-2.0
18  *  ============LICENSE_END=========================================================
19  */
20 package org.oran.smo.ncmp_to_teiv_adapter;
21
22 import io.cloudevents.CloudEvent;
23 import io.cloudevents.core.builder.CloudEventBuilder;
24
25 import java.net.URI;
26 import java.nio.charset.StandardCharsets;
27 import java.time.OffsetDateTime;
28 import java.util.UUID;
29
30 public class CloudEventFactory {
31
32     public static CloudEvent createEvent(String data, String type) {
33         return CloudEventBuilder.v1().withId(UUID.randomUUID().toString()).withSource(URI.create("ncmp-dmi-plugin:nm-1"))
34                 .withType("topology-inventory-ingestion." + type).withDataSchema(URI.create(
35                         "https://teiv:8080/schemas/v1/r1-topology")).withTime(OffsetDateTime.now()).withData(
36                                 "application/yang-data+json", data.getBytes(StandardCharsets.UTF_8)).build();
37     }
38 }