@@ -213,6 +213,7 @@ def __init__(
213213 self .agency_wallet_did = self .did
214214 self .agency_wallet_key = self .wallet_key
215215
216+ self .multi_write_ledger_url = None
216217 if self .genesis_txn_list :
217218 updated_config_list = []
218219 with open (self .genesis_txn_list , "r" ) as stream :
@@ -225,6 +226,10 @@ def __init__(
225226 "$LEDGER_HOST" , str (self .external_host )
226227 )
227228 updated_config_list .append (config )
229+ if "is_write" in config and config ["is_write" ]:
230+ self .multi_write_ledger_url = config ["genesis_url" ].replace (
231+ "/genesis" , ""
232+ )
228233 with open (self .genesis_txn_list , "w" ) as file :
229234 documents = yaml .dump (updated_config_list , file )
230235
@@ -479,7 +484,10 @@ async def register_did(
479484 # if registering a did for issuing indy credentials, publish the did on the ledger
480485 self .log (f"Registering { self .ident } ..." )
481486 if not ledger_url :
482- ledger_url = LEDGER_URL
487+ if self .multi_write_ledger_url :
488+ ledger_url = self .multi_write_ledger_url
489+ else :
490+ ledger_url = LEDGER_URL
483491 if not ledger_url :
484492 ledger_url = f"http://{ self .external_host } :9000"
485493 data = {"alias" : alias or self .ident }
@@ -501,6 +509,7 @@ async def register_did(
501509 await asyncio .sleep (3.0 )
502510 nym_info = data
503511 else :
512+ log_msg ("using ledger: " + ledger_url + "/register" )
504513 resp = await self .client_session .post (
505514 ledger_url + "/register" , json = data
506515 )
0 commit comments