From 425a0efeca5da563f981bc8dd271bf7f9421fb5d Mon Sep 17 00:00:00 2001 From: Scott Shawcroft Date: Mon, 11 Jul 2022 14:53:20 -0700 Subject: [PATCH] A bit more cleanup --- shared-bindings/hashlib/Hash.c | 7 ------- .../shared/web_workflow/static/serial.js | 2 -- supervisor/shared/web_workflow/web_workflow.c | 21 ++++++++----------- 3 files changed, 9 insertions(+), 21 deletions(-) diff --git a/shared-bindings/hashlib/Hash.c b/shared-bindings/hashlib/Hash.c index 5dab05fa10..e27b71ef78 100644 --- a/shared-bindings/hashlib/Hash.c +++ b/shared-bindings/hashlib/Hash.c @@ -26,13 +26,6 @@ #include "shared-bindings/hashlib/Hash.h" -// #include "shared-bindings/util.h" - -// #include "shared/runtime/buffer_helper.h" -// #include "shared/runtime/interrupt_char.h" - -// #include "py/mperrno.h" -// #include "py/mphal.h" #include "py/obj.h" #include "py/objproperty.h" #include "py/objstr.h" diff --git a/supervisor/shared/web_workflow/static/serial.js b/supervisor/shared/web_workflow/static/serial.js index 595bbe6653..6ecc2b1659 100644 --- a/supervisor/shared/web_workflow/static/serial.js +++ b/supervisor/shared/web_workflow/static/serial.js @@ -21,7 +21,6 @@ function onSubmit() { input.focus(); } -// Connect to Web Socket ws = new WebSocket("ws://" + window.location.host + "/cp/serial/"); ws.onopen = function() { @@ -32,7 +31,6 @@ var setting_title = false; var encoder = new TextEncoder(); var left_count = 0; ws.onmessage = function(e) { - // e.data contains received string. if (e.data == "\x1b]0;") { setting_title = true; title.textContent = ""; diff --git a/supervisor/shared/web_workflow/web_workflow.c b/supervisor/shared/web_workflow/web_workflow.c index 3f9920d1c7..6cf765b8f9 100644 --- a/supervisor/shared/web_workflow/web_workflow.c +++ b/supervisor/shared/web_workflow/web_workflow.c @@ -522,10 +522,16 @@ static void _reply_redirect(socketpool_socket_obj_t *socket, _request *request, "HTTP/1.1 301 Moved Permanently\r\n", "Connection: close\r\n", "Content-Length: 0\r\n", - "Location: http://", hostname, ".local", path, "\r\n", NULL); + "Location: ", NULL); + if (request->websocket) { + _send_str(socket, "ws"); + } else { + _send_str(socket, "http"); + } + + _send_strs(socket, "://", hostname, ".local", path, "\r\n", NULL); _cors_header(socket, request); _send_str(socket, "\r\n"); - ESP_LOGI(TAG, "redirect"); } static void _reply_directory_json(socketpool_socket_obj_t *socket, _request *request, FF_DIR *dir, const char *request_path, const char *path) { @@ -853,10 +859,7 @@ static void _reply_static(socketpool_socket_obj_t *socket, _request *request, co #define _REPLY_STATIC(socket, request, filename) _reply_static(socket, request, filename, filename##_length, filename##_content_type) - - static void _reply_websocket_upgrade(socketpool_socket_obj_t *socket, _request *request) { - ESP_LOGI(TAG, "websocket!"); // Compute accept key hashlib_hash_obj_t hash; common_hal_hashlib_new(&hash, "sha1"); @@ -876,8 +879,6 @@ static void _reply_websocket_upgrade(socketpool_socket_obj_t *socket, _request * "Sec-WebSocket-Accept: ", encoded_accept, "\r\n", "\r\n", NULL); websocket_handoff(socket); - - ESP_LOGI(TAG, "socket upgrade done"); // socket is now closed and "disconnected". } @@ -885,7 +886,7 @@ static bool _reply(socketpool_socket_obj_t *socket, _request *request) { if (request->redirect) { _reply_redirect(socket, request, request->path); } else if (strlen(request->origin) > 0 && !_origin_ok(request->origin)) { - ESP_LOGI(TAG, "bad origin %s", request->origin); + ESP_LOGE(TAG, "bad origin %s", request->origin); _reply_forbidden(socket, request); } else if (memcmp(request->path, "/fs/", 4) == 0) { if (!request->authenticated) { @@ -1199,7 +1200,6 @@ static void _process_request(socketpool_socket_obj_t *socket, _request *request) return; } bool reload = _reply(socket, request); - ESP_LOGI(TAG, "reply done"); _reset_request(request); autoreload_resume(AUTORELOAD_SUSPEND_WEB); if (reload) { @@ -1217,12 +1217,10 @@ void supervisor_web_workflow_background(void) { uint32_t port; int newsoc = socketpool_socket_accept(&listening, (uint8_t *)&ip, &port); if (newsoc == -EBADF) { - ESP_LOGI(TAG, "listen closed"); common_hal_socketpool_socket_close(&listening); return; } if (newsoc > 0) { - ESP_LOGI(TAG, "new socket %d", newsoc); // Close the active socket because we have another we accepted. if (!common_hal_socketpool_socket_get_closed(&active)) { common_hal_socketpool_socket_close(&active); @@ -1243,7 +1241,6 @@ void supervisor_web_workflow_background(void) { // If we have a request in progress, continue working on it. if (common_hal_socketpool_socket_get_connected(&active)) { - // ESP_LOGI(TAG, "active connected %d", active_request.in_progress); _process_request(&active, &active_request); } }