httpd.c 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878
  1. #define MODULE "httpd"
  2. #include "common.h"
  3. #include "fw.h"
  4. #include "httpd.h"
  5. #include "config.h"
  6. #include <incbin.h>
  7. #include <unzipLIB.h>
  8. #define HTTPD_PRIORITY 4
  9. static httpd_handle_t httpd;
  10. static const char fallback_language[] = "en"; /* For unknown language */
  11. static const char redir_filename[] = "_redir"; /* For a directory "file" */
  12. #define MAX_LANG_LEN 16
  13. /* Looping version of httpd_send(); this is a hidden function in the server */
  14. static esp_err_t httpd_send_all(httpd_req_t *req, const void *buf, size_t len)
  15. {
  16. const char *p = buf;
  17. while (len) {
  18. int sent = httpd_send(req, p, len);
  19. if (sent <= 0)
  20. return ESP_ERR_HTTPD_RESP_SEND;
  21. p += sent;
  22. len -= sent;
  23. }
  24. return ESP_OK;
  25. }
  26. /* Create a file pointer from an http request */
  27. static ssize_t httpd_io_read(void *cookie, char *buf, size_t n)
  28. {
  29. int rv = httpd_req_recv(cookie, buf, n);
  30. return rv < 0 ? -1 : rv;
  31. }
  32. static ssize_t httpd_io_write(void *cookie, const char *buf, size_t n)
  33. {
  34. return httpd_resp_send_chunk(cookie, buf, n) ? 0 : n;
  35. }
  36. static int httpd_io_close_write(void *cookie)
  37. {
  38. return httpd_resp_send_chunk(cookie, NULL, 0) ? -1 : 0;
  39. }
  40. static FILE *httpd_fopen_read(httpd_req_t *req)
  41. {
  42. static const cookie_io_functions_t http_io_read_funcs = {
  43. .read = httpd_io_read,
  44. .write = NULL, /* Not writeable */
  45. .seek = NULL, /* Not seekable */
  46. .close = NULL,
  47. };
  48. return fopencookie((void *)req, "r", http_io_read_funcs);
  49. }
  50. static FILE *httpd_fopen_write(httpd_req_t *req)
  51. {
  52. static const cookie_io_functions_t http_io_write_funcs = {
  53. .read = httpd_io_read,
  54. .write = httpd_io_write,
  55. .seek = NULL, /* Not seekable */
  56. .close = httpd_io_close_write
  57. };
  58. return fopencookie((void *)req, "r+", http_io_write_funcs);
  59. }
  60. #define TIMEBUF_LEN 32
  61. static const char *http_date(const struct tm *when)
  62. {
  63. static char timebuf[32];
  64. strftime(timebuf, sizeof timebuf,
  65. "%a, %d %b %Y %H:%M:%S GMT", when);
  66. return timebuf;
  67. }
  68. static const char *http_now(void)
  69. {
  70. time_t t = time(NULL);
  71. return http_date(gmtime(&t));
  72. }
  73. static struct tm *set_weekday(struct tm *tm)
  74. {
  75. /*
  76. * This is a variation on Zeller's congruence with a table lookup
  77. * for the month. The table contains the number of days since March 1,
  78. * mod 7 (for Jan and Feb, from March 1 of the *previous year*.)
  79. *
  80. * Sample test cases:
  81. * Wed Mar 1 0000
  82. * Thu Jan 1 1970
  83. * Wed Apr 27 2022
  84. * Mon Feb 28 2000
  85. * Wed Mar 1 2000
  86. * Sun Feb 28 2100
  87. * Mon Mar 1 2100
  88. */
  89. static const uint8_t md[12] = { 5, 1, 0, 3, 5, 1, 3, 6, 2, 4, 0, 2 };
  90. unsigned int c, y, m, d;
  91. y = tm->tm_year + 1900;
  92. m = tm->tm_mon;
  93. d = tm->tm_mday;
  94. if (m < 2)
  95. y--; /* Jan, Feb */
  96. c = y/100;
  97. /*
  98. * 2 represents the base date of Tue Feb 29 0000
  99. *
  100. * 0 = Sun, 6 = Sat
  101. */
  102. tm->tm_wday = (d + md[m] + y + (y >> 2) - c + (c >> 2) + 2) % 7;
  103. return tm;
  104. }
  105. static const char *http_dos_date(uint32_t dos_date)
  106. {
  107. struct tm tm;
  108. tm.tm_sec = (dos_date << 1) & 63;
  109. tm.tm_min = (dos_date >> 5) & 63;
  110. tm.tm_hour = (dos_date >> 11) & 31;
  111. tm.tm_mday = (dos_date >> 16) & 31;
  112. tm.tm_mon = ((dos_date >> 21) & 15) - 1;
  113. tm.tm_year = (dos_date >> 25) + 80;
  114. tm.tm_isdst = 0; /* Times are stored in GMT */
  115. return http_date(set_weekday(&tm));
  116. }
  117. static const char text_plain[] = "text/plain; charset=\"UTF-8\"";
  118. static void httpd_print_request(const httpd_req_t *req)
  119. {
  120. printf("[HTTP] %s %s\n", http_method_str(req->method), req->uri);
  121. }
  122. static char *httpd_req_get_hdr(httpd_req_t *req, const char *field, size_t *lenp)
  123. {
  124. size_t len = httpd_req_get_hdr_value_len(req, field);
  125. char *val = NULL;
  126. if (len) {
  127. val = malloc(len+1);
  128. if (val) {
  129. httpd_req_get_hdr_value_str(req, field, val, len+1);
  130. val[len] = '\0';
  131. }
  132. }
  133. if (lenp)
  134. *lenp = len;
  135. return val;
  136. }
  137. enum hsp_flags {
  138. HSP_CRLF = 1, /* Append CR LF to the body */
  139. HSP_CLOSE = 2, /* Add a Connection: close header */
  140. HSP_REFERER = 4, /* Use referer as body (for redirects) */
  141. HSP_UNCACHE = 8 /* Wipe caches, please... */
  142. };
  143. static esp_err_t httpd_send_plain(httpd_req_t *req,
  144. unsigned int rcode,
  145. const char *body, size_t blen,
  146. enum hsp_flags flags, unsigned int refresh)
  147. {
  148. char *header = NULL;
  149. esp_err_t err;
  150. int hlen;
  151. const char *now = http_now();
  152. MSG("http_send_plain %u \"%.*s\"\n", rcode, (int)blen, body);
  153. if (rcode > 499)
  154. flags |= HSP_CLOSE;
  155. const char *closer = flags & HSP_CLOSE ? "Connection: close\r\n" : "";
  156. bool redirect = rcode >= 300 && rcode <= 399;
  157. char *referer = NULL;
  158. char *refresher_buf = NULL;
  159. if (refresh || (flags & HSP_REFERER)) {
  160. size_t referer_len;
  161. referer = httpd_req_get_hdr(req, "Referer", &referer_len);
  162. /* "Effective" referer */
  163. const char * const ereferer = referer ? referer : "/";
  164. if (refresh) {
  165. asprintf(&refresher_buf, "Refresh: %u;url=%s\r\n",
  166. refresh, ereferer);
  167. }
  168. if (flags & HSP_REFERER) {
  169. body = ereferer;
  170. blen = referer ? referer_len : 1;
  171. }
  172. }
  173. const char * const refresher = refresher_buf ? refresher_buf : "";
  174. const char * const uncacher = (flags & HSP_UNCACHE)
  175. ? "Clear-Site-Data: \"cache\"\r\n" : "";
  176. if (redirect) {
  177. /* \0 -> \n so don't include it */
  178. size_t blenadj = sizeof("3xx Redirect \r");
  179. /* Always CR LF */
  180. flags |= HSP_CRLF;
  181. /* Drop any CR LF already in the redirect string */
  182. for (size_t bchk = 0; bchk < blen; bchk++) {
  183. if (body[bchk] == '\r' || body[bchk] == '\n') {
  184. blen = bchk;
  185. break;
  186. }
  187. }
  188. hlen = asprintf(&header,
  189. "HTTP/1.1 %u\r\n"
  190. "Content-Type: %s\r\n"
  191. "Content-Length: %zu\r\n"
  192. "Date %s\r\n"
  193. "Location: %.*s\r\n"
  194. "%s%s%s"
  195. "\r\n"
  196. "%3u Redirect ",
  197. rcode, text_plain, blen + blenadj,
  198. now, (int)blen, body,
  199. closer, refresher, uncacher,
  200. rcode);
  201. } else {
  202. size_t blenadj = (flags & HSP_CRLF) ? 2 : 0;
  203. hlen = asprintf(&header,
  204. "HTTP/1.1 %u\r\n"
  205. "Content-Type: %s\r\n"
  206. "Content-Length: %zu\r\n"
  207. "Cache-Control: no-cache\r\n"
  208. "Date: %s\r\n"
  209. "%s%s%s"
  210. "\r\n",
  211. rcode, text_plain, blen + blenadj, now,
  212. closer, refresher, uncacher);
  213. }
  214. if (refresher_buf)
  215. free(refresher_buf);
  216. if (referer)
  217. free(referer);
  218. if (!header)
  219. return ESP_ERR_NO_MEM;
  220. err = httpd_send_all(req, header, hlen);
  221. if (!err && blen) {
  222. err = httpd_send_all(req, body, blen);
  223. }
  224. if (!err && (flags & HSP_CRLF)) {
  225. err = httpd_send_all(req, "\r\n", 2);
  226. }
  227. if (header)
  228. free(header);
  229. return err;
  230. }
  231. #define SL(s) (s), (sizeof(s)-1)
  232. #define HTTP_ERR(r,e,s) httpd_send_plain((r), (e), SL(s), HSP_CRLF, 0)
  233. static esp_err_t httpd_err_enoent(httpd_req_t *req)
  234. {
  235. return HTTP_ERR(req, 404, "URI not found");
  236. }
  237. static esp_err_t httpd_send_ok(httpd_req_t *req)
  238. {
  239. return HTTP_ERR(req, 200, "OK");
  240. }
  241. static esp_err_t httpd_err_enomem(httpd_req_t *req)
  242. {
  243. return HTTP_ERR(req, 503, "Out of memory");
  244. }
  245. static esp_err_t httpd_update_done(httpd_req_t *req, const char *what, int err)
  246. {
  247. char *response = NULL;
  248. int len;
  249. unsigned int reboot_time = reboot_delayed();
  250. if (err) {
  251. len = asprintf(&response,
  252. "%s update failed: %s\r\n"
  253. "Rebooting in %u seconds\r\n",
  254. what, firmware_errstr(err), reboot_time);
  255. } else {
  256. len = asprintf(&response,
  257. "%s update complete\r\n"
  258. "Rebooting in %u seconds\r\n",
  259. what, reboot_time);
  260. }
  261. if (!response)
  262. len = 0;
  263. esp_err_t rv = httpd_send_plain(req, err ? 400 : 200, response, len,
  264. HSP_CLOSE|HSP_UNCACHE, reboot_time+5);
  265. if (response)
  266. free(response);
  267. return rv;
  268. }
  269. static esp_err_t httpd_firmware_update(httpd_req_t *req)
  270. {
  271. int rv;
  272. /* XXX: use httpd_fopen_read() here */
  273. rv = firmware_update((read_func_t)httpd_req_recv, (token_t)req);
  274. return httpd_update_done(req, "Firmware", rv);
  275. }
  276. static esp_err_t httpd_set_config(httpd_req_t *req, const char *query)
  277. {
  278. FILE *f;
  279. size_t qlen;
  280. int rv1 = 0;
  281. if (query) {
  282. rv1 = set_config_url_string(query);
  283. }
  284. int rv2 = 0;
  285. f = NULL;
  286. if (req->content_len) {
  287. f = httpd_fopen_read(req);
  288. if (!f)
  289. return HTTP_ERR(req, 500, "Unable to get request handle");
  290. }
  291. rv2 = read_config(f, true);
  292. if (f)
  293. fclose(f);
  294. return httpd_update_done(req, "Configuration", rv1 ? rv1 : rv2);
  295. }
  296. #define MIN_STATUS_REF 2 /* Minimum refresh time in ms */
  297. static void httpd_get_status_extra(FILE *f, httpd_req_t *req)
  298. {
  299. static const char refresh_time_config[] = "http.status.refresh";
  300. const unsigned long min_status_ref = 5;
  301. char timebuf[64];
  302. size_t len;
  303. struct timeval tv;
  304. unsigned long statref;
  305. statref = Max(getenv_ul(refresh_time_config, 0), min_status_ref);
  306. if (httpd_req_get_url_query_str(req, timebuf, sizeof timebuf) == ESP_OK &&
  307. *timebuf) {
  308. char *ep;
  309. unsigned long newstatref = strtoul(timebuf, &ep, 10);
  310. if (!*ep && newstatref >= min_status_ref && newstatref != statref) {
  311. statref = newstatref;
  312. setenv_config(refresh_time_config, timebuf);
  313. read_config(NULL, true); /* Save changed config */
  314. }
  315. }
  316. fprintf(f, "%s=%lu\n", refresh_time_config, statref);
  317. gettimeofday(&tv,NULL);
  318. const struct tm *tm = localtime(&tv.tv_sec);
  319. len = strftime(timebuf, sizeof timebuf, "localtime=%Y-%m-%d %H:%M:%S.", tm);
  320. snprintf(timebuf+len, sizeof timebuf - len, "%06u",
  321. (unsigned long)tv.tv_usec);
  322. len += 3;
  323. len += strftime(timebuf+len, sizeof timebuf - len, " %z (%Z)\n", tm);
  324. fwrite(timebuf, 1, len, f);
  325. }
  326. static esp_err_t httpd_get_config_status(httpd_req_t *req, bool status)
  327. {
  328. FILE *f = httpd_fopen_write(req);
  329. if (!f)
  330. return HTTP_ERR(req, 500, "Unable to get request handle");
  331. httpd_resp_set_type(req, text_plain);
  332. httpd_resp_set_hdr(req, "Cache-Control", "no-cache");
  333. if (status)
  334. httpd_get_status_extra(f, req);
  335. int rv = write_env(f, status);
  336. fclose(f);
  337. return rv ? ESP_FAIL : ESP_OK;
  338. }
  339. static esp_err_t httpd_set_lang(httpd_req_t *req, const char *query)
  340. {
  341. if (query) {
  342. int qlen = strlen(query);
  343. setenv_config("LANG", qlen && qlen <= MAX_LANG_LEN ? query : NULL);
  344. read_config(NULL, true); /* Save configuration */
  345. }
  346. /*
  347. * 303 = "See other": proper return code saying "this is not what
  348. * you asked for, this is *about* what you asked for"; see spec
  349. * but this is exactly what we want here.
  350. */
  351. return httpd_send_plain(req, 303, NULL, 0, HSP_REFERER, 0);
  352. }
  353. static esp_err_t httpd_get_lang(httpd_req_t *req)
  354. {
  355. const char *lang = getenv_def("LANG", "");
  356. return httpd_send_plain(req, 200, lang, strlen(lang), HSP_CRLF, 0);
  357. }
  358. static esp_err_t httpd_lang_redirect(httpd_req_t *req)
  359. {
  360. char lang_buf[sizeof("/lang/") + MAX_LANG_LEN];
  361. int len = snprintf(lang_buf, sizeof lang_buf, "/lang/%s",
  362. getenv_def("LANG", fallback_language));
  363. return httpd_send_plain(req, 302, lang_buf, len, 0, 0);
  364. }
  365. #define STRING_MATCHES(str, len, what) \
  366. (((len) == sizeof(what)-1) && !memcmp((str), (what), sizeof(what)-1))
  367. static esp_err_t httpd_sys_handler(httpd_req_t *req)
  368. {
  369. httpd_print_request(req);
  370. if (req->method == HTTP_POST &&
  371. !httpd_req_get_hdr_value_len(req, "Content-Length")) {
  372. return HTTP_ERR(req, 411, "Length required");
  373. }
  374. const char *query = strchrnul(req->uri, '?');
  375. if (query < req->uri+5 || memcmp(req->uri, "/sys/", 5))
  376. return httpd_err_enoent(req); /* This should never happen */
  377. const char *file = req->uri + 5;
  378. size_t filelen = query - file;
  379. query = *query == '?' ? query+1 : NULL;
  380. if (STRING_MATCHES(file, filelen, "lang"))
  381. return httpd_lang_redirect(req);
  382. if (STRING_MATCHES(file, filelen, "getstatus"))
  383. return httpd_get_config_status(req, true);
  384. if (STRING_MATCHES(file, filelen, "getconfig"))
  385. return httpd_get_config_status(req, false);
  386. if (req->method == HTTP_POST && STRING_MATCHES(file, filelen, "fwupdate"))
  387. return httpd_firmware_update(req);
  388. if (STRING_MATCHES(file, filelen, "setconfig"))
  389. return httpd_set_config(req, query);
  390. if (STRING_MATCHES(file, filelen, "getlang"))
  391. return httpd_get_lang(req);
  392. if (STRING_MATCHES(file, filelen, "setlang"))
  393. return httpd_set_lang(req, query);
  394. return httpd_err_enoent(req);
  395. }
  396. INCBIN_EXTERN(wwwzip);
  397. struct mime_type {
  398. const char *ext;
  399. uint16_t ext_len;
  400. uint16_t flags;
  401. const char *mime;
  402. };
  403. #define MT_CHARSET 1 /* Add charset to Content-Type */
  404. #define MT_REDIR 2 /* It is a redirect */
  405. static const struct mime_type mime_types[] = {
  406. { ".html", 5, MT_CHARSET, "text/html" },
  407. { ".xhtml", 6, MT_CHARSET, "text/html" },
  408. { ".css", 4, MT_CHARSET, "text/css" },
  409. { ".webp", 5, 0, "image/webp" },
  410. { ".jpg", 4, 0, "image/jpeg" },
  411. { ".png", 4, 0, "image/png" },
  412. { ".ico", 4, 0, "image/png" }, /* favicon.ico */
  413. { ".svg", 4, MT_CHARSET, "image/svg+xml" },
  414. { ".otf", 4, 0, "font/otf" },
  415. { ".ttf", 4, 0, "font/ttf" },
  416. { ".woff", 5, 0, "font/woff" },
  417. { ".woff2", 6, 0, "font/woff2" },
  418. { ".pdf", 4, 0, "application/pdf" },
  419. { ".js", 3, MT_CHARSET, "text/javascript" },
  420. { ".mjs", 4, MT_CHARSET, "text/javascript" },
  421. { ".json", 5, MT_CHARSET, "application/json" },
  422. { ".xml", 4, MT_CHARSET, "text/xml" },
  423. { ".bin", 4, 0, "application/octet-stream" },
  424. { ".fw", 3, 0, "application/octet-stream" },
  425. { "_redir", 6, MT_REDIR, NULL },
  426. { NULL, 0, MT_CHARSET, "text/plain" } /* default */
  427. };
  428. static esp_err_t httpd_static_handler(httpd_req_t *req)
  429. {
  430. size_t buffer_size = UNZ_BUFSIZE;
  431. const char *uri, *enduri;
  432. bool is_dir;
  433. char *buffer = NULL;
  434. ZIPFILE *zip = NULL;
  435. unzFile unz = NULL;
  436. bool file_open = false;
  437. int err = 0;
  438. size_t len;
  439. httpd_print_request(req);
  440. uri = req->uri;
  441. while (*uri == '/')
  442. uri++; /* Skip leading slashes */
  443. const char *first_slash = NULL, *last_slash = NULL;
  444. for (enduri = uri; *enduri; enduri++) {
  445. if (*enduri == '/') {
  446. last_slash = enduri;
  447. if (!first_slash)
  448. first_slash = enduri;
  449. }
  450. }
  451. if (enduri == uri) {
  452. is_dir = true;
  453. } else if (last_slash == enduri-1) {
  454. is_dir = true;
  455. enduri--; /* Drop terminal slash */
  456. if (first_slash == last_slash)
  457. first_slash = NULL;
  458. } else {
  459. is_dir = false; /* Try the plain filename first */
  460. }
  461. const size_t filename_buffer_size =
  462. (enduri - uri) + 2 + sizeof redir_filename;
  463. if (buffer_size < filename_buffer_size)
  464. buffer_size = filename_buffer_size;
  465. buffer = malloc(buffer_size);
  466. zip = malloc(sizeof *zip);
  467. if (!buffer || !zip) {
  468. err = httpd_err_enomem(req);
  469. goto out;
  470. }
  471. char * const filebase = buffer + 1;
  472. char * const endbase = mempcpy(filebase, uri, enduri - uri);
  473. filebase[-1] = '/';
  474. unz = unzOpen(NULL, (void *)gwwwzipData, gwwwzipSize,
  475. zip, NULL, NULL, NULL, NULL);
  476. if (!unz) {
  477. MSG("[HTTP] unzOpen failed!\n");
  478. err = HTTP_ERR(req, 500, "Cannot open content archive");
  479. goto out;
  480. }
  481. char * const filename = filebase; /* Separate for future needs */
  482. char *endfile = endbase;
  483. unsigned int m;
  484. bool found = false;
  485. for (m = is_dir ? 2 : 0; m < 3; m++) {
  486. char *sx;
  487. switch (m) {
  488. default: /* filename = /url */
  489. endfile = endbase;
  490. break;
  491. case 1: /* filename = /url_redir */
  492. sx = endbase;
  493. endfile = mempcpy(sx, redir_filename, sizeof redir_filename) - 1;
  494. break;
  495. case 2: /* filename = /url/_redir */
  496. sx = endbase - (endbase[-1] == '/');
  497. *sx++ = '/';
  498. endfile = mempcpy(sx, redir_filename, sizeof redir_filename) - 1;
  499. break;
  500. }
  501. *endfile = '\0';
  502. if (!filename)
  503. continue;
  504. filename[-1] = '/';
  505. MSG("trying to open: %s... ", filename);
  506. if (unzLocateFile(unz, filename, 1) == UNZ_OK) {
  507. CMSG("found\n");
  508. found = true;
  509. break;
  510. } else {
  511. CMSG("not found\n");
  512. }
  513. }
  514. if (!found) {
  515. err = httpd_err_enoent(req);
  516. goto out;
  517. }
  518. size_t filelen = endfile - filename;
  519. const struct mime_type *mime_type = mime_types;
  520. /* The default entry with length 0 will always match */
  521. while (mime_type->ext_len) {
  522. len = mime_type->ext_len;
  523. if (len <= filelen && !memcmp(endfile - len, mime_type->ext, len))
  524. break;
  525. mime_type++;
  526. }
  527. MSG("found %s ext %s type %s\n",
  528. filename,
  529. mime_type->ext ? mime_type->ext : "(none)",
  530. mime_type->mime ? mime_type->mime : "(none)");
  531. unz_file_info fileinfo;
  532. memset(&fileinfo, 0, sizeof fileinfo);
  533. unzGetCurrentFileInfo(unz, &fileinfo, NULL, 0, NULL, 0, NULL, 0);
  534. MSG("len %u compressed %u\n",
  535. fileinfo.uncompressed_size,
  536. fileinfo.compressed_size);
  537. /*
  538. * Is it a redirect?
  539. */
  540. if (mime_type->flags & MT_REDIR) {
  541. if (fileinfo.uncompressed_size > buffer_size ||
  542. unzOpenCurrentFile(unz) != UNZ_OK) {
  543. err = HTTP_ERR(req, 500, "Cannot open file in archive");
  544. goto out;
  545. }
  546. file_open = true;
  547. len = fileinfo.uncompressed_size;
  548. if (unzReadCurrentFile(unz, buffer, len) != len) {
  549. err = ESP_ERR_HTTPD_RESULT_TRUNC;
  550. goto out;
  551. }
  552. MSG("redirect: %.*s\n", (int)len, buffer);
  553. err = httpd_send_plain(req, 302, buffer, len, 0, 0);
  554. goto out;
  555. }
  556. /*
  557. * Hopefully the combination of date and CRC
  558. * is strong enough to quality for a "strong" ETag
  559. */
  560. char etag[16+3+1];
  561. snprintf(etag, sizeof etag, "\"%08x:%08x\"",
  562. fileinfo.dosDate, fileinfo.crc);
  563. bool skip_body = req->method == HTTP_HEAD || !fileinfo.uncompressed_size;
  564. bool skip_meta = false;
  565. const char *response = "200 OK";
  566. if (httpd_req_get_hdr_value_str(req, "If-None-Match",
  567. buffer, buffer_size) == ESP_OK &&
  568. strstr(buffer, etag)) {
  569. skip_body = skip_meta = true;
  570. response = "304 Not Modified";
  571. }
  572. len = snprintf(buffer, buffer_size-2,
  573. "HTTP/1.1 %s\r\n"
  574. "Date: %s\r\n"
  575. "Cache-Control: max-age=10, immutable\r\n"
  576. "ETag: %s\r\n",
  577. response,
  578. http_now(),
  579. etag);
  580. if (len < buffer_size-2 && !skip_meta) {
  581. const char *mime_extra =
  582. mime_type->flags & MT_CHARSET ? "; charset=\"UTF-8\"" : "";
  583. len += snprintf(buffer + len, buffer_size-2 - len,
  584. "Content-Type: %s%s\r\n"
  585. "Content-Length: %u\r\n"
  586. "Allow: GET, HEAD\r\n"
  587. "Connection: close\r\n"
  588. "Last-Modified: %s\r\n",
  589. mime_type->mime, mime_extra,
  590. fileinfo.uncompressed_size,
  591. http_dos_date(fileinfo.dosDate));
  592. }
  593. if (len >= buffer_size-2) {
  594. err = HTTP_ERR(req, 500, "buffer_size too small");
  595. goto out;
  596. }
  597. buffer[len++] = '\r';
  598. buffer[len++] = '\n';
  599. err = httpd_send_all(req, buffer, len);
  600. if (skip_body || err) {
  601. /* No need to spend time uncompressing the file content */
  602. goto out;
  603. }
  604. if (unzOpenCurrentFile(unz) != UNZ_OK) {
  605. err = HTTP_ERR(req, 400, "Cannot open file in archive");
  606. goto out;
  607. }
  608. file_open = true;
  609. len = fileinfo.uncompressed_size;
  610. while (len) {
  611. size_t chunk = len;
  612. if (chunk > buffer_size)
  613. chunk = buffer_size;
  614. if (unzReadCurrentFile(unz, buffer, chunk) != chunk) {
  615. err = ESP_ERR_HTTPD_RESULT_TRUNC;
  616. goto out;
  617. }
  618. err = httpd_send_all(req, buffer, chunk);
  619. if (err)
  620. goto out;
  621. len -= chunk;
  622. }
  623. err = ESP_OK; /* All good! */
  624. out:
  625. if (file_open)
  626. unzCloseCurrentFile(unz);
  627. if (unz)
  628. unzClose(unz);
  629. if (zip)
  630. free(zip);
  631. if (buffer)
  632. free(buffer);
  633. return err;
  634. }
  635. /*
  636. * Match a URL against a path prefix. To keep httpd from refusing to
  637. * register subpaths, the root template does not include the leading
  638. * '/', but uri is required to have it. Do not include a trailing /
  639. * in prefix; it is implied.
  640. */
  641. static bool httpd_uri_match_prefix(const char *template, const char *uri,
  642. size_t len)
  643. {
  644. #if 0
  645. printf("[HTTP] matching URI \"%.*s\" against template \"%s\"\n",
  646. len, uri, template);
  647. #endif
  648. if (!len-- || *uri++ != '/')
  649. return false;
  650. /* Previous template character (leading '/' implied) */
  651. unsigned char tp = '/';
  652. while (1) {
  653. unsigned char t = *template++;
  654. unsigned char u;
  655. if (!len-- || !(u = *uri++)) {
  656. return !t;
  657. } else if (!t) {
  658. return tp == '/' || u == '/';
  659. } else if (t != u) {
  660. return false;
  661. }
  662. tp = t;
  663. }
  664. }
  665. /* Do not include leading or trailing /; most specific prefix first */
  666. static const httpd_uri_t uri_handlers[] = {
  667. {
  668. .uri = "sys",
  669. .method = HTTP_GET,
  670. .handler = httpd_sys_handler,
  671. .user_ctx = NULL
  672. },
  673. {
  674. .uri = "",
  675. .method = HTTP_GET,
  676. .handler = httpd_static_handler,
  677. .user_ctx = NULL
  678. },
  679. {
  680. .uri = "",
  681. .method = HTTP_HEAD,
  682. .handler = httpd_static_handler,
  683. .user_ctx = NULL
  684. },
  685. {
  686. .uri = "sys",
  687. .method = HTTP_POST,
  688. .handler = httpd_sys_handler,
  689. .user_ctx = NULL
  690. },
  691. };
  692. void my_httpd_stop(void)
  693. {
  694. if (httpd) {
  695. esp_unregister_shutdown_handler(my_httpd_stop);
  696. httpd_stop(httpd);
  697. httpd = NULL;
  698. }
  699. }
  700. void my_httpd_start(void)
  701. {
  702. httpd_config_t config = HTTPD_DEFAULT_CONFIG();
  703. httpd_handle_t server;
  704. if (httpd)
  705. return;
  706. config.task_priority = HTTPD_PRIORITY;
  707. config.max_open_sockets = 10;
  708. printf("[HTTP] Default stack size: %zu\n", config.stack_size);
  709. config.stack_size <<= 2;
  710. printf("[HTTP] Requesting stack size: %zu\n", config.stack_size);
  711. config.uri_match_fn = httpd_uri_match_prefix;
  712. if (httpd_start(&server, &config) != ESP_OK)
  713. return;
  714. esp_register_shutdown_handler(my_httpd_stop);
  715. httpd = server;
  716. for (size_t i = 0; i < ARRAY_SIZE(uri_handlers); i++) {
  717. const httpd_uri_t * const handler = &uri_handlers[i];
  718. if (httpd_register_uri_handler(httpd, handler))
  719. printf("[HTTP] failed to register URI handler: %s %s\n",
  720. http_method_str(handler->method), handler->uri);
  721. }
  722. printf("[HTTP] httpd started\n");
  723. }