| package org.apache.maven.scm.provider.cvslib; |
| |
| /* |
| * Copyright 2001-2005 The Apache Software Foundation. |
| * |
| * Licensed under the Apache License, Version 2.0 (the "License"); |
| * you may not use this file except in compliance with the License. |
| * You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| import org.apache.maven.scm.CommandParameters; |
| import org.apache.maven.scm.ScmException; |
| import org.apache.maven.scm.ScmFileSet; |
| import org.apache.maven.scm.command.add.AddScmResult; |
| import org.apache.maven.scm.command.changelog.ChangeLogScmResult; |
| import org.apache.maven.scm.command.checkin.CheckInScmResult; |
| import org.apache.maven.scm.command.checkout.CheckOutScmResult; |
| import org.apache.maven.scm.command.diff.DiffScmResult; |
| import org.apache.maven.scm.command.remove.RemoveScmResult; |
| import org.apache.maven.scm.command.status.StatusScmResult; |
| import org.apache.maven.scm.command.tag.TagScmResult; |
| import org.apache.maven.scm.command.update.UpdateScmResult; |
| import org.apache.maven.scm.login.LoginScmResult; |
| import org.apache.maven.scm.provider.AbstractScmProvider; |
| import org.apache.maven.scm.provider.ScmProviderRepository; |
| import org.apache.maven.scm.provider.cvslib.command.add.CvsAddCommand; |
| import org.apache.maven.scm.provider.cvslib.command.changelog.CvsChangeLogCommand; |
| import org.apache.maven.scm.provider.cvslib.command.checkin.CvsCheckInCommand; |
| import org.apache.maven.scm.provider.cvslib.command.checkout.CvsCheckOutCommand; |
| import org.apache.maven.scm.provider.cvslib.command.diff.CvsDiffCommand; |
| import org.apache.maven.scm.provider.cvslib.command.login.CvsLoginCommand; |
| import org.apache.maven.scm.provider.cvslib.command.remove.CvsRemoveCommand; |
| import org.apache.maven.scm.provider.cvslib.command.status.CvsStatusCommand; |
| import org.apache.maven.scm.provider.cvslib.command.tag.CvsTagCommand; |
| import org.apache.maven.scm.provider.cvslib.command.update.CvsUpdateCommand; |
| import org.apache.maven.scm.provider.cvslib.repository.CvsScmProviderRepository; |
| import org.apache.maven.scm.repository.ScmRepository; |
| import org.apache.maven.scm.repository.ScmRepositoryException; |
| import org.apache.maven.scm.repository.UnknownRepositoryStructure; |
| import org.codehaus.plexus.util.FileUtils; |
| import org.codehaus.plexus.util.StringUtils; |
| |
| import java.io.File; |
| import java.io.IOException; |
| import java.util.List; |
| import java.util.ArrayList; |
| |
| /** |
| * @author <a href="mailto:evenisse@apache.org">Emmanuel Venisse </a> |
| * @author <a href="mailto:trygvis@inamo.no">Trygve Laugstøl</a> |
| * @version $Id$ |
| */ |
| public class CvsScmProvider |
| extends AbstractScmProvider |
| { |
| /** */ |
| private final static String TRANSPORT_LOCAL = "local"; |
| |
| /** */ |
| private final static String TRANSPORT_PSERVER = "pserver"; |
| |
| /** */ |
| private final static String TRANSPORT_LSERVER = "lserver"; |
| |
| /** */ |
| private final static String TRANSPORT_EXT = "ext"; |
| |
| // ---------------------------------------------------------------------- |
| // |
| // ---------------------------------------------------------------------- |
| |
| private static class ScmUrlParserResult |
| { |
| List messages = new ArrayList(); |
| |
| ScmProviderRepository repository; |
| } |
| |
| // ---------------------------------------------------------------------- |
| // ScmProvider Implementation |
| // ---------------------------------------------------------------------- |
| |
| public ScmProviderRepository makeProviderScmRepository( String scmSpecificUrl, char delimiter ) |
| throws ScmRepositoryException |
| { |
| ScmUrlParserResult result = parseScmUrl( scmSpecificUrl, delimiter ); |
| |
| if ( result.messages.size() > 0 ) |
| { |
| throw new ScmRepositoryException( "The scm url is invalid.", result.messages ); |
| } |
| |
| return result.repository; |
| } |
| |
| /** |
| * @see org.apache.maven.scm.provider.AbstractScmProvider#makeProviderScmRepository(java.io.File) |
| */ |
| public ScmProviderRepository makeProviderScmRepository( File path ) |
| throws ScmRepositoryException, UnknownRepositoryStructure |
| { |
| if ( path == null || !path.isDirectory() ) |
| { |
| throw new ScmRepositoryException( path.getAbsolutePath() + " isn't a valid directory." ); |
| } |
| |
| File cvsDirectory = new File( path, "CVS" ); |
| |
| if ( !cvsDirectory.exists() ) |
| { |
| throw new ScmRepositoryException( path.getAbsolutePath() + " isn't a cvs checkout directory." ); |
| } |
| |
| File cvsRootFile = new File( cvsDirectory, "Root" ); |
| |
| File moduleFile = new File( cvsDirectory, "Repository" ); |
| |
| String cvsRoot; |
| |
| String module; |
| |
| try |
| { |
| cvsRoot = FileUtils.fileRead( cvsRootFile ).trim().substring( 1 ); |
| } |
| catch ( IOException e ) |
| { |
| throw new ScmRepositoryException( "Can't read " + cvsRootFile.getAbsolutePath() ); |
| } |
| try |
| { |
| module = FileUtils.fileRead( moduleFile ).trim(); |
| } |
| catch ( IOException e ) |
| { |
| throw new ScmRepositoryException( "Can't read " + moduleFile.getAbsolutePath() ); |
| } |
| |
| return makeProviderScmRepository( cvsRoot + ":" + module, ':' ); |
| } |
| |
| public List validateScmUrl( String scmSpecificUrl, char delimiter ) |
| { |
| ScmUrlParserResult result = parseScmUrl( scmSpecificUrl, delimiter ); |
| |
| return result.messages; |
| } |
| |
| public String getScmType() |
| { |
| return "cvs"; |
| } |
| |
| // ---------------------------------------------------------------------- |
| // |
| // ---------------------------------------------------------------------- |
| |
| private ScmUrlParserResult parseScmUrl( String scmSpecificUrl, char delimiter ) |
| { |
| ScmUrlParserResult result = new ScmUrlParserResult(); |
| |
| String[] tokens = StringUtils.split( scmSpecificUrl, Character.toString( delimiter ) ); |
| |
| if ( tokens.length < 3 ) |
| { |
| result.messages.add( "The connection string contains to few tokens." ); |
| |
| return result; |
| } |
| |
| String cvsroot; |
| |
| String transport = tokens[0]; |
| |
| if ( transport.equalsIgnoreCase( TRANSPORT_LOCAL ) ) |
| { |
| // use the local repository directory eg. '/home/cvspublic' |
| cvsroot = tokens[1]; |
| } |
| else if ( transport.equalsIgnoreCase( TRANSPORT_PSERVER ) || transport.equalsIgnoreCase( TRANSPORT_LSERVER ) |
| || transport.equalsIgnoreCase( TRANSPORT_EXT ) ) |
| { |
| if ( tokens.length != 4 && transport.equalsIgnoreCase( TRANSPORT_EXT ) ) |
| { |
| result.messages.add( "The connection string contains to few tokens." ); |
| |
| return result; |
| } |
| else if ( ( tokens.length < 4 || tokens.length > 6 ) && transport.equalsIgnoreCase( TRANSPORT_PSERVER ) ) |
| { |
| result.messages.add( "The connection string contains to few tokens." ); |
| |
| return result; |
| } |
| else if ( tokens.length < 4 || tokens.length > 5 && !transport.equalsIgnoreCase( TRANSPORT_PSERVER ) ) |
| { |
| result.messages.add( "The connection string contains to few tokens." ); |
| |
| return result; |
| } |
| |
| if ( transport.equalsIgnoreCase( TRANSPORT_LSERVER ) ) |
| { |
| //create the cvsroot as the local socket cvsroot |
| cvsroot = tokens[1] + ":" + tokens[2]; |
| } |
| else |
| { |
| //create the cvsroot as the remote cvsroot |
| if ( tokens.length == 4 ) |
| { |
| cvsroot = ":" + transport + ":" + tokens[1] + ":" + tokens[2]; |
| } |
| else |
| { |
| cvsroot = ":" + transport + ":" + tokens[1] + ":" + tokens[2] + ":" + tokens[3]; |
| } |
| } |
| } |
| else |
| { |
| result.messages.add( "Unknown transport: " + transport ); |
| |
| return result; |
| } |
| |
| String user = null; |
| |
| String password = null; |
| |
| String host = null; |
| |
| String path = null; |
| |
| String module = null; |
| |
| int port = -1; |
| |
| if ( transport.equalsIgnoreCase( TRANSPORT_PSERVER ) ) |
| { |
| // set default port, it's necessary for checking entries in .cvspass |
| port = 2401; |
| |
| if ( tokens.length == 4 ) |
| { |
| String userhost = tokens[1]; |
| |
| int index = userhost.indexOf( "@" ); |
| |
| if ( index == -1 ) |
| { |
| result.messages.add( "The userhost part must be on the form: <username>@<hostname>." ); |
| |
| return result; |
| } |
| |
| user = userhost.substring( 0, index ); |
| |
| host = userhost.substring( index + 1 ); |
| |
| path = tokens[2]; |
| |
| module = tokens[3]; |
| } |
| else if ( tokens.length == 6 ) |
| { |
| user = tokens[1]; |
| |
| String passhost = tokens[2]; |
| |
| int index = passhost.indexOf( "@" ); |
| |
| if ( index == -1 ) |
| { |
| result.messages |
| .add( "The user_password_host part must be on the form: <username>:<password>@<hostname>." ); |
| |
| return result; |
| } |
| |
| password = passhost.substring( 0, index ); |
| |
| host = passhost.substring( index + 1 ); |
| |
| port = new Integer( tokens[3] ).intValue(); |
| |
| path = tokens[4]; |
| |
| module = tokens[5]; |
| } |
| else |
| { |
| //tokens.length == 5 |
| if ( tokens[1].indexOf( "@" ) > 0 ) |
| { |
| //<username>@<hostname>:<port> |
| String userhost = tokens[1]; |
| |
| int index = userhost.indexOf( "@" ); |
| |
| if ( index == -1 ) |
| { |
| result.messages.add( "The userhost part must be on the form: <username>@<hostname>." ); |
| |
| return result; |
| } |
| |
| user = userhost.substring( 0, index ); |
| |
| host = userhost.substring( index + 1 ); |
| |
| port = new Integer( tokens[2] ).intValue(); |
| } |
| else if ( tokens[2].indexOf( "@" ) >= 0 ) |
| { |
| //<username>:<password>@<hostname> |
| user = tokens[1]; |
| |
| String passhost = tokens[2]; |
| |
| int index = passhost.indexOf( "@" ); |
| |
| if ( index == -1 ) |
| { |
| result.messages |
| .add( "The user_password_host part must be on the form: <username>:<password>@<hostname>." ); |
| |
| return result; |
| } |
| |
| password = passhost.substring( 0, index ); |
| |
| host = passhost.substring( index + 1 ); |
| } |
| else |
| { |
| //incorrect |
| result.messages.add( "You need to specify an user in the url." ); |
| |
| return result; |
| } |
| |
| path = tokens[3]; |
| |
| module = tokens[4]; |
| } |
| |
| String userHost = host; |
| |
| if ( user != null ) |
| { |
| userHost = user + "@" + host; |
| } |
| |
| // cvsroot format is :pserver:[user@]host:[port]path |
| cvsroot = ":" + transport + ":" + userHost + ":"; |
| |
| if ( port != -1 ) |
| { |
| cvsroot += port; |
| } |
| |
| cvsroot += path; |
| } |
| else |
| { |
| if ( !transport.equalsIgnoreCase( TRANSPORT_LOCAL ) ) |
| { |
| String userhost = tokens[1]; |
| |
| int index = userhost.indexOf( "@" ); |
| |
| if ( index == -1 ) |
| { |
| result.messages.add( "The userhost part must be on the form: <username>@<hostname>." ); |
| |
| return result; |
| } |
| |
| user = userhost.substring( 0, index ); |
| |
| host = userhost.substring( index + 1 ); |
| } |
| |
| if ( transport.equals( TRANSPORT_LOCAL ) ) |
| { |
| path = tokens[1]; |
| |
| module = tokens[2]; |
| } |
| else |
| { |
| if ( tokens.length == 4 ) |
| { |
| path = tokens[2]; |
| |
| module = tokens[3]; |
| } |
| else |
| { |
| port = new Integer( tokens[2] ).intValue(); |
| |
| path = tokens[3]; |
| |
| module = tokens[4]; |
| } |
| } |
| } |
| |
| if ( port == -1 ) |
| { |
| result.repository = new CvsScmProviderRepository( cvsroot, transport, user, password, host, path, module ); |
| } |
| else |
| { |
| result.repository = new CvsScmProviderRepository( cvsroot, transport, user, password, host, port, path, |
| module ); |
| } |
| |
| return result; |
| } |
| |
| /** |
| * @see org.apache.maven.scm.provider.AbstractScmProvider#add(org.apache.maven.scm.repository.ScmRepository, org.apache.maven.scm.ScmFileSet, org.apache.maven.scm.CommandParameters) |
| */ |
| public AddScmResult add( ScmRepository repository, ScmFileSet fileSet, CommandParameters parameters ) |
| throws ScmException |
| { |
| CvsAddCommand command = new CvsAddCommand(); |
| |
| command.setLogger( getLogger() ); |
| |
| return (AddScmResult) command.execute( repository.getProviderRepository(), fileSet, parameters ); |
| } |
| |
| /** |
| * @see org.apache.maven.scm.provider.AbstractScmProvider#changelog(org.apache.maven.scm.repository.ScmRepository, org.apache.maven.scm.ScmFileSet, org.apache.maven.scm.CommandParameters) |
| */ |
| public ChangeLogScmResult changelog( ScmRepository repository, ScmFileSet fileSet, CommandParameters parameters ) |
| throws ScmException |
| { |
| CvsChangeLogCommand command = new CvsChangeLogCommand(); |
| |
| command.setLogger( getLogger() ); |
| |
| return (ChangeLogScmResult) command.execute( repository.getProviderRepository(), fileSet, parameters ); |
| } |
| |
| /** |
| * @see org.apache.maven.scm.provider.AbstractScmProvider#checkin(org.apache.maven.scm.repository.ScmRepository, org.apache.maven.scm.ScmFileSet, org.apache.maven.scm.CommandParameters) |
| */ |
| public CheckInScmResult checkin( ScmRepository repository, ScmFileSet fileSet, CommandParameters parameters ) |
| throws ScmException |
| { |
| CvsCheckInCommand command = new CvsCheckInCommand(); |
| |
| command.setLogger( getLogger() ); |
| |
| return (CheckInScmResult) command.execute( repository.getProviderRepository(), fileSet, parameters ); |
| } |
| |
| /** |
| * @see org.apache.maven.scm.provider.AbstractScmProvider#checkout(org.apache.maven.scm.repository.ScmRepository, org.apache.maven.scm.ScmFileSet, org.apache.maven.scm.CommandParameters) |
| */ |
| public CheckOutScmResult checkout( ScmRepository repository, ScmFileSet fileSet, CommandParameters parameters ) |
| throws ScmException |
| { |
| CvsCheckOutCommand command = new CvsCheckOutCommand(); |
| |
| command.setLogger( getLogger() ); |
| |
| return (CheckOutScmResult) command.execute( repository.getProviderRepository(), fileSet, parameters ); |
| } |
| |
| /** |
| * @see org.apache.maven.scm.provider.AbstractScmProvider#diff(org.apache.maven.scm.repository.ScmRepository, org.apache.maven.scm.ScmFileSet, org.apache.maven.scm.CommandParameters) |
| */ |
| public DiffScmResult diff( ScmRepository repository, ScmFileSet fileSet, CommandParameters parameters ) |
| throws ScmException |
| { |
| CvsDiffCommand command = new CvsDiffCommand(); |
| |
| command.setLogger( getLogger() ); |
| |
| return (DiffScmResult) command.execute( repository.getProviderRepository(), fileSet, parameters ); |
| } |
| |
| /** |
| * @see org.apache.maven.scm.provider.AbstractScmProvider#login(org.apache.maven.scm.repository.ScmRepository, org.apache.maven.scm.ScmFileSet, org.apache.maven.scm.CommandParameters) |
| */ |
| public LoginScmResult login( ScmRepository repository, ScmFileSet fileSet, CommandParameters parameters ) |
| throws ScmException |
| { |
| CvsLoginCommand command = new CvsLoginCommand(); |
| |
| command.setLogger( getLogger() ); |
| |
| return (LoginScmResult) command.execute( repository.getProviderRepository(), fileSet, parameters ); |
| } |
| |
| /** |
| * @see org.apache.maven.scm.provider.AbstractScmProvider#remove(org.apache.maven.scm.repository.ScmRepository, org.apache.maven.scm.ScmFileSet, org.apache.maven.scm.CommandParameters) |
| */ |
| public RemoveScmResult remove( ScmRepository repository, ScmFileSet fileSet, CommandParameters parameters ) |
| throws ScmException |
| { |
| CvsRemoveCommand command = new CvsRemoveCommand(); |
| |
| command.setLogger( getLogger() ); |
| |
| return (RemoveScmResult) command.execute( repository.getProviderRepository(), fileSet, parameters ); |
| } |
| |
| /** |
| * @see org.apache.maven.scm.provider.AbstractScmProvider#status(org.apache.maven.scm.repository.ScmRepository, org.apache.maven.scm.ScmFileSet, org.apache.maven.scm.CommandParameters) |
| */ |
| public StatusScmResult status( ScmRepository repository, ScmFileSet fileSet, CommandParameters parameters ) |
| throws ScmException |
| { |
| CvsStatusCommand command = new CvsStatusCommand(); |
| |
| command.setLogger( getLogger() ); |
| |
| return (StatusScmResult) command.execute( repository.getProviderRepository(), fileSet, parameters ); |
| } |
| |
| /** |
| * @see org.apache.maven.scm.provider.AbstractScmProvider#tag(org.apache.maven.scm.repository.ScmRepository, org.apache.maven.scm.ScmFileSet, org.apache.maven.scm.CommandParameters) |
| */ |
| public TagScmResult tag( ScmRepository repository, ScmFileSet fileSet, CommandParameters parameters ) |
| throws ScmException |
| { |
| CvsTagCommand command = new CvsTagCommand(); |
| |
| command.setLogger( getLogger() ); |
| |
| return (TagScmResult) command.execute( repository.getProviderRepository(), fileSet, parameters ); |
| } |
| |
| /** |
| * @see org.apache.maven.scm.provider.AbstractScmProvider#update(org.apache.maven.scm.repository.ScmRepository, org.apache.maven.scm.ScmFileSet, org.apache.maven.scm.CommandParameters) |
| */ |
| public UpdateScmResult update( ScmRepository repository, ScmFileSet fileSet, CommandParameters parameters ) |
| throws ScmException |
| { |
| CvsUpdateCommand command = new CvsUpdateCommand(); |
| |
| command.setLogger( getLogger() ); |
| |
| return (UpdateScmResult) command.execute( repository.getProviderRepository(), fileSet, parameters ); |
| } |
| } |
