Coverage Report

Coverage Report - org.apache.maven.scm.provider.vss.commands.edit.VssEditConsumer

Classes in this File

Line Coverage

Branch Coverage

Complexity

VssEditConsumer

0 %

0/38

0 %

0/20

2,714

 package org.apache.maven.scm.provider.vss.commands.edit;
 
 /*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
  * regarding copyright ownership.  The ASF licenses this file
  * to you 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.ScmFile;
 import org.apache.maven.scm.ScmFileStatus;
 import org.apache.maven.scm.log.ScmLogger;
 import org.apache.maven.scm.provider.vss.commands.VssConstants;
 import org.apache.maven.scm.provider.vss.repository.VssScmProviderRepository;
 import org.apache.maven.scm.util.AbstractConsumer;
 import org.codehaus.plexus.util.cli.StreamConsumer;
 
 import java.util.ArrayList;
 import java.util.List;
 
 /**
  * @author <a href="mailto:triek@thrx.de">Thorsten Riek</a>
  * @version $Id: VssEditConsumer.java 1054772 2011-01-03 21:34:47Z olamy $
  */
 public class VssEditConsumer
     extends AbstractConsumer
     implements StreamConsumer
 {
 
     /**
      * expecting file information
      */
     private static final int GET_UNKNOWN = 0;
 
     /**
      * expecting file information
      */
     private static final int GET_FILE = 1;
 
     /**
      * expecting file information
      */
     private static final int CURRENTLY_CHECKED_OUT_FILE = 2;
 
     /**
      * expecting file path information
      */
     private static final int GET_FILE_PATH = 3;
 
     /**
      * expecting writable copy
      */
     private static final int IS_WRITABLE_COPY = 4;
 
     /**
      * expecting working folder
      */
     private static final int SET_WORKING_FOLDER = 5;
 
     /**
      * Marks start of file data
      */
     private static final String START_FILE_PATH = "$/";
 
     /**
      * Marks getting a new File
      */
     @SuppressWarnings( "unused" )
     private static final String START_GETTING = "Getting";
 
     /**
      * Marks replacing a old File
      */
     private static final String START_CURRENTLY_CHECKED_OUT = "You currently have file";
 
     /**
      * Marks a writable copy of a File / maybe a conflict
      */
     private static final String START_WRITABLE_COPY = "A writable ";
 
     /**
      * Marks "Set the default folder for project" question
      */
     private static final String CONTAINS_SET_DEFAULT_WORKING_FOLDER = "as the default folder for project";
 
     private String currentPath = "";
 
     private List<ScmFile> updatedFiles = new ArrayList<ScmFile>();
 
     private VssScmProviderRepository repo;
 
     public VssEditConsumer( VssScmProviderRepository repo, ScmLogger logger )
     {
         super( logger );
         this.repo = repo;
     }
 
     /** {@inheritDoc} */
     public void consumeLine( String line )
     {
         if ( getLogger().isDebugEnabled() )
         {
             getLogger().debug( line );
         }
 
         switch ( getLineStatus( line ) )
         {
             case GET_FILE_PATH:
                 processGetFilePath( line );
                 break;
             case GET_FILE:
                 processGetFile( line );
                 break;
             case CURRENTLY_CHECKED_OUT_FILE:
                 processReplaceFile( line );
                 break;
             case IS_WRITABLE_COPY:
                 // will be overwritten and uses REPLACE_FILE
                 break;
             case SET_WORKING_FOLDER:
                 // to trash
                 break;
             default:
                 break;
         }
     }
 
     /**
      * Process the current input line in the Get File state.
      *
      * @param line a line of text from the VSS log output
      */
     private void processGetFile( String line )
     {
         String[] fileLine = line.split( " " );
         updatedFiles.add( new ScmFile( currentPath + "/" + fileLine[1], ScmFileStatus.EDITED ) );
         if ( getLogger().isInfoEnabled() )
         {
             getLogger().info( fileLine[0] + ": " + currentPath + "/" + fileLine[1] );
         }
     }
 
     /**
      * Process the current input line in the Replace File state.
      *
      * @param line a line of text from the VSS log output
      */
     private void processReplaceFile( String line )
     {
 //        updatedFiles.add( new ScmFile( currentPath + "/" + line.substring(START_CURRENTLY_CHECKED_OUT.length()),
 //                          ScmFileStatus.UPDATED ) );
         if ( getLogger().isInfoEnabled() )
         {
             getLogger().info(
                               START_CURRENTLY_CHECKED_OUT + currentPath + "/"
                                   + line.substring( START_CURRENTLY_CHECKED_OUT.length() ) );
         }
     }
 
     /**
      * Process the current input line in the Get File Path state.
      *
      * @param line a line of text from the VSS log output
      */
     private void processGetFilePath( String line )
     {
         currentPath = line.substring( ( VssConstants.PROJECT_PREFIX + repo.getProject() ).length(), line.length() - 1 );
     }
 
     /**
      * Identify the status of a vss get line
      *
      * @param line The line to process
      * @return status
      */
     private int getLineStatus( String line )
     {
         int argument = GET_UNKNOWN;
         if ( line.startsWith( START_FILE_PATH ) )
         {
             argument = GET_FILE_PATH;
         }
         else if ( line.startsWith( START_CURRENTLY_CHECKED_OUT ) )
         {
             argument = CURRENTLY_CHECKED_OUT_FILE;
         }
         else if ( line.startsWith( START_WRITABLE_COPY ) )
         {
             argument = IS_WRITABLE_COPY;
         }
         else if ( line.indexOf( CONTAINS_SET_DEFAULT_WORKING_FOLDER ) != -1 )
         {
             argument = SET_WORKING_FOLDER;
         }
 
         return argument;
     }
 
     public List<ScmFile> getUpdatedFiles()
     {
         return updatedFiles;
     }
 
 }

1		package org.apache.maven.scm.provider.vss.commands.edit;
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 org.apache.maven.scm.ScmFile;
23		import org.apache.maven.scm.ScmFileStatus;
24		import org.apache.maven.scm.log.ScmLogger;
25		import org.apache.maven.scm.provider.vss.commands.VssConstants;
26		import org.apache.maven.scm.provider.vss.repository.VssScmProviderRepository;
27		import org.apache.maven.scm.util.AbstractConsumer;
28		import org.codehaus.plexus.util.cli.StreamConsumer;
29
30		import java.util.ArrayList;
31		import java.util.List;
32
33		/**
34		* @author <a href="mailto:triek@thrx.de">Thorsten Riek</a>
35		* @version $Id: VssEditConsumer.java 1054772 2011-01-03 21:34:47Z olamy $
36		*/
37		public class VssEditConsumer
38		extends AbstractConsumer
39		implements StreamConsumer
40		{
41
42		/**
43		* expecting file information
44		*/
45		private static final int GET_UNKNOWN = 0;
46
47		/**
48		* expecting file information
49		*/
50		private static final int GET_FILE = 1;
51
52		/**
53		* expecting file information
54		*/
55		private static final int CURRENTLY_CHECKED_OUT_FILE = 2;
56
57		/**
58		* expecting file path information
59		*/
60		private static final int GET_FILE_PATH = 3;
61
62		/**
63		* expecting writable copy
64		*/
65		private static final int IS_WRITABLE_COPY = 4;
66
67		/**
68		* expecting working folder
69		*/
70		private static final int SET_WORKING_FOLDER = 5;
71
72		/**
73		* Marks start of file data
74		*/
75		private static final String START_FILE_PATH = "$/";
76
77		/**
78		* Marks getting a new File
79		*/
80		@SuppressWarnings( "unused" )
81		private static final String START_GETTING = "Getting";
82
83		/**
84		* Marks replacing a old File
85		*/
86		private static final String START_CURRENTLY_CHECKED_OUT = "You currently have file";
87
88		/**
89		* Marks a writable copy of a File / maybe a conflict
90		*/
91		private static final String START_WRITABLE_COPY = "A writable ";
92
93		/**
94		* Marks "Set the default folder for project" question
95		*/
96		private static final String CONTAINS_SET_DEFAULT_WORKING_FOLDER = "as the default folder for project";
97
98	0	private String currentPath = "";
99
100	0	private List<ScmFile> updatedFiles = new ArrayList<ScmFile>();
101
102		private VssScmProviderRepository repo;
103
104		public VssEditConsumer( VssScmProviderRepository repo, ScmLogger logger )
105		{
106	0	super( logger );
107	0	this.repo = repo;
108	0	}
109
110		/** {@inheritDoc} */
111		public void consumeLine( String line )
112		{
113	0	if ( getLogger().isDebugEnabled() )
114		{
115	0	getLogger().debug( line );
116		}
117
118	0	switch ( getLineStatus( line ) )
119		{
120		case GET_FILE_PATH:
121	0	processGetFilePath( line );
122	0	break;
123		case GET_FILE:
124	0	processGetFile( line );
125	0	break;
126		case CURRENTLY_CHECKED_OUT_FILE:
127	0	processReplaceFile( line );
128	0	break;
129		case IS_WRITABLE_COPY:
130		// will be overwritten and uses REPLACE_FILE
131	0	break;
132		case SET_WORKING_FOLDER:
133		// to trash
134	0	break;
135		default:
136		break;
137		}
138	0	}
139
140		/**
141		* Process the current input line in the Get File state.
142		*
143		* @param line a line of text from the VSS log output
144		*/
145		private void processGetFile( String line )
146		{
147	0	String[] fileLine = line.split( " " );
148	0	updatedFiles.add( new ScmFile( currentPath + "/" + fileLine[1], ScmFileStatus.EDITED ) );
149	0	if ( getLogger().isInfoEnabled() )
150		{
151	0	getLogger().info( fileLine[0] + ": " + currentPath + "/" + fileLine[1] );
152		}
153	0	}
154
155		/**
156		* Process the current input line in the Replace File state.
157		*
158		* @param line a line of text from the VSS log output
159		*/
160		private void processReplaceFile( String line )
161		{
162		// updatedFiles.add( new ScmFile( currentPath + "/" + line.substring(START_CURRENTLY_CHECKED_OUT.length()),
163		// ScmFileStatus.UPDATED ) );
164	0	if ( getLogger().isInfoEnabled() )
165		{
166	0	getLogger().info(
167		START_CURRENTLY_CHECKED_OUT + currentPath + "/"
168		+ line.substring( START_CURRENTLY_CHECKED_OUT.length() ) );
169		}
170	0	}
171
172		/**
173		* Process the current input line in the Get File Path state.
174		*
175		* @param line a line of text from the VSS log output
176		*/
177		private void processGetFilePath( String line )
178		{
179	0	currentPath = line.substring( ( VssConstants.PROJECT_PREFIX + repo.getProject() ).length(), line.length() - 1 );
180	0	}
181
182		/**
183		* Identify the status of a vss get line
184		*
185		* @param line The line to process
186		* @return status
187		*/
188		private int getLineStatus( String line )
189		{
190	0	int argument = GET_UNKNOWN;
191	0	if ( line.startsWith( START_FILE_PATH ) )
192		{
193	0	argument = GET_FILE_PATH;
194		}
195	0	else if ( line.startsWith( START_CURRENTLY_CHECKED_OUT ) )
196		{
197	0	argument = CURRENTLY_CHECKED_OUT_FILE;
198		}
199	0	else if ( line.startsWith( START_WRITABLE_COPY ) )
200		{
201	0	argument = IS_WRITABLE_COPY;
202		}
203	0	else if ( line.indexOf( CONTAINS_SET_DEFAULT_WORKING_FOLDER ) != -1 )
204		{
205	0	argument = SET_WORKING_FOLDER;
206		}
207
208	0	return argument;
209		}
210
211		public List<ScmFile> getUpdatedFiles()
212		{
213	0	return updatedFiles;
214		}
215
216		}