From 6ab2bb518d84a470585f852a85622e4bc0193b1e Mon Sep 17 00:00:00 2001
From: Grahame Grieve <grahameg@gmail.ccom>
Date: Sat, 4 Jan 2025 10:29:56 +1100
Subject: [PATCH] handle tx ecosystem failure properly

---
 .../client/TerminologyClientManager.java      | 57 ++++++++++++-------
 1 file changed, 38 insertions(+), 19 deletions(-)

diff --git a/org.hl7.fhir.r5/src/main/java/org/hl7/fhir/r5/terminologies/client/TerminologyClientManager.java b/org.hl7.fhir.r5/src/main/java/org/hl7/fhir/r5/terminologies/client/TerminologyClientManager.java
index f4df2975f..d9dd3077a 100644
--- a/org.hl7.fhir.r5/src/main/java/org/hl7/fhir/r5/terminologies/client/TerminologyClientManager.java
+++ b/org.hl7.fhir.r5/src/main/java/org/hl7/fhir/r5/terminologies/client/TerminologyClientManager.java
@@ -160,6 +160,8 @@ public class TerminologyClientManager {
 
   private ILoggingService logger;
 
+  private int ecosystemfailCount;
+
   public TerminologyClientManager(ITerminologyClientFactory factory, String cacheId, ILoggingService logger) {
     super();
     this.factory = factory;
@@ -566,29 +568,46 @@ public class TerminologyClientManager {
       if (!useEcosystem) {
         server = getMasterClient().getAddress();
       } else {
-        if (usage != null) {
-          request = request + "&usage="+usage;
-        }
-        JsonObject json = JsonParser.parseObjectFromUrl(request);
-        for (JsonObject item : json.getJsonObjects("authoritative")) {
-          if (server == null) {
-            server = item.asString("url");
+        ecosystemfailCount = 0; 
+        try {
+          if (usage != null) {
+            request = request + "&usage="+usage;
           }
-        }
-        for (JsonObject item : json.getJsonObjects("candidates")) {
-          if (server == null) {
-            server = item.asString("url");
+          JsonObject json = JsonParser.parseObjectFromUrl(request);
+          for (JsonObject item : json.getJsonObjects("authoritative")) {
+            if (server == null) {
+              server = item.asString("url");
+            }
+          }
+          for (JsonObject item : json.getJsonObjects("candidates")) {
+            if (server == null) {
+              server = item.asString("url");
+            }
+          }
+          if (server == null) {
+            server = getMasterClient().getAddress();
+          }
+          if (server.contains("://tx.fhir.org")) {
+            try {
+              server = server.replace("tx.fhir.org", host());
+            } catch (MalformedURLException e) {
+            }
+          }
+        } catch (Exception e) {
+          // the ecosystem cal failed, so we're just going to fall back to 
+          String msg = "Error resolving valueSet "+canonical+": "+e.getMessage();
+          if (!hasMessage(msg)) {
+            internalLog.add(new InternalLogEvent(msg, canonical, request));
+          }
+          if (logger.isDebugLogging()) {
+            e.printStackTrace();
+          }
+          ecosystemfailCount++;
+          if (ecosystemfailCount > 3) {
+            useEcosystem = false;
           }
-        }
-        if (server == null) {
           server = getMasterClient().getAddress();
         }
-        if (server.contains("://tx.fhir.org")) {
-          try {
-            server = server.replace("tx.fhir.org", host());
-          } catch (MalformedURLException e) {
-          }
-        }
       }
       TerminologyClientContext client = serverMap.get(server);
       if (client == null) {