[hibernate-commits] Hibernate SVN: r11087 - branches/Branch_3_2/HibernateExt/metadata/src/java/org/hibernate/search/util.
Author: epbernard
Date: 2007-01-23 15:12:25 -0500 (Tue, 23 Jan 2007)
New Revision: 11087
Added:
branches/Branch_3_2/HibernateExt/metadata/src/java/org/hibernate/search/util/DirectoryProviderHelper.java
Log:
ANN-519 pluggable worker
ANN-523 JMS implementation
Added:
branches/Branch_3_2/HibernateExt/metadata/src/java/org/hibernate/search/util/DirectoryProviderHelper.java
===================================================================
---
branches/Branch_3_2/HibernateExt/metadata/src/java/org/hibernate/search/util/DirectoryProviderHelper.java
(rev 0)
+++
branches/Branch_3_2/HibernateExt/metadata/src/java/org/hibernate/search/util/DirectoryProviderHelper.java 2007-01-23
20:12:25 UTC (rev 11087)
@@ -0,0 +1,80 @@
+//$Id: $
+package org.hibernate.search.util;
+
+import java.util.Properties;
+import java.io.File;
+import java.io.IOException;
+import java.text.MessageFormat;
+
+import org.hibernate.HibernateException;
+import org.hibernate.AssertionFailure;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+/**
+ * @author Emmanuel Bernard
+ */
+public class DirectoryProviderHelper {
+ private static Log log = LogFactory.getLog( DirectoryProviderHelper.class );
+ /**
+ * Build a directory name out of a root and relative path, guessing the significant
part
+ * and checking for the file availability
+ *
+ */
+ public static String getSourceDirectory(String rootPropertyName, String
relativePropertyName, Properties properties) {
+ //TODO check that it's a directory
+ String root = properties.getProperty( rootPropertyName );
+ String relative = properties.getProperty( relativePropertyName );
+ if ( log.isTraceEnabled() ) {
+ log.trace(
+ "Guess source directory from " + rootPropertyName + " " + root
!= null ? root : "<null>"
+ + " and " + relativePropertyName + " " + relative != null ?
relative : "<null>"
+ );
+ }
+ if (relative == null) throw new HibernateException("source property
mandatory");
+ if (root == null) {
+ log.debug( "No root directory, go with relative " + relative );
+ File sourceFile = new File(relative);
+ if ( ! sourceFile.exists() ) {
+ throw new HibernateException("Unable to read source directory: " +
relative);
+ }
+ //else keep source as it
+ }
+ else {
+ File sourceFile = new File(root, relative);
+ if ( sourceFile.exists() ) {
+ log.debug( "Get directory from root + relative");
+ try {
+ relative = sourceFile.getCanonicalPath();
+ }
+ catch (IOException e) {
+ throw new AssertionFailure("Unable to get canonical path: " + root +
" + " + relative);
+ }
+ }
+ else {
+ sourceFile = new File(relative);
+ log.debug( "Get directory from relative only");
+ if ( ! sourceFile.exists() ) {
+ throw new HibernateException("Unable to read source directory: " +
relative);
+ }
+ //else keep source as it
+ }
+ }
+ return relative;
+ }
+
+ public static File determineIndexDir(String directoryProviderName, Properties
properties) {
+ String indexBase = properties.getProperty( "indexBase", "." );
+ File indexDir = new File( indexBase );
+ if ( !( indexDir.exists() && indexDir.isDirectory() ) ) {
+ //TODO create the directory?
+ throw new HibernateException( MessageFormat.format( "Index directory does not
exists: {0}", indexBase ) );
+ }
+ if ( !indexDir.canWrite() ) {
+ throw new HibernateException( "Cannot write into index directory: " +
indexBase );
+ }
+
+ indexDir = new File( indexDir, directoryProviderName );
+ return indexDir;
+ }
+}