Alex Perry | 5f474f2 | 2020-02-01 12:14:24 -0800 | [diff] [blame] | 1 | #include "aos/events/shm_event_loop.h" |
Alex Perry | 09648e0 | 2020-02-28 19:50:29 -0800 | [diff] [blame] | 2 | #include "aos/flatbuffer_merge.h" |
Alex Perry | b3b5079 | 2020-01-18 16:13:45 -0800 | [diff] [blame] | 3 | #include "aos/init.h" |
Alex Perry | b3b5079 | 2020-01-18 16:13:45 -0800 | [diff] [blame] | 4 | #include "aos/network/web_proxy.h" |
Alex Perry | 5f474f2 | 2020-02-01 12:14:24 -0800 | [diff] [blame] | 5 | #include "aos/seasocks/seasocks_logger.h" |
| 6 | #include "gflags/gflags.h" |
Alex Perry | b3b5079 | 2020-01-18 16:13:45 -0800 | [diff] [blame] | 7 | |
| 8 | #include "internal/Embedded.h" |
| 9 | #include "seasocks/Server.h" |
| 10 | #include "seasocks/WebSocket.h" |
| 11 | |
Alex Perry | 5f474f2 | 2020-02-01 12:14:24 -0800 | [diff] [blame] | 12 | DEFINE_string(config, "./config.json", "File path of aos configuration"); |
| 13 | DEFINE_string(data_dir, "www", "Directory to serve data files from"); |
| 14 | |
Alex Perry | 5f474f2 | 2020-02-01 12:14:24 -0800 | [diff] [blame] | 15 | int main(int argc, char **argv) { |
Alex Perry | 5f474f2 | 2020-02-01 12:14:24 -0800 | [diff] [blame] | 16 | aos::InitGoogle(&argc, &argv); |
James Kuszmaul | 7ad9152 | 2020-09-01 19:15:35 -0700 | [diff] [blame^] | 17 | // Make sure to reference this to force the linker to include it. |
Alex Perry | b3b5079 | 2020-01-18 16:13:45 -0800 | [diff] [blame] | 18 | findEmbeddedContent(""); |
| 19 | |
| 20 | aos::InitNRT(); |
| 21 | |
Alex Perry | 5f474f2 | 2020-02-01 12:14:24 -0800 | [diff] [blame] | 22 | aos::FlatbufferDetachedBuffer<aos::Configuration> config = |
| 23 | aos::configuration::ReadConfig(FLAGS_config); |
Alex Perry | b3b5079 | 2020-01-18 16:13:45 -0800 | [diff] [blame] | 24 | |
James Kuszmaul | 7ad9152 | 2020-09-01 19:15:35 -0700 | [diff] [blame^] | 25 | aos::ShmEventLoop event_loop(&config.message()); |
Alex Perry | 5f474f2 | 2020-02-01 12:14:24 -0800 | [diff] [blame] | 26 | |
| 27 | seasocks::Server server(std::shared_ptr<seasocks::Logger>( |
| 28 | new aos::seasocks::SeasocksLogger(seasocks::Logger::Level::Info))); |
| 29 | |
James Kuszmaul | 7ad9152 | 2020-09-01 19:15:35 -0700 | [diff] [blame^] | 30 | auto websocket_handler = |
| 31 | std::make_shared<aos::web_proxy::WebsocketHandler>(&server, &event_loop); |
Alex Perry | b3b5079 | 2020-01-18 16:13:45 -0800 | [diff] [blame] | 32 | server.addWebSocketHandler("/ws", websocket_handler); |
| 33 | |
James Kuszmaul | 7ad9152 | 2020-09-01 19:15:35 -0700 | [diff] [blame^] | 34 | std::thread data_thread{[&event_loop]() { event_loop.Run(); }}; |
| 35 | |
Alex Perry | 5f474f2 | 2020-02-01 12:14:24 -0800 | [diff] [blame] | 36 | server.serve(FLAGS_data_dir.c_str(), 8080); |
Alex Perry | b3b5079 | 2020-01-18 16:13:45 -0800 | [diff] [blame] | 37 | } |