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

   1 package org.apache.maven.repository.proxy.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.artifact.repository.layout.DefaultRepositoryLayout;
  20 import org.apache.maven.repository.proxy.repository.ProxyRepository;
  21 import org.codehaus.plexus.util.StringUtils;
  22
  23 import java.io.File;
  24 import java.io.IOException;
  25 import java.io.InputStream;
  26 import java.util.ArrayList;
  27 import java.util.Enumeration;
  28 import java.util.Iterator;
  29 import java.util.List;
  30 import java.util.Properties;
  31 import java.util.StringTokenizer;
  32
  33 /**
  34  * @author Ben Walding
  35  */
  36 public class MavenProxyPropertyLoader
  37 {
  38     private static final String REPO_LOCAL_STORE = "repo.local.store";
  39
  40     private static final String PROXY_LIST = "proxy.list";
  41
  42     private static final String REPO_LIST = "repo.list";
  43
  44     public ProxyConfiguration load( Properties props )
  45         throws ValidationException
  46     {
  47         ProxyConfiguration config = new ProxyConfiguration();
  48
  49         config.setLayout( "default" );
  50
  51         config.setRepositoryCachePath( getMandatoryProperty( props, REPO_LOCAL_STORE ) );
  52
  53         //just get the first proxy and break
  54         String propertyList = props.getProperty( PROXY_LIST );
  55         if ( propertyList != null )
  56         {
  57             StringTokenizer tok = new StringTokenizer( propertyList, "," );
  58             while ( tok.hasMoreTokens() )
  59             {
  60                 String key = tok.nextToken();
  61                 if ( StringUtils.isNotEmpty( key ) )
  62                 {
  63                     String host = getMandatoryProperty( props, "proxy." + key + ".host" );
  64                     int port = Integer.parseInt( getMandatoryProperty( props, "proxy." + key + ".port" ) );
  65
  66                     // the username and password isn't required
  67                     String username = props.getProperty( "proxy." + key + ".username" );
  68                     String password = props.getProperty( "proxy." + key + ".password" );
  69
  70                     if ( StringUtils.isNotEmpty( username ) )
  71                     {
  72                         config.setHttpProxy( host, port, username, password );
  73                     }
  74                     else
  75                     {
  76                         config.setHttpProxy( host, port );
  77                     }
  78
  79                     //accept only one proxy configuration
  80                     break;
  81                 }
  82             }
  83         }
  84
  85         List repositories = new ArrayList();
  86
  87         //get the remote repository list
  88         String repoList = getMandatoryProperty( props, REPO_LIST );
  89
  90         StringTokenizer tok = new StringTokenizer( repoList, "," );
  91         while ( tok.hasMoreTokens() )
  92         {
  93             String key = tok.nextToken();
  94
  95             Properties repoProps = getSubset( props, "repo." + key + "." );
  96             String url = getMandatoryProperty( props, "repo." + key + ".url" );
  97             String proxyKey = repoProps.getProperty( "proxy" );
  98
  99             boolean cacheFailures =
 100                 Boolean.valueOf( repoProps.getProperty( "cache.failures", "false" ) ).booleanValue();
 101             boolean hardFail = Boolean.valueOf( repoProps.getProperty( "hardfail", "true" ) ).booleanValue();
 102             long cachePeriod = Long.parseLong( repoProps.getProperty( "cache.period", "0" ) );
 103
 104             ProxyRepository repository =
 105                 new ProxyRepository( key, url, new DefaultRepositoryLayout(), cacheFailures, cachePeriod );
 106
 107             repository.setHardfail( hardFail );
 108
 109             if ( StringUtils.isNotEmpty( proxyKey ) )
 110             {
 111                 repository.setProxied( true );
 112             }
 113
 114             repositories.add( repository );
 115         }
 116
 117         config.setRepositories( repositories );
 118
 119         validateDirectories( config );
 120         validateRemoteRepo( config );
 121
 122         return config;
 123     }
 124
 125     /**
 126      * @todo should be shared with any other configuration loader - move method to configuration?
 127      */
 128     private static void validateRemoteRepo( ProxyConfiguration configuration )
 129         throws ValidationException
 130     {
 131         //Verify remote repository set
 132         //only warn if missing
 133         if ( configuration.getRepositories().size() < 1 )
 134         {
 135             throw new ValidationException( "At least one remote repository must be configured." );
 136         }
 137     }
 138
 139     private Properties getSubset( Properties props, String prefix )
 140     {
 141         Enumeration keys = props.keys();
 142         Properties result = new Properties();
 143         while ( keys.hasMoreElements() )
 144         {
 145             String key = (String) keys.nextElement();
 146             String value = props.getProperty( key );
 147             if ( key.startsWith( prefix ) )
 148             {
 149                 String newKey = key.substring( prefix.length() );
 150                 result.setProperty( newKey, value );
 151             }
 152         }
 153         return result;
 154     }
 155
 156     public ProxyConfiguration load( InputStream is )
 157         throws IOException, ValidationException
 158     {
 159         Properties props = new Properties();
 160         props.load( is );
 161         return load( props );
 162     }
 163
 164     private String getMandatoryProperty( Properties props, String key )
 165         throws ValidationException
 166     {
 167         String value = props.getProperty( key );
 168
 169         if ( value == null )
 170         {
 171             throw new ValidationException( "Missing property: " + key );
 172         }
 173
 174         return value;
 175     }
 176
 177     /**
 178      * @todo should be shared with any other configuration loader - move method to configuration?
 179      */
 180     private static void validateDirectories( ProxyConfiguration configuration )
 181         throws ValidationException
 182     {
 183         File f = new File( configuration.getRepositoryCachePath() );
 184         if ( !f.exists() )
 185         {
 186             throw new ValidationException( "Specified directory does not exist: " + f.getAbsolutePath() );
 187         }
 188
 189         for ( Iterator repos = configuration.getRepositories().iterator(); repos.hasNext(); )
 190         {
 191             ProxyRepository repo = (ProxyRepository) repos.next();
 192             if ( repo.getUrl().startsWith( "file://" ) )
 193             {
 194                 File f2 = new File( repo.getBasedir() );
 195                 if ( !f2.exists() )
 196                 {
 197                     throw new ValidationException( "Specified directory does not exist: " + f2.getAbsolutePath() );
 198                 }
 199             }
 200         }
 201     }
 202
 203 }