implement most missing endpoints. Add TODO's for test

Author: wip-abramson

libs/aries-basic-controller/aries_basic_controller/controllers/base.py

@@ -103,3 +103,17 @@ async def admin_POST(
             raise
 
 
+    async def admin_DELETE(
+            self, path, text=False, params=None
+    ) -> ClientResponse:
+        try:
+            EVENT_LOGGER.debug("Controller DELETE %s request to Agent", path)
+
+            response = await self.admin_request("DELETE", path, None, text, params)
+            EVENT_LOGGER.debug(
+                "Response from DELETE %s received: \n%s", path, repr_json(response),
+            )
+            return response
+        except ClientError as e:
+            self.log(f"Error during DELETE {path}: {str(e)}")
+            raise

libs/aries-basic-controller/aries_basic_controller/controllers/connections.py

@@ -120,7 +120,7 @@ async def establish_inbound(self, connection_id: str, router_conn_id: str):
         return response
 
     async def remove_connection(self, connection_id):
-        response = await self.admin_POST(f"/connections/{connection_id}/remove")
+        response = await self.admin_DELETE(f"/connections/{connection_id}")
         return response
 
     async def create_static(self, their_seed, their_label, their_verkey, their_role, my_seed, my_did, their_endpoint, alias, their_did):

libs/aries-basic-controller/aries_basic_controller/controllers/credential.py

@@ -16,7 +16,7 @@ async def get_credential_mime_types(self, credential_id):
         return await self.admin_GET(f"/credential/mime-types/{credential_id}")
 
     async def remove_credential(self, credential_id):
-        return await self.admin_POST(f"/credential/{credential_id}/remove")
+        return await self.admin_DELETE(f"/credential/{credential_id}")
 
     async def get_all(self, wql_query: str = None, count: int = None, start: int = None):
         params = {}
@@ -27,4 +27,7 @@ async def get_all(self, wql_query: str = None, count: int = None, start: int = N
         if start:
             params["start"] = start
 
-        return await self.admin_GET("/credentials", params=params)
+        return await self.admin_GET("/credentials", params=params)
+
+    async def is_revoked(self, credential_id):
+        return await self.admin_GET(f"credential/revoked/{credential_id}")

libs/aries-basic-controller/aries_basic_controller/controllers/issuer.py

@@ -96,21 +96,21 @@ async def store_credential(self, cred_ex_id, credential_id):
         return await self.admin_POST(f"{self.base_url}/records/{cred_ex_id}/store", json_data=body)
 
     # Revoke and issued credential
-    async def revoke_credential(self, rev_reg_id, cred_rev_id, publish: bool = False):
-        params = {
-            "rev_reg_id": rev_reg_id,
-            "cred_reg_id": cred_rev_id,
-            "publish": publish
-        }
-        return await self.admin_POST(f"{self.base_url}/revoke", params=params)
-
-    # Publish pending revocations
-    async def publish_revocations(self):
-        return await self.admin_POST(f"{self.base_url}/publish-revocations")
+    # async def revoke_credential(self, rev_reg_id, cred_rev_id, publish: bool = False):
+    #     params = {
+    #         "rev_reg_id": rev_reg_id,
+    #         "cred_reg_id": cred_rev_id,
+    #         "publish": publish
+    #     }
+    #     return await self.admin_POST(f"{self.base_url}/revoke", params=params)
+    #
+    # # Publish pending revocations
+    # async def publish_revocations(self):
+    #     return await self.admin_POST(f"{self.base_url}/publish-revocations")
 
     # Remove an existing credential exchange record
     async def remove_record(self, cred_ex_id):
-        return await self.admin_POST(f"{self.base_url}/records/{cred_ex_id}/remove")
+        return await self.admin_DELETE(f"{self.base_url}/records/{cred_ex_id}")
 
     # Send a problem report for a credential exchange
     async def problem_report(self, cred_ex_id, explanation: str):

libs/aries-basic-controller/aries_basic_controller/controllers/ledger.py

@@ -22,6 +22,12 @@ async def register_nym(self, did, verkey, role: str = None, alias: str = None):
 
         return await self.admin_POST(f"{self.base_url}/register-nym", params=params)
 
+    async def get_nym_role(self, did):
+        params = {
+            "did": did
+        }
+        return await self.admin_GET(f"{self.base_url}/get-nym-role", params=params)
+
 
     async def get_did_verkey(self, did):
         params = {
@@ -41,4 +47,6 @@ async def get_taa(self):
     async def accept_taa(self, data):
         return await self.admin_POST(f"{self.base_url}/taa/accept", json_data=data)
 
+    #TODO PATCH rotate key pair
+
 

libs/aries-basic-controller/aries_basic_controller/controllers/proof.py

@@ -79,7 +79,7 @@ async def verify_presentation(self, pres_ex_id):
         return await self.admin_POST(f"{self.base_url}/records/{pres_ex_id}/verify-presentation")
 
     async def remove_presentation_record(self, pres_ex_id):
-        return await self.admin_POST(f"{self.base_url}/records/{pres_ex_id}/remove")
+        return await self.admin_DELETE(f"{self.base_url}/records/{pres_ex_id}")
 
     # def build_proof_request(self, name, version, requested_attributes, requested_predicates):
 

libs/aries-basic-controller/aries_basic_controller/controllers/server.py

@@ -19,9 +19,17 @@ async def get_status(self):
     async def reset_status(self):
         return await self.admin_POST('/status/reset')
 
+    async def status_ready(self):
+        return await self.admin_GET('/status/ready')
+
+    async def status_live(self):
+        return await self.admin_GET('/status/live')
+
     async def get_features(self, query: str = None):
         params = {}
         if query:
             params["query"] = query
 
         return await self.admin_GET('/features', params=params)
+
+    ## TODO implement shutdown. Should this be a POST?

libs/aries-basic-controller/aries_basic_controller/controllers/wallet.py

@@ -26,8 +26,18 @@ async def assign_public_did(self, did):
         }
         return await self.admin_POST(f"{self.base_url}/did/public", params=params)
 
-    async def get_tag_policy(self, credential_definition_id):
-        return await self.admin_GET(f"{self.base_url}/tag-policy/{credential_definition_id}")
+    async def get_did_endpoint(self, did):
+        params = {
+            "did": did
+        }
+        return await self.admin_GET(f"{self.base_url}/get-did-endpoint", params=params)
+
+    async def set_did_endpoint(self, did, endpoint, endpoint_type):
+        body = {
+            "did": did,
+            "endpoint": endpoint,
+            "endpoint_type": endpoint_type
+        }
+        return await self.admin_POST(f"{self.base_url}/set-did-endpoint", json_data=body)
 
-    async def set_tag_policy(self, credential_definition_id):
-        return await self.admin_POST(f"{self.base_url}/tag-policy/{credential_definition_id}")
+    ## TODO Patch rotate-keypair