Annotation of embedaddon/mpd/src/web.c, revision 1.1.1.1
1.1 misho 1:
2: /*
3: * web.c
4: *
5: * Written by Alexander Motin <mav@FreeBSD.org>
6: */
7:
8: #include "ppp.h"
9: #include "web.h"
10: #include "util.h"
11:
12:
13: /*
14: * DEFINITIONS
15: */
16:
17: /* Set menu options */
18: enum {
19: SET_OPEN,
20: SET_CLOSE,
21: SET_SELF,
22: SET_DISABLE,
23: SET_ENABLE
24: };
25:
26:
27: /*
28: * INTERNAL FUNCTIONS
29: */
30:
31: static int WebSetCommand(Context ctx, int ac, char *av[], void *arg);
32:
33: static int WebServletRun(struct http_servlet *servlet,
34: struct http_request *req, struct http_response *resp);
35: static void WebServletDestroy(struct http_servlet *servlet);
36:
37: static void WebLogger(int sev, const char *fmt, ...);
38:
39: static void WebConsoleSessionWrite(ConsoleSession cs, const char *fmt, ...);
40: static void WebConsoleSessionWriteV(ConsoleSession cs, const char *fmt, va_list vl);
41: static void WebConsoleSessionShowPrompt(ConsoleSession cs);
42:
43: static void WebRunBinCmd(FILE *f, const char *query, int priv);
44: static void WebRunCmd(FILE *f, const char *query, int priv);
45: static void WebShowSummary(FILE *f, int priv);
46:
47: /*
48: * GLOBAL VARIABLES
49: */
50:
51: const struct cmdtab WebSetCmds[] = {
52: { "open", "Open the web" ,
53: WebSetCommand, NULL, 2, (void *) SET_OPEN },
54: { "close", "Close the web" ,
55: WebSetCommand, NULL, 2, (void *) SET_CLOSE },
56: { "self {ip} [{port}]", "Set web ip and port" ,
57: WebSetCommand, NULL, 2, (void *) SET_SELF },
58: { "enable [opt ...]", "Enable web option" ,
59: WebSetCommand, NULL, 2, (void *) SET_ENABLE },
60: { "disable [opt ...]", "Disable web option" ,
61: WebSetCommand, NULL, 2, (void *) SET_DISABLE },
62: { NULL },
63: };
64:
65:
66: /*
67: * INTERNAL VARIABLES
68: */
69:
70: static const struct confinfo gConfList[] = {
71: { 0, WEB_AUTH, "auth" },
72: { 0, 0, NULL },
73: };
74:
75: static struct pevent_ctx *gWebCtx = NULL;
76:
77: /*
78: * WebInit()
79: */
80:
81: int
82: WebInit(Web w)
83: {
84: /* setup web-defaults */
85: memset(w, 0, sizeof(*w));
86:
87: Enable(&w->options, WEB_AUTH);
88:
89: ParseAddr(DEFAULT_WEB_IP, &w->addr, ALLOW_IPV4|ALLOW_IPV6);
90: w->port = DEFAULT_WEB_PORT;
91:
92: return 0;
93: }
94:
95: /*
96: * WebOpen()
97: */
98:
99: int
100: WebOpen(Web w)
101: {
102: char addrstr[INET6_ADDRSTRLEN];
103:
104: if (w->srv) {
105: Log(LG_ERR, ("web: web already running"));
106: return -1;
107: }
108:
109: gWebCtx = pevent_ctx_create(MB_WEB, NULL);
110: if (!gWebCtx) {
111: Log(LG_ERR, ("%s: error pevent_ctx_create: %d", __FUNCTION__, errno));
112: return(-1);
113: }
114:
115: if (!(w->srv = http_server_start(gWebCtx, w->addr.u.ip4,
116: w->port, NULL, "mpd web server", WebLogger))) {
117: Log(LG_ERR, ("%s: error http_server_start: %d", __FUNCTION__, errno));
118: return(-1);
119: }
120:
121: w->srvlet.arg=NULL;
122: w->srvlet.hook=NULL;
123: w->srvlet.run=WebServletRun;
124: w->srvlet.destroy=WebServletDestroy;
125:
126: if (http_server_register_servlet(w->srv, &w->srvlet, NULL, ".*", 10) < 0) {
127: Log(LG_ERR, ("%s: error http_server_register_servlet: %d", __FUNCTION__, errno));
128: return(-1);
129: }
130:
131: Log(LG_ERR, ("web: listening on %s %d",
132: u_addrtoa(&w->addr,addrstr,sizeof(addrstr)), w->port));
133: return 0;
134: }
135:
136: /*
137: * WebClose()
138: */
139:
140: int
141: WebClose(Web w)
142: {
143: if (!w->srv) {
144: Log(LG_ERR, ("web: web is not running"));
145: return -1;
146: }
147:
148: http_server_stop(&w->srv);
149: if (gWebCtx) pevent_ctx_destroy(&gWebCtx);
150:
151: return 0;
152: }
153:
154: /*
155: * WebStat()
156: */
157:
158: int
159: WebStat(Context ctx, int ac, char *av[], void *arg)
160: {
161: Web w = &gWeb;
162: char addrstr[64];
163:
164: Printf("Web configuration:\r\n");
165: Printf("\tState : %s\r\n", w->srv ? "OPENED" : "CLOSED");
166: Printf("\tIP-Address : %s\r\n", u_addrtoa(&w->addr,addrstr,sizeof(addrstr)));
167: Printf("\tPort : %d\r\n", w->port);
168:
169: Printf("Web options:\r\n");
170: OptStat(ctx, &w->options, gConfList);
171:
172: return 0;
173: }
174:
175: /*
176: * ConsoleSessionWriteV()
177: */
178:
179: static void
180: WebConsoleSessionWriteV(ConsoleSession cs, const char *fmt, va_list vl)
181: {
182: vfprintf((FILE *)(cs->cookie), fmt, vl);
183: }
184:
185: /*
186: * WebConsoleSessionWrite()
187: */
188:
189: static void
190: WebConsoleSessionWrite(ConsoleSession cs, const char *fmt, ...)
191: {
192: va_list vl;
193:
194: va_start(vl, fmt);
195: WebConsoleSessionWriteV(cs, fmt, vl);
196: va_end(vl);
197: }
198:
199: /*
200: * WebConsoleShowPrompt()
201: */
202:
203: static void
204: WebConsoleSessionShowPrompt(ConsoleSession cs)
205: {
206: if (cs->context.lnk)
207: cs->write(cs, "[%s] ", cs->context.lnk->name);
208: else if (cs->context.bund)
209: cs->write(cs, "[%s] ", cs->context.bund->name);
210: else if (cs->context.rep)
211: cs->write(cs, "[%s] ", cs->context.rep->name);
212: else
213: cs->write(cs, "[] ");
214: }
215:
216: static void
217: WebShowCSS(FILE *f)
218: {
219: fprintf(f, "body {font-family: Arial, Helvetica, Sans-Serif; background-color: #EEEEEE; }\n");
220: fprintf(f, "table {background-color: #FFFFFF; }\n");
221: fprintf(f, "th, td {padding: 0 2pt 0 2pt; }\n");
222: fprintf(f, "th {background-color: #00B000; }\n");
223: fprintf(f, "td {background-color: #EEEEEE; }\n");
224: fprintf(f, "td.r {background-color: #EECCCC; }\n");
225: fprintf(f, "td.y {background-color: #EEEEBB; }\n");
226: fprintf(f, "td.g {background-color: #BBEEBB; }\n");
227: fprintf(f, "td.d {background-color: #CCCCCC; }\n");
228: fprintf(f, "pre {background-color: #FFFFFF; }\n");
229: fprintf(f, "a, a:visited, a:link { color: blue; }\n");
230: }
231:
232: static void
233: WebShowSummary(FILE *f, int priv)
234: {
235: int b,l;
236: Bund B;
237: Link L;
238: Rep R;
239: char buf[64],buf2[64];
240:
241: fprintf(f, "<H2>Current status summary</H2>\n");
242: fprintf(f, "<table>\n");
243: fprintf(f, "<TR><TH>Bund</TH><TH colspan=2>Iface</TH><TH>IPCP</TH><TH>IPV6CP</TH><TH>CCP</TH><TH>ECP</TH>"
244: "<TH>Link</TH><TH>LCP</TH><TH>User</TH><TH colspan=2>Device</TH><TH>Peer</TH><TH>IP</TH><TH colspan=3></TH>%s</TR>",
245: priv?"<TH>State</TH>":"");
246: #define FSM_COLOR(s) (((s)==ST_OPENED)?"g":(((s)==ST_INITIAL)?"r":"y"))
247: #define PHYS_COLOR(s) (((s)==PHYS_STATE_UP)?"g":(((s)==PHYS_STATE_DOWN)?"r":"y"))
248: for (b = 0; b<gNumLinks; b++) {
249: if ((L=gLinks[b]) != NULL && L->bund == NULL && L->rep == NULL) {
250: fprintf(f, "<TR>\n");
251: fprintf(f, "<TD colspan=\"7\"> </a></TD>\n");
252: fprintf(f, "<TD class=\"%s\"><A href=\"/cmd?link%%20%s&show%%20link\">%s</a></TD>\n",
253: L->tmpl?"d":FSM_COLOR(L->lcp.fsm.state), L->name, L->name);
254: fprintf(f, "<TD class=\"%s\"><A href=\"/cmd?link%%20%s&show%%20lcp\">%s</a></TD>\n",
255: L->tmpl?"d":FSM_COLOR(L->lcp.fsm.state), L->name, FsmStateName(L->lcp.fsm.state));
256: fprintf(f, "<TD class=\"%s\"><A href=\"/cmd?link%%20%s&show%%20auth\">%s</a></TD>\n",
257: L->tmpl?"d":FSM_COLOR(L->lcp.fsm.state), L->name, L->lcp.auth.params.authname);
258: fprintf(f, "<TD class=\"%s\"><A href=\"/cmd?link%%20%s&show%%20device\">%s</a></TD>\n",
259: L->tmpl?"d":PHYS_COLOR(L->state), L->name, L->type?L->type->name:"");
260: fprintf(f, "<TD class=\"%s\"><A href=\"/cmd?link%%20%s&show%%20device\">%s</a></TD>\n",
261: L->tmpl?"d":PHYS_COLOR(L->state), L->name, gPhysStateNames[L->state]);
262: if (L->state != PHYS_STATE_DOWN) {
263: PhysGetPeerAddr(L, buf, sizeof(buf));
264: fprintf(f, "<TD>%s</TD>\n", buf);
265: fprintf(f, "<TD></TD>\n");
266: PhysGetCallingNum(L, buf, sizeof(buf));
267: PhysGetCalledNum(L, buf2, sizeof(buf2));
268: if (PhysGetOriginate(L) == LINK_ORIGINATE_REMOTE) {
269: fprintf(f, "<TD>%s</TD><TD><=</TD><TD>%s</TD>\n",
270: buf2, buf);
271: } else {
272: fprintf(f, "<TD>%s</TD><TD>=></TD><TD>%s</TD>\n",
273: buf, buf2);
274: }
275: } else {
276: fprintf(f, "<TD></TD>\n");
277: fprintf(f, "<TD></TD>\n");
278: fprintf(f, "<TD colspan=3></TD>\n");
279: }
280: if (priv) {
281: if (!L->tmpl) {
282: switch (L->state) {
283: case PHYS_STATE_DOWN:
284: fprintf(f, "<TD><A href=\"/cmd?link%%20%s&open\">[Open]</A></TD>\n",
285: L->name);
286: break;
287: case PHYS_STATE_UP:
288: fprintf(f, "<TD><A href=\"/cmd?link%%20%s&close\">[Close]</A></TD>\n",
289: L->name);
290: break;
291: default:
292: fprintf(f, "<TD><A href=\"/cmd?link%%20%s&open\">[Open]</a> <A href=\"/cmd?link%%20%s&close\">[Close]</a></TD>\n",
293: L->name, L->name);
294: }
295: } else {
296: fprintf(f, "<TD></TD>\n");
297: }
298: }
299: fprintf(f, "</TR>\n");
300: }
301: }
302: for (b = 0; b<gNumBundles; b++) {
303: if ((B=gBundles[b]) != NULL) {
304: int rows = B->n_links?B->n_links:1;
305: int first = 1;
306: fprintf(f, "<TR>\n");
307: fprintf(f, "<TD rowspan=\"%d\" class=\"%s\"><A href=\"/cmd?bund%%20%s&show%%20bund\">%s</a></TD>\n",
308: rows, B->tmpl?"d":(B->iface.up?"g":"r"), B->name, B->name);
309: fprintf(f, "<TD rowspan=\"%d\" class=\"%s\"><A href=\"/cmd?bund%%20%s&show%%20iface\">%s</a></TD>\n",
310: rows, B->tmpl?"d":(B->iface.up?"g":"r"), B->name, B->iface.ifname);
311: fprintf(f, "<TD rowspan=\"%d\" class=\"%s\"><A href=\"/cmd?bund%%20%s&show%%20iface\">%s</a></TD>\n",
312: rows, B->tmpl?"d":(B->iface.up?"g":"r"), B->name, (B->iface.up?"Up":"Down"));
313: fprintf(f, "<TD rowspan=\"%d\" class=\"%s\"><A href=\"/cmd?bund%%20%s&show%%20ipcp\">%s</a></TD>\n",
314: rows, B->tmpl?"d":FSM_COLOR(B->ipcp.fsm.state), B->name,FsmStateName(B->ipcp.fsm.state));
315: fprintf(f, "<TD rowspan=\"%d\" class=\"%s\"><A href=\"/cmd?bund%%20%s&show%%20ipv6cp\">%s</a></TD>\n",
316: rows, B->tmpl?"d":FSM_COLOR(B->ipv6cp.fsm.state), B->name,FsmStateName(B->ipv6cp.fsm.state));
317: fprintf(f, "<TD rowspan=\"%d\" class=\"%s\"><A href=\"/cmd?bund%%20%s&show%%20ccp\">%s</a></TD>\n",
318: rows, B->tmpl?"d":FSM_COLOR(B->ccp.fsm.state), B->name,FsmStateName(B->ccp.fsm.state));
319: fprintf(f, "<TD rowspan=\"%d\" class=\"%s\"><A href=\"/cmd?bund%%20%s&show%%20ecp\">%s</a></TD>\n",
320: rows, B->tmpl?"d":FSM_COLOR(B->ecp.fsm.state), B->name,FsmStateName(B->ecp.fsm.state));
321: if (B->n_links == 0) {
322: fprintf(f, "<TD colspan=\"11\"> </a></TD>\n</TR>\n");
323: }
324: for (l = 0; l < NG_PPP_MAX_LINKS; l++) {
325: if ((L=B->links[l]) != NULL) {
326: if (first)
327: first = 0;
328: else
329: fprintf(f, "<TR>\n");
330: fprintf(f, "<TD class=\"%s\"><A href=\"/cmd?link%%20%s&show%%20link\">%s</a></TD>\n",
331: L->tmpl?"d":FSM_COLOR(L->lcp.fsm.state), L->name, L->name);
332: fprintf(f, "<TD class=\"%s\"><A href=\"/cmd?link%%20%s&show%%20lcp\">%s</a></TD>\n",
333: L->tmpl?"d":FSM_COLOR(L->lcp.fsm.state), L->name, FsmStateName(L->lcp.fsm.state));
334: fprintf(f, "<TD class=\"%s\"><A href=\"/cmd?link%%20%s&show%%20auth\">%s</a></TD>\n",
335: L->tmpl?"d":FSM_COLOR(L->lcp.fsm.state), L->name, L->lcp.auth.params.authname);
336: fprintf(f, "<TD class=\"%s\"><A href=\"/cmd?link%%20%s&show%%20device\">%s</a></TD>\n",
337: L->tmpl?"d":PHYS_COLOR(L->state), L->name, L->type?L->type->name:"");
338: fprintf(f, "<TD class=\"%s\"><A href=\"/cmd?link%%20%s&show%%20device\">%s</a></TD>\n",
339: L->tmpl?"d":PHYS_COLOR(L->state), L->name, gPhysStateNames[L->state]);
340: if (L->state != PHYS_STATE_DOWN) {
341: PhysGetPeerAddr(L, buf, sizeof(buf));
342: fprintf(f, "<TD>%s</TD>\n", buf);
343: if (L->bund != NULL)
344: fprintf(f, "<TD>%s</TD>\n", inet_ntoa(L->bund->ipcp.peer_addr));
345: else
346: fprintf(f, "<TD></TD>\n");
347: PhysGetCallingNum(L, buf, sizeof(buf));
348: PhysGetCalledNum(L, buf2, sizeof(buf2));
349: if (PhysGetOriginate(L) == LINK_ORIGINATE_REMOTE) {
350: fprintf(f, "<TD>%s</TD><TD><=</TD><TD>%s</TD>\n",
351: buf2, buf);
352: } else {
353: fprintf(f, "<TD>%s</TD><TD>=></TD><TD>%s</TD>\n",
354: buf, buf2);
355: }
356: } else {
357: fprintf(f, "<TD></TD>\n");
358: fprintf(f, "<TD></TD>\n");
359: fprintf(f, "<TD colspan=3></TD>\n");
360: }
361: if (priv) {
362: switch (L->state) {
363: case PHYS_STATE_DOWN:
364: fprintf(f, "<TD><A href=\"/cmd?link%%20%s&open\">[Open]</A></TD>\n",
365: L->name);
366: break;
367: case PHYS_STATE_UP:
368: fprintf(f, "<TD><A href=\"/cmd?link%%20%s&close\">[Close]</A></TD>\n",
369: L->name);
370: break;
371: default:
372: fprintf(f, "<TD><A href=\"/cmd?link%%20%s&open\">[Open]</a> <A href=\"/cmd?link%%20%s&close\">[Close]</a></TD>\n",
373: L->name, L->name);
374: }
375: }
376: fprintf(f, "</TR>\n");
377: }
378: }
379: }
380: }
381: for (b = 0; b<gNumReps; b++) {
382: if ((R=gReps[b]) != NULL) {
383: int shown = 0;
384: #define FSM_COLOR(s) (((s)==ST_OPENED)?"g":(((s)==ST_INITIAL)?"r":"y"))
385: #define PHYS_COLOR(s) (((s)==PHYS_STATE_UP)?"g":(((s)==PHYS_STATE_DOWN)?"r":"y"))
386: int rows = (R->links[0]?1:0) + (R->links[1]?1:0);
387: if (rows == 0)
388: rows = 1;
389: fprintf(f, "<TR>\n");
390: fprintf(f, "<TD rowspan=\"%d\" colspan=6>Repeater</TD>\n", rows);
391: fprintf(f, "<TD rowspan=\"%d\" class=\"%s\"><A href=\"/cmd?rep%%20%s&show%%20repeater\">%s</a></TD>\n",
392: rows, R->p_up?"g":"r", R->name, R->name);
393: for (l = 0; l < 2; l++) {
394: if ((L=R->links[l]) != NULL) {
395: if (shown)
396: fprintf(f, "<TR>\n");
397: fprintf(f, "<TD class=\"%s\"><A href=\"/cmd?link%%20%s&show%%20device\">%s</a></TD>\n",
398: PHYS_COLOR(L->state), L->name, L->name);
399: fprintf(f, "<TD colspan=2></TD>\n");
400: fprintf(f, "<TD class=\"%s\"><A href=\"/cmd?link%%20%s&show%%20device\">%s</a></TD>\n",
401: PHYS_COLOR(L->state), L->name, L->type?L->type->name:"");
402: fprintf(f, "<TD class=\"%s\"><A href=\"/cmd?link%%20%s&show%%20device\">%s</a></TD>\n",
403: PHYS_COLOR(L->state), L->name, gPhysStateNames[L->state]);
404: if (L->state != PHYS_STATE_DOWN) {
405: PhysGetPeerAddr(L, buf, sizeof(buf));
406: fprintf(f, "<TD>%s</TD>\n", buf);
407: if (L->bund != NULL)
408: fprintf(f, "<TD>%s</TD>\n", inet_ntoa(L->bund->ipcp.peer_addr));
409: else
410: fprintf(f, "<TD></TD>\n");
411: PhysGetCallingNum(L, buf, sizeof(buf));
412: PhysGetCalledNum(L, buf2, sizeof(buf2));
413: if (PhysGetOriginate(L) == LINK_ORIGINATE_REMOTE) {
414: fprintf(f, "<TD>%s</TD><TD><=</TD><TD>%s</TD>\n",
415: buf2, buf);
416: } else {
417: fprintf(f, "<TD>%s</TD><TD>=></TD><TD>%s</TD>\n",
418: buf, buf2);
419: }
420: } else {
421: fprintf(f, "<TD></TD>\n");
422: fprintf(f, "<TD></TD>\n");
423: fprintf(f, "<TD colspan=3></TD>\n");
424: }
425: fprintf(f, "<TD></TD>\n");
426: fprintf(f, "</TR>\n");
427:
428: shown = 1;
429: }
430: }
431: if (!shown) {
432: fprintf(f, "<TD colspan = \"11\"></TD>\n");
433: fprintf(f, "</TR>\n");
434: }
435: }
436: }
437: fprintf(f, "</TABLE>\n");
438: }
439:
440: static void
441: WebRunBinCmd(FILE *f, const char *query, int priv)
442: {
443: Console c = &gConsole;
444: struct console_session css;
445: ConsoleSession cs = &css;
446: char *buf;
447: char *tmp;
448: int argc, k;
449: char *argv[MAX_CONSOLE_ARGS];
450:
451: memset(cs, 0, sizeof(*cs));
452:
453: cs->cookie = f;
454: cs->console = c;
455: cs->close = NULL;
456: cs->write = WebConsoleSessionWrite;
457: cs->writev = WebConsoleSessionWriteV;
458: cs->prompt = WebConsoleSessionShowPrompt;
459: cs->context.cs = cs;
460: cs->context.priv = priv;
461:
462: tmp = buf = Mstrdup(MB_WEB, query);
463: for (argc = 0; (argv[argc] = strsep(&tmp, "&")) != NULL;)
464: if (argv[argc][0] != '\0')
465: if (++argc >= MAX_CONSOLE_ARGS)
466: break;
467:
468: for (k = 0; k < argc; k++) {
469: int ac, rtn;
470: char *av[MAX_CONSOLE_ARGS];
471: char *buf1;
472:
473: buf1 = Malloc(MB_WEB, strlen(argv[k]) + 1);
474: http_request_url_decode(argv[k], buf1);
475: Log2(LG_CONSOLE, ("[%s] WEB: %s",
476: cs->context.lnk ? cs->context.lnk->name :
477: (cs->context.bund? cs->context.bund->name : ""),
478: buf1));
479: ac = ParseLine(buf1, av, sizeof(av) / sizeof(*av), 0);
480: cs->context.errmsg[0] = 0;
481: rtn = DoCommandTab(&cs->context, gCommands, ac, av);
482: Freee(buf1);
483: fprintf(f, "RESULT: %d %s\n", rtn, cs->context.errmsg);
484: }
485: Freee(buf);
486: RESETREF(cs->context.lnk, NULL);
487: RESETREF(cs->context.bund, NULL);
488: RESETREF(cs->context.rep, NULL);
489: }
490:
491: static void
492: WebRunCmd(FILE *f, const char *query, int priv)
493: {
494: Console c = &gConsole;
495: struct console_session css;
496: ConsoleSession cs = &css;
497: char *buf;
498: char *tmp;
499: int argc, k;
500: char *argv[MAX_CONSOLE_ARGS];
501:
502: memset(cs, 0, sizeof(*cs));
503:
504: cs->cookie = f;
505: cs->console = c;
506: cs->close = NULL;
507: cs->write = WebConsoleSessionWrite;
508: cs->writev = WebConsoleSessionWriteV;
509: cs->prompt = WebConsoleSessionShowPrompt;
510: cs->context.cs = cs;
511: cs->context.priv = priv;
512:
513: tmp = buf = Mstrdup(MB_WEB, query);
514: for (argc = 0; (argv[argc] = strsep(&tmp, "&")) != NULL;)
515: if (argv[argc][0] != '\0')
516: if (++argc >= MAX_CONSOLE_ARGS)
517: break;
518:
519: fprintf(f, "<P><A href=\"/\"><< Back</A></P>\n");
520:
521: if (argc == 0) {
522: fprintf(f, "<P>No command cpecified!</P>\n");
523: goto done;
524: }
525:
526: fprintf(f, "<PRE>\n");
527: for (k = 0; k < argc; k++) {
528: int ac;
529: char *av[MAX_CONSOLE_ARGS];
530: char *buf1;
531:
532: buf1 = Malloc(MB_WEB, strlen(argv[k]) + 1);
533: http_request_url_decode(argv[k], buf1);
534: Log2(LG_CONSOLE, ("[%s] WEB: %s",
535: cs->context.lnk ? cs->context.lnk->name :
536: (cs->context.bund? cs->context.bund->name : ""),
537: buf1));
538:
539: cs->prompt(cs);
540: cs->write(cs, "%s\n", buf1);
541:
542: ac = ParseLine(buf1, av, sizeof(av) / sizeof(*av), 0);
543: DoCommand(&cs->context, ac, av, NULL, 0);
544: Freee(buf1);
545: }
546: fprintf(f, "</PRE>\n");
547: done:
548: Freee(buf);
549: fprintf(f, "<P><A href=\"/\"><< Back</A></P>\n");
550: RESETREF(cs->context.lnk, NULL);
551: RESETREF(cs->context.bund, NULL);
552: RESETREF(cs->context.rep, NULL);
553: }
554:
555: static void
556: WebServletRunCleanup(void *cookie) {
557: GIANT_MUTEX_UNLOCK();
558: }
559:
560: static int
561: WebServletRun(struct http_servlet *servlet,
562: struct http_request *req, struct http_response *resp)
563: {
564: FILE *f;
565: const char *path;
566: const char *query;
567: int priv = 0;
568:
569: if (Enabled(&gWeb.options, WEB_AUTH)) {
570: const char *username;
571: const char *password;
572: ConsoleUser u;
573: struct console_user iu;
574:
575: /* Get username and password */
576: if ((username = http_request_get_username(req)) == NULL)
577: username = "";
578: if ((password = http_request_get_password(req)) == NULL)
579: password = "";
580:
581: strlcpy(iu.username, username, sizeof(iu.username));
582: RWLOCK_RDLOCK(gUsersLock);
583: u = ghash_get(gUsers, &iu);
584: RWLOCK_UNLOCK(gUsersLock);
585:
586: if ((u == NULL) || strcmp(u->password, password)) {
587: http_response_send_basic_auth(resp, "Access Restricted");
588: return (1);
589: }
590: priv = u->priv;
591: }
592:
593: if (!(f = http_response_get_output(resp, 1))) {
594: return 0;
595: }
596: if (!(path = http_request_get_path(req)))
597: return 0;
598: if (!(query = http_request_get_query_string(req)))
599: return 0;
600:
601: if (!strcmp(path,"/mpd.css")) {
602: http_response_set_header(resp, 0, "Content-Type", "text/css");
603: WebShowCSS(f);
604: } else if (!strcmp(path,"/bincmd")) {
605: http_response_set_header(resp, 0, "Content-Type", "text/plain");
606: http_response_set_header(resp, 1, "Pragma", "no-cache");
607: http_response_set_header(resp, 1, "Cache-Control", "no-cache, must-revalidate");
608:
609: pthread_cleanup_push(WebServletRunCleanup, NULL);
610: GIANT_MUTEX_LOCK();
611: WebRunBinCmd(f, query, priv);
612: GIANT_MUTEX_UNLOCK();
613: pthread_cleanup_pop(0);
614: } else if (!strcmp(path,"/") || !strcmp(path,"/cmd")) {
615: http_response_set_header(resp, 0, "Content-Type", "text/html");
616: http_response_set_header(resp, 1, "Pragma", "no-cache");
617: http_response_set_header(resp, 1, "Cache-Control", "no-cache, must-revalidate");
618:
619: pthread_cleanup_push(WebServletRunCleanup, NULL);
620: GIANT_MUTEX_LOCK();
621: fprintf(f, "<!DOCTYPE HTML "
622: "PUBLIC \"-//W3C//DTD HTML 4.01//EN\" "
623: "\"http://www.w3.org/TR/html4/strict.dtd\">\n");
624: fprintf(f, "<HTML>\n");
625: fprintf(f, "<HEAD><TITLE>Multi-link PPP Daemon for FreeBSD (mpd)</TITLE>\n");
626: fprintf(f, "<LINK rel='stylesheet' href='/mpd.css' type='text/css'>\n");
627: fprintf(f, "</HEAD>\n<BODY>\n");
628: fprintf(f, "<H1>Multi-link PPP Daemon for FreeBSD</H1>\n");
629:
630: if (!strcmp(path,"/"))
631: WebShowSummary(f, priv);
632: else if (!strcmp(path,"/cmd"))
633: WebRunCmd(f, query, priv);
634:
635: GIANT_MUTEX_UNLOCK();
636: pthread_cleanup_pop(0);
637:
638: fprintf(f, "</BODY>\n</HTML>\n");
639: } else {
640: http_response_send_error(resp, 404, NULL);
641: }
642: return 1;
643: }
644:
645: static void
646: WebServletDestroy(struct http_servlet *servlet)
647: {
648: }
649:
650: static void
651: WebLogger(int sev, const char *fmt, ...)
652: {
653: va_list args;
654:
655: va_start(args, fmt);
656: vLogPrintf(fmt, args);
657: va_end(args);
658: }
659:
660: /*
661: * WebSetCommand()
662: */
663:
664: static int
665: WebSetCommand(Context ctx, int ac, char *av[], void *arg)
666: {
667: Web w = &gWeb;
668: int port;
669:
670: switch ((intptr_t)arg) {
671:
672: case SET_OPEN:
673: WebOpen(w);
674: break;
675:
676: case SET_CLOSE:
677: WebClose(w);
678: break;
679:
680: case SET_ENABLE:
681: EnableCommand(ac, av, &w->options, gConfList);
682: break;
683:
684: case SET_DISABLE:
685: DisableCommand(ac, av, &w->options, gConfList);
686: break;
687:
688: case SET_SELF:
689: if (ac < 1 || ac > 2)
690: return(-1);
691:
692: if (!ParseAddr(av[0],&w->addr, ALLOW_IPV4))
693: Error("Bogus IP address given %s", av[0]);
694:
695: if (ac == 2) {
696: port = strtol(av[1], NULL, 10);
697: if (port < 1 || port > 65535)
698: Error("Bogus port given %s", av[1]);
699: w->port=port;
700: }
701: break;
702:
703: default:
704: return(-1);
705:
706: }
707:
708: return 0;
709: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to web.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / mpd / src