Add Subscription get and list API; Provide swagger openAPI doc

[pti/o2.git] / o2ims / views / ocloud_view.py

diff --git a/o2ims/views/ocloud_view.py b/o2ims/views/ocloud_view.py
index b1b6e5d..513e9e0 100644 (file)
--- a/o2ims/views/ocloud_view.py
+++ b/o2ims/views/ocloud_view.py
@@ -14,8 +14,8 @@
 \r
 from sqlalchemy import select\r
 \r
-from o2ims.adapter.orm import ocloud, resource, \\r
-    resourcetype, resourcepool, deploymentmanager\r
+from o2ims.adapter.orm import ocloud, resource, resourcetype, \\r
+    resourcepool, deploymentmanager, subscription\r
 from o2ims.adapter import unit_of_work\r
 # from o2ims.domain.ocloud import Ocloud\r
 \r
@@ -167,3 +167,18 @@ def deployment_manager_one(deploymentManagerId: str,
             deploymentmanager.c.deploymentManagerId == deploymentManagerId))\r
         first = res.first()\r
     return None if first is None else dict(first)\r
+\r
+\r
+def subscriptions(uow: unit_of_work.SqlAlchemyUnitOfWork):\r
+    with uow:\r
+        res = uow.session.execute(select(subscription))\r
+    return [dict(r) for r in res]\r
+\r
+\r
+def subscription_one(subscriptionId: str,\r
+                     uow: unit_of_work.SqlAlchemyUnitOfWork):\r
+    with uow:\r
+        res = uow.session.execute(select(subscription).where(\r
+            subscription.c.subscriptionId == subscriptionId))\r
+        first = res.first()\r
+    return None if first is None else dict(first)\r