clientdb

package

Go to main page

Versions in this module

v0

v0.2.0

May 9, 2024

Changes in this version

type AddressBookEntry

+ LastCompletedKX time.Time

+ NickAlias string

+ func (abe *AddressBookEntry) Nick() string

type Config

+ EmbedsRoot string

type DB

+ func (db *DB) PopEarlyPostStatusUpdate(tx ReadWriteTx, from UserID, pid PostID) ([]rpc.RMPostShare, error)

+ func (db *DB) PruneEmbeds(age time.Duration) error

+ func (db *DB) SaveEmbed(filename string, data []byte) (string, error)

+ func (db *DB) StoreEarlyPostStatusUpdate(tx ReadWriteTx, from UserID, pid PostID, rmps rpc.RMPostShare) error

+ type EarlyPostStatus struct

+ PID PostID

+ Status rpc.RMPostShare

v0.1.10

Jan 17, 2024

Changes in this version

type DB

+ func (db *DB) ListPostCommentReceiveReceipts(tx ReadTx, postFrom UserID, pid PostID, commentID zkidentity.ShortID) ([]*ReceiveReceipt, error)

+ func (db *DB) ListPostReceiveReceipts(tx ReadTx, postFrom UserID, pid PostID) ([]*ReceiveReceipt, error)

+ func (db *DB) StoreReceiveReceipt(tx ReadWriteTx, sender, localID UserID, rr *rpc.RMReceiveReceipt, ...) error

+ type ReceiveReceipt struct

+ ClientTime int64

+ ServerTime int64

+ User UserID

v0.1.9

Sep 26, 2023

Changes in this version

+ type AddressBookAndRatchet struct

+ AddressBook *AddressBookEntry

+ Ratchet *ratchet.Ratchet

type AddressBookEntry

+ FirstCreated time.Time

+ LastHandshakeAttempt time.Time

v0.1.8

Jul 26, 2023

Changes in this version

+ var ErrLocalIDEmpty = errors.New("local ID is not initialized")

+ var ErrServerIDEmpty = errors.New("server ID is not known")

+ type ContentFilter struct

+ GC *zkidentity.ShortID

+ ID uint64

+ Regexp string

+ SkipGCMs bool

+ SkipPMs bool

+ SkipPostComments bool

+ SkipPosts bool

+ UID *UserID

type DB

+ func (db *DB) Backup(_ ReadTx, rootDir, destPath string) (string, error)

+ func (db *DB) CacheReceivedGCM(tx ReadWriteTx, rgcm clientintf.ReceivedGCMsg) error

+ func (db *DB) HasKXWithUser(tx ReadTx, target UserID) ([]KXData, error)

+ func (db *DB) ListCachedRGCMs(tx ReadTx) ([]clientintf.ReceivedGCMsg, error)

+ func (db *DB) ListContentFilters(tx ReadTx) ([]ContentFilter, error)

+ func (db *DB) ListGCsWithMember(tx ReadTx, uid UserID) ([]zkidentity.ShortID, error)

+ func (db *DB) ListGeneratedTipInvoices(tx ReadTx) ([]GeneratedInvoiceForTip, error)

+ func (db *DB) ListOldestValidTipUserAttempts(tx ReadTx, maxLifetime time.Duration) ([]TipUserAttempt, error)

+ func (db *DB) MarkGeneratedTipInvoiceExpired(tx ReadWriteTx, uid UserID, invoice string) error

+ func (db *DB) MarkGeneratedTipInvoiceReceived(tx ReadWriteTx, uid UserID, invoice string, receivedMAtoms int64) error

+ func (db *DB) NewPagesSession(tx ReadWriteTx) (clientintf.PagesSessionID, error)

+ func (db *DB) NextTipAttemptToRetryForUser(tx ReadTx, uid UserID, maxLifetime time.Duration) (TipUserAttempt, error)

+ func (db *DB) OnchainRecvAddrForUser(tx ReadTx, uid UserID) (string, error)

+ func (db *DB) ReadLogGCMsg(tx ReadTx, gcName string, gcID zkidentity.ShortID, page, pageNum int) ([]PMLogEntry, error)

+ func (db *DB) ReadLogPM(tx ReadTx, uid UserID, page, pageNum int) ([]PMLogEntry, error)

+ func (db *DB) ReadUnxkdUserInfo(tx ReadTx, uid UserID) (UnkxdUserInfo, error)

+ func (db *DB) RemoveCachedRGCM(tx ReadWriteTx, rgcm clientintf.ReceivedGCMsg) error

+ func (db *DB) RemoveContentFilter(tx ReadWriteTx, filterID uint64) error

+ func (db *DB) RemoveUnkxUserInfo(tx ReadWriteTx, uid UserID) error

+ func (db *DB) StoreContentFilter(tx ReadWriteTx, filter *ContentFilter) error

+ func (db *DB) StoreFetchedResource(tx ReadWriteTx, uid UserID, tag rpc.ResourceTag, ...) (FetchedResource, PageSessionOverview, error)

+ func (db *DB) StoreGeneratedTipInvoice(tx ReadWriteTx, uid UserID, invoice string, amountMAtoms int64) error

+ func (db *DB) StoreResourceRequest(tx ReadWriteTx, uid UserID, sess, parentPage clientintf.PagesSessionID, ...) error

+ func (db *DB) StoreUnkxdUserInfo(tx ReadWriteTx, info UnkxdUserInfo) error

+ func (db *DB) UpdateOnchainRecvAddrForUser(tx ReadWriteTx, uid UserID, addr string) error

+ func (db *DB) UserWithOnchainRecvAddr(tx ReadTx, addr string) *UserID

+ type FetchedResource struct

+ PageID clientintf.PagesSessionID

+ ParentPage clientintf.PagesSessionID

+ Request rpc.RMFetchResource

+ RequestTS time.Time

+ Response rpc.RMFetchResourceReply

+ ResponseTS time.Time

+ SessionID clientintf.PagesSessionID

+ UID UserID

+ type GeneratedInvoiceForTip struct

+ Created time.Time

+ Invoice string

+ MilliAtoms uint64

+ UID UserID

+ type PMLogEntry struct

+ From string

+ Internal bool

+ Message string

+ Timestamp int64

+ type PageSessionOverview struct

+ LastRequestTS time.Time

+ LastResponseTS time.Time

+ Requests []PageSessionOverviewRequest

+ Responses []PageSessionOverviewResponse

+ type PageSessionOverviewRequest struct

+ Tag rpc.ResourceTag

+ UID clientintf.UserID

+ type PageSessionOverviewResponse struct

+ ID clientintf.PagesSessionID

+ Parent clientintf.PagesSessionID

+ type ResourceRequest struct

+ ParentPage clientintf.PagesSessionID

+ Request rpc.RMFetchResource

+ SesssionID clientintf.PagesSessionID

+ Timestamp time.Time

+ UID UserID

type TipUserAttempt

+ PaymentAttemptCount uint32

+ PaymentAttemptFailed *time.Time

+ type UnkxdUserInfo struct

+ AddedToGCTime *time.Time

+ MIRequests uint32

+ UID UserID

v0.1.7

Apr 25, 2023

Changes in this version

type DB

+ func (db *DB) HasOnboardState(tx ReadTx) bool

+ func (db *DB) KXExists(tx ReadTx, initialRV RawRVID) bool

+ func (db *DB) ListTipUserAttempts(tx ReadTx, uid UserID) ([]TipUserAttempt, error)

+ func (db *DB) ListTipUserAttemptsToRetry(tx ReadTx, ignoreAfter time.Time, maxLifetime time.Duration) ([]TipUserAttempt, error)

+ func (db *DB) ReadOnboardState(tx ReadTx) (clientintf.OnboardState, error)

+ func (db *DB) ReadTipAttempt(tx ReadWriteTx, uid UserID, tag int32) (TipUserAttempt, error)

+ func (db *DB) RemoveOnboardState(tx ReadWriteTx) error

+ func (db *DB) RemoveTipUserAttempt(tx ReadWriteTx, uid UserID, tag int32) error

+ func (db *DB) StoreTipUserAttempt(tx ReadWriteTx, ta TipUserAttempt) error

+ func (db *DB) UnusedTipUserTag(tx ReadWriteTx, uid clientintf.UserID) int32

+ func (db *DB) UpdateOnboardState(tx ReadWriteTx, st *clientintf.OnboardState) error

+ type TipUserAttempt struct

+ Attempts int32

+ Completed *time.Time

+ Created time.Time

+ InvoiceRequested time.Time

+ LastInvoice string

+ LastInvoiceError *string

+ MaxAttempts int32

+ MilliAtoms uint64

+ PaymentAttempt *time.Time

+ PrevInvoices []string

+ Tag int32

+ UID UserID

v0.1.7-rc1

Apr 21, 2023

v0.1.6

Mar 30, 2023

Changes in this version

type DB

+ func (db *DB) AddInitialKXAction(tx ReadWriteTx, initialRV zkidentity.ShortID, action PostKXAction) error

+ func (db *DB) DelAllInvitesToGC(tx ReadWriteTx, gcid zkidentity.ShortID) error

+ func (db *DB) FindAcceptedGCInvite(tx ReadTx, gcID, uid zkidentity.ShortID) (rpc.RMGroupInvite, uint64, error)

+ func (db *DB) InitialToPostKXActions(tx ReadWriteTx, initialRV, target zkidentity.ShortID) error

+ func (db *DB) RemoveInitialKXActions(tx ReadWriteTx, initialRV zkidentity.ShortID) error

+ func (db *DB) RemoveRelayedPostCopies(author UserID, pid PostID) error

type PostKXActionType

+ const PKXActionInviteGC

v0.1.6-rc1

Mar 22, 2023

v0.1.5

Feb 27, 2023

v0.1.5-rc1

Feb 27, 2023

v0.1.4

Feb 16, 2023

Changes in this version

type DB

+ func (db *DB) CleanupPushPaymentAttempts(tx ReadWriteTx, limit time.Time) error

+ func (db *DB) DeletePushPaymentAttempt(tx ReadWriteTx, rv ratchet.RVPoint) error

+ func (db *DB) HasPushPaymentAttempt(tx ReadTx, rv ratchet.RVPoint) (string, time.Time, error)

+ func (db *DB) ReplaceLastConnDate(tx ReadWriteTx, date time.Time) (time.Time, error)

+ func (db *DB) StorePushPaymentAttempt(tx ReadWriteTx, rv ratchet.RVPoint, invoice string, time time.Time) error

+ func (db *DB) StoreUserUnackedRM(tx ReadWriteTx, uid UserID, encrypted []byte, rv RawRVID, payEvent string) error

v0.1.3

Jan 20, 2023

Changes in this version

+ var ErrNotSubscribed = errors.New("not subscribed")

v0.1.2

Jan 6, 2023

v0.1.1

Dec 16, 2022

v0.1.0

Dec 13, 2022

Changes in this version

+ var ErrAlreadyExists = errors.New("already exists")

+ var ErrAlreadySubscribed = errors.New("already subscribed")

+ var ErrDuplicatePostStatus = errors.New("duplicate post status")

+ var ErrNotFound = errors.New("entry not found")

+ var ErrPostStatusValidation = errors.New("invalid post status update")

+ var LocalIDEmptyError = errors.New("local ID is not initialized")

+ var ServerIDEmptyError = errors.New("server ID is not known")

+ func RMGroupListToGCEntry(gc *rpc.RMGroupList, entry *GCAddressBookEntry)

+ type AddressBookEntry struct

+ ID *zkidentity.PublicIdentity

+ Ignored bool

+ MyResetRV RawRVID

+ R *ratchet.Ratchet

+ TheirResetRV RawRVID

+ type ChunkID = clientintf.ID

+ type ChunkState string

+ const ChunkStateDownloaded

+ const ChunkStateHasInvoice

+ const ChunkStatePaid

+ const ChunkStatePayingInvoice

+ const ChunkStateRequestedChunk

+ const ChunkStateSentInvoice

+ const ChunkStateUploaded

+ type ChunkUpload struct

+ CID ChunkID

+ FID FileID

+ Index int

+ Invoices []string

+ Paid int

+ State ChunkState

+ UID UserID

+ type Config struct

+ ChunkSize int

+ DownloadsRoot string

+ LocalIDInitier func() zkidentity.FullIdentity

+ Logger slog.Logger

+ MsgsRoot string

+ Root string

+ type DB struct

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

+ func (db *DB) AddChunkUploadInvoice(tx ReadWriteTx, uid UserID, fid FileID, cid ChunkID, index int, invoice string) error

+ func (db *DB) AddGCInvite(tx ReadWriteTx, user UserID, invite rpc.RMGroupInvite) (uint64, error)

+ func (db *DB) AddKXSearchQuery(tx ReadWriteTx, target UserID, search rpc.RMKXSearch, query KXSearchQuery) error

+ func (db *DB) AddPostKXAction(tx ReadWriteTx, target UserID, action PostKXAction) error

+ func (db *DB) AddPostStatus(tx ReadWriteTx, postFrom, statusFrom UserID, pid PostID, ...) error

+ func (db *DB) AddPostStatusUpdate(tx ReadWriteTx, from UserID, p rpc.PostMetadata) (UserID, rpc.PostMetadataStatus, error)

+ func (db *DB) AddToGCBlockList(tx ReadWriteTx, gcid zkidentity.ShortID, uid UserID) error

+ func (db *DB) AddToSendQueue(tx ReadWriteTx, typ string, dests []UserID, msg []byte, priority uint) (SendQID, error)

+ func (db *DB) AddUniquePostKXAction(tx ReadWriteTx, target UserID, action PostKXAction) error

+ func (db *DB) AddressBookEntryExists(tx ReadTx, id UserID) bool

+ func (db *DB) CancelFileDownload(tx ReadWriteTx, fid FileID) error

+ func (db *DB) CleanupPaidRVs(tx ReadWriteTx, expirationDays int) error

+ func (db *DB) ClearPayStats(tx ReadWriteTx, user *UserID) error

+ func (db *DB) CreatePost(tx ReadWriteTx, post, descr string, fname string, extraAttrs map[string]string, ...) (PostSummary, rpc.PostMetadata, error)

+ func (db *DB) DelGCInvite(tx ReadWriteTx, inviteID uint64) error

+ func (db *DB) DeleteGC(tx ReadWriteTx, gcID zkidentity.ShortID) error

+ func (db *DB) DeleteKX(tx ReadWriteTx, initialRV RawRVID) error

+ func (db *DB) DeleteTransResetHalfKX(tx ReadWriteTx, id UserID) error

+ func (db *DB) FindGCInvite(tx ReadTx, gcID zkidentity.ShortID, token uint64) (rpc.RMGroupInvite, UserID, uint64, error)

+ func (db *DB) FindSharedFileID(tx ReadTx, fname string) (FileID, error)

+ func (db *DB) GetAddressBookEntry(tx ReadTx, id UserID, localID *zkidentity.FullIdentity) (*AddressBookEntry, error)

+ func (db *DB) GetFileChunkUpload(tx ReadTx, uid UserID, fid FileID, cid ChunkID) (ChunkUpload, error)

+ func (db *DB) GetGC(tx ReadTx, id zkidentity.ShortID) (rpc.RMGroupList, error)

+ func (db *DB) GetGCAliases(tx ReadTx) (map[string]zkidentity.ShortID, error)

+ func (db *DB) GetGCBlockList(tx ReadTx, gcid zkidentity.ShortID) (GCBlockList, error)

+ func (db *DB) GetGCInvite(tx ReadTx, inviteID uint64) (rpc.RMGroupInvite, UserID, error)

+ func (db *DB) GetKX(tx ReadTx, initialRV RawRVID) (KXData, error)

+ func (db *DB) GetKXSearch(tx ReadTx, target UserID) (KXSearch, error)

+ func (db *DB) GetSharedFile(tx ReadTx, uid *UserID, fid FileID) (SharedFile, rpc.FileMetadata, error)

+ func (db *DB) GetSharedFileChunkData(tx ReadTx, sf *SharedFile, chunkIdx int) ([]byte, error)

+ func (db *DB) GetSharedFileForUpload(tx ReadTx, uid UserID, fid FileID) (SharedFile, rpc.FileMetadata, error)

+ func (db *DB) HasAnyRecentMediateID(tx ReadTx, target UserID, recentThreshold time.Duration) (bool, error)

+ func (db *DB) HasDownloadedFile(tx ReadTx, fid zkidentity.ShortID) (bool, error)

+ func (db *DB) HasDownloadedFiles(tx ReadTx, user string, uid UserID, files []rpc.FileMetadata) ([]RemoteFile, error)

+ func (db *DB) HasMediateID(tx ReadTx, mediator, target UserID) (MediateIDRequest, error)

+ func (db *DB) IsBlocked(tx ReadTx, id UserID) bool

+ func (db *DB) IsPostSubscriber(tx ReadTx, uid UserID) (bool, error)

+ func (db *DB) IsPostSubscription(tx ReadTx, uid UserID) (bool, error)

+ func (db *DB) IsRVPaid(tx ReadWriteTx, rv ratchet.RVPoint, expirationDays int) (bool, error)

+ func (db *DB) ListAllSharedFiles(tx ReadTx) ([]SharedFileAndShares, error)

+ func (db *DB) ListGCInvites(tx ReadTx, name string) ([]*GCInvite, error)

+ func (db *DB) ListGCs(tx ReadTx) ([]GCAddressBookEntry, error)

+ func (db *DB) ListKXSearches(tx ReadTx) ([]UserID, error)

+ func (db *DB) ListKXs(tx ReadTx) ([]KXData, error)

+ func (db *DB) ListMediateIDs(tx ReadTx) ([]MediateIDRequest, error)

+ func (db *DB) ListOutstandingDownloads(tx ReadTx) ([]FileDownload, error)

+ func (db *DB) ListOutstandingUploads(tx ReadTx) ([]ChunkUpload, error)

+ func (db *DB) ListPayStats(tx ReadTx) (map[UserID]UserPayStats, error)

+ func (db *DB) ListPostKXActions(tx ReadTx, target UserID) ([]PostKXAction, error)

+ func (db *DB) ListPostRelayers(tx ReadTx, post PostID) ([]UserID, error)

+ func (db *DB) ListPostStatusUpdates(tx ReadTx, from UserID, post PostID) ([]rpc.PostMetadataStatus, error)

+ func (db *DB) ListPostSubscribers(tx ReadTx) ([]UserID, error)

+ func (db *DB) ListPostSubscriptions(tx ReadTx) ([]PostSubscription, error)

+ func (db *DB) ListPosts(tx ReadTx) ([]PostSummary, error)

+ func (db *DB) ListSendQueue(tx ReadTx) ([]SendQueueElement, error)

+ func (db *DB) ListSharedFiles(tx ReadTx, uid *UserID) ([]rpc.FileMetadata, error)

+ func (db *DB) ListUnackedUserRMs(tx ReadTx) ([]UnackedRM, error)

+ func (db *DB) ListUserPosts(tx ReadTx, from UserID) ([]rpc.PostMetadata, error)

+ func (db *DB) LoadAddressBook(tx ReadTx, localID *zkidentity.FullIdentity) ([]*AddressBookEntry, error)

+ func (db *DB) LoadTransResetHalfKX(tx ReadTx, id UserID, localID *zkidentity.FullIdentity) (*ratchet.Ratchet, error)

+ func (db *DB) LocalID(tx ReadTx) (*zkidentity.FullIdentity, error)

+ func (db *DB) LogGCMsg(tx ReadWriteTx, gcName string, gcID zkidentity.ShortID, internal bool, ...) error

+ func (db *DB) LogPM(tx ReadWriteTx, uid UserID, internal bool, from, msg string, ts time.Time) error

+ func (db *DB) MarkChunkUploadInvoiceExpired(tx ReadWriteTx, uid UserID, fid FileID, cid ChunkID, index int, invoice string) error

+ func (db *DB) MarkChunkUploadInvoiceSent(tx ReadWriteTx, uid UserID, fid FileID, cid ChunkID, index int) error

+ func (db *DB) MarkChunkUploadPaid(tx ReadWriteTx, uid UserID, fid FileID, cid ChunkID, index int, invoice string) error

+ func (db *DB) MarkChunkUploadSent(tx ReadWriteTx, uid UserID, fid FileID, cid ChunkID, index int) error

+ func (db *DB) MarkGCInviteAccepted(tx ReadWriteTx, inviteID uint64) error

+ func (db *DB) MarkRVUnpaid(tx ReadWriteTx, rv ratchet.RVPoint) error

+ func (db *DB) MissingFileDownloadChunks(tx ReadTx, fd *FileDownload) []int

+ func (db *DB) PostExists(tx ReadTx, from UserID, post PostID) (bool, error)

+ func (db *DB) ReadFileDownload(tx ReadTx, uid UserID, fid FileID) (FileDownload, error)

+ func (db *DB) ReadPost(tx ReadTx, from UserID, post PostID) (rpc.PostMetadata, error)

+ func (db *DB) RecordUserPayEvent(tx ReadWriteTx, user UserID, event string, amount, payFee int64) error

+ func (db *DB) RelayPost(tx ReadWriteTx, from UserID, pid PostID, me *zkidentity.FullIdentity) (rpc.PostMetadata, bool, error)

+ func (db *DB) RemoveFromGCBlockList(tx ReadWriteTx, gcid zkidentity.ShortID, uid UserID) error

+ func (db *DB) RemoveFromSendQueue(tx ReadWriteTx, id SendQID, dest UserID) error

+ func (db *DB) RemoveKXSearch(tx ReadWriteTx, target UserID) error

+ func (db *DB) RemoveMediateID(tx ReadWriteTx, mediator, target UserID) error

+ func (db *DB) RemovePostKXActions(tx ReadWriteTx, target UserID) error

+ func (db *DB) RemoveUser(tx ReadWriteTx, id UserID, block bool) error

+ func (db *DB) RemoveUserUnackedRMWithRV(tx ReadWriteTx, uid UserID, rv RawRVID) (bool, error)

+ func (db *DB) ReplaceFileDownloadChunkState(tx ReadWriteTx, fd *FileDownload, chunkIdx int, chunkState ChunkState) error

+ func (db *DB) ReplaceFileDownloadInvoices(tx ReadWriteTx, fd *FileDownload, invoices map[int]string) error

+ func (db *DB) ReplaceUserUnackedRM(tx ReadWriteTx, uid UserID, encrypted []byte, rv RawRVID, payEvent string) error

+ func (db *DB) Run(ctx context.Context) error

+ func (db *DB) RunStarted() <-chan struct{}

+ func (db *DB) SaveFileDownloadChunk(tx ReadWriteTx, user string, fd *FileDownload, chunkIdx int, data []byte) (string, error)

+ func (db *DB) SaveGC(tx ReadWriteTx, gc rpc.RMGroupList) error

+ func (db *DB) SaveKX(tx ReadWriteTx, kx KXData) error

+ func (db *DB) SaveRVPaid(tx ReadWriteTx, rv ratchet.RVPoint) error

+ func (db *DB) SaveReceivedPost(tx ReadWriteTx, from UserID, p rpc.PostMetadata) (PostID, PostSummary, error)

+ func (db *DB) ServerID(tx ReadTx) ([]byte, zkidentity.PublicIdentity, error)

+ func (db *DB) SetGCAlias(tx ReadWriteTx, gcID zkidentity.ShortID, name string) (map[string]zkidentity.ShortID, error)

+ func (db *DB) ShareFile(tx ReadWriteTx, fname string, uid *UserID, cost uint64, descr string, ...) (SharedFile, rpc.FileMetadata, error)

+ func (db *DB) StartFileDownload(tx ReadWriteTx, uid UserID, fid FileID, isSentFile bool) (FileDownload, error)

+ func (db *DB) StoreMediateIDRequested(tx ReadWriteTx, mediator, target UserID) error

+ func (db *DB) StorePostSubscription(tx ReadWriteTx, to UserID) error

+ func (db *DB) StorePostUnsubscription(tx ReadWriteTx, to UserID) error

+ func (db *DB) StoreTransResetHalfKX(tx ReadWriteTx, r *ratchet.Ratchet, theirID zkidentity.ShortID) error

+ func (db *DB) SubscribeToPosts(tx ReadWriteTx, user UserID) error

+ func (db *DB) SummarizeUserPayStats(tx ReadTx, uid UserID) ([]PayStatsSummary, error)

+ func (db *DB) UnshareFile(tx ReadWriteTx, fid FileID, uid *UserID) error

+ func (db *DB) UnsubscribeToPosts(tx ReadWriteTx, user UserID) error

+ func (db *DB) Update(ctx context.Context, f func(tx ReadWriteTx) error) error

+ func (db *DB) UpdateAddressBookEntry(tx ReadWriteTx, id *zkidentity.PublicIdentity, myResetRV, theirResetRV RawRVID, ...) error

+ func (db *DB) UpdateFileDownloadMetadata(tx ReadWriteTx, fd *FileDownload, md rpc.FileMetadata) error

+ func (db *DB) UpdateLocalID(tx ReadWriteTx, id *zkidentity.FullIdentity) error

+ func (db *DB) UpdateRatchet(tx ReadWriteTx, r *ratchet.Ratchet, theirID zkidentity.ShortID) error

+ func (db *DB) UpdateServerID(tx ReadWriteTx, tlsCert []byte, pid *zkidentity.PublicIdentity) error

+ func (db *DB) View(ctx context.Context, f func(tx ReadTx) error) error

+ type FileDownload struct

+ ChunkStates map[int]ChunkState

+ ChunkUpdatedTime map[int]time.Time

+ CompletedName string

+ FID FileID

+ Invoices map[int]string

+ IsSentFile bool

+ Metadata *rpc.FileMetadata

+ UID UserID

+ func (fd *FileDownload) CountChunks(atState ChunkState) int

+ func (fd *FileDownload) GetChunkInvoice(chunkIdx int) string

+ func (fd *FileDownload) GetChunkState(chunkIdx int) ChunkState

+ type FileID = clientintf.ID

+ type GCAddressBookEntry struct

+ ID zkidentity.ShortID

+ Members []UserID

+ type GCBlockList map[string]struct

+ func (gcbl GCBlockList) FilterMembers(members []UserID) []UserID

+ func (gcbl GCBlockList) IsBlocked(uid UserID) bool

+ type GCInvite struct

+ Accepted bool

+ ID uint64

+ Invite rpc.RMGroupInvite

+ User UserID

+ type KXData struct

+ HalfRatchet *disk.RatchetState

+ InitialRV RawRVID

+ Invitee *zkidentity.PublicIdentity

+ IsForReset bool

+ MediatorID *UserID

+ MyResetRV RawRVID

+ Public zkidentity.PublicIdentity

+ Stage KXStage

+ Step3RV RawRVID

+ TheirResetRV RawRVID

+ Timestamp time.Time

+ type KXSearch struct

+ Queries []KXSearchQuery

+ Search rpc.RMKXSearch

+ Target clientintf.ID

+ type KXSearchQuery struct

+ DateSent time.Time

+ IDsReceived []clientintf.ID

+ User clientintf.ID

+ type KXStage uint8

+ const KXStageStep2IDKX

+ const KXStageStep3IDKX

+ const KXStageUnknown

+ func (stage KXStage) String() string

+ type MediateIDRequest struct

+ Date time.Time

+ Mediator UserID

+ Target UserID

+ type PayStatEvent struct

+ Amount int64

+ Event string

+ PayFee int64

+ Timestamp int64

+ type PayStatsSummary struct

+ Prefix string

+ Total int64

+ type PostID = clientintf.PostID

+ type PostKXAction struct

+ Data string

+ DateAdded time.Time

+ Type PostKXActionType

+ type PostKXActionType string

+ const PKXActionFetchPost

+ const PKXActionKXSearch

+ type PostSubscription struct

+ Date time.Time

+ To UserID

+ type PostSummary struct

+ AuthorID UserID

+ AuthorNick string

+ Date time.Time

+ From UserID

+ ID PostID

+ LastStatusTS time.Time

+ Title string

+ func PostSummFromMetadata(post *rpc.PostMetadata, from UserID) PostSummary

+ type RawRVID = clientintf.RawRVID

+ type ReadTx interface

+ Context func() context.Context

+ type ReadWriteTx interface

+ Writable func() bool

+ type RemoteFile struct

+ DiskPath string

+ FID FileID

+ Metadata rpc.FileMetadata

+ UID UserID

+ type SendQID = clientintf.ID

+ type SendQueueElement struct

+ Dests []UserID

+ ID clientintf.ID

+ Msg []byte

+ Priority uint

+ Type string

+ type SharedFile struct

+ FID FileID

+ FileHash clientintf.ID

+ Filename string

+ type SharedFileAndShares struct

+ Cost uint64

+ Global bool

+ SF SharedFile

+ Shares []clientintf.ID

+ Size uint64

+ type UnackedRM struct

+ Encrypted []byte

+ PayEvent string

+ RV RawRVID

+ UID UserID

+ type UserID = clientintf.UserID

+ type UserPayStats struct

+ TotalPayFee int64

+ TotalReceived int64

+ TotalSent int64

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