PR for endorser support to update endpoints on ledger.

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

@@ -886,7 +886,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.
 
@@ -895,6 +900,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
 
@@ -923,6 +934,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/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)