package org.apache.maven.it;

import java.io.File;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Set;

import org.apache.maven.it.util.ResourceExtractor;

/**
 * Test set for <a href="https://issues.apache.org/jira/browse/MNG-5965">MNG-5965</a>.
 */
public class MavenITmng5965ParallelBuildMultipliesWorkTest
    extends AbstractMavenIntegrationTestCase
{
    public MavenITmng5965ParallelBuildMultipliesWorkTest()
    {
        super( "[3.6.1,)" );
    }

    public void testItShouldOnlyRunEachTaskOnce()
        throws Exception
    {
        File testDir =
            ResourceExtractor.simpleExtractResources( getClass(), "/mng-5965-parallel-build-multiplies-work" );

        Verifier verifier = newVerifier( testDir.getAbsolutePath(), false );
        verifier.setMavenDebug( false );
        verifier.setAutoclean( false );

        verifier.setLogFileName( "log-only.txt" );
        verifier.addCliOption( "-T1" );
        // include an aggregator task so that the two goals end up in different task segments
        verifier.executeGoals( Arrays.asList( "clean", "install:help" ) );
        verifier.verifyErrorFreeLog();
        verifier.resetStreams();

        List<String> logLines = verifier.loadLines( "log-only.txt", "UTF-8" );

        List<String> cleanGoalsExecuted = findCleanExecutions( logLines );

        // clean only executed once per module
        assertNoRepeatedLines( cleanGoalsExecuted );

        // clean executed in the 3 modules
        assertEquals( cleanGoalsExecuted.size(), 3 );
    }

    private void assertNoRepeatedLines( List<String> logLines )
        throws VerificationException
    {
        Set<String> uniqueLines = new LinkedHashSet<>();
        for ( String line : logLines )
        {
            if ( uniqueLines.contains( line ) )
            {
                throw new VerificationException( "Goal executed twice: " + line );
            }
            uniqueLines.add( line );
        }
    }

    private List<String> findCleanExecutions( List<String> fullLog )
    {
        List<String> cleanExecutions = new ArrayList<>();
        for ( String line : fullLog )
        {
            if ( line.contains( "(default-clean)" ) )
            {
                cleanExecutions.add( line );
            }
        }

        return cleanExecutions;
    }

}