X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2ims%2Fviews%2Focloud_view.py;h=9404d9a59001c92bb28360f61949c369d912df77;hb=f73c8e3b01b8f5b7438ba544870e06d8f30cdea0;hp=9a1a595b8cd1662fe128fda736ac4e74c9ec5237;hpb=84867b76a65efc4e9add52c86eae7e451c4a038d;p=pti%2Fo2.git

diff --git a/o2ims/views/ocloud_view.py b/o2ims/views/ocloud_view.py
index 9a1a595..9404d9a 100644
--- a/o2ims/views/ocloud_view.py
+++ b/o2ims/views/ocloud_view.py
@@ -12,11 +12,13 @@
 #  See the License for the specific language governing permissions and
 #  limitations under the License.
 
+import uuid
 from sqlalchemy import select
 
 from o2ims.adapter.orm import ocloud, resource, resourcetype, \
     resourcepool, deploymentmanager, subscription
 from o2common.service import unit_of_work
+from o2ims.views.ocloud_dto import SubscriptionDTO
 from o2ims.domain.ocloud import Subscription
 
 
@@ -115,11 +117,18 @@ def subscription_one(subscriptionId: str,
     return None if first is None else dict(first)
 
 
-def subscription_create(subscription: Subscription,
+def subscription_create(subscriptionDto: SubscriptionDTO.subscription,
                         uow: unit_of_work.AbstractUnitOfWork):
+
+    sub_uuid = str(uuid.uuid4())
+    subscription = Subscription(
+        sub_uuid, subscriptionDto['callback'],
+        subscriptionDto['consumerSubscriptionId'],
+        subscriptionDto['filter'])
     with uow:
         uow.subscriptions.add(subscription)
         uow.commit()
+    return {"subscriptionId": sub_uuid}
 
 
 def subscription_delete(subscriptionId: str,