1 package org.apache.maven.scm.provider.perforce.command.tag;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import java.util.ArrayList;
23 import java.util.List;
24
25 import org.apache.maven.scm.ScmFile;
26 import org.apache.maven.scm.ScmFileStatus;
27 import org.apache.maven.scm.provider.perforce.command.AbstractPerforceConsumer;
28 import org.apache.regexp.RE;
29 import org.apache.regexp.RESyntaxException;
30 import org.codehaus.plexus.util.cli.StreamConsumer;
31
32
33
34
35
36
37 public class PerforceTagConsumer
38 extends AbstractPerforceConsumer
39 implements StreamConsumer
40 {
41
42 private static final String LABEL_PATTERN = "^Label ([^ ]+) saved.$";
43
44 private static final String SYNC_PATTERN = "^([^#]+)#\\d+ - (.*)";
45
46 public static final int STATE_CREATE = 1;
47
48 public static final int STATE_SYNC = 2;
49
50 public static final int STATE_ERROR = 3;
51
52 private int currentState = STATE_CREATE;
53
54 private List<ScmFile> tagged = new ArrayList<ScmFile>();
55
56 private RE syncRegexp;
57
58 public PerforceTagConsumer()
59 {
60 try
61 {
62 syncRegexp = new RE( SYNC_PATTERN );
63 }
64 catch ( RESyntaxException ignored )
65 {
66 ignored.printStackTrace();
67 }
68 }
69
70
71
72
73
74
75
76
77
78 public List<ScmFile> getTagged()
79 {
80 return tagged;
81 }
82
83
84
85
86
87
88
89
90
91
92
93
94
95 public void consumeLine( String line )
96 {
97 switch ( currentState )
98 {
99 case STATE_CREATE:
100 if ( !new RE( LABEL_PATTERN ).match( line ) )
101 {
102 error( line );
103 break;
104 }
105 currentState = STATE_SYNC;
106 break;
107 case STATE_SYNC:
108 if ( !syncRegexp.match( line ) )
109 {
110 error( line );
111 break;
112 }
113 tagged.add( new ScmFile( syncRegexp.getParen( 1 ), ScmFileStatus.TAGGED ) );
114 break;
115 default:
116 error( line );
117 break;
118 }
119 }
120
121 private void error( String line )
122 {
123 currentState = STATE_ERROR;
124 output.println( line );
125 }
126
127 public boolean isSuccess()
128 {
129 return currentState == STATE_SYNC;
130 }
131
132 }