client

package

Go to main page

Versions in this module

v0

v0.2.2

Sep 19, 2024

Changes in this version

+ var ErrGCInvitationExpired = errors.New("invitation to GC expired")

type Client

+ func (c *Client) CancelDownload(fid clientdb.FileID) error

+ func (c *Client) SubscribeToAllRemotePosts(progressChan chan SendProgress) error

+ func (c *Client) UserLogNick(uid UserID) string

type Config

+ GCInviteExpiration time.Duration

type DcrlnPaymentClient

+ func (pc *DcrlnPaymentClient) LNRouter() routerrpc.RouterClient

v0.2.1

Jun 5, 2024

v0.2.0

May 9, 2024

Changes in this version

type Client

+ func (c *Client) AddressBookLoaded() <-chan struct{}

+ func (c *Client) AllRemoteUsers() []*RemoteUser

+ func (c *Client) Logger() slog.Logger

+ func (c *Client) Public() zkidentity.PublicIdentity

+ func (c *Client) SaveEmbed(data []byte, typ string) (string, error)

+ func (c *Client) UpdateLocalAvatar(avatar []byte) error

type Config

+ AutoSubscribeToPosts bool

+ Collator *collate.Collator

+ PingInterval time.Duration

type DcrlnPaymentClient

+ func (pc *DcrlnPaymentClient) LNChain() chainrpc.ChainNotifierClient

+ type OnProfileUpdated func(ru *RemoteUser, ab *clientdb.AddressBookEntry, fields []ProfileUpdateField)

+ type OnRMSent func(ru *RemoteUser, p interface{})

+ type OnRequestingMediateID func(mediator, target UserID)

+ type OnTransitiveEvent func(src, dst UserID, event TransitiveEvent)

+ type ProfileUpdateField string

+ const ProfileUpdateAvatar

v0.1.10

Jan 17, 2024

Changes in this version

type Client

+ func (c *Client) ListPostCommentReceiveReceipts(pid clientintf.PostID, statusID zkidentity.ShortID) ([]*clientdb.ReceiveReceipt, error)

+ func (c *Client) ListPostReceiveReceipts(pid clientintf.PostID) ([]*clientdb.ReceiveReceipt, error)

+ func (c *Client) ModifyGCOwner(gcid zkidentity.ShortID, newOwner clientintf.UserID, reason string) error

+ func (c *Client) ReadHistoryMessages(uid UserID, gcName string, page, pageNum int) ([]ChatHistoryEntry, time.Time, error)

+ func (c *Client) ServerSession() clientintf.ServerSessionIntf

type Config

+ SendReceiveReceipts bool

+ type OnContentListReceived func(user *RemoteUser, files []clientdb.RemoteFile, listErr error)

+ type OnFileDownloadCompleted func(user *RemoteUser, fm rpc.FileMetadata, diskPath string)

+ type OnFileDownloadProgress func(user *RemoteUser, fm rpc.FileMetadata, nbMissingChunks int)

+ type OnRMReceived func(ru *RemoteUser, h *rpc.RMHeader, p interface{}, ts time.Time)

+ type OnReceiveReceipt func(user *RemoteUser, rr rpc.RMReceiveReceipt, serverTime time.Time)

+ type OnServerUnwelcomeError func(err error)

v0.1.9

Sep 26, 2023

Changes in this version

type Client

+ func (c *Client) AddressBookEntry(uid UserID) (*clientdb.AddressBookEntry, error)

type Config

+ AutoHandshakeInterval time.Duration

+ AutoRemoveIdleUsersIgnoreList []string

+ AutoRemoveIdleUsersInterval time.Duration

+ type OnPostSubscriberUpdated func(user *RemoteUser, subscribed bool)

+ type OnPostsListReceived func(user *RemoteUser, postList rpc.RMListPostsReply)

+ type OnUnsubscribingIdleRemoteClient func(user *RemoteUser, lastDecTime time.Time)

v0.1.8

Jul 26, 2023

Changes in this version

+ func TrackWalletCheckEvents(ctx context.Context, lnRPC lnrpc.LightningClient) (chan struct{}, error)

+ type ChatHistoryEntry struct

+ From string

+ Internal bool

+ Message string

+ Timestamp int64

type Client

+ func (c *Client) Backup(_ context.Context, rootDir, destPath string) (string, error)

+ func (c *Client) FetchLocalResource(path []string, meta map[string]string) error

+ func (c *Client) FetchResource(uid UserID, path []string, meta map[string]string, ...) (rpc.ResourceTag, error)

+ func (c *Client) FillTestInterface(i *testutils.UnsafeTestInterface)

+ func (c *Client) FilterGCM(uid UserID, gcid zkidentity.ShortID, msg string) (bool, uint64)

+ func (c *Client) FilterPM(uid UserID, msg string) (bool, uint64)

+ func (c *Client) FilterPost(uid UserID, pid clientintf.PostID, post string) (bool, uint64)

+ func (c *Client) FilterPostComment(uid, postFrom UserID, pid clientintf.PostID, comment string) (bool, uint64)

+ func (c *Client) GCsWithMember(uid UserID) ([]zkidentity.ShortID, error)

+ func (c *Client) Handshake(uid UserID) error

+ func (c *Client) ListContentFilters() []clientdb.ContentFilter

+ func (c *Client) ListRunningTipUserAttempts() []RunningTipUserAttempt

+ func (c *Client) NewGroupChatVersion(name string, version uint8) (zkidentity.ShortID, error)

+ func (c *Client) NewPagesSession() (clientintf.PagesSessionID, error)

+ func (c *Client) OnchainRecvAddrForUser(uid UserID, acct string) (string, error)

+ func (c *Client) ReadUserHistoryMessages(uid UserID, gcName string, page, pageNum int) ([]ChatHistoryEntry, time.Time, error)

+ func (c *Client) RemoveAllContentFilters() error

+ func (c *Client) RemoveContentFilter(id uint64) error

+ func (c *Client) StoreContentFilter(cf *clientdb.ContentFilter) error

+ func (c *Client) UpdateOnchainRecvAddrForUser(uid UserID, addr string) error

+ func (c *Client) UserWithOnchainRecvAddr(addr string) *UserID

type Config

+ MaxAutoKXMediateIDRequests int

+ NoLoadChatHistory bool

+ RecentMediateIDThreshold time.Duration

+ ResourcesProvider resources.Provider

+ TipUserPayRetryDelayFactor time.Duration

+ UnkxdWarningTimeout time.Duration

type DcrlnPaymentClient

+ func (pc *DcrlnPaymentClient) ChainParams(ctx context.Context) (*chaincfg.Params, error)

+ func (pc *DcrlnPaymentClient) NewReceiveAddress(ctx context.Context, acct string) (stdaddr.Address, error)

+ func (pc *DcrlnPaymentClient) TrackInvoice(ctx context.Context, invoice string, minMAtoms int64) (int64, error)

+ func (pc *DcrlnPaymentClient) WatchTransactions(ctx context.Context, handler func(tx *lnrpc.Transaction))

+ type MsgContentFilteredEvent struct

+ GC *zkidentity.ShortID

+ IsPostComment bool

+ Msg string

+ PID *clientintf.PostID

+ PostFrom *clientintf.UserID

+ Rule clientdb.ContentFilter

+ UID UserID

type NotificationManager

+ func (ngmr *NotificationManager) AnyRegistered(handler NotificationHandler) bool

+ type OnGCWithUnkxdMemberNtfn func(gc zkidentity.ShortID, uid clientintf.UserID, hasKX, hasMI bool, ...)

+ type OnHandshakeStageNtfn func(ru *RemoteUser, msgtype string)

+ type OnMsgContentFilteredNtfn func(MsgContentFilteredEvent)

+ type OnResourceFetchedNtfn func(ru *RemoteUser, fr clientdb.FetchedResource, sess clientdb.PageSessionOverview)

+ type OnTipReceivedNtfn func(ru *RemoteUser, amountMAtoms int64)

+ type OnTipUserInvoiceGeneratedNtfn func(ru *RemoteUser, tag uint32, invoice string)

+ type RunningTipUserAttempt struct

+ NextAction string

+ NextActionTime time.Time

+ Tag int32

+ UID clientintf.UserID

v0.1.7

Apr 25, 2023

Changes in this version

type Client

+ func (c *Client) CancelOnboarding() error

+ func (c *Client) CreatePrepaidInvite(w io.Writer, funds *rpc.InviteFunds) (rpc.OOBPublicIdentityInvite, clientintf.PaidInviteKey, error)

+ func (c *Client) FetchPrepaidInvite(ctx context.Context, key clientintf.PaidInviteKey, w io.Writer) (rpc.OOBPublicIdentityInvite, error)

+ func (c *Client) ListTipUserAttempts(uid UserID) ([]clientdb.TipUserAttempt, error)

+ func (c *Client) ReadOnboard() (*clientintf.OnboardState, error)

+ func (c *Client) RetryOnboarding() error

+ func (c *Client) SkipOnboardingStage() error

+ func (c *Client) StartOnboarding(key clientintf.PaidInviteKey) error

type Config

+ GCMQInitialDelay time.Duration

+ GCMQMaxLifetime time.Duration

+ GCMQUpdtDelay time.Duration

+ TipUserMaxLifetime time.Duration

+ TipUserReRequestInvoiceDelay time.Duration

+ TipUserRestartDelay time.Duration

type DcrlnPaymentClient

+ func (pc *DcrlnPaymentClient) CreateInviteFunds(ctx context.Context, amount dcrutil.Amount, account string) (*rpc.InviteFunds, error)

+ func (pc *DcrlnPaymentClient) LNWallet() walletrpc.WalletKitClient

+ func (pc *DcrlnPaymentClient) RedeemInviteFunds(ctx context.Context, funds *rpc.InviteFunds) (dcrutil.Amount, chainhash.Hash, error)

+ func (pc *DcrlnPaymentClient) WaitNextBlock(ctx context.Context) (chainhash.Hash, uint32, error)

+ func (pc *DcrlnPaymentClient) WaitTxConfirmed(ctx context.Context, tx chainhash.Hash) error

+ type OnBlockNtfn func(user *RemoteUser)

+ type OnKXSuggested func(*RemoteUser, zkidentity.PublicIdentity)

+ type OnOnboardStateChangedNtfn func(state clientintf.OnboardState, err error)

+ type OnServerSessionChangedNtfn func(connected bool, pushRate, subRate, expirationDays uint64)

+ type OnTipAttemptProgressNtfn func(ru *RemoteUser, amtMAtoms int64, completed bool, attempt int, attemptErr error, ...)

v0.1.7-rc1

Apr 21, 2023

v0.1.6

Mar 30, 2023

Changes in this version

type Client

+ func (c *Client) AddInviteOnKX(initialRV, gcID zkidentity.ShortID) error

+ func (c *Client) GCsWithPrefix(prefix string) []string

+ func (c *Client) ModifyGCAdmins(gcid zkidentity.ShortID, extraAdmins []zkidentity.ShortID, reason string) error

+ func (c *Client) NicksWithPrefix(prefix string) []string

+ func (c *Client) SubscribeToPostsAndFetch(uid UserID, pid clientintf.PostID) error

+ func (c *Client) UpgradeGC(gcid zkidentity.ShortID, newVersion uint8) error

+ type ErrKXSearchNeeded struct

+ Author UserID

+ func (err ErrKXSearchNeeded) Error() string

+ func (err ErrKXSearchNeeded) Is(target error) bool

+ type OnAddedGCMembersNtfn func(gc rpc.RMGroupList, uids []clientintf.UserID)

+ type OnGCAdminsChangedNtfn func(ru *RemoteUser, gc rpc.RMGroupList, added, removed []zkidentity.ShortID)

+ type OnGCInviteAcceptedNtfn func(user *RemoteUser, gc rpc.RMGroupList)

+ type OnGCKilledNtfn func(gcid GCID, reason string)

+ type OnGCUpgradedNtfn func(gc rpc.RMGroupList, oldVersion uint8)

+ type OnGCUserPartedNtfn func(gcid GCID, uid UserID, reason string, kicked bool)

+ type OnInvitedToGCNtfn func(user *RemoteUser, iid uint64, invite rpc.RMGroupInvite)

+ type OnJoinedGCNtfn func(gc rpc.RMGroupList)

+ type OnKXSearchCompleted func(user *RemoteUser)

+ type OnRemovedGCMembersNtfn func(gc rpc.RMGroupList, uids []clientintf.UserID)

v0.1.6-rc1

Mar 22, 2023

v0.1.5

Feb 27, 2023

Changes in this version

type Client

+ func (c *Client) ResendGCList(gcid zkidentity.ShortID, uid *UserID) error

+ type OnGCVersionWarning func(user *RemoteUser, gc rpc.RMGroupList, minVersion, maxVersion uint8)

+ type OnInvoiceGenFailedNtfn func(user *RemoteUser, dcrAmount float64, err error)

+ type OnKXCompleted func(*RemoteUser)

v0.1.5-rc1

Feb 27, 2023

v0.1.4

Feb 16, 2023

Changes in this version

type Client

+ func (c *Client) ListUsersLastReceivedTime() ([]LastUserReceivedTime, error)

+ func (c *Client) NotificationManager() *NotificationManager

+ func (c *Client) ResetAllOldRatchets(limitInterval time.Duration, progrChan chan clientintf.UserID) ([]clientintf.UserID, error)

type Config

+ Notifications *NotificationManager

type DcrlnPaymentClient

+ func (pc *DcrlnPaymentClient) IsPaymentCompleted(ctx context.Context, invoice string) error

+ type LastUserReceivedTime struct

+ LastDecrypted time.Time

+ UID clientintf.UserID

+ type NotificationHandler interface

+ type NotificationManager struct

+ func NewNotificationManager() *NotificationManager

+ func (nmgr *NotificationManager) Register(handler NotificationHandler) NotificationRegistration

+ func (nmgr *NotificationManager) RegisterSync(handler NotificationHandler) NotificationRegistration

+ type NotificationRegistration struct

+ func (reg NotificationRegistration) Unregister() bool

+ type OnGCMNtfn func(*RemoteUser, rpc.RMGroupMessage, time.Time)

+ type OnLocalClientOfflineTooLong func(time.Time)

+ type OnPMNtfn func(*RemoteUser, rpc.RMPrivateMessage, time.Time)

+ type OnPostRcvdNtfn func(*RemoteUser, clientdb.PostSummary, rpc.PostMetadata)

+ type OnPostStatusRcvdNtfn func(*RemoteUser, clientintf.PostID, UserID, rpc.PostMetadataStatus)

+ type OnRemoteSubscriptionChangedNtfn func(*RemoteUser, bool)

+ type OnRemoteSubscriptionErrorNtfn func(user *RemoteUser, wasSubscribing bool, errMsg string)

+ type RatchetDebugInfo struct

+ DrainRV ratchet.RVPoint

+ DrainRVPlain string

+ LastDecTime time.Time

+ LastEncTime time.Time

+ MyResetRV string

+ NbSavedKeys int

+ RecvRV ratchet.RVPoint

+ RecvRVPlain string

+ SendRV ratchet.RVPoint

+ SendRVPlain string

+ TheirResetRV string

+ WillRatchet bool

type RemoteUser

+ func (ru *RemoteUser) LastRatchetTimes() (time.Time, time.Time)

+ func (ru *RemoteUser) RatchetDebugInfo() RatchetDebugInfo

v0.1.3

Jan 20, 2023

Changes in this version

type Config

+ RemoteSubscriptionChanged func(user *RemoteUser, subscribed bool)

+ RemoteSubscriptionError func(user *RemoteUser, wasSubscribing bool, errMsg string)

v0.1.2

Jan 6, 2023

Changes in this version

type Client

+ func (c *Client) RMQTimingStat() []timestats.Quantile

type DcrlnPaymentClient

+ func (pc *DcrlnPaymentClient) PaymentTimingStats() []timestats.Quantile

v0.1.1

Dec 16, 2022

v0.1.0

Dec 13, 2022

Changes in this version

+ const ErrLowOutboundBalance

+ const ErrNoActiveChannels

+ const ErrNoPeers

+ const ErrNoRouteToServer

+ const ErrTooOldBlockchain

+ const ErrUnableToPingPeers

+ const ErrUnableToQueryNode

+ const TEMediateID

+ const TEMsgForward

+ const TEReceivedInvite

+ const TERequestInvite

+ const TEResetReply

+ const TEResetRequest

+ func CheckLNWalletUsable(ctx context.Context, lc lnrpc.LightningClient, svrNode string) error

+ func PaymentFeeLimit(amountMAtoms uint64) *lnrpc.FeeLimit

+ type AddressBookEntry struct

+ ID UserID

+ Ignored bool

+ Name string

+ Nick string

+ type Client struct

+ func New(cfg Config) (*Client, error)

+ func (c *Client) AcceptGroupChatInvite(iid uint64) error

+ func (c *Client) AcceptInvite(invite rpc.OOBPublicIdentityInvite) error

+ func (c *Client) AddToGCBlockList(gcid zkidentity.ShortID, uid UserID) error

+ func (c *Client) AddressBook() []*AddressBookEntry

+ func (c *Client) AliasGC(gcID zkidentity.ShortID, newAlias string) error

+ func (c *Client) Block(uid UserID) error

+ func (c *Client) ClearPayStats(uid *UserID) error

+ func (c *Client) CommentPost(postFrom clientintf.UserID, pid clientintf.PostID, comment string, ...) error

+ func (c *Client) CreatePost(post, descr string) (clientdb.PostSummary, error)

+ func (c *Client) FindSharedFileID(fname string) (clientdb.FileID, error)

+ func (c *Client) GCIDByName(name string) (zkidentity.ShortID, error)

+ func (c *Client) GCKick(gcID zkidentity.ShortID, uid UserID, reason string) error

+ func (c *Client) GCMessage(gcID zkidentity.ShortID, msg string, mode rpc.MessageMode, ...) error

+ func (c *Client) GetGC(gcID zkidentity.ShortID) (clientdb.GCAddressBookEntry, error)

+ func (c *Client) GetGCAlias(gcID zkidentity.ShortID) (string, error)

+ func (c *Client) GetGCBlockList(gcID zkidentity.ShortID) (clientdb.GCBlockList, error)

+ func (c *Client) GetKXSearch(targetID UserID) (clientdb.KXSearch, error)

+ func (c *Client) GetUserContent(uid UserID, fid clientdb.FileID) error

+ func (c *Client) GetUserPost(from UserID, pid clientintf.PostID, includeStatus bool) error

+ func (c *Client) GoOnline()

+ func (c *Client) HasDownloadedFile(fid zkidentity.ShortID) (bool, error)

+ func (c *Client) HasPostSubscribers() (bool, error)

+ func (c *Client) HeartPost(from clientintf.UserID, pid clientintf.PostID, heart bool) error

+ func (c *Client) Ignore(uid UserID, ignore bool) error

+ func (c *Client) InviteToGroupChat(gcID zkidentity.ShortID, user UserID) error

+ func (c *Client) IsIgnored(uid clientintf.UserID) (bool, error)

+ func (c *Client) KXSearchPostAuthor(postFrom UserID, post clientintf.PostID) error

+ func (c *Client) KillGroupChat(gcID zkidentity.ShortID, reason string) error

+ func (c *Client) ListDownloads() ([]clientdb.FileDownload, error)

+ func (c *Client) ListGCInvitesFor(gcName string) ([]*clientdb.GCInvite, error)

+ func (c *Client) ListGCs() ([]clientdb.GCAddressBookEntry, error)

+ func (c *Client) ListKXSearches() ([]UserID, error)

+ func (c *Client) ListKXs() ([]clientdb.KXData, error)

+ func (c *Client) ListLocalSharedFiles() ([]clientdb.SharedFileAndShares, error)

+ func (c *Client) ListMediateIDs() ([]clientdb.MediateIDRequest, error)

+ func (c *Client) ListPaymentStats() (map[UserID]clientdb.UserPayStats, error)

+ func (c *Client) ListPostStatusUpdates(from UserID, pid clientintf.PostID) ([]rpc.PostMetadataStatus, error)

+ func (c *Client) ListPostSubscribers() ([]clientintf.UserID, error)

+ func (c *Client) ListPostSubscriptions() ([]clientdb.PostSubscription, error)

+ func (c *Client) ListPosts() ([]clientdb.PostSummary, error)

+ func (c *Client) ListUserContent(uid UserID, dirs []string, filter string) error

+ func (c *Client) ListUserPosts(uid UserID) error

+ func (c *Client) LocalNick() string

+ func (c *Client) NewGroupChat(name string) (zkidentity.ShortID, error)

+ func (c *Client) PM(uid UserID, msg string) error

+ func (c *Client) PartFromGC(gcID zkidentity.ShortID, reason string) error

+ func (c *Client) PublicID() UserID

+ func (c *Client) RMQLen() int

+ func (c *Client) RVsUpToDate() bool

+ func (c *Client) ReadInvite(r io.Reader) (rpc.OOBPublicIdentityInvite, error)

+ func (c *Client) ReadPost(uid clientintf.UserID, pid clientintf.PostID) (rpc.PostMetadata, error)

+ func (c *Client) RelayPost(postFrom clientintf.UserID, pid clientintf.PostID, toUser clientintf.UserID) error

+ func (c *Client) RelayPostToSubscribers(postFrom clientintf.UserID, pid clientintf.PostID) error

+ func (c *Client) RemainOffline()

+ func (c *Client) RemoveFromGCBlockList(gcid zkidentity.ShortID, uid UserID) error

+ func (c *Client) RenameUser(uid UserID, newNick string) error

+ func (c *Client) RequestMediateIdentity(mediator, target UserID) error

+ func (c *Client) RequestTransitiveReset(mediator, target UserID) error

+ func (c *Client) ResetRatchet(uid UserID) error

+ func (c *Client) Run(ctx context.Context) error

+ func (c *Client) SendFile(uid UserID, filepath string) error

+ func (c *Client) ServerLNNode() string

+ func (c *Client) ShareFile(fname string, uid *UserID, cost uint64, isRef bool, descr string) (clientdb.SharedFile, rpc.FileMetadata, error)

+ func (c *Client) SubscribeToPosts(uid UserID) error

+ func (c *Client) SuggestKX(invitee, target UserID) error

+ func (c *Client) SummarizeUserPayStats(uid UserID) ([]clientdb.PayStatsSummary, error)

+ func (c *Client) TipUser(uid UserID, dcrAmount float64) error

+ func (c *Client) UIDByNick(nick string) (UserID, error)

+ func (c *Client) UnshareFile(fid clientdb.FileID, uid *UserID) error

+ func (c *Client) UnsubscribeToPosts(uid UserID) error

+ func (c *Client) UserByID(uid UserID) (*RemoteUser, error)

+ func (c *Client) UserByNick(nick string) (*RemoteUser, error)

+ func (c *Client) UserExists(id UserID) bool

+ func (c *Client) UserNick(uid UserID) (string, error)

+ func (c *Client) WriteNewInvite(w io.Writer) (rpc.OOBPublicIdentityInvite, error)

+ type Config struct

+ CertConfirmer clientintf.CertConfirmer

+ CheckServerSession func(connCtx context.Context, lnNode string) error

+ CompressLevel int

+ ContentListReceived func(user *RemoteUser, files []clientdb.RemoteFile, listErr error)

+ DB *clientdb.DB

+ Dialer clientintf.Dialer

+ FileDownloadCompleted func(user *RemoteUser, fm rpc.FileMetadata, diskPath string)

+ FileDownloadConfirmer func(user *RemoteUser, fm rpc.FileMetadata) bool

+ FileDownloadProgress func(user *RemoteUser, fm rpc.FileMetadata, nbMissingChunks int)

+ GCInviteHandler func(user *RemoteUser, iid uint64, invite rpc.RMGroupInvite)

+ GCJoinHandler func(user *RemoteUser, gc clientdb.GCAddressBookEntry)

+ GCKilled func(gcid GCID, reason string)

+ GCListUpdated func(gc clientdb.GCAddressBookEntry)

+ GCMInterMsgDelay time.Duration

+ GCMMaxDelay time.Duration

+ GCMsgHandler func(user *RemoteUser, msg rpc.RMGroupMessage, ts time.Time)

+ GCUserParted func(gcid GCID, uid UserID, reason string, kicked bool)

+ GCWithUnkxdMember func(gcid GCID, uid UserID)

+ KXCompleted func(user *RemoteUser)

+ KXSearchCompleted func(user *RemoteUser)

+ KXSuggestion func(user *RemoteUser, pii zkidentity.PublicIdentity)

+ LocalIDIniter func(ctx context.Context) (*zkidentity.FullIdentity, error)

+ LogPings bool

+ Logger func(subsys string) slog.Logger

+ PMHandler func(user *RemoteUser, msg rpc.RMPrivateMessage, ts time.Time)

+ PayClient clientintf.PaymentClient

+ PostReceived func(user *RemoteUser, summary clientdb.PostSummary, post rpc.PostMetadata)

+ PostStatusReceived func(user *RemoteUser, pid clientintf.PostID, statusFrom UserID, ...)

+ PostsListReceived func(user *RemoteUser, postList rpc.RMListPostsReply)

+ ReconnectDelay time.Duration

+ ServerSessionChanged func(connected bool, pushRate, subRate, expirationDays uint64)

+ SubscriptionChanged func(user *RemoteUser, subscribed bool)

+ TipReceived func(user *RemoteUser, amount float64)

+ TransitiveEvent func(src, dst UserID, event TransitiveEvent)

+ UserBlocked func(user *RemoteUser)

+ type DcrlnPaymentClient struct

+ func NewDcrlndPaymentClient(ctx context.Context, cfg DcrlnPaymentClientCfg) (*DcrlnPaymentClient, error)

+ func (pc *DcrlnPaymentClient) DecodeInvoice(ctx context.Context, invoice string) (clientintf.DecodedInvoice, error)

+ func (pc *DcrlnPaymentClient) GetInvoice(ctx context.Context, mat int64, cb func(int64)) (string, error)

+ func (pc *DcrlnPaymentClient) IsInvoicePaid(ctx context.Context, minMatAmt int64, invoice string) error

+ func (pc *DcrlnPaymentClient) LNRPC() lnrpc.LightningClient

+ func (pc *DcrlnPaymentClient) PayInvoice(ctx context.Context, invoice string) (int64, error)

+ func (pc *DcrlnPaymentClient) PayInvoiceAmount(ctx context.Context, invoice string, amount int64) (int64, error)

+ func (pc *DcrlnPaymentClient) PayScheme() string

+ func (pc *DcrlnPaymentClient) UnlockWallet(ctx context.Context, pass string) error

+ type DcrlnPaymentClientCfg struct

+ Address string

+ Log slog.Logger

+ MacaroonPath string

+ TLSCertPath string

+ type GCID = zkidentity.ShortID

+ type RemoteUser struct

+ func (ru *RemoteUser) AddressBookEntry() AddressBookEntry

+ func (ru *RemoteUser) ID() UserID

+ func (ru *RemoteUser) IsIgnored() bool

+ func (ru *RemoteUser) Nick() string

+ func (ru *RemoteUser) PublicIdentity() zkidentity.PublicIdentity

+ func (ru *RemoteUser) SetIgnored(ignored bool)

+ func (ru *RemoteUser) String() string

+ type SendProgress struct

+ Err error

+ Sent int

+ Total int

+ type TransitiveEvent string

+ type UserID = clientintf.UserID

+ func SortedUserPayStatsIDs(stats map[UserID]clientdb.UserPayStats) []UserID

+ func UserIDFromStr(s string) UserID

+ type WalletUsableError struct

+ func (err WalletUsableError) Error() string

+ func (err WalletUsableError) Unwrap() error

+ type WalletUsableErrorKind string

+ func (err WalletUsableErrorKind) Error() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL