log.go

package main

import (
    "fmt"
    "log"
    "log/syslog"
    "os"
)

type Logger struct {
    toSyslog  bool
    level     syslog.Priority
    selectors map[string]bool

    logger *log.Logger
    syslog [syslog.LOG_DEBUG + 1]*log.Logger
}

var _log Logger

func DEBUG(selector string, format string, v ...interface{}) {
    if _log.level >= syslog.LOG_DEBUG {
        selected := _log.selectors[selector]
        if !selected {
            return
        }
        if _log.toSyslog {
            _log.syslog[syslog.LOG_INFO].Output(2, fmt.Sprintf(format, v...))
        } else {
            _log.logger.Output(2, fmt.Sprintf("DBG  "+format, v...))
        }
    }
}

func INFO(format string, v ...interface{}) {
    if _log.level >= syslog.LOG_INFO {
        if _log.toSyslog {
            _log.syslog[syslog.LOG_INFO].Output(2, fmt.Sprintf(format, v...))
        } else {
            _log.logger.Output(2, fmt.Sprintf("INFO "+format, v...))
        }
    }
}

func WARN(format string, v ...interface{}) {
    if _log.level >= syslog.LOG_WARNING {
        if _log.toSyslog {
            _log.syslog[syslog.LOG_WARNING].Output(2, fmt.Sprintf(format, v...))
        } else {
            _log.logger.Output(2, fmt.Sprintf("WARN "+format, v...))
        }
    }
}

func ERR(format string, v ...interface{}) {
    if _log.level >= syslog.LOG_ERR {
        if _log.toSyslog {
            _log.syslog[syslog.LOG_ERR].Output(2, fmt.Sprintf(format, v...))
        } else {
            _log.logger.Output(2, fmt.Sprintf("ERR  "+format, v...))
        }
    }
}

func CRIT(format string, v ...interface{}) {
    if _log.level >= syslog.LOG_CRIT {
        if _log.toSyslog {
            _log.syslog[syslog.LOG_CRIT].Output(2, fmt.Sprintf(format, v...))
        } else {
            _log.logger.Output(2, fmt.Sprintf("CRIT "+format, v...))
        }
    }
}

func WTF(format string, v ...interface{}) {
    if _log.level >= syslog.LOG_CRIT {
        if _log.toSyslog {
            _log.syslog[syslog.LOG_CRIT].Output(2, fmt.Sprintf(format, v...))
        } else {
            _log.logger.Output(2, fmt.Sprintf("CRIT "+format, v...))
        }
    }

    // TODO: assert here when not in production mode
}

func openSyslog(level syslog.Priority, prefix string) *log.Logger {
    logger, err := syslog.NewLogger(level, log.Lshortfile)
    if err != nil {
        fmt.Println("Error opening syslog: ", err)
        return nil
    }
    logger.SetPrefix(prefix)

    return logger
}

func LogInit(level syslog.Priority, prefix string, toSyslog bool, debugSelectors []string) {
    _log.toSyslog = toSyslog
    _log.level = level

    _log.selectors = make(map[string]bool)
    for _, selector := range debugSelectors {
        _log.selectors[selector] = true
    }

    if _log.toSyslog {
        for prio := syslog.LOG_EMERG; prio <= syslog.LOG_DEBUG; prio++ {
            _log.syslog[prio] = openSyslog(prio, prefix)
        }
    } else {
        _log.logger = log.New(os.Stdout, prefix, log.Lshortfile)
    }
}