No commit message

Pop3/trunk/Ntlx.Server/Dispatcher/Dispatcher.cs

@@ -0,0 +1,55 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using Ntlx.Server.Net;
+using Ntlx.Server.Sessions;
+using Ntlx.Server.Formatters;
+using Ntlx.Server.Collections.Generic;
+
+namespace Ntlx.Server.Dispatcher
+{
+	public class Dispatcher
+	{
+		private Gateway gateway;
+
+		private SessionManager sessionManager = new SessionManager();
+
+		private IDictionary<string, IFormatter> formatters = new ThreadSafeDictionary<string, IFormatter>();
+
+
+		public Dispatcher(Gateway gateway)
+		{
+			this.gateway = gateway;
+			gateway.OpenConnection += OpenConnection;
+			gateway.CloseConnection += CloseConnection;
+		}
+
+
+		private void OpenConnection(object sender, ConnectionOpenEventArgs e)
+		{
+			sessionManager.AddSession(new Session(e.Connection.Id));
+			e.Connection.Received += ReceivedData;
+			e.Formatter.DeserializedMessage += DeserializedMessage;
+			formatters[e.Connection.Id] = e.Formatter;
+		}
+
+		private void CloseConnection(object sender, ConnectionCloseEventArgs e)
+		{
+			e.Connection.Received -= ReceivedData;
+			formatters[e.Connection.Id].DeserializedMessage -= DeserializedMessage;
+			formatters.Remove(e.Connection.Id);
+			sessionManager.RemoveSession(e.Connection.Id);
+		}
+
+		private void ReceivedData(object sender, ConnectionBufferEventArgs e)
+		{
+			formatters[e.Connection.Id].WriteMessage(e.Buffer, e.Offset, e.Count);
+		}
+
+		private void DeserializedMessage(object sender, EventArgs e)
+		{
+			throw new NotImplementedException();
+		}
+	}
+}

Pop3/trunk/Ntlx.Server/Formatters/IFormatter.cs

@@ -0,0 +1,16 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace Ntlx.Server.Formatters
+{
+	public interface IFormatter
+	{
+		void WriteMessage(byte[] buffer, int offset, int count);
+
+		event EventHandler DeserializedMessage;
+
+		byte[] SerializeMessage(object obj);
+	}
+}

Pop3/trunk/Ntlx.Server/Sessions/Session.cs

@@ -0,0 +1,21 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace Ntlx.Server.Sessions
+{
+	public class Session
+	{
+		public string Id
+		{
+			get;
+			private set;
+		}
+
+		public Session(string id)
+		{
+			Id = id;
+		}
+	}
+}

Pop3/trunk/Ntlx.Server/Sessions/SessionManager.cs

@@ -0,0 +1,24 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using Ntlx.Server.Collections.Generic;
+
+namespace Ntlx.Server.Sessions
+{
+	public class SessionManager
+	{
+		private IDictionary<string, Session> sessions = new ThreadSafeDictionary<string, Session>();
+
+
+		public void AddSession(Session session)
+		{
+
+		}
+
+		public void RemoveSession(string id)
+		{
+
+		}
+	}
+}

Pop3/trunk/Pop3Server/Pop3Server.csproj

@@ -48,6 +48,12 @@
     <Compile Include="Program.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
   </ItemGroup>
+  <ItemGroup>
+    <ProjectReference Include="..\Ntlx.Server\Ntlx.Server.csproj">
+      <Project>{670996D1-E75A-403F-A2BC-CCF0B3EEF1BC}</Project>
+      <Name>Ntlx.Server</Name>
+    </ProjectReference>
+  </ItemGroup>
   <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
   <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
        Other similar extension points exist, see Microsoft.Common.targets.

Pop3/trunk/Pop3Server/Program.cs

@@ -2,13 +2,15 @@
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
+using Ntlx.Server.Dispatcher;
 
 namespace Pop3Server
 {
 	class Program
 	{
 		static void Main(string[] args)
 		{
+
 		}
 	}
 }