Ux analytics plugin

app/display/runtime/src/main/java/org/csstudio/display/builder/runtime/app/DisplayRuntimeInstance.java

@@ -174,6 +174,7 @@ public static DisplayRuntimeInstance ofDisplayModel(final DisplayModel model)
         layout.addEventFilter(KeyEvent.KEY_PRESSED, this::handleKeys);
 
         dock_item.addClosedNotification(this::onClosed);
+        representation_init.run();
     }
 
     @Override
@@ -543,6 +544,11 @@ public void onClosed()
         navigation.dispose();
     }
 
+    DisplayModel getActiveModel()
+    {
+        return active_model;
+    }
+
     public void addListener(ToolkitListener listener){
         this.getRepresentation().removeListener(listener);
         this.getRepresentation().addListener(listener);

app/pom.xml

@@ -38,5 +38,6 @@
     <module>credentials-management</module>
     <module>eslog</module>
     <module>queue-server</module>
+    <module>ux-analytics</module>
   </modules>
 </project>

app/ux-analytics/monitor/pom.xml

@@ -0,0 +1,170 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+
+    <parent>
+        <groupId>org.phoebus</groupId>
+        <artifactId>app-ux-analytics</artifactId>
+        <version>5.0.3-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>app-analytics-monitor</artifactId>
+
+    <properties>
+        <maven.compiler.source>22</maven.compiler.source>
+        <maven.compiler.target>22</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.openjfx</groupId>
+            <artifactId>javafx-graphics</artifactId>
+            <version>19</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.openjfx</groupId>
+            <artifactId>javafx-fxml</artifactId>
+            <version>19</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.phoebus</groupId>
+            <artifactId>core-framework</artifactId>
+            <version>5.0.3-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.phoebus</groupId>
+            <artifactId>core-ui</artifactId>
+            <version>5.0.3-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.phoebus</groupId>
+            <artifactId>app-display-model</artifactId>
+            <version>5.0.3-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.phoebus</groupId>
+            <artifactId>app-display-runtime</artifactId>
+            <version>5.0.3-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+            <version>4.5.14</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter</artifactId>
+            <version>${junit.version}</version>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.mariadb.jdbc</groupId>
+            <artifactId>mariadb-java-client</artifactId>
+            <version>3.4.0</version>
+            <scope>runtime</scope>
+        </dependency>
+        <!-- https://mvnrepository.com/artifact/com.sun.jersey.contribs/jersey-multipart -->
+        <dependency>
+            <groupId>com.sun.jersey.contribs</groupId>
+            <artifactId>jersey-multipart</artifactId>
+            <version>1.19</version>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.datatype</groupId>
+            <artifactId>jackson-datatype-jsr310</artifactId>
+            <version>${jackson.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.sun.activation</groupId>
+            <artifactId>javax.activation</artifactId>
+            <version>1.2.0</version>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-core</artifactId>
+            <version>${jackson.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.sun.jersey</groupId>
+            <artifactId>jersey-client</artifactId>
+            <version>1.19.4</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.glassfish.jersey.core</groupId>
+            <artifactId>jersey-common</artifactId>
+            <version>2.22.2</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.sun.jersey</groupId>
+            <artifactId>jersey-json</artifactId>
+            <version>1.19.4</version>
+        </dependency>
+        <dependency>
+            <groupId>javax.ws.rs</groupId>
+            <artifactId>javax.ws.rs-api</artifactId>
+            <version>2.1.1</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.phoebus</groupId>
+            <artifactId>app-filebrowser</artifactId>
+            <version>5.0.3-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.testng</groupId>
+            <artifactId>testng</artifactId>
+            <version>RELEASE</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.testfx</groupId>
+            <artifactId>testfx-junit</artifactId>
+            <version>4.0.13-alpha</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.mockito</groupId>
+            <artifactId>mockito-inline</artifactId>
+            <version>${mockito.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>net.bytebuddy</groupId>
+            <artifactId>byte-buddy</artifactId>
+            <version>1.17.5</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.mockito</groupId>
+            <artifactId>mockito-core</artifactId>
+            <version>5.11.0</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <resources>
+            <resource>
+                <directory>src/main/resources</directory>
+            </resource>
+            <resource>
+                <directory>src/main/java</directory>
+                <includes>
+                    <include>**/*.fxml</include>
+                </includes>
+            </resource>
+        </resources>
+    </build>
+</project>

app/ux-analytics/monitor/src/main/java/org/phoebus/applications/uxanalytics/monitor/UXAMonitor.java

@@ -0,0 +1,58 @@
+package org.phoebus.applications.uxanalytics.monitor;
+
+
+import java.util.ArrayList;
+import java.util.concurrent.ExecutorService;
+
+import javafx.stage.Stage;
+import org.csstudio.display.builder.runtime.RuntimeUtil;
+import org.phoebus.applications.uxanalytics.monitor.backend.database.BackendConnection;
+import org.phoebus.applications.uxanalytics.monitor.representation.ActiveWindowsService;
+
+/**
+ * Singleton Class to capture UI events (clicks, PV Writes, Display open/close)
+ * and dispatch them to backend connections
+ */
+public class UXAMonitor{
+    private static final UXAMonitor instance = new UXAMonitor();
+    private ArrayList<Stage> activeStages;
+    private static ActiveWindowsService activeWindowsService = ActiveWindowsService.getInstance();
+    private static final ExecutorService executor = RuntimeUtil.getExecutor();
+
+    //This dispatcher has exactly one phoebus related connection and one JFX related connection
+    //If you want to broadcast to multiple back-ends, subclass BackendConnection to notify them.
+    private BackendConnection phoebusConnection;
+    private BackendConnection jfxConnection;
+
+    private UXAMonitor(){
+    }
+
+    public BackendConnection getJfxConnection() {return jfxConnection;}
+
+    public BackendConnection getPhoebusConnection() { return phoebusConnection;}
+
+    public static synchronized UXAMonitor getInstance() {
+        return instance;
+    }
+
+    public void notifyConnectionChange(BackendConnection connection){
+        jfxConnection = connection;
+        phoebusConnection = connection;
+    }
+
+    public void setPhoebusConnection(BackendConnection phoebusConnection) {
+        this.phoebusConnection = phoebusConnection;
+    }
+
+    public void disableTracking(){
+        activeWindowsService.stop();
+    }
+
+    public void enableTracking(){
+        activeWindowsService.start();
+    }
+
+    public void setJfxConnection(BackendConnection jfxConnection) {
+        this.jfxConnection = jfxConnection;
+    }
+}

app/ux-analytics/monitor/src/main/java/org/phoebus/applications/uxanalytics/monitor/UXAMouseMonitor.java

@@ -0,0 +1,22 @@
+package org.phoebus.applications.uxanalytics.monitor;
+
+import javafx.event.EventHandler;
+import javafx.scene.input.MouseEvent;
+import org.phoebus.applications.uxanalytics.monitor.representation.ActiveTab;
+
+public class UXAMouseMonitor implements EventHandler<MouseEvent>{
+
+    private final UXAMonitor monitor = UXAMonitor.getInstance();
+    private final ActiveTab tab;
+
+    public UXAMouseMonitor(ActiveTab tab){
+        this.tab = tab;
+    }
+
+    @Override
+    public void handle(MouseEvent event) {
+        if(event.getEventType().equals(MouseEvent.MOUSE_CLICKED)){
+            monitor.getJfxConnection().handleClick(tab, (int) event.getX(), (int) event.getY());
+        }
+    }
+}

app/ux-analytics/monitor/src/main/java/org/phoebus/applications/uxanalytics/monitor/UXAToolkitListener.java

@@ -0,0 +1,113 @@
+package org.phoebus.applications.uxanalytics.monitor;
+
+import org.csstudio.display.builder.model.Widget;
+import org.csstudio.display.builder.model.spi.ActionInfo;
+import org.csstudio.display.builder.model.properties.ActionInfoBase;
+import org.csstudio.display.builder.representation.ToolkitListener;
+import org.csstudio.display.builder.runtime.app.DisplayInfo;
+import org.phoebus.applications.uxanalytics.monitor.representation.ActiveTab;
+import org.phoebus.applications.uxanalytics.monitor.util.ResourceOpenSources;
+
+import java.util.*;
+import java.util.logging.Logger;
+
+
+public class UXAToolkitListener implements ToolkitListener {
+
+    Logger logger = Logger.getLogger(UXAToolkitListener.class.getName());
+
+    public static final HashMap<String, ResourceOpenSources> openSources = new HashMap<>(
+            Map.of(
+                    org.csstudio.display.builder.runtime.app.actionhandlers.OpenDisplayActionHandler.class.getName()+".handleAction", ResourceOpenSources.ACTION_BUTTON,
+                    org.phoebus.applications.filebrowser.FileBrowserController.class.getName()+".openResource", ResourceOpenSources.FILE_BROWSER,
+                    org.phoebus.ui.application.PhoebusApplication.class.getName()+".fileOpen", ResourceOpenSources.FILE_BROWSER,
+                    org.csstudio.display.builder.runtime.app.NavigationAction.class.getName()+".navigate", ResourceOpenSources.NAVIGATION_BUTTON,
+                    org.phoebus.ui.internal.MementoHelper.class.getName()+".restoreDockItem", ResourceOpenSources.RESTORED,
+                    org.phoebus.ui.application.PhoebusApplication.class.getName()+".createTopResourcesMenu", ResourceOpenSources.TOP_RESOURCES,
+                    org.csstudio.display.builder.runtime.app.DisplayRuntimeInstance.class.getName()+".reload", ResourceOpenSources.RELOAD
+            )
+    );
+
+    private ActiveTab tabWrapper;
+    private final UXAMonitor monitor = UXAMonitor.getInstance();
+    public void setTabWrapper(ActiveTab tabWrapper){
+        this.tabWrapper = tabWrapper;
+    }
+
+    @Override
+    public void handleAction(Widget widget, ActionInfo action) {
+        monitor.getPhoebusConnection().handleAction(tabWrapper, widget, action);
+    }
+
+    @Override
+    public void handleWrite(Widget widget, Object value) {
+        monitor.getPhoebusConnection().handlePVWrite(tabWrapper, widget, widget.getPropertyValue("pv_name"), value.toString());
+    }
+
+    @Override
+    public void handleClick(Widget widget, boolean with_control) {
+        //nothing for now
+    }
+
+    //Traverse down a given call stack to find out what caused the display to open
+    private static ResourceOpenSources getSourceOfOpen(StackTraceElement[] stackTrace){
+
+        for(StackTraceElement e: stackTrace){
+            String methodName =  unmangleLambda(e.getMethodName());
+            String fullName = e.getClassName()+"."+methodName;
+            if(openSources.containsKey(fullName)){
+                return openSources.get(fullName);
+            }
+        }
+        return ResourceOpenSources.UNKNOWN;
+    }
+
+    private static String unmangleLambda(String expression){
+        //find index of first '$' after 'lambda$'
+        if(expression.contains("lambda$")) {
+            int start = expression.indexOf("lambda$") + 7;
+            int end = expression.indexOf("$", start);
+            return expression.substring(start, end);
+        }
+        return expression;
+    }
+
+    public UXAMonitor getMonitor() {
+        return monitor;
+    }
+
+    @Override
+    public void handleMethodCalled(Object... user_args) {
+        StackTraceElement[] stackTrace;
+        if(user_args[0] instanceof List &&
+                ((List) user_args[0]).get(0) instanceof DisplayInfo &&
+                user_args[1] instanceof StackTraceElement[] &&
+                monitor.getPhoebusConnection()!=null) {
+            List<DisplayInfo> dst_src = (List<DisplayInfo>) user_args[0];
+            stackTrace = (StackTraceElement[]) user_args[1];
+            for(StackTraceElement e: stackTrace){
+                String methodName = e.getMethodName();
+                if (methodName.equals("loadDisplayFile")) {
+                    ResourceOpenSources source = getSourceOfOpen(stackTrace);
+                    switch(source){
+                        case ACTION_BUTTON:
+                            //nothing, handled by handleAction
+                            break;
+
+                        case NAVIGATION_BUTTON:
+                        case RELOAD:
+                            monitor.getPhoebusConnection().handleDisplayOpen(dst_src.get(0), dst_src.get(1), source);
+                            break;
+
+                        case FILE_BROWSER:
+                        case RESTORED:
+                        case TOP_RESOURCES:
+                        case UNKNOWN:
+                            monitor.getPhoebusConnection().handleDisplayOpen(dst_src.get(0), null, source);
+                    }
+                }
+            }
+        }
+    }
+}
+