feature/Notifications #390
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,3 @@ | ||
| package software.aws.toolkits.eclipse.amazonq.lsp.model; | ||
aseemxs marked this conversation as resolved.
Show resolved
Hide resolved
|
||
|
|
||
| public record EventIdentifier(String id) { } | ||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,3 @@ | ||
| package software.aws.toolkits.eclipse.amazonq.lsp.model; | ||
|
|
||
| public record NotificationAction(String text, String type) { } | ||
|
There was a problem hiding this comment. Notification actions may include a URI property (wait for the Flare protocol updates). |
||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,4 @@ | ||
| package software.aws.toolkits.eclipse.amazonq.lsp.model; | ||
|
|
||
|
|
||
| public record NotificationContent(String text, String title) { } |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,12 @@ | ||
| package software.aws.toolkits.eclipse.amazonq.lsp.model; | ||
|
|
||
| import java.util.List; | ||
|
|
||
| import org.eclipse.lsp4j.MessageType; | ||
|
|
||
| public record NotificationParams( | ||
| MessageType type, | ||
| NotificationContent content, | ||
| String id, | ||
| List<NotificationAction> actions | ||
| ) { } |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,158 @@ | ||
| package software.aws.toolkits.eclipse.amazonq.notification; | ||
|
|
||
| import java.util.ArrayList; | ||
| import java.util.List; | ||
| import java.util.Map; | ||
| import java.util.HashMap; | ||
| import java.util.Collections; | ||
| import java.util.concurrent.Executors; | ||
| import java.util.concurrent.ScheduledExecutorService; | ||
| import java.util.concurrent.TimeUnit; | ||
| import java.util.concurrent.atomic.AtomicBoolean; | ||
|
|
||
| import org.eclipse.lsp4j.jsonrpc.services.JsonNotification; | ||
|
|
||
| import software.aws.toolkits.eclipse.amazonq.plugin.Activator; | ||
| import software.aws.toolkits.eclipse.amazonq.lsp.AmazonQLspClient; | ||
|
|
||
| /** | ||
| * Maintains client state information for the notification system. | ||
| * | ||
| * This class tracks both static and dynamic information about the Eclipse environment | ||
| * that the notification server uses to determine which notifications to show. | ||
| */ | ||
| public class NotificationConfiguration{ | ||
|
|
||
| // Singleton, needed one for whole eclipse session | ||
| private static NotificationConfiguration instance; | ||
|
|
||
| private final AmazonQLspClient lspClient; | ||
|
|
||
| private final List<String> contexts = new ArrayList<>(); | ||
|
There was a problem hiding this comment. Consider using a HashSet for contexts. |
||
|
|
||
| private final Map<String, String> clientStates = new HashMap<>(); | ||
|
|
||
| private final ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor(); | ||
| private final AtomicBoolean pendingUpdate = new AtomicBoolean(false); | ||
| private static final int DEBOUNCE_DELAY_MS = 1000; //1 sec debounce | ||
|
|
||
| /** | ||
| * Gets the singleton instance of NotificationConfiguration. | ||
| * | ||
| * @param lspClient The LSP client to use for communication with the server | ||
| * @return The NotificationConfiguration instance | ||
| */ | ||
| public static synchronized NotificationConfiguration getInstance(AmazonQLspClient lspClient) { | ||
|
There was a problem hiding this comment. Consider splitting this to explicit instantiation instead of lazy instantiation so that not all code that wants to call getInstance must also have an instance of AmazonQLspClient easily available as well. |
||
| if (instance == null) { | ||
| instance = new NotificationConfiguration(lspClient); | ||
| } | ||
| return instance; | ||
| } | ||
|
|
||
| /** | ||
| * Private constructor to enforce singleton pattern. | ||
| * | ||
| * @param lspClient The LSP client to use for communication | ||
| */ | ||
| private NotificationConfiguration(AmazonQLspClient lspClient) { | ||
| this.lspClient = lspClient; | ||
| initializeStaticClientStates(); | ||
| } | ||
|
|
||
| /** | ||
| * Initialize static client states that won't change during the Eclipse session. | ||
| */ | ||
| private void initializeStaticClientStates() { | ||
| clientStates.put("IDE/VERSION", getEclipseVersion()); | ||
|
|
||
| // Add other static values as needed | ||
| // clientStates.put("ANOTHER_STATIC_VALUE", getSomeOtherStaticValue()); | ||
| } | ||
|
|
||
| private String getEclipseVersion() { | ||
| //placeholder - need to use the actual Eclipse API to get the version | ||
| return org.eclipse.core.runtime.Platform.getProduct().getDefiningBundle().getVersion().toString(); | ||
| } | ||
|
|
||
| /** | ||
| * Add a context to the active contexts list. | ||
| * | ||
| * @param context The context to add | ||
| */ | ||
| public synchronized void addContext(String context) { | ||
| if (!contexts.contains(context)) { | ||
| contexts.add(context); | ||
| notifyConfigurationChanged(); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Remove a context from the active contexts list. | ||
| * | ||
| * @param context The context to remove | ||
| */ | ||
| public synchronized void removeContext(String context) { | ||
| if (contexts.contains(context)) { | ||
| contexts.remove(context); | ||
| notifyConfigurationChanged(); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Set SSO scopes. | ||
| * | ||
| * @param scopes The list of SSO scopes | ||
| */ | ||
| public synchronized void setSsoScopes(List<String> scopes) { | ||
| String scopesCopy = new ArrayList<>(scopes); | ||
| clientStates.put("SSO_SCOPES", scopesCopy); | ||
| notifyConfigurationChanged(); | ||
| } | ||
|
|
||
| /** | ||
| * Get the current notification configuration. | ||
| * | ||
| * @return A map representing the current notification configuration | ||
| */ | ||
| public synchronized Map<String, Object> getConfiguration() { | ||
|
There was a problem hiding this comment. Not sure this needs to be public. Will client code need this? The format of this will be a little different, but doesn't need to be updated now. |
||
| Map<String, Object> config = new HashMap<>(); | ||
| config.putAll(clientStates); | ||
| config.put("CONTEXT", new ArrayList<>(contexts)); | ||
|
|
||
| return config; | ||
| } | ||
|
|
||
| /** | ||
| * Notify the server of a configuration change in a try catch block using didChangeConfiguration | ||
| */ | ||
| private void notifyConfigurationChanged() { | ||
| if (pendingUpdate.compareAndSet(false, true)) { | ||
| scheduler.schedule(() -> { | ||
| try { | ||
| lspClient.didChangeConfiguration(null); | ||
| Activator.getLogger().info("sent didChangeConfiguration notification"); | ||
|
|
||
| } catch (Exception e) { | ||
| Activator.getLogger().error("Error sending didChangeConfiguration notification", e); | ||
| } finally { | ||
| pendingUpdate.set(false); | ||
| } | ||
| }, DEBOUNCE_DELAY_MS, TimeUnit.MILLISECONDS); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Handles the getConfiguration request from the server. | ||
| * | ||
| * @param section The configuration section requested | ||
| * @return The requested configuration section | ||
| */ | ||
| public Object handleGetConfiguration(String section) { | ||
| if ("notifications".equals(section)) { | ||
| return getConfiguration(); | ||
| } | ||
|
|
||
| // Handle other sections or return null if not recognized | ||
| return null; | ||
| } | ||
|
|
||
| } | ||
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Nothing to worry about now, but I may try to convert this to showNotifications (if Flare will agree) and send an array of Notification instead of just one.