poolcore

type Actor struct {
	Name    string
	PrivKey *ec.PrivateKey
	PubKey  *ec.PublicKey
	PubHex  string
	Addr    string
}

type BaseTxReq struct {
	ClientID string `protobuf:"bytes,1,opt,name=client_pubkey_hex,json=clientId,proto3" json:"client_pubkey_hex"`

	SpendTxID string `protobuf:"bytes,2,opt,name=spend_txid,json=spendTxid,proto3" json:"spend_txid"`
	BaseTx    []byte `protobuf:"bytes,3,opt,name=base_tx,json=baseTx,proto3" json:"base_tx"`
	ClientSig []byte `protobuf:"bytes,4,opt,name=client_sig,json=clientSig,proto3" json:"client_signature"`
}

type BaseTxResp struct {
	Success  bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success"`
	Status   string `protobuf:"bytes,2,opt,name=status,proto3" json:"status"`
	BaseTxID string `protobuf:"bytes,3,opt,name=base_txid,json=baseTxid,proto3" json:"base_txid,omitempty"`
	Error    string `protobuf:"bytes,4,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
}

type BillableServiceContext struct {
	Request              ServiceQuoteReq
	Offer                payflow.ServiceOffer
	ServiceParamsPayload []byte
	Gateway              *GatewayService
}

type BillableServiceDecision struct {
	Status              string
	Error               string
	ChargeReason        string
	ChargeAmountSatoshi uint64
	QuoteTTLSeconds     uint32
}

type BillableServiceDecl struct {
	ServiceType  string
	ChargeReason string
	Quote        BillableServiceQuoteFunc
}

type BillableServiceQuoteFunc func(BillableServiceContext) (BillableServiceDecision, error)

type BoundQuoteChargeReasons map[string]struct{}

type ChainClient interface {
	GetUTXOs(address string) ([]UTXO, error)
	GetTipHeight() (uint32, error)
	Broadcast(txHex string) (string, error)
}

type CloseReq struct {
	ClientID string `protobuf:"bytes,1,opt,name=client_pubkey_hex,json=clientId,proto3" json:"client_pubkey_hex"`

	SpendTxID    string `protobuf:"bytes,2,opt,name=spend_txid,json=spendTxid,proto3" json:"spend_txid"`
	ServerAmount uint64 `protobuf:"varint,3,opt,name=server_amount,json=serverAmount,proto3" json:"server_amount"`
	Fee          uint64 `protobuf:"varint,4,opt,name=fee,proto3" json:"fee"`
	ClientSig    []byte `protobuf:"bytes,5,opt,name=client_sig,json=clientSig,proto3" json:"signature"`
}

type CloseRequest struct {
	SpendTxID      string
	ServerAmount   uint64
	Fee            uint64
	ClientSigBytes []byte
}

type CloseResp struct {
	Success        bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success"`
	Status         string `protobuf:"bytes,2,opt,name=status,proto3" json:"status"`
	Broadcasted    bool   `protobuf:"varint,3,opt,name=broadcasted,proto3" json:"broadcasted"`
	FinalSpendTxID string `protobuf:"bytes,4,opt,name=final_spend_txid,json=finalSpendTxid,proto3" json:"final_spend_txid,omitempty"`
	Error          string `protobuf:"bytes,5,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
}

type CloseResponse struct {
	FinalTxID      string
	ServerSigBytes []byte
}

type CreateReq struct {
	ClientID string `protobuf:"bytes,1,opt,name=client_pubkey_hex,json=clientId,proto3" json:"client_pubkey_hex"`

	SpendTx        []byte `protobuf:"bytes,2,opt,name=spend_tx,json=spendTx,proto3" json:"spend_tx"`
	InputAmount    uint64 `protobuf:"varint,3,opt,name=input_amount,json=inputAmount,proto3" json:"input_amount"`
	SequenceNumber uint32 `protobuf:"varint,4,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number"`
	ServerAmount   uint64 `protobuf:"varint,5,opt,name=server_amount,json=serverAmount,proto3" json:"server_amount"`
	ClientSig      []byte `protobuf:"bytes,6,opt,name=client_sig,json=clientSig,proto3" json:"client_signature"`
}

type CreateResp struct {
	SpendTxID     string `protobuf:"bytes,1,opt,name=spend_txid,json=spendTxid,proto3" json:"spend_txid"`
	ServerSig     []byte `protobuf:"bytes,2,opt,name=server_sig,json=serverSig,proto3" json:"server_signature"`
	ErrorMessage  string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	SpendTxFeeSat uint64 `protobuf:"varint,4,opt,name=spend_tx_fee_satoshi,json=spendTxFeeSatoshi,proto3" json:"spend_tx_fee_satoshi"`
	PoolAmountSat uint64 `protobuf:"varint,5,opt,name=pool_amount_satoshi,json=poolAmountSatoshi,proto3" json:"pool_amount_satoshi"`
}

type GatewayParams struct {
	MinimumPoolAmountSatoshi uint64
	LockBlocks               uint32
	FeeRateSatPerByte        float64
	// PayRejectBeforeExpiryBlocks 控制“临近到期时拒绝继续 pay”的安全窗口（单位：区块）。
	// 取值为 0 时，会使用默认值 1。
	PayRejectBeforeExpiryBlocks uint32

	BillingCycleSeconds      uint32
	SingleCycleFeeSatoshi    uint64
	SinglePublishFeeSatoshi  uint64
	SingleQueryFeeSatoshi    uint64
	RenewNotifyBeforeSeconds uint32
}

type GatewayService struct {
	DB    *sql.DB
	Actor *sqliteactor.Actor
	Chain ChainClient

	ServerPrivHex string
	Params        GatewayParams
	// BoundQuoteChargeReasons 由模块装配阶段注入。
	// 费用池底座只持有“哪些 charge_reason 必须绑定 quote”的策略，不直接依赖具体业务模块。
	BoundQuoteChargeReasons BoundQuoteChargeReasons

	// IsMainnet 控制地址派生与签名脚本等网络相关参数。
	// 说明：BSV 主网/测试网的地址格式不同；公私钥本身不变。
	IsMainnet bool
	// contains filtered or unexported fields
}

type GatewaySessionRow struct {
	SpendTxID string

	ClientID                  string
	ClientBSVCompressedPubHex string
	ServerBSVCompressedPubHex string

	InputAmountSat  uint64
	PoolAmountSat   uint64
	SpendTxFeeSat   uint64
	Sequence        uint32
	ServerAmountSat uint64
	ClientAmountSat uint64

	BaseTxID  string
	FinalTxID string

	BaseTxHex    string
	CurrentTxHex string

	LifecycleState string
	FrozenReason   string

	LastSubmitError         string
	SubmitRetryCount        int
	LastSubmitAttemptAtUnix int64
	CloseSubmitAtUnix       int64
	CloseObservedAtUnix     int64
	CloseObserveStatus      string
	CloseObserveReason      string

	CreatedAt int64
	UpdatedAt int64
}

type InfoReq struct {
	ClientID string `protobuf:"bytes,1,opt,name=client_pubkey_hex,json=clientId,proto3" json:"client_pubkey_hex"`
}

type InfoResp struct {
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status"`

	MinimumPoolAmountSatoshi uint64  `` /* 128-byte string literal not displayed */
	LockBlocks               uint32  `protobuf:"varint,3,opt,name=lock_blocks,json=lockBlocks,proto3" json:"lock_blocks"`
	FeeRateSatPerByte        float64 `protobuf:"fixed64,4,opt,name=fee_rate_sat_per_byte,json=feeRateSatPerByte,proto3" json:"fee_rate_sat_per_byte"`

	BillingCycleSeconds      uint32 `protobuf:"varint,5,opt,name=billing_cycle_seconds,json=billingCycleSeconds,proto3" json:"billing_cycle_seconds"`
	SingleCycleFeeSatoshi    uint64 `protobuf:"varint,6,opt,name=single_cycle_fee_satoshi,json=singleCycleFeeSatoshi,proto3" json:"single_cycle_fee_satoshi"`
	SinglePublishFeeSatoshi  uint64 `protobuf:"varint,7,opt,name=single_publish_fee_satoshi,json=singlePublishFeeSatoshi,proto3" json:"single_publish_fee_satoshi"`
	RenewNotifyBeforeSeconds uint32 `` /* 128-byte string literal not displayed */
	SingleQueryFeeSatoshi    uint64 `protobuf:"varint,9,opt,name=single_query_fee_satoshi,json=singleQueryFeeSatoshi,proto3" json:"single_query_fee_satoshi"`
}

type ListenCycleServicePayload struct {
	RequestedDurationSeconds uint32
	RequestedUntilUnix       int64
	ProposedPaymentSatoshi   uint64
}

type ListenerTargetRow struct {
	ClientID string
}

type OpenBaseTxRequest struct {
	SpendTxID      string
	BaseTxHex      string
	ClientSigBytes []byte
}

type OpenCreateRequest struct {
	ClientPubHex   string
	SpendTxHex     string
	InputAmount    uint64
	SequenceNumber uint32
	ServerAmount   uint64
	ClientSigBytes []byte
}

type OpenCreateResponse struct {
	SpendTxID      string
	ServerSigBytes []byte
}

type PayConfirmReq struct {
	ClientID string `protobuf:"bytes,1,opt,name=client_pubkey_hex,json=clientId,proto3" json:"client_pubkey_hex"`

	SpendTxID      string `protobuf:"bytes,2,opt,name=spend_txid,json=spendTxid,proto3" json:"spend_txid"`
	SequenceNumber uint32 `protobuf:"varint,3,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number"`
	ServerAmount   uint64 `protobuf:"varint,4,opt,name=server_amount,json=serverAmount,proto3" json:"server_amount"`
	Fee            uint64 `protobuf:"varint,5,opt,name=fee,proto3" json:"fee"`
	ClientSig      []byte `protobuf:"bytes,6,opt,name=client_sig,json=clientSig,proto3" json:"signature"`

	// 业务字段（不上链，仅用于观测/审计/幂等核对）。
	ChargeReason        string `protobuf:"bytes,7,opt,name=charge_reason,json=chargeReason,proto3" json:"charge_reason,omitempty"`
	ChargeAmountSatoshi uint64 `protobuf:"varint,8,opt,name=charge_amount_satoshi,json=chargeAmountSatoshi,proto3" json:"charge_amount_satoshi,omitempty"`
	FileHash            string `protobuf:"bytes,9,opt,name=file_hash,json=fileHash,proto3" json:"file_hash,omitempty"`
	ProofIntent         []byte `protobuf:"bytes,10,opt,name=proof_intent,json=proofIntent,proto3" json:"proof_intent,omitempty"`
	SignedProofCommit   []byte `protobuf:"bytes,11,opt,name=signed_proof_commit,json=signedProofCommit,proto3" json:"signed_proof_commit,omitempty"`
	ServiceQuote        []byte `protobuf:"bytes,13,opt,name=service_quote,json=serviceQuote,proto3" json:"service_quote,omitempty"`
}

type PayConfirmRequest struct {
	SpendTxID      string
	SequenceNumber uint32
	ServerAmount   uint64
	Fee            uint64
	ClientSigBytes []byte
}

type PayConfirmResp struct {
	Success     bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success"`
	Status      string `protobuf:"bytes,2,opt,name=status,proto3" json:"status"`
	UpdatedTxID string `protobuf:"bytes,3,opt,name=updated_txid,json=updatedTxid,proto3" json:"updated_txid,omitempty"`

	Sequence     uint32 `protobuf:"varint,4,opt,name=sequence,proto3" json:"sequence,omitempty"`
	ServerAmount uint64 `protobuf:"varint,5,opt,name=server_amount,json=serverAmount,proto3" json:"server_amount,omitempty"`
	ClientAmount uint64 `protobuf:"varint,6,opt,name=client_amount,json=clientAmount,proto3" json:"client_amount,omitempty"`

	ErrorCode         string `protobuf:"bytes,7,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	Error             string `protobuf:"bytes,8,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	MergedCurrentTx   []byte `protobuf:"bytes,9,opt,name=merged_current_tx,json=mergedCurrentTx,proto3" json:"merged_current_tx,omitempty"`
	ProofStatePayload []byte `protobuf:"bytes,10,opt,name=proof_state_payload,json=proofStatePayload,proto3" json:"proof_state_payload,omitempty"`
	ServiceReceipt    []byte `protobuf:"bytes,11,opt,name=service_receipt,json=serviceReceipt,proto3" json:"service_receipt,omitempty"`
}

type PayStep struct {
	CycleIndex   uint32 `json:"cycle_index"`
	Sequence     uint32 `json:"sequence"`
	ServerAmount uint64 `json:"server_amount"`
	ClientAmount uint64 `json:"client_amount"`
	UpdatedTxID  string `json:"updated_txid"`
}

type ReceiptFinalizeSpec[T any] struct {
	ServiceType       string
	OfferHash         func(T) string
	ApplyPayOut       func(T, PayConfirmResp) T
	MarshalPayload    func(T) ([]byte, error)
	SetServiceReceipt func(T, []byte) T
}

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

type ServiceOfferRow struct {
	OfferHash              string
	ServiceType            string
	ServiceNodePubkeyHex   string
	ClientPubkeyHex        string
	RequestParams          []byte
	CreatedAtUnix          int64
	LastQuotedAtUnix       int64
	LastQuotedAmountSat    uint64
	LastQuoteExpiresAtUnix int64
}

type ServiceQuoteBuildInput struct {
	Offer               payflow.ServiceOffer
	ChargeAmountSatoshi uint64
	QuoteTTLSeconds     uint32
}

type ServiceQuotePaymentRow struct {
	QuoteHash       string
	OfferHash       string
	PaymentScheme   string
	PaymentTxID     string
	ClientPubkeyHex string
	AcceptedAtUnix  int64
}

type ServiceQuoteReq struct {
	ClientID string `protobuf:"bytes,1,opt,name=client_pubkey_hex,json=clientId,proto3" json:"client_pubkey_hex"`

	ServiceOffer         []byte `protobuf:"bytes,2,opt,name=service_offer,json=serviceOffer,proto3" json:"service_offer,omitempty"`
	ServiceParamsPayload []byte `protobuf:"bytes,3,opt,name=service_params_payload,json=serviceParamsPayload,proto3" json:"service_params_payload,omitempty"`
}

type ServiceQuoteResp struct {
	Success      bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success"`
	Status       string `protobuf:"bytes,2,opt,name=status,proto3" json:"status"`
	ServiceQuote []byte `protobuf:"bytes,3,opt,name=service_quote,json=serviceQuote,proto3" json:"service_quote,omitempty"`
	Error        string `protobuf:"bytes,4,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
}

type Session struct {
	Client      *Actor
	Server      *Actor
	InputAmount uint64
	PoolAmount  uint64
	EndHeight   uint32
	SpendTxFee  uint64

	SpendTxID    string
	BaseTxID     string
	FinalTxID    string
	BaseTxHex    string
	CurrentTxHex string

	Sequence     uint32
	ServerAmount uint64
	ClientAmount uint64
	Status       string

	PaySteps []PayStep
}

type StateReq struct {
	ClientID  string `protobuf:"bytes,1,opt,name=client_pubkey_hex,json=clientId,proto3" json:"client_pubkey_hex"`
	SpendTxID string `protobuf:"bytes,2,opt,name=spend_txid,json=spendTxid,proto3" json:"spend_txid,omitempty"`
}

type StateResp struct {
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status"`

	SpendTxID string `protobuf:"bytes,2,opt,name=spend_txid,json=spendTxid,proto3" json:"spend_txid,omitempty"`
	BaseTxID  string `protobuf:"bytes,3,opt,name=base_txid,json=baseTxid,proto3" json:"base_txid,omitempty"`
	FinalTxID string `protobuf:"bytes,4,opt,name=final_txid,json=finalTxid,proto3" json:"final_txid,omitempty"`
	CurrentTx []byte `protobuf:"bytes,5,opt,name=current_tx,json=currentTx,proto3" json:"current_tx,omitempty"`

	PoolAmountSat   uint64 `protobuf:"varint,6,opt,name=pool_amount_satoshi,json=poolAmountSatoshi,proto3" json:"pool_amount_satoshi"`
	SpendTxFeeSat   uint64 `protobuf:"varint,7,opt,name=spend_tx_fee_satoshi,json=spendTxFeeSatoshi,proto3" json:"spend_tx_fee_satoshi"`
	Sequence        uint32 `protobuf:"varint,8,opt,name=sequence,proto3" json:"sequence"`
	ServerAmountSat uint64 `protobuf:"varint,9,opt,name=server_amount_satoshi,json=serverAmountSatoshi,proto3" json:"server_amount_satoshi"`
	ClientAmountSat uint64 `protobuf:"varint,10,opt,name=client_amount_satoshi,json=clientAmountSatoshi,proto3" json:"client_amount_satoshi"`

	LifecycleState    string `protobuf:"bytes,11,opt,name=lifecycle_state,json=lifecycleState,proto3" json:"lifecycle_state,omitempty"`
	Payability        string `protobuf:"bytes,12,opt,name=payability,proto3" json:"payability,omitempty"`
	Phase             string `protobuf:"bytes,13,opt,name=phase,proto3" json:"phase,omitempty"`
	ExpireHeight      uint32 `protobuf:"varint,14,opt,name=expire_height,json=expireHeight,proto3" json:"expire_height,omitempty"`
	TipHeight         uint32 `protobuf:"varint,15,opt,name=tip_height,json=tipHeight,proto3" json:"tip_height,omitempty"`
	OutpointSpent     bool   `protobuf:"varint,16,opt,name=outpoint_spent,json=outpointSpent,proto3" json:"outpoint_spent"`
	ProofStatePayload []byte `protobuf:"bytes,17,opt,name=proof_state_payload,json=proofStatePayload,proto3" json:"proof_state_payload,omitempty"`
}

type SystemEndpoint struct {
	Name     string
	Chain    ChainClient
	FeeRate  float64
	Sessions map[string]*Session // key=spend_txid
}

type UTXO struct {
	TxID  string `json:"txid"`
	Vout  uint32 `json:"vout"`
	Value uint64 `json:"value"`
}