fix(examples): enhance error handling and logging

cshamrick · cshamrick · commit bb3e626fecbf · 2025-12-08T08:52:19.000-06:00
Signed-off-by: Scott Hamrick &lt;2623452+cshamrick@users.noreply.github.com&gt;
diff --git a/examples/src/main/java/io/opentdf/platform/CreateAttribute.java b/examples/src/main/java/io/opentdf/platform/CreateAttribute.java
@@ -13,6 +13,7 @@
 import java.util.Collections;
 
 import java.util.Arrays;
+import java.util.Objects;
 
 public class CreateAttribute {
 
@@ -23,6 +24,7 @@ public static void main(String[] args) {
     String clientId = "opentdf";
     String clientSecret = "secret";
     String platformEndpoint = "localhost:8080";
+    String namespaceName = "mynamespace.com";
 
     SDKBuilder builder = new SDKBuilder();
 
@@ -33,25 +35,17 @@ public static void main(String[] args) {
             .useInsecurePlaintextConnection(true)
             .build()) {
 
-      Namespace namespace;
-      String namespaceName = "mynamespace.com";
-
-      try {
-        namespace =
-            ResponseMessageKt.getOrThrow(
-                    sdk.getServices()
-                        .namespaces()
-                        .getNamespaceBlocking(
-                            GetNamespaceRequest.newBuilder()
-                                .setFqn("https://" + namespaceName)
-                                .build(),
-                            Collections.emptyMap())
-                        .execute())
-                .getNamespace();
-      } catch (Exception e) {
-        logger.error("Namespace '{}' not found", namespaceName);
-        throw e;
-      }
+      Namespace namespace =
+          ResponseMessageKt.getOrThrow(
+                  sdk.getServices()
+                      .namespaces()
+                      .getNamespaceBlocking(
+                          GetNamespaceRequest.newBuilder()
+                              .setFqn("https://" + namespaceName)
+                              .build(),
+                          Collections.emptyMap())
+                      .execute())
+              .getNamespace();
 
       CreateAttributeRequest createAttributeRequest =
           CreateAttributeRequest.newBuilder()
@@ -74,7 +68,13 @@ public static void main(String[] args) {
           "Successfully created attribute with ID: {}",
           createAttributeResponse.getAttribute().getId());
     } catch (Exception e) {
-      logger.fatal("Failed to create attribute", e);
+      if (Objects.equals(e.getMessage(), "resource not found")) {
+        logger.error("Namespace '{}' not found", namespaceName, e);
+      } else if (Objects.equals(e.getMessage(), "resource unique field violation")) {
+        logger.error("Attribute already exists", e);
+      } else {
+        logger.error("Failed to create attribute", e);
+      }
     }
   }
 }
diff --git a/examples/src/main/java/io/opentdf/platform/CreateNamespace.java b/examples/src/main/java/io/opentdf/platform/CreateNamespace.java
@@ -8,6 +8,7 @@
 import org.apache.logging.log4j.Logger;
 
 import java.util.Collections;
+import java.util.Objects;
 
 public class CreateNamespace {
 
@@ -18,6 +19,7 @@ public static void main(String[] args) {
     String clientId = "opentdf";
     String clientSecret = "secret";
     String platformEndpoint = "localhost:8080";
+    String namespaceName = "mynamespace.com";
 
     SDKBuilder builder = new SDKBuilder();
 
@@ -29,7 +31,7 @@ public static void main(String[] args) {
             .build()) {
 
       CreateNamespaceRequest createNamespaceRequest =
-          CreateNamespaceRequest.newBuilder().setName("mynamespace.com").build();
+          CreateNamespaceRequest.newBuilder().setName(namespaceName).build();
 
       CreateNamespaceResponse createNamespaceResponse =
           ResponseMessageKt.getOrThrow(
@@ -43,7 +45,11 @@ public static void main(String[] args) {
           createNamespaceResponse.getNamespace().getId());
 
     } catch (Exception e) {
-      logger.fatal("Failed to create namespace", e);
+      if (Objects.equals(e.getMessage(), "resource unique field violation")) {
+        logger.error("Namespace '{}' already exists", namespaceName, e);
+      } else {
+        logger.error("Failed to create namespace", e);
+      }
     }
   }
 }
diff --git a/examples/src/main/java/io/opentdf/platform/CreateSubjectConditionSet.java b/examples/src/main/java/io/opentdf/platform/CreateSubjectConditionSet.java
@@ -60,14 +60,15 @@ public static void main(String[] args) {
                   .createSubjectConditionSetBlocking(
                       createSubjectConditionSetRequest, Collections.emptyMap())
                   .execute());
+
       SubjectConditionSet subjectConditionSet =
           createSubjectConditionSetResponse.getSubjectConditionSet();
 
       logger.info(
           "Successfully created subject condition set with ID: {}", subjectConditionSet.getId());
 
     } catch (Exception e) {
-      logger.fatal("Failed to create subject condition set", e);
+      logger.error("Failed to create subject condition set", e);
     }
   }
 }
diff --git a/examples/src/main/java/io/opentdf/platform/CreateSubjectMapping.java b/examples/src/main/java/io/opentdf/platform/CreateSubjectMapping.java
@@ -3,7 +3,6 @@
 import com.connectrpc.ResponseMessageKt;
 import io.opentdf.platform.policy.Action;
 import io.opentdf.platform.policy.Attribute;
-import io.opentdf.platform.policy.AttributeRuleTypeEnum;
 import io.opentdf.platform.policy.Condition;
 import io.opentdf.platform.policy.ConditionBooleanTypeEnum;
 import io.opentdf.platform.policy.ConditionGroup;
@@ -12,8 +11,6 @@
 import io.opentdf.platform.policy.SubjectMapping;
 import io.opentdf.platform.policy.SubjectMappingOperatorEnum;
 import io.opentdf.platform.policy.SubjectSet;
-import io.opentdf.platform.policy.attributes.CreateAttributeRequest;
-import io.opentdf.platform.policy.attributes.CreateAttributeResponse;
 import io.opentdf.platform.policy.attributes.GetAttributeRequest;
 import io.opentdf.platform.policy.namespaces.GetNamespaceRequest;
 import io.opentdf.platform.policy.subjectmapping.CreateSubjectConditionSetRequest;
@@ -26,8 +23,8 @@
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 
-import java.util.Arrays;
 import java.util.Collections;
+import java.util.Objects;
 
 public class CreateSubjectMapping {
 
@@ -37,6 +34,8 @@ public static void main(String[] args) {
     String clientId = "opentdf";
     String clientSecret = "secret";
     String platformEndpoint = "localhost:8080";
+    String namespaceName = "mynamespace.com";
+    String attributeName = "test-attribute";
 
     SDKBuilder builder = new SDKBuilder();
     try (SDK sdk =
@@ -47,7 +46,6 @@ public static void main(String[] args) {
             .build()) {
 
       Namespace namespace;
-      String namespaceName = "mynamespace.com";
 
       try {
         namespace =
@@ -62,12 +60,15 @@ public static void main(String[] args) {
                         .execute())
                 .getNamespace();
       } catch (Exception e) {
-        logger.error("Namespace '{}' not found", namespaceName);
-        throw e;
+        if (Objects.equals(e.getMessage(), "resource not found")) {
+          logger.error("Namespace '{}' not found", namespaceName, e);
+        } else {
+          logger.error("Failed to retrieve namespace '{}'", namespaceName, e);
+        }
+        return;
       }
 
       Attribute attribute;
-      String attributeName = "test-attribute";
       String attributeFqn = namespace.getFqn() + "/attr/" + attributeName;
 
       try {
@@ -82,29 +83,13 @@ public static void main(String[] args) {
                         .execute())
                 .getAttribute();
 
-        logger.info("Found existing attribute with ID: {}", attribute.getId());
-
       } catch (Exception e) {
-        CreateAttributeRequest attributeRequest =
-            CreateAttributeRequest.newBuilder()
-                .setNamespaceId(namespace.getId())
-                .setName(attributeName)
-                .setRule(
-                    AttributeRuleTypeEnum.forNumber(
-                        AttributeRuleTypeEnum.ATTRIBUTE_RULE_TYPE_ENUM_ALL_OF_VALUE))
-                .addAllValues(Arrays.asList("test1", "test2"))
-                .build();
-
-        CreateAttributeResponse attributeResponse =
-            ResponseMessageKt.getOrThrow(
-                sdk.getServices()
-                    .attributes()
-                    .createAttributeBlocking(attributeRequest, Collections.emptyMap())
-                    .execute());
-
-        attribute = attributeResponse.getAttribute();
-
-        logger.info("Successfully created attribute with ID: {}", attribute.getId());
+        if (Objects.equals(e.getMessage(), "resource not found")) {
+          logger.error("Attribute '{}' not found", attributeFqn, e);
+        } else {
+          logger.error("Failed to retrieve attribute '{}'", attributeFqn, e);
+        }
+        return;
       }
 
       CreateSubjectConditionSetRequest subjectConditionSetRequest =
@@ -155,7 +140,7 @@ public static void main(String[] args) {
 
       logger.info("Successfully created subject mapping with ID: {}", subjectMapping.getId());
     } catch (Exception e) {
-      logger.fatal("Failed to create subject mapping", e);
+      logger.error("Failed to create subject mapping", e);
     }
   }
 }
diff --git a/examples/src/main/java/io/opentdf/platform/GetDecisions.java b/examples/src/main/java/io/opentdf/platform/GetDecisions.java
@@ -16,6 +16,7 @@
 import java.util.Collections;
 
 import java.util.List;
+import java.util.stream.Collectors;
 
 public class GetDecisions {
 
@@ -64,9 +65,14 @@ public static void main(String[] args) {
 
       List<DecisionResponse> decisions = getDecisionsResponse.getDecisionResponsesList();
 
-      logger.info("Successfully retrieved decision {}", decisions.get(0).getDecision());
+      logger.info(
+          "Successfully retrieved decisions: [{}]",
+          decisions.stream()
+              .map(DecisionResponse::getDecision)
+              .map(DecisionResponse.Decision::toString)
+              .collect(Collectors.joining(", ")));
     } catch (Exception e) {
-      logger.fatal("Failed to get decisions", e);
+      logger.error("Failed to get decisions", e);
     }
   }
 }
diff --git a/examples/src/main/java/io/opentdf/platform/GetEntitlements.java b/examples/src/main/java/io/opentdf/platform/GetEntitlements.java
@@ -12,6 +12,7 @@
 import java.util.Collections;
 
 import java.util.List;
+import java.util.stream.Collectors;
 
 public class GetEntitlements {
   private static final Logger logger = LogManager.getLogger(GetEntitlements.class);
@@ -46,10 +47,13 @@ public static void main(String[] args) {
       List<EntityEntitlements> entitlements = getEntitlementsResponse.getEntitlementsList();
 
       logger.info(
-          "Successfully retrieved entitlements {}",
-          entitlements.get(0).getAttributeValueFqnsList());
+          "Successfully retrieved entitlements: [{}]",
+          entitlements.stream()
+              .map(EntityEntitlements::getAttributeValueFqnsList)
+              .map(List::toString)
+              .collect(Collectors.joining(", ")));
     } catch (Exception e) {
-      logger.fatal("Failed to get entitlements", e);
+      logger.error("Failed to get entitlements", e);
     }
   }
 }
diff --git a/examples/src/main/java/io/opentdf/platform/ListAttributes.java b/examples/src/main/java/io/opentdf/platform/ListAttributes.java
@@ -44,10 +44,10 @@ public static void main(String[] args) {
       List<Attribute> attributes = listAttributesResponse.getAttributesList();
 
       logger.info(
-          "Successfully retrieved attributes {}",
+          "Successfully retrieved attributes: [{}]",
           attributes.stream().map(Attribute::getFqn).collect(Collectors.joining(", ")));
     } catch (Exception e) {
-      logger.fatal("Failed to list attributes", e);
+      logger.error("Failed to list attributes", e);
     }
   }
 }
diff --git a/examples/src/main/java/io/opentdf/platform/ListNamespaces.java b/examples/src/main/java/io/opentdf/platform/ListNamespaces.java
@@ -42,10 +42,10 @@ public static void main(String[] args) {
       List<Namespace> namespaces = listNamespacesResponse.getNamespacesList();
 
       logger.info(
-          "Successfully retrieved namespaces {}",
+          "Successfully retrieved namespaces: [{}]",
           namespaces.stream().map(Namespace::getFqn).collect(Collectors.joining(", ")));
     } catch (Exception e) {
-      logger.fatal("Failed to list namespaces", e);
+      logger.error("Failed to list namespaces", e);
     }
   }
 }
diff --git a/examples/src/main/java/io/opentdf/platform/ListSubjectMappings.java b/examples/src/main/java/io/opentdf/platform/ListSubjectMappings.java
@@ -44,10 +44,10 @@ public static void main(String[] args) {
       List<SubjectMapping> subjectMappings = listSubjectMappingsResponse.getSubjectMappingsList();
 
       logger.info(
-          "Successfully retrieved subject mappings {}",
+          "Successfully retrieved subject mappings: [{}]",
           subjectMappings.stream().map(SubjectMapping::getId).collect(Collectors.joining(", ")));
     } catch (Exception e) {
-      logger.fatal("Failed to list subject mappings", e);
+      logger.error("Failed to list subject mappings", e);
     }
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -60,14 +60,15 @@ public static void main(String[] args) {`
`60`	`60`	`.createSubjectConditionSetBlocking(`
`61`	`61`	`createSubjectConditionSetRequest, Collections.emptyMap())`
`62`	`62`	`.execute());`
	`63`	`+`
`63`	`64`	`SubjectConditionSet subjectConditionSet =`
`64`	`65`	`createSubjectConditionSetResponse.getSubjectConditionSet();`
`65`	`66`
`66`	`67`	`logger.info(`
`67`	`68`	`"Successfully created subject condition set with ID: {}", subjectConditionSet.getId());`
`68`	`69`
`69`	`70`	`} catch (Exception e) {`
`70`		`- logger.fatal("Failed to create subject condition set", e);`
	`71`	`+ logger.error("Failed to create subject condition set", e);`
`71`	`72`	`}`
`72`	`73`	`}`
`73`	`74`	`}`
Original file line number	Diff line number	Diff line change
`@@ -16,6 +16,7 @@`
`16`	`16`	`import java.util.Collections;`
`17`	`17`
`18`	`18`	`import java.util.List;`
	`19`	`+import java.util.stream.Collectors;`
`19`	`20`
`20`	`21`	`public class GetDecisions {`
`21`	`22`
`@@ -64,9 +65,14 @@ public static void main(String[] args) {`
`64`	`65`
`65`	`66`	`List<DecisionResponse> decisions = getDecisionsResponse.getDecisionResponsesList();`
`66`	`67`
`67`		`- logger.info("Successfully retrieved decision {}", decisions.get(0).getDecision());`
	`68`	`+ logger.info(`
	`69`	`+ "Successfully retrieved decisions: [{}]",`
	`70`	`+ decisions.stream()`
	`71`	`+ .map(DecisionResponse::getDecision)`
	`72`	`+ .map(DecisionResponse.Decision::toString)`
	`73`	`+ .collect(Collectors.joining(", ")));`
`68`	`74`	`} catch (Exception e) {`
`69`		`- logger.fatal("Failed to get decisions", e);`
	`75`	`+ logger.error("Failed to get decisions", e);`
`70`	`76`	`}`
`71`	`77`	`}`
`72`	`78`	`}`
Original file line number	Diff line number	Diff line change
`@@ -44,10 +44,10 @@ public static void main(String[] args) {`
`44`	`44`	`List<Attribute> attributes = listAttributesResponse.getAttributesList();`
`45`	`45`
`46`	`46`	`logger.info(`
`47`		`- "Successfully retrieved attributes {}",`
	`47`	`+ "Successfully retrieved attributes: [{}]",`
`48`	`48`	`attributes.stream().map(Attribute::getFqn).collect(Collectors.joining(", ")));`
`49`	`49`	`} catch (Exception e) {`
`50`		`- logger.fatal("Failed to list attributes", e);`
	`50`	`+ logger.error("Failed to list attributes", e);`
`51`	`51`	`}`
`52`	`52`	`}`
`53`	`53`	`}`
Original file line number	Diff line number	Diff line change
`@@ -42,10 +42,10 @@ public static void main(String[] args) {`
`42`	`42`	`List<Namespace> namespaces = listNamespacesResponse.getNamespacesList();`
`43`	`43`
`44`	`44`	`logger.info(`
`45`		`- "Successfully retrieved namespaces {}",`
	`45`	`+ "Successfully retrieved namespaces: [{}]",`
`46`	`46`	`namespaces.stream().map(Namespace::getFqn).collect(Collectors.joining(", ")));`
`47`	`47`	`} catch (Exception e) {`
`48`		`- logger.fatal("Failed to list namespaces", e);`
	`48`	`+ logger.error("Failed to list namespaces", e);`
`49`	`49`	`}`
`50`	`50`	`}`
`51`	`51`	`}`