wt/mongoose
1
0 Fork 0
mirror of https://github.com/cesanta/mongoose.git synced 2026-11-01 13:10:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add mg_dash_ev_handler

Browse Source
This commit is contained in:
cpq committed 2026-04-17 10:27:45 +01:00
1 parent 32da43a758
commit 18464b1c89
2 files changed
+52
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

mongoose.h
+26
View File
@@ -3158,6 +3158,12 @@ struct mg_field {
typedef void (*mg_dash_get_fn)(struct mg_field *);
typedef void (*mg_dash_set_fn)(struct mg_field *);
struct mg_dash {
struct mg_field *fields;
mg_dash_get_fn get;
mg_dash_set_fn set;
};
static inline struct mg_str trimq(struct mg_str s) { // Trim double quotes
if (s.len > 1 && s.buf[0] == '"') s.len -= 2, s.buf++;
return s;
@@ -3328,6 +3334,26 @@ static inline void mg_dash_process_msg(struct mg_connection *c,
mg_dash_error(c, req, "%s", "unknown method");
}
}
static inline void mg_dash_ev_handler(struct mg_connection *c, int ev,
void *ev_data) {
if (ev == MG_EV_HTTP_MSG) {
struct mg_http_message *hm = (struct mg_http_message *) ev_data;
if (mg_match(hm->uri, mg_str("/api/websocket"), NULL)) {
mg_ws_upgrade(c, hm, NULL);
} else {
struct mg_http_serve_opts opts = {0};
opts.fs = &mg_fs_packed;
mg_mem_files = mg_packed_files;
mg_http_serve_file(c, hm, "/dashboard.html", &opts);
}
} else if (ev == MG_EV_WS_MSG) {
// Add this to automatically handle "get" and "set" JSON-RPC calls
struct mg_dash *dash = (struct mg_dash *) c->fn_data;
struct mg_ws_message *wm = (struct mg_ws_message *) ev_data;
mg_dash_process_msg(c, wm, dash->fields, dash->get, dash->set);
}
}
// Copyright (c) 2023 Cesanta Software Limited
// All rights reserved
src/dash.h
+26
View File
@@ -20,6 +20,12 @@ struct mg_field {
typedef void (*mg_dash_get_fn)(struct mg_field *);
typedef void (*mg_dash_set_fn)(struct mg_field *);
struct mg_dash {
struct mg_field *fields;
mg_dash_get_fn get;
mg_dash_set_fn set;
};
static inline struct mg_str trimq(struct mg_str s) { // Trim double quotes
if (s.len > 1 && s.buf[0] == '"') s.len -= 2, s.buf++;
return s;
@@ -190,3 +196,23 @@ static inline void mg_dash_process_msg(struct mg_connection *c,
mg_dash_error(c, req, "%s", "unknown method");
}
}
static inline void mg_dash_ev_handler(struct mg_connection *c, int ev,
void *ev_data) {
if (ev == MG_EV_HTTP_MSG) {
struct mg_http_message *hm = (struct mg_http_message *) ev_data;
if (mg_match(hm->uri, mg_str("/api/websocket"), NULL)) {
mg_ws_upgrade(c, hm, NULL);
} else {
struct mg_http_serve_opts opts = {0};
opts.fs = &mg_fs_packed;
mg_mem_files = mg_packed_files;
mg_http_serve_file(c, hm, "/dashboard.html", &opts);
}
} else if (ev == MG_EV_WS_MSG) {
// Add this to automatically handle "get" and "set" JSON-RPC calls
struct mg_dash *dash = (struct mg_dash *) c->fn_data;
struct mg_ws_message *wm = (struct mg_ws_message *) ev_data;
mg_dash_process_msg(c, wm, dash->fields, dash->get, dash->set);
}
}