* ci: consolidate duplicate workflows and merge CodeQL configs Remove 17 duplicate workflow files that were split copies of the combined originals. Each family (CI, CodeQL, Coverage, PR Build, Alpha Release) had the same job duplicated across separate push/pull_request/schedule/manual trigger files. Merge codeql.yml and codescan.yml into a single codeql.yml with a language matrix covering go, javascript-typescript, python, and actions — matching the previous default setup coverage. Remaining workflows (one per family): - ci.yml (push + PR + manual) - codeql.yml (push + PR + schedule, all languages) - coverage.yml (push + PR + manual) - alpha-release.yml (push + manual) - pr-build.yml (PR + manual) - release.yml (tag push) - agent-verify.yml, auto-label.yml, auto-project.yml Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> * feat: add collect, config, crypt, plugin packages and fix all lint issues Add four new infrastructure packages with CLI commands: - pkg/config: layered configuration (defaults → file → env → flags) - pkg/crypt: crypto primitives (Argon2id, AES-GCM, ChaCha20, HMAC, checksums) - pkg/plugin: plugin system with GitHub-based install/update/remove - pkg/collect: collection subsystem (GitHub, BitcoinTalk, market, papers, excavate) Fix all golangci-lint issues across the entire codebase (~100 errcheck, staticcheck SA1012/SA1019/ST1005, unused, ineffassign fixes) so that `core go qa` passes with 0 issues. Closes #167, #168, #170, #250, #251, #252, #253, #254, #255, #256 Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> --------- Co-authored-by: Claude Opus 4.5 <noreply@anthropic.com>
219 lines
4.7 KiB
Go
219 lines
4.7 KiB
Go
// Package log provides structured logging for Core applications.
|
|
//
|
|
// The package works standalone or integrated with the Core framework:
|
|
//
|
|
// // Standalone usage
|
|
// log.SetLevel(log.LevelDebug)
|
|
// log.Info("server started", "port", 8080)
|
|
// log.Error("failed to connect", "err", err)
|
|
//
|
|
// // With Core framework
|
|
// core.New(
|
|
// framework.WithName("log", log.NewService(log.Options{Level: log.LevelInfo})),
|
|
// )
|
|
package log
|
|
|
|
import (
|
|
"fmt"
|
|
"io"
|
|
"os"
|
|
"sync"
|
|
"time"
|
|
)
|
|
|
|
// Level defines logging verbosity.
|
|
type Level int
|
|
|
|
// Logging level constants ordered by increasing verbosity.
|
|
const (
|
|
// LevelQuiet suppresses all log output.
|
|
LevelQuiet Level = iota
|
|
// LevelError shows only error messages.
|
|
LevelError
|
|
// LevelWarn shows warnings and errors.
|
|
LevelWarn
|
|
// LevelInfo shows informational messages, warnings, and errors.
|
|
LevelInfo
|
|
// LevelDebug shows all messages including debug details.
|
|
LevelDebug
|
|
)
|
|
|
|
// String returns the level name.
|
|
func (l Level) String() string {
|
|
switch l {
|
|
case LevelQuiet:
|
|
return "quiet"
|
|
case LevelError:
|
|
return "error"
|
|
case LevelWarn:
|
|
return "warn"
|
|
case LevelInfo:
|
|
return "info"
|
|
case LevelDebug:
|
|
return "debug"
|
|
default:
|
|
return "unknown"
|
|
}
|
|
}
|
|
|
|
// Logger provides structured logging.
|
|
type Logger struct {
|
|
mu sync.RWMutex
|
|
level Level
|
|
output io.Writer
|
|
|
|
// Style functions for formatting (can be overridden)
|
|
StyleTimestamp func(string) string
|
|
StyleDebug func(string) string
|
|
StyleInfo func(string) string
|
|
StyleWarn func(string) string
|
|
StyleError func(string) string
|
|
}
|
|
|
|
// Options configures a Logger.
|
|
type Options struct {
|
|
Level Level
|
|
Output io.Writer // defaults to os.Stderr
|
|
}
|
|
|
|
// New creates a new Logger with the given options.
|
|
func New(opts Options) *Logger {
|
|
output := opts.Output
|
|
if output == nil {
|
|
output = os.Stderr
|
|
}
|
|
|
|
return &Logger{
|
|
level: opts.Level,
|
|
output: output,
|
|
StyleTimestamp: identity,
|
|
StyleDebug: identity,
|
|
StyleInfo: identity,
|
|
StyleWarn: identity,
|
|
StyleError: identity,
|
|
}
|
|
}
|
|
|
|
func identity(s string) string { return s }
|
|
|
|
// SetLevel changes the log level.
|
|
func (l *Logger) SetLevel(level Level) {
|
|
l.mu.Lock()
|
|
l.level = level
|
|
l.mu.Unlock()
|
|
}
|
|
|
|
// Level returns the current log level.
|
|
func (l *Logger) Level() Level {
|
|
l.mu.RLock()
|
|
defer l.mu.RUnlock()
|
|
return l.level
|
|
}
|
|
|
|
// SetOutput changes the output writer.
|
|
func (l *Logger) SetOutput(w io.Writer) {
|
|
l.mu.Lock()
|
|
l.output = w
|
|
l.mu.Unlock()
|
|
}
|
|
|
|
func (l *Logger) shouldLog(level Level) bool {
|
|
l.mu.RLock()
|
|
defer l.mu.RUnlock()
|
|
return level <= l.level
|
|
}
|
|
|
|
func (l *Logger) log(level Level, prefix, msg string, keyvals ...any) {
|
|
l.mu.RLock()
|
|
output := l.output
|
|
styleTimestamp := l.StyleTimestamp
|
|
l.mu.RUnlock()
|
|
|
|
timestamp := styleTimestamp(time.Now().Format("15:04:05"))
|
|
|
|
// Format key-value pairs
|
|
var kvStr string
|
|
if len(keyvals) > 0 {
|
|
kvStr = " "
|
|
for i := 0; i < len(keyvals); i += 2 {
|
|
if i > 0 {
|
|
kvStr += " "
|
|
}
|
|
key := keyvals[i]
|
|
var val any
|
|
if i+1 < len(keyvals) {
|
|
val = keyvals[i+1]
|
|
}
|
|
kvStr += fmt.Sprintf("%v=%v", key, val)
|
|
}
|
|
}
|
|
|
|
_, _ = fmt.Fprintf(output, "%s %s %s%s\n", timestamp, prefix, msg, kvStr)
|
|
}
|
|
|
|
// Debug logs a debug message with optional key-value pairs.
|
|
func (l *Logger) Debug(msg string, keyvals ...any) {
|
|
if l.shouldLog(LevelDebug) {
|
|
l.log(LevelDebug, l.StyleDebug("[DBG]"), msg, keyvals...)
|
|
}
|
|
}
|
|
|
|
// Info logs an info message with optional key-value pairs.
|
|
func (l *Logger) Info(msg string, keyvals ...any) {
|
|
if l.shouldLog(LevelInfo) {
|
|
l.log(LevelInfo, l.StyleInfo("[INF]"), msg, keyvals...)
|
|
}
|
|
}
|
|
|
|
// Warn logs a warning message with optional key-value pairs.
|
|
func (l *Logger) Warn(msg string, keyvals ...any) {
|
|
if l.shouldLog(LevelWarn) {
|
|
l.log(LevelWarn, l.StyleWarn("[WRN]"), msg, keyvals...)
|
|
}
|
|
}
|
|
|
|
// Error logs an error message with optional key-value pairs.
|
|
func (l *Logger) Error(msg string, keyvals ...any) {
|
|
if l.shouldLog(LevelError) {
|
|
l.log(LevelError, l.StyleError("[ERR]"), msg, keyvals...)
|
|
}
|
|
}
|
|
|
|
// --- Default logger ---
|
|
|
|
var defaultLogger = New(Options{Level: LevelInfo})
|
|
|
|
// Default returns the default logger.
|
|
func Default() *Logger {
|
|
return defaultLogger
|
|
}
|
|
|
|
// SetDefault sets the default logger.
|
|
func SetDefault(l *Logger) {
|
|
defaultLogger = l
|
|
}
|
|
|
|
// SetLevel sets the default logger's level.
|
|
func SetLevel(level Level) {
|
|
defaultLogger.SetLevel(level)
|
|
}
|
|
|
|
// Debug logs to the default logger.
|
|
func Debug(msg string, keyvals ...any) {
|
|
defaultLogger.Debug(msg, keyvals...)
|
|
}
|
|
|
|
// Info logs to the default logger.
|
|
func Info(msg string, keyvals ...any) {
|
|
defaultLogger.Info(msg, keyvals...)
|
|
}
|
|
|
|
// Warn logs to the default logger.
|
|
func Warn(msg string, keyvals ...any) {
|
|
defaultLogger.Warn(msg, keyvals...)
|
|
}
|
|
|
|
// Error logs to the default logger.
|
|
func Error(msg string, keyvals ...any) {
|
|
defaultLogger.Error(msg, keyvals...)
|
|
}
|