--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/src/server/daemon/websocket.h Mon Dec 26 14:00:10 2016 +0100
@@ -0,0 +1,115 @@
+/*
+ * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
+ *
+ * Copyright 2016 Olaf Wintermann. All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * 1. Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ *
+ * 2. Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+ * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
+ * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
+ * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
+ * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
+ * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
+ * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
+ * POSSIBILITY OF SUCH DAMAGE.
+ */
+
+#ifndef WEBSOCKET_H
+#define WEBSOCKET_H
+
+#include "../public/nsapi.h"
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+#define WS_FRAMEHEADER_BUFLEN 16
+
+typedef struct WSParser WSParser;
+typedef struct WSFrame WSFrame;
+
+// WSMessage is defined in nsapi.h
+
+struct WSFrame {
+ uint8_t header_complete;
+ uint8_t fin;
+ uint8_t mask;
+ uint8_t opcode;
+ uint32_t masking_key;
+ uint64_t payload_length;
+};
+
+struct WSParser {
+ // input buffer size
+ const char *inbuf;
+ // inbuf data length
+ size_t length;
+ // current buffer position
+ size_t pos;
+
+ // current message or NULL
+ WSMessage *current;
+ // parser state: 0: parse frame, 1: get payload data
+ int state;
+ // current payload length
+ size_t cur_plen;
+ // current message frame
+ WSFrame frame;
+
+ // tmp buffer for incomplete frame header
+ char tmpbuf[WS_FRAMEHEADER_BUFLEN];
+ // length of tmpbuf
+ size_t tmplen;
+
+ pool_handle_t *pool;
+};
+
+/*
+ * creates a new websocket parser
+ */
+WSParser* websocket_parser(Session *sn);
+
+/*
+ * puts input data into the websocket parser
+ * you can use websocket_get_message() after that
+ */
+void websocket_input(WSParser *parser, const char *data, size_t length);
+
+/*
+ * tries to read a complete websocket message
+ * returns a pointer to an allocated WSMessage or NULL
+ * sets error to 1 if an error occurs, otherwise to 0
+ */
+WSMessage* websocket_get_message(WSParser *parser, int *error);
+
+/*
+ * reads a websocket frame util begin of the payload data
+ * returns position of payload data or 0 if the frame header is incomplete
+ */
+ssize_t websocket_get_frameheader(WSFrame *frame, const char *buf, size_t len);
+
+/*
+ * masks or unmasks data
+ * this is done by a simple xor with each element in buf and mask
+ */
+void websocket_mask_data(char *buf, size_t len, uint32_t mask);
+
+
+#ifdef __cplusplus
+}
+#endif
+
+#endif /* WEBSOCKET_H */
+