fix(examples): improve logging and setup logic in examples

.github/workflows/checks.yaml

@@ -42,18 +42,20 @@ jobs:
             revert
           # Scopes include:
           #   - ci: anything related to ci
-          #   - cmdline: changes to @opentdf/ctl
+          #   - cmdline: changes to cmdline
           #   - docs: anything related solely to documentation
           #   - main: bot generated commits
-          #   - sdk: changes to @opentdf/sdk (was lib)
+          #   - sdk: changes to sdk
           #   - tests: test only changes
+          #   - examples: examples only changes
           scopes: |
             ci
             cmdline
             docs
             main
             sdk
             tests
+            examples
 
   mavenverify:
     runs-on: ubuntu-latest

examples/src/main/java/io/opentdf/platform/CreateAttribute.java

@@ -1,37 +1,80 @@
 package io.opentdf.platform;
+
 import com.connectrpc.ResponseMessageKt;
-import io.opentdf.platform.policy.Attribute;
 import io.opentdf.platform.policy.AttributeRuleTypeEnum;
+import io.opentdf.platform.policy.Namespace;
 import io.opentdf.platform.policy.attributes.CreateAttributeRequest;
 import io.opentdf.platform.policy.attributes.CreateAttributeResponse;
+import io.opentdf.platform.policy.namespaces.GetNamespaceRequest;
 import io.opentdf.platform.sdk.*;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
 
 import java.util.Collections;
-import java.util.concurrent.ExecutionException;
 
 import java.util.Arrays;
+import java.util.Objects;
 
 public class CreateAttribute {
-    public static void main(String[] args) {
 
-        String clientId = "opentdf";
-        String clientSecret = "secret";
-        String platformEndpoint = "localhost:8080";
+  private static final Logger logger = LogManager.getLogger(CreateAttribute.class);
+
+  public static void main(String[] args) {
+
+    String clientId = "opentdf";
+    String clientSecret = "secret";
+    String platformEndpoint = "localhost:8080";
+    String namespaceName = "opentdf.io";
+
+    SDKBuilder builder = new SDKBuilder();
 
-        SDKBuilder builder = new SDKBuilder();
-        SDK sdk = builder.platformEndpoint(platformEndpoint)
-                .clientSecret(clientId, clientSecret).useInsecurePlaintextConnection(true)
-                .build();
+    try (SDK sdk =
+        builder
+            .platformEndpoint(platformEndpoint)
+            .clientSecret(clientId, clientSecret)
+            .useInsecurePlaintextConnection(true)
+            .build()) {
 
-        CreateAttributeRequest request = CreateAttributeRequest.newBuilder()
-        .setNamespaceId("877990d1-609b-42ab-a273-4253b8b321eb")
-        .setName("test")
-        .setRule(AttributeRuleTypeEnum.forNumber(AttributeRuleTypeEnum.ATTRIBUTE_RULE_TYPE_ENUM_ALL_OF_VALUE))
-        .addAllValues(Arrays.asList("test1", "test2")).build();
+      Namespace namespace =
+          ResponseMessageKt.getOrThrow(
+                  sdk.getServices()
+                      .namespaces()
+                      .getNamespaceBlocking(
+                          GetNamespaceRequest.newBuilder()
+                              .setFqn("https://" + namespaceName)
+                              .build(),
+                          Collections.emptyMap())
+                      .execute())
+              .getNamespace();
 
-        CreateAttributeResponse resp = ResponseMessageKt.getOrThrow(sdk.getServices().attributes().createAttributeBlocking(request, Collections.emptyMap()).execute());
+      CreateAttributeRequest createAttributeRequest =
+          CreateAttributeRequest.newBuilder()
+              .setNamespaceId(namespace.getId())
+              .setName("test-attribute")
+              .setRule(
+                  AttributeRuleTypeEnum.forNumber(
+                      AttributeRuleTypeEnum.ATTRIBUTE_RULE_TYPE_ENUM_ALL_OF_VALUE))
+              .addAllValues(Arrays.asList("test1", "test2"))
+              .build();
 
-        Attribute attribute = resp.getAttribute();
+      CreateAttributeResponse createAttributeResponse =
+          ResponseMessageKt.getOrThrow(
+              sdk.getServices()
+                  .attributes()
+                  .createAttributeBlocking(createAttributeRequest, Collections.emptyMap())
+                  .execute());
 
+      logger.info(
+          "Successfully created attribute with ID: {}",
+          createAttributeResponse.getAttribute().getId());
+    } catch (Exception 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);
+      }
     }
+  }
 }

examples/src/main/java/io/opentdf/platform/CreateNamespace.java

@@ -1,29 +1,55 @@
 package io.opentdf.platform;
+
 import com.connectrpc.ResponseMessageKt;
 import io.opentdf.platform.policy.namespaces.CreateNamespaceRequest;
 import io.opentdf.platform.policy.namespaces.CreateNamespaceResponse;
 import io.opentdf.platform.sdk.*;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
 
 import java.util.Collections;
-import java.util.concurrent.ExecutionException;
+import java.util.Objects;
 
 public class CreateNamespace {
-    public static void main(String[] args) {
 
-        String clientId = "opentdf";
-        String clientSecret = "secret";
-        String platformEndpoint = "localhost:8080";
+  private static final Logger logger = LogManager.getLogger(CreateNamespace.class);
+
+  public static void main(String[] args) {
+
+    String clientId = "opentdf";
+    String clientSecret = "secret";
+    String platformEndpoint = "localhost:8080";
+    String namespaceName = "opentdf.io";
+
+    SDKBuilder builder = new SDKBuilder();
+
+    try (SDK sdk =
+        builder
+            .platformEndpoint(platformEndpoint)
+            .clientSecret(clientId, clientSecret)
+            .useInsecurePlaintextConnection(true)
+            .build()) {
 
-        SDKBuilder builder = new SDKBuilder();
-        SDK sdk = builder.platformEndpoint(platformEndpoint)
-                .clientSecret(clientId, clientSecret).useInsecurePlaintextConnection(true)
-                .build();
+      CreateNamespaceRequest createNamespaceRequest =
+          CreateNamespaceRequest.newBuilder().setName(namespaceName).build();
 
-        CreateNamespaceRequest request = CreateNamespaceRequest.newBuilder().setName("mynamespace.com").build();
+      CreateNamespaceResponse createNamespaceResponse =
+          ResponseMessageKt.getOrThrow(
+              sdk.getServices()
+                  .namespaces()
+                  .createNamespaceBlocking(createNamespaceRequest, Collections.emptyMap())
+                  .execute());
 
-        CreateNamespaceResponse resp = ResponseMessageKt.getOrThrow(sdk.getServices().namespaces().createNamespaceBlocking(request, Collections.emptyMap()).execute());
+      logger.info(
+          "Successfully created namespace with ID: {}",
+          createNamespaceResponse.getNamespace().getId());
 
-        System.out.println(resp.getNamespace().getName());
-
+    } catch (Exception 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);
+      }
     }
+  }
 }

examples/src/main/java/io/opentdf/platform/CreateSubjectConditionSet.java

@@ -1,4 +1,5 @@
 package io.opentdf.platform;
+
 import com.connectrpc.ResponseMessageKt;
 import io.opentdf.platform.policy.Condition;
 import io.opentdf.platform.policy.ConditionBooleanTypeEnum;
@@ -10,40 +11,64 @@
 import io.opentdf.platform.policy.subjectmapping.CreateSubjectConditionSetResponse;
 import io.opentdf.platform.policy.subjectmapping.SubjectConditionSetCreate;
 import io.opentdf.platform.sdk.*;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
 
 import java.util.Collections;
-import java.util.concurrent.ExecutionException;
-
 
 public class CreateSubjectConditionSet {
-    public static void main(String[] args) {
 
-        String clientId = "opentdf";
-        String clientSecret = "secret";
-        String platformEndpoint = "localhost:8080";
+  private static final Logger logger = LogManager.getLogger(CreateSubjectConditionSet.class);
+
+  public static void main(String[] args) {
+
+    String clientId = "opentdf";
+    String clientSecret = "secret";
+    String platformEndpoint = "localhost:8080";
+
+    SDKBuilder builder = new SDKBuilder();
+
+    try (SDK sdk =
+        builder
+            .platformEndpoint(platformEndpoint)
+            .clientSecret(clientId, clientSecret)
+            .useInsecurePlaintextConnection(true)
+            .build()) {
 
-        SDKBuilder builder = new SDKBuilder();
-        SDK sdk = builder.platformEndpoint(platformEndpoint)
-                .clientSecret(clientId, clientSecret).useInsecurePlaintextConnection(true)
-                .build();
+      SubjectSet.Builder subjectSetBuilder =
+          SubjectSet.newBuilder()
+              .addConditionGroups(
+                  ConditionGroup.newBuilder()
+                      .setBooleanOperator(ConditionBooleanTypeEnum.CONDITION_BOOLEAN_TYPE_ENUM_AND)
+                      .addConditions(
+                          Condition.newBuilder()
+                              .setSubjectExternalSelectorValue(".myfield")
+                              .setOperator(
+                                  SubjectMappingOperatorEnum.SUBJECT_MAPPING_OPERATOR_ENUM_IN)
+                              .addSubjectExternalValues("myvalue")));
 
-        var subjectset = SubjectSet.newBuilder().addConditionGroups(ConditionGroup.newBuilder()
-        .setBooleanOperator(ConditionBooleanTypeEnum.CONDITION_BOOLEAN_TYPE_ENUM_AND)
-        .addConditions(Condition.newBuilder()
-        .setSubjectExternalSelectorValue(".myfield")
-        .setOperator(SubjectMappingOperatorEnum.SUBJECT_MAPPING_OPERATOR_ENUM_IN)
-        .addSubjectExternalValues("myvalue")
-        ));
+      CreateSubjectConditionSetRequest createSubjectConditionSetRequest =
+          CreateSubjectConditionSetRequest.newBuilder()
+              .setSubjectConditionSet(
+                  SubjectConditionSetCreate.newBuilder().addSubjectSets(subjectSetBuilder))
+              .build();
 
-        CreateSubjectConditionSetRequest request = CreateSubjectConditionSetRequest.newBuilder()
-        .setSubjectConditionSet(
-            SubjectConditionSetCreate.newBuilder().addSubjectSets(subjectset))
-        .build();
+      CreateSubjectConditionSetResponse createSubjectConditionSetResponse =
+          ResponseMessageKt.getOrThrow(
+              sdk.getServices()
+                  .subjectMappings()
+                  .createSubjectConditionSetBlocking(
+                      createSubjectConditionSetRequest, Collections.emptyMap())
+                  .execute());
 
-        CreateSubjectConditionSetResponse resp = ResponseMessageKt.getOrThrow(sdk.getServices().subjectMappings().createSubjectConditionSetBlocking(request, Collections.emptyMap()).execute());
+      SubjectConditionSet subjectConditionSet =
+          createSubjectConditionSetResponse.getSubjectConditionSet();
 
-        SubjectConditionSet scs = resp.getSubjectConditionSet();
+      logger.info(
+          "Successfully created subject condition set with ID: {}", subjectConditionSet.getId());
 
-        System.out.println(scs.getId());
+    } catch (Exception e) {
+      logger.error("Failed to create subject condition set", e);
     }
+  }
 }