Add seasocks to aos externals for http_status and add test server.
This is stage 1 of the http_status project!
Seasocks requires a rather elaborate method of compiling the code
and including the web pages into the compiled executable as raw data,
so some of the stuff in the gyp system may not be pretty. We will fix
these problems up in later revisions as needed.
The web directory holds the rudimentary files for the web server (404
message, javascript library that we will use in later stages of
designing th web page interface, and icons. web_test holds the files for
the test webpage that can be accessed at localhost:8080 when the server
is running. Again, this directory, along with the content of
http_status.cc, is temporary and intended only to show the functionality
of the server socket.
Change-Id: I2ad1598ae200b526620b014db970e980f3c8a563
diff --git a/frc971/http_status/http_status.cc b/frc971/http_status/http_status.cc
new file mode 100644
index 0000000..9a6440a
--- /dev/null
+++ b/frc971/http_status/http_status.cc
@@ -0,0 +1,114 @@
+// Copyright (c) 2013, Matt Godbolt
+// All rights reserved.
+//
+// Redistribution and use in source and binary forms, with or without
+// modification, are permitted provided that the following conditions are met:
+//
+// Redistributions of source code must retain the above copyright notice, this
+// list of conditions and the following disclaimer.
+//
+// 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.
+
+// An extraordinarily simple test which presents a web page with some buttons.
+// Clicking on the numbered button increments the number, which is visible to
+// other connected clients. WebSockets are used to do this: by the rather
+// suspicious means of sending raw JavaScript commands to be executed on other
+// clients.
+
+#include "seasocks/PrintfLogger.h"
+#include "seasocks/Server.h"
+#include "seasocks/StringUtil.h"
+#include "seasocks/WebSocket.h"
+#include "seasocks/util/Json.h"
+
+#include <cstring>
+#include <iostream>
+#include <memory>
+#include <set>
+#include <sstream>
+#include <string>
+
+#include "embedded.h"
+
+using namespace seasocks;
+using namespace std;
+
+class MyHandler: public WebSocket::Handler {
+public:
+ MyHandler(Server* server) : _server(server), _currentValue(0) {
+ setValue(1);
+ }
+
+ virtual void onConnect(WebSocket* connection) {
+ _connections.insert(connection);
+ connection->send(_currentSetValue.c_str());
+ cout << "Connected: " << connection->getRequestUri()
+ << " : " << formatAddress(connection->getRemoteAddress())
+ << endl;
+ cout << "Credentials: " << *(connection->credentials()) << endl;
+ }
+
+ virtual void onData(WebSocket* connection, const char* data) {
+ if (0 == strcmp("die", data)) {
+ _server->terminate();
+ return;
+ }
+ if (0 == strcmp("close", data)) {
+ cout << "Closing.." << endl;
+ connection->close();
+ cout << "Closed." << endl;
+ return;
+ }
+
+ int value = atoi(data) + 1;
+ if (value > _currentValue) {
+ setValue(value);
+ for (auto connection : _connections) {
+ connection->send(_currentSetValue.c_str());
+ }
+ }
+ }
+
+ virtual void onDisconnect(WebSocket* connection) {
+ _connections.erase(connection);
+ cout << "Disconnected: " << connection->getRequestUri()
+ << " : " << formatAddress(connection->getRemoteAddress())
+ << endl;
+ }
+
+private:
+ set<WebSocket*> _connections;
+ Server* _server;
+ int _currentValue;
+ string _currentSetValue;
+
+ void setValue(int value) {
+ _currentValue = value;
+ _currentSetValue = makeExecString("set", _currentValue);
+ }
+};
+
+int main(int argc, const char* argv[]) {
+ shared_ptr<Logger> logger(new PrintfLogger(Logger::DEBUG));
+
+ Server server(logger);
+
+ shared_ptr<MyHandler> handler(new MyHandler(&server));
+ server.addWebSocketHandler("/ws", handler);
+ server.serve("web_test", 8080);
+ return 0;
+}