chat

package
v3.2.1+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 10, 2019 License: BSD-3-Clause, BSD-3-Clause Imports: 69 Imported by: 0

Documentation

Index

Constants

View Source 
const CurrentMessageBoxedVersion = chat1.MessageBoxedVersion_V2

Variables

View Source 
var ActiveIntervalAfterSend = 30 * 24 * time.Hour
View Source 
var ErrChatServerTimeout = errors.New("timeout calling chat server")
View Source 
var ErrDuplicateConnection = errors.New("error calling chat server")
View Source 
var ErrKeyServerTimeout = errors.New("timeout calling into key server")
View Source 
var InitialAssumedActiveInterval = 24 * time.Hour

All devices are presumed active for the first 24 hours. See comment below.

Functions

func CreateNameInfoSource 

func CreateNameInfoSource(ctx context.Context, g *globals.Context, membersType chat1.ConversationMembersType) types.NameInfoSource

func CurrentUID added in v1.0.27 

func CurrentUID(g *globals.Context) (keybase1.UID, error)

func FindConversations added in v1.0.27 

func FindConversations(ctx context.Context, g *globals.Context, debugger utils.DebugLabeler,
	dataSource types.InboxSourceDataSourceTyp, ri func() chat1.RemoteInterface, uid gregor1.UID,
	tlfName string, topicType chat1.TopicType,
	membersTypeIn chat1.ConversationMembersType, vis keybase1.TLFVisibility, topicName string,
	oneChatPerTLF *bool) (res []chat1.ConversationLocal, err error)

func GetInboxQueryNameInfo added in v1.0.27 

func GetInboxQueryNameInfo(ctx context.Context, g *globals.Context,
	lquery *chat1.GetInboxLocalQuery) (res types.NameInfo, err error)

func GetLastSendTime added in v1.0.39 

func GetLastSendTime(ctx context.Context, g *globals.Context, log utils.DebugLabeler) time.Time

Returns the zero time if there is no recorded last send time (either because the device has never sent a message, or because it hasn't sent one since we started recording).

func GetMessage 

func GetMessage(ctx context.Context, g *globals.Context, uid gregor1.UID, convID chat1.ConversationID,
	msgID chat1.MessageID, resolveSupersedes bool, reason *chat1.GetThreadReason) (chat1.MessageUnboxed, error)

func GetMessages 

func GetMessages(ctx context.Context, g *globals.Context, uid gregor1.UID, convID chat1.ConversationID,
	msgIDs []chat1.MessageID, resolveSupersedes bool, reason *chat1.GetThreadReason) ([]chat1.MessageUnboxed, error)

func GetTopicNameState added in v1.0.27 

func GetTopicNameState(ctx context.Context, g *globals.Context, debugger utils.DebugLabeler,
	convs []chat1.ConversationLocal,
	uid gregor1.UID, tlfID chat1.TLFID, topicType chat1.TopicType,
	membersType chat1.ConversationMembersType) (res chat1.TopicNameState, err error)

func IsRekeyError 

func IsRekeyError(err error) (typ chat1.ConversationErrorType, ok bool)

func JoinConversation added in v1.0.27 

func JoinConversation(ctx context.Context, g *globals.Context, debugger utils.DebugLabeler,
	ri func() chat1.RemoteInterface, uid gregor1.UID, convID chat1.ConversationID) (err error)

func JoinConversationByName 

func JoinConversationByName(ctx context.Context, g *globals.Context, debugger utils.DebugLabeler,
	ri func() chat1.RemoteInterface, uid gregor1.UID, tlfName, topicName string, topicType chat1.TopicType,
	vis keybase1.TLFVisibility) (err error)

func LeaveConversation added in v1.0.27 

func LeaveConversation(ctx context.Context, g *globals.Context, debugger utils.DebugLabeler,
	ri func() chat1.RemoteInterface, uid gregor1.UID, convID chat1.ConversationID) (err error)

func NewConversation added in v1.0.27 

func NewConversation(ctx context.Context, g *globals.Context, uid gregor1.UID, tlfName string,
	topicName *string, topicType chat1.TopicType, membersType chat1.ConversationMembersType,
	vis keybase1.TLFVisibility, ri func() chat1.RemoteInterface, findExistingMode NewConvFindExistingMode) (chat1.ConversationLocal, error)

func NewConversationSource 

func NewConversationSource(g *globals.Context, typ string, boxer *Boxer, storage *storage.Storage,
	ri func() chat1.RemoteInterface) types.ConversationSource

func NewConversationWithMemberSourceConv 

func NewConversationWithMemberSourceConv(ctx context.Context, g *globals.Context, uid gregor1.UID,
	tlfName string, topicName *string, topicType chat1.TopicType, membersType chat1.ConversationMembersType,
	vis keybase1.TLFVisibility, ri func() chat1.RemoteInterface,
	findExistingMode NewConvFindExistingMode, memberSourceConv *chat1.ConversationID) (chat1.ConversationLocal, error)

func NewCtxFactory 

func NewCtxFactory(g *globals.Context) types.ContextFactory

func NewFTLError 

func NewFTLError(s string) error

func NewInboxSource added in v1.0.19 

func NewInboxSource(g *globals.Context, typ string, ri func() chat1.RemoteInterface) types.InboxSource

func NewKeyFinder 

func NewKeyFinder(g *globals.Context) types.KeyFinder

NewKeyFinder creates a KeyFinder.

func NewKeyFinderMock 

func NewKeyFinderMock(cryptKeys []keybase1.CryptKey) types.KeyFinder

func NewPermanentUnboxingError added in v1.0.19 

func NewPermanentUnboxingError(inner error) types.UnboxingError

func NewTransientUnboxingError added in v1.0.19 

func NewTransientUnboxingError(inner error) types.UnboxingError

func PresentConversationLocalWithFetchRetry 

func PresentConversationLocalWithFetchRetry(ctx context.Context, g *globals.Context,
	uid gregor1.UID, conv chat1.ConversationLocal) (res *chat1.InboxUIItem)

func PreviewConversation added in v1.0.34 

func PreviewConversation(ctx context.Context, g *globals.Context, debugger utils.DebugLabeler,
	ri func() chat1.RemoteInterface, uid gregor1.UID, convID chat1.ConversationID) (err error)

func RecentConversationParticipants added in v1.0.27 

func RecentConversationParticipants(ctx context.Context, g *globals.Context, myUID gregor1.UID) ([]gregor1.UID, error)

func RecordChatSend added in v1.0.39 

func RecordChatSend(ctx context.Context, g *globals.Context, log utils.DebugLabeler)

func TouchFirstChatActiveQueryTime added in v1.0.39 

func TouchFirstChatActiveQueryTime(ctx context.Context, g *globals.Context, log utils.DebugLabeler) time.Time

If no first query time is found in the local db, this function writes the current time.

Types

type AttachmentHTTPSrv added in v1.0.48 

type AttachmentHTTPSrv struct {
	sync.Mutex
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewAttachmentHTTPSrv added in v1.0.48 

func NewAttachmentHTTPSrv(g *globals.Context, fetcher types.AttachmentFetcher, ri func() chat1.RemoteInterface) *AttachmentHTTPSrv

func (*AttachmentHTTPSrv) GetAttachmentFetcher added in v1.0.48 

func (r *AttachmentHTTPSrv) GetAttachmentFetcher() types.AttachmentFetcher

func (*AttachmentHTTPSrv) GetGiphyGalleryURL 

func (r *AttachmentHTTPSrv) GetGiphyGalleryURL(ctx context.Context, convID chat1.ConversationID,
	tlfName string, results []chat1.GiphySearchResult) string

func (*AttachmentHTTPSrv) GetGiphyURL 

func (r *AttachmentHTTPSrv) GetGiphyURL(ctx context.Context, giphyURL string) string

func (*AttachmentHTTPSrv) GetPendingPreviewURL 

func (r *AttachmentHTTPSrv) GetPendingPreviewURL(ctx context.Context, outboxID chat1.OutboxID) string

func (*AttachmentHTTPSrv) GetURL added in v1.0.48 

func (r *AttachmentHTTPSrv) GetURL(ctx context.Context, convID chat1.ConversationID, msgID chat1.MessageID,
	preview bool) string

func (*AttachmentHTTPSrv) GetUnfurlAssetURL 

func (r *AttachmentHTTPSrv) GetUnfurlAssetURL(ctx context.Context, convID chat1.ConversationID,
	asset chat1.Asset) string

func (*AttachmentHTTPSrv) OnCacheCleared 

func (r *AttachmentHTTPSrv) OnCacheCleared(mctx libkb.MetaContext)

func (*AttachmentHTTPSrv) Sign added in v1.0.48 

func (r *AttachmentHTTPSrv) Sign(payload []byte) ([]byte, error)

Sign implements github.com/keybase/go/chat/s3.Signer interface.

type AttachmentUploadError 

type AttachmentUploadError struct {
	Msg  string
	Perm bool
}

func NewAttachmentUploadError 

func NewAttachmentUploadError(msg string, perm bool) AttachmentUploadError

func (AttachmentUploadError) Error 

func (e AttachmentUploadError) Error() string

func (AttachmentUploadError) IsImmediateFail 

func (e AttachmentUploadError) IsImmediateFail() (chat1.OutboxErrorType, bool)

type BackgroundConvLoader added in v1.0.27 

type BackgroundConvLoader struct {
	globals.Contextified
	utils.DebugLabeler
	sync.Mutex
	// contains filtered or unexported fields
}

func NewBackgroundConvLoader added in v1.0.27 

func NewBackgroundConvLoader(g *globals.Context) *BackgroundConvLoader

func (*BackgroundConvLoader) Queue added in v1.0.27 

func (b *BackgroundConvLoader) Queue(ctx context.Context, job types.ConvLoaderJob) error

func (*BackgroundConvLoader) Resume added in v1.0.46 

func (b *BackgroundConvLoader) Resume(ctx context.Context) bool

func (*BackgroundConvLoader) Start added in v1.0.27 

func (b *BackgroundConvLoader) Start(ctx context.Context, uid gregor1.UID)

func (*BackgroundConvLoader) Stop added in v1.0.27 

func (b *BackgroundConvLoader) Stop(ctx context.Context) chan struct{}

func (*BackgroundConvLoader) Suspend added in v1.0.46 

func (b *BackgroundConvLoader) Suspend(ctx context.Context) (canceled bool)

type BackgroundEphemeralPurger 

type BackgroundEphemeralPurger struct {
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewBackgroundEphemeralPurger 

func NewBackgroundEphemeralPurger(g *globals.Context, storage *storage.Storage) *BackgroundEphemeralPurger

func (*BackgroundEphemeralPurger) Queue 

func (b *BackgroundEphemeralPurger) Queue(ctx context.Context, purgeInfo chat1.EphemeralPurgeInfo) error

func (*BackgroundEphemeralPurger) SetClock 

func (b *BackgroundEphemeralPurger) SetClock(clock clockwork.Clock)

func (*BackgroundEphemeralPurger) Start 

func (b *BackgroundEphemeralPurger) Start(ctx context.Context, uid gregor1.UID)

func (*BackgroundEphemeralPurger) Stop 

func (b *BackgroundEphemeralPurger) Stop(ctx context.Context) (ch chan struct{})

type BlockingSender added in v1.0.19 

type BlockingSender struct {
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewBlockingSender added in v1.0.19 

func NewBlockingSender(g *globals.Context, boxer *Boxer, getRi func() chat1.RemoteInterface) *BlockingSender

func (*BlockingSender) Prepare added in v1.0.19 

func (s *BlockingSender) Prepare(ctx context.Context, plaintext chat1.MessagePlaintext,
	membersType chat1.ConversationMembersType, conv *chat1.Conversation, inopts *types.SenderPrepareOptions) (res types.SenderPrepareResult, err error)

Prepare a message to be sent. Returns (boxedMessage, pendingAssetDeletes, error)

func (*BlockingSender) Send added in v1.0.19 

func (s *BlockingSender) Send(ctx context.Context, convID chat1.ConversationID,
	msg chat1.MessagePlaintext, clientPrev chat1.MessageID,
	outboxID *chat1.OutboxID, joinMentionsAs *chat1.ConversationMemberStatus) (obid chat1.OutboxID, boxed *chat1.MessageBoxed, err error)

func (*BlockingSender) SetClock 

func (s *BlockingSender) SetClock(clock clockwork.Clock)

func (*BlockingSender) Sign added in v1.0.19 

func (s *BlockingSender) Sign(payload []byte) ([]byte, error)

Sign implements github.com/keybase/go/chat/s3.Signer interface.

type BodyHashInvalid added in v1.0.19 

type BodyHashInvalid struct{}

func (BodyHashInvalid) Error added in v1.0.19 

func (e BodyHashInvalid) Error() string

type Boxer 

type Boxer struct {
	utils.DebugLabeler
	globals.Contextified
	// contains filtered or unexported fields
}

func NewBoxer 

func NewBoxer(g *globals.Context) *Boxer

func (*Boxer) BoxMessage 

func (b *Boxer) BoxMessage(ctx context.Context, msg chat1.MessagePlaintext,
	membersType chat1.ConversationMembersType,
	signingKeyPair libkb.NaclSigningKeyPair, info *types.BoxerEncryptionInfo) (res chat1.MessageBoxed, err error)

BoxMessage encrypts a keybase1.MessagePlaintext into a chat1.MessageBoxed. It finds the most recent key for the TLF.

func (*Boxer) CompareTlfNames added in v1.0.21 

func (b *Boxer) CompareTlfNames(ctx context.Context, tlfName1, tlfName2 string,
	membersType chat1.ConversationMembersType, tlfPublic bool) (bool, error)

func (*Boxer) GetBoxedVersion 

func (b *Boxer) GetBoxedVersion(msg chat1.MessagePlaintext) (chat1.MessageBoxedVersion, error)

func (*Boxer) GetEncryptionInfo 

func (b *Boxer) GetEncryptionInfo(ctx context.Context, msg *chat1.MessagePlaintext,
	membersType chat1.ConversationMembersType, signingKeyPair libkb.NaclSigningKeyPair) (res types.BoxerEncryptionInfo, err error)

func (*Boxer) SetClock added in v1.0.48 

func (b *Boxer) SetClock(clock clockwork.Clock)

func (*Boxer) UnboxMessage 

func (b *Boxer) UnboxMessage(ctx context.Context, boxed chat1.MessageBoxed, conv types.UnboxConversationInfo,
	info *types.BoxerEncryptionInfo) (m chat1.MessageUnboxed, uberr types.UnboxingError)

UnboxMessage unboxes a chat1.MessageBoxed into a chat1.MessageUnboxed. It finds the appropriate keybase1.CryptKey, decrypts the message, and verifies several things:

  • The message's signature is valid.
  • (TODO) The signing KID was valid when the signature was made.
  • (TODO) The signing KID belongs to the sending device.
  • (TODO) The sending device belongs to the sender. [Note that we do currently check the KID -> UID relationship, independent of the device ID.]
  • (TODO) The sender has write permission in the TLF.
  • (TODO) The TLF name, public flag, and finalized info resolve to the TLF ID.
  • The conversation ID derives from the ConversationIDTriple.
  • The body hash is not a replay from another message we know about.
  • The prev pointers are consistent with other messages we know about.
  • (TODO) The prev pointers are not absurdly ancient.
  • The ClientHeader provided with the BoxedMessage matches the one we decrypt.

The first return value is unusable if the err != nil. Returns (_, err) for non-permanent errors, and (MessageUnboxedError, nil) for permanent errors. Permanent errors can be cached and must be treated as a value to deal with, whereas temporary errors are transient failures.

func (*Boxer) UnboxMessages 

func (b *Boxer) UnboxMessages(ctx context.Context, boxed []chat1.MessageBoxed, conv types.UnboxConversationInfo) (unboxed []chat1.MessageUnboxed, err error)

func (*Boxer) UnboxThread 

func (b *Boxer) UnboxThread(ctx context.Context, boxed chat1.ThreadViewBoxed, conv types.UnboxConversationInfo) (thread chat1.ThreadView, err error)

unboxThread transforms a chat1.ThreadViewBoxed to a keybase1.ThreadView.

func (*Boxer) ValidSenderKey added in v1.0.19 

func (b *Boxer) ValidSenderKey(ctx context.Context, sender gregor1.UID, key []byte, ctime gregor1.Time) (found, validAtCTime bool, revoked *gregor1.Time, unboxErr types.UnboxingError)

ValidSenderKey checks that the key was active for sender at ctime. This trusts the server for ctime, so a colluding server could use a revoked key and this check erroneously pass. But (revoked != nil) if the key was ever revoked, so that is irrespective of ctime. Returns (validAtCtime, revoked, err)

type BoxingCryptKeysError added in v1.0.19 

type BoxingCryptKeysError struct {
	Err error
}

func NewBoxingCryptKeysError added in v1.0.19 

func NewBoxingCryptKeysError(err error) BoxingCryptKeysError

func (BoxingCryptKeysError) Error added in v1.0.19 

func (e BoxingCryptKeysError) Error() string

func (BoxingCryptKeysError) Inner added in v1.0.19 

func (e BoxingCryptKeysError) Inner() error

func (BoxingCryptKeysError) IsImmediateFail added in v1.0.19 

func (e BoxingCryptKeysError) IsImmediateFail() (chat1.OutboxErrorType, bool)

type BoxingError added in v1.0.19 

type BoxingError struct {
	Msg  string
	Perm bool
}

func NewBoxingError added in v1.0.19 

func NewBoxingError(msg string, perm bool) BoxingError

func (BoxingError) Error added in v1.0.19 

func (e BoxingError) Error() string

func (BoxingError) IsImmediateFail added in v1.0.19 

func (e BoxingError) IsImmediateFail() (chat1.OutboxErrorType, bool)

type CachingAttachmentFetcher added in v1.0.48 

type CachingAttachmentFetcher struct {
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewCachingAttachmentFetcher added in v1.0.48 

func NewCachingAttachmentFetcher(g *globals.Context, store attachments.Store, size int) *CachingAttachmentFetcher

func (*CachingAttachmentFetcher) DeleteAssets 

func (c *CachingAttachmentFetcher) DeleteAssets(ctx context.Context,
	convID chat1.ConversationID, assets []chat1.Asset, ri func() chat1.RemoteInterface, signer s3.Signer) (err error)

func (*CachingAttachmentFetcher) FetchAttachment added in v1.0.48 

func (c *CachingAttachmentFetcher) FetchAttachment(ctx context.Context, w io.Writer,
	convID chat1.ConversationID, asset chat1.Asset, ri func() chat1.RemoteInterface, signer s3.Signer,
	progress types.ProgressReporter) (err error)

func (*CachingAttachmentFetcher) IsAssetLocal 

func (c *CachingAttachmentFetcher) IsAssetLocal(ctx context.Context, asset chat1.Asset) (found bool, err error)

func (*CachingAttachmentFetcher) OnCacheCleared 

func (c *CachingAttachmentFetcher) OnCacheCleared(mctx libkb.MetaContext)

func (*CachingAttachmentFetcher) PutUploadedAsset 

func (c *CachingAttachmentFetcher) PutUploadedAsset(ctx context.Context, filename string, asset chat1.Asset) (err error)

func (*CachingAttachmentFetcher) StreamAttachment 

func (c *CachingAttachmentFetcher) StreamAttachment(ctx context.Context, convID chat1.ConversationID,
	asset chat1.Asset, ri func() chat1.RemoteInterface, signer s3.Signer) (res io.ReadSeeker, err error)

type CachingIdentifyNotifier added in v1.0.42 

type CachingIdentifyNotifier struct {
	globals.Contextified
	utils.DebugLabeler

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewCachingIdentifyNotifier added in v1.0.42 

func NewCachingIdentifyNotifier(g *globals.Context) *CachingIdentifyNotifier

func (*CachingIdentifyNotifier) Reset added in v1.0.42 

func (i *CachingIdentifyNotifier) Reset()

func (*CachingIdentifyNotifier) ResetOnGUIConnect added in v1.0.42 

func (i *CachingIdentifyNotifier) ResetOnGUIConnect()

func (*CachingIdentifyNotifier) Send added in v1.0.42 

func (i *CachingIdentifyNotifier) Send(ctx context.Context, update keybase1.CanonicalTLFNameAndIDWithBreaks)

type CachingUPAKFinder added in v1.0.42 

type CachingUPAKFinder struct {
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewCachingUPAKFinder added in v1.0.42 

func NewCachingUPAKFinder(g *globals.Context) *CachingUPAKFinder

func (*CachingUPAKFinder) CheckKIDForUID added in v1.0.42 

func (u *CachingUPAKFinder) CheckKIDForUID(ctx context.Context, uid keybase1.UID, kid keybase1.KID) (found bool, revokedAt *keybase1.KeybaseTime, deleted bool, err error)

func (*CachingUPAKFinder) LookupUsernameAndDevice added in v1.0.42 

func (u *CachingUPAKFinder) LookupUsernameAndDevice(ctx context.Context, uid keybase1.UID, deviceID keybase1.DeviceID) (username libkb.NormalizedUsername, deviceName string, deviceType string, err error)

type ChatThreadConsistencyError added in v1.0.19 

type ChatThreadConsistencyError interface {
	error
	Code() ConsistencyErrorCode
}

func CheckPrevPointersAndGetUnpreved 

func CheckPrevPointersAndGetUnpreved(thread *chat1.ThreadView) (newPrevsForRegular, newPrevsForExploding []chat1.MessagePreviousPointer, err ChatThreadConsistencyError)

Ingest a ThreadView, check several invariants, and produce a list of prev pointers to not-yet-pointed-to messages. Check several invariants at the same time: 1. No two messages have the same ID. 2. All prev pointers point to messages with lesser IDs. 3. All prev pointers to a message agree on that message's header hash. 4. For all messages we have locally, the hashes pointing to them are actually correct. TODO: All of this should happen in the cache instead of here all at once.

func NewChatThreadConsistencyError added in v1.0.19 

func NewChatThreadConsistencyError(code ConsistencyErrorCode, msg string, formatArgs ...interface{}) ChatThreadConsistencyError

type ConsistencyErrorCode added in v1.0.19 

type ConsistencyErrorCode int
const (
	DuplicateID ConsistencyErrorCode = iota
	OutOfOrderID
	InconsistentHash
	IncorrectHash
)

type ConversationRetry added in v1.0.27 

type ConversationRetry struct {
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewConversationRetry added in v1.0.27 

func NewConversationRetry(g *globals.Context, convID chat1.ConversationID, tlfID *chat1.TLFID, kind FetchType) *ConversationRetry

func (*ConversationRetry) Fix added in v1.0.27 

func (c *ConversationRetry) Fix(ctx context.Context, uid gregor1.UID) error

func (*ConversationRetry) RekeyFixable added in v1.0.31 

func (c *ConversationRetry) RekeyFixable(ctx context.Context, tlfID chat1.TLFID) bool

func (*ConversationRetry) SendStale added in v1.0.27 

func (c *ConversationRetry) SendStale(ctx context.Context, uid gregor1.UID)

func (*ConversationRetry) String added in v1.0.27 

func (c *ConversationRetry) String() string

type CtxFactory 

type CtxFactory struct {
	globals.Contextified
}

func (*CtxFactory) NewKeyFinder 

func (c *CtxFactory) NewKeyFinder() types.KeyFinder

func (*CtxFactory) NewUPAKFinder 

func (c *CtxFactory) NewUPAKFinder() types.UPAKFinder

type DecryptionKeyNotFoundError 

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

func NewDecryptionKeyNotFoundError 

func NewDecryptionKeyNotFoundError(generation int, public, kbfsEncrypted bool) DecryptionKeyNotFoundError

func (DecryptionKeyNotFoundError) Error 

func (e DecryptionKeyNotFoundError) Error() string

type Deliverer added in v1.0.19 

type Deliverer struct {
	globals.Contextified
	sync.Mutex
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewDeliverer added in v1.0.19 

func NewDeliverer(g *globals.Context, sender types.Sender) *Deliverer

func (*Deliverer) ActiveDeliveries 

func (s *Deliverer) ActiveDeliveries(ctx context.Context) (res []chat1.ConversationID, err error)

func (*Deliverer) Connected added in v1.0.19 

func (s *Deliverer) Connected(ctx context.Context)

func (*Deliverer) Disconnected added in v1.0.19 

func (s *Deliverer) Disconnected(ctx context.Context)

func (*Deliverer) ForceDeliverLoop added in v1.0.19 

func (s *Deliverer) ForceDeliverLoop(ctx context.Context)

func (*Deliverer) IsDelivering 

func (s *Deliverer) IsDelivering() bool

func (*Deliverer) IsOffline added in v1.0.19 

func (s *Deliverer) IsOffline(ctx context.Context) bool

func (*Deliverer) NextFailure 

func (s *Deliverer) NextFailure() (chan []chat1.OutboxRecord, func())

func (*Deliverer) Queue added in v1.0.19 

func (s *Deliverer) Queue(ctx context.Context, convID chat1.ConversationID, msg chat1.MessagePlaintext,
	outboxID *chat1.OutboxID,
	identifyBehavior keybase1.TLFIdentifyBehavior) (obr chat1.OutboxRecord, err error)

func (*Deliverer) SetClock added in v1.0.19 

func (s *Deliverer) SetClock(clock clockwork.Clock)

func (*Deliverer) SetSender added in v1.0.19 

func (s *Deliverer) SetSender(sender types.Sender)

func (*Deliverer) Start added in v1.0.19 

func (s *Deliverer) Start(ctx context.Context, uid gregor1.UID)

func (*Deliverer) Stop added in v1.0.19 

func (s *Deliverer) Stop(ctx context.Context) chan struct{}

type DelivererInfoError added in v1.0.19 

type DelivererInfoError interface {
	IsImmediateFail() (chat1.OutboxErrorType, bool)
}

type DevConversationBackedStorage 

type DevConversationBackedStorage struct {
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewDevConversationBackedStorage 

func NewDevConversationBackedStorage(g *globals.Context, ri func() chat1.RemoteInterface) *DevConversationBackedStorage

func (*DevConversationBackedStorage) Get 

func (s *DevConversationBackedStorage) Get(ctx context.Context, uid gregor1.UID, name string,
	dest interface{}) (found bool, err error)

func (*DevConversationBackedStorage) Put 

func (s *DevConversationBackedStorage) Put(ctx context.Context, uid gregor1.UID, name string, src interface{}) (err error)

type DummyIdentifyNotifier added in v1.0.42 

type DummyIdentifyNotifier struct{}

func (DummyIdentifyNotifier) Reset added in v1.0.42 

func (d DummyIdentifyNotifier) Reset()

func (DummyIdentifyNotifier) ResetOnGUIConnect added in v1.0.42 

func (d DummyIdentifyNotifier) ResetOnGUIConnect()

func (DummyIdentifyNotifier) Send added in v1.0.42 

func (d DummyIdentifyNotifier) Send(ctx context.Context, update keybase1.CanonicalTLFNameAndIDWithBreaks)

type DuplicateTopicNameError added in v1.0.27 

type DuplicateTopicNameError struct {
	TopicName string
}

func (DuplicateTopicNameError) Error added in v1.0.27 

func (e DuplicateTopicNameError) Error() string

type EphemeralAlreadyExpiredError 

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

func NewEphemeralAlreadyExpiredError 

func NewEphemeralAlreadyExpiredError() EphemeralAlreadyExpiredError

func (EphemeralAlreadyExpiredError) Error 

func (e EphemeralAlreadyExpiredError) Error() string

func (EphemeralAlreadyExpiredError) InternalError 

func (e EphemeralAlreadyExpiredError) InternalError() string

type EphemeralUnboxingError 

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

func NewEphemeralUnboxingError 

func NewEphemeralUnboxingError(inner ephemeral.EphemeralKeyError) EphemeralUnboxingError

func (EphemeralUnboxingError) Error 

func (e EphemeralUnboxingError) Error() string

func (EphemeralUnboxingError) InternalError 

func (e EphemeralUnboxingError) InternalError() string

type FTLError 

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

func (FTLError) Error 

func (f FTLError) Error() string

type FetchRetrier added in v1.0.22 

type FetchRetrier struct {
	globals.Contextified
	utils.DebugLabeler
	sync.Mutex
	// contains filtered or unexported fields
}

FetchRetrier is responsible for tracking any nonblock fetch failures, and retrying them automatically.

func NewFetchRetrier added in v1.0.22 

func NewFetchRetrier(g *globals.Context) *FetchRetrier

func (*FetchRetrier) Connected added in v1.0.22 

func (f *FetchRetrier) Connected(ctx context.Context)

Connected is called when a connection to the chat server is established, and forces a pass over the retry queue

func (*FetchRetrier) Disconnected added in v1.0.22 

func (f *FetchRetrier) Disconnected(ctx context.Context)

Disconnected is called when we lose connection to the chat server, and pauses attempts on the retry queue.

func (*FetchRetrier) Failure added in v1.0.22 

func (f *FetchRetrier) Failure(ctx context.Context, uid gregor1.UID, desc types.RetryDescription) (err error)

Failure indicates a failure of type kind has happened when loading a conversation.

func (*FetchRetrier) Force added in v1.0.22 

func (f *FetchRetrier) Force(ctx context.Context)

Force forces a run of the retry loop.

func (*FetchRetrier) IsOffline added in v1.0.22 

func (f *FetchRetrier) IsOffline(ctx context.Context) bool

IsOffline returns if the module thinks we are connected to the chat server.

func (*FetchRetrier) Rekey added in v1.0.31 

func (f *FetchRetrier) Rekey(ctx context.Context, name string, membersType chat1.ConversationMembersType,
	public bool)

func (*FetchRetrier) SetClock added in v1.0.22 

func (f *FetchRetrier) SetClock(clock clockwork.Clock)

SetClock sets a custom clock for testing.

func (*FetchRetrier) Start added in v1.0.22 

func (f *FetchRetrier) Start(ctx context.Context, uid gregor1.UID)

func (*FetchRetrier) Stop added in v1.0.22 

func (f *FetchRetrier) Stop(ctx context.Context) chan struct{}

func (*FetchRetrier) Success added in v1.0.22 

func (f *FetchRetrier) Success(ctx context.Context, uid gregor1.UID, desc types.RetryDescription) (err error)

Success indicates a success of type kind loading a conversation. This effectively removes that conversation from the retry queue.

type FetchType added in v1.0.27 

type FetchType int
const (
	InboxLoad FetchType = iota
	ThreadLoad
	FullInboxLoad
)

type FlipManager 

type FlipManager struct {
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewFlipManager 

func NewFlipManager(g *globals.Context, ri func() chat1.RemoteInterface) *FlipManager

func (*FlipManager) CLogf 

func (m *FlipManager) CLogf(ctx context.Context, fmt string, args ...interface{})

CLogf implements the flip.DealersHelper interface

func (*FlipManager) Clock 

func (m *FlipManager) Clock() clockwork.Clock

Clock implements the flip.DealersHelper interface

func (*FlipManager) DescribeFlipText 

func (m *FlipManager) DescribeFlipText(ctx context.Context, text string) string

func (*FlipManager) HasActiveGames 

func (m *FlipManager) HasActiveGames(ctx context.Context) bool

func (*FlipManager) IsFlipConversationCreated 

func (m *FlipManager) IsFlipConversationCreated(ctx context.Context, outboxID chat1.OutboxID) (convID chat1.ConversationID, status types.FlipSendStatus)

func (*FlipManager) LoadFlip 

func (m *FlipManager) LoadFlip(ctx context.Context, uid gregor1.UID, hostConvID chat1.ConversationID,
	hostMsgID chat1.MessageID, flipConvID chat1.ConversationID, gameID chat1.FlipGameID)

LoadFlip implements the types.CoinFlipManager interface

func (*FlipManager) MaybeInjectFlipMessage 

func (m *FlipManager) MaybeInjectFlipMessage(ctx context.Context, boxedMsg chat1.MessageBoxed,
	inboxVers chat1.InboxVers, uid gregor1.UID, convID chat1.ConversationID, topicType chat1.TopicType) bool

MaybeInjectFlipMessage implements the types.CoinFlipManager interface

func (*FlipManager) Me 

func (m *FlipManager) Me() flip.UserDevice

Me implements the flip.DealersHelper interface

func (*FlipManager) SendChat 

func (m *FlipManager) SendChat(ctx context.Context, convID chat1.ConversationID, gameID chat1.FlipGameID,
	msg flip.GameMessageEncoded) (err error)

SendChat implements the flip.DealersHelper interface

func (*FlipManager) ServerTime 

func (m *FlipManager) ServerTime(ctx context.Context) (res time.Time, err error)

ServerTime implements the flip.DealersHelper interface

func (*FlipManager) ShouldCommit 

func (m *FlipManager) ShouldCommit(ctx context.Context) bool

func (*FlipManager) Start 

func (m *FlipManager) Start(ctx context.Context, uid gregor1.UID)

func (*FlipManager) StartFlip 

func (m *FlipManager) StartFlip(ctx context.Context, uid gregor1.UID, hostConvID chat1.ConversationID,
	tlfName, text string, inOutboxID *chat1.OutboxID) (err error)

StartFlip implements the types.CoinFlipManager interface

func (*FlipManager) Stop 

func (m *FlipManager) Stop(ctx context.Context) (ch chan struct{})

type FlipVisualizer 

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

func NewFlipVisualizer 

func NewFlipVisualizer(width, height int) *FlipVisualizer

func (*FlipVisualizer) Visualize 

func (v *FlipVisualizer) Visualize(status *chat1.UICoinFlipStatus)

type FullInboxRetry added in v1.0.27 

type FullInboxRetry struct {
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewFullInboxRetry added in v1.0.27 

func NewFullInboxRetry(g *globals.Context, query *chat1.GetInboxLocalQuery, p *chat1.Pagination) FullInboxRetry

func (FullInboxRetry) Fix added in v1.0.27 

func (f FullInboxRetry) Fix(ctx context.Context, uid gregor1.UID) error

func (FullInboxRetry) RekeyFixable added in v1.0.31 

func (f FullInboxRetry) RekeyFixable(ctx context.Context, tlfID chat1.TLFID) bool

func (FullInboxRetry) SendStale added in v1.0.27 

func (f FullInboxRetry) SendStale(ctx context.Context, uid gregor1.UID)

func (FullInboxRetry) String added in v1.0.27 

func (f FullInboxRetry) String() string

type HeaderMismatchError added in v1.0.19 

type HeaderMismatchError struct {
	Field string
}

func NewHeaderMismatchError added in v1.0.19 

func NewHeaderMismatchError(field string) HeaderMismatchError

func (HeaderMismatchError) Error added in v1.0.19 

func (e HeaderMismatchError) Error() string

type Helper added in v1.0.34 

type Helper struct {
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewHelper added in v1.0.34 

func NewHelper(g *globals.Context, ri func() chat1.RemoteInterface) *Helper

func (*Helper) FindConversations added in v1.0.40 

func (h *Helper) FindConversations(ctx context.Context,
	name string, topicName *string,
	topicType chat1.TopicType, membersType chat1.ConversationMembersType, vis keybase1.TLFVisibility) ([]chat1.ConversationLocal, error)

func (*Helper) FindConversationsByID added in v1.0.40 

func (h *Helper) FindConversationsByID(ctx context.Context, convIDs []chat1.ConversationID) ([]chat1.ConversationLocal, error)

func (*Helper) GetChannelTopicName added in v1.0.42 

func (h *Helper) GetChannelTopicName(ctx context.Context, teamID keybase1.TeamID,
	topicType chat1.TopicType, convID chat1.ConversationID) (topicName string, err error)

GetChannelTopicName gets the name of a team channel even if it's not in the inbox.

func (*Helper) GetMessage 

func (h *Helper) GetMessage(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID,
	msgID chat1.MessageID, resolveSupersedes bool, reason *chat1.GetThreadReason) (chat1.MessageUnboxed, error)

func (*Helper) GetMessages added in v1.0.48 

func (h *Helper) GetMessages(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID,
	msgIDs []chat1.MessageID, resolveSupersedes bool, reason *chat1.GetThreadReason) ([]chat1.MessageUnboxed, error)

func (*Helper) JoinConversationByID 

func (h *Helper) JoinConversationByID(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID) (err error)

func (*Helper) JoinConversationByName 

func (h *Helper) JoinConversationByName(ctx context.Context, uid gregor1.UID, tlfName, topicName string,
	topicType chat1.TopicType, vis keybase1.TLFVisibility) (err error)

func (*Helper) LeaveConversation 

func (h *Helper) LeaveConversation(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID) (err error)

func (*Helper) NewConversation 

func (h *Helper) NewConversation(ctx context.Context, uid gregor1.UID, tlfName string,
	topicName *string, topicType chat1.TopicType, membersType chat1.ConversationMembersType,
	vis keybase1.TLFVisibility) (chat1.ConversationLocal, error)

func (*Helper) NewConversationWithMemberSourceConv 

func (h *Helper) NewConversationWithMemberSourceConv(ctx context.Context, uid gregor1.UID, tlfName string,
	topicName *string, topicType chat1.TopicType, membersType chat1.ConversationMembersType,
	vis keybase1.TLFVisibility, memberSourceConv *chat1.ConversationID) (chat1.ConversationLocal, error)

func (*Helper) SendMsgByID added in v1.0.34 

func (h *Helper) SendMsgByID(ctx context.Context, convID chat1.ConversationID, tlfName string,
	body chat1.MessageBody, msgType chat1.MessageType) error

func (*Helper) SendMsgByIDNonblock added in v1.0.34 

func (h *Helper) SendMsgByIDNonblock(ctx context.Context, convID chat1.ConversationID,
	tlfName string, body chat1.MessageBody, msgType chat1.MessageType, inOutboxID *chat1.OutboxID) (chat1.OutboxID, error)

func (*Helper) SendMsgByName added in v1.0.34 

func (h *Helper) SendMsgByName(ctx context.Context, name string, topicName *string,
	membersType chat1.ConversationMembersType, ident keybase1.TLFIdentifyBehavior, body chat1.MessageBody,
	msgType chat1.MessageType) error

func (*Helper) SendMsgByNameNonblock added in v1.0.34 

func (h *Helper) SendMsgByNameNonblock(ctx context.Context, name string, topicName *string,
	membersType chat1.ConversationMembersType, ident keybase1.TLFIdentifyBehavior, body chat1.MessageBody,
	msgType chat1.MessageType, inOutboxID *chat1.OutboxID) (chat1.OutboxID, error)

func (*Helper) SendTextByID added in v1.0.34 

func (h *Helper) SendTextByID(ctx context.Context, convID chat1.ConversationID,
	tlfName string, text string) error

func (*Helper) SendTextByIDNonblock added in v1.0.34 

func (h *Helper) SendTextByIDNonblock(ctx context.Context, convID chat1.ConversationID,
	tlfName string, text string, outboxID *chat1.OutboxID) (chat1.OutboxID, error)

func (*Helper) SendTextByName added in v1.0.34 

func (h *Helper) SendTextByName(ctx context.Context, name string, topicName *string,
	membersType chat1.ConversationMembersType, ident keybase1.TLFIdentifyBehavior, text string) error

func (*Helper) SendTextByNameNonblock added in v1.0.34 

func (h *Helper) SendTextByNameNonblock(ctx context.Context, name string, topicName *string,
	membersType chat1.ConversationMembersType, ident keybase1.TLFIdentifyBehavior, text string,
	inOutboxID *chat1.OutboxID) (chat1.OutboxID, error)

func (*Helper) TopReacjis 

func (h *Helper) TopReacjis(ctx context.Context, uid gregor1.UID) []string

func (*Helper) UpgradeKBFSToImpteam added in v1.0.46 

func (h *Helper) UpgradeKBFSToImpteam(ctx context.Context, tlfName string, tlfID chat1.TLFID, public bool) (err error)

type HybridConversationSource 

type HybridConversationSource struct {
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewHybridConversationSource 

func NewHybridConversationSource(g *globals.Context, b *Boxer, storage *storage.Storage,
	ri func() chat1.RemoteInterface) *HybridConversationSource

func (*HybridConversationSource) AcquireConversationLock added in v1.0.48 

func (s *HybridConversationSource) AcquireConversationLock(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID) error

func (*HybridConversationSource) Clear 

func (s *HybridConversationSource) Clear(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID) error

func (*HybridConversationSource) ClearFromDelete added in v1.0.48 

func (s *HybridConversationSource) ClearFromDelete(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, deleteID chat1.MessageID) bool

ClearFromDelete clears the current cache if there is a delete that we don't know about and returns true to the caller if it schedules a background loader job

func (HybridConversationSource) DeleteAssets 

func (s HybridConversationSource) DeleteAssets(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, assets []chat1.Asset)

DeleteAssets implements github.com/keybase/go/chat/storage/storage.AssetDeleter interface.

func (*HybridConversationSource) EphemeralPurge 

func (s *HybridConversationSource) EphemeralPurge(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, purgeInfo *chat1.EphemeralPurgeInfo) (newPurgeInfo *chat1.EphemeralPurgeInfo, explodedMsgs []chat1.MessageUnboxed, err error)

func (*HybridConversationSource) Expunge added in v1.0.43 

func (s *HybridConversationSource) Expunge(ctx context.Context,
	convID chat1.ConversationID, uid gregor1.UID, expunge chat1.Expunge) (err error)

Expunge from storage and maybe notify the gui of staleness

func (*HybridConversationSource) GetMessages added in v1.0.19 

func (s *HybridConversationSource) GetMessages(ctx context.Context, conv types.UnboxConversationInfo,
	uid gregor1.UID, msgIDs []chat1.MessageID, threadReason *chat1.GetThreadReason) (res []chat1.MessageUnboxed, err error)

func (*HybridConversationSource) GetMessagesWithRemotes added in v1.0.19 

func (s *HybridConversationSource) GetMessagesWithRemotes(ctx context.Context,
	conv chat1.Conversation, uid gregor1.UID, msgs []chat1.MessageBoxed) ([]chat1.MessageUnboxed, error)

func (*HybridConversationSource) GetUnreadline 

func (s *HybridConversationSource) GetUnreadline(ctx context.Context,
	convID chat1.ConversationID, uid gregor1.UID, readMsgID chat1.MessageID) (unreadlineID *chat1.MessageID, err error)

func (HybridConversationSource) MarkAsRead 

func (s HybridConversationSource) MarkAsRead(ctx context.Context, convID chat1.ConversationID,
	uid gregor1.UID, msgID chat1.MessageID) (err error)

func (*HybridConversationSource) Pull 

func (s *HybridConversationSource) Pull(ctx context.Context, convID chat1.ConversationID,
	uid gregor1.UID, reason chat1.GetThreadReason, query *chat1.GetThreadQuery, pagination *chat1.Pagination) (thread chat1.ThreadView, err error)

func (HybridConversationSource) PullFull 

func (s HybridConversationSource) PullFull(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, reason chat1.GetThreadReason,
	query *chat1.GetThreadQuery, maxPages *int) (res chat1.ThreadView, err error)

func (*HybridConversationSource) PullLocalOnly added in v1.0.19 

func (s *HybridConversationSource) PullLocalOnly(ctx context.Context, convID chat1.ConversationID,
	uid gregor1.UID, query *chat1.GetThreadQuery, pagination *chat1.Pagination, maxPlaceholders int) (tv chat1.ThreadView, err error)

func (*HybridConversationSource) Push 

func (s *HybridConversationSource) Push(ctx context.Context, convID chat1.ConversationID,
	uid gregor1.UID, msg chat1.MessageBoxed) (decmsg chat1.MessageUnboxed, continuousUpdate bool, err error)

func (*HybridConversationSource) PushUnboxed added in v1.0.48 

func (s *HybridConversationSource) PushUnboxed(ctx context.Context, convID chat1.ConversationID,
	uid gregor1.UID, msg chat1.MessageUnboxed) (continuousUpdate bool, err error)

func (*HybridConversationSource) ReleaseConversationLock added in v1.0.48 

func (s *HybridConversationSource) ReleaseConversationLock(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID)

func (HybridConversationSource) SetRemoteInterface added in v1.0.19 

func (s HybridConversationSource) SetRemoteInterface(ri func() chat1.RemoteInterface)

func (HybridConversationSource) Sign 

func (s HybridConversationSource) Sign(payload []byte) ([]byte, error)

Sign implements github.com/keybase/go/chat/s3.Signer interface.

func (HybridConversationSource) TransformSupersedes added in v1.0.19 

func (s HybridConversationSource) TransformSupersedes(ctx context.Context,
	unboxInfo types.UnboxConversationInfo, uid gregor1.UID, msgs []chat1.MessageUnboxed) ([]chat1.MessageUnboxed, error)

type HybridInboxSource added in v1.0.19 

type HybridInboxSource struct {
	sync.Mutex
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewHybridInboxSource added in v1.0.19 

func NewHybridInboxSource(g *globals.Context,
	getChatInterface func() chat1.RemoteInterface) *HybridInboxSource

func (*HybridInboxSource) Clear 

func (s *HybridInboxSource) Clear(ctx context.Context, uid gregor1.UID) error

func (HybridInboxSource) Connected added in v1.0.19 

func (b HybridInboxSource) Connected(ctx context.Context)

func (*HybridInboxSource) ConversationsUpdate 

func (s *HybridInboxSource) ConversationsUpdate(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	convUpdates []chat1.ConversationUpdate) (err error)

func (HybridInboxSource) Disconnected added in v1.0.19 

func (b HybridInboxSource) Disconnected(ctx context.Context)

func (*HybridInboxSource) Expunge added in v1.0.43 

func (s *HybridInboxSource) Expunge(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID,
	expunge chat1.Expunge, maxMsgs []chat1.MessageSummary) (*chat1.ConversationLocal, error)

func (HybridInboxSource) GetInboxQueryLocalToRemote added in v1.0.27 

func (b HybridInboxSource) GetInboxQueryLocalToRemote(ctx context.Context,
	lquery *chat1.GetInboxLocalQuery) (rquery *chat1.GetInboxQuery, info types.NameInfo, err error)

func (HybridInboxSource) IsMember added in v1.0.27 

func (b HybridInboxSource) IsMember(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID) (bool, error)

func (HybridInboxSource) IsOffline added in v1.0.19 

func (b HybridInboxSource) IsOffline(ctx context.Context) bool

func (HybridInboxSource) Localize 

func (b HybridInboxSource) Localize(ctx context.Context, uid gregor1.UID, convs []types.RemoteConversation,
	localizerTyp types.ConversationLocalizerTyp) ([]chat1.ConversationLocal, chan types.AsyncInboxResult, error)

func (*HybridInboxSource) MembershipUpdate added in v1.0.27 

func (s *HybridInboxSource) MembershipUpdate(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	joined []chat1.ConversationMember, removed []chat1.ConversationMember, resets []chat1.ConversationMember,
	previews []chat1.ConversationID) (res types.MembershipUpdateRes, err error)

func (*HybridInboxSource) NewConversation added in v1.0.19 

func (s *HybridInboxSource) NewConversation(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	conv chat1.Conversation) (err error)

func (*HybridInboxSource) NewMessage added in v1.0.19 

func (s *HybridInboxSource) NewMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	convID chat1.ConversationID, msg chat1.MessageBoxed, maxMsgs []chat1.MessageSummary) (conv *chat1.ConversationLocal, err error)

func (*HybridInboxSource) Read added in v1.0.19 

func (s *HybridInboxSource) Read(ctx context.Context, uid gregor1.UID,
	localizerTyp types.ConversationLocalizerTyp, dataSource types.InboxSourceDataSourceTyp, maxLocalize *int,
	query *chat1.GetInboxLocalQuery, p *chat1.Pagination) (inbox types.Inbox, localizeCb chan types.AsyncInboxResult, err error)

func (*HybridInboxSource) ReadMessage added in v1.0.19 

func (s *HybridInboxSource) ReadMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	convID chat1.ConversationID, msgID chat1.MessageID) (conv *chat1.ConversationLocal, err error)

func (*HybridInboxSource) ReadUnverified added in v1.0.19 

func (s *HybridInboxSource) ReadUnverified(ctx context.Context, uid gregor1.UID,
	dataSource types.InboxSourceDataSourceTyp, query *chat1.GetInboxQuery, p *chat1.Pagination) (res types.Inbox, err error)

func (HybridInboxSource) RemoteSetConversationStatus 

func (b HybridInboxSource) RemoteSetConversationStatus(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, status chat1.ConversationStatus) (err error)

func (HybridInboxSource) Resume 

func (b HybridInboxSource) Resume(ctx context.Context) bool

func (*HybridInboxSource) SetAppNotificationSettings added in v1.0.27 

func (s *HybridInboxSource) SetAppNotificationSettings(ctx context.Context, uid gregor1.UID,
	vers chat1.InboxVers, convID chat1.ConversationID, settings chat1.ConversationNotificationInfo) (conv *chat1.ConversationLocal, err error)

func (*HybridInboxSource) SetConvRetention added in v1.0.41 

func (s *HybridInboxSource) SetConvRetention(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	convID chat1.ConversationID, policy chat1.RetentionPolicy) (res *chat1.ConversationLocal, err error)

func (*HybridInboxSource) SetConvSettings 

func (s *HybridInboxSource) SetConvSettings(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	convID chat1.ConversationID, convSettings *chat1.ConversationSettings) (res *chat1.ConversationLocal, err error)

func (HybridInboxSource) SetRemoteInterface added in v1.0.19 

func (b HybridInboxSource) SetRemoteInterface(ri func() chat1.RemoteInterface)

func (*HybridInboxSource) SetStatus added in v1.0.19 

func (s *HybridInboxSource) SetStatus(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	convID chat1.ConversationID, status chat1.ConversationStatus) (conv *chat1.ConversationLocal, err error)

func (*HybridInboxSource) SetTeamRetention added in v1.0.41 

func (s *HybridInboxSource) SetTeamRetention(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	teamID keybase1.TeamID, policy chat1.RetentionPolicy) (convs []chat1.ConversationLocal, err error)

func (*HybridInboxSource) Start 

func (s *HybridInboxSource) Start(ctx context.Context, uid gregor1.UID)

func (*HybridInboxSource) Stop 

func (s *HybridInboxSource) Stop(ctx context.Context) chan struct{}

func (*HybridInboxSource) SubteamRename 

func (s *HybridInboxSource) SubteamRename(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	convIDs []chat1.ConversationID) (convs []chat1.ConversationLocal, err error)

func (HybridInboxSource) Suspend 

func (b HybridInboxSource) Suspend(ctx context.Context) bool

func (*HybridInboxSource) TeamTypeChanged added in v1.0.30 

func (s *HybridInboxSource) TeamTypeChanged(ctx context.Context, uid gregor1.UID,
	vers chat1.InboxVers, convID chat1.ConversationID, teamType chat1.TeamType) (conv *chat1.ConversationLocal, err error)

func (*HybridInboxSource) TlfFinalize added in v1.0.19 

func (s *HybridInboxSource) TlfFinalize(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	convIDs []chat1.ConversationID, finalizeInfo chat1.ConversationFinalizeInfo) (convs []chat1.ConversationLocal, err error)

func (*HybridInboxSource) UpdateInboxVersion 

func (s *HybridInboxSource) UpdateInboxVersion(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers) (err error)

func (*HybridInboxSource) UpgradeKBFSToImpteam added in v1.0.41 

func (s *HybridInboxSource) UpgradeKBFSToImpteam(ctx context.Context, uid gregor1.UID,
	vers chat1.InboxVers, convID chat1.ConversationID) (conv *chat1.ConversationLocal, err error)

type IdentifyChangedHandler added in v1.0.19 

type IdentifyChangedHandler struct {
	globals.Contextified
	utils.DebugLabeler
}

func NewIdentifyChangedHandler added in v1.0.19 

func NewIdentifyChangedHandler(g *globals.Context) *IdentifyChangedHandler

func (*IdentifyChangedHandler) BackgroundIdentifyChanged added in v1.0.19 

func (h *IdentifyChangedHandler) BackgroundIdentifyChanged(ctx context.Context, job engine.IdentifyJob)

func (*IdentifyChangedHandler) HandleUserChanged added in v1.0.19 

func (h *IdentifyChangedHandler) HandleUserChanged(uid keybase1.UID) (err error)

type ImplicitTeamsNameInfoSource added in v1.0.29 

type ImplicitTeamsNameInfoSource struct {
	globals.Contextified
	utils.DebugLabeler
	*NameIdentifier
	// contains filtered or unexported fields
}

func NewImplicitTeamsNameInfoSource added in v1.0.29 

func NewImplicitTeamsNameInfoSource(g *globals.Context, lookupUpgraded bool) *ImplicitTeamsNameInfoSource

func (*ImplicitTeamsNameInfoSource) AllCryptKeys 

func (t *ImplicitTeamsNameInfoSource) AllCryptKeys(ctx context.Context, name string, public bool) (res types.AllCryptKeys, err error)

func (*ImplicitTeamsNameInfoSource) DecryptionKey 

func (t *ImplicitTeamsNameInfoSource) DecryptionKey(ctx context.Context, name string, teamID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool,
	keyGeneration int, kbfsEncrypted bool) (res types.CryptKey, err error)

func (*ImplicitTeamsNameInfoSource) EncryptionKey 

func (t *ImplicitTeamsNameInfoSource) EncryptionKey(ctx context.Context, name string, teamID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool) (res types.CryptKey, ni types.NameInfo, err error)

func (*ImplicitTeamsNameInfoSource) EphemeralDecryptionKey added in v1.0.48 

func (t *ImplicitTeamsNameInfoSource) EphemeralDecryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool,
	generation keybase1.EkGeneration, contentCtime *gregor1.Time) (teamEK keybase1.TeamEk, err error)

func (*ImplicitTeamsNameInfoSource) EphemeralEncryptionKey added in v1.0.48 

func (t *ImplicitTeamsNameInfoSource) EphemeralEncryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool) (teamEK keybase1.TeamEk, err error)

func (*ImplicitTeamsNameInfoSource) LookupID 

func (t *ImplicitTeamsNameInfoSource) LookupID(ctx context.Context, name string, public bool) (res types.NameInfo, err error)

func (*ImplicitTeamsNameInfoSource) LookupName 

func (t *ImplicitTeamsNameInfoSource) LookupName(ctx context.Context, tlfID chat1.TLFID, public bool) (res types.NameInfo, err error)

func (*ImplicitTeamsNameInfoSource) ShouldPairwiseMAC 

func (t *ImplicitTeamsNameInfoSource) ShouldPairwiseMAC(ctx context.Context, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool) (bool, []keybase1.KID, error)

type ImpteamBadteamError 

type ImpteamBadteamError struct {
	Msg string
}

func (ImpteamBadteamError) Error 

func (e ImpteamBadteamError) Error() string

type InvalidMACError 

type InvalidMACError struct{}

func NewInvalidMACError 

func NewInvalidMACError() InvalidMACError

func (InvalidMACError) Error 

func (e InvalidMACError) Error() string

type KBFSNameInfoSource added in v1.0.27 

type KBFSNameInfoSource struct {
	globals.Contextified
	utils.DebugLabeler
	*NameIdentifier
}

func NewKBFSNameInfoSource added in v1.0.27 

func NewKBFSNameInfoSource(g *globals.Context) *KBFSNameInfoSource

func (*KBFSNameInfoSource) AllCryptKeys 

func (t *KBFSNameInfoSource) AllCryptKeys(ctx context.Context, tlfName string, public bool) (res types.AllCryptKeys, err error)

func (*KBFSNameInfoSource) CompleteAndCanonicalizePrivateTlfName added in v1.0.27 

func (t *KBFSNameInfoSource) CompleteAndCanonicalizePrivateTlfName(ctx context.Context, tlfName string) (res keybase1.CanonicalTLFNameAndIDWithBreaks, err error)

func (*KBFSNameInfoSource) CryptKeys added in v1.0.27 

func (t *KBFSNameInfoSource) CryptKeys(ctx context.Context, tlfName string) (res keybase1.GetTLFCryptKeysRes, ferr error)

func (*KBFSNameInfoSource) DecryptionKey 

func (t *KBFSNameInfoSource) DecryptionKey(ctx context.Context, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool,
	keyGeneration int, kbfsEncrypted bool) (res types.CryptKey, err error)

func (*KBFSNameInfoSource) EncryptionKey 

func (t *KBFSNameInfoSource) EncryptionKey(ctx context.Context, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool) (res types.CryptKey, ni types.NameInfo, err error)

func (*KBFSNameInfoSource) EphemeralDecryptionKey added in v1.0.48 

func (t *KBFSNameInfoSource) EphemeralDecryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool,
	generation keybase1.EkGeneration, contentCtime *gregor1.Time) (teamEK keybase1.TeamEk, err error)

func (*KBFSNameInfoSource) EphemeralEncryptionKey added in v1.0.48 

func (t *KBFSNameInfoSource) EphemeralEncryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool) (teamEK keybase1.TeamEk, err error)

func (*KBFSNameInfoSource) LookupID 

func (t *KBFSNameInfoSource) LookupID(ctx context.Context, tlfName string, public bool) (res types.NameInfo, err error)

func (*KBFSNameInfoSource) LookupName 

func (t *KBFSNameInfoSource) LookupName(ctx context.Context, tlfID chat1.TLFID, public bool) (res types.NameInfo, err error)

func (*KBFSNameInfoSource) PublicCanonicalTLFNameAndID added in v1.0.27 

func (t *KBFSNameInfoSource) PublicCanonicalTLFNameAndID(ctx context.Context, tlfName string) (res keybase1.CanonicalTLFNameAndIDWithBreaks, ferr error)

func (*KBFSNameInfoSource) ShouldPairwiseMAC 

func (t *KBFSNameInfoSource) ShouldPairwiseMAC(ctx context.Context, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool) (bool, []keybase1.KID, error)

type KeyFinderImpl 

type KeyFinderImpl struct {
	globals.Contextified
	utils.DebugLabeler
	sync.Mutex
	// contains filtered or unexported fields
}

KeyFinder remembers results from previous calls to CryptKeys().

func (*KeyFinderImpl) EphemeralKeyForDecryption added in v1.0.48 

func (k *KeyFinderImpl) EphemeralKeyForDecryption(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool,
	generation keybase1.EkGeneration, contentCtime *gregor1.Time) (keybase1.TeamEk, error)

func (*KeyFinderImpl) EphemeralKeyForEncryption added in v1.0.48 

func (k *KeyFinderImpl) EphemeralKeyForEncryption(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool) (ek keybase1.TeamEk, err error)

func (*KeyFinderImpl) FindForDecryption added in v1.0.27 

func (k *KeyFinderImpl) FindForDecryption(ctx context.Context,
	tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool,
	keyGeneration int, kbfsEncrypted bool) (res types.CryptKey, err error)

FindForDecryption ignores tlfName or teamID based on membersType.

func (*KeyFinderImpl) FindForEncryption added in v1.0.27 

func (k *KeyFinderImpl) FindForEncryption(ctx context.Context, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool) (res types.CryptKey, ni types.NameInfo, err error)

FindForEncryption finds keys up-to-date enough for encrypting. Ignores tlfName or teamID based on membersType.

func (*KeyFinderImpl) Reset added in v1.0.42 

func (k *KeyFinderImpl) Reset()

func (*KeyFinderImpl) ShouldPairwiseMAC 

func (k *KeyFinderImpl) ShouldPairwiseMAC(ctx context.Context, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool) (bool, []keybase1.KID, error)

type KeyFinderMock 

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

func (*KeyFinderMock) EphemeralKeyForDecryption 

func (k *KeyFinderMock) EphemeralKeyForDecryption(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool,
	generation keybase1.EkGeneration, contentCtime *gregor1.Time) (keybase1.TeamEk, error)

func (*KeyFinderMock) EphemeralKeyForEncryption 

func (k *KeyFinderMock) EphemeralKeyForEncryption(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool) (keybase1.TeamEk, error)

func (*KeyFinderMock) FindForDecryption 

func (k *KeyFinderMock) FindForDecryption(ctx context.Context,
	tlfName string, teamID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool,
	keyGeneration int, kbfsEncrypted bool) (res types.CryptKey, err error)

func (*KeyFinderMock) FindForEncryption 

func (k *KeyFinderMock) FindForEncryption(ctx context.Context,
	tlfName string, teamID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool) (res types.CryptKey, ni types.NameInfo, err error)

func (*KeyFinderMock) Reset 

func (k *KeyFinderMock) Reset()

func (*KeyFinderMock) SetNameInfoSourceOverride 

func (k *KeyFinderMock) SetNameInfoSourceOverride(ni types.NameInfoSource)

func (*KeyFinderMock) ShouldPairwiseMAC 

func (k *KeyFinderMock) ShouldPairwiseMAC(ctx context.Context, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool) (bool, []keybase1.KID, error)

type MobilePush 

type MobilePush struct {
	globals.Contextified
	utils.DebugLabeler
}

func NewMobilePush 

func NewMobilePush(g *globals.Context) *MobilePush

func (*MobilePush) AckNotificationSuccess 

func (h *MobilePush) AckNotificationSuccess(ctx context.Context, pushIDs []string)

func (*MobilePush) FormatPushText 

func (h *MobilePush) FormatPushText(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID,
	membersType chat1.ConversationMembersType, msg chat1.MessageUnboxed) (res string, err error)

func (*MobilePush) UnboxPushNotification 

func (h *MobilePush) UnboxPushNotification(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, membersType chat1.ConversationMembersType, payload string) (res chat1.MessageUnboxed, err error)

type NameIdentifier added in v1.0.29 

type NameIdentifier struct {
	globals.Contextified
	utils.DebugLabeler
}

func NewNameIdentifier added in v1.0.29 

func NewNameIdentifier(g *globals.Context) *NameIdentifier

func (*NameIdentifier) Identify added in v1.0.29 

func (t *NameIdentifier) Identify(ctx context.Context, names []string, private bool,
	getTLFID func() keybase1.TLFID, getCanonicalName func() keybase1.CanonicalTlfName) (res []keybase1.TLFIdentifyFailure, err error)

type NewConvFindExistingMode 

type NewConvFindExistingMode int
const (
	NewConvFindExistingNormal NewConvFindExistingMode = iota
	NewConvFindExistingSkip
)

type NonblockingSender added in v1.0.19 

type NonblockingSender struct {
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewNonblockingSender added in v1.0.19 

func NewNonblockingSender(g *globals.Context, sender types.Sender) *NonblockingSender

func (*NonblockingSender) Prepare added in v1.0.19 

func (s *NonblockingSender) Prepare(ctx context.Context, msg chat1.MessagePlaintext,
	membersType chat1.ConversationMembersType, conv *chat1.Conversation, opts *types.SenderPrepareOptions) (types.SenderPrepareResult, error)

func (*NonblockingSender) Send added in v1.0.19 

func (s *NonblockingSender) Send(ctx context.Context, convID chat1.ConversationID,
	msg chat1.MessagePlaintext, clientPrev chat1.MessageID, outboxID *chat1.OutboxID,
	joinMentionsAs *chat1.ConversationMemberStatus) (chat1.OutboxID, *chat1.MessageBoxed, error)

func (*NonblockingSender) SendUnfurlNonblock 

func (s *NonblockingSender) SendUnfurlNonblock(ctx context.Context, convID chat1.ConversationID,
	msg chat1.MessagePlaintext, clientPrev chat1.MessageID, outboxID chat1.OutboxID) (chat1.OutboxID, error)

type NotAuthenticatedForThisDeviceError 

type NotAuthenticatedForThisDeviceError struct{}

func NewNotAuthenticatedForThisDeviceError 

func NewNotAuthenticatedForThisDeviceError() NotAuthenticatedForThisDeviceError

func (NotAuthenticatedForThisDeviceError) Error 

func (e NotAuthenticatedForThisDeviceError) Error() string

type NotifyRouterActivityRouter 

type NotifyRouterActivityRouter struct {
	utils.DebugLabeler
	globals.Contextified
	sync.Mutex
	// contains filtered or unexported fields
}

func NewNotifyRouterActivityRouter 

func NewNotifyRouterActivityRouter(g *globals.Context) *NotifyRouterActivityRouter

func (*NotifyRouterActivityRouter) Activity 

func (n *NotifyRouterActivityRouter) Activity(ctx context.Context, uid gregor1.UID,
	topicType chat1.TopicType, activity *chat1.ChatActivity, source chat1.ChatActivitySource)

func (*NotifyRouterActivityRouter) AttachmentUploadProgress 

func (n *NotifyRouterActivityRouter) AttachmentUploadProgress(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, outboxID chat1.OutboxID, bytesComplete, bytesTotal int64)

func (*NotifyRouterActivityRouter) AttachmentUploadStart 

func (n *NotifyRouterActivityRouter) AttachmentUploadStart(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, outboxID chat1.OutboxID)

func (*NotifyRouterActivityRouter) InboxStale 

func (n *NotifyRouterActivityRouter) InboxStale(ctx context.Context, uid gregor1.UID)

func (*NotifyRouterActivityRouter) InboxSyncStarted 

func (n *NotifyRouterActivityRouter) InboxSyncStarted(ctx context.Context, uid gregor1.UID)

func (*NotifyRouterActivityRouter) InboxSynced 

func (n *NotifyRouterActivityRouter) InboxSynced(ctx context.Context, uid gregor1.UID,
	topicType chat1.TopicType, syncRes chat1.ChatSyncResult)

func (*NotifyRouterActivityRouter) JoinedConversation 

func (n *NotifyRouterActivityRouter) JoinedConversation(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, topicType chat1.TopicType, conv *chat1.InboxUIItem)

func (*NotifyRouterActivityRouter) KBFSToImpteamUpgrade 

func (n *NotifyRouterActivityRouter) KBFSToImpteamUpgrade(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, topicType chat1.TopicType)

func (*NotifyRouterActivityRouter) LeftConversation 

func (n *NotifyRouterActivityRouter) LeftConversation(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, topicType chat1.TopicType)

func (*NotifyRouterActivityRouter) PromptUnfurl 

func (n *NotifyRouterActivityRouter) PromptUnfurl(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, msgID chat1.MessageID, domain string)

func (*NotifyRouterActivityRouter) ResetConversation 

func (n *NotifyRouterActivityRouter) ResetConversation(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, topicType chat1.TopicType)

func (*NotifyRouterActivityRouter) SetConvRetention 

func (n *NotifyRouterActivityRouter) SetConvRetention(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, topicType chat1.TopicType, conv *chat1.InboxUIItem)

func (*NotifyRouterActivityRouter) SetConvSettings 

func (n *NotifyRouterActivityRouter) SetConvSettings(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, topicType chat1.TopicType, conv *chat1.InboxUIItem)

func (*NotifyRouterActivityRouter) SetTeamRetention 

func (n *NotifyRouterActivityRouter) SetTeamRetention(ctx context.Context, uid gregor1.UID,
	teamID keybase1.TeamID, topicType chat1.TopicType, convs []chat1.InboxUIItem)

func (*NotifyRouterActivityRouter) SubteamRename 

func (n *NotifyRouterActivityRouter) SubteamRename(ctx context.Context, uid gregor1.UID,
	convIDs []chat1.ConversationID, topicType chat1.TopicType, convs []chat1.InboxUIItem)

func (*NotifyRouterActivityRouter) TLFFinalize 

func (n *NotifyRouterActivityRouter) TLFFinalize(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, topicType chat1.TopicType, finalizeInfo chat1.ConversationFinalizeInfo, conv *chat1.InboxUIItem)

func (*NotifyRouterActivityRouter) TLFResolve 

func (n *NotifyRouterActivityRouter) TLFResolve(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, topicType chat1.TopicType, resolveInfo chat1.ConversationResolveInfo)

func (*NotifyRouterActivityRouter) ThreadsStale 

func (n *NotifyRouterActivityRouter) ThreadsStale(ctx context.Context, uid gregor1.UID,
	updates []chat1.ConversationStaleUpdate)

func (*NotifyRouterActivityRouter) TypingUpdate 

func (n *NotifyRouterActivityRouter) TypingUpdate(ctx context.Context, updates []chat1.ConvTypingUpdate)

type OfflineClient added in v1.0.27 

type OfflineClient struct {
}

func (OfflineClient) Call added in v1.0.27 

func (e OfflineClient) Call(ctx context.Context, method string, arg interface{}, res interface{}) error

func (OfflineClient) CallCompressed 

func (e OfflineClient) CallCompressed(ctx context.Context, method string, arg interface{}, res interface{}, ctype rpc.CompressionType) error

func (OfflineClient) Notify added in v1.0.27 

func (e OfflineClient) Notify(ctx context.Context, method string, arg interface{}) error

type OfflineError added in v1.0.19 

type OfflineError struct {
}

func (OfflineError) Error added in v1.0.19 

func (e OfflineError) Error() string

type OfflineErrorKind added in v1.0.46 

type OfflineErrorKind int
const (
	OfflineErrorKindOnline OfflineErrorKind = iota
	OfflineErrorKindOfflineBasic
	OfflineErrorKindOfflineReconnect
)

func IsOfflineError added in v1.0.46 

func IsOfflineError(err error) OfflineErrorKind

type PermanentUnboxingError added in v1.0.19 

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

func (PermanentUnboxingError) Error added in v1.0.19 

func (e PermanentUnboxingError) Error() string

func (PermanentUnboxingError) ExportType added in v1.0.19 

func (e PermanentUnboxingError) ExportType() chat1.MessageUnboxedErrorType

func (PermanentUnboxingError) Inner added in v1.0.19 

func (e PermanentUnboxingError) Inner() error

func (PermanentUnboxingError) InternalError 

func (e PermanentUnboxingError) InternalError() string

func (PermanentUnboxingError) IsCritical 

func (e PermanentUnboxingError) IsCritical() bool

func (PermanentUnboxingError) IsPermanent added in v1.0.19 

func (e PermanentUnboxingError) IsPermanent() bool

func (PermanentUnboxingError) ToStatus 

func (e PermanentUnboxingError) ToStatus() (status keybase1.Status)

func (PermanentUnboxingError) VersionKind 

func (e PermanentUnboxingError) VersionKind() chat1.VersionKind

func (PermanentUnboxingError) VersionNumber 

func (e PermanentUnboxingError) VersionNumber() int

type PublicTeamEphemeralKeyError 

type PublicTeamEphemeralKeyError struct{}

func NewPublicTeamEphemeralKeyError 

func NewPublicTeamEphemeralKeyError() PublicTeamEphemeralKeyError

func (PublicTeamEphemeralKeyError) Error 

func (e PublicTeamEphemeralKeyError) Error() string

type PushHandler added in v1.0.19 

type PushHandler struct {
	globals.Contextified
	utils.DebugLabeler
	sync.Mutex
	// contains filtered or unexported fields
}

func NewPushHandler added in v1.0.19 

func NewPushHandler(g *globals.Context) *PushHandler

func (*PushHandler) Activity added in v1.0.19 

func (g *PushHandler) Activity(ctx context.Context, m gregor.OutOfBandMessage) (err error)

func (*PushHandler) ConversationsUpdate 

func (g *PushHandler) ConversationsUpdate(ctx context.Context, m gregor.OutOfBandMessage) (err error)

func (*PushHandler) HandleOobm added in v1.0.27 

func (g *PushHandler) HandleOobm(ctx context.Context, obm gregor.OutOfBandMessage) (bool, error)

func (*PushHandler) MembershipUpdate added in v1.0.27 

func (g *PushHandler) MembershipUpdate(ctx context.Context, m gregor.OutOfBandMessage) (err error)

func (*PushHandler) SetBadger added in v1.0.27 

func (g *PushHandler) SetBadger(badger *badges.Badger)

func (*PushHandler) SetClock added in v1.0.27 

func (g *PushHandler) SetClock(clock clockwork.Clock)

func (*PushHandler) SetConvRetention added in v1.0.41 

func (g *PushHandler) SetConvRetention(ctx context.Context, m gregor.OutOfBandMessage) (err error)

func (*PushHandler) SetConvSettings 

func (g *PushHandler) SetConvSettings(ctx context.Context, m gregor.OutOfBandMessage) (err error)

func (*PushHandler) SetTeamRetention added in v1.0.41 

func (g *PushHandler) SetTeamRetention(ctx context.Context, m gregor.OutOfBandMessage) (err error)

func (*PushHandler) SubteamRename 

func (g *PushHandler) SubteamRename(ctx context.Context, m gregor.OutOfBandMessage) (err error)

func (*PushHandler) TlfFinalize added in v1.0.19 

func (g *PushHandler) TlfFinalize(ctx context.Context, m gregor.OutOfBandMessage) (err error)

func (*PushHandler) TlfResolve added in v1.0.19 

func (g *PushHandler) TlfResolve(ctx context.Context, m gregor.OutOfBandMessage) (err error)

func (*PushHandler) Typing added in v1.0.27 

func (g *PushHandler) Typing(ctx context.Context, m gregor.OutOfBandMessage) (err error)

func (*PushHandler) UpgradeKBFSToImpteam added in v1.0.41 

func (g *PushHandler) UpgradeKBFSToImpteam(ctx context.Context, m gregor.OutOfBandMessage) (err error)

type RemoteAttachmentFetcher added in v1.0.48 

type RemoteAttachmentFetcher struct {
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewRemoteAttachmentFetcher added in v1.0.48 

func NewRemoteAttachmentFetcher(g *globals.Context, store attachments.Store) *RemoteAttachmentFetcher

func (*RemoteAttachmentFetcher) DeleteAssets 

func (r *RemoteAttachmentFetcher) DeleteAssets(ctx context.Context,
	convID chat1.ConversationID, assets []chat1.Asset, ri func() chat1.RemoteInterface, signer s3.Signer) (err error)

func (*RemoteAttachmentFetcher) FetchAttachment added in v1.0.48 

func (r *RemoteAttachmentFetcher) FetchAttachment(ctx context.Context, w io.Writer,
	convID chat1.ConversationID, asset chat1.Asset,
	ri func() chat1.RemoteInterface, signer s3.Signer, progress types.ProgressReporter) (err error)

func (*RemoteAttachmentFetcher) IsAssetLocal 

func (r *RemoteAttachmentFetcher) IsAssetLocal(ctx context.Context, asset chat1.Asset) (bool, error)

func (*RemoteAttachmentFetcher) OnCacheCleared 

func (r *RemoteAttachmentFetcher) OnCacheCleared(mctx libkb.MetaContext)

func (*RemoteAttachmentFetcher) PutUploadedAsset 

func (r *RemoteAttachmentFetcher) PutUploadedAsset(ctx context.Context, filename string, asset chat1.Asset) error

func (*RemoteAttachmentFetcher) StreamAttachment 

func (r *RemoteAttachmentFetcher) StreamAttachment(ctx context.Context, convID chat1.ConversationID,
	asset chat1.Asset, ri func() chat1.RemoteInterface, signer s3.Signer) (res io.ReadSeeker, err error)

type RemoteClient added in v1.0.22 

type RemoteClient struct {
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewRemoteClient added in v1.0.22 

func NewRemoteClient(g *globals.Context, cli rpc.GenericClient) *RemoteClient

func (*RemoteClient) Call added in v1.0.22 

func (c *RemoteClient) Call(ctx context.Context, method string, arg interface{}, res interface{}) (err error)

func (*RemoteClient) CallCompressed 

func (c *RemoteClient) CallCompressed(ctx context.Context, method string, arg interface{}, res interface{}, ctype rpc.CompressionType) (err error)

func (*RemoteClient) Notify added in v1.0.22 

func (c *RemoteClient) Notify(ctx context.Context, method string, arg interface{}) (err error)

type RemoteConversationSource 

type RemoteConversationSource struct {
	globals.Contextified
	// contains filtered or unexported fields
}

func NewRemoteConversationSource 

func NewRemoteConversationSource(g *globals.Context, b *Boxer, ri func() chat1.RemoteInterface) *RemoteConversationSource

func (*RemoteConversationSource) AcquireConversationLock added in v1.0.48 

func (s *RemoteConversationSource) AcquireConversationLock(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID) error

func (*RemoteConversationSource) Clear 

func (s *RemoteConversationSource) Clear(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID) error

func (*RemoteConversationSource) ClearFromDelete added in v1.0.48 

func (s *RemoteConversationSource) ClearFromDelete(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, msgID chat1.MessageID) bool

func (RemoteConversationSource) DeleteAssets 

func (s RemoteConversationSource) DeleteAssets(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, assets []chat1.Asset)

DeleteAssets implements github.com/keybase/go/chat/storage/storage.AssetDeleter interface.

func (*RemoteConversationSource) EphemeralPurge 

func (s *RemoteConversationSource) EphemeralPurge(ctx context.Context, convID chat1.ConversationID,
	uid gregor1.UID, purgeInfo *chat1.EphemeralPurgeInfo) (*chat1.EphemeralPurgeInfo, []chat1.MessageUnboxed, error)

func (*RemoteConversationSource) Expunge added in v1.0.43 

func (s *RemoteConversationSource) Expunge(ctx context.Context,
	convID chat1.ConversationID, uid gregor1.UID, expunge chat1.Expunge) error

func (*RemoteConversationSource) GetMessages added in v1.0.19 

func (s *RemoteConversationSource) GetMessages(ctx context.Context, conv types.UnboxConversationInfo,
	uid gregor1.UID, msgIDs []chat1.MessageID, threadReason *chat1.GetThreadReason) ([]chat1.MessageUnboxed, error)

func (*RemoteConversationSource) GetMessagesWithRemotes added in v1.0.19 

func (s *RemoteConversationSource) GetMessagesWithRemotes(ctx context.Context,
	conv chat1.Conversation, uid gregor1.UID, msgs []chat1.MessageBoxed) ([]chat1.MessageUnboxed, error)

func (*RemoteConversationSource) GetUnreadline 

func (s *RemoteConversationSource) GetUnreadline(ctx context.Context,
	convID chat1.ConversationID, uid gregor1.UID, readMsgID chat1.MessageID) (*chat1.MessageID, error)

func (RemoteConversationSource) MarkAsRead 

func (s RemoteConversationSource) MarkAsRead(ctx context.Context, convID chat1.ConversationID,
	uid gregor1.UID, msgID chat1.MessageID) (err error)

func (*RemoteConversationSource) Pull 

func (s *RemoteConversationSource) Pull(ctx context.Context, convID chat1.ConversationID,
	uid gregor1.UID, reason chat1.GetThreadReason, query *chat1.GetThreadQuery, pagination *chat1.Pagination) (chat1.ThreadView, error)

func (RemoteConversationSource) PullFull 

func (s RemoteConversationSource) PullFull(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, reason chat1.GetThreadReason,
	query *chat1.GetThreadQuery, maxPages *int) (res chat1.ThreadView, err error)

func (*RemoteConversationSource) PullLocalOnly added in v1.0.19 

func (s *RemoteConversationSource) PullLocalOnly(ctx context.Context, convID chat1.ConversationID,
	uid gregor1.UID, query *chat1.GetThreadQuery, pagination *chat1.Pagination, maxPlaceholders int) (chat1.ThreadView, error)

func (*RemoteConversationSource) Push 

func (s *RemoteConversationSource) Push(ctx context.Context, convID chat1.ConversationID,
	uid gregor1.UID, msg chat1.MessageBoxed) (chat1.MessageUnboxed, bool, error)

func (*RemoteConversationSource) PushUnboxed added in v1.0.48 

func (s *RemoteConversationSource) PushUnboxed(ctx context.Context, convID chat1.ConversationID,
	uid gregor1.UID, msg chat1.MessageUnboxed) (bool, error)

func (*RemoteConversationSource) ReleaseConversationLock added in v1.0.48 

func (s *RemoteConversationSource) ReleaseConversationLock(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID)

func (RemoteConversationSource) SetRemoteInterface added in v1.0.19 

func (s RemoteConversationSource) SetRemoteInterface(ri func() chat1.RemoteInterface)

func (RemoteConversationSource) Sign 

func (s RemoteConversationSource) Sign(payload []byte) ([]byte, error)

Sign implements github.com/keybase/go/chat/s3.Signer interface.

func (RemoteConversationSource) TransformSupersedes added in v1.0.19 

func (s RemoteConversationSource) TransformSupersedes(ctx context.Context,
	unboxInfo types.UnboxConversationInfo, uid gregor1.UID, msgs []chat1.MessageUnboxed) ([]chat1.MessageUnboxed, error)

type RemoteInboxSource added in v1.0.19 

type RemoteInboxSource struct {
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewRemoteInboxSource added in v1.0.19 

func NewRemoteInboxSource(g *globals.Context, ri func() chat1.RemoteInterface) *RemoteInboxSource

func (*RemoteInboxSource) Clear 

func (s *RemoteInboxSource) Clear(ctx context.Context, uid gregor1.UID) error

func (RemoteInboxSource) Connected added in v1.0.19 

func (b RemoteInboxSource) Connected(ctx context.Context)

func (*RemoteInboxSource) ConversationsUpdate 

func (s *RemoteInboxSource) ConversationsUpdate(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	convUpdates []chat1.ConversationUpdate) error

func (RemoteInboxSource) Disconnected added in v1.0.19 

func (b RemoteInboxSource) Disconnected(ctx context.Context)

func (*RemoteInboxSource) Expunge added in v1.0.43 

func (s *RemoteInboxSource) Expunge(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers, convID chat1.ConversationID,
	expunge chat1.Expunge, maxMsgs []chat1.MessageSummary) (res *chat1.ConversationLocal, err error)

func (RemoteInboxSource) GetInboxQueryLocalToRemote added in v1.0.27 

func (b RemoteInboxSource) GetInboxQueryLocalToRemote(ctx context.Context,
	lquery *chat1.GetInboxLocalQuery) (rquery *chat1.GetInboxQuery, info types.NameInfo, err error)

func (RemoteInboxSource) IsMember added in v1.0.27 

func (b RemoteInboxSource) IsMember(ctx context.Context, uid gregor1.UID, convID chat1.ConversationID) (bool, error)

func (RemoteInboxSource) IsOffline added in v1.0.19 

func (b RemoteInboxSource) IsOffline(ctx context.Context) bool

func (RemoteInboxSource) Localize 

func (b RemoteInboxSource) Localize(ctx context.Context, uid gregor1.UID, convs []types.RemoteConversation,
	localizerTyp types.ConversationLocalizerTyp) ([]chat1.ConversationLocal, chan types.AsyncInboxResult, error)

func (*RemoteInboxSource) MembershipUpdate added in v1.0.27 

func (s *RemoteInboxSource) MembershipUpdate(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	joined []chat1.ConversationMember, removed []chat1.ConversationMember, resets []chat1.ConversationMember,
	previews []chat1.ConversationID) (res types.MembershipUpdateRes, err error)

func (*RemoteInboxSource) NewConversation added in v1.0.19 

func (s *RemoteInboxSource) NewConversation(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	conv chat1.Conversation) error

func (*RemoteInboxSource) NewMessage added in v1.0.19 

func (s *RemoteInboxSource) NewMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	convID chat1.ConversationID, msg chat1.MessageBoxed, maxMsgs []chat1.MessageSummary) (*chat1.ConversationLocal, error)

func (*RemoteInboxSource) Read added in v1.0.19 

func (s *RemoteInboxSource) Read(ctx context.Context, uid gregor1.UID,
	localizerTyp types.ConversationLocalizerTyp, dataSource types.InboxSourceDataSourceTyp, maxLocalize *int,
	query *chat1.GetInboxLocalQuery, p *chat1.Pagination) (types.Inbox, chan types.AsyncInboxResult, error)

func (*RemoteInboxSource) ReadMessage added in v1.0.19 

func (s *RemoteInboxSource) ReadMessage(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	convID chat1.ConversationID, msgID chat1.MessageID) (*chat1.ConversationLocal, error)

func (*RemoteInboxSource) ReadUnverified added in v1.0.19 

func (s *RemoteInboxSource) ReadUnverified(ctx context.Context, uid gregor1.UID,
	dataSource types.InboxSourceDataSourceTyp, rquery *chat1.GetInboxQuery, p *chat1.Pagination) (types.Inbox, error)

func (RemoteInboxSource) RemoteSetConversationStatus 

func (b RemoteInboxSource) RemoteSetConversationStatus(ctx context.Context, uid gregor1.UID,
	convID chat1.ConversationID, status chat1.ConversationStatus) (err error)

func (RemoteInboxSource) Resume 

func (b RemoteInboxSource) Resume(ctx context.Context) bool

func (*RemoteInboxSource) SetAppNotificationSettings added in v1.0.27 

func (s *RemoteInboxSource) SetAppNotificationSettings(ctx context.Context, uid gregor1.UID,
	vers chat1.InboxVers, convID chat1.ConversationID, settings chat1.ConversationNotificationInfo) (*chat1.ConversationLocal, error)

func (*RemoteInboxSource) SetConvRetention added in v1.0.41 

func (s *RemoteInboxSource) SetConvRetention(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	convID chat1.ConversationID, policy chat1.RetentionPolicy) (res *chat1.ConversationLocal, err error)

func (*RemoteInboxSource) SetConvSettings 

func (s *RemoteInboxSource) SetConvSettings(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	convID chat1.ConversationID, convSettings *chat1.ConversationSettings) (res *chat1.ConversationLocal, err error)

func (RemoteInboxSource) SetRemoteInterface added in v1.0.19 

func (b RemoteInboxSource) SetRemoteInterface(ri func() chat1.RemoteInterface)

func (*RemoteInboxSource) SetStatus added in v1.0.19 

func (s *RemoteInboxSource) SetStatus(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	convID chat1.ConversationID, status chat1.ConversationStatus) (*chat1.ConversationLocal, error)

func (*RemoteInboxSource) SetTeamRetention added in v1.0.41 

func (s *RemoteInboxSource) SetTeamRetention(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	teamID keybase1.TeamID, policy chat1.RetentionPolicy) (res []chat1.ConversationLocal, err error)

func (RemoteInboxSource) Start 

func (b RemoteInboxSource) Start(ctx context.Context, uid gregor1.UID)

func (RemoteInboxSource) Stop 

func (b RemoteInboxSource) Stop(ctx context.Context) chan struct{}

func (*RemoteInboxSource) SubteamRename 

func (s *RemoteInboxSource) SubteamRename(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	convIDs []chat1.ConversationID) (convs []chat1.ConversationLocal, err error)

func (RemoteInboxSource) Suspend 

func (b RemoteInboxSource) Suspend(ctx context.Context) bool

func (*RemoteInboxSource) TeamTypeChanged added in v1.0.41 

func (s *RemoteInboxSource) TeamTypeChanged(ctx context.Context, uid gregor1.UID,
	vers chat1.InboxVers, convID chat1.ConversationID, teamType chat1.TeamType) (conv *chat1.ConversationLocal, err error)

func (*RemoteInboxSource) TlfFinalize added in v1.0.19 

func (s *RemoteInboxSource) TlfFinalize(ctx context.Context, uid gregor1.UID, vers chat1.InboxVers,
	convIDs []chat1.ConversationID, finalizeInfo chat1.ConversationFinalizeInfo) ([]chat1.ConversationLocal, error)

func (*RemoteInboxSource) UpdateInboxVersion 

func (s *RemoteInboxSource) UpdateInboxVersion(ctx context.Context, uid gregor1.UID,
	vers chat1.InboxVers) error

func (*RemoteInboxSource) UpgradeKBFSToImpteam 

func (s *RemoteInboxSource) UpgradeKBFSToImpteam(ctx context.Context, uid gregor1.UID,
	vers chat1.InboxVers, convID chat1.ConversationID) (conv *chat1.ConversationLocal, err error)

type SenderTestImmediateFailError 

type SenderTestImmediateFailError struct {
}

func (SenderTestImmediateFailError) Error 

func (e SenderTestImmediateFailError) Error() string

func (SenderTestImmediateFailError) IsImmediateFail 

func (e SenderTestImmediateFailError) IsImmediateFail() (chat1.OutboxErrorType, bool)

type Server added in v1.0.22 

type Server struct {
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewServer added in v1.0.22 

func NewServer(g *globals.Context, serverConn ServerConnection, uiSource UISource) *Server

func (*Server) AddTeamMemberAfterReset added in v1.0.39 

func (h *Server) AddTeamMemberAfterReset(ctx context.Context,
	arg chat1.AddTeamMemberAfterResetArg) (err error)

func (*Server) BulkAddToConv 

func (h *Server) BulkAddToConv(ctx context.Context, arg chat1.BulkAddToConvArg) (err error)

func (*Server) CancelActiveSearch 

func (h *Server) CancelActiveSearch(ctx context.Context) (err error)

func (*Server) CancelPost added in v1.0.22 

func (h *Server) CancelPost(ctx context.Context, outboxID chat1.OutboxID) (err error)

func (*Server) DeleteConversationLocal added in v1.0.31 

func (h *Server) DeleteConversationLocal(ctx context.Context, arg chat1.DeleteConversationLocalArg) (res chat1.DeleteConversationLocalRes, err error)

func (*Server) DownloadAttachmentLocal added in v1.0.22 

func (h *Server) DownloadAttachmentLocal(ctx context.Context, arg chat1.DownloadAttachmentLocalArg) (res chat1.DownloadAttachmentLocalRes, err error)

DownloadAttachmentLocal implements chat1.LocalInterface.DownloadAttachmentLocal.

func (*Server) DownloadFileAttachmentLocal added in v1.0.22 

func (h *Server) DownloadFileAttachmentLocal(ctx context.Context, arg chat1.DownloadFileAttachmentLocalArg) (res chat1.DownloadFileAttachmentLocalRes, err error)

DownloadFileAttachmentLocal implements chat1.LocalInterface.DownloadFileAttachmentLocal.

func (*Server) FindConversationsLocal added in v1.0.22 

func (h *Server) FindConversationsLocal(ctx context.Context,
	arg chat1.FindConversationsLocalArg) (res chat1.FindConversationsLocalRes, err error)

func (*Server) GenerateOutboxID added in v1.0.27 

func (h *Server) GenerateOutboxID(ctx context.Context) (res chat1.OutboxID, err error)

func (*Server) GetCachedThread added in v1.0.22 

func (h *Server) GetCachedThread(ctx context.Context, arg chat1.GetCachedThreadArg) (res chat1.GetThreadLocalRes, err error)

func (*Server) GetConversationForCLILocal added in v1.0.22 

func (h *Server) GetConversationForCLILocal(ctx context.Context, arg chat1.GetConversationForCLILocalQuery) (res chat1.GetConversationForCLILocalRes, err error)

func (*Server) GetGlobalAppNotificationSettingsLocal added in v1.0.27 

func (h *Server) GetGlobalAppNotificationSettingsLocal(ctx context.Context) (res chat1.GlobalAppNotificationSettings, err error)

func (*Server) GetInboxAndUnboxLocal added in v1.0.22 

func (h *Server) GetInboxAndUnboxLocal(ctx context.Context, arg chat1.GetInboxAndUnboxLocalArg) (res chat1.GetInboxAndUnboxLocalRes, err error)

GetInboxAndUnboxLocal implements keybase.chatLocal.getInboxAndUnboxLocal protocol.

func (*Server) GetInboxAndUnboxUILocal 

func (h *Server) GetInboxAndUnboxUILocal(ctx context.Context, arg chat1.GetInboxAndUnboxUILocalArg) (res chat1.GetInboxAndUnboxUILocalRes, err error)

func (*Server) GetInboxNonblockLocal added in v1.0.22 

func (h *Server) GetInboxNonblockLocal(ctx context.Context, arg chat1.GetInboxNonblockLocalArg) (res chat1.NonblockFetchRes, err error)

func (*Server) GetInboxSummaryForCLILocal added in v1.0.22 

func (h *Server) GetInboxSummaryForCLILocal(ctx context.Context, arg chat1.GetInboxSummaryForCLILocalQuery) (res chat1.GetInboxSummaryForCLILocalRes, err error)

func (*Server) GetInboxUILocal 

func (h *Server) GetInboxUILocal(ctx context.Context, arg chat1.GetInboxUILocalArg) (res chat1.GetInboxUILocalRes, err error)

func (*Server) GetMessagesLocal added in v1.0.22 

func (h *Server) GetMessagesLocal(ctx context.Context, arg chat1.GetMessagesLocalArg) (res chat1.GetMessagesLocalRes, err error)

func (*Server) GetNextAttachmentMessageLocal 

func (h *Server) GetNextAttachmentMessageLocal(ctx context.Context,
	arg chat1.GetNextAttachmentMessageLocalArg) (res chat1.GetNextAttachmentMessageLocalRes, err error)

func (*Server) GetStaticConfig 

func (h *Server) GetStaticConfig(ctx context.Context) (res chat1.StaticConfig, err error)

func (*Server) GetTLFConversationsLocal added in v1.0.27 

func (h *Server) GetTLFConversationsLocal(ctx context.Context, arg chat1.GetTLFConversationsLocalArg) (res chat1.GetTLFConversationsLocalRes, err error)

func (*Server) GetTeamRetentionLocal added in v1.0.46 

func (h *Server) GetTeamRetentionLocal(ctx context.Context, teamID keybase1.TeamID) (res *chat1.RetentionPolicy, err error)

func (*Server) GetThreadLocal added in v1.0.22 

func (h *Server) GetThreadLocal(ctx context.Context, arg chat1.GetThreadLocalArg) (res chat1.GetThreadLocalRes, err error)

GetThreadLocal implements keybase.chatLocal.getThreadLocal protocol.

func (*Server) GetThreadNonblock added in v1.0.22 

func (h *Server) GetThreadNonblock(ctx context.Context, arg chat1.GetThreadNonblockArg) (res chat1.NonblockFetchRes, fullErr error)

func (*Server) GetUnfurlSettings 

func (h *Server) GetUnfurlSettings(ctx context.Context) (res chat1.UnfurlSettingsDisplay, err error)

func (*Server) GetUnreadline 

func (h *Server) GetUnreadline(ctx context.Context, arg chat1.GetUnreadlineArg) (res chat1.UnreadlineRes, err error)

func (*Server) GetUploadTempFile 

func (h *Server) GetUploadTempFile(ctx context.Context, arg chat1.GetUploadTempFileArg) (res string, err error)

func (*Server) JoinConversationByIDLocal added in v1.0.27 

func (h *Server) JoinConversationByIDLocal(ctx context.Context, convID chat1.ConversationID) (res chat1.JoinLeaveConversationLocalRes, err error)

func (*Server) JoinConversationLocal added in v1.0.27 

func (h *Server) JoinConversationLocal(ctx context.Context, arg chat1.JoinConversationLocalArg) (res chat1.JoinLeaveConversationLocalRes, err error)

func (*Server) LeaveConversationLocal added in v1.0.27 

func (h *Server) LeaveConversationLocal(ctx context.Context, convID chat1.ConversationID) (res chat1.JoinLeaveConversationLocalRes, err error)

func (*Server) MakePreview added in v1.0.22 

func (h *Server) MakePreview(ctx context.Context, arg chat1.MakePreviewArg) (res chat1.MakePreviewRes, err error)

MakePreview implements chat1.LocalInterface.MakePreview.

func (*Server) MakeUploadTempFile 

func (h *Server) MakeUploadTempFile(ctx context.Context, arg chat1.MakeUploadTempFileArg) (res string, err error)

func (*Server) MarkAsReadLocal added in v1.0.22 

func (h *Server) MarkAsReadLocal(ctx context.Context, arg chat1.MarkAsReadLocalArg) (res chat1.MarkAsReadLocalRes, err error)

func (*Server) NewConversationLocal added in v1.0.22 

func (h *Server) NewConversationLocal(ctx context.Context, arg chat1.NewConversationLocalArg) (res chat1.NewConversationLocalRes, err error)

NewConversationLocal implements keybase.chatLocal.newConversationLocal protocol. Create a new conversation. Or in the case of CHAT, create-or-get a conversation.

func (*Server) PostDeleteHistoryByAge added in v1.0.40 

func (h *Server) PostDeleteHistoryByAge(ctx context.Context, arg chat1.PostDeleteHistoryByAgeArg) (res chat1.PostLocalRes, err error)

func (*Server) PostDeleteHistoryThrough added in v1.0.43 

func (h *Server) PostDeleteHistoryThrough(ctx context.Context, arg chat1.PostDeleteHistoryThroughArg) (res chat1.PostLocalRes, err error)

func (*Server) PostDeleteHistoryUpto added in v1.0.40 

func (h *Server) PostDeleteHistoryUpto(ctx context.Context, arg chat1.PostDeleteHistoryUptoArg) (res chat1.PostLocalRes, err error)

func (*Server) PostDeleteNonblock added in v1.0.22 

func (h *Server) PostDeleteNonblock(ctx context.Context, arg chat1.PostDeleteNonblockArg) (chat1.PostLocalNonblockRes, error)

func (*Server) PostEditNonblock added in v1.0.22 

func (h *Server) PostEditNonblock(ctx context.Context, arg chat1.PostEditNonblockArg) (res chat1.PostLocalNonblockRes, err error)

func (*Server) PostFileAttachmentLocal added in v1.0.22 

func (h *Server) PostFileAttachmentLocal(ctx context.Context, arg chat1.PostFileAttachmentLocalArg) (res chat1.PostLocalRes, err error)

PostFileAttachmentLocal implements chat1.LocalInterface.PostFileAttachmentLocal.

func (*Server) PostFileAttachmentLocalNonblock 

func (h *Server) PostFileAttachmentLocalNonblock(ctx context.Context,
	arg chat1.PostFileAttachmentLocalNonblockArg) (res chat1.PostLocalNonblockRes, err error)

func (*Server) PostHeadline added in v1.0.29 

func (h *Server) PostHeadline(ctx context.Context, arg chat1.PostHeadlineArg) (chat1.PostLocalRes, error)

func (*Server) PostHeadlineNonblock added in v1.0.29 

func (h *Server) PostHeadlineNonblock(ctx context.Context, arg chat1.PostHeadlineNonblockArg) (chat1.PostLocalNonblockRes, error)

func (*Server) PostLocal added in v1.0.22 

func (h *Server) PostLocal(ctx context.Context, arg chat1.PostLocalArg) (res chat1.PostLocalRes, err error)

PostLocal implements keybase.chatLocal.postLocal protocol.

func (*Server) PostLocalNonblock added in v1.0.22 

func (h *Server) PostLocalNonblock(ctx context.Context, arg chat1.PostLocalNonblockArg) (res chat1.PostLocalNonblockRes, err error)

func (*Server) PostMetadata added in v1.0.34 

func (h *Server) PostMetadata(ctx context.Context, arg chat1.PostMetadataArg) (chat1.PostLocalRes, error)

func (*Server) PostMetadataNonblock added in v1.0.34 

func (h *Server) PostMetadataNonblock(ctx context.Context, arg chat1.PostMetadataNonblockArg) (chat1.PostLocalNonblockRes, error)

func (*Server) PostReactionNonblock 

func (h *Server) PostReactionNonblock(ctx context.Context, arg chat1.PostReactionNonblockArg) (res chat1.PostLocalNonblockRes, err error)

func (*Server) PostTextNonblock added in v1.0.22 

func (h *Server) PostTextNonblock(ctx context.Context, arg chat1.PostTextNonblockArg) (res chat1.PostLocalNonblockRes, err error)

func (*Server) PreviewConversationByIDLocal added in v1.0.34 

func (h *Server) PreviewConversationByIDLocal(ctx context.Context, convID chat1.ConversationID) (res chat1.JoinLeaveConversationLocalRes, err error)

func (*Server) ProfileChatSearch 

func (h *Server) ProfileChatSearch(ctx context.Context, identifyBehavior keybase1.TLFIdentifyBehavior) (res map[string]chat1.ProfileSearchConvStats, err error)

func (*Server) ResolveUnfurlPrompt 

func (h *Server) ResolveUnfurlPrompt(ctx context.Context, arg chat1.ResolveUnfurlPromptArg) (err error)

func (*Server) RetryPost added in v1.0.22 

func (h *Server) RetryPost(ctx context.Context, arg chat1.RetryPostArg) (err error)

func (*Server) SaveUnfurlSettings 

func (h *Server) SaveUnfurlSettings(ctx context.Context, arg chat1.SaveUnfurlSettingsArg) (err error)

func (*Server) SearchInbox 

func (h *Server) SearchInbox(ctx context.Context, arg chat1.SearchInboxArg) (res chat1.SearchInboxRes, err error)

func (*Server) SearchRegexp 

func (h *Server) SearchRegexp(ctx context.Context, arg chat1.SearchRegexpArg) (res chat1.SearchRegexpRes, err error)

func (*Server) SetAppNotificationSettingsLocal added in v1.0.27 

func (h *Server) SetAppNotificationSettingsLocal(ctx context.Context,
	arg chat1.SetAppNotificationSettingsLocalArg) (res chat1.SetAppNotificationSettingsLocalRes, err error)

func (*Server) SetClock added in v1.0.42 

func (h *Server) SetClock(clock clockwork.Clock)

func (*Server) SetConvMinWriterRoleLocal 

func (h *Server) SetConvMinWriterRoleLocal(ctx context.Context, arg chat1.SetConvMinWriterRoleLocalArg) (err error)

func (*Server) SetConvRetentionLocal added in v1.0.40 

func (h *Server) SetConvRetentionLocal(ctx context.Context, arg chat1.SetConvRetentionLocalArg) (err error)

func (*Server) SetConversationStatusLocal added in v1.0.22 

func (h *Server) SetConversationStatusLocal(ctx context.Context, arg chat1.SetConversationStatusLocalArg) (res chat1.SetConversationStatusLocalRes, err error)

func (*Server) SetGlobalAppNotificationSettingsLocal added in v1.0.27 

func (h *Server) SetGlobalAppNotificationSettingsLocal(ctx context.Context,
	strSettings map[string]bool) (err error)

func (*Server) SetTeamRetentionLocal added in v1.0.40 

func (h *Server) SetTeamRetentionLocal(ctx context.Context, arg chat1.SetTeamRetentionLocalArg) (err error)

func (*Server) ToggleMessageCollapse 

func (h *Server) ToggleMessageCollapse(ctx context.Context, arg chat1.ToggleMessageCollapseArg) (err error)

func (*Server) UnboxMobilePushNotification added in v1.0.27 

func (h *Server) UnboxMobilePushNotification(ctx context.Context, arg chat1.UnboxMobilePushNotificationArg) (res string, err error)

func (*Server) UpdateTyping added in v1.0.27 

func (h *Server) UpdateTyping(ctx context.Context, arg chat1.UpdateTypingArg) (err error)

func (*Server) UpdateUnsentText 

func (h *Server) UpdateUnsentText(ctx context.Context, arg chat1.UpdateUnsentTextArg) (err error)

func (*Server) UpgradeKBFSConversationToImpteam added in v1.0.41 

func (h *Server) UpgradeKBFSConversationToImpteam(ctx context.Context, convID chat1.ConversationID) (err error)

type ServerConnection added in v1.0.22 

type ServerConnection interface {
	Reconnect(context.Context) (bool, error)
	GetClient() chat1.RemoteInterface
}

type SimpleIdentifyNotifier added in v1.0.42 

type SimpleIdentifyNotifier struct {
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewSimpleIdentifyNotifier added in v1.0.42 

func NewSimpleIdentifyNotifier(g *globals.Context) *SimpleIdentifyNotifier

func (*SimpleIdentifyNotifier) Reset added in v1.0.42 

func (d *SimpleIdentifyNotifier) Reset()

func (*SimpleIdentifyNotifier) ResetOnGUIConnect added in v1.0.42 

func (d *SimpleIdentifyNotifier) ResetOnGUIConnect()

func (*SimpleIdentifyNotifier) Send added in v1.0.42 

func (d *SimpleIdentifyNotifier) Send(ctx context.Context, update keybase1.CanonicalTLFNameAndIDWithBreaks)

type Syncer added in v1.0.19 

type Syncer struct {
	globals.Contextified
	utils.DebugLabeler
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSyncer added in v1.0.19 

func NewSyncer(g *globals.Context) *Syncer

func (*Syncer) Connected added in v1.0.19 

func (s *Syncer) Connected(ctx context.Context, cli chat1.RemoteInterface, uid gregor1.UID,
	syncRes *chat1.SyncChatRes) (err error)

func (*Syncer) Disconnected added in v1.0.19 

func (s *Syncer) Disconnected(ctx context.Context)

func (*Syncer) GetSelectedConversation added in v1.0.48 

func (s *Syncer) GetSelectedConversation() chat1.ConversationID

func (*Syncer) IsConnected added in v1.0.21 

func (s *Syncer) IsConnected(ctx context.Context) bool

func (*Syncer) RegisterOfflinable added in v1.0.19 

func (s *Syncer) RegisterOfflinable(offlinable types.Offlinable)

func (*Syncer) SelectConversation added in v1.0.47 

func (s *Syncer) SelectConversation(ctx context.Context, convID chat1.ConversationID)

func (*Syncer) SendChatStaleNotifications added in v1.0.19 

func (s *Syncer) SendChatStaleNotifications(ctx context.Context, uid gregor1.UID,
	updates []chat1.ConversationStaleUpdate, immediate bool)

func (*Syncer) SetClock added in v1.0.21 

func (s *Syncer) SetClock(clock clockwork.Clock)

func (*Syncer) Shutdown added in v1.0.21 

func (s *Syncer) Shutdown()

func (*Syncer) Sync added in v1.0.21 

func (s *Syncer) Sync(ctx context.Context, cli chat1.RemoteInterface, uid gregor1.UID,
	syncRes *chat1.SyncChatRes) (err error)

type TeamChannelSource 

type TeamChannelSource struct {
	globals.Contextified
	utils.DebugLabeler
}

func NewTeamChannelSource 

func NewTeamChannelSource(g *globals.Context) *TeamChannelSource

func (*TeamChannelSource) GetChannelTopicName 

func (c *TeamChannelSource) GetChannelTopicName(ctx context.Context, uid gregor1.UID,
	tlfID chat1.TLFID, topicType chat1.TopicType, convID chat1.ConversationID) (res string, err error)

func (*TeamChannelSource) GetChannelsFull 

func (c *TeamChannelSource) GetChannelsFull(ctx context.Context, uid gregor1.UID,
	tlfID chat1.TLFID, topicType chat1.TopicType) (res []chat1.ConversationLocal, err error)

func (*TeamChannelSource) GetChannelsTopicName 

func (c *TeamChannelSource) GetChannelsTopicName(ctx context.Context, uid gregor1.UID,
	tlfID chat1.TLFID, topicType chat1.TopicType) (res []chat1.ChannelNameMention, err error)

type TeamLoader added in v1.0.47 

type TeamLoader struct {
	libkb.Contextified
	utils.DebugLabeler
}

func NewTeamLoader added in v1.0.47 

func NewTeamLoader(g *libkb.GlobalContext) *TeamLoader

type TeamsNameInfoSource added in v1.0.27 

type TeamsNameInfoSource struct {
	globals.Contextified
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewTeamsNameInfoSource added in v1.0.27 

func NewTeamsNameInfoSource(g *globals.Context) *TeamsNameInfoSource

func (*TeamsNameInfoSource) AllCryptKeys 

func (t *TeamsNameInfoSource) AllCryptKeys(ctx context.Context, name string, public bool) (res types.AllCryptKeys, err error)

func (*TeamsNameInfoSource) DecryptionKey 

func (t *TeamsNameInfoSource) DecryptionKey(ctx context.Context, name string, teamID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool,
	keyGeneration int, kbfsEncrypted bool) (res types.CryptKey, err error)

func (*TeamsNameInfoSource) EncryptionKey 

func (t *TeamsNameInfoSource) EncryptionKey(ctx context.Context, name string, teamID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool) (res types.CryptKey, ni types.NameInfo, err error)

func (*TeamsNameInfoSource) EphemeralDecryptionKey added in v1.0.48 

func (t *TeamsNameInfoSource) EphemeralDecryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool,
	generation keybase1.EkGeneration, contentCtime *gregor1.Time) (teamEK keybase1.TeamEk, err error)

func (*TeamsNameInfoSource) EphemeralEncryptionKey added in v1.0.48 

func (t *TeamsNameInfoSource) EphemeralEncryptionKey(mctx libkb.MetaContext, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool) (teamEK keybase1.TeamEk, err error)

func (*TeamsNameInfoSource) LookupID 

func (t *TeamsNameInfoSource) LookupID(ctx context.Context, name string, public bool) (res types.NameInfo, err error)

func (*TeamsNameInfoSource) LookupName 

func (t *TeamsNameInfoSource) LookupName(ctx context.Context, tlfID chat1.TLFID, public bool) (res types.NameInfo, err error)

func (*TeamsNameInfoSource) ShouldPairwiseMAC 

func (t *TeamsNameInfoSource) ShouldPairwiseMAC(ctx context.Context, tlfName string, tlfID chat1.TLFID,
	membersType chat1.ConversationMembersType, public bool) (bool, []keybase1.KID, error)

type TransientUnboxingError added in v1.0.19 

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

func (TransientUnboxingError) Error added in v1.0.19 

func (e TransientUnboxingError) Error() string

func (TransientUnboxingError) ExportType added in v1.0.19 

func (e TransientUnboxingError) ExportType() chat1.MessageUnboxedErrorType

func (TransientUnboxingError) Inner added in v1.0.19 

func (e TransientUnboxingError) Inner() error

func (TransientUnboxingError) InternalError 

func (e TransientUnboxingError) InternalError() string

func (TransientUnboxingError) IsCritical 

func (e TransientUnboxingError) IsCritical() bool

func (TransientUnboxingError) IsPermanent added in v1.0.19 

func (e TransientUnboxingError) IsPermanent() bool

func (TransientUnboxingError) ToStatus 

func (e TransientUnboxingError) ToStatus() (status keybase1.Status)

func (TransientUnboxingError) VersionKind 

func (e TransientUnboxingError) VersionKind() chat1.VersionKind

func (TransientUnboxingError) VersionNumber 

func (e TransientUnboxingError) VersionNumber() int

type TypingMonitor added in v1.0.27 

type TypingMonitor struct {
	globals.Contextified
	sync.Mutex
	utils.DebugLabeler
	// contains filtered or unexported fields
}

func NewTypingMonitor added in v1.0.27 

func NewTypingMonitor(g *globals.Context) *TypingMonitor

func (*TypingMonitor) SetClock added in v1.0.27 

func (t *TypingMonitor) SetClock(clock clockwork.Clock)

func (*TypingMonitor) SetTimeout added in v1.0.27 

func (t *TypingMonitor) SetTimeout(timeout time.Duration)

func (*TypingMonitor) Update added in v1.0.27 

func (t *TypingMonitor) Update(ctx context.Context, typer chat1.TyperInfo, convID chat1.ConversationID,
	typing bool)

type UISource added in v1.0.22 

type UISource interface {
	GetChatUI(sessionID int) libkb.ChatUI
	GetStreamUICli() *keybase1.StreamUiClient
}

type UnknownTLFNameError 

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

func NewUnknownTLFNameError 

func NewUnknownTLFNameError(name string) UnknownTLFNameError

func (UnknownTLFNameError) Error 

func (e UnknownTLFNameError) Error() string

type VersionError added in v1.0.19 

type VersionError struct {
	Kind     string
	Version  int
	Critical bool
}

func NewBodyVersionError added in v1.0.19 

func NewBodyVersionError(version chat1.BodyPlaintextVersion, defaultBody chat1.BodyPlaintextUnsupported) VersionError

func NewHeaderVersionError added in v1.0.19 

func NewHeaderVersionError(version chat1.HeaderPlaintextVersion,
	defaultHeader chat1.HeaderPlaintextUnsupported) VersionError

func NewMessageBoxedVersionError added in v1.0.19 

func NewMessageBoxedVersionError(version chat1.MessageBoxedVersion) VersionError

func (VersionError) Error added in v1.0.19 

func (e VersionError) Error() string

func (VersionError) ExportType added in v1.0.19 

func (e VersionError) ExportType() chat1.MessageUnboxedErrorType

func (VersionError) IsCritical 

func (e VersionError) IsCritical() bool

func (VersionError) VersionKind 

func (e VersionError) VersionKind() chat1.VersionKind

func (VersionError) VersionNumber 

func (e VersionError) VersionNumber() int

Source Files

View all Source files

Directories

Path Synopsis
example
tools
slam
display
scraper

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.