diff --git a/internal/peer/node/node.go b/internal/peer/node/node.go index fab6ca6..02def71 100644 --- a/internal/peer/node/node.go +++ b/internal/peer/node/node.go @@ -39,10 +39,10 @@ func New(disk disk.Disk, system system.System) *Node { func (a *Node) Run(ctx context.Context) error { opts := &slog.HandlerOptions{ - AddSource: true, + AddSource: false, Level: slog.LevelDebug, } - logger := slog.New(slog.NewJSONHandler(a.system.Stdout(), opts)) + logger := slog.New(slog.NewTextHandler(a.system.Stdout(), opts)) slog.SetDefault(logger) ctx = logging.WithContext(ctx, logger) @@ -65,12 +65,16 @@ func (a *Node) Run(ctx context.Context) error { return err } - _, err = a.loadAdmins() + admins, err := a.loadAdmins() if err != nil { logger.ErrorContext(ctx, "failed to read admins file", slog.Any("error", err)) return err } + if len(admins) == 0 { + logger.WarnContext(ctx, "no admins found", slog.String("admins", "none")) + } + tcpAddrRaw := net.JoinHostPort(a.conf.Host, a.conf.Port) tcpAddr, err := net.ResolveTCPAddr("tcp", tcpAddrRaw) if err != nil { @@ -87,6 +91,8 @@ func (a *Node) Run(ctx context.Context) error { return err } + logger.InfoContext(ctx, "serving", slog.String("address", addr.String())) + for { conn, err := listener.Accept() if err != nil {