bridge

type Bridge struct {
	// contains filtered or unexported fields
}

type Clock interface {
	Now() time.Time
	After(d time.Duration) <-chan time.Time
}

type Config struct {
	// DataDir holds mcpclient.json (settings) and mcpspend.json (the spend
	// log).
	DataDir string
	// Sender delivers outgoing envelope parts; the host resolves the peer
	// uid to a private message.
	Sender brmcp.PMSender
	// Payer settles payment_required refusals.
	Payer Payer
	// ListenAddr, when non-empty, makes the bridge own a TCP listener that
	// binds only while the settings enable the bridge. Empty means the host
	// mounts Handler() itself and owns the listener lifecycle. The bridge
	// never chooses a bind address on its own.
	ListenAddr string
	// Name brands the MCP client identity and the refusal-note prefix.
	// Empty selects "brmcp-bridge".
	Name string
	// Logf, when non-nil, receives diagnostic lines.
	Logf func(format string, args ...any)
	// Clock overrides the system clock (tests).
	Clock Clock
	// TTL, ChunkSize, Assembler tune the underlying router (zero selects
	// the brmcp defaults).
	TTL       time.Duration
	ChunkSize int
	Assembler wire.AssemblerConfig
}

type Payer interface {
	Pay(ctx context.Context, payeeUID string, atoms int64) error
}

type PayerFunc func(ctx context.Context, payeeUID string, atoms int64) error

type PendingPayment struct {
	ID      string `json:"id"`
	Bot     string `json:"bot"`
	Tool    string `json:"tool"`
	Atoms   int64  `json:"atoms"`
	Created int64  `json:"created"`
}

type Settings struct {
	Enabled bool   `json:"enabled"`
	Token   string `json:"token"`
	// Mode is "approval" (every payment waits for a human decision) or
	// "autopay" (payments under the caps run unattended). Any other value
	// is coerced to "approval".
	Mode string `json:"mode"`
	// Caps are hard ceilings on BOTH modes; zero means never pay.
	PerCallCapAtoms int64 `json:"per_call_cap_atoms"`
	PerDayCapAtoms  int64 `json:"per_day_cap_atoms"`
	// AllowedBots is the default-deny list of callable bot uids (64-hex,
	// matched case-insensitively).
	AllowedBots []string `json:"allowed_bots"`
	// ApprovalTimeoutSecs bounds how long a call waits for a decision.
	// Nonpositive selects 120.
	ApprovalTimeoutSecs int `json:"approval_timeout_secs"`
	// TipWaitSecs bounds how long a call waits for the payment to complete
	// before giving up. Nonpositive selects 180.
	TipWaitSecs int `json:"tip_wait_secs"`
}

type SpendEntry struct {
	TS    int64  `json:"ts"`
	Bot   string `json:"bot"`
	Tool  string `json:"tool"`
	Rail  string `json:"rail"`
	Atoms int64  `json:"atoms"`
	// contains filtered or unexported fields
}

type TipMatcher struct {
	// contains filtered or unexported fields
}

type TipWait struct {
	// contains filtered or unexported fields
}