Changeset 357:85fc65cb2520 for kraken-core/src/main/java/org/krakenapps/bundle/BundleManagerService.java

Timestamp:

09/21/11 16:46:58 (8 months ago)

Author:

delmitz

Branch:

default

Convert:

svn:7c3792e6-d75b-4784-96a6-b298f655ee64/trunk@2791

Message:

• modified script name timestamps to timestamp.
• modified bundle update.

File:

• kraken-core/src/main/java/org/krakenapps/bundle/BundleManagerService.java (modified) (3 diffs)

kraken-core/src/main/java/org/krakenapps/bundle/BundleManagerService.java

@@ -62 +62 @@
  */
 public class BundleManagerService implements SynchronousBundleListener, BundleManager {
-        final Logger logger = LoggerFactory.getLogger(BundleManagerService.class.getName());
+        private Logger logger = LoggerFactory.getLogger(BundleManagerService.class);
 
         private BundleContext context;
@@ -312 +312 @@
                         bundle.stop();
                 } catch (BundleException e) {
-                        e.printStackTrace();
+                        logger.error("kraken core: stopping bundle failed.", e);
                 }
         }
@@ -330 +330 @@
 
                 try {
+                        if (!isLocalJar(bundle)) {
+                                try {
+                                        File before = new File(bundle.getLocation().replace("file://", ""));
+                                        File temp = File.createTempFile(before.getName(), "", before.getParentFile());
+                                        temp.delete();
+                                        if (before.renameTo(temp)) {
+                                                MavenResolver resolver = new MavenResolver(getLocalRepository(),
+                                                                config.getBundleRepositories(), null, getKeyStoreManager());
+                                                MavenArtifact artifact = getArtifact(bundle);
+                                                File after = resolver.resolve(artifact);
+                                                if (after.exists())
+                                                        temp.delete();
+                                                else
+                                                        temp.renameTo(before);
+                                        }
+                                } catch (MavenResolveException e) {
+                                        logger.error("kraken core: maven resolve failed.", e);
+                                } catch (IOException e) {
+                                        logger.error("kraken core: create temp file failed.", e);
+                                }
+                        }
                         bundle.update();
                 } catch (BundleException e) {
-                        e.printStackTrace();
-                }
+                        logger.error("kraken core: updating bundle failed.", e);
+                }
+        }
+
+        private boolean isLocalJar(Bundle bundle) {
+                File location = new File(bundle.getLocation().replace("file://", ""));
+                File krakenDownload = new File(System.getProperty("kraken.download.dir"));
+
+                while (location.getParentFile() != null) {
+                        if (location.equals(krakenDownload))
+                                return false;
+                        location = location.getParentFile();
+                }
+
+                return true;
+        }
+
+        private MavenArtifact getArtifact(Bundle bundle) {
+                File location = new File(bundle.getLocation().replace("file://", ""));
+                File krakenDownload = new File(System.getProperty("kraken.download.dir"));
+
+                String groupId = null;
+                String artifactId = null;
+                Version version = null;
+                while (location.getParentFile() != null) {
+                        location = location.getParentFile();
+                        if (location.equals(krakenDownload))
+                                break;
+
+                        String name = location.getName();
+                        if (version == null)
+                                version = new Version(name);
+                        else if (artifactId == null)
+                                artifactId = name;
+                        else if (groupId == null)
+                                groupId = name;
+                        else
+                                groupId = name + "." + groupId;
+                }
+
+                return new MavenArtifact(groupId, artifactId, version);
         }