protocol:

	a bit of work with "client_event_subscription_request"
	some comments
server:
	event subsystem:
		event's object class skeleton
		very basic event subscription handler

4 files changed, 130 insertions, 3 deletions

diff --git a/server/src/client.cpp b/server/src/client.cpp
index 858b230..0990317 100644
--- a/server/src/client.cpp
+++ b/server/src/client.cpp
@@ -1,10 +1,35 @@
+/*
+	Copyright © 2015 Gluzskiy Alexandr (sss)
+
+    This file is part of Unknown Download Manager (UDM).
+
+    UDM is free software: you can redistribute it and/or modify
+    it under the terms of the GNU General Public License as published by
+    the Free Software Foundation, either version 2 of the License, or
+    (at your option) any later version.
+
+    UDM is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU General Public License for more details.
+
+    You should have received a copy of the GNU General Public License
+    along with UDM.  If not, see <http://www.gnu.org/licenses/>.
+
+*/
+
 #include "client.h"
+#include "server_session.h"
 
-client::client(std::string &client_auth_token) : auth_token(client_auth_token)
+client::client(std::string &client_auth_token, server_session *sess) : auth_token(client_auth_token), session(sess)
 {
 	//ctor
 }
 
+void client::add_event_subscription(event_subscription_base* e)
+{
+}
+
 client::~client()
 {
 	//dtor
diff --git a/server/src/event_subscription_event.cpp b/server/src/event_subscription_event.cpp
new file mode 100644
index 0000000..10ca824
--- /dev/null
+++ b/server/src/event_subscription_event.cpp
@@ -0,0 +1,32 @@
+/*
+	Copyright © 2015 Gluzskiy Alexandr (sss)
+
+    This file is part of Unknown Download Manager (UDM).
+
+    UDM is free software: you can redistribute it and/or modify
+    it under the terms of the GNU General Public License as published by
+    the Free Software Foundation, either version 2 of the License, or
+    (at your option) any later version.
+
+    UDM is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU General Public License for more details.
+
+    You should have received a copy of the GNU General Public License
+    along with UDM.  If not, see <http://www.gnu.org/licenses/>.
+
+*/
+
+
+#include "event_subscription_event.h"
+
+event_subscription_event::event_subscription_event(client_event_subscription_request *req)
+{
+	subtype = EVENT_SUBTYPE_EVENT;
+}
+
+event_subscription_event::~event_subscription_event()
+{
+}
+
diff --git a/server/src/event_subscription_repeated.cpp b/server/src/event_subscription_repeated.cpp
new file mode 100644
index 0000000..13e0165
--- /dev/null
+++ b/server/src/event_subscription_repeated.cpp
@@ -0,0 +1,32 @@
+/*
+        Copyright © 2015 Gluzskiy Alexandr (sss)
+
+    This file is part of Unknown Download Manager (UDM).
+
+    UDM is free software: you can redistribute it and/or modify
+    it under the terms of the GNU General Public License as published by
+    the Free Software Foundation, either version 2 of the License, or
+    (at your option) any later version.
+
+    UDM is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU General Public License for more details.
+
+    You should have received a copy of the GNU General Public License
+    along with UDM.  If not, see <http://www.gnu.org/licenses/>.
+
+*/
+
+
+#include "event_subscription_repeated.h"
+
+event_subscription_repeated::event_subscription_repeated(client_event_subscription_request *req)
+{
+	subtype = EVENT_SUBTYPE_REPEATED;
+}
+
+event_subscription_repeated::~event_subscription_repeated()
+{
+}
+
diff --git a/server/src/server_session.cpp b/server/src/server_session.cpp
index 43d8837..113a756 100644
--- a/server/src/server_session.cpp
+++ b/server/src/server_session.cpp
@@ -27,6 +27,8 @@
 #include "socket_wraper.h"
 #include "client.h"
 #include "modules_handler.h"
+#include "event_subscription_event.h"
+#include "event_subscription_repeated.h"
 
 extern std::map<std::string, client> clients;
 extern modules_handler *modules;
@@ -280,7 +282,6 @@ bool server_session::handle_command(client_msg *msg)
 	{
 		server_msg m;
 		m.set_type(SERVER_MSG_TYPE::SERVER_AUTH_REPLY);
-		//TODO: check for already existing auth token
 		std::string server_password = runtime_config.config_file.get<std::string>("server.password", "");
 		if(server_password.empty())
 			m.mutable_auth_reply()->set_status(true);
@@ -470,6 +471,7 @@ bool server_session::handle_command(client_msg *msg)
 				d->set_module_name(msg->download_add_request().module_name());
 				d->set_downloaded(dl.downloaded);
 				send_message(&m);
+				//TODO: fire event
 				break;
 			}
 		}
@@ -488,6 +490,10 @@ bool server_session::handle_command(client_msg *msg)
 					{
 						//TODO: handle error
 					}
+					else
+					{
+						//TODO: fire event
+					}
 					break;
 				}
 			}
@@ -507,6 +513,10 @@ bool server_session::handle_command(client_msg *msg)
 					{
 						//TODO: handle error
 					}
+					else
+					{
+						//TODO: fire event
+					}
 					break;
 				}
 			}
@@ -522,16 +532,44 @@ bool server_session::handle_command(client_msg *msg)
 				if(m->get_module_info().name == downloads[i.download_id()].module_name)
 				{
 					auto dm = static_cast<module_downloader *>(m);
-					if(!dm->delete_download(i.download_id(), i.with_data()));
+					if(!dm->delete_download(i.download_id(), i.with_data()))
 					{
 						//TODO: handle error
 					}
+					else
+					{
+						//TODO: fire event
+					}
 					break;
 				}
 			}
 		}
 	}
 	break;
+	case CLIENT_MSG_TYPE::CLIENT_SUBSCRIPTION_REQUEST:
+	{
+		for(auto i : msg->subscription_request())
+		{
+			switch(i.mode())
+			{
+				case SUBSCRIPTION_MODE::S_MODE_EVENT:
+				{
+					event_subscription_event *e = new event_subscription_event(&i);
+					client_->add_event_subscription(e);
+				}
+				break;
+				case SUBSCRIPTION_MODE::S_MODE_REPEATED:
+				{
+					event_subscription_repeated *e = new event_subscription_repeated(&i);
+					client_->add_event_subscription(e);
+				}
+				break;
+				default:
+				break;
+			}
+		}
+	}
+	break;
 	default:
 		return false;
 		break;