using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using UnityEngine.Networking;

public class test : MonoBehaviour {

	int m_MyHostId;
	int m_PeerId;

	byte error;

	bool connected = false;

	byte[] b = new byte[500];

	void Start()
	{
		NetworkTransport.Init ();
		ConnectionConfig myConfig = new ConnectionConfig();
		myConfig.AddChannel(QosType.Reliable);

		HostTopology hostTopology = new HostTopology(myConfig, 10);         //up to 10 connection allowed
		m_MyHostId = NetworkTransport.AddHost(hostTopology, 9999);

		m_PeerId = NetworkTransport.Connect(m_MyHostId, "127.0.0.1", 9999, 0, out error);
		if ((NetworkError)error != NetworkError.Ok)
		{
			Debug.LogError("Network error is occurred: " + (NetworkError)error);
		}
	}

	void Update()
	{
		int recHostId;
		int connectionId;
		int channelId;
		byte[] recBuffer = new byte[1024];
		int bufferSize = 1024;
		int dataSize;

		if (connected) {
			for (int i = 0; i < 2; i++) {

				NetworkTransport.Send (m_MyHostId, m_PeerId, 0, b, b.Length, out error);

				if ((NetworkError)error != NetworkError.Ok)
				{
					Debug.LogError("Network error is occurred: " + (NetworkError)error);
					connected = false;
				}
			}
		}

		while (true) {
			NetworkEventType recData = NetworkTransport.Receive (out recHostId, out connectionId, out channelId, recBuffer, bufferSize, out dataSize, out error);

			if ((NetworkError)error != NetworkError.Ok) {
				Debug.LogError ("Network error is occurred: " + (NetworkError)error);
				connected = false;
				break;
			}

			if (recData == NetworkEventType.Nothing) {
				break;
			}

			switch (recData) {
			case NetworkEventType.ConnectEvent:
				Debug.Assert (connectionId == m_PeerId, "Success");
				connected = true;
				break;
			case NetworkEventType.DataEvent:
				Debug.Log ("Received Data");
				break;
			case NetworkEventType.DisconnectEvent:
				Debug.Assert (connectionId == m_PeerId, "Failure");
				connected = false;
				break;
			default:
				break;
			}
		}

		System.GC.Collect ();
	}
}