more run stuff into the shell script

examples/auth/callout/java/Main.java

@@ -53,13 +53,8 @@ public static void main(String[] args) throws Exception {
       // ----------------------------------------------------------------------------------------------------
       CompletableFuture<Boolean> serviceStoppedFuture = acService.startService();
 
-      test(natsURL, "alice", "alice", "test", "should connect, publish and receive");
-      test(natsURL, "alice", "wrong", "n/a", "should not connect");
-      test(natsURL, "bob", "bob", "bob.test", "should connect, publish and receive");
-      test(natsURL, "bob", "bob", "test", "should connect, publish but not receive");
-
       // plenty of time to finish running the main.sh example script
-      Thread.sleep(2000);
+      Thread.sleep(20000);
 
       // A real service will do something like this
       // serviceStoppedFuture.get();
@@ -68,49 +63,5 @@ public static void main(String[] args) throws Exception {
       e.printStackTrace();
     }
   }
-
-  public static void test(String natsURL, String u, String p, String subject, String behavior) {
-    System.out.println("\n--------------------------------------------------------------------------------");
-    System.out.println("[TEST] user     : " + u);
-    System.out.println("[TEST] subject  : " + subject);
-    System.out.println("[TEST] behavior : " + behavior);
-
-    Options options = new Options.Builder()
-        .server(natsURL)
-        .errorListener(new ErrorListener() {})
-        .userInfo(u, p)
-        .maxReconnects(3)
-        .build();
-
-    boolean connected = false;
-    try (Connection nc = Nats.connect(options)) {
-      System.out.println("[TEST] connected " + u);
-      connected = true;
-
-      AtomicBoolean gotMessage = new AtomicBoolean(false);
-      Dispatcher d = nc.createDispatcher(m -> {
-        System.out.println("[TEST] received message on '" + m.getSubject() + "'");
-        gotMessage.set(true);
-      });
-      d.subscribe(subject);
-
-      nc.publish(subject, (u + "-publish-" + System.currentTimeMillis()).getBytes());
-      System.out.println("[TEST] published to '" + subject + "'");
-
-      Thread.sleep(1000); // just giving time for publish to work
-
-      if (!gotMessage.get()) {
-        System.out.println("[TEST] no message from '" + subject + "'");
-      }
-    }
-    catch (Exception e) {
-      if (connected) {
-        System.out.println("[TEST] post connection exception, " + e);
-      }
-      else {
-        System.out.println("[TEST] did not connect, " + e);
-      }
-    }
-  }
 }
 

examples/auth/callout/java/main.sh

@@ -72,3 +72,26 @@ sleep 1
 # Start the auth callout service providing the auth credentials
 # to connect and the issuer seed.
 java -cp /app/example.jar example.Main &
+
+sleep 2
+
+# Users sys, alice and bob are known to the example code
+# Confirm alice can connect and publish.
+echo -e '\n\n--------------------------------------------------\nTest alice'
+nats --user alice --password alice pub test 'hello from alice'
+
+# Confirm bob cannot publish to a subject they are not allowed to.
+echo -e '\n\n--------------------------------------------------\nTest bob on denied subject'
+nats --user bob --password bob pub test 'hello from bob' || true
+
+# Confirm bob can connect and publish to a subject they are allowed to.
+echo -e '\n\n--------------------------------------------------\nTest bob on allowed subject'
+nats --user bob --password bob pub bob.test 'hello from bob'
+
+# Confirm an unknown user cannot connect.
+echo -e '\n\n--------------------------------------------------\nTest unknown user'
+nats --user pam --password pam pub test 'hello from pam' || true
+
+# Confirm the system account user has the expected system permission.
+echo -e '\n\n--------------------------------------------------\nTest system account user'
+nats --user sys --password sys server list