maven-scm-providers/maven-scm-provider-perforce/src/main/java/org/apache/maven/scm/provider/perforce/command/checkin/PerforceCheckInConsumer.java

package org.apache.maven.scm.provider.perforce.command.checkin;

/*
 * 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.regexp.RE;
import org.apache.regexp.RESyntaxException;
import org.codehaus.plexus.util.cli.StreamConsumer;

import java.io.PrintWriter;
import java.io.StringWriter;

/**
 * @author Mike Perham
 * @version $Id: PerforceChangeLogConsumer.java 331276 2005-11-07 15:04:54Z
 *          evenisse $
 */
public class PerforceCheckInConsumer
    implements StreamConsumer
{
    private static final String CREATED_PATTERN = "^Change \\d+ created .+$";

    private static final String SUBMITTING_PATTERN = "^Submitting change \\d+\\.$";

    private static final String LOCKING_PATTERN = "^Locking \\d+ files \\.\\.\\.$";

    private static final String OP_PATTERN = "^[a-z]+ //[^#]+#\\d+$";

    // SCM-181 Two possible messages:
    // "Change 94821 renamed change 94823 and submitted."
    // "Change 94821 submitted."
    private static final String COMPLETE_PATTERN = "^Change \\d+ .*submitted.$";

    public static final int STATE_CREATED = 1;

    public static final int STATE_SUBMITTING = 2;

    public static final int STATE_LOCKING = 3;

    public static final int STATE_OP = 4;

    public static final int STATE_COMPLETE = 5;

    public static final int STATE_ERROR = 6;

    private StringWriter errors = new StringWriter();

    private PrintWriter errorOutput = new PrintWriter( errors );

    private int currentState = STATE_CREATED;

    private RE opRegexp;

    public PerforceCheckInConsumer()
    {
        try
        {
            opRegexp = new RE( OP_PATTERN );
        }
        catch ( RESyntaxException ignored )
        {
            ignored.printStackTrace();
        }
    }

    /*
     * Change 80835 created with 1 open file(s). Submitting change 80835.
     * Locking 1 files ... add //depot/modules/cordoba/runtime-ear/foo.xml#1
     * Change 80835 submitted.
     */
    /*
     * Submitting change 80837. Locking 1 files ... edit
     * //depot/modules/cordoba/runtime-ear/Foo.java#2 Submit validation failed --
     * fix problems then use 'p4 submit -c 80837'. 'checkstyle' validation
     * failed:
     * 
     * depot/modules/cordoba/runtime-ear/Foo.java:3:1: Got an exception -
     * expecting EOF, found '}'
     */
    public void consumeLine( String line )
    {
        if ( line.startsWith( "... " ) )
        {
            //TODO log this somehow?
            //System.out.println("Perforce: " + line);
            return;
        }

        switch ( currentState )
        {
            case STATE_CREATED:
                boolean created = new RE( CREATED_PATTERN ).match( line );
                if ( created )
                {
                    currentState++;
                    break;
                }
                error( line );
                break;
            case STATE_SUBMITTING:
                boolean submitting = new RE( SUBMITTING_PATTERN ).match( line );
                if ( submitting )
                {
                    currentState++;
                    break;
                }
                error( line );
                break;
            case STATE_LOCKING:
                boolean locked = new RE( LOCKING_PATTERN ).match( line );
                if ( locked )
                {
                    currentState++;
                    break;
                }
                error( line );
                break;
            case STATE_OP:
                boolean operation = opRegexp.match( line );
                if ( operation )
                {
                    break;
                }
                else if ( new RE( COMPLETE_PATTERN ).match( line ) )
                {
                    currentState++;
                    break;
                }
                error( line );
                break;
            case STATE_ERROR:
                error( line );
                break;
        }
    }

    private void error( String line )
    {
        //        if (currentState != STATE_ERROR) {
        //            System.out.println("Unable to match: " + line + " State: " +
        // currentState);
        //            new Exception().printStackTrace();
        //        }
        currentState = STATE_ERROR;
        errorOutput.println( line );
    }

    public boolean isSuccess()
    {
        return currentState == STATE_COMPLETE;
    }

    public String getOutput()
    {
        errorOutput.flush();
        errors.flush();
        return errors.toString();
    }
}