73 |
73 |
74 case LWS_CALLBACK_ESTABLISHED: { |
74 case LWS_CALLBACK_ESTABLISHED: { |
75 ws_clients++; |
75 ws_clients++; |
76 pss->ringbuffer_tail = ringbuffer_head; |
76 pss->ringbuffer_tail = ringbuffer_head; |
77 pss->wsi = wsi; |
77 pss->wsi = wsi; |
|
78 syslog(LOG_NOTICE, "Websocket: new client, now %d", ws_clients); |
78 break; |
79 break; |
79 } |
80 } |
80 |
81 |
81 case LWS_CALLBACK_PROTOCOL_DESTROY: |
82 case LWS_CALLBACK_PROTOCOL_DESTROY: |
82 syslog(LOG_NOTICE, "Websocket: protocol cleaning up"); |
83 syslog(LOG_NOTICE, "Websocket: protocol cleaning up"); |
113 |
114 |
114 case LWS_CALLBACK_RECEIVE: |
115 case LWS_CALLBACK_RECEIVE: |
115 |
116 |
116 memcpy(buf, in, len); |
117 memcpy(buf, in, len); |
117 buf[len] = '\0'; |
118 buf[len] = '\0'; |
118 // syslog(LOG_NOTICE, "ws: reveived %ld bytes %s", len, buf); |
119 syslog(LOG_NOTICE, "ws: reveived %ld bytes %s", len, buf); |
119 /* |
120 /* |
120 * These are send by bmsapp to bmsd. Then bmsd resends these via MQTT. |
121 * These are send by bmsapp to bmsd. Then bmsd resends these via MQTT. |
121 * Do we want to change that? Or use it for the new web pages. |
122 * Do we want to change that? Or use it for the new web pages. |
122 * {"node":"rpi01","group_id":"fermenters","control":"reboot"} |
123 * {"node":"rpi01","group_id":"fermenters","control":"reboot"} |
123 * {"node":"rpi01","group_id":"fermenters","control":"rebirth"} |
124 * {"node":"rpi01","group_id":"fermenters","control":"rebirth"} |