PVA Server: Provide ClientInfo

Author: kasemir

core/pva/src/main/java/org/epics/pva/server/PVAServer.java

@@ -10,6 +10,7 @@
 import static org.epics.pva.PVASettings.logger;
 
 import java.net.InetSocketAddress;
+import java.util.Collection;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentHashMap.KeySetView;
 import java.util.concurrent.ForkJoinPool;
@@ -161,6 +162,26 @@ ServerPV getPV(final int sid)
         return pv_by_sid.get(sid);
     }
 
+
+    /** Info about a client to the PVA server:
+     *  Network address and authentication info
+     */
+    public static record ClientInfo(InetSocketAddress address,
+                                    ServerAuth authentication)
+    {
+    }
+
+    /** Get information about clients to this PVA server
+     *  @return {@link ClientInfo}s
+     */
+    public Collection<ClientInfo> getClientInfos()
+    {
+        return tcp_handlers.stream()
+                           .map(tcp -> new ClientInfo(tcp.getRemoteAddress(),
+                                                      tcp.getAuth()))
+                           .toList();
+    }
+
     /** Special address used in TCP search reply to indicate "Use this TCP connection" */
     private static final InetSocketAddress USE_THIS_TCP_CONNECTION = new InetSocketAddress(0);
 

core/pva/src/main/java/org/epics/pva/server/ServerAuth.java

@@ -1,5 +1,5 @@
 /*******************************************************************************
- * Copyright (c) 2019-2023 Oak Ridge National Laboratory.
+ * Copyright (c) 2019-2025 Oak Ridge National Laboratory.
  * All rights reserved. This program and the accompanying materials
  * are made available under the terms of the Eclipse Public License v1.0
  * which accompanies this distribution, and is available at
@@ -20,7 +20,7 @@
  *  @author Kay Kasemir
  */
 @SuppressWarnings("nls")
-abstract class ServerAuth
+public abstract class ServerAuth
 {
     /** @param channel Channel for which to check write access
      *  @return Does client have write access?
@@ -62,7 +62,7 @@ public static ServerAuth decode(final ServerTCPHandler tcp, final ByteBuffer buf
 
         if (PVAAuth.X509.equals(auth))
             return new X509ServerAuth(tls_info);
-        
+
         return Anonymous;
     }