xref: /plan9/sys/src/cmd/ip/httpd/log.c (revision b89146921ae046704254cb6244e6b53ef05722cd)

#include <u.h>
#include <libc.h>
#include "httpd.h"
#include "httpsrv.h"

int		logall[3];  /* logall[2] is in "Common Log Format" */

static char *
monname[12] =
{
	"Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug", "Sep", "Oct", "Nov", "Dec"
};

void
logit(HConnect *c, char *fmt, ...)
{
	char buf[4096];
	va_list arg;
	HSPriv *p;

	va_start(arg, fmt);
	vseprint(buf, buf+sizeof(buf), fmt, arg);
	va_end(arg);
	p = nil;
	if(c != nil)
		p = c->private;
	if(p != nil && p->remotesys != nil)
		syslog(0, HTTPLOG, "%s %s", p->remotesys, buf);
	else
		syslog(0, HTTPLOG, "%s", buf);
}

void
writelog(HConnect *c, char *fmt, ...)
{
	HSPriv *p;
	char buf[HBufSize+500], *bufp, *bufe;
	char statuscode[4];
	vlong objectsize;
	ulong now, today;
	int logfd;
	va_list arg;
	Tm *tm;

	if(c == nil)
		return;
	p = c->private;
	bufe = buf + sizeof(buf);
	now = time(nil);
	tm = gmtime(now);
	today = now / (24*60*60);

	/* verbose logfile, for research on web traffic */
	logfd = logall[today & 1];
	if(logfd > 0){
		if(c->hstop == c->header || c->hstop[-1] != '\n')
			*c->hstop = '\n';
		*c->hstop = '\0';
		bufp = seprint(buf, bufe, "==========\n");
		bufp = seprint(bufp, bufe, "LogTime:  %D\n", now);
		bufp = seprint(bufp, bufe, "ConnTime: %D\n", c->reqtime);
		bufp = seprint(bufp, bufe, "RemoteIP: %s\n", p->remotesys);
		bufp = seprint(bufp, bufe, "Port: %s\n", p->remoteserv);
		va_start(arg, fmt);
		bufp = vseprint(bufp, bufe, fmt, arg);
		va_end(arg);
		if(c->req.uri != nil && c->req.uri[0] != 0)
			bufp = seprint(bufp, bufe, "FinalURI: %s\n", c->req.uri);
		bufp = seprint(bufp, bufe, "----------\n%s\n", (char*)c->header);
		write(logfd, buf, bufp-buf);   /* append-only file */
	}

	/* another log, with less information but formatted for common analysis tools */
	if(logall[2] > 0 && strncmp(fmt, "Reply: ", 7) == 0){
		objectsize = 0;
		strecpy(statuscode, statuscode+4, fmt+7);
		if( fmt[7] == '%'){
			va_start(arg, fmt);
			vseprint(statuscode, statuscode+4, fmt+7, arg);
			va_end(arg);
		}else if(
			strcmp(fmt+7, "200 file %lld %lld\n") == 0 ||
			strcmp(fmt+7, "206 partial content %lld %lld\n") == 0 ||
			strcmp(fmt+7, "206 partial content, early termination %lld %lld\n") == 0){
			va_start(arg, fmt);
			objectsize = va_arg(arg, vlong); /* length in sendfd.c */
			USED(objectsize);
			objectsize = va_arg(arg, vlong); /* wrote in sendfd.c */
			va_end(arg);
		}
		bufp = seprint(buf, bufe, "%s - -", p->remotesys);
		bufp = seprint(bufp, bufe, " [%.2d/%s/%d:%.2d:%.2d:%.2d +0000]", tm->mday, monname[tm->mon], tm->year+1900, tm->hour, tm->min, tm->sec);
		if(c->req.uri == nil || c->req.uri[0] == 0){
			bufp = seprint(bufp, bufe, " \"%.*s\"",
				(int)utfnlen((char*)c->header, strcspn((char*)c->header, "\r\n")),
				(char*)c->header);
		}else{
			/* use more canonical form of URI, if available */
			bufp = seprint(bufp, bufe, " \"%s %s HTTP/%d.%d\"", c->req.meth, c->req.uri, c->req.vermaj,  c->req.vermin);
		}
		bufp = seprint(bufp, bufe, " %s %lld\n", statuscode, objectsize);
		write(logall[2], buf, bufp-buf);   /* append-only file */
	}
}