old_trunk/core-plugin/src/main/java/org/apache/directory/server/core/tools/schema/DirectorySchemaToolMojo.java - directory-server - Git at Google

 /*
  *  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.directory.server.core.tools.schema;


 import java.io.File;
 import java.io.FileInputStream;
 import java.io.FileWriter;
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.io.Reader;
 import java.io.Writer;
 import java.util.ArrayList;
 import java.util.List;

 import org.apache.directory.server.schema.bootstrap.AbstractBootstrapSchema;
 import org.apache.directory.server.schema.bootstrap.BootstrapSchema;
 import org.apache.directory.server.schema.bootstrap.ProducerTypeEnum;
 import org.apache.directory.shared.ldap.constants.SchemaConstants;
 import org.apache.directory.shared.ldap.schema.parser.AttributeTypeLiteral;
 import org.apache.directory.shared.ldap.schema.parser.ObjectClassLiteral;
 import org.apache.directory.shared.ldap.schema.parser.OpenLdapSchemaParser;
 import org.apache.maven.plugin.AbstractMojo;
 import org.apache.maven.plugin.MojoExecutionException;
 import org.apache.maven.project.MavenProject;
 import org.apache.velocity.VelocityContext;
 import org.apache.velocity.app.Velocity;


 /**
  * Maven 2 plugin mojo wrapper for directory plugin.
  *
  * @goal generate
  * @description Generates ApacheDS schema classes from OpenLDAP schema files
  * @phase generate-sources
  * @author <a href="mailto:dev@directory.apache.org">Apache Directory Project</a>
  * @version $Rev$
  */
 public class DirectorySchemaToolMojo extends AbstractMojo
 {
     /**
      * The directory containing the OpenLDAP schema files.
      * @parameter expression="src/main/schema"
      */
     private File sourceDirectory;

     /**
      * The target directory into which the plugin generates schema java sources.
      * @parameter expression="target/generated-sources"
      */
     private File outputDirectory;

     /**
      * The default package to use for generated schema classes.
      * @parameter expression="org.apache.directory.server.schema.bootstrap"
      */
     private String defaultPackage;

     /**
      * The distinguished name of the default schema owner.
      * @parameter expression="uid=admin,ou=system"
      */
     private String defaultOwner;

     /**
      * The set of schemas to generate classes for.
      * @parameter
      */
     private Schema[] schemas;

     /**
      * Toggles verbose output.
      * @parameter expression="true"
      */
     private boolean verboseOutput;

     /**
      * @parameter expression="${project}"
      * @required
      */
     private MavenProject project;


     public DirectorySchemaToolMojo() throws Exception
     {
         Velocity.init();
     }


     private void generate( BootstrapSchema schema ) throws Exception
     {
         if ( schema == null )
         {
             throw new NullPointerException( "the schema property must be set" );
         }

         String filePath = sourceDirectory + File.separator + schema.getSchemaName() + ".schema";
         InputStream in = new FileInputStream( filePath );
         OpenLdapSchemaParser parser = new OpenLdapSchemaParser();
         parser.parse( in );
         generateSchema( schema );
         generateAttributeTypes( parser, schema );
         generateObjectClasses( parser, schema );
         generateRest( schema );
     }


     protected void generateSchema( BootstrapSchema schema ) throws Exception
     {
         StringBuffer schemaCapped = new StringBuffer();
         schemaCapped.append( Character.toUpperCase( schema.getSchemaName().charAt( 0 ) ) );
         schemaCapped.append( schema.getSchemaName().substring( 1, schema.getSchemaName().length() ) );

         VelocityContext context = new VelocityContext();
         context.put( "package", schema.getPackageName() );
         context.put( "classname", schemaCapped.toString() + "Schema" );
         context.put( "schema", schema.getSchemaName() );
         context.put( "owner", schema.getOwner() );
         context.put( "deps", schema.getDependencies() );

         Reader fileIn = getResourceReader( "Schema.template" );
         Writer writer = getResourceWriter( schema.getPackageName(), schema.getUnqualifiedClassName() );
         Velocity.evaluate( context, writer, "LOG", fileIn );

         writer.flush();
         writer.close();
     }


     protected void generateRest( BootstrapSchema schema ) throws Exception
     {
         List types = new ArrayList();
         types.addAll( ProducerTypeEnum.getList() );
         types.remove( ProducerTypeEnum.ATTRIBUTE_TYPE_PRODUCER );
         types.remove( ProducerTypeEnum.OBJECT_CLASS_PRODUCER );

         ProducerTypeEnum type = null;
         for ( int ii = 0; ii < types.size(); ii++ )
         {
             type = ( ProducerTypeEnum ) types.get( ii );

             if ( exists( schema.getFullDefaultBaseClassName( type ), type ) )
             {
                 continue;
             }

             VelocityContext context = new VelocityContext();
             context.put( "package", schema.getPackageName() );
             context.put( "classname", schema.getUnqualifiedClassName( type ) );
             context.put( "schema", schema.getSchemaName() );
             context.put( "owner", schema.getOwner() );
             context.put( "type", type.getName().substring( 0, type.getName().length() - 8 ) );

             String typeName = null;

             switch ( type )
             {
                 case COMPARATOR_PRODUCER :
                     typeName = "ProducerTypeEnum.COMPARATOR_PRODUCER";
                     break;

                 case DIT_CONTENT_RULE_PRODUCER :
                     typeName = "ProducerTypeEnum.DIT_CONTENT_RULE_PRODUCER";
                     break;

                 case DIT_STRUCTURE_RULE_PRODUCER :
                     typeName = "ProducerTypeEnum.DIT_STRUCTURE_RULE_PRODUCER";
                     break;

                 case MATCHING_RULE_PRODUCER :
                     typeName = "ProducerTypeEnum.MATCHING_RULE_PRODUCER";
                     break;

                 case MATCHING_RULE_USE_PRODUCER :
                     typeName = "ProducerTypeEnum.MATCHING_RULE_USE_PRODUCER";
                     break;

                 case NAME_FORM_PRODUCER :
                     typeName = "ProducerTypeEnum.NAME_FORM_PRODUCER";
                     break;

                 case NORMALIZER_PRODUCER :
                     typeName = "ProducerTypeEnum.NORMALIZER_PRODUCER";
                     break;

                 case SYNTAX_CHECKER_PRODUCER :
                     typeName = "ProducerTypeEnum.SYNTAX_CHECKER_PRODUCER";
                     break;

                 case SYNTAX_PRODUCER :
                     typeName = "ProducerTypeEnum.SYNTAX_PRODUCER";
                     break;

                 default:
                     throw new IllegalStateException( "Unexpected producer: " + type.getName() );
             }

             context.put( "typeName", typeName );
             runVelocity( schema.getPackageName(), schema.getUnqualifiedClassName( type ), context, "typeless.template",
                 type );
         }
     }


     protected void generateAttributeTypes( OpenLdapSchemaParser parser, BootstrapSchema schema ) throws Exception
     {
         final ProducerTypeEnum type = ProducerTypeEnum.ATTRIBUTE_TYPE_PRODUCER;

         // check to see if the producer exists for this type
         if ( exists( schema.getFullDefaultBaseClassName( type ), type ) )
         {
             return;
         }

         int size = parser.getAttributeTypes().size();
         AttributeTypeLiteral[] attributeTypes = new AttributeTypeLiteral[size];
         attributeTypes = ( AttributeTypeLiteral[] ) parser.getAttributeTypes().toArray( attributeTypes );

         VelocityContext context = new VelocityContext();
         context.put( "package", schema.getPackageName() );
         context.put( "classname", schema.getUnqualifiedClassName( type ) );
         context.put( "schema", schema.getSchemaName() );
         context.put( "owner", schema.getOwner() );
         context.put( "schemaDepCount", new Integer( schema.getDependencies().length ) );
         context.put( "schemaDeps", new String[]
             { "dep1", "dep2" } );
         context.put( "attrTypes", attributeTypes );
         runVelocity( schema.getPackageName(), schema.getUnqualifiedClassName( type ), context,
             "AttributeTypes.template", type );
     }


     protected void generateObjectClasses( OpenLdapSchemaParser parser, BootstrapSchema schema ) throws Exception
     {
         final ProducerTypeEnum type = ProducerTypeEnum.OBJECT_CLASS_PRODUCER;

         // check to see if the producer exists for this type
         if ( exists( schema.getFullDefaultBaseClassName( type ), type ) )
         {
             return;
         }

         int size = parser.getObjectClassTypes().size();
         ObjectClassLiteral[] objectClasses = new ObjectClassLiteral[size];
         objectClasses = ( ObjectClassLiteral[] ) parser.getObjectClassTypes().toArray( objectClasses );

         VelocityContext context = new VelocityContext();
         context.put( "package", schema.getPackageName() );
         context.put( "classname", schema.getUnqualifiedClassName( type ) );
         context.put( "schema", schema.getSchemaName() );
         context.put( "owner", schema.getOwner() );
         context.put( "schemaDepCount", new Integer( schema.getDependencies().length ) );
         context.put( "schemaDeps", new String[]
             { "dep1", "dep2" } );
         context.put( SchemaConstants.OBJECT_CLASSES_AT, objectClasses );
         runVelocity( schema.getPackageName(), schema.getUnqualifiedClassName( type ), context,
             "ObjectClasses.template", type );
     }


     protected void runVelocity( String pkg, String uqcn, VelocityContext context, String template, ProducerTypeEnum type )
         throws Exception
     {
         Reader fileIn = getResourceReader( template );
         Writer writer = getResourceWriter( pkg, uqcn );
         Velocity.evaluate( context, writer, "LOG", fileIn );
         writer.flush();
         writer.close();
     }


     protected Reader getResourceReader( String res ) throws IOException
     {
         return new InputStreamReader( getClass().getResourceAsStream( res ) );
     }


     protected boolean mkdirs( String base, String path )
     {
         String[] comps = path.split( "/" );
         File file = new File( base );

         if ( !file.exists() )
         {
             file.mkdirs();
         }

         for ( int ii = 0; ii < comps.length; ii++ )
         {
             file = new File( file, comps[ii] );

             if ( !file.exists() )
             {
                 file.mkdirs();
             }
         }

         return file.exists();
     }


     protected FileWriter getResourceWriter( String pkg, String classname ) throws IOException
     {
         mkdirs( outputDirectory.getPath(), pkg.replace( '.', File.separatorChar ) );
         File base = outputDirectory;
         String relativePath = pkg.replace( '.', File.separatorChar );
         File dir = new File( base, relativePath );
         return new FileWriter( new File( dir, classname + ".java" ) );
     }


     protected boolean exists( String defaultClass, ProducerTypeEnum type )
     {
         // check to see if any of the classes are available in the java
         // source directory, if so we return true
         File defaultFile = new File( project.getBuild().getSourceDirectory() + File.separator
             + getFilePath( defaultClass ) );
         return defaultFile.exists();
     }


     private String getFilePath( String fqcn )
     {
         String path = fqcn.replace( '.', File.separatorChar );
         path += ".java";
         return path;
     }


     private boolean isStale( BootstrapSchema schema )
     {
         String pkgPath = schema.getPackageName().replace( '.', File.separatorChar );
         File dir = new File( outputDirectory, pkgPath );
         File schemaClassFile = new File( dir, schema.getUnqualifiedClassName() + ".java" );

         if ( !schemaClassFile.exists() )
         {
             return true;
         }

         File schemaFile = new File( sourceDirectory, schema.getSchemaName() + ".schema" );
         return schemaFile.lastModified() > schemaClassFile.lastModified();
     }


     public void execute() throws MojoExecutionException
     {
         // Bypass if no schemas have yet been defined
         if ( schemas == null || schemas.length == 0 )
         {
             getLog().warn( "No schemas defined for directory plugin!" );
             return;
         }

         // Make sure schema configurations have a name field and set defaults
         // for any other missing properties of the bean: pkg and owner.
         for ( int ii = 0; ii < schemas.length; ii++ )
         {
             Schema schema = schemas[ii];

             if ( schema.getName() == null )
             {
                 String msg = ii + "th schema configuration element must specify a name.";
                 getLog().error( msg );
                 throw new MojoExecutionException( msg );
             }

             if ( schema.getPkg() == null )
             {
                 schema.setPkg( defaultPackage );
             }

             if ( schema.getOwner() == null )
             {
                 schema.setOwner( defaultOwner );
             }
         }

         // Report configuration if verbose output is enabled
         if ( verboseOutput )
         {
             report();
         }

         // Create output directory if it does not exist
         if ( !outputDirectory.exists() )
         {
             outputDirectory.mkdirs();
         }

         // Generate for each schema
         for ( int ii = 0; ii < schemas.length; ii++ )
         {
             try
             {
                 BootstrapSchema bootstrapSchema = new AbstractBootstrapSchema( schemas[ii].getOwner(), schemas[ii]
                     .getName(), schemas[ii].getPkg(), schemas[ii].getDependencies() )
                 {
                 };

                 if ( isStale( bootstrapSchema ) )
                 {
                     getLog().info( "Generating " + schemas[ii].getName() + " schema." );
                     generate( bootstrapSchema );
                 }
                 else
                 {
                     getLog().info( schemas[ii].getName() + " schema is up to date." );
                 }
             }
             catch ( Exception e )
             {
                 throw new MojoExecutionException( "Failed while generating sources for " + schemas[ii].getName(), e );
             }
         }

         project.addCompileSourceRoot( outputDirectory.getPath() );
     }


     private void report()
     {
         getLog().info( "===================================================================" );
         getLog().info( "[directory:generate]" );
         getLog().info( "sourceDirectory = " + sourceDirectory );
         getLog().info( "outputDirectory = " + outputDirectory );
         getLog().info( "defaultPackage  = " + defaultPackage );
         getLog().info( "defaultOwner    = " + defaultOwner );
         getLog().info( "----------------------------- schemas -----------------------------" );

         if ( schemas != null )
         {
             for ( int ii = 0; ii < schemas.length; ii++ )
             {
                 getLog().info( "SCHEMA: " + schemas[ii].getName() );

                 if ( schemas[ii].getDependencies() != null )
                 {
                     StringBuffer buf = new StringBuffer();
                     for ( int jj = 0; jj < schemas[ii].getDependencies().length; jj++ )
                     {
                         buf.append( schemas[ii].getDependencies()[jj] );
                         buf.append( " " );
                     }
                     getLog().info( "DEPENDENCIES: " + buf.toString() );
                 }

                 getLog().info( "PACKAGE: " + schemas[ii].getPkg() );
                 getLog().info( "OWNER: " + schemas[ii].getOwner() );

                 if ( ii + 1 < schemas.length )
                 {
                     getLog().info( "" );
                 }
             }
         }

         getLog().info( "===================================================================" );
     }
 }
	/*
	* 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.directory.server.core.tools.schema;


	import java.io.File;
	import java.io.FileInputStream;
	import java.io.FileWriter;
	import java.io.IOException;
	import java.io.InputStream;
	import java.io.InputStreamReader;
	import java.io.Reader;
	import java.io.Writer;
	import java.util.ArrayList;
	import java.util.List;

	import org.apache.directory.server.schema.bootstrap.AbstractBootstrapSchema;
	import org.apache.directory.server.schema.bootstrap.BootstrapSchema;
	import org.apache.directory.server.schema.bootstrap.ProducerTypeEnum;
	import org.apache.directory.shared.ldap.constants.SchemaConstants;
	import org.apache.directory.shared.ldap.schema.parser.AttributeTypeLiteral;
	import org.apache.directory.shared.ldap.schema.parser.ObjectClassLiteral;
	import org.apache.directory.shared.ldap.schema.parser.OpenLdapSchemaParser;
	import org.apache.maven.plugin.AbstractMojo;
	import org.apache.maven.plugin.MojoExecutionException;
	import org.apache.maven.project.MavenProject;
	import org.apache.velocity.VelocityContext;
	import org.apache.velocity.app.Velocity;


	/**
	* Maven 2 plugin mojo wrapper for directory plugin.
	*
	* @goal generate
	* @description Generates ApacheDS schema classes from OpenLDAP schema files
	* @phase generate-sources
	* @author <a href="mailto:dev@directory.apache.org">Apache Directory Project</a>
	* @version $Rev$
	*/
	public class DirectorySchemaToolMojo extends AbstractMojo
	{
	/**
	* The directory containing the OpenLDAP schema files.
	* @parameter expression="src/main/schema"
	*/
	private File sourceDirectory;

	/**
	* The target directory into which the plugin generates schema java sources.
	* @parameter expression="target/generated-sources"
	*/
	private File outputDirectory;

	/**
	* The default package to use for generated schema classes.
	* @parameter expression="org.apache.directory.server.schema.bootstrap"
	*/
	private String defaultPackage;

	/**
	* The distinguished name of the default schema owner.
	* @parameter expression="uid=admin,ou=system"
	*/
	private String defaultOwner;

	/**
	* The set of schemas to generate classes for.
	* @parameter
	*/
	private Schema[] schemas;

	/**
	* Toggles verbose output.
	* @parameter expression="true"
	*/
	private boolean verboseOutput;

	/**
	* @parameter expression="${project}"
	* @required
	*/
	private MavenProject project;


	public DirectorySchemaToolMojo() throws Exception
	{
	Velocity.init();
	}


	private void generate( BootstrapSchema schema ) throws Exception
	{
	if ( schema == null )
	{
	throw new NullPointerException( "the schema property must be set" );
	}

	String filePath = sourceDirectory + File.separator + schema.getSchemaName() + ".schema";
	InputStream in = new FileInputStream( filePath );
	OpenLdapSchemaParser parser = new OpenLdapSchemaParser();
	parser.parse( in );
	generateSchema( schema );
	generateAttributeTypes( parser, schema );
	generateObjectClasses( parser, schema );
	generateRest( schema );
	}


	protected void generateSchema( BootstrapSchema schema ) throws Exception
	{
	StringBuffer schemaCapped = new StringBuffer();
	schemaCapped.append( Character.toUpperCase( schema.getSchemaName().charAt( 0 ) ) );
	schemaCapped.append( schema.getSchemaName().substring( 1, schema.getSchemaName().length() ) );

	VelocityContext context = new VelocityContext();
	context.put( "package", schema.getPackageName() );
	context.put( "classname", schemaCapped.toString() + "Schema" );
	context.put( "schema", schema.getSchemaName() );
	context.put( "owner", schema.getOwner() );
	context.put( "deps", schema.getDependencies() );

	Reader fileIn = getResourceReader( "Schema.template" );
	Writer writer = getResourceWriter( schema.getPackageName(), schema.getUnqualifiedClassName() );
	Velocity.evaluate( context, writer, "LOG", fileIn );

	writer.flush();
	writer.close();
	}


	protected void generateRest( BootstrapSchema schema ) throws Exception
	{
	List types = new ArrayList();
	types.addAll( ProducerTypeEnum.getList() );
	types.remove( ProducerTypeEnum.ATTRIBUTE_TYPE_PRODUCER );
	types.remove( ProducerTypeEnum.OBJECT_CLASS_PRODUCER );

	ProducerTypeEnum type = null;
	for ( int ii = 0; ii < types.size(); ii++ )
	{
	type = ( ProducerTypeEnum ) types.get( ii );

	if ( exists( schema.getFullDefaultBaseClassName( type ), type ) )
	{
	continue;
	}

	VelocityContext context = new VelocityContext();
	context.put( "package", schema.getPackageName() );
	context.put( "classname", schema.getUnqualifiedClassName( type ) );
	context.put( "schema", schema.getSchemaName() );
	context.put( "owner", schema.getOwner() );
	context.put( "type", type.getName().substring( 0, type.getName().length() - 8 ) );

	String typeName = null;

	switch ( type )
	{
	case COMPARATOR_PRODUCER :
	typeName = "ProducerTypeEnum.COMPARATOR_PRODUCER";
	break;

	case DIT_CONTENT_RULE_PRODUCER :
	typeName = "ProducerTypeEnum.DIT_CONTENT_RULE_PRODUCER";
	break;

	case DIT_STRUCTURE_RULE_PRODUCER :
	typeName = "ProducerTypeEnum.DIT_STRUCTURE_RULE_PRODUCER";
	break;

	case MATCHING_RULE_PRODUCER :
	typeName = "ProducerTypeEnum.MATCHING_RULE_PRODUCER";
	break;

	case MATCHING_RULE_USE_PRODUCER :
	typeName = "ProducerTypeEnum.MATCHING_RULE_USE_PRODUCER";
	break;

	case NAME_FORM_PRODUCER :
	typeName = "ProducerTypeEnum.NAME_FORM_PRODUCER";
	break;

	case NORMALIZER_PRODUCER :
	typeName = "ProducerTypeEnum.NORMALIZER_PRODUCER";
	break;

	case SYNTAX_CHECKER_PRODUCER :
	typeName = "ProducerTypeEnum.SYNTAX_CHECKER_PRODUCER";
	break;

	case SYNTAX_PRODUCER :
	typeName = "ProducerTypeEnum.SYNTAX_PRODUCER";
	break;

	default:
	throw new IllegalStateException( "Unexpected producer: " + type.getName() );
	}

	context.put( "typeName", typeName );
	runVelocity( schema.getPackageName(), schema.getUnqualifiedClassName( type ), context, "typeless.template",
	type );
	}
	}


	protected void generateAttributeTypes( OpenLdapSchemaParser parser, BootstrapSchema schema ) throws Exception
	{
	final ProducerTypeEnum type = ProducerTypeEnum.ATTRIBUTE_TYPE_PRODUCER;

	// check to see if the producer exists for this type
	if ( exists( schema.getFullDefaultBaseClassName( type ), type ) )
	{
	return;
	}

	int size = parser.getAttributeTypes().size();
	AttributeTypeLiteral[] attributeTypes = new AttributeTypeLiteral[size];
	attributeTypes = ( AttributeTypeLiteral[] ) parser.getAttributeTypes().toArray( attributeTypes );

	VelocityContext context = new VelocityContext();
	context.put( "package", schema.getPackageName() );
	context.put( "classname", schema.getUnqualifiedClassName( type ) );
	context.put( "schema", schema.getSchemaName() );
	context.put( "owner", schema.getOwner() );
	context.put( "schemaDepCount", new Integer( schema.getDependencies().length ) );
	context.put( "schemaDeps", new String[]
	{ "dep1", "dep2" } );
	context.put( "attrTypes", attributeTypes );
	runVelocity( schema.getPackageName(), schema.getUnqualifiedClassName( type ), context,
	"AttributeTypes.template", type );
	}


	protected void generateObjectClasses( OpenLdapSchemaParser parser, BootstrapSchema schema ) throws Exception
	{
	final ProducerTypeEnum type = ProducerTypeEnum.OBJECT_CLASS_PRODUCER;

	// check to see if the producer exists for this type
	if ( exists( schema.getFullDefaultBaseClassName( type ), type ) )
	{
	return;
	}

	int size = parser.getObjectClassTypes().size();
	ObjectClassLiteral[] objectClasses = new ObjectClassLiteral[size];
	objectClasses = ( ObjectClassLiteral[] ) parser.getObjectClassTypes().toArray( objectClasses );

	VelocityContext context = new VelocityContext();
	context.put( "package", schema.getPackageName() );
	context.put( "classname", schema.getUnqualifiedClassName( type ) );
	context.put( "schema", schema.getSchemaName() );
	context.put( "owner", schema.getOwner() );
	context.put( "schemaDepCount", new Integer( schema.getDependencies().length ) );
	context.put( "schemaDeps", new String[]
	{ "dep1", "dep2" } );
	context.put( SchemaConstants.OBJECT_CLASSES_AT, objectClasses );
	runVelocity( schema.getPackageName(), schema.getUnqualifiedClassName( type ), context,
	"ObjectClasses.template", type );
	}


	protected void runVelocity( String pkg, String uqcn, VelocityContext context, String template, ProducerTypeEnum type )
	throws Exception
	{
	Reader fileIn = getResourceReader( template );
	Writer writer = getResourceWriter( pkg, uqcn );
	Velocity.evaluate( context, writer, "LOG", fileIn );
	writer.flush();
	writer.close();
	}


	protected Reader getResourceReader( String res ) throws IOException
	{
	return new InputStreamReader( getClass().getResourceAsStream( res ) );
	}


	protected boolean mkdirs( String base, String path )
	{
	String[] comps = path.split( "/" );
	File file = new File( base );

	if ( !file.exists() )
	{
	file.mkdirs();
	}

	for ( int ii = 0; ii < comps.length; ii++ )
	{
	file = new File( file, comps[ii] );

	if ( !file.exists() )
	{
	file.mkdirs();
	}
	}

	return file.exists();
	}


	protected FileWriter getResourceWriter( String pkg, String classname ) throws IOException
	{
	mkdirs( outputDirectory.getPath(), pkg.replace( '.', File.separatorChar ) );
	File base = outputDirectory;
	String relativePath = pkg.replace( '.', File.separatorChar );
	File dir = new File( base, relativePath );
	return new FileWriter( new File( dir, classname + ".java" ) );
	}


	protected boolean exists( String defaultClass, ProducerTypeEnum type )
	{
	// check to see if any of the classes are available in the java
	// source directory, if so we return true
	File defaultFile = new File( project.getBuild().getSourceDirectory() + File.separator
	+ getFilePath( defaultClass ) );
	return defaultFile.exists();
	}


	private String getFilePath( String fqcn )
	{
	String path = fqcn.replace( '.', File.separatorChar );
	path += ".java";
	return path;
	}


	private boolean isStale( BootstrapSchema schema )
	{
	String pkgPath = schema.getPackageName().replace( '.', File.separatorChar );
	File dir = new File( outputDirectory, pkgPath );
	File schemaClassFile = new File( dir, schema.getUnqualifiedClassName() + ".java" );

	if ( !schemaClassFile.exists() )
	{
	return true;
	}

	File schemaFile = new File( sourceDirectory, schema.getSchemaName() + ".schema" );
	return schemaFile.lastModified() > schemaClassFile.lastModified();
	}


	public void execute() throws MojoExecutionException
	{
	// Bypass if no schemas have yet been defined
	if ( schemas == null \|\| schemas.length == 0 )
	{
	getLog().warn( "No schemas defined for directory plugin!" );
	return;
	}

	// Make sure schema configurations have a name field and set defaults
	// for any other missing properties of the bean: pkg and owner.
	for ( int ii = 0; ii < schemas.length; ii++ )
	{
	Schema schema = schemas[ii];

	if ( schema.getName() == null )
	{
	String msg = ii + "th schema configuration element must specify a name.";
	getLog().error( msg );
	throw new MojoExecutionException( msg );
	}

	if ( schema.getPkg() == null )
	{
	schema.setPkg( defaultPackage );
	}

	if ( schema.getOwner() == null )
	{
	schema.setOwner( defaultOwner );
	}
	}

	// Report configuration if verbose output is enabled
	if ( verboseOutput )
	{
	report();
	}

	// Create output directory if it does not exist
	if ( !outputDirectory.exists() )
	{
	outputDirectory.mkdirs();
	}

	// Generate for each schema
	for ( int ii = 0; ii < schemas.length; ii++ )
	{
	try
	{
	BootstrapSchema bootstrapSchema = new AbstractBootstrapSchema( schemas[ii].getOwner(), schemas[ii]
	.getName(), schemas[ii].getPkg(), schemas[ii].getDependencies() )
	{
	};

	if ( isStale( bootstrapSchema ) )
	{
	getLog().info( "Generating " + schemas[ii].getName() + " schema." );
	generate( bootstrapSchema );
	}
	else
	{
	getLog().info( schemas[ii].getName() + " schema is up to date." );
	}
	}
	catch ( Exception e )
	{
	throw new MojoExecutionException( "Failed while generating sources for " + schemas[ii].getName(), e );
	}
	}

	project.addCompileSourceRoot( outputDirectory.getPath() );
	}


	private void report()
	{
	getLog().info( "===================================================================" );
	getLog().info( "[directory:generate]" );
	getLog().info( "sourceDirectory = " + sourceDirectory );
	getLog().info( "outputDirectory = " + outputDirectory );
	getLog().info( "defaultPackage = " + defaultPackage );
	getLog().info( "defaultOwner = " + defaultOwner );
	getLog().info( "----------------------------- schemas -----------------------------" );

	if ( schemas != null )
	{
	for ( int ii = 0; ii < schemas.length; ii++ )
	{
	getLog().info( "SCHEMA: " + schemas[ii].getName() );

	if ( schemas[ii].getDependencies() != null )
	{
	StringBuffer buf = new StringBuffer();
	for ( int jj = 0; jj < schemas[ii].getDependencies().length; jj++ )
	{
	buf.append( schemas[ii].getDependencies()[jj] );
	buf.append( " " );
	}
	getLog().info( "DEPENDENCIES: " + buf.toString() );
	}

	getLog().info( "PACKAGE: " + schemas[ii].getPkg() );
	getLog().info( "OWNER: " + schemas[ii].getOwner() );

	if ( ii + 1 < schemas.length )
	{
	getLog().info( "" );
	}
	}
	}

	getLog().info( "===================================================================" );
	}
	}