mirror of
https://github.com/cesanta/mongoose.git
synced 2026-10-01 05:52:32 +07:00
112 lines
3.6 KiB
C
112 lines
3.6 KiB
C
// Copyright (c) 2022-2026 Cesanta Software Limited
|
|
// All rights reserved
|
|
//
|
|
// This example runs MDNS server, auto-discoverable as MDNS_NAME
|
|
// Also it runs as web server
|
|
|
|
#include "mongoose.h"
|
|
|
|
#define MDNS_NAME "mongoose-device"
|
|
#define WEB_SERVER_ADDR "http://0.0.0.0:8000"
|
|
|
|
//static struct mg_connection *s_mdns_conn;
|
|
//static struct mg_connection *s_http_conn;
|
|
|
|
#if 0
|
|
// A TXT record data containing JSON, if actually needed.
|
|
// The whole record must not exceed 256 bytes, so keep this small
|
|
char txt[] = "\x15{\"property\": \"value\"}";
|
|
// string length followed by string data, data length = 21 + 1 = 22 bytes
|
|
|
|
// DNS-SD service records
|
|
static const struct mg_dnssd_record s_records[] = {
|
|
{{"_myservice._tcp", 15}, {"", 0}, 9876},
|
|
{{"_myservice._udp", 15}, {txt, 22}, 9876}};
|
|
|
|
#if 0
|
|
// DNS-SD service records database
|
|
struct dnssd_db {
|
|
struct mg_dnssd_record *srvcs; // service record data
|
|
uint8_t num; // number of records in db
|
|
} db_ = {
|
|
(struct mg_dnssd_record *) srvcs,
|
|
sizeof(srvcs) / sizeof(struct mg_dnssd_record),
|
|
};
|
|
#endif
|
|
|
|
static struct mg_dnssd_record *dnssd_lookup(struct mg_str name) {
|
|
size_t i;
|
|
for (i = 0; i < sizeof(s_records) / sizeof(s_records[0]); i++) {
|
|
if (mg_strcasecmp(s_records[i].srvcproto, name) == 0) return &s_records[i];
|
|
}
|
|
return NULL;
|
|
}
|
|
#endif
|
|
|
|
// we can do more complex stuff, this is a simple implementation
|
|
static void mdns_ev_handler(struct mg_connection *c, int ev, void *ev_data) {
|
|
struct mg_mdns_req *req = (struct mg_mdns_req *) ev_data;
|
|
// MDNS resolver expects response IP address in the c->data
|
|
// memcpy(c->data, &response_ip, sizeof(response_ip));
|
|
MG_INFO(("---> %lu %d %p %p", c->id, ev, ev_data, req));
|
|
if (ev == MG_EV_MDNS_PTR) {
|
|
// do we serve this service ?
|
|
//MG_INFO(("PTR"));
|
|
} else if (ev == MG_EV_MDNS_SRV) {
|
|
//MG_INFO(("SrV"));
|
|
} else if (ev == MG_EV_MDNS_TXT) {
|
|
//MG_INFO(("TXT"));
|
|
} else if (ev == MG_EV_MDNS_A) { // is this us ?
|
|
//MG_INFO(("A, ADDR: %M", mg_print_ip, &req->addr));
|
|
}
|
|
|
|
#if 0
|
|
struct mg_mdns_req *req = (struct mg_mdns_req *) ev_data;
|
|
if (ev == MG_EV_MDNS_PTR) { // do we serve this service ?
|
|
struct mg_dnssd_record *r;
|
|
if (req->is_listing) return; // TODO(): handle services listing
|
|
r = dnssd_lookup(req->reqname);
|
|
if (r == NULL) return;
|
|
req->r = r;
|
|
req->is_resp = true;
|
|
} else if (ev == MG_EV_MDNS_SRV || ev == MG_EV_MDNS_TXT) {
|
|
// Mongoose already checked the host name for us, otherwise we need to do
|
|
// that ourselves first, then check for service name in db
|
|
struct mg_dnssd_record *r = dnssd_lookup(req->reqname);
|
|
if (r == NULL) return;
|
|
req->r = r;
|
|
req->is_resp = true;
|
|
} else if (ev == MG_EV_MDNS_A) { // is this us ?
|
|
// Mongoose already checked the host name for us, otherwise we need to do
|
|
// that ourselves
|
|
}
|
|
(void) c;
|
|
#endif
|
|
}
|
|
|
|
// Simple web server, responds with a JSON like this
|
|
// {"uri":"/","addr":"192.168.0.2:1234"}
|
|
static void http_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;
|
|
mg_http_reply(c, 200, "", "{%m:%m,%m:%m}\n", // Print JSON response
|
|
MG_ESC("uri"), mg_print_esc, hm->uri.len, hm->uri.buf, // URI
|
|
MG_ESC("addr"), mg_print_ip, &c->rem); // And remote addr
|
|
}
|
|
}
|
|
|
|
int main(void) {
|
|
struct mg_mgr mgr;
|
|
|
|
mg_log_set(MG_LL_DEBUG); // Set log level
|
|
mg_mgr_init(&mgr); // Initialise event manager
|
|
|
|
mg_mdns_listen(&mgr, mdns_ev_handler, MDNS_NAME);
|
|
mg_http_listen(&mgr, WEB_SERVER_ADDR, http_ev_handler, NULL);
|
|
|
|
for (;;) mg_mgr_poll(&mgr, 1000); // Event loop
|
|
|
|
mg_mgr_free(&mgr);
|
|
return 0;
|
|
}
|