using System;
using System.Runtime.Serialization;
using System.Runtime.Serialization.Formatters.Binary;
using System.Net.Sockets;
using System.IO;

//using Util;

namespace lib
{




public interface IProcess
{
	void process( object obj );
}




public class Conn
{
	public Socket Sock { get { return m_socket; } }
	public Stream Stream { get { return m_streamNet; } }


	public Conn( Socket sock, IProcess proc )
	{
		m_socket = sock;

		sock.NoDelay = true;
			
		m_streamNet = new NetworkStream( m_socket );

		m_proc = proc;
	}

	public object recieveObject()
	{
		return recieveObject( Stream );
	}

	public object recieveObject( Stream stream )
	{
		object obj = null;

		var formatter = new XmlFormatter2();

		try
		{
			obj = formatter.Deserialize( stream );
		}
		catch( System.Xml.XmlException e )
		{
			lib.Log.error( "Outer Exception {0}", e.ToString() );
		}

		return obj;
	}

	public void send( object obj )
	{

		var formatter = new XmlFormatter2();

		try
		{
			var ms = new MemoryStream( 1024 );
			formatter.Serialize( ms, obj );

			//var str = System.Text.Encoding.Default.GetString( mm_buffer, 0, (int)ms.Position );
			//lib.Log.info( "Sent data {0} of length {1}", str, ms.Position );
			//lib.Log.info( "Sent {0}", obj );

			byte[] byteSize = BitConverter.GetBytes( (uint)ms.Position );
			m_streamNet.Write( byteSize, 0, 4 );
			m_streamNet.Write( ms.GetBuffer(), 0, (int)ms.Position );

			m_streamNet.Flush();
		}
		catch( Exception e )
		{
			lib.Log.warn( $"Exception sending obj {obj} of {e}" );
			throw;
		}
	}
		
	public virtual void recieve( object obj )
	{
		if( m_proc != null ) m_proc.process( obj );
	}
		
	Socket m_socket;

	NetworkStream m_streamNet;

	IProcess m_proc;



	//private BufferedStream m_streamBufIn;
	//private BufferedStream m_streamBufOut;
}



}