support reloading profile/connections/resources/deployment targets.

Author: wangmingliang-ms

PluginsAndFeatures/azure-toolkit-for-intellij/azure-intellij-resource-connector-lib/src/main/java/com/microsoft/azure/toolkit/intellij/connector/dotazure/ConnectionManager.java

@@ -56,6 +56,10 @@ public class ConnectionManager {
 
     public ConnectionManager(@Nonnull final Profile profile) {
         this.profile = profile;
+        this.reload();
+    }
+
+    public void reload() {
         try {
             this.load();
         } catch (final Exception e) {
@@ -142,7 +146,7 @@ public VirtualFile getConnectionsFile() {
 
     @ExceptionNotification
     @AzureOperation(name = "boundary/connector.save_connections")
-    void save() throws IOException {
+    synchronized void save() throws IOException {
         final Element connectionsEle = new Element(ELEMENT_NAME_CONNECTIONS);
         for (final Connection<?, ?> connection : this.connections) {
             final Element connectionEle = new Element(ELEMENT_NAME_CONNECTION);
@@ -159,7 +163,7 @@ void save() throws IOException {
 
     @ExceptionNotification
     @AzureOperation(name = "boundary/connector.load_connections")
-    void load() throws Exception {
+    synchronized void load() throws Exception {
         this.connectionsFile = getConnectionsFile();
         if (Objects.isNull(connectionsFile) || connectionsFile.contentsToByteArray().length < 1) {
             return;

PluginsAndFeatures/azure-toolkit-for-intellij/azure-intellij-resource-connector-lib/src/main/java/com/microsoft/azure/toolkit/intellij/connector/dotazure/DeploymentTargetManager.java

@@ -36,6 +36,10 @@ public class DeploymentTargetManager {
 
     public DeploymentTargetManager(@Nonnull final Profile profile) {
         this.profile = profile;
+        this.reload();
+    }
+
+    public void reload() {
         try {
             this.load();
         } catch (final Exception e) {
@@ -62,7 +66,7 @@ public List<String> getTargets() {
 
     @ExceptionNotification
     @AzureOperation("boundary/connector.save_target_apps")
-    void save() throws IOException {
+    synchronized void save() throws IOException {
         final Element appsEle = new Element(ELEMENT_NAME_APPS);
         this.targetAppIds.stream().map(id -> new Element(ELEMENT_NAME_APP).setAttribute("id", id)).forEach(appsEle::addContent);
         final VirtualFile appsFile = this.profile.getProfileDir().findOrCreateChildData(this, TARGETS_FILE);
@@ -71,7 +75,7 @@ void save() throws IOException {
 
     @ExceptionNotification
     @AzureOperation(name = "boundary/connector.load_target_apps")
-    void load() throws Exception {
+    synchronized void load() throws Exception {
         final VirtualFile appsFile = this.profile.getProfileDir().findChild(TARGETS_FILE);
         if (Objects.isNull(appsFile) || appsFile.contentsToByteArray().length < 1) {
             return;

PluginsAndFeatures/azure-toolkit-for-intellij/azure-intellij-resource-connector-lib/src/main/java/com/microsoft/azure/toolkit/intellij/connector/dotazure/Profile.java

@@ -117,7 +117,13 @@ public synchronized Future<?> createOrUpdateConnection(@Nonnull Connection<?, ?>
         return this.addConnection(connection);
     }
 
-    public void save() {
+    public synchronized void reload() {
+        this.resourceManager.reload();
+        this.deploymentTargetManager.reload();
+        this.connectionManager.reload();
+    }
+
+    public synchronized void save() {
         try {
             this.connectionManager.save();
             this.resourceManager.save();

PluginsAndFeatures/azure-toolkit-for-intellij/azure-intellij-resource-connector-lib/src/main/java/com/microsoft/azure/toolkit/intellij/connector/dotazure/ResourceManager.java

@@ -49,6 +49,10 @@ public class ResourceManager {
 
     public ResourceManager(@Nonnull final Profile profile) {
         this.profile = profile;
+        this.reload();
+    }
+
+    public void reload() {
         try {
             this.load();
         } catch (final Exception e) {
@@ -100,10 +104,10 @@ public Resource<?> getResourceById(String id) {
 
     @ExceptionNotification
     @AzureOperation("boundary/connector.save_resources")
-    void save() throws IOException {
+    synchronized void save() throws IOException {
         final Element resourcesEle = new Element(ELEMENT_NAME_RESOURCES);
         // todo: whether to save invalid resources?
-        this.resources.stream().forEach(resource -> {
+        for (final Resource<?> resource : this.resources) {
             final Element resourceEle = new Element(ELEMENT_NAME_RESOURCE);
             try {
                 if (resource.writeTo(resourceEle)) {
@@ -113,14 +117,14 @@ void save() throws IOException {
             } catch (final Exception e) {
                 log.warn(String.format("error occurs when persist resource of type '%s'", resource.getDefinition().getName()), e);
             }
-        });
+        }
         final VirtualFile resourcesFile = this.profile.getProfileDir().findOrCreateChildData(this, RESOURCES_FILE);
         JDOMUtil.write(resourcesEle, resourcesFile.toNioPath());
     }
 
     @ExceptionNotification
     @AzureOperation(name = "boundary/connector.load_resources")
-    void load() throws Exception {
+    synchronized void load() throws Exception {
         final VirtualFile resourcesFile = this.profile.getProfileDir().findChild(RESOURCES_FILE);
         if (Objects.isNull(resourcesFile) || resourcesFile.contentsToByteArray().length < 1) {
             return;