mercury-1.0.0-alpha-2/mercury-repo/mercury-repo-remote-m2/src/main/java/org/apache/maven/mercury/repository/remote/m2/RepositoryUtilM2.java

/**
 *  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.
 */
package org.apache.maven.mercury.repository.remote.m2;

import java.io.File;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.NoSuchElementException;
import java.util.concurrent.ConcurrentLinkedQueue;

import org.apache.maven.mercury.artifact.ArtifactCoordinates;
import org.apache.maven.mercury.logging.IMercuryLogger;
import org.apache.maven.mercury.logging.MercuryLoggerManager;
import org.apache.maven.mercury.repository.local.m2.LocalRepositoryM2;
import org.apache.maven.mercury.repository.metadata.AddVersionOperation;
import org.apache.maven.mercury.repository.metadata.Metadata;
import org.apache.maven.mercury.repository.metadata.MetadataBuilder;
import org.apache.maven.mercury.repository.metadata.MetadataException;
import org.apache.maven.mercury.repository.metadata.MetadataOperation;
import org.apache.maven.mercury.repository.metadata.StringOperand;
import org.apache.maven.mercury.util.FileUtil;
import org.codehaus.plexus.lang.DefaultLanguage;
import org.codehaus.plexus.lang.Language;

/**
 *
 *
 * @author Oleg Gusakov
 * @version $Id$
 *
 */
public class RepositoryUtilM2
{
  private static final IMercuryLogger _log = MercuryLoggerManager.getLogger( RepositoryUtilM2.class ); 
  private static final Language _lang = new DefaultLanguage( RepositoryUtilM2.class );
  //----------------------------------------------------------------------------------
  public static void flip( LocalRepositoryM2 repo, File dest )
  {
    if( repo == null )
      throw new IllegalArgumentException( _lang.getMessage( "lrepo.null" ) );

    File lDir = repo.getDirectory();
    
    if( lDir == null )
      throw new IllegalArgumentException( _lang.getMessage( "lrepo.no.dir" ) );
    
    if( !lDir.exists() || !lDir.isDirectory() )
      throw new IllegalArgumentException( _lang.getMessage( "lrepo.dir.not.exists", lDir.toString() ) );
    
    if( dest.exists() && !dest.isFile() )
      throw new IllegalArgumentException( _lang.getMessage( "dest.is.file", dest.toString() ) );
    
    
  }

  public static void flipLocalFolderToRemoteRepository( File repoDir )
  {
    
    if( !repoDir.exists() || !repoDir.isDirectory() )
      throw new IllegalArgumentException( _lang.getMessage( "lrepo.dir.not.exists", repoDir.toString() ) );

    // temporary solution: just rename metadata, hoping it is correct
    // ideally - will use metadata correction utility
    FileUtil.renameFile( repoDir, LocalRepositoryM2.METADATA_FILE_NAME, RemoteRepositoryM2.METADATA_FILE_NAME );
  }
  
  private static final void findGA( File dir )
  throws MetadataException, IOException
  {
    if( dir.isFile() )
      return;
    
    File [] files = dir.listFiles();
    
    if( files == null || files.length < 1 )
      return;
    
    int dep = FileUtil.depth( dir );
    
    List<MetadataOperation> vo = null;
    
    if( dep <= 1 )
      vo = new ArrayList<MetadataOperation>();
    
    for( File f : files )
    {
      if( f.isFile() )
        return;
      
      if( dep == 1 )
      {
        vo.add( new AddVersionOperation( new StringOperand(f.getName()) ) );
      }
      else 
        findGA( f );
    }
    
    if( dep == 1 )
    {
      Metadata md = new Metadata();
      
      byte [] mdBytes = MetadataBuilder.changeMetadata( md, vo );
      
      FileUtil.writeRawData( new File( dir, RemoteRepositoryM2.METADATA_FILE_NAME ), mdBytes );
    }
    else if( dep == 0 )
    {
      
    }
  }
  //----------------------------------------------------------------------------------
  //----------------------------------------------------------------------------------
}
//=====================================================================================
class copyGa
implements Runnable
{
  ConcurrentLinkedQueue<ArtifactCoordinates> _q;
  File _root;
  File _dest;
  
  public copyGa( ConcurrentLinkedQueue<ArtifactCoordinates> q, File from, File to )
  {
    this._q = q;
    this._root = from;
    this._dest = to;
  }

  // copy GAV to it's final dest
  public void run()
  {
    try
    {
      for(;;)
      {
        ArtifactCoordinates ga = _q.remove();
        
//        File gaDir = new File( _root );
//        File gaDest = new File( _dest );
//        
//        gaDest.mkdirs();
//        
//        Metadata gaMd = new Metadata();
//        gaMd.setGroupId( groupId )
//        
//        File [] versions = gaDir.listFiles(); 
//        
//        for( File v : versions )
//        {
//          if( v.isFile() )
//            continue;
//        }
        
      }
    }
    catch( NoSuchElementException e )
    {
    }
  }
  //-------------------------------------
}
//=====================================================================================