Commit 7578298b authored by Matthew Holt's avatar Matthew Holt

Rewrote access log middleware

parent d2892fc7
// Package log implements basic but useful request logging middleware. // Package log implements basic but useful request (access) logging middleware.
package log package log
import ( import (
...@@ -11,61 +11,112 @@ import ( ...@@ -11,61 +11,112 @@ import (
// New instantiates a new instance of logging middleware. // New instantiates a new instance of logging middleware.
func New(c middleware.Controller) (middleware.Middleware, error) { func New(c middleware.Controller) (middleware.Middleware, error) {
var logWhat, outputFile, format string rules, err := parse(c)
var logger *log.Logger if err != nil {
return nil, err
}
for c.Next() { // Open the log files for writing when the server starts
c.Args(&logWhat, &outputFile, &format) c.Startup(func() error {
for i := 0; i < len(rules); i++ {
var err error
var file *os.File
if logWhat == "" { if rules[i].OutputFile == "stdout" {
return nil, c.ArgErr() file = os.Stdout
} } else if rules[i].OutputFile == "stderr" {
if outputFile == "" { file = os.Stderr
outputFile = defaultLogFilename } else {
file, err = os.OpenFile(rules[i].OutputFile, os.O_RDWR|os.O_CREATE|os.O_APPEND, 0644)
if err != nil {
return err
}
}
rules[i].Log = log.New(file, "", 0)
} }
switch format {
case "": return nil
format = defaultReqLogFormat })
case "{common}":
format = commonLogFormat return func(next middleware.HandlerFunc) middleware.HandlerFunc {
case "{combined}": return Logger{Next: next, Rules: rules}.ServeHTTP
format = combinedLogFormat }, nil
}
func (l Logger) ServeHTTP(w http.ResponseWriter, r *http.Request) (int, error) {
for _, rule := range l.Rules {
if middleware.Path(r.URL.Path).Matches(rule.PathScope) {
responseRecorder := middleware.NewResponseRecorder(w)
status, err := l.Next(responseRecorder, r)
rep := middleware.NewReplacer(r, responseRecorder)
rule.Log.Println(rep.Replace(rule.Format))
return status, err
} }
} }
return l.Next(w, r)
}
// Open the log file for writing when the server starts func parse(c middleware.Controller) ([]LogRule, error) {
c.Startup(func() error { var rules []LogRule
var err error
var file *os.File for c.Next() {
args := c.RemainingArgs()
if outputFile == "stdout" { if len(args) == 0 {
file = os.Stdout // Nothing specified; use defaults
} else if outputFile == "stderr" { rules = append(rules, LogRule{
file = os.Stderr PathScope: "/",
OutputFile: defaultLogFilename,
Format: defaultLogFormat,
})
} else if len(args) == 1 {
// Only an output file specified
rules = append(rules, LogRule{
PathScope: "/",
OutputFile: args[0],
Format: defaultLogFormat,
})
} else { } else {
file, err = os.OpenFile(outputFile, os.O_RDWR|os.O_CREATE|os.O_APPEND, 0644) // Path scope, output file, and maybe a format specified
if err != nil {
return err format := defaultLogFormat
if len(args) > 2 {
switch args[2] {
case "{common}":
format = commonLogFormat
case "{combined}":
format = combinedLogFormat
}
} }
rules = append(rules, LogRule{
PathScope: args[0],
OutputFile: args[1],
Format: format,
})
} }
}
logger = log.New(file, "", 0) return rules, nil
return nil }
})
return func(next http.HandlerFunc) http.HandlerFunc { type Logger struct {
return func(w http.ResponseWriter, r *http.Request) { Next middleware.HandlerFunc
sw := middleware.NewResponseRecorder(w) Rules []LogRule
next(sw, r) }
rep := middleware.NewReplacer(r, sw)
logger.Println(rep.Replace(format)) type LogRule struct {
} PathScope string
}, nil OutputFile string
Format string
Log *log.Logger
} }
const ( const (
defaultLogFilename = "access.log" defaultLogFilename = "access.log"
commonLogFormat = `{remote} ` + middleware.EmptyStringReplacer + ` [{when}] "{method} {uri} {proto}" {status} {size}` commonLogFormat = `{remote} ` + middleware.EmptyStringReplacer + ` [{when}] "{method} {uri} {proto}" {status} {size}`
combinedLogFormat = commonLogFormat + ` "{>Referer}" "{>User-Agent}"` combinedLogFormat = commonLogFormat + ` "{>Referer}" "{>User-Agent}"`
defaultReqLogFormat = commonLogFormat defaultLogFormat = commonLogFormat
) )
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment