Multi-ledger issues WIP

Signed-off-by: Ian Costanzo <ian@anon-solutions.ca>

Author: ianco

aries_cloudagent/admin/server.py

@@ -370,6 +370,7 @@ async def check_multitenant_authorization(request: web.Request, handler):
                     and not is_server_path
                     and not is_unprotected_path(path)
                     and not base_limited_access_path
+                    and not (request.method == "OPTIONS")  # CORS fix
                 ):
                     raise web.HTTPUnauthorized()
 

demo/multi_ledger_config.yml

@@ -1,6 +1,10 @@
-- id: bcorvinTest
+- id: local
   is_production: true
-  genesis_url: 'http://test.bcovrin.vonx.io/genesis'
+  is_write: true
+  genesis_url: 'http://$LEDGER_HOST:9000/genesis'
+#- id: bcorvinTest
+#  is_production: true
+#  genesis_url: 'http://dev.bcovrin.vonx.io/genesis'
 - id: greenlightTest
   is_production: true
   genesis_url: 'http://dev.greenlight.bcovrin.vonx.io/genesis'

demo/runners/agent_container.py

@@ -1274,9 +1274,11 @@ async def create_agent_with_args(args, ident: str = None):
         )
 
     multi_ledger_config_path = None
+    genesis = None
     if "multi_ledger" in args and args.multi_ledger:
         multi_ledger_config_path = "./demo/multi_ledger_config.yml"
-    genesis = await default_genesis_txns()
+    else:
+        genesis = await default_genesis_txns()
     if not genesis and not multi_ledger_config_path:
         print("Error retrieving ledger genesis transactions")
         sys.exit(1)

demo/runners/support/agent.py

@@ -213,6 +213,7 @@ def __init__(
             self.agency_wallet_did = self.did
             self.agency_wallet_key = self.wallet_key
 
+        self.multi_write_ledger_url = None
         if self.genesis_txn_list:
             updated_config_list = []
             with open(self.genesis_txn_list, "r") as stream:
@@ -225,6 +226,8 @@ def __init__(
                         "$LEDGER_HOST", str(self.external_host)
                     )
                 updated_config_list.append(config)
+                if "is_write" in config and config["is_write"]:
+                    self.multi_write_ledger_url = config["genesis_url"].replace("/genesis", "")
             with open(self.genesis_txn_list, "w") as file:
                 documents = yaml.dump(updated_config_list, file)
 
@@ -479,7 +482,10 @@ async def register_did(
             # if registering a did for issuing indy credentials, publish the did on the ledger
             self.log(f"Registering {self.ident} ...")
             if not ledger_url:
-                ledger_url = LEDGER_URL
+                if self.multi_write_ledger_url:
+                    ledger_url = self.multi_write_ledger_url
+                else:
+                    ledger_url = LEDGER_URL
             if not ledger_url:
                 ledger_url = f"http://{self.external_host}:9000"
             data = {"alias": alias or self.ident}
@@ -501,6 +507,7 @@ async def register_did(
                 await asyncio.sleep(3.0)
                 nym_info = data
             else:
+                log_msg("using ledger: " + ledger_url + "/register")
                 resp = await self.client_session.post(
                     ledger_url + "/register", json=data
                 )