Log Levels View

headless-services/commons/commons-lsp-extensions/src/main/java/org/springframework/ide/vscode/commons/protocol/LiveProcessLoggersSummary.java

@@ -0,0 +1,16 @@
+/*******************************************************************************
+ * Copyright (c) 2023 Broadcom, Inc.
+ * 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
+ * https://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     Broadcom, Inc. - initial API and implementation
+ *******************************************************************************/
+package org.springframework.ide.vscode.commons.protocol;
+
+public record LiveProcessLoggersSummary(String processType, String processKey, String processName, String processID,
+		String packageName, String effectiveLevel, String configuredLevel) {
+
+}

headless-services/commons/commons-lsp-extensions/src/main/java/org/springframework/ide/vscode/commons/protocol/STS4LanguageClient.java

@@ -51,6 +51,9 @@ public interface STS4LanguageClient extends LanguageClient, SpringIndexLanguageC
 
 	@JsonNotification("sts/liveprocess/gcpauses/metrics/updated")
 	void liveProcessGcPausesMetricsDataUpdated(LiveProcessSummary processKey);
+
+	@JsonNotification("sts/liveprocess/loglevel/updated")
+	void liveProcessLogLevelUpdated(LiveProcessLoggersSummary liveProcessLoggersSummary);
 
 	@JsonNotification("sts/highlight")
 	void highlight(HighlightParams highlights);

headless-services/commons/language-server-test-harness/src/main/java/org/springframework/ide/vscode/languageserver/testharness/LanguageServerHarness.java

@@ -114,6 +114,7 @@
 import org.springframework.ide.vscode.commons.languageserver.util.SimpleLanguageServer;
 import org.springframework.ide.vscode.commons.protocol.CursorMovement;
 import org.springframework.ide.vscode.commons.protocol.HighlightParams;
+import org.springframework.ide.vscode.commons.protocol.LiveProcessLoggersSummary;
 import org.springframework.ide.vscode.commons.protocol.LiveProcessSummary;
 import org.springframework.ide.vscode.commons.protocol.STS4LanguageClient;
 import org.springframework.ide.vscode.commons.protocol.java.ClasspathListenerParams;
@@ -437,6 +438,10 @@ public void indexUpdated() {
 					receiveIndexUpdated();
 				}
 
+				@Override
+				public void liveProcessLogLevelUpdated(LiveProcessLoggersSummary processKey) {	
+				}
+
 			});
 
 		}

headless-services/spring-boot-language-server/src/main/java/org/springframework/ide/vscode/boot/java/livehover/v2/ActuatorConnection.java

@@ -33,4 +33,8 @@ public interface ActuatorConnection {
 	Map<?, ?> getStartup() throws IOException;
 
 	String getLiveMetrics(String metricName, String tags) throws IOException;
+
+	String getLoggers() throws IOException;
+
+	String configureLogLevel(Map<String, String> args) throws IOException;
 }

headless-services/spring-boot-language-server/src/main/java/org/springframework/ide/vscode/boot/java/livehover/v2/HttpActuatorConnection.java

@@ -80,6 +80,21 @@ public String getBeans() throws IOException {
 		return restTemplate.getForObject("/beans", String.class);
 	}
 
+	@Override
+	public String getLoggers() throws IOException {
+		return restTemplate.getForObject("/loggers", String.class);
+	}
+
+	@Override
+	public String configureLogLevel(Map<String, String> args) throws IOException {
+		UriComponentsBuilder uriBuilder = UriComponentsBuilder.fromPath("/loggers/"+args.get("packageName"));
+		if (args != null) {
+				uriBuilder.queryParam("configuredLevel", args.get("configuredLevel"));
+		}
+		String url = actuatorUrl + uriBuilder.toUriString();
+		return restTemplate.postForObject(URI.create(url), null, String.class);
+	}
+
 	@Override
 	public String getLiveMetrics(String metricName, String tags) throws IOException {
 		UriComponentsBuilder uriBuilder = UriComponentsBuilder.fromPath("/metrics/"+metricName);

headless-services/spring-boot-language-server/src/main/java/org/springframework/ide/vscode/boot/java/livehover/v2/LoggerInfo.java

@@ -0,0 +1,29 @@
+/*******************************************************************************
+ * Copyright (c) 2023 Broadcom, Inc.
+ * 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
+ * https://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     Broadcom, Inc. - initial API and implementation
+ *******************************************************************************/
+package org.springframework.ide.vscode.boot.java.livehover.v2;
+
+/**
+ * @author Udayani V
+ */
+public class LoggerInfo {
+
+	private String configuredLevel;
+
+    private String effectiveLevel;
+
+	public String getConfiguredLevel() {
+		return configuredLevel;
+	}
+	public String getEffectiveLevel() {
+		return effectiveLevel;
+	}
+
+}

headless-services/spring-boot-language-server/src/main/java/org/springframework/ide/vscode/boot/java/livehover/v2/Loggers.java

@@ -0,0 +1,35 @@
+/*******************************************************************************
+ * Copyright (c) 2023 Broadcom, Inc.
+ * 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
+ * https://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     Broadcom, Inc. - initial API and implementation
+ *******************************************************************************/
+package org.springframework.ide.vscode.boot.java.livehover.v2;
+
+import java.util.List;
+import java.util.Map;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+
+/**
+ * @author Udayani V
+ */
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class Loggers {
+
+	private List<String> levels;
+    private Map<String, LoggerInfo> loggers;
+
+	public List<String> getLevels() {
+		return levels;
+	}
+
+	public Map<String, LoggerInfo> getLoggers() {
+		return loggers;
+	}
+
+}

headless-services/spring-boot-language-server/src/main/java/org/springframework/ide/vscode/boot/java/livehover/v2/SpringProcessCommandHandler.java

@@ -12,6 +12,7 @@
 
 import java.util.ArrayList;
 import java.util.Collection;
+import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
@@ -43,6 +44,8 @@ public class SpringProcessCommandHandler {
 	private static final String COMMAND_LIST_CONNECTED = "sts/livedata/listConnected";
 	private static final String COMMAND_GET_METRICS = "sts/livedata/get/metrics";
 	private static final String COMMAND_GET_REFRESH_METRICS = "sts/livedata/refresh/metrics";
+	private static final String COMMAND_GET_LOGGERS = "sts/livedata/getLoggers";
+	private static final String COMMAND_CONFIGURE_LOGLEVEL = "sts/livedata/configure/logLevel";
 
 	private final SpringProcessConnectorService connectorService;
 	private final SpringProcessConnectorLocal localProcessConnector;
@@ -88,6 +91,16 @@ public SpringProcessCommandHandler(SimpleLanguageServer server, SpringProcessCon
 			return refreshMetrics(params);
 		});
 		log.info("Registered command handler: {}",COMMAND_GET_METRICS);
+
+		server.onCommand(COMMAND_GET_LOGGERS, (params) -> {
+			return getLoggers(params);
+		});
+		log.info("Registered command handler: {}",COMMAND_GET_LOGGERS);
+
+		server.onCommand(COMMAND_CONFIGURE_LOGLEVEL, (params) -> {
+			return configureLogLevel(params);
+		});
+		log.info("Registered command handler: {}",COMMAND_CONFIGURE_LOGLEVEL);
 
 		server.onCommand(COMMAND_LIST_CONNECTED, (params) -> {
 			List<LiveProcessSummary> result = new ArrayList<>();
@@ -320,4 +333,34 @@ private CompletableFuture<Object> handleLiveMetricsProcessRequest(ExecuteCommand
 		return CompletableFuture.completedFuture(null);
 	}
 
+
+	private CompletableFuture<Object> getLoggers(ExecuteCommandParams params) {
+		SpringProcessLoggersData loggersData = null;
+		SpringProcessParams springProcessParams = new SpringProcessParams();
+	    springProcessParams.setProcessKey(getProcessKey(params));    
+	    springProcessParams.setEndpoint(getArgumentByKey(params, "endpoint"));
+		if (springProcessParams.getProcessKey() != null) {
+			loggersData = connectorService.getLoggers(springProcessParams);
+			return CompletableFuture.completedFuture(loggersData);
+		}
+
+		return CompletableFuture.completedFuture(loggersData);
+	}
+
+	private CompletableFuture<Object> configureLogLevel(ExecuteCommandParams params) {
+		Map<String, String> args = new HashMap<>();
+	    args.put("packageName", getArgumentByKey(params, "packageName"));
+	    args.put("configuredLevel", getArgumentByKey(params, "configuredLevel"));
+	    args.put("effectiveLevel", getArgumentByKey(params, "effectiveLevel"));
+	    SpringProcessParams springProcessParams = new SpringProcessParams();
+	    springProcessParams.setProcessKey(getProcessKey(params));   
+		springProcessParams.setArgs(args);
+
+		if (springProcessParams.getProcessKey() != null) {
+			connectorService.configureLogLevel(springProcessParams);
+		}
+
+		return CompletableFuture.completedFuture(null);
+	}
+
 }

headless-services/spring-boot-language-server/src/main/java/org/springframework/ide/vscode/boot/java/livehover/v2/SpringProcessConnector.java

@@ -10,6 +10,8 @@
  *******************************************************************************/
 package org.springframework.ide.vscode.boot.java.livehover.v2;
 
+import java.util.Map;
+
 /**
  * @author Martin Lippert
  */
@@ -29,4 +31,6 @@ public interface SpringProcessConnector {
 	String getProcessName();
 	SpringProcessGcPausesMetricsLiveData refreshGcPausesMetrics(SpringProcessLiveData current, String metricName, String tags) throws Exception;
 	SpringProcessMemoryMetricsLiveData refreshMemoryMetrics(SpringProcessLiveData current, String metricName, String tags) throws Exception;
+	SpringProcessLoggersData getLoggers(SpringProcessLiveData currentData) throws Exception;
+	SpringProcessUpdatedLogLevelData configureLogLevel(SpringProcessLiveData currentData, Map<String, String> args) throws Exception;
 }

headless-services/spring-boot-language-server/src/main/java/org/springframework/ide/vscode/boot/java/livehover/v2/SpringProcessConnectorOverHttp.java

@@ -10,6 +10,8 @@
  *******************************************************************************/
 package org.springframework.ide.vscode.boot.java.livehover.v2;
 
+import java.util.Map;
+
 public class SpringProcessConnectorOverHttp implements SpringProcessConnector {
 
 	private final ProcessType processType;
@@ -157,6 +159,49 @@ public SpringProcessMemoryMetricsLiveData refreshMemoryMetrics(SpringProcessLive
 
         throw new Exception("no live memory metrics data received, lets try again");
 	}
+
+
+	@Override
+	public SpringProcessLoggersData getLoggers(SpringProcessLiveData currentData)
+			throws Exception {
+	    if (actuatorConnection != null) {
+	    	SpringProcessLoggersData loggersData = new SpringProcessLiveDataExtractorOverHttp().retrieveLoggersData(getProcessType(), actuatorConnection, processID, processName, currentData);
+
+            if (this.processID == null) {
+                this.processID = loggersData.getProcessID();
+            }
+
+            if (this.processName == null) {
+                this.processName = loggersData.getProcessName();
+            }
+
+            if (loggersData != null && loggersData.getLoggers() != null) {
+                return loggersData;
+            }
+        }
+
+        throw new Exception("no loggers data received, lets try again");
+	}
+
+
+	@Override
+	public SpringProcessUpdatedLogLevelData configureLogLevel(SpringProcessLiveData currentData, Map<String, String> args) throws Exception {
+		if (actuatorConnection != null) {
+			SpringProcessUpdatedLogLevelData springProcessUpdatedLoggersData = new SpringProcessLiveDataExtractorOverHttp().configureLogLevel(getProcessType(), actuatorConnection, processID, processName, currentData, args);
+
+            if (this.processID == null) {
+                this.processID = springProcessUpdatedLoggersData.getProcessID();
+            }
+
+            if (this.processName == null) {
+                this.processName = springProcessUpdatedLoggersData.getProcessName();
+                return springProcessUpdatedLoggersData;
+            }
+
+        }
+
+        throw new Exception("configure log levels failed, lets try again");		
+	}
 
 
 }

headless-services/spring-boot-language-server/src/main/java/org/springframework/ide/vscode/boot/java/livehover/v2/SpringProcessConnectorOverJMX.java

@@ -210,6 +210,50 @@ public void disconnect() throws Exception {
 			log.error("error closing the JMX connection for: " + jmxURL, e);
 		}
 	}
+
+	@Override
+	public SpringProcessLoggersData getLoggers(SpringProcessLiveData currentData) throws Exception {
+		log.info("try to open JMX connection to: " + jmxURL);
+
+		if (jmxConnection != null) {
+			try {
+				SpringProcessLiveDataExtractorOverJMX springJMXConnector = new SpringProcessLiveDataExtractorOverJMX();
+
+				log.info("retrieve live data from: " + jmxURL);
+				SpringProcessLoggersData loggersData = springJMXConnector.retrieveLoggersData(getProcessType(), jmxConnection, processID, processName, currentData);
+
+				if (loggersData != null) {
+					return loggersData;
+				}
+			}
+			catch (Exception e) {
+				log.error("exception while connecting to jmx: " + jmxURL, e);
+			}
+		}
+
+		throw new Exception("no loggers data received, lets try again");
+	}
+
+	@Override
+	public SpringProcessUpdatedLogLevelData configureLogLevel(SpringProcessLiveData currentData, Map<String, String> args) throws Exception {
+		log.info("try to open JMX connection to: " + jmxURL);
+
+		if (jmxConnection != null) {
+			try {
+				SpringProcessLiveDataExtractorOverJMX springJMXConnector = new SpringProcessLiveDataExtractorOverJMX();
+
+				log.info("retrieve live data from: " + jmxURL);
+				SpringProcessUpdatedLogLevelData springProcessUpdatedLoggersData = springJMXConnector.configureLogLevel(getProcessType(), jmxConnection, processID, processName, currentData, args);
+
+				return springProcessUpdatedLoggersData;
+			}
+			catch (Exception e) {
+				log.error("exception while connecting to jmx: " + jmxURL, e);
+			}
+		}
+
+		throw new Exception("configure log level failed, lets try again");
+	}
 
 	@Override
 	public void addConnectorChangeListener(SpringProcessConnectionChangeListener listener) {