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

   1 package org.apache.maven.archiva.web.action.admin.networkproxies;
   2
   3 /*
   4  * Licensed to the Apache Software Foundation (ASF) under one
   5  * or more contributor license agreements.  See the NOTICE file
   6  * distributed with this work for additional information
   7  * regarding copyright ownership.  The ASF licenses this file
   8  * to you under the Apache License, Version 2.0 (the
   9  * "License"); you may not use this file except in compliance
  10  * with the License.  You may obtain a copy of the License at
  11  *
  12  *  http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing,
  15  * software distributed under the License is distributed on an
  16  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
  17  * KIND, either express or implied.  See the License for the
  18  * specific language governing permissions and limitations
  19  * under the License.
  20  */
  21
  22 import com.opensymphony.xwork2.Preparable;
  23 import com.opensymphony.xwork2.Validateable;
  24 import org.apache.commons.collections.CollectionUtils;
  25 import org.apache.commons.collections.functors.NotPredicate;
  26 import org.apache.commons.lang.StringUtils;
  27 import org.apache.maven.archiva.configuration.ArchivaConfiguration;
  28 import org.apache.maven.archiva.configuration.Configuration;
  29 import org.apache.maven.archiva.configuration.IndeterminateConfigurationException;
  30 import org.apache.maven.archiva.configuration.NetworkProxyConfiguration;
  31 import org.apache.maven.archiva.configuration.functors.NetworkProxySelectionPredicate;
  32 import org.apache.archiva.security.ArchivaRoleConstants;
  33 import org.apache.maven.archiva.web.action.AbstractActionSupport;
  34 import org.codehaus.plexus.redback.rbac.Resource;
  35 import org.codehaus.plexus.registry.RegistryException;
  36 import org.codehaus.redback.integration.interceptor.SecureAction;
  37 import org.codehaus.redback.integration.interceptor.SecureActionBundle;
  38 import org.codehaus.redback.integration.interceptor.SecureActionException;
  39 import org.springframework.context.annotation.Scope;
  40 import org.springframework.stereotype.Controller;
  41
  42 import javax.inject.Inject;
  43
  44 /**
  45  * ConfigureNetworkProxyAction
  46  *
  47  * @version $Id$
  48  *          plexus.component role="com.opensymphony.xwork2.Action" role-hint="configureNetworkProxyAction" instantiation-strategy="per-lookup"
  49  */
  50 @Controller( "configureNetworkProxyAction" )
  51 @Scope( "prototype" )
  52 public class ConfigureNetworkProxyAction
  53     extends AbstractActionSupport
  54     implements SecureAction, Preparable, Validateable
  55 {
  56     /**
  57      * plexus.requirement
  58      */
  59     @Inject
  60     private ArchivaConfiguration archivaConfiguration;
  61
  62     private String mode;
  63
  64     private String proxyid;
  65
  66     private NetworkProxyConfiguration proxy;
  67
  68     public String add()
  69     {
  70         this.mode = "add";
  71         return INPUT;
  72     }
  73
  74     public String confirm()
  75     {
  76         return INPUT;
  77     }
  78
  79     public String delete()
  80     {
  81         Configuration config = archivaConfiguration.getConfiguration();
  82
  83         String id = getProxyid();
  84         if ( StringUtils.isBlank( id ) )
  85         {
  86             addActionError( "Unable to delete network proxy with blank id." );
  87             return SUCCESS;
  88         }
  89
  90         NetworkProxySelectionPredicate networkProxySelection = new NetworkProxySelectionPredicate( id );
  91         NetworkProxyConfiguration proxyConfig =
  92             (NetworkProxyConfiguration) CollectionUtils.find( config.getNetworkProxies(), networkProxySelection );
  93         if ( proxyConfig == null )
  94         {
  95             addActionError( "Unable to remove network proxy, proxy with id [" + id + "] not found." );
  96             return SUCCESS;
  97         }
  98
  99         archivaConfiguration.getConfiguration().removeNetworkProxy( proxyConfig );
 100         addActionMessage( "Successfully removed network proxy [" + id + "]" );
 101         return saveConfiguration();
 102     }
 103
 104     public String edit()
 105     {
 106         this.mode = "edit";
 107         return INPUT;
 108     }
 109
 110     public String getMode()
 111     {
 112         return mode;
 113     }
 114
 115     public NetworkProxyConfiguration getProxy()
 116     {
 117         return proxy;
 118     }
 119
 120     public String getProxyid()
 121     {
 122         return proxyid;
 123     }
 124
 125     public SecureActionBundle getSecureActionBundle()
 126         throws SecureActionException
 127     {
 128         SecureActionBundle bundle = new SecureActionBundle();
 129
 130         bundle.setRequiresAuthentication( true );
 131         bundle.addRequiredAuthorization( ArchivaRoleConstants.OPERATION_MANAGE_CONFIGURATION, Resource.GLOBAL );
 132
 133         return bundle;
 134     }
 135
 136     public String input()
 137     {
 138         return INPUT;
 139     }
 140
 141     public void prepare()
 142         throws Exception
 143     {
 144         String id = getProxyid();
 145
 146         if ( StringUtils.isNotBlank( id ) )
 147         {
 148             proxy = findNetworkProxy( id );
 149         }
 150
 151         if ( proxy == null )
 152         {
 153             proxy = new NetworkProxyConfiguration();
 154         }
 155     }
 156
 157     public String save()
 158     {
 159         String mode = getMode();
 160
 161         String id = getProxy().getId();
 162
 163         if ( StringUtils.equalsIgnoreCase( "edit", mode ) )
 164         {
 165             removeNetworkProxy( id );
 166         }
 167         else
 168         {
 169             if ( findNetworkProxy( id ) != null )
 170             {
 171                 addActionError( "Unable to add new repository with id [" + id + "], that id already exists." );
 172                 return INPUT;
 173             }
 174         }
 175
 176         addNetworkProxy( getProxy() );
 177         return saveConfiguration();
 178     }
 179
 180     public void validate()
 181     {
 182         // trim all unecessary trailing/leading white-spaces; always put this statement before the closing braces(after all validation).
 183         trimAllRequestParameterValues();
 184     }
 185
 186     public void setMode( String mode )
 187     {
 188         this.mode = mode;
 189     }
 190
 191     public void setProxy( NetworkProxyConfiguration proxy )
 192     {
 193         this.proxy = proxy;
 194     }
 195
 196     public void setProxyid( String proxyid )
 197     {
 198         this.proxyid = proxyid;
 199     }
 200
 201     private void addNetworkProxy( NetworkProxyConfiguration proxy )
 202     {
 203         archivaConfiguration.getConfiguration().addNetworkProxy( proxy );
 204     }
 205
 206     private NetworkProxyConfiguration findNetworkProxy( String id )
 207     {
 208         Configuration config = archivaConfiguration.getConfiguration();
 209
 210         NetworkProxySelectionPredicate selectedProxy = new NetworkProxySelectionPredicate( id );
 211
 212         return (NetworkProxyConfiguration) CollectionUtils.find( config.getNetworkProxies(), selectedProxy );
 213     }
 214
 215     private void removeNetworkProxy( String id )
 216     {
 217         NetworkProxySelectionPredicate selectedProxy = new NetworkProxySelectionPredicate( id );
 218         NotPredicate notSelectedProxy = new NotPredicate( selectedProxy );
 219         CollectionUtils.filter( archivaConfiguration.getConfiguration().getNetworkProxies(), notSelectedProxy );
 220     }
 221
 222     private String saveConfiguration()
 223     {
 224         try
 225         {
 226             archivaConfiguration.save( archivaConfiguration.getConfiguration() );
 227             addActionMessage( "Successfully saved configuration" );
 228         }
 229         catch ( RegistryException e )
 230         {
 231             addActionError( "Unable to save configuration: " + e.getMessage() );
 232             return INPUT;
 233         }
 234         catch ( IndeterminateConfigurationException e )
 235         {
 236             addActionError( e.getMessage() );
 237             return INPUT;
 238         }
 239
 240         return SUCCESS;
 241     }
 242
 243     private void trimAllRequestParameterValues()
 244     {
 245         if ( StringUtils.isNotEmpty( proxy.getId() ) )
 246         {
 247             proxy.setId( proxy.getId().trim() );
 248         }
 249
 250         if ( StringUtils.isNotEmpty( proxy.getHost() ) )
 251         {
 252             proxy.setHost( proxy.getHost().trim() );
 253         }
 254
 255         if ( StringUtils.isNotEmpty( proxy.getPassword() ) )
 256         {
 257             proxy.setPassword( proxy.getPassword().trim() );
 258         }
 259
 260         if ( StringUtils.isNotEmpty( proxy.getProtocol() ) )
 261         {
 262             proxy.setProtocol( proxy.getProtocol().trim() );
 263         }
 264
 265         if ( StringUtils.isNotEmpty( proxy.getUsername() ) )
 266         {
 267             proxy.setUsername( proxy.getUsername().trim() );
 268         }
 269     }
 270 }