d4708
/
opentracker
mirror of git://erdgeist.org/opentracker
1
0
Fork 0
Code Issues Projects Releases Wiki Activity
Browse Source

url parser

dynamic-accesslists
denis 18 years ago
parent
1c1fd9fe4a
commit
0a3dc7b4ce
1 changed files with 254 additions and 159 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 413
      opentracker.c

413
opentracker.c
Unescape View File

@ -31,177 +31,272 @@ struct http_data {
io_batch iob; io_batch iob;
char* hdrbuf; char* hdrbuf;
int hlen; int hlen;
char ip[16];
}; };
int header_complete(struct http_data* r) { int header_complete(struct http_data* r)
long i; {
long l=array_bytes(&r->r); long i;
const char* c=array_start(&r->r);
for (i=0; i+1<l; ++i) { long l = array_bytes(&r->r);
if (c[i]=='\n' && c[i+1]=='\n') const char* c = array_start(&r->r);
return i+2;
if (i+3<l && for (i=0; i+1<l; ++i)
c[i]=='\r' && c[i+1]=='\n' && {
c[i+2]=='\r' && c[i+3]=='\n') if (c[i]=='\n' && c[i+1]=='\n')
return i+4; return i+2;
}
return 0; if (i+3<l && c[i]=='\r' && c[i+1]=='\n' && c[i+2]=='\r' && c[i+3]=='\n')
return i+4;
}
return 0;
} }
void httperror(struct http_data* r,const char* title,const char* message) { void httperror(struct http_data* r,const char* title,const char* message)
char* c; {
c=r->hdrbuf=(char*)malloc(strlen(message)+strlen(title)+200); char* c;
if (!c) { c=r->hdrbuf=(char*)malloc(strlen(message)+strlen(title)+200);
r->hdrbuf="HTTP/1.0 500 internal error\r\nContent-Type: text/plain\r\nConnection: close\r\n\r\nout of memory\n";
r->hlen=strlen(r->hdrbuf); if (!c)
} else { {
c+=fmt_str(c,"HTTP/1.0 "); r->hdrbuf="HTTP/1.0 500 internal error\r\nContent-Type: text/plain\r\nConnection: close\r\n\r\nout of memory\n";
c+=fmt_str(c,title); r->hlen=strlen(r->hdrbuf);
c+=fmt_str(c,"\r\nContent-Type: text/html\r\nConnection: close\r\nContent-Length: "); }
c+=fmt_ulong(c,strlen(message)+strlen(title)+16-4); else
c+=fmt_str(c,"\r\n\r\n<title>"); {
c+=fmt_str(c,title+4); c+=fmt_str(c,"HTTP/1.0 ");
c+=fmt_str(c,"</title>\n"); c+=fmt_str(c,title);
r->hlen=c - r->hdrbuf; c+=fmt_str(c,"\r\nContent-Type: text/html\r\nConnection: close\r\nContent-Length: ");
} c+=fmt_ulong(c,strlen(message)+strlen(title)+16-4);
iob_addbuf(&r->iob,r->hdrbuf,r->hlen); c+=fmt_str(c,"\r\n\r\n<title>");
c+=fmt_str(c,title+4);
c+=fmt_str(c,"</title>\n");
r->hlen=c - r->hdrbuf;
}
iob_addbuf(&r->iob,r->hdrbuf,r->hlen);
} }
const char* http_header(struct http_data* r,const char* h) { // bestimmten http parameter auslesen und adresse zurueckgeben
long i;
long l=array_bytes(&r->r); const char* http_header(struct http_data* r,const char* h)
long sl=strlen(h); {
const char* c=array_start(&r->r); long i;
for (i=0; i+sl+2<l; ++i)
if (c[i]=='\n' && case_equalb(c+i+1,sl,h) && c[i+sl+1]==':') { long l = array_bytes(&r->r);
c+=i+sl+1; long sl = strlen(h);
if (*c==' ' || *c=='\t') ++c; const char* c = array_start(&r->r);
return c;
} for (i=0; i+sl+2<l; ++i)
return 0; {
if (c[i]=='\n' && case_equalb(c+i+1,sl,h) && c[i+sl+1]==':')
{
c+=i+sl+1;
if (*c==' ' || *c=='\t') ++c;
return c;
}
return 0;
}
} }
void httpresponse(struct http_data* h,int64 s) { void httpresponse(struct http_data* h,int64 s)
char* c; {
array_cat0(&h->r); char* c;
c=array_start(&h->r); array_cat0(&h->r);
if (byte_diff(c,4,"GET ")) {
c = array_start(&h->r);
if (byte_diff(c,4,"GET "))
{
e400: e400:
httperror(h,"400 Invalid Request","This server only understands GET."); httperror(h,"400 Invalid Request","This server only understands GET.");
} else { }
char *d; else
int64 fd; {
struct stat s; char *d;
c+=4; int64 fd;
for (d=c; *d!=' '&&*d!='\t'&&*d!='\n'&&*d!='\r'; ++d) ; struct stat s;
if (*d!=' ') goto e400;
*d=0; // expect 'GET /uri?nnbjhg HTTP/1.*'
if (c[0]!='/') goto e404; c+=4;
while (c[1]=='/') ++c;
if (!io_readfile(&fd,c+1)) { for (d=c; *d!=' '&&*d!='\t'&&*d!='\n'&&*d!='\r'; ++d) ;
if (*d!=' ') goto e400;
*d=0;
if (c[0]!='/') goto e404;
while (c[1]=='/') ++c;
if (!byte_diff(c,9,"announce?"))
{
// info_hash, left, port, numwant, compact
struct ot_peer peer;
byte_copy( peer.ip, h->ip, 4);
peer.port = 6881;
c+=9;
while( *c!=' ' ) {
if(!byte_diff(c,10,"info_hash="))
{
// String is expected to be URL encoded, so expect
// (%[0-9A-F][0-9A-F]){20}
int s = scan_urlencoded(
}
else if(!byte_diff(c,8,"numwant="))
{
}
else if(!byte_diff(c,8,"compact="))
{
}
else if(!byte_diff(c,5,"port="))
{
}
else if(!byte_diff(c,5,"left="))
{
}
while( *++c!=' ' && *c!='&');
}
}
else if (!byte_diff(c,7,"scrape?"))
{
}
else
{
httperror(h,"404 Not Found","No such file or directory.");
goto e404;
}
c=h->hdrbuf=(char*)malloc(500);
c+=fmt_str(c,"HTTP/1.1 Coming Up\r\nContent-Type: text/plain");
c+=fmt_str(c,"\r\nContent-Length: ");
/* ANSWER SIZE*/
c+=fmt_ulonglong(c,s.st_size);
c+=fmt_str(c,"\r\nLast-Modified: ");
/* MODIFY DATE */
c+=fmt_httpdate(c,s.st_mtime);
c+=fmt_str(c,"\r\nConnection: close\r\n\r\n");
iob_addbuf(&h->iob,h->hdrbuf,c - h->hdrbuf);
iob_addbuf(&h->iob,tracker_answer, tzracker_answer_size);
}
e404: e404:
httperror(h,"404 Not Found","No such file or directory."); io_dontwantread(s);
} else { io_wantwrite(s);
if (fstat(fd,&s)==-1) {
io_close(fd);
goto e404;
}
c=h->hdrbuf=(char*)malloc(500);
c+=fmt_str(c,"HTTP/1.1 Coming Up\r\nContent-Type: text/plain");
c+=fmt_str(c,"\r\nContent-Length: ");
/* ANSWER SIZE*/
c+=fmt_ulonglong(c,s.st_size);
c+=fmt_str(c,"\r\nLast-Modified: ");
/* MODIFY DATE */
c+=fmt_httpdate(c,s.st_mtime);
c+=fmt_str(c,"\r\nConnection: close\r\n\r\n");
iob_addbuf(&h->iob,h->hdrbuf,c - h->hdrbuf);
iob_addfile(&h->iob,fd,0,s.st_size);
}
}
io_dontwantread(s);
io_wantwrite(s);
} }
int main() { int main()
int s=socket_tcp6(); {
uint32 scope_id; int s=socket_tcp6();
char ip[16]; uint32 scope_id;
uint16 port; char ip[16];
if (socket_bind6_reuse(s,V6any,8000,0)==-1) uint16 port;
panic("socket_bind6_reuse");
if (socket_listen(s,16)==-1) if (socket_bind6_reuse(s,V6any,8000,0)==-1)
panic("socket_listen"); panic("socket_bind6_reuse");
if (!io_fd(s))
panic("io_fd"); if (socket_listen(s,16)==-1)
io_wantread(s); panic("socket_listen");
for (;;) {
int64 i; if (!io_fd(s))
io_wait(); panic("io_fd");
while ((i=io_canread())!=-1) {
if (i==s) { io_wantread(s);
int n;
while ((n=socket_accept6(s,ip,&port,&scope_id))!=-1) { for (;;)
if (io_fd(n)) { {
struct http_data* h=(struct http_data*)malloc(sizeof(struct http_data)); int64 i;
io_wantread(n); io_wait();
if (h) {
byte_zero(h,sizeof(struct http_data)); while ((i=io_canread())!=-1)
io_setcookie(n,h); {
} else if (i==s) // ist es der serversocket?
io_close(n); {
} else int n;
io_close(n); while ((n=socket_accept6(s,ip,&port,&scope_id))!=-1)
buffer_putnlflush(buffer_2); {
} if (io_fd(n))
if (errno==EAGAIN) {
io_eagain(s); struct http_data* h=(struct http_data*)malloc(sizeof(struct http_data));
else io_wantread(n);
carp("socket_accept6");
} else { if (h)
char buf[8192]; {
struct http_data* h=io_getcookie(i); byte_zero(h,sizeof(struct http_data));
int l=io_tryread(i,buf,sizeof buf); byte_copy(h->ip,ip,sizeof(ip));
if (l==-3) { io_setcookie(n,h);
if (h) { } else
array_reset(&h->r); io_close(n);
iob_reset(&h->iob); } else
free(h->hdrbuf); h->hdrbuf=0; io_close(n);
} buffer_putnlflush(buffer_2);
io_close(i); }
} else if (l==0) { if (errno==EAGAIN)
if (h) { io_eagain(s);
array_reset(&h->r); else
iob_reset(&h->iob); carp("socket_accept6");
free(h->hdrbuf); h->hdrbuf=0; }
} else
io_close(i); {
} else if (l>0) { char buf[8192];
array_catb(&h->r,buf,l); struct http_data* h=io_getcookie(i);
if (array_failed(&h->r)) {
httperror(h,"500 Server Error","request too long."); int l=io_tryread(i,buf,sizeof buf);
if (l<=0)
{
if (h)
{
array_reset(&h->r);
iob_reset(&h->iob);
free(h->hdrbuf); h->hdrbuf=0;
}
io_close(i);
}
else
{
array_catb(&h->r,buf,l);
if (array_failed(&h->r))
{
httperror(h,"500 Server Error","request too long.");
emerge: emerge:
io_dontwantread(i); io_dontwantread(i);
io_wantwrite(i); io_wantwrite(i);
} else if (array_bytes(&h->r)>8192) { }
httperror(h,"500 request too long","You sent too much headers"); else if (array_bytes(&h->r)>8192)
goto emerge; {
} else if ((l=header_complete(h))) httperror(h,"500 request too long","You sent too much headers");
httpresponse(h,i); goto emerge;
}
else if ((l=header_complete(h)))
{
httpresponse(h,i);
}
}
}
}
while ((i=io_canwrite())!=-1)
{
struct http_data* h=io_getcookie(i);
int64 r=iob_send(i,&h->iob);
if (r==-1)
io_eagain(i);
else
if (r<=0)
{
array_trunc(&h->r);
iob_reset(&h->iob);
free(h->hdrbuf); h->hdrbuf=0;
io_close(i);
}
}
} }
} return 0;
}
while ((i=io_canwrite())!=-1) {
struct http_data* h=io_getcookie(i);
int64 r=iob_send(i,&h->iob);
if (r==-1) io_eagain(i); else
if (r<=0) {
array_trunc(&h->r);
iob_reset(&h->iob);
free(h->hdrbuf); h->hdrbuf=0;
io_close(i);
}
}
}
return 0;
} }

Write Preview
Loading…
Cancel
Save