/**
* Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of the License "Eclipse Public License v1.0"
* which accompanies this distribution, and is available
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
*
* Initial Contributors:
* Nokia Corporation - initial contribution.
*
* Contributors:
*
* Description: 
*
*/

package com.nokia.carbide.remoteconnections.tests.discovery;

import java.net.URL;
import java.util.HashSet;
import java.util.Map;
import java.util.Random;
import java.util.Set;

import org.eclipse.core.runtime.CoreException;

import com.nokia.carbide.remoteconnections.RemoteConnectionsActivator;
import com.nokia.carbide.remoteconnections.interfaces.IConnectionFactory;
import com.nokia.carbide.remoteconnections.interfaces.IConnectionType;
import com.nokia.carbide.remoteconnections.interfaces.IConnectionsManager;
import com.nokia.carbide.remoteconnections.internal.api.IConnection2;
import com.nokia.carbide.remoteconnections.internal.api.IDeviceDiscoveryAgent;
import com.nokia.carbide.remoteconnections.tests.extensions.IntervalConnectionType;
import com.nokia.carbide.remoteconnections.tests.extensions.TestFilter;

public class RandomDiscoveryAgent implements IDeviceDiscoveryAgent {
	private static final String CONNECTION_TYPE = 
		"com.nokia.carbide.remoteconnections.tests.extensions.IntervalConnectionType";
	private Random random = new Random();
	private Set<IConnection2> connections = new HashSet<IConnection2>();
	private IConnectionsManager manager = RemoteConnectionsActivator.getConnectionsManager();

	private final class DiscoveryThread extends Thread {
		private static final int MAX = 60000;
		private static final int MIN = 10000;
		private volatile boolean keepRunning;
		
		public void run() {
			keepRunning = true;
			while (keepRunning) {
				try {
					sleep(getRandomCreationIntervalMs());
				} catch (InterruptedException e) {
					keepRunning = false;
				}
				if (getRandomIntBetween(0, connections.size() + 1) == 0) {
					createNewConnection();
				}
				else if (!connections.isEmpty()) {
					IConnection2 connection = connections.iterator().next();
					connections.remove(connection);
					manager.disconnect(connection);
				}
			}
		}
		
		private int getRandomCreationIntervalMs() {
			return getRandomIntBetween(MIN, MAX);
		}

		public void stopRunning() {
			keepRunning = false;
		}
	}

	private DiscoveryThread thread = new DiscoveryThread();

	public URL getInformation() {
		return null;
	}

	private void createNewConnection() {
		IConnectionType connectionType = 
			RemoteConnectionsActivator.getConnectionTypeProvider().getConnectionType(CONNECTION_TYPE);
		IConnectionFactory factory = connectionType.getConnectionFactory();
		Map<String, String> settings = factory.getSettingsFromUI();
		String val = getRandomIntervalString();
		settings.put(IntervalConnectionType.KEY, val);
		IConnection2 connection = (IConnection2) factory.createConnection(settings);
		connection.setDisplayName(connection.getConnectionType().getDisplayName() + " " + val + " ms");
		connection.setDynamic(true);
		connections.add(connection);
		manager.addConnection(connection);
		manager.setCurrentConnection(connection);
	}

	private String getRandomIntervalString() {
		int r = getRandomIntBetween(1000, 30000);
		return Integer.toString(r);
	}		
	
	private int getRandomIntBetween(int min, int max) {
		return (Math.abs(random.nextInt()) % (max - min)) + min;
	}
	
	public void start() throws CoreException {
		if (TestFilter.isTest)
			thread.start();
	}

	public void stop() throws CoreException {
		thread.stopRunning();
	}

}