Endorser support for updating DID endpoints on ledger

.pre-commit-config.yaml

@@ -8,7 +8,7 @@ repos:
         args: ["--config", ".commitlint.config.js"]
         additional_dependencies: ['@commitlint/config-conventional']
   - repo: https://github.com/psf/black
-    rev: 20.8b1
+    rev: 22.3.0
     hooks:
       - id: black
         stages: [commit]

aries_cloudagent/ledger/base.py

@@ -75,6 +75,8 @@ async def update_endpoint_for_did(
         did: str,
         endpoint: str,
         endpoint_type: EndpointType = EndpointType.ENDPOINT,
+        write_ledger: bool = True,
+        endorser_did: str = None,
     ) -> bool:
         """Check and update the endpoint on the ledger.
 

aries_cloudagent/ledger/indy.py

@@ -888,7 +888,12 @@ async def get_endpoint_for_did(
         return address
 
     async def update_endpoint_for_did(
-        self, did: str, endpoint: str, endpoint_type: EndpointType = None
+        self,
+        did: str,
+        endpoint: str,
+        endpoint_type: EndpointType = None,
+        write_ledger: bool = True,
+        endorser_did: str = None,
     ) -> bool:
         """Check and update the endpoint on the ledger.
 
@@ -897,6 +902,12 @@ async def update_endpoint_for_did(
             endpoint: The endpoint address
             endpoint_type: The type of the endpoint
         """
+        public_info = await self.get_wallet_public_did()
+        if not public_info:
+            raise BadLedgerRequestError(
+                "Cannot update endpoint at ledger without a public DID"
+            )
+
         if not endpoint_type:
             endpoint_type = EndpointType.ENDPOINT
 
@@ -925,6 +936,20 @@ async def update_endpoint_for_did(
                 request_json = await indy.ledger.build_attrib_request(
                     nym, nym, None, attr_json, None
                 )
+
+                if endorser_did and not write_ledger:
+                    request_json = await indy.ledger.append_request_endorser(
+                        request_json, endorser_did
+                    )
+                    resp = await self._submit(
+                        request_json,
+                        True,
+                        sign_did=public_info,
+                        write_ledger=write_ledger,
+                    )
+                    if not write_ledger:
+                        return {"signed_txn": resp}
+
             await self._submit(request_json, True, True)
             return True
         return False

aries_cloudagent/ledger/indy_vdr.py

@@ -893,7 +893,12 @@ async def get_endpoint_for_did(
         return address
 
     async def update_endpoint_for_did(
-        self, did: str, endpoint: str, endpoint_type: EndpointType = None
+        self,
+        did: str,
+        endpoint: str,
+        endpoint_type: EndpointType = None,
+        write_ledger: bool = True,
+        endorser_did: str = None,
     ) -> bool:
         """Check and update the endpoint on the ledger.
 
@@ -902,6 +907,12 @@ async def update_endpoint_for_did(
             endpoint: The endpoint address
             endpoint_type: The type of the endpoint
         """
+        public_info = await self.get_wallet_public_did()
+        if not public_info:
+            raise BadLedgerRequestError(
+                "Cannot update endpoint at ledger without a public DID"
+            )
+
         if not endpoint_type:
             endpoint_type = EndpointType.ENDPOINT
 
@@ -930,6 +941,18 @@ async def update_endpoint_for_did(
                 attrib_req = ledger.build_attrib_request(
                     nym, nym, None, attr_json, None
                 )
+
+                if endorser_did and not write_ledger:
+                    attrib_req.set_endorser(endorser_did)
+                    resp = await self._submit(
+                        attrib_req,
+                        True,
+                        sign_did=public_info,
+                        write_ledger=write_ledger,
+                    )
+                    if not write_ledger:
+                        return {"signed_txn": resp}
+
             except VdrError as err:
                 raise LedgerError("Exception when building attribute request") from err
 

aries_cloudagent/wallet/askar.py

@@ -446,6 +446,8 @@ async def set_did_endpoint(
         endpoint: str,
         ledger: BaseLedger,
         endpoint_type: EndpointType = None,
+        write_ledger: bool = True,
+        endorser_did: str = None,
     ):
         """
         Update the endpoint for a DID in the wallet, send to ledger if public or posted.
@@ -478,7 +480,15 @@ async def set_did_endpoint(
                 )
             if not ledger.read_only:
                 async with ledger:
-                    await ledger.update_endpoint_for_did(did, endpoint, endpoint_type)
+                    attrib_def = await ledger.update_endpoint_for_did(
+                        did,
+                        endpoint,
+                        endpoint_type,
+                        write_ledger=write_ledger,
+                        endorser_did=endorser_did,
+                    )
+                    if not write_ledger:
+                        return attrib_def
 
         await self.replace_local_did_metadata(did, metadata)
 

aries_cloudagent/wallet/base.py

@@ -224,6 +224,8 @@ async def set_did_endpoint(
         endpoint: str,
         _ledger: BaseLedger,
         endpoint_type: EndpointType = None,
+        write_ledger: bool = True,
+        endorser_did: str = None,
     ):
         """
         Update the endpoint for a DID in the wallet, send to ledger if public or posted.

aries_cloudagent/wallet/indy.py

@@ -705,6 +705,8 @@ async def set_did_endpoint(
         endpoint: str,
         ledger: BaseLedger,
         endpoint_type: EndpointType = None,
+        write_ledger: bool = True,
+        endorser_did: str = None,
     ):
         """
         Update the endpoint for a DID in the wallet, send to ledger if public or posted.
@@ -738,7 +740,15 @@ async def set_did_endpoint(
                 )
             if not ledger.read_only:
                 async with ledger:
-                    await ledger.update_endpoint_for_did(did, endpoint, endpoint_type)
+                    attrib_def = await ledger.update_endpoint_for_did(
+                        did,
+                        endpoint,
+                        endpoint_type,
+                        write_ledger=write_ledger,
+                        endorser_did=endorser_did,
+                    )
+                    if not write_ledger:
+                        return attrib_def
 
         await self.replace_local_did_metadata(did, metadata)