Peer Graph - Importing and Exporting a Database

using System;
using System.Runtime.InteropServices;

namespace Peer.Graph
{
	public class PeerOpenConnection
	{
		PeerGraph graph;
		System.Int64 connectionId;

		public PeerOpenConnection(PeerGraph Graph, System.Int64 ConnectionId)
		{
			graph = Graph;
			connectionId = ConnectionId;
		}

		public PeerGraph Graph
		{
			get
			{
				return graph;
			}
		}

		public System.Int64 ConnectionId
		{
			get
			{
				return connectionId;
			}
		}

		public void Close()
		{
			if (connectionId != 0) 
			{
				graph.CloseDirectConnection(connectionId);
				connectionId = 0;
			}
		}

		public PeerConnection Connection
		{
			get
			{
				return graph.GetConnectionInfo(connectionId);
			}
		}

		public void SendData(Guid Type, string Message)
		{
			IntPtr dataptr = Marshal.StringToHGlobalUni(Message);
			int size = (Message.Length+1)*2;
			graph.SendData(connectionId, Type, size, dataptr);
		}

		public void SendData(Guid Type, System.IO.Stream Data)
		{
			int size = (int)Data.Length;
			byte[] data = new byte[size];
			Data.Read(data, 0, size);
			IntPtr dataptr = Marshal.AllocHGlobal(size);
			Marshal.StructureToPtr(data, dataptr, false);
			graph.SendData(connectionId, Type, size, dataptr);
		}

		public delegate void DataReceivedHandler(object sender, PeerGraphDataReceiveEventArgs e);
		public event DataReceivedHandler DataReceived;

		internal void RaiseDataReceivedEvent(PeerGraphDataReceiveEventArgs args)
		{
			if (DataReceived != null)
			{
				DataReceived(this, args);
			}
		}
	}

	public class PeerConnection
	{
		private PeerConnectionType type;
		private System.Int64 connectionId;
		private System.Int64 peerId;
		private string peerName;
		private PEER_ADDRESS address;

		internal PeerConnection(PEER_CONNECTION_INFO info)
		{
			type = (PeerConnectionType)info.dwFlags;
			connectionId = info.ullConnectionId;
			peerId = info.ullNodeId;
			peerName = info.wzPeerName;
			address = info.address;
		}

		public PeerConnectionType Type
		{
			get
			{
				return type;
			}
		}

		public System.Int64 ConnectionId
		{
			get
			{
				return connectionId;
			}
		}

		public System.Int64 PeerId
		{
			get
			{
				return peerId;
			}
		}

		public string PeerName
		{
			get
			{
				return peerName;
			}
		}

		public System.Net.IPEndPoint Address
		{
			get
			{
				return new System.Net.IPEndPoint(new System.Net.IPAddress(address.sin6.sin6_addr), address.sin6.sin6_port);
			}
		}
	}
}