summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/observe_proto.cc66
-rw-r--r--src/observe_proto.h14
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__*/