/*

  * Copyright 2008 fastConnect.

  *    

  * This file is part of Composite BulkDataPersister.  

  *

  * This is free software; you can redistribute it and/or modify it

  * under the terms of the GNU Lesser General Public License as

  * published by the Free Software Foundation; either version 3 of

  * the License, or (at your option) any later version.

  *

  * This software is distributed in the hope that it will be useful,

  * but WITHOUT ANY WARRANTY; without even the implied warranty of

  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU

  * Lesser General Public License for more details.

  *

  * You should have received a copy of the GNU Lesser General Public

  * License along with this software. If not, see <http://www.gnu.org/licenses/>.

  */

 package fr.fastconnect.gigaspaces.datasource.strategy;

 import java.util.List;

 import java.util.Properties;

 import java.util.logging.Level;

 import java.util.logging.Logger;

 import net.jini.core.lease.Lease;

 import com.gigaspaces.datasource.BulkDataPersister;

 import com.gigaspaces.datasource.BulkItem;

 import com.gigaspaces.datasource.DataSourceException;

 import com.j_spaces.core.IJSpace;

 import com.j_spaces.core.client.FinderException;

 import com.j_spaces.core.client.SpaceFinder;

 import fr.fastconnect.gigaspaces.datasource.ExecutionFailureStrategy;

 /**

  * Use a space to store data.

  * <br />

  * Space is defined by a URL configured through {@value SpaceStorageExecutionFailureStrategy#SPACE_STORAGE_EXECUTION_EXCEPTION_STRATEGY_URL_PROPERTY}SPACE_STORAGE_EXECUTION_EXCEPTION_STRATEGY_URL_PROPERTY.

  * If undefined then {@link SpaceStorageExecutionFailureStrategy#init(Properties)} will throw a {@link DataSourceException}.

  * <br />

  * If underlying {@link SpaceFinder#find(String)} throws an exception then {@link SpaceStorageExecutionFailureStrategy#init(Properties)} will throw a {@link DataSourceException}.

  */

 public class SpaceStorageExecutionFailureStrategy implements ExecutionFailureStrategy {

         private final static Logger LOGGER = Logger.getLogger(SpaceStorageExecutionFailureStrategy.class.getName());

         public static final String SPACE_STORAGE_EXECUTION_EXCEPTION_STRATEGY_URL_PROPERTY = "spacestorage-executionexceptionstrategy-url";

         private IJSpace proxy;

         public SpaceStorageExecutionFailureStrategy() {

         }

         public SpaceStorageExecutionFailureStrategy(final IJSpace proxy) {

                 this.proxy = proxy;

         }

         /** 

          * {@inheritDoc}

          */

         public void init(final Properties properties) throws DataSourceException {

                 if (this.proxy != null) {

                         final String url = properties.getProperty(SPACE_STORAGE_EXECUTION_EXCEPTION_STRATEGY_URL_PROPERTY);

                         if (url != null) {

                                 if (SpaceStorageExecutionFailureStrategy.LOGGER.isLoggable(Level.FINE)) {

                                         SpaceStorageExecutionFailureStrategy.LOGGER.fine("Using <"+url+"> as "+SPACE_STORAGE_EXECUTION_EXCEPTION_STRATEGY_URL_PROPERTY);

                                 }

                                 try {

                                         this.proxy = IJSpace.class.cast(SpaceFinder.find(url));

                                 } catch(FinderException e) {

                                         final String message = "Cannot find Space using URL <"+url+">";

                                         if (SpaceStorageExecutionFailureStrategy.LOGGER.isLoggable(Level.SEVERE)) {

                                                 SpaceStorageExecutionFailureStrategy.LOGGER.log(Level.SEVERE, message, e);

                                         }

                                         throw new DataSourceException(message, e);

                                 }

                         } else {

                                 final String message = "No "+SPACE_STORAGE_EXECUTION_EXCEPTION_STRATEGY_URL_PROPERTY+" defined";

                                 if (SpaceStorageExecutionFailureStrategy.LOGGER.isLoggable(Level.SEVERE)) {

                                         SpaceStorageExecutionFailureStrategy.LOGGER.log(Level.SEVERE, message);

                                 }

                                 throw new DataSourceException(message);

                         }

                 } else {

                         if (SpaceStorageExecutionFailureStrategy.LOGGER.isLoggable(Level.CONFIG)) {

                                 SpaceStorageExecutionFailureStrategy.LOGGER.log(Level.CONFIG, SpaceStorageExecutionFailureStrategy.class.getSimpleName()+" configured manually; ignoring properties");

                         }

                 }

                 if (SpaceStorageExecutionFailureStrategy.LOGGER.isLoggable(Level.CONFIG)) {

                         SpaceStorageExecutionFailureStrategy.LOGGER.log(Level.CONFIG, "Using proxy <"+this.proxy+">");

                 }

         }

         public void handleExecutionFailure(final BulkDataPersister bulkDataPersister, final List<BulkItem> bulkItems, final DataSourceException exception) throws Exception {

                 this.proxy.write(new SpaceStorageExecutionFailure(bulkDataPersister.getClass().getName(), bulkItems, exception), null, Lease.FOREVER);

         }

         public void setSpace(final IJSpace space) {

                 this.proxy = space;

         }

 }