Coverage Report

Coverage Report - org.apache.maven.scm.provider.vss.commands.update.VssUpdateConsumer

Classes in this File

Line Coverage

Branch Coverage

Complexity

VssUpdateConsumer

0 %

0/43

0 %

0/22

2,625

 package org.apache.maven.scm.provider.vss.commands.update;
 
 /*
  * 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: VssUpdateConsumer.java 1056980 2011-01-09 17:23:55Z olamy $
  */
 public class VssUpdateConsumer
     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 REPLACE_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
      */
     private static final String START_GETTING = "Getting";
 
     /**
      * Marks replacing a old File
      */
     private static final String START_REPLACING = "Replacing local copy of ";
 
     /**
      * 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 VssUpdateConsumer( 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 REPLACE_FILE:
                 processReplaceFile( line );
                 break;
             case IS_WRITABLE_COPY:
                 // FIXME is actually in error stream if command is build without -G-
                 processWritableFile( line );
                 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.UPDATED ) );
         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_REPLACING.length() ), ScmFileStatus.UPDATED ) );
         if ( getLogger().isInfoEnabled() )
         {
             getLogger().info( START_REPLACING + currentPath + "/" + line.substring( START_REPLACING.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 );
     }
 
     /**
      * Process the current input line in the writable File state.
      *
      * @param line a line of text from the VSS log output
      */
     private void processWritableFile( String line )
     {
         // FIXME extract file name
         //        String[] fileLine = line.split( " " );
         //        updatedFiles.add( new ScmFile( currentPath + "/" + fileLine[1], ScmFileStatus.MODIFIED ) );
         //        getLogger().info( fileLine[0] + ": " + currentPath + "/" + fileLine[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_GETTING ) )
         {
             argument = GET_FILE;
         }
         else if ( line.startsWith( START_REPLACING ) )
         {
             argument = REPLACE_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.update;
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: VssUpdateConsumer.java 1056980 2011-01-09 17:23:55Z olamy $
36		*/
37		public class VssUpdateConsumer
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 REPLACE_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		private static final String START_GETTING = "Getting";
81
82		/**
83		* Marks replacing a old File
84		*/
85		private static final String START_REPLACING = "Replacing local copy of ";
86
87		/**
88		* Marks a writable copy of a File / maybe a conflict
89		*/
90		private static final String START_WRITABLE_COPY = "A writable ";
91
92		/**
93		* Marks "Set the default folder for project" question
94		*/
95		private static final String CONTAINS_SET_DEFAULT_WORKING_FOLDER = "as the default folder for project";
96
97	0	private String currentPath = "";
98
99	0	private List<ScmFile> updatedFiles = new ArrayList<ScmFile>();
100
101		private VssScmProviderRepository repo;
102
103		public VssUpdateConsumer( VssScmProviderRepository repo, ScmLogger logger )
104		{
105	0	super( logger );
106	0	this.repo = repo;
107	0	}
108
109		/** {@inheritDoc} */
110		public void consumeLine( String line )
111		{
112	0	if ( getLogger().isDebugEnabled() )
113		{
114	0	getLogger().debug( line );
115		}
116
117	0	switch ( getLineStatus( line ) )
118		{
119		case GET_FILE_PATH:
120	0	processGetFilePath( line );
121	0	break;
122		case GET_FILE:
123	0	processGetFile( line );
124	0	break;
125		case REPLACE_FILE:
126	0	processReplaceFile( line );
127	0	break;
128		case IS_WRITABLE_COPY:
129		// FIXME is actually in error stream if command is build without -G-
130	0	processWritableFile( line );
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.UPDATED ) );
149	0	if ( getLogger().isInfoEnabled() )
150		{
151	0	getLogger().info( fileLine[0] + ": " + currentPath + "/" + fileLine[1] );
152		}
153
154	0	}
155
156		/**
157		* Process the current input line in the Replace File state.
158		*
159		* @param line a line of text from the VSS log output
160		*/
161		private void processReplaceFile( String line )
162		{
163	0	updatedFiles.add(
164		new ScmFile( currentPath + "/" + line.substring( START_REPLACING.length() ), ScmFileStatus.UPDATED ) );
165	0	if ( getLogger().isInfoEnabled() )
166		{
167	0	getLogger().info( START_REPLACING + currentPath + "/" + line.substring( START_REPLACING.length() ) );
168		}
169	0	}
170
171		/**
172		* Process the current input line in the Get File Path state.
173		*
174		* @param line a line of text from the VSS log output
175		*/
176		private void processGetFilePath( String line )
177		{
178	0	currentPath = line.substring( ( VssConstants.PROJECT_PREFIX + repo.getProject() ).length(), line.length() - 1 );
179	0	}
180
181		/**
182		* Process the current input line in the writable File state.
183		*
184		* @param line a line of text from the VSS log output
185		*/
186		private void processWritableFile( String line )
187		{
188		// FIXME extract file name
189		// String[] fileLine = line.split( " " );
190		// updatedFiles.add( new ScmFile( currentPath + "/" + fileLine[1], ScmFileStatus.MODIFIED ) );
191		// getLogger().info( fileLine[0] + ": " + currentPath + "/" + fileLine[1] );
192
193	0	}
194
195		/**
196		* Identify the status of a vss get line
197		*
198		* @param line The line to process
199		* @return status
200		*/
201		private int getLineStatus( String line )
202		{
203	0	int argument = GET_UNKNOWN;
204	0	if ( line.startsWith( START_FILE_PATH ) )
205		{
206	0	argument = GET_FILE_PATH;
207		}
208	0	else if ( line.startsWith( START_GETTING ) )
209		{
210	0	argument = GET_FILE;
211		}
212	0	else if ( line.startsWith( START_REPLACING ) )
213		{
214	0	argument = REPLACE_FILE;
215		}
216	0	else if ( line.startsWith( START_WRITABLE_COPY ) )
217		{
218	0	argument = IS_WRITABLE_COPY;
219		}
220	0	else if ( line.indexOf( CONTAINS_SET_DEFAULT_WORKING_FOLDER ) != -1 )
221		{
222	0	argument = SET_WORKING_FOLDER;
223		}
224
225	0	return argument;
226		}
227
228		public List<ScmFile> getUpdatedFiles()
229		{
230	0	return updatedFiles;
231		}
232
233		}