Merge pull request #19 from cloudblue/feature/LITE-27143

LITE-27143 Helpdesk Cases are automatically resolved in Admin API

Author: AntonHinz

CHANGELOG.md

@@ -15,4 +15,5 @@
     * `ui-` for ones imported from Connect UI Toolkit
   * Table columns now may be styled directly with a column descriptor `style` property
 * 0.2.3: Better handling of DB and Client Server errors
-* 0.3.0: Administrative UI
+* 0.3.0: Administrative UI
+* 0.3.1: Helpdesk Cases are automatically resolved in administrative actions

dbaas/extension.json

@@ -1,9 +1,9 @@
 {
   "name": "DBaaS",
   "description": "On-demand provisioning of cloud-based database storages as a service.",
-  "version": "0.3.0",
+  "version": "0.3.1",
   "audience": ["reseller", "distributor", "vendor"],
-  "readme_url": "https://github.com/cloudblue/connect-extension-dbaas/blob/0.3.0/README.md",
-  "changelog_url": "https://github.com/cloudblue/connect-extension-dbaas/blob/0.3.0/CHANGELOG.md",
+  "readme_url": "https://github.com/cloudblue/connect-extension-dbaas/blob/0.3.1/README.md",
+  "changelog_url": "https://github.com/cloudblue/connect-extension-dbaas/blob/0.3.1/CHANGELOG.md",
   "icon": "googleExtensionBaseline"
 }

dbaas/services.py

@@ -4,6 +4,7 @@
 # All rights reserved.
 #
 
+import asyncio
 import random
 import string
 from copy import copy
@@ -107,6 +108,7 @@ async def delete(
         cls,
         db_document: dict,
         db: AsyncIOMotorDatabase,
+        client: AsyncConnectClient,
         **kwargs,
     ) -> dict:
         updated_db_document = copy(db_document)
@@ -121,8 +123,10 @@ async def delete(
             {'id': db_document['id']},
             {'$set': updates},
         )
-
         updated_db_document.update(updates)
+
+        cls._resolve_last_db_document_case(db_document, client)
+
         return cls._db_document_repr(updated_db_document)
 
     @classmethod
@@ -181,9 +185,10 @@ async def activate(
         data: dict,
         db: AsyncIOMotorDatabase,
         config: dict,
+        client: AsyncConnectClient,
         **kwargs,
     ) -> dict:
-        updated_db_document = await cls._activate(db_document, data, db, config)
+        updated_db_document = await cls._activate(db_document, data, db, config, client)
 
         return cls._db_document_repr(updated_db_document, config=config)
 
@@ -194,6 +199,7 @@ async def _activate(
         data: dict,
         db: AsyncIOMotorDatabase,
         config: dict,
+        client: AsyncConnectClient,
     ):
         status = db_document.get('status')
         credentials = data.get('credentials')
@@ -226,8 +232,10 @@ async def _activate(
             {'id': db_document['id']},
             {'$set': updates},
         )
-
         updated_db_document.update(updates)
+
+        cls._resolve_last_db_document_case(db_document, client)
+
         return updated_db_document
 
     @classmethod
@@ -272,6 +280,12 @@ async def _update(
         updated_db_document.update(updates)
         return updated_db_document
 
+    @classmethod
+    def _resolve_last_db_document_case(cls, db_document: dict, client: AsyncConnectClient):
+        case = cls._get_last_db_document_case(db_document)
+        if case:
+            asyncio.create_task(ConnectHelpdeskCase.resolve(case['id'], client))
+
     @classmethod
     def _default_query(cls, context: Context) -> dict:
         q = {'status': {'$ne': DBStatus.DELETED}}
@@ -285,9 +299,9 @@ def _default_query(cls, context: Context) -> dict:
     def _db_document_repr(cls, db_document: dict, config: dict = None) -> dict:
         document = copy(db_document)
 
-        cases = document.get('cases')
-        if cases:
-            document['case'] = cases[-1]
+        case = cls._get_last_db_document_case(document)
+        if case:
+            document['case'] = case
 
         status = document.get('status')
         credentials = db_document.get('credentials')
@@ -300,6 +314,11 @@ def _db_document_repr(cls, db_document: dict, config: dict = None) -> dict:
 
         return document
 
+    @classmethod
+    def _get_last_db_document_case(cls, db_document: dict) -> Optional[dict]:
+        cases = db_document.get('cases')
+        return cases[-1] if cases else None
+
     @classmethod
     async def _get_validated_region_document(
         cls,
@@ -605,3 +624,10 @@ async def create(
         helpdesk_case = await client('helpdesk').cases.create(payload=data)
 
         return helpdesk_case
+
+    @classmethod
+    async def resolve(cls, case_id: str, client: AsyncConnectClient):
+        try:
+            await client('helpdesk').cases[case_id]('resolve').post()
+        except ClientError:
+            client.logger.logger.warning('Could not resolve case %s.', case_id)

dbaas/static/6c5bb1bba5eebb952b58.js renamed to dbaas/static/b7d579a519616740b116.js

@@ -1 +1 @@
-<html><head><title>Lorem ipsum</title><link href="https://fonts.googleapis.com/css?family=Roboto:300,400,500,700|Roboto+Mono:400,500|Material+Icons" rel="stylesheet"><link id="mock-favicon" rel="shortcut icon" href="#"><script defer="defer" src="6c5bb1bba5eebb952b58.js"></script><link href="main.css" rel="stylesheet"></head><body><div id="app"></div></body></html>
+<html><head><title>Lorem ipsum</title><link href="https://fonts.googleapis.com/css?family=Roboto:300,400,500,700|Roboto+Mono:400,500|Material+Icons" rel="stylesheet"><link id="mock-favicon" rel="shortcut icon" href="#"><script defer="defer" src="b7d579a519616740b116.js"></script><link href="main.css" rel="stylesheet"></head><body><div id="app"></div></body></html>

dbaas/static/6c5bb1bba5eebb952b58.js.LICENSE.txt renamed to dbaas/static/b7d579a519616740b116.js.LICENSE.txt

@@ -162,10 +162,11 @@ async def delete_database(
         self,
         db_id: _db_id_type,
         context: Context = Depends(get_call_context),
+        client: AsyncConnectClient = Depends(get_installation_client),
         db=Depends(get_db),
     ):
         result = await self._action(
-            db_id, action=DB.delete, is_admin_action=True, context=context, db=db,
+            db_id, action=DB.delete, is_admin_action=True, context=context, db=db, client=client,
         )
 
         return responses.Response(status_code=204) if isinstance(result, BaseModel) else result
@@ -209,6 +210,7 @@ async def activate_database(
         data: DatabaseActivate,
         context: Context = Depends(get_call_context),
         config: dict = Depends(get_config),
+        client: AsyncConnectClient = Depends(get_installation_client),
         db=Depends(get_db),
     ):
         result = await self._action(
@@ -219,6 +221,7 @@ async def activate_database(
             context=context,
             db=db,
             config=config,
+            client=client,
         )
 
         return result