View Javadoc

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   *
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      private String currentPath = "";
99  
100     private List<ScmFile> updatedFiles = new ArrayList<ScmFile>();
101 
102     private VssScmProviderRepository repo;
103 
104     public VssEditConsumer( VssScmProviderRepository repo, ScmLogger logger )
105     {
106         super( logger );
107         this.repo = repo;
108     }
109 
110     /** {@inheritDoc} */
111     public void consumeLine( String line )
112     {
113         if ( getLogger().isDebugEnabled() )
114         {
115             getLogger().debug( line );
116         }
117 
118         switch ( getLineStatus( line ) )
119         {
120             case GET_FILE_PATH:
121                 processGetFilePath( line );
122                 break;
123             case GET_FILE:
124                 processGetFile( line );
125                 break;
126             case CURRENTLY_CHECKED_OUT_FILE:
127                 processReplaceFile( line );
128                 break;
129             case IS_WRITABLE_COPY:
130                 // will be overwritten and uses REPLACE_FILE
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.EDITED ) );
149         if ( getLogger().isInfoEnabled() )
150         {
151             getLogger().info( fileLine[0] + ": " + currentPath + "/" + fileLine[1] );
152         }
153     }
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         if ( getLogger().isInfoEnabled() )
165         {
166             getLogger().info(
167                               START_CURRENTLY_CHECKED_OUT + currentPath + "/"
168                                   + line.substring( START_CURRENTLY_CHECKED_OUT.length() ) );
169         }
170     }
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         currentPath = line.substring( ( VssConstants.PROJECT_PREFIX + repo.getProject() ).length(), line.length() - 1 );
180     }
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         int argument = GET_UNKNOWN;
191         if ( line.startsWith( START_FILE_PATH ) )
192         {
193             argument = GET_FILE_PATH;
194         }
195         else if ( line.startsWith( START_CURRENTLY_CHECKED_OUT ) )
196         {
197             argument = CURRENTLY_CHECKED_OUT_FILE;
198         }
199         else if ( line.startsWith( START_WRITABLE_COPY ) )
200         {
201             argument = IS_WRITABLE_COPY;
202         }
203         else if ( line.indexOf( CONTAINS_SET_DEFAULT_WORKING_FOLDER ) != -1 )
204         {
205             argument = SET_WORKING_FOLDER;
206         }
207 
208         return argument;
209     }
210 
211     public List<ScmFile> getUpdatedFiles()
212     {
213         return updatedFiles;
214     }
215 
216 }