Skip to content

Repository navigation

feat: log rejected payer funds and startup state #21

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
rickstaa wants to merge 4 commits into
base: main
Choose a base branch
from
Open

feat: log rejected payer funds and startup state #21

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
1a7d9ee
feat(orchestrator): log rejected payer funds and on-chain mode
rickstaa Oct 29, 2026
e1280a4
feat(signer): log a startup line and use the text log handler
rickstaa Oct 29, 2026
6983cd3
fix(orchestrator): route the funds warning through the engine logger
rickstaa Oct 29, 2026
325136b
fix(orchestrator): name the claimable reserve in the funds warning
rickstaa Oct 29, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion orchestrator/app.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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)) {
Expand Down
3 changes: 3 additions & 0 deletions orchestrator/payment_engine.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Comment on lines +256 to +257
}
return ethcommon.Address{}, nil, pm.ErrPayerUnavailable
}
e.mu.Lock()
Expand Down
4 changes: 4 additions & 0 deletions signer/app.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,11 +5,13 @@ import (
"errors"
"fmt"
"io"
"log/slog"
"math/big"
"net"
"net/http"
"net/netip"
"net/url"
"os"
"os/signal"
"sync"
"syscall"
Expand Down Expand Up @@ -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)
Expand Down Expand Up @@ -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:
Expand Down
Loading