55b2c410e35714702bfd6aaf0d8159ca8076e693
2 * uhttpd - Tiny single-threaded httpd - Utility functions
4 * Copyright (C) 2010 Jo-Philipp Wich <xm@subsignal.org>
6 * Licensed under the Apache License, Version 2.0 (the "License");
7 * you may not use this file except in compliance with the License.
8 * You may obtain a copy of the License at
10 * http://www.apache.org/licenses/LICENSE-2.0
12 * Unless required by applicable law or agreed to in writing, software
13 * distributed under the License is distributed on an "AS IS" BASIS,
14 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 * See the License for the specific language governing permissions and
16 * limitations under the License.
19 #define _XOPEN_SOURCE 500 /* crypt() */
20 #define _BSD_SOURCE /* strcasecmp(), strncasecmp() */
23 #include "uhttpd-utils.h"
26 #include "uhttpd-tls.h"
30 static char *uh_index_files
[] = {
38 const char * sa_straddr(void *sa
)
40 static char str
[INET6_ADDRSTRLEN
];
41 struct sockaddr_in
*v4
= (struct sockaddr_in
*)sa
;
42 struct sockaddr_in6
*v6
= (struct sockaddr_in6
*)sa
;
44 if( v4
->sin_family
== AF_INET
)
45 return inet_ntop(AF_INET
, &(v4
->sin_addr
), str
, sizeof(str
));
47 return inet_ntop(AF_INET6
, &(v6
->sin6_addr
), str
, sizeof(str
));
50 const char * sa_strport(void *sa
)
53 snprintf(str
, sizeof(str
), "%i", sa_port(sa
));
59 return ntohs(((struct sockaddr_in6
*)sa
)->sin6_port
);
62 /* Simple strstr() like function that takes len arguments for both haystack and needle. */
63 char *strfind(char *haystack
, int hslen
, const char *needle
, int ndlen
)
68 for( i
= 0; i
< hslen
; i
++ )
70 if( haystack
[i
] == needle
[0] )
72 match
= ((ndlen
== 1) || ((i
+ ndlen
) <= hslen
));
74 for( j
= 1; (j
< ndlen
) && ((i
+ j
) < hslen
); j
++ )
76 if( haystack
[i
+j
] != needle
[j
] )
91 /* interruptable select() */
92 int select_intr(int n
, fd_set
*r
, fd_set
*w
, fd_set
*e
, struct timeval
*t
)
99 sigaddset(&ssn
, SIGCHLD
);
100 sigprocmask(SIG_UNBLOCK
, &ssn
, &sso
);
102 rv
= select(n
, r
, w
, e
, t
);
104 /* restore signal mask */
105 sigprocmask(SIG_SETMASK
, &sso
, NULL
);
111 int uh_tcp_send(struct client
*cl
, const char *buf
, int len
)
114 struct timeval timeout
;
117 FD_SET(cl
->socket
, &writer
);
120 timeout
.tv_usec
= 500000;
122 if( select(cl
->socket
+ 1, NULL
, &writer
, NULL
, &timeout
) > 0 )
126 return cl
->server
->conf
->tls_send(cl
, (void *)buf
, len
);
129 return send(cl
->socket
, buf
, len
, 0);
135 int uh_tcp_peek(struct client
*cl
, char *buf
, int len
)
137 int sz
= uh_tcp_recv(cl
, buf
, len
);
139 /* store received data in peek buffer */
143 memcpy(cl
->peekbuf
, buf
, sz
);
149 int uh_tcp_recv(struct client
*cl
, char *buf
, int len
)
154 /* first serve data from peek buffer */
155 if( cl
->peeklen
> 0 )
157 sz
= min(cl
->peeklen
, len
);
158 len
-= sz
; cl
->peeklen
-= sz
;
160 memcpy(buf
, cl
->peekbuf
, sz
);
161 memmove(cl
->peekbuf
, &cl
->peekbuf
[sz
], cl
->peeklen
);
164 /* caller wants more */
169 rsz
= cl
->server
->conf
->tls_recv(cl
, (void *)&buf
[sz
], len
);
172 rsz
= recv(cl
->socket
, (void *)&buf
[sz
], len
, 0);
174 if( (sz
== 0) || (rsz
> 0) )
182 do { if( x < 0 ) return -1; } while(0)
184 int uh_http_sendhf(struct client
*cl
, int code
, const char *summary
, const char *fmt
, ...)
188 char buffer
[UH_LIMIT_MSGHEAD
];
191 len
= snprintf(buffer
, sizeof(buffer
),
192 "HTTP/1.1 %03i %s\r\n"
193 "Connection: close\r\n"
194 "Content-Type: text/plain\r\n"
195 "Transfer-Encoding: chunked\r\n\r\n",
199 ensure(uh_tcp_send(cl
, buffer
, len
));
202 len
= vsnprintf(buffer
, sizeof(buffer
), fmt
, ap
);
205 ensure(uh_http_sendc(cl
, buffer
, len
));
206 ensure(uh_http_sendc(cl
, NULL
, 0));
212 int uh_http_sendc(struct client
*cl
, const char *data
, int len
)
222 clen
= snprintf(chunk
, sizeof(chunk
), "%X\r\n", len
);
223 ensure(uh_tcp_send(cl
, chunk
, clen
));
224 ensure(uh_tcp_send(cl
, data
, len
));
225 ensure(uh_tcp_send(cl
, "\r\n", 2));
229 ensure(uh_tcp_send(cl
, "0\r\n\r\n", 5));
236 struct client
*cl
, struct http_request
*req
, const char *fmt
, ...
239 char buffer
[UH_LIMIT_MSGHEAD
];
243 len
= vsnprintf(buffer
, sizeof(buffer
), fmt
, ap
);
246 if( (req
!= NULL
) && (req
->version
> 1.0) )
247 ensure(uh_http_sendc(cl
, buffer
, len
));
249 ensure(uh_tcp_send(cl
, buffer
, len
));
255 struct client
*cl
, struct http_request
*req
, const char *buf
, int len
260 if( (req
!= NULL
) && (req
->version
> 1.0) )
261 ensure(uh_http_sendc(cl
, buf
, len
));
263 ensure(uh_tcp_send(cl
, buf
, len
));
269 int uh_urldecode(char *buf
, int blen
, const char *src
, int slen
)
275 (((x) <= '9') ? ((x) - '0') : \
276 (((x) <= 'F') ? ((x) - 'A' + 10) : \
279 for( i
= 0; (i
<= slen
) && (i
<= blen
); i
++ )
283 if( ((i
+2) <= slen
) && isxdigit(src
[i
+1]) && isxdigit(src
[i
+2]) )
285 buf
[len
++] = (char)(16 * hex(src
[i
+1]) + hex(src
[i
+2]));
302 int uh_urlencode(char *buf
, int blen
, const char *src
, int slen
)
306 const char hex
[] = "0123456789abcdef";
308 for( i
= 0; (i
<= slen
) && (i
<= blen
); i
++ )
310 if( isalnum(src
[i
]) || (src
[i
] == '-') || (src
[i
] == '_') ||
311 (src
[i
] == '.') || (src
[i
] == '~') )
315 else if( (len
+3) <= blen
)
318 buf
[len
++] = hex
[(src
[i
] >> 4) & 15];
319 buf
[len
++] = hex
[(src
[i
] & 15) & 15];
330 int uh_b64decode(char *buf
, int blen
, const unsigned char *src
, int slen
)
335 unsigned int cin
= 0;
336 unsigned int cout
= 0;
339 for( i
= 0; (i
<= slen
) && (src
[i
] != 0); i
++ )
343 if( (cin
>= '0') && (cin
<= '9') )
344 cin
= cin
- '0' + 52;
345 else if( (cin
>= 'A') && (cin
<= 'Z') )
347 else if( (cin
>= 'a') && (cin
<= 'z') )
348 cin
= cin
- 'a' + 26;
349 else if( cin
== '+' )
351 else if( cin
== '/' )
353 else if( cin
== '=' )
358 cout
= (cout
<< 6) | cin
;
362 if( (len
+ 3) < blen
)
364 buf
[len
++] = (char)(cout
>> 16);
365 buf
[len
++] = (char)(cout
>> 8);
366 buf
[len
++] = (char)(cout
);
380 struct path_info
* uh_path_lookup(struct client
*cl
, const char *url
)
382 static char path_phys
[PATH_MAX
];
383 static char path_info
[PATH_MAX
];
384 static struct path_info p
;
386 char buffer
[UH_LIMIT_MSGHEAD
];
387 char *docroot
= cl
->server
->conf
->docroot
;
388 char *pathptr
= NULL
;
394 memset(path_phys
, 0, sizeof(path_phys
));
395 memset(path_info
, 0, sizeof(path_info
));
396 memset(buffer
, 0, sizeof(buffer
));
397 memset(&p
, 0, sizeof(p
));
400 memcpy(buffer
, docroot
,
401 min(strlen(docroot
), sizeof(buffer
) - 1));
403 /* separate query string from url */
404 if( (pathptr
= strchr(url
, '?')) != NULL
)
406 p
.query
= pathptr
[1] ? pathptr
+ 1 : NULL
;
408 /* urldecode component w/o query */
411 &buffer
[strlen(docroot
)],
412 sizeof(buffer
) - strlen(docroot
) - 1,
413 url
, (int)(pathptr
- url
) - 1
417 /* no query string, decode all of url */
421 &buffer
[strlen(docroot
)],
422 sizeof(buffer
) - strlen(docroot
) - 1,
427 /* create canon path */
428 for( i
= strlen(buffer
); i
>= 0; i
-- )
430 if( (buffer
[i
] == 0) || (buffer
[i
] == '/') )
432 memset(path_info
, 0, sizeof(path_info
));
433 memcpy(path_info
, buffer
, min(i
+ 1, sizeof(path_info
) - 1));
435 if( realpath(path_info
, path_phys
) )
437 memset(path_info
, 0, sizeof(path_info
));
438 memcpy(path_info
, &buffer
[i
],
439 min(strlen(buffer
) - i
, sizeof(path_info
) - 1));
446 /* check whether found path is within docroot */
447 if( strncmp(path_phys
, docroot
, strlen(docroot
)) ||
448 ((path_phys
[strlen(docroot
)] != 0) &&
449 (path_phys
[strlen(docroot
)] != '/'))
454 /* test current path */
455 if( ! stat(path_phys
, &p
.stat
) )
457 /* is a regular file */
458 if( p
.stat
.st_mode
& S_IFREG
)
462 p
.name
= &path_phys
[strlen(docroot
)];
463 p
.info
= path_info
[0] ? path_info
: NULL
;
467 else if( (p
.stat
.st_mode
& S_IFDIR
) && !strlen(path_info
) )
469 /* ensure trailing slash */
470 if( path_phys
[strlen(path_phys
)-1] != '/' )
471 path_phys
[strlen(path_phys
)] = '/';
473 /* try to locate index file */
474 memset(buffer
, 0, sizeof(buffer
));
475 memcpy(buffer
, path_phys
, sizeof(buffer
));
476 pathptr
= &buffer
[strlen(buffer
)];
478 for( i
= 0; i
< array_size(uh_index_files
); i
++ )
480 strncat(buffer
, uh_index_files
[i
], sizeof(buffer
));
482 if( !stat(buffer
, &s
) && (s
.st_mode
& S_IFREG
) )
484 memcpy(path_phys
, buffer
, sizeof(path_phys
));
485 memcpy(&p
.stat
, &s
, sizeof(p
.stat
));
494 p
.name
= &path_phys
[strlen(docroot
)];
498 return p
.phys
? &p
: NULL
;
502 static char uh_realms
[UH_LIMIT_AUTHREALMS
* sizeof(struct auth_realm
)] = { 0 };
503 static int uh_realm_count
= 0;
505 struct auth_realm
* uh_auth_add(char *path
, char *user
, char *pass
)
507 struct auth_realm
*new = NULL
;
511 if( uh_realm_count
< UH_LIMIT_AUTHREALMS
)
513 new = (struct auth_realm
*)
514 &uh_realms
[uh_realm_count
* sizeof(struct auth_realm
)];
516 memset(new, 0, sizeof(struct auth_realm
));
518 memcpy(new->path
, path
,
519 min(strlen(path
), sizeof(new->path
) - 1));
521 memcpy(new->user
, user
,
522 min(strlen(user
), sizeof(new->user
) - 1));
524 /* given password refers to a passwd entry */
525 if( (strlen(pass
) > 3) && !strncmp(pass
, "$p$", 3) )
527 /* try to resolve shadow entry */
528 if( ((spwd
= getspnam(&pass
[3])) != NULL
) && spwd
->sp_pwdp
)
530 memcpy(new->pass
, spwd
->sp_pwdp
,
531 min(strlen(spwd
->sp_pwdp
), sizeof(new->pass
) - 1));
534 /* try to resolve passwd entry */
535 else if( ((pwd
= getpwnam(&pass
[3])) != NULL
) && pwd
->pw_passwd
&&
536 (pwd
->pw_passwd
[0] != '!') && (pwd
->pw_passwd
[0] != 0)
538 memcpy(new->pass
, pwd
->pw_passwd
,
539 min(strlen(pwd
->pw_passwd
), sizeof(new->pass
) - 1));
546 memcpy(new->pass
, pass
,
547 min(strlen(pass
), sizeof(new->pass
) - 1));
557 struct client
*cl
, struct http_request
*req
, struct path_info
*pi
559 int i
, plen
, rlen
, protected;
560 char buffer
[UH_LIMIT_MSGHEAD
];
564 struct auth_realm
*realm
= NULL
;
566 plen
= strlen(pi
->name
);
569 /* check whether at least one realm covers the requested url */
570 for( i
= 0; i
< uh_realm_count
; i
++ )
572 realm
= (struct auth_realm
*)
573 &uh_realms
[i
* sizeof(struct auth_realm
)];
575 rlen
= strlen(realm
->path
);
577 if( (plen
>= rlen
) && !strncasecmp(pi
->name
, realm
->path
, rlen
) )
585 /* requested resource is covered by a realm */
588 /* try to get client auth info */
589 foreach_header(i
, req
->headers
)
591 if( !strcasecmp(req
->headers
[i
], "Authorization") &&
592 (strlen(req
->headers
[i
+1]) > 6) &&
593 !strncasecmp(req
->headers
[i
+1], "Basic ", 6)
595 memset(buffer
, 0, sizeof(buffer
));
596 uh_b64decode(buffer
, sizeof(buffer
) - 1,
597 (unsigned char *) &req
->headers
[i
+1][6],
598 strlen(req
->headers
[i
+1]) - 6);
600 if( (pass
= strchr(buffer
, ':')) != NULL
)
610 /* have client auth */
613 /* find matching realm */
614 for( i
= 0, realm
= NULL
; i
< uh_realm_count
; i
++ )
616 realm
= (struct auth_realm
*)
617 &uh_realms
[i
* sizeof(struct auth_realm
)];
619 rlen
= strlen(realm
->path
);
621 if( (plen
>= rlen
) &&
622 !strncasecmp(pi
->name
, realm
->path
, rlen
) &&
623 !strcmp(user
, realm
->user
)
632 /* found a realm matching the username */
635 /* is a crypt passwd */
636 if( realm
->pass
[0] == '$' )
637 pass
= crypt(pass
, realm
->pass
);
639 /* check user pass */
640 if( !strcmp(pass
, realm
->pass
) )
646 uh_http_sendf(cl
, NULL
,
647 "HTTP/%.1f 401 Authorization Required\r\n"
648 "WWW-Authenticate: Basic realm=\"%s\"\r\n"
649 "Content-Type: text/plain\r\n"
650 "Content-Length: 23\r\n\r\n"
651 "Authorization Required\n",
652 req
->version
, cl
->server
->conf
->realm
662 static char uh_listeners
[UH_LIMIT_LISTENERS
* sizeof(struct listener
)] = { 0 };
663 static char uh_clients
[UH_LIMIT_CLIENTS
* sizeof(struct client
)] = { 0 };
665 static int uh_listener_count
= 0;
666 static int uh_client_count
= 0;
669 struct listener
* uh_listener_add(int sock
, struct config
*conf
)
671 struct listener
*new = NULL
;
674 if( uh_listener_count
< UH_LIMIT_LISTENERS
)
676 new = (struct listener
*)
677 &uh_listeners
[uh_listener_count
* sizeof(struct listener
)];
682 /* get local endpoint addr */
683 sl
= sizeof(struct sockaddr_in6
);
684 memset(&(new->addr
), 0, sl
);
685 getsockname(sock
, (struct sockaddr
*) &(new->addr
), &sl
);
693 struct listener
* uh_listener_lookup(int sock
)
695 struct listener
*cur
= NULL
;
698 for( i
= 0; i
< uh_listener_count
; i
++ )
700 cur
= (struct listener
*) &uh_listeners
[i
* sizeof(struct listener
)];
702 if( cur
->socket
== sock
)
710 struct client
* uh_client_add(int sock
, struct listener
*serv
)
712 struct client
*new = NULL
;
715 if( uh_client_count
< UH_LIMIT_CLIENTS
)
717 new = (struct client
*)
718 &uh_clients
[uh_client_count
* sizeof(struct client
)];
723 /* get remote endpoint addr */
724 sl
= sizeof(struct sockaddr_in6
);
725 memset(&(new->peeraddr
), 0, sl
);
726 getpeername(sock
, (struct sockaddr
*) &(new->peeraddr
), &sl
);
728 /* get local endpoint addr */
729 sl
= sizeof(struct sockaddr_in6
);
730 memset(&(new->servaddr
), 0, sl
);
731 getsockname(sock
, (struct sockaddr
*) &(new->servaddr
), &sl
);
739 struct client
* uh_client_lookup(int sock
)
741 struct client
*cur
= NULL
;
744 for( i
= 0; i
< uh_client_count
; i
++ )
746 cur
= (struct client
*) &uh_clients
[i
* sizeof(struct client
)];
748 if( cur
->socket
== sock
)
755 void uh_client_remove(int sock
)
757 struct client
*del
= uh_client_lookup(sock
);
761 memmove(del
, del
+ 1,
762 sizeof(uh_clients
) - (int)((char *)del
- uh_clients
) - sizeof(struct client
));
This page took 0.085537 seconds and 3 git commands to generate.