source.dussan.org Git - archiva.git/blob

   1 package org.apache.maven.archiva.configuration;
   2
   3 /*
   4  * Copyright 2005-2006 The Apache Software Foundation.
   5  *
   6  * Licensed under the Apache License, Version 2.0 (the "License");
   7  * you may not use this file except in compliance with the License.
   8  * You may obtain a copy of the License at
   9  *
  10  *      http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  */
  18
  19 import org.apache.maven.archiva.configuration.io.xpp3.ConfigurationXpp3Reader;
  20 import org.apache.maven.archiva.configuration.io.xpp3.ConfigurationXpp3Writer;
  21 import org.codehaus.plexus.logging.AbstractLogEnabled;
  22 import org.apache.commons.io.IOUtils;
  23 import org.apache.commons.lang.StringUtils;
  24 import org.codehaus.plexus.util.xml.pull.XmlPullParserException;
  25
  26 import java.io.File;
  27 import java.io.FileNotFoundException;
  28 import java.io.FileReader;
  29 import java.io.FileWriter;
  30 import java.io.IOException;
  31 import java.util.Iterator;
  32 import java.util.LinkedList;
  33 import java.util.List;
  34
  35 /**
  36  * Load and store the configuration. No synchronization is used, but it is unnecessary as the old configuration object
  37  * can continue to be used.
  38  *
  39  * @author <a href="mailto:brett@apache.org">Brett Porter</a>
  40  * @todo would be great for plexus to do this for us - so the configuration would be a component itself rather than this store
  41  * @todo would be good to monitor the store file for changes
  42  * @todo support other implementations than XML file
  43  * @plexus.component
  44  */
  45 public class DefaultConfigurationStore
  46     extends AbstractLogEnabled
  47     implements ConfigurationStore
  48 {
  49     /**
  50      * @plexus.configuration default-value="${configuration.store.file}"
  51      */
  52     private File file;
  53
  54     /**
  55      * The cached configuration.
  56      */
  57     private Configuration configuration;
  58
  59     /**
  60      * List of listeners to configuration changes.
  61      */
  62     private List/*<ConfigurationChangeListener>*/ listeners = new LinkedList();
  63
  64     public Configuration getConfigurationFromStore()
  65         throws ConfigurationStoreException
  66     {
  67         if ( configuration == null )
  68         {
  69             ConfigurationXpp3Reader reader = new ConfigurationXpp3Reader();
  70
  71             if ( file == null )
  72             {
  73                 file = new File( System.getProperty( "user.home" ), "/.m2/archiva.xml" );
  74
  75                 // migration for those with the old file
  76                 if ( !file.exists() )
  77                 {
  78                     File file = new File( System.getProperty( "user.home" ), "/.m2/repository-manager.xml" );
  79                     if ( file.exists() )
  80                     {
  81                         getLogger().info( "Migrating " + file + " to " + this.file );
  82                         file.renameTo( this.file );
  83                     }
  84                 }
  85             }
  86
  87             FileReader fileReader;
  88             try
  89             {
  90                 fileReader = new FileReader( file );
  91             }
  92             catch ( FileNotFoundException e )
  93             {
  94                 getLogger().warn( "Configuration file: " + file + " not found. Using defaults." );
  95                 configuration = new Configuration();
  96                 return configuration;
  97             }
  98
  99             getLogger().info( "Reading configuration from " + file );
 100             try
 101             {
 102                 configuration = reader.read( fileReader, false );
 103                 sanitizeConfiguration( configuration );
 104             }
 105             catch ( IOException e )
 106             {
 107                 throw new ConfigurationStoreException( e.getMessage(), e );
 108             }
 109             catch ( XmlPullParserException e )
 110             {
 111                 throw new ConfigurationStoreException( e.getMessage(), e );
 112             }
 113             finally
 114             {
 115                 IOUtils.closeQuietly( fileReader );
 116             }
 117         }
 118         return configuration;
 119     }
 120
 121     /**
 122      * Perform any Upgrades and Adjustments needed to bring configuration up to the
 123      * current configuration format.
 124      *
 125      * @param config the configuration to upgrade and adjust.
 126      */
 127     private void sanitizeConfiguration( Configuration config )
 128     {
 129         Iterator it = config.getRepositories().iterator();
 130         while ( it.hasNext() )
 131         {
 132             RepositoryConfiguration repo = (RepositoryConfiguration) it.next();
 133
 134             // Ensure that the repo.urlName is set.
 135             if ( StringUtils.isEmpty( repo.getUrlName() ) )
 136             {
 137                 repo.setUrlName( repo.getId() );
 138             }
 139         }
 140     }
 141
 142     public void storeConfiguration( Configuration configuration )
 143         throws ConfigurationStoreException, InvalidConfigurationException, ConfigurationChangeException
 144     {
 145         for ( Iterator i = listeners.iterator(); i.hasNext(); )
 146         {
 147             ConfigurationChangeListener listener = (ConfigurationChangeListener) i.next();
 148
 149             listener.notifyOfConfigurationChange( configuration );
 150         }
 151
 152         ConfigurationXpp3Writer writer = new ConfigurationXpp3Writer();
 153
 154         getLogger().info( "Writing configuration to " + file );
 155         FileWriter fileWriter = null;
 156         try
 157         {
 158             file.getParentFile().mkdirs();
 159
 160             fileWriter = new FileWriter( file );
 161             writer.write( fileWriter, configuration );
 162         }
 163         catch ( IOException e )
 164         {
 165             throw new ConfigurationStoreException( e.getMessage(), e );
 166         }
 167         finally
 168         {
 169             IOUtils.closeQuietly( fileWriter );
 170         }
 171     }
 172
 173     public void addChangeListener( ConfigurationChangeListener listener )
 174     {
 175         listeners.add( listener );
 176     }
 177 }