package jbCAP;

import jVARIANT.VARIANT;
import jVARIANT.VARENUM;
import java.util.ArrayList;
import java.util.Arrays;

/** @file bCapControllers.java
 *
 *  @brief b-CAP client library
 *
 *  @version	1.2
 *	@date		2014/5/26
 *	@author		DENSO WAVE (m)
 *
 */
public class bCapControllers extends bCapCollectionTmpl{
	protected bCapControllers()
	{
		m_hr = 0;
		m_objArray = new ArrayList<bCapObjectTmpl>();
	}
	
	public bCapController Item(int index)
	{
		return (bCapController)super.Item(new VARIANT(VARENUM.VT_I4, index));
	}
	
	public bCapController Item(VARIANT index)
	{
		return (bCapController)super.Item(index);
	}
	
	public void Remove(bCapController ctrl){
		Remove((bCapObjectTmpl)ctrl);
	}
	
	public bCapController Add(String host, int port, boolean UDP, int timeout, int retry, int wdt, int zipMode, String strController, String strProvider, String strMachine, String strOption)
	{
		if(UDP)
		{
			m_bCapSock = new bCapSocketUDP(host, port, timeout, retry, wdt);
		}
		else
		{
			m_bCapSock = new bCapSocketTCP(host, port, timeout, wdt, zipMode);
		}
		
		if((m_hr = m_bCapSock.IsConnected()) < 0)
		{
			return null;
		}
		
		bCapPacket msg = new bCapPacket();
		msg.m_ID = 3; // Controller_Connect
		
		VARIANT[] vnt = new VARIANT[4];
		vnt[0] = new VARIANT(VARENUM.VT_BSTR, strController);
		vnt[1] = new VARIANT(VARENUM.VT_BSTR, strProvider);
		vnt[2] = new VARIANT(VARENUM.VT_BSTR, strMachine);
		vnt[3] = new VARIANT(VARENUM.VT_BSTR, strOption);
		msg.m_vntArray.addAll(Arrays.asList(vnt));
		
		msg = m_bCapSock.SendMessage(msg);

		m_hr = msg.m_ID;

		if(msg.m_vntArray.size() == 1 && msg.m_vntArray.get(0).VariantGetType() == VARENUM.VT_I4)
		{
			bCapController ctrl = new bCapController((Integer) msg.m_vntArray.get(0).VariantGetObject(), m_bCapSock);
			
			m_objArray.add(ctrl);
			
			return ctrl;
		}
		else
		{
			return null;
		}
	}
}