X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=smo-install%2Ftest%2Fpythonsdk%2Fsrc%2Foransdk%2Fdmaap%2Foran_dmaap.py;fp=smo-install%2Ftest%2Fpythonsdk%2Fsrc%2Foransdk%2Fdmaap%2Foran_dmaap.py;h=a3079090805c88cb95e7557afc4b7df941329d98;hb=edc7d501e675517ea6fc14cfdf7f22b1ac7b1705;hp=0000000000000000000000000000000000000000;hpb=a2c2df5014145ee3126146987d9039e397b12407;p=it%2Fdep.git

diff --git a/smo-install/test/pythonsdk/src/oransdk/dmaap/oran_dmaap.py b/smo-install/test/pythonsdk/src/oransdk/dmaap/oran_dmaap.py
new file mode 100644
index 00000000..a3079090
--- /dev/null
+++ b/smo-install/test/pythonsdk/src/oransdk/dmaap/oran_dmaap.py
@@ -0,0 +1,45 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+# SPDX-License-Identifier: Apache-2.0
+"""Oran Dmaap module."""
+from typing import Dict
+from onapsdk.dmaap.dmaap import Dmaap
+from onapsdk.dmaap.dmaap_service import DmaapService
+
+class OranDmaap(Dmaap):
+    """Dmaap library provides functions for getting events from Dmaap."""
+
+    get_all_topics_url = f"{DmaapService._url}/topics/listAll"
+
+    @classmethod
+    def create_topic(cls,
+                    topic,
+                    basic_auth: Dict[str, str]) -> dict:
+        """
+        Create topic in Dmaap.
+
+        Args:
+           topic: the topic to create, in json format
+           basic_auth: (Dict[str, str]) for example:{ 'username': 'bob', 'password': 'secret' }
+
+        """
+        create_events_url = f"{DmaapService._url}/topics/create"
+        instance_details = cls.send_message('POST',
+                                            'Create Dmaap Topic',
+                                            create_events_url,
+                                            data=topic)
+
+    @classmethod
+    def get_all_topics(cls,
+                       basic_auth: Dict[str, str]) -> dict:
+        """
+        Get all topics stored in Dmaap.
+
+        Args:
+           basic_auth: (Dict[str, str]) for example:{ 'username': 'bob', 'password': 'secret' }
+
+        Returns:
+            (dict) Topics from Dmaap
+
+        """
+        return super().get_all_topics(basic_auth)
\ No newline at end of file