2 files changed, 67 insertions, 13 deletions
diff --git a/src/observe_proto.cc b/src/observe_proto.cc
index 8ea6104..a572d1e 100644
--- a/src/observe_proto.cc
+++ b/src/observe_proto.cc
@@ -27,20 +27,60 @@
  */
 #include "observe_proto.h"
 
-#ifdef TEST_OBSERVE_PROTO
-//Additional dependency files
-//deps:
-//Required cflags (autoconf vars may be used)
-//cflags:
-//Required link options (autoconf vars may be used)
-//libs:
-#include "test.h"
+#include <stdio.h>
+#include <string.h>
 
-TEST_BEGIN;
+#include <queue>
+#include <map>
 
-// TODO: Put some testcode here (see test.h for usable macros).
-TEST_TRUE(false, "No tests yet!");
+#include "task.h"
+#include "msgparser.h"
+#include "xmlparser.h"
 
-TEST_END;
+#include "connectionhandler.h"
 
-#endif/*TEST_OBSERVE_PROTO*/
+int callback_lws_observe(struct libwebsocket_context *context,
+                         struct libwebsocket *wsi,
+                         enum libwebsocket_callback_reasons reason,
+                         void *user, void *in, size_t len)
+{
+  switch (reason) {
+  case LWS_CALLBACK_ESTABLISHED:
+    connection_handler.init(wsi);
+    break;
+
+  case LWS_CALLBACK_CLOSED:
+    connection_handler.close(wsi);
+    break;
+
+  case LWS_CALLBACK_RECEIVE:
+    {
+      std::string data;
+      data.append((char*)in, len);
+
+      MessageList mlst = parse_msg(data);
+      for(MessageList::iterator i = mlst.begin(); i != mlst.end(); i++) {
+        message_t m = *i;
+        switch(m.cmd) {
+        case cmd::observe: {
+          connection_handler.observe(wsi, m.observe.id);
+          break;
+        }
+        case cmd::unobserve: {
+          connection_handler.unobserve(wsi, m.observe.id);
+          break;
+        }
+        default:
+          printf("Wrong command :(\n");
+          break;
+        }
+      }
+    }
+    break;
+
+  default:
+    break;
+  }
+
+  return 0;
+}
diff --git a/src/observe_proto.h b/src/observe_proto.h
index fea9ebd..6ef1e66 100644
--- a/src/observe_proto.h
+++ b/src/observe_proto.h
@@ -27,4 +27,18 @@
  */
 #ifndef __MUNIA_OBSERVE_PROTO_H__
 #define __MUNIA_OBSERVE_PROTO_H__
+
+#include <stdlib.h>
+
+#include <libwebsockets.h>
+
+int callback_lws_observe(struct libwebsocket_context *context,
+                         struct libwebsocket *wsi,
+                         enum libwebsocket_callback_reasons reason,
+                         void *user, void *in, size_t len);
+
+struct per_session_data__lws_observe {
+	struct libwebsocket *wsi;
+};
+
 #endif/*__MUNIA_OBSERVE_PROTO_H__*/