View Javadoc

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   *
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      private String currentPath = "";
98  
99      private List<ScmFile> updatedFiles = new ArrayList<ScmFile>();
100 
101     private VssScmProviderRepository repo;
102 
103     public VssUpdateConsumer( VssScmProviderRepository repo, ScmLogger logger )
104     {
105         super( logger );
106         this.repo = repo;
107     }
108 
109     /** {@inheritDoc} */
110     public void consumeLine( String line )
111     {
112         if ( getLogger().isDebugEnabled() )
113         {
114             getLogger().debug( line );
115         }
116 
117         switch ( getLineStatus( line ) )
118         {
119             case GET_FILE_PATH:
120                 processGetFilePath( line );
121                 break;
122             case GET_FILE:
123                 processGetFile( line );
124                 break;
125             case REPLACE_FILE:
126                 processReplaceFile( line );
127                 break;
128             case IS_WRITABLE_COPY:
129                 // FIXME is actually in error stream if command is build without -G-
130                 processWritableFile( line );
131                 break;
132             case SET_WORKING_FOLDER:
133                 // to trash
134                 break;
135             default:
136                 break;
137         }
138     }
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         String[] fileLine = line.split( " " );
148         updatedFiles.add( new ScmFile( currentPath + "/" + fileLine[1], ScmFileStatus.UPDATED ) );
149         if ( getLogger().isInfoEnabled() )
150         {
151             getLogger().info( fileLine[0] + ": " + currentPath + "/" + fileLine[1] );
152         }
153 
154     }
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         updatedFiles.add(
164             new ScmFile( currentPath + "/" + line.substring( START_REPLACING.length() ), ScmFileStatus.UPDATED ) );
165         if ( getLogger().isInfoEnabled() )
166         {
167             getLogger().info( START_REPLACING + currentPath + "/" + line.substring( START_REPLACING.length() ) );
168         }
169     }
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         currentPath = line.substring( ( VssConstants.PROJECT_PREFIX + repo.getProject() ).length(), line.length() - 1 );
179     }
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     }
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         int argument = GET_UNKNOWN;
204         if ( line.startsWith( START_FILE_PATH ) )
205         {
206             argument = GET_FILE_PATH;
207         }
208         else if ( line.startsWith( START_GETTING ) )
209         {
210             argument = GET_FILE;
211         }
212         else if ( line.startsWith( START_REPLACING ) )
213         {
214             argument = REPLACE_FILE;
215         }
216         else if ( line.startsWith( START_WRITABLE_COPY ) )
217         {
218             argument = IS_WRITABLE_COPY;
219         }
220         else if ( line.indexOf( CONTAINS_SET_DEFAULT_WORKING_FOLDER ) != -1 )
221         {
222             argument = SET_WORKING_FOLDER;
223         }
224 
225         return argument;
226     }
227 
228     public List<ScmFile> getUpdatedFiles()
229     {
230         return updatedFiles;
231     }
232 
233 }