clientintf

type CertConfirmer func(context.Context, *tls.ConnectionState, *zkidentity.PublicIdentity) error

type Conn interface {
	io.Reader
	io.Writer
	io.Closer
	RemoteAddr() net.Addr
}

type DecodedInvoice struct {
	ID         []byte
	MAtoms     int64
	ExpiryTime time.Time
}

type DialFunc func(context.Context, string, string) (net.Conn, error)

type Dialer func(context.Context) (Conn, *tls.ConnectionState, error)

type FileID = ID

type FreePaymentClient struct{}

type ID = zkidentity.ShortID

type OnboardStage string

type OnboardState struct {
	Stage        OnboardStage                 `json:"stage"`
	Key          *PaidInviteKey               `json:"key"`
	Invite       *rpc.OOBPublicIdentityInvite `json:"invite"`
	RedeemTx     *chainhash.Hash              `json:"redeem_tx"`
	RedeemAmount dcrutil.Amount               `json:"redeem_amount"`
	OutChannelID string                       `json:"out_channel_id"`
	InChannelID  string                       `json:"in_channel_id"`

	OutChannelHeightHint  uint32 `json:"out_channel_height_hint"`
	OutChannelMinedHeight uint32 `json:"out_channel_mined_height"`
	OutChannelConfsLeft   int32  `json:"out_channel_confs_left"`
}

type PagesSessionID uint64

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

type PaymentClient interface {
	PayScheme() string
	PayInvoice(context.Context, string) (int64, error)
	PayInvoiceAmount(context.Context, string, int64) (int64, error)
	GetInvoice(context.Context, int64, func(int64)) (string, error)
	DecodeInvoice(context.Context, string) (DecodedInvoice, error)
	IsInvoicePaid(context.Context, int64, string) error
	TrackInvoice(context.Context, string, int64) (int64, error)
	IsPaymentCompleted(context.Context, string) (int64, error)
}

type PostID = ID

type RawRVID = ID

type ReceivedGCMsg struct {
	MsgID   zkidentity.ShortID `json:"msg_id"`
	UID     UserID             `json:"uid"`
	GCM     rpc.RMGroupMessage `json:"gcm"`
	TS      time.Time          `json:"ts"`
	GCAlias string             `json:"gc_alias"`
}

type ServerPolicy struct {
	PushPaymentLifetime time.Duration `json:"push_payment_lifetime"`
	MaxPushInvoices     int           `json:"max_push_invoices"`

	// MaxMsgSizeVersion is the version of the max message size accepted
	// by the server.
	MaxMsgSizeVersion rpc.MaxMsgSizeVersion `json:"max_msg_size_version"`

	// MaxMsgSize is the maximum message size accepted by the server.
	MaxMsgSize uint `json:"max_msg_size"`

	// ExpirationDays is the number of days after which data pushed to the server
	// is removed if not fetched.
	ExpirationDays int `json:"expiration_days"`

	// PushPayRateMAtoms is the rate (in milli-atoms per PushPayRateBytes) to
	// push data to the server.
	PushPayRateMAtoms uint64 `json:"push_pay_rate_matoms"`

	// PushPayRateBytes is the number of bytes used in calculating the final
	// push pay rate.
	PushPayRateBytes uint64 `json:"push_pay_rate_bytes"`

	// PushPayRateMinMAtoms is the minimum payment amount (in MAtoms)
	// independently of size.
	PushPayRateMinMAtoms uint64 `json:"push_pay_rate_min_matoms"`

	// SubPayRate is the rate (in milli-atoms) to subscribe to an RV point
	// on the server.
	SubPayRate uint64 `json:"sub_pay_rate"`

	// PingLimit is the deadline for writing messages (including ping) to
	// the server.
	PingLimit time.Duration `json:"ping_limit"`

	// ClientVersions is a list of server-provided client and versions
	// suggested for use when connecting to this server. This can be used
	// by the client to determine if it should be updated.
	ClientVersions []rpc.SuggestedClientVersion `json:"client_versions"`

	MilliAtomsPerRTSess     uint64
	MilliAtomsPerUserRTSess uint64
	MilliAtomsGetCookie     uint64
	MilliAtomsPerUserCookie uint64
	MilliAtomsRTJoin        uint64
	MilliAtomsRTPushRate    uint64
	RTPushRateMBytes        uint64
}

type ServerSessionIntf interface {
	SendPRPC(msg rpc.Message, payload interface{}, reply chan<- interface{}) error
	RequestClose(err error)
	PayClient() PaymentClient
	Policy() ServerPolicy

	// Context returns a context that gets cancelled once this session stops
	// running.
	Context() context.Context
}

type UserID = ID