diff --git a/orchestrator/app.go b/orchestrator/app.go index c066b7c..4f6f95f 100644 --- a/orchestrator/app.go +++ b/orchestrator/app.go @@ -363,7 +363,7 @@ func Serve(parent context.Context, p Params, logOut io.Writer) (result error) { var workers sync.WaitGroup workers.Go(func() { errs <- mainServer.Serve(mainListener) }) workers.Go(func() { errs <- metricsServer.Serve(metricsListener) }) - logger.Info("orchestrator started", "event", "started", "operation", "serve", "outcome", "success", "listen", p.Listen, "metrics_listen", p.MetricsListen) + logger.Info("orchestrator started", "event", "started", "operation", "serve", "outcome", "success", "listen", p.Listen, "metrics_listen", p.MetricsListen, "onchain", engine != nil) // Independent bounded workers keep slow RPC/health calls off the billing // and expiry paths. Every worker uses the shutdown context and is joined. startWorker := func(period, timeout time.Duration, work func(context.Context)) { diff --git a/orchestrator/payment_engine.go b/orchestrator/payment_engine.go index e60d6d7..34e713b 100644 --- a/orchestrator/payment_engine.go +++ b/orchestrator/payment_engine.go @@ -253,6 +253,9 @@ func (e *PaymentEngine) Receive(ctx context.Context, runner, manifest, paymentHe return ethcommon.Address{}, nil, paymentObservation{err, "rejected"} } if funds.Reserve.Cmp(params.FaceValue) < 0 || funds.Deposit.Cmp(params.FaceValue) < 0 { + if e.store != nil && e.store.logger != nil { + e.store.logger.WarnContext(ctx, "orchestrator payer deposit or claimable reserve below ticket face value", "event", "payment", "operation", "receive", "outcome", "rejected", "payer", payer, "deposit", funds.Deposit, "claimable_reserve", funds.Reserve, "face_value", params.FaceValue) + } return ethcommon.Address{}, nil, pm.ErrPayerUnavailable } e.mu.Lock() diff --git a/signer/app.go b/signer/app.go index 6f9edc1..1be7191 100644 --- a/signer/app.go +++ b/signer/app.go @@ -5,11 +5,13 @@ import ( "errors" "fmt" "io" + "log/slog" "math/big" "net" "net/http" "net/netip" "net/url" + "os" "os/signal" "sync" "syscall" @@ -148,6 +150,7 @@ func (p Params) Validate() error { } func Serve(p Params) error { + slog.SetDefault(slog.New(slog.NewTextHandler(os.Stderr, nil))) ctx, stop := signal.NotifyContext(context.Background(), syscall.SIGTERM, syscall.SIGINT) defer stop() return serve(ctx, p) @@ -270,6 +273,7 @@ func serve(parent context.Context, p Params) error { } workers.Go(func() { errCh <- srv.Serve(listener) }) workers.Go(func() { errCh <- metricsServer.Serve(metricsListener) }) + slog.Info("signer started", "component", "signer", "event", "started", "operation", "serve", "outcome", "success", "listen", p.Listen, "metrics_listen", p.MetricsListen) select { case <-ctx.Done(): case err = <-errCh: