28 #include "xutil.h" |
28 #include "xutil.h" |
29 #include "websocket.h" |
29 #include "websocket.h" |
30 #include "fermenters.h" |
30 #include "fermenters.h" |
31 #include "co2meters.h" |
31 #include "co2meters.h" |
32 #include "ispindels.h" |
32 #include "ispindels.h" |
|
33 #include "nodes.h" |
33 #include <libwebsockets.h> |
34 #include <libwebsockets.h> |
34 |
35 |
35 |
36 |
36 extern sys_config Config; |
37 extern sys_config Config; |
37 extern int debug; |
38 extern int debug; |
124 fermenter_ws_receive(buf); |
125 fermenter_ws_receive(buf); |
125 } else if (strncmp(buf, (char *)"{\"device\":\"co2meters\",", 22) == 0) { |
126 } else if (strncmp(buf, (char *)"{\"device\":\"co2meters\",", 22) == 0) { |
126 co2meter_ws_receive(buf); |
127 co2meter_ws_receive(buf); |
127 } else if (strncmp(buf, (char *)"{\"device\":\"ispindels\",", 22) == 0) { |
128 } else if (strncmp(buf, (char *)"{\"device\":\"ispindels\",", 22) == 0) { |
128 ispindel_ws_receive(buf); |
129 ispindel_ws_receive(buf); |
|
130 } else if (strncmp(buf, (char *)"{\"node\":\"", 9) == 0) { |
|
131 node_ws_receive(buf); |
129 } |
132 } |
130 |
133 |
131 break; |
134 break; |
132 |
135 |
133 case LWS_CALLBACK_CLOSED: |
136 case LWS_CALLBACK_CLOSED: |