httpd.c 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837
  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. static esp_err_t httpd_get_config(httpd_req_t *req)
  297. {
  298. FILE *f = httpd_fopen_write(req);
  299. if (!f)
  300. return HTTP_ERR(req, 500, "Unable to get request handle");
  301. httpd_resp_set_type(req, text_plain);
  302. httpd_resp_set_hdr(req, "Cache-Control", "no-cache");
  303. int rv = write_config(f);
  304. fclose(f);
  305. return rv ? ESP_FAIL : ESP_OK;
  306. }
  307. static esp_err_t httpd_set_lang(httpd_req_t *req, const char *query)
  308. {
  309. if (query) {
  310. int qlen = strlen(query);
  311. setenv_config("LANG", qlen && qlen <= MAX_LANG_LEN ? query : NULL);
  312. read_config(NULL, true); /* Save configuration */
  313. }
  314. /*
  315. * 303 = "See other": proper return code saying "this is not what
  316. * you asked for, this is *about* what you asked for"; see spec
  317. * but this is exactly what we want here.
  318. */
  319. return httpd_send_plain(req, 303, NULL, 0, HSP_REFERER, 0);
  320. }
  321. static esp_err_t httpd_get_lang(httpd_req_t *req)
  322. {
  323. const char *lang = getenv_def("LANG", "");
  324. return httpd_send_plain(req, 200, lang, strlen(lang), HSP_CRLF, 0);
  325. }
  326. static esp_err_t httpd_lang_redirect(httpd_req_t *req)
  327. {
  328. char lang_buf[sizeof("/lang/") + MAX_LANG_LEN];
  329. int len = snprintf(lang_buf, sizeof lang_buf, "/lang/%s",
  330. getenv_def("LANG", fallback_language));
  331. return httpd_send_plain(req, 302, lang_buf, len, 0, 0);
  332. }
  333. #define STRING_MATCHES(str, len, what) \
  334. (((len) == sizeof(what)-1) && !memcmp((str), (what), sizeof(what)-1))
  335. static esp_err_t httpd_sys_handler(httpd_req_t *req)
  336. {
  337. httpd_print_request(req);
  338. if (req->method == HTTP_POST &&
  339. !httpd_req_get_hdr_value_len(req, "Content-Length")) {
  340. return HTTP_ERR(req, 411, "Length required");
  341. }
  342. const char *query = strchrnul(req->uri, '?');
  343. if (query < req->uri+5 || memcmp(req->uri, "/sys/", 5))
  344. return httpd_err_enoent(req); /* This should never happen */
  345. const char *file = req->uri + 5;
  346. size_t filelen = query - file;
  347. query = *query == '?' ? query+1 : NULL;
  348. if (STRING_MATCHES(file, filelen, "lang"))
  349. return httpd_lang_redirect(req);
  350. if (STRING_MATCHES(file, filelen, "getconfig"))
  351. return httpd_get_config(req);
  352. if (req->method == HTTP_POST && STRING_MATCHES(file, filelen, "fwupdate"))
  353. return httpd_firmware_update(req);
  354. if (STRING_MATCHES(file, filelen, "setconfig"))
  355. return httpd_set_config(req, query);
  356. if (STRING_MATCHES(file, filelen, "getlang"))
  357. return httpd_get_lang(req);
  358. if (STRING_MATCHES(file, filelen, "setlang"))
  359. return httpd_set_lang(req, query);
  360. return httpd_err_enoent(req);
  361. }
  362. INCBIN_EXTERN(wwwzip);
  363. struct mime_type {
  364. const char *ext;
  365. uint16_t ext_len;
  366. uint16_t flags;
  367. const char *mime;
  368. };
  369. #define MT_CHARSET 1 /* Add charset to Content-Type */
  370. #define MT_REDIR 2 /* It is a redirect */
  371. static const struct mime_type mime_types[] = {
  372. { ".html", 5, MT_CHARSET, "text/html" },
  373. { ".xhtml", 6, MT_CHARSET, "text/html" },
  374. { ".css", 4, MT_CHARSET, "text/css" },
  375. { ".webp", 5, 0, "image/webp" },
  376. { ".jpg", 4, 0, "image/jpeg" },
  377. { ".png", 4, 0, "image/png" },
  378. { ".ico", 4, 0, "image/png" }, /* favicon.ico */
  379. { ".svg", 4, MT_CHARSET, "image/svg+xml" },
  380. { ".otf", 4, 0, "font/otf" },
  381. { ".ttf", 4, 0, "font/ttf" },
  382. { ".woff", 5, 0, "font/woff" },
  383. { ".woff2", 6, 0, "font/woff2" },
  384. { ".pdf", 4, 0, "application/pdf" },
  385. { ".js", 3, MT_CHARSET, "text/javascript" },
  386. { ".mjs", 4, MT_CHARSET, "text/javascript" },
  387. { ".json", 5, MT_CHARSET, "application/json" },
  388. { ".xml", 4, MT_CHARSET, "text/xml" },
  389. { ".bin", 4, 0, "application/octet-stream" },
  390. { ".fw", 3, 0, "application/octet-stream" },
  391. { "_redir", 6, MT_REDIR, NULL },
  392. { NULL, 0, MT_CHARSET, "text/plain" } /* default */
  393. };
  394. static esp_err_t httpd_static_handler(httpd_req_t *req)
  395. {
  396. size_t buffer_size = UNZ_BUFSIZE;
  397. const char *uri, *enduri;
  398. bool is_dir;
  399. char *buffer = NULL;
  400. ZIPFILE *zip = NULL;
  401. unzFile unz = NULL;
  402. bool file_open = false;
  403. int err = 0;
  404. size_t len;
  405. httpd_print_request(req);
  406. uri = req->uri;
  407. while (*uri == '/')
  408. uri++; /* Skip leading slashes */
  409. const char *first_slash = NULL, *last_slash = NULL;
  410. for (enduri = uri; *enduri; enduri++) {
  411. if (*enduri == '/') {
  412. last_slash = enduri;
  413. if (!first_slash)
  414. first_slash = enduri;
  415. }
  416. }
  417. if (enduri == uri) {
  418. is_dir = true;
  419. } else if (last_slash == enduri-1) {
  420. is_dir = true;
  421. enduri--; /* Drop terminal slash */
  422. if (first_slash == last_slash)
  423. first_slash = NULL;
  424. } else {
  425. is_dir = false; /* Try the plain filename first */
  426. }
  427. const size_t filename_buffer_size =
  428. (enduri - uri) + 2 + sizeof redir_filename;
  429. if (buffer_size < filename_buffer_size)
  430. buffer_size = filename_buffer_size;
  431. buffer = malloc(buffer_size);
  432. zip = malloc(sizeof *zip);
  433. if (!buffer || !zip) {
  434. err = httpd_err_enomem(req);
  435. goto out;
  436. }
  437. char * const filebase = buffer + 1;
  438. char * const endbase = mempcpy(filebase, uri, enduri - uri);
  439. filebase[-1] = '/';
  440. unz = unzOpen(NULL, (void *)gwwwzipData, gwwwzipSize,
  441. zip, NULL, NULL, NULL, NULL);
  442. if (!unz) {
  443. MSG("[HTTP] unzOpen failed!\n");
  444. err = HTTP_ERR(req, 500, "Cannot open content archive");
  445. goto out;
  446. }
  447. char * const filename = filebase; /* Separate for future needs */
  448. char *endfile = endbase;
  449. unsigned int m;
  450. bool found = false;
  451. for (m = is_dir ? 2 : 0; m < 3; m++) {
  452. char *sx;
  453. switch (m) {
  454. default: /* filename = /url */
  455. endfile = endbase;
  456. break;
  457. case 1: /* filename = /url_redir */
  458. sx = endbase;
  459. endfile = mempcpy(sx, redir_filename, sizeof redir_filename) - 1;
  460. break;
  461. case 2: /* filename = /url/_redir */
  462. sx = endbase - (endbase[-1] == '/');
  463. *sx++ = '/';
  464. endfile = mempcpy(sx, redir_filename, sizeof redir_filename) - 1;
  465. break;
  466. }
  467. *endfile = '\0';
  468. if (!filename)
  469. continue;
  470. filename[-1] = '/';
  471. MSG("trying to open: %s... ", filename);
  472. if (unzLocateFile(unz, filename, 1) == UNZ_OK) {
  473. CMSG("found\n");
  474. found = true;
  475. break;
  476. } else {
  477. CMSG("not found\n");
  478. }
  479. }
  480. if (!found) {
  481. err = httpd_err_enoent(req);
  482. goto out;
  483. }
  484. size_t filelen = endfile - filename;
  485. const struct mime_type *mime_type = mime_types;
  486. /* The default entry with length 0 will always match */
  487. while (mime_type->ext_len) {
  488. len = mime_type->ext_len;
  489. if (len <= filelen && !memcmp(endfile - len, mime_type->ext, len))
  490. break;
  491. mime_type++;
  492. }
  493. MSG("found %s ext %s type %s\n",
  494. filename,
  495. mime_type->ext ? mime_type->ext : "(none)",
  496. mime_type->mime ? mime_type->mime : "(none)");
  497. unz_file_info fileinfo;
  498. memset(&fileinfo, 0, sizeof fileinfo);
  499. unzGetCurrentFileInfo(unz, &fileinfo, NULL, 0, NULL, 0, NULL, 0);
  500. MSG("len %u compressed %u\n",
  501. fileinfo.uncompressed_size,
  502. fileinfo.compressed_size);
  503. /*
  504. * Is it a redirect?
  505. */
  506. if (mime_type->flags & MT_REDIR) {
  507. if (fileinfo.uncompressed_size > buffer_size ||
  508. unzOpenCurrentFile(unz) != UNZ_OK) {
  509. err = HTTP_ERR(req, 500, "Cannot open file in archive");
  510. goto out;
  511. }
  512. file_open = true;
  513. len = fileinfo.uncompressed_size;
  514. if (unzReadCurrentFile(unz, buffer, len) != len) {
  515. err = ESP_ERR_HTTPD_RESULT_TRUNC;
  516. goto out;
  517. }
  518. MSG("redirect: %.*s\n", (int)len, buffer);
  519. err = httpd_send_plain(req, 302, buffer, len, 0, 0);
  520. goto out;
  521. }
  522. /*
  523. * Hopefully the combination of date and CRC
  524. * is strong enough to quality for a "strong" ETag
  525. */
  526. char etag[16+3+1];
  527. snprintf(etag, sizeof etag, "\"%08x:%08x\"",
  528. fileinfo.dosDate, fileinfo.crc);
  529. bool skip_body = req->method == HTTP_HEAD || !fileinfo.uncompressed_size;
  530. bool skip_meta = false;
  531. const char *response = "200 OK";
  532. if (httpd_req_get_hdr_value_str(req, "If-None-Match",
  533. buffer, buffer_size) == ESP_OK &&
  534. strstr(buffer, etag)) {
  535. skip_body = skip_meta = true;
  536. response = "304 Not Modified";
  537. }
  538. len = snprintf(buffer, buffer_size-2,
  539. "HTTP/1.1 %s\r\n"
  540. "Date: %s\r\n"
  541. "Cache-Control: max-age=10, immutable\r\n"
  542. "ETag: %s\r\n",
  543. response,
  544. http_now(),
  545. etag);
  546. if (len < buffer_size-2 && !skip_meta) {
  547. const char *mime_extra =
  548. mime_type->flags & MT_CHARSET ? "; charset=\"UTF-8\"" : "";
  549. len += snprintf(buffer + len, buffer_size-2 - len,
  550. "Content-Type: %s%s\r\n"
  551. "Content-Length: %u\r\n"
  552. "Allow: GET, HEAD\r\n"
  553. "Connection: close\r\n"
  554. "Last-Modified: %s\r\n",
  555. mime_type->mime, mime_extra,
  556. fileinfo.uncompressed_size,
  557. http_dos_date(fileinfo.dosDate));
  558. }
  559. if (len >= buffer_size-2) {
  560. err = HTTP_ERR(req, 500, "buffer_size too small");
  561. goto out;
  562. }
  563. buffer[len++] = '\r';
  564. buffer[len++] = '\n';
  565. err = httpd_send_all(req, buffer, len);
  566. if (skip_body || err) {
  567. /* No need to spend time uncompressing the file content */
  568. goto out;
  569. }
  570. if (unzOpenCurrentFile(unz) != UNZ_OK) {
  571. err = HTTP_ERR(req, 400, "Cannot open file in archive");
  572. goto out;
  573. }
  574. file_open = true;
  575. len = fileinfo.uncompressed_size;
  576. while (len) {
  577. size_t chunk = len;
  578. if (chunk > buffer_size)
  579. chunk = buffer_size;
  580. if (unzReadCurrentFile(unz, buffer, chunk) != chunk) {
  581. err = ESP_ERR_HTTPD_RESULT_TRUNC;
  582. goto out;
  583. }
  584. err = httpd_send_all(req, buffer, chunk);
  585. if (err)
  586. goto out;
  587. len -= chunk;
  588. }
  589. err = ESP_OK; /* All good! */
  590. out:
  591. if (file_open)
  592. unzCloseCurrentFile(unz);
  593. if (unz)
  594. unzClose(unz);
  595. if (zip)
  596. free(zip);
  597. if (buffer)
  598. free(buffer);
  599. return err;
  600. }
  601. /*
  602. * Match a URL against a path prefix. To keep httpd from refusing to
  603. * register subpaths, the root template does not include the leading
  604. * '/', but uri is required to have it. Do not include a trailing /
  605. * in prefix; it is implied.
  606. */
  607. static bool httpd_uri_match_prefix(const char *template, const char *uri,
  608. size_t len)
  609. {
  610. #if 0
  611. printf("[HTTP] matching URI \"%.*s\" against template \"%s\"\n",
  612. len, uri, template);
  613. #endif
  614. if (!len-- || *uri++ != '/')
  615. return false;
  616. /* Previous template character (leading '/' implied) */
  617. unsigned char tp = '/';
  618. while (1) {
  619. unsigned char t = *template++;
  620. unsigned char u;
  621. if (!len-- || !(u = *uri++)) {
  622. return !t;
  623. } else if (!t) {
  624. return tp == '/' || u == '/';
  625. } else if (t != u) {
  626. return false;
  627. }
  628. tp = t;
  629. }
  630. }
  631. /* Do not include leading or trailing /; most specific prefix first */
  632. static const httpd_uri_t uri_handlers[] = {
  633. {
  634. .uri = "sys",
  635. .method = HTTP_GET,
  636. .handler = httpd_sys_handler,
  637. .user_ctx = NULL
  638. },
  639. {
  640. .uri = "",
  641. .method = HTTP_GET,
  642. .handler = httpd_static_handler,
  643. .user_ctx = NULL
  644. },
  645. {
  646. .uri = "",
  647. .method = HTTP_HEAD,
  648. .handler = httpd_static_handler,
  649. .user_ctx = NULL
  650. },
  651. {
  652. .uri = "sys",
  653. .method = HTTP_POST,
  654. .handler = httpd_sys_handler,
  655. .user_ctx = NULL
  656. },
  657. };
  658. void my_httpd_stop(void)
  659. {
  660. if (httpd) {
  661. esp_unregister_shutdown_handler(my_httpd_stop);
  662. httpd_stop(httpd);
  663. httpd = NULL;
  664. }
  665. }
  666. void my_httpd_start(void)
  667. {
  668. httpd_config_t config = HTTPD_DEFAULT_CONFIG();
  669. httpd_handle_t server;
  670. if (httpd)
  671. return;
  672. config.task_priority = HTTPD_PRIORITY;
  673. config.max_open_sockets = 10;
  674. printf("[HTTP] Default stack size: %zu\n", config.stack_size);
  675. config.stack_size <<= 2;
  676. printf("[HTTP] Requesting stack size: %zu\n", config.stack_size);
  677. config.uri_match_fn = httpd_uri_match_prefix;
  678. if (httpd_start(&server, &config) != ESP_OK)
  679. return;
  680. esp_register_shutdown_handler(my_httpd_stop);
  681. httpd = server;
  682. for (size_t i = 0; i < ARRAY_SIZE(uri_handlers); i++) {
  683. const httpd_uri_t * const handler = &uri_handlers[i];
  684. if (httpd_register_uri_handler(httpd, handler))
  685. printf("[HTTP] failed to register URI handler: %s %s\n",
  686. http_method_str(handler->method), handler->uri);
  687. }
  688. printf("[HTTP] httpd started\n");
  689. }