package com.trendmicro.grid.acl.ds.msmq;
   
   import net.sf.tinyjee.collections.Filter;
   import net.sf.tinyjee.collections.FilteredCollection;
   import net.sf.tinyjee.config.*;
   import net.sf.tinyjee.config.documentation.ResourceDocumentation;
   import net.sf.tinyjee.config.documentation.SectionDocumentation;
   
   import java.util.Arrays;
  import java.util.Collection;
  import java.util.Collections;
  
  /**
   * Adds a new configuration section to the application server's config file.
   *
   * @author juergen_kellerer, 2010-06-02
   * @version 1.0
   */
  @SectionDocumentation(
  		name = MSMQPropertySection.NAME_SECTION,
  		description = "Configures the data binding against the MSMQ Message Bus."
  )
  @ResourceDocumentation(
  		name = MSMQPropertySection.NAME_CONNECTION,
  		description = "Defines an outgoing connection to the MSMQ server using the HTTP " +
  				"transport protocol.\n" +
  				"\n" +
  				"Adjust the value of 'msmqhost' to match the hostname or hostname:port of " +
  				"the IIS server hosting the 'HTTPMSMQBridge' module. The complete address " +
  				"must point to the custom bridge application in order to make the MSQM connection " +
  				"functional."
  )
  public class MSMQPropertySection extends PropertySection implements ConfigurationBuilder {
  
  	private static final long serialVersionUID = -4111897772847377832L;
  
  	public static final String NAME_SECTION = "gacl-msmq-messagebus";
  	public static final String NAME_CONNECTION = "gacl-msmq";
  
  	public static final String KEY_TARGET_QUEUE_PREFIX = "targetQueue:";
  	public static final String QUEUE_PROCESS_REQUEST = "process.requests";
  
  	public static String getTargetQueueKey(String queueName) {
  		return KEY_TARGET_QUEUE_PREFIX.concat(queueName);
  	}
  
  	public static String getTargetQueue(String queueName) {
  		String key = getTargetQueueKey(queueName);
  		return ConfigurationContext.getInstance().getConfiguration().getPropertyValue(key);
  	}
  
  	public static Collection<Connection> getMSMQConnections() {
  		Configuration config = ConfigurationContext.getInstance().getConfiguration();
  		return new FilteredCollection<Connection>(config.getActiveConnections(), new Filter<Connection>() {
  			public boolean accept(Connection value) {
  				return NAME_CONNECTION.equals(value.getName());
  			}
  		});
  	}
  
  	public MSMQPropertySection() {
  		super(NAME_SECTION);
  
  		// Define default values
  		addProperty(getTargetQueueKey(QUEUE_PROCESS_REQUEST), "al_out");
  	}
  
  	/**
  	 * {@inheritDoc}
  	 */
  	public Collection<PropertySection> buildDefaultSections() {
  		return Collections.singleton((PropertySection) new MSMQPropertySection());
  	}
  
  	/**
  	 * {@inheritDoc}
  	 */
  	@Override
  	public Collection<? extends Resource> buildDefaultResources() {
  		Connection devConnection = createConnection();
  		return Arrays.asList(devConnection);
  	}
  
  	private Connection createConnection() {
  		return new Connection(
  				Connection.Protocol.http, Connection.Type.outgoing, NAME_CONNECTION,
  				"http://${msmqbridgehost}/HTTPMSMQBridge/", 80);
  	}
  }