package com.trendmicro.grid.acl.ds.cache.commands;
   
   import com.trendmicro.grid.acl.ds.cache.CacheDestination;
   import com.trendmicro.grid.acl.ds.cache.CacheSettings;
   import org.slf4j.Logger;
   import org.slf4j.LoggerFactory;
   
   import java.util.ArrayList;
   import java.util.Collection;
  import java.util.Map;
  
  /**
   * Removes a bunch of keys from a cache destination.
   *
   * @author juergen_kellerer, 2011-03-25
   * @version 1.0
   */
  public class RemoveCommand<K, V> extends AbstractCommand<K, V> {
  
  	private static final Logger log = LoggerFactory.getLogger(RemoveCommand.class);
  
  	private CacheDestination<K, ?>[] cacheDestinations;
  
  	/**
  	 * Constructs the command.
  	 *
  	 * @param keys			 the keys to remove.
  	 * @param cacheDestination the destination(s) to remove the keys from.
  	 */
  	public RemoveCommand(Collection<K> keys, CacheDestination<K, ?>... cacheDestination) {
  		super(new ArrayList<K>(keys));
  		// Copying the keys as the removal may be async. and external keys collection may change.
  
  		cacheDestinations = cacheDestination;
  	}
  
  	/**
  	 * Returns this command as batch command.
  	 *
  	 * @return this command as batch command.
  	 */
  	public BatchCommand<K, V> asBatchCommand() {
  		return new BatchCommand<K, V>(keys, this, cacheDestinations);
  	}
  
  	protected void removeKeys() {
  		for (CacheDestination<K, ?> destination : cacheDestinations)
  			destination.removeAll(keys);
  	}
  
  	/**
  	 * {@inheritDoc}
  	 */
  	@Override
  	public Map<K, V> call() throws Exception {
  		if (!CacheSettings.DISABLED)
  			removeKeys();
  		return keysToCallResult();
  	}
  }