|
|
@ -8,7 +8,6 @@ |
|
|
|
#include "ansi_parser.h" |
|
|
|
#include "ansi_parser.h" |
|
|
|
#include "jstring.h" |
|
|
|
#include "jstring.h" |
|
|
|
#include "uart_driver.h" |
|
|
|
#include "uart_driver.h" |
|
|
|
#include "cgi_logging.h" |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Heartbeat interval in ms
|
|
|
|
// Heartbeat interval in ms
|
|
|
|
#define HB_TIME 1000 |
|
|
|
#define HB_TIME 1000 |
|
|
@ -17,9 +16,12 @@ |
|
|
|
// Must be less than httpd sendbuf
|
|
|
|
// Must be less than httpd sendbuf
|
|
|
|
#define SOCK_BUF_LEN 2000 |
|
|
|
#define SOCK_BUF_LEN 2000 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// flags for screen update timeouts
|
|
|
|
volatile bool notify_available = true; |
|
|
|
volatile bool notify_available = true; |
|
|
|
volatile bool notify_cooldown = false; |
|
|
|
volatile bool notify_cooldown = false; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/** True if we sent XOFF to browser to stop uploading,
|
|
|
|
|
|
|
|
* and we have to tell it we're ready again */ |
|
|
|
volatile bool browser_wants_xon = false; |
|
|
|
volatile bool browser_wants_xon = false; |
|
|
|
|
|
|
|
|
|
|
|
static ETSTimer notifyContentTim; |
|
|
|
static ETSTimer notifyContentTim; |
|
|
@ -27,6 +29,8 @@ static ETSTimer notifyLabelsTim; |
|
|
|
static ETSTimer notifyCooldownTim; |
|
|
|
static ETSTimer notifyCooldownTim; |
|
|
|
static ETSTimer heartbeatTim; |
|
|
|
static ETSTimer heartbeatTim; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
volatile int active_clients = 0; |
|
|
|
|
|
|
|
|
|
|
|
// we're trying to do a kind of mutex here, without the actual primitives
|
|
|
|
// we're trying to do a kind of mutex here, without the actual primitives
|
|
|
|
// this might glitch, very rarely.
|
|
|
|
// this might glitch, very rarely.
|
|
|
|
// it's recommended to put some delay between setting labels and updating the screen.
|
|
|
|
// it's recommended to put some delay between setting labels and updating the screen.
|
|
|
@ -115,6 +119,8 @@ notifyLabelsTimCb(void *arg) |
|
|
|
void ICACHE_FLASH_ATTR |
|
|
|
void ICACHE_FLASH_ATTR |
|
|
|
send_beep(void) |
|
|
|
send_beep(void) |
|
|
|
{ |
|
|
|
{ |
|
|
|
|
|
|
|
if (active_clients == 0) return; |
|
|
|
|
|
|
|
|
|
|
|
// here's some potential for a race error with the other broadcast functions :C
|
|
|
|
// here's some potential for a race error with the other broadcast functions :C
|
|
|
|
cgiWebsockBroadcast(URL_WS_UPDATE, "B", 1, 0); |
|
|
|
cgiWebsockBroadcast(URL_WS_UPDATE, "B", 1, 0); |
|
|
|
} |
|
|
|
} |
|
|
@ -124,6 +130,8 @@ send_beep(void) |
|
|
|
void ICACHE_FLASH_ATTR |
|
|
|
void ICACHE_FLASH_ATTR |
|
|
|
notify_growl(char *msg) |
|
|
|
notify_growl(char *msg) |
|
|
|
{ |
|
|
|
{ |
|
|
|
|
|
|
|
if (active_clients == 0) return; |
|
|
|
|
|
|
|
|
|
|
|
// TODO via timer...
|
|
|
|
// TODO via timer...
|
|
|
|
// here's some potential for a race error with the other broadcast functions :C
|
|
|
|
// here's some potential for a race error with the other broadcast functions :C
|
|
|
|
cgiWebsockBroadcast(URL_WS_UPDATE, msg, (int) strlen(msg), 0); |
|
|
|
cgiWebsockBroadcast(URL_WS_UPDATE, msg, (int) strlen(msg), 0); |
|
|
@ -137,8 +145,9 @@ notify_growl(char *msg) |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
void ICACHE_FLASH_ATTR screen_notifyChange(ScreenNotifyChangeTopic topic) |
|
|
|
void ICACHE_FLASH_ATTR screen_notifyChange(ScreenNotifyChangeTopic topic) |
|
|
|
{ |
|
|
|
{ |
|
|
|
// this is not the most ideal/cleanest implementation
|
|
|
|
if (active_clients == 0) return; |
|
|
|
// PRs are welcome for a nicer update "queue" solution
|
|
|
|
|
|
|
|
|
|
|
|
// this is probably not needed here - ensure timeout is not 0
|
|
|
|
if (termconf->display_tout_ms == 0) termconf->display_tout_ms = SCR_DEF_DISPLAY_TOUT_MS; |
|
|
|
if (termconf->display_tout_ms == 0) termconf->display_tout_ms = SCR_DEF_DISPLAY_TOUT_MS; |
|
|
|
|
|
|
|
|
|
|
|
// NOTE: the timers are restarted if already running
|
|
|
|
// NOTE: the timers are restarted if already running
|
|
|
@ -297,22 +306,46 @@ void ICACHE_FLASH_ATTR updateSockRx(Websock *ws, char *data, int len, int flags) |
|
|
|
/** Send a heartbeat msg */ |
|
|
|
/** Send a heartbeat msg */ |
|
|
|
void ICACHE_FLASH_ATTR heartbeatTimCb(void *unused) |
|
|
|
void ICACHE_FLASH_ATTR heartbeatTimCb(void *unused) |
|
|
|
{ |
|
|
|
{ |
|
|
|
if (notify_available) { |
|
|
|
if (notify_available && active_clients > 0) { |
|
|
|
// Heartbeat packet - indicate we're still connected
|
|
|
|
// Heartbeat packet - indicate we're still connected
|
|
|
|
// JS reloads the page if heartbeat is lost for a couple seconds
|
|
|
|
// JS reloads the page if heartbeat is lost for a couple seconds
|
|
|
|
cgiWebsockBroadcast(URL_WS_UPDATE, ".", 1, 0); |
|
|
|
cgiWebsockBroadcast(URL_WS_UPDATE, ".", 1, 0); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
void ICACHE_FLASH_ATTR closeSockCb(Websock *ws) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
active_clients--; |
|
|
|
|
|
|
|
if (active_clients <= 0) { |
|
|
|
|
|
|
|
active_clients = 0; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (mouse_tracking.focus_tracking) { |
|
|
|
|
|
|
|
UART_SendAsync("\x1b[O", 3); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// stop the timer
|
|
|
|
|
|
|
|
os_timer_disarm(&heartbeatTim); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/** Socket connected for updates */ |
|
|
|
/** Socket connected for updates */ |
|
|
|
void ICACHE_FLASH_ATTR updateSockConnect(Websock *ws) |
|
|
|
void ICACHE_FLASH_ATTR updateSockConnect(Websock *ws) |
|
|
|
{ |
|
|
|
{ |
|
|
|
inp_info("Socket connected to "URL_WS_UPDATE); |
|
|
|
inp_info("Socket connected to "URL_WS_UPDATE); |
|
|
|
ws->recvCb = updateSockRx; |
|
|
|
ws->recvCb = updateSockRx; |
|
|
|
|
|
|
|
ws->closeCb = closeSockCb; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (active_clients == 0) { |
|
|
|
|
|
|
|
if (mouse_tracking.focus_tracking) { |
|
|
|
|
|
|
|
UART_SendAsync("\x1b[I", 3); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
TIMER_START(&heartbeatTim, heartbeatTimCb, HB_TIME, 1); |
|
|
|
TIMER_START(&heartbeatTim, heartbeatTimCb, HB_TIME, 1); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
active_clients++; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
ETSTimer xonTim; |
|
|
|
ETSTimer xonTim; |
|
|
|
|
|
|
|
|
|
|
|
void ICACHE_FLASH_ATTR notify_empty_txbuf_cb(void *unused) |
|
|
|
void ICACHE_FLASH_ATTR notify_empty_txbuf_cb(void *unused) |
|
|
|