package com.dianping.cat.build;

import java.util.ArrayList;
import java.util.List;

import com.dianping.cat.message.MessageProducer;
import com.dianping.cat.message.internal.DefaultMessageManager;
import com.dianping.cat.message.internal.DefaultMessageProducer;
import com.dianping.cat.message.internal.MessageIdFactory;
import com.dianping.cat.message.io.DefaultMessageQueue;
import com.dianping.cat.message.io.DefaultTransportManager;
import com.dianping.cat.message.io.InMemoryQueue;
import com.dianping.cat.message.io.InMemoryReceiver;
import com.dianping.cat.message.io.InMemorySender;
import com.dianping.cat.message.io.MessageReceiver;
import com.dianping.cat.message.io.MessageSender;
import com.dianping.cat.message.io.TcpSocketHierarchySender;
import com.dianping.cat.message.io.TcpSocketReceiver;
import com.dianping.cat.message.io.TcpSocketSender;
import com.dianping.cat.message.io.TransportManager;
import com.dianping.cat.message.spi.MessageCodec;
import com.dianping.cat.message.spi.MessageConsumer;
import com.dianping.cat.message.spi.MessageConsumerRegistry;
import com.dianping.cat.message.spi.MessageHandler;
import com.dianping.cat.message.spi.MessageManager;
import com.dianping.cat.message.spi.MessagePathBuilder;
import com.dianping.cat.message.spi.MessageQueue;
import com.dianping.cat.message.spi.MessageStatistics;
import com.dianping.cat.message.spi.MessageStorage;
import com.dianping.cat.message.spi.consumer.DummyConsumer;
import com.dianping.cat.message.spi.consumer.DumpToHtmlConsumer;
import com.dianping.cat.message.spi.internal.DefaultMessageConsumerRegistry;
import com.dianping.cat.message.spi.internal.DefaultMessageHandler;
import com.dianping.cat.message.spi.internal.DefaultMessagePathBuilder;
import com.dianping.cat.message.spi.internal.DefaultMessageStatistics;
import com.dianping.cat.message.spi.internal.DefaultMessageStorage;
import com.dianping.cat.status.StatusUpdateTask;
import com.site.lookup.configuration.AbstractResourceConfigurator;
import com.site.lookup.configuration.Component;

public class ComponentsConfigurator extends AbstractResourceConfigurator {
	@Override
	public List<Component> defineComponents() {
		List<Component> all = new ArrayList<Component>();

		all.add(C(InMemoryQueue.class));
		all.add(C(MessageSender.class, "in-memory", InMemorySender.class) //
		      .req(InMemoryQueue.class));
		all.add(C(MessageReceiver.class, "in-memory", InMemoryReceiver.class) //
		      .req(InMemoryQueue.class));

		all.add(C(MessageManager.class, DefaultMessageManager.class) //
		      .req(MessageStatistics.class));
		all.add(C(MessageProducer.class, DefaultMessageProducer.class) //
		      .req(MessageManager.class, MessageIdFactory.class));
		all.add(C(MessageIdFactory.class));
		all.add(C(MessagePathBuilder.class, DefaultMessagePathBuilder.class) //
		      .req(MessageManager.class));

		all.add(C(MessageStorage.class, "html", DefaultMessageStorage.class) //
		      .req(MessagePathBuilder.class) //
		      .req(MessageCodec.class, "html"));
		all.add(C(MessageConsumer.class, DummyConsumer.ID, DummyConsumer.class));
		all.add(C(MessageConsumer.class, DumpToHtmlConsumer.ID, DumpToHtmlConsumer.class) //
		      .req(MessageStorage.class, "html") //
		      .req(MessagePathBuilder.class));
		all.add(C(MessageConsumerRegistry.class, DefaultMessageConsumerRegistry.class) //
		      .req(MessageConsumer.class, new String[] { DummyConsumer.ID }, "m_consumers"));

		all.add(C(MessageQueue.class, DefaultMessageQueue.class) //
		      .config(E("size").value("1000")) //
		      .is(PER_LOOKUP));

		all.add(C(MessageSender.class, "tcp-socket", TcpSocketSender.class) //
		      .is(PER_LOOKUP) //
		      .req(MessageStatistics.class, "default", "m_statistics") //
		      .req(MessageCodec.class, "plain-text", "m_codec")//
		      .req(MessageQueue.class, "default", "m_queue"));
		all.add(C(MessageSender.class, "tcp-socket-hierarchy", TcpSocketHierarchySender.class) //
				.is(PER_LOOKUP) //
				.req(MessageStatistics.class, "default", "m_statistics") //
				.req(MessageCodec.class, "plain-text", "m_codec")//
				.req(MessageQueue.class, "default", "m_queue"));
		all.add(C(MessageReceiver.class, "tcp-socket", TcpSocketReceiver.class) //
		      .is(PER_LOOKUP) //
		      .req(MessageCodec.class, "plain-text"));
		all.add(C(TransportManager.class, DefaultTransportManager.class) //
		      .req(MessageManager.class));

		all.add(C(MessageHandler.class, DefaultMessageHandler.class) //
		      .req(MessageManager.class, MessageConsumerRegistry.class));
		all.add(C(MessageStatistics.class, DefaultMessageStatistics.class));
		all.add(C(StatusUpdateTask.class) //
		      .req(MessageStatistics.class));

		all.addAll(new CodecComponentConfigurator().defineComponents());
		all.addAll(new StorageComponentConfigurator().defineComponents());

		return all;
	}

	public static void main(String[] args) {
		generatePlexusComponentsXmlFile(new ComponentsConfigurator());
	}
}