client

package

Go to main page

Versions in this module

v0

v0.3.8

Aug 14, 2026

v0.3.7

Aug 13, 2026

Changes in this version

type Session

+ func (s *Session) ProcessPropagatedCommitment(pm *engine.ProtocolMessage) (*TrustEstablishment, error)

+ func (s *Session) ProcessPropagatedInvitation(pm *engine.ProtocolMessage) (*TrustEstablishment, string, error)

v0.3.6

Aug 13, 2026

v0.3.5

Aug 7, 2026

v0.3.4

Aug 7, 2026

v0.3.3

Aug 5, 2026

Changes in this version

type Option

+ func WithDeviceName(name string) Option

v0.3.2

Aug 5, 2026

Changes in this version

+ type DiscussionRead struct

+ GroupOwner []byte

+ GroupUID []byte

+ GroupV2Identifier []byte

+ OneToOneIdentifier *OneToOneIdentifier

+ Timestamp int64

+ type LimitedVisibilityOpened struct

+ GroupOwner []byte

+ GroupUID []byte

+ GroupV2Identifier []byte

+ OneToOneIdentifier *OneToOneIdentifier

+ Reference *MessageReference

type MessagePayload

+ DiscussionRead *DiscussionRead

+ LimitedVisibilityOpened *LimitedVisibilityOpened

type ReceivedMessageWithAttachments

+ FromOwnDevice bool

type Session

+ func (s *Session) EnsureOwnedDeviceChannels() error

+ func (s *Session) NotifyContactToRediscoverDevices(identity []byte)

+ func (s *Session) ReflectDiscussionRead(dr *DiscussionRead) (sent int, firstErr error)

+ func (s *Session) ReflectLimitedVisibilityOpened(lvo *LimitedVisibilityOpened) (sent int, firstErr error)

+ func (s *Session) ReflectToOwnDevices(appEnvelope []byte) (sent int, firstErr error)

+ func (s *Session) RegisterReflectedReturnReceipt(rr *ReturnReceipt) error

v0.3.1

Aug 4, 2026

v0.3.0

Aug 4, 2026

Changes in this version

+ type ContactMgmtEvent int

+ const ContactMgmtDeleted

+ const ContactMgmtDowngraded

+ const ContactMgmtNone

+ type Disposition int

+ const Consumed

+ const NotMine

+ const Rejected

+ const Retry

+ type IntroductionStore interface

+ DeleteIntroduction func(instanceUID []byte) error

+ LoadIntroductions func() ([][]byte, error)

+ SaveIntroduction func(instanceUID, encoded []byte) error

type Option

+ func WithIntroductionStore(is IntroductionStore) Option

+ type ProtocolHandler interface

+ Handle func(pm *engine.ProtocolMessage, rc ReceptionContext) Disposition

+ ProtocolID func() int

+ Reception func(messageID int) ReceptionReq

+ type ReceptionContext struct

+ OwnDevice bool

+ Sender *Contact

+ UID []byte

+ ViaChannel string

+ type ReceptionReq int

+ const RecvAny

+ const RecvAsymmetric

+ const RecvFromContact

+ const RecvFromOneToOneContact

+ const RecvFromOwnDevice

type Session

+ func (s *Session) AnnounceCapabilities(peer *engine.CryptoIdentity, deviceUID []byte, ownDevice, isResponse bool) error

+ func (s *Session) AnnounceCapabilitiesToAllChannels()

+ func (s *Session) CancelTrust(instance [32]byte) bool

+ func (s *Session) ContactCapabilities(identity []byte) []string

+ func (s *Session) DeleteContact(identity []byte) error

+ func (s *Session) DeviceCapabilities(deviceUID []byte) []string

+ func (s *Session) DowngradeContact(identity []byte) error

+ func (s *Session) NotifyContactsOfDeletion()

+ func (s *Session) NotifyContactsToRediscoverDevices()

+ func (s *Session) OnContactManagement(fn func(ContactMgmtEvent, []byte))

+ func (s *Session) OnOwnedIdentityDeleted(fn func([]byte))

+ func (s *Session) OnTrustEstablished(fn func(*Contact))

+ func (s *Session) OnTrustFailed(fn func(TrustInfo, string))

+ func (s *Session) OnTrustInbound(fn func(TrustInfo))

+ func (s *Session) OnTrustSASReady(fn func(TrustInfo))

+ func (s *Session) ProcessCapabilitiesMessage(pm *engine.ProtocolMessage, viaChannel string) error

+ func (s *Session) ProcessContactManagementMessage(pm *engine.ProtocolMessage, viaChannel string) (ContactMgmtEvent, []byte)

+ func (s *Session) ProcessOwnedIdentityDeleted(pm *engine.ProtocolMessage) ([]byte, bool)

+ func (s *Session) RegisterProtocolHandler(h ProtocolHandler)

+ func (s *Session) RenameOwnedDevice(deviceUID []byte, name string) error

+ func (s *Session) ReplayPendingIntroductions()

+ func (s *Session) StartTrust(link string) (TrustInfo, error)

+ func (s *Session) SubmitSAS(instance [32]byte, digits []byte) error

+ func (s *Session) TrustsAwaitingSAS() []TrustInfo

+ func (s *Session) TrustsInProgress() []TrustInfo

+ type TrustInfo struct

+ Awaiting bool

+ Confirming bool

+ Inbound bool

+ InstanceUID [32]byte

+ Peer *engine.CryptoIdentity

+ PeerDisplayName string

+ SAS string

v0.2.5

Aug 4, 2026

Changes in this version

+ func IsTrustEstablishmentSASMessage(pm *engine.ProtocolMessage) bool

type Session

+ func (s *Session) OwnedDeviceList() ([]server.OwnedDeviceInfo, *bool, error)

+ func (s *Session) ProcessGroupLeftBroadcast(msg *engine.ProtocolMessage) (*Group, error)

+ func (s *Session) QuerySubscription() (server.SubscriptionInfo, error)

+ func (s *Session) RemoveOwnedDevice(deviceUID []byte) error

type TrustEstablishment

+ func (te *TrustEstablishment) Cancelled() bool

+ func (te *TrustEstablishment) InstanceUID() [32]byte

+ func (te *TrustEstablishment) PeerDisplayName() string

+ func (te *TrustEstablishment) PeerIdentity() *engine.CryptoIdentity

+ func (te *TrustEstablishment) ReceiveParsed(pm *engine.ProtocolMessage) (awaitingSAS bool, err error)

v0.2.4

Aug 2, 2026

Changes in this version

type Option

+ func WithServerCertObserver(obs server.CertObserver) Option

v0.2.3

Aug 2, 2026

v0.2.2

Aug 2, 2026

v0.2.1

Aug 2, 2026

Changes in this version

type DeviceTransfer

+ func (dt *DeviceTransfer) KeepActiveDevice() []byte

type Session

+ func (s *Session) SetContext(ctx context.Context)

+ func (s *Session) SetDeviceNonExpiring(deviceUID []byte) error

+ func (s *Session) StartOwnedDeviceChannelCreation(otherDeviceUID []byte) error

v0.2.0

Aug 2, 2026

Changes in this version

type Session

+ func (s *Session) CreationInFlight(device []byte) bool

+ func (s *Session) MaintainChannelCreations() (retried, gaveUp [][]byte)

+ func (s *Session) OnChannelEstablished(fn func(deviceUID, identity []byte))

+ func (s *Session) RemoveChannel(contactDeviceUID []byte)

+ func (s *Session) StartChannelCreation(contact *engine.CryptoIdentity, contactDeviceUID []byte) error

v0.1.4

Aug 1, 2026

v0.1.3

Aug 1, 2026

v0.1.2

Aug 1, 2026

v0.1.1

Aug 1, 2026

Changes in this version

type Session

+ func (s *Session) OnUndecryptable(fn func())

v0.1.0

Aug 1, 2026

Changes in this version

+ const CallAnswer

+ const CallBusy

+ const CallHangedUp

+ const CallReconnect

+ const CallReject

+ const CallRinging

+ const CallStart

+ const LocationTypeEndSharing

+ const LocationTypeSend

+ const LocationTypeSharing

+ const MaxAttachmentBytes

+ const SDPTypeOffer

+ const SDPTypePranswer

+ const TrustDirect

+ const TrustGroup

+ const TrustIntroduction

+ const TrustKeycloak

+ const TrustServerGroupV2

+ var AttachmentChunkDataSize = 2 << 20

+ func DecodeApplicationMessage(plaintext []byte) (payloadJSON []byte, err error)

+ func DecodeApplicationMessageAttachments(plaintext []byte) (payloadJSON []byte, descriptors [][]byte, err error)

+ func EncodeApplicationMessage(payloadJSON []byte) []byte

+ func EncodeApplicationMessageWithAttachments(payloadJSON []byte, descriptors [][]byte) []byte

+ func EncodeApplicationPayload(p *MessagePayload) ([]byte, error)

+ func GunzipSDP(gzipped []byte) ([]byte, error)

+ func GzipSDP(sdp []byte) ([]byte, error)

+ func IsTrustEstablishmentRequest(pm *engine.ProtocolMessage) bool

+ func OpenInteropBackup(seed engine.BackupSeed, blob []byte) (*engine.BackupJSON, error)

+ func ParseInvitationLink(link string) (*engine.ObvURLIdentity, error)

+ func RestoreOwnedIdentityFromBackup(b *engine.BackupJSON) (*engine.OwnedCryptoIdentity, error)

+ func SerializeGroupName(name string) string

+ func SerializeGroupNameAndDescription(name, description string) string

+ func SerializeGroupType(t string) string

+ type AnswerCallMessage struct

+ GzippedSDP []byte

+ SessionDescriptionType string

+ type BackupOptions struct

+ APIKey string

+ Contacts []ContactBackupInput

+ GroupsV2 []*Group

+ LatestDetails engine.IdentityDetailsBackup

+ PublishedDetails engine.IdentityDetailsBackup

+ Snapshot *engine.Snapshot

+ TimestampMillis int64

+ type CallMessage struct

+ CallIdentifier string

+ MessageType int

+ Payload []byte

+ func (m *CallMessage) ParseAnswerCall() (*AnswerCallMessage, error)

+ func (m *CallMessage) ParseMuted() (*MutedMessage, error)

+ func (m *CallMessage) ParseReconnectCall() (*ReconnectCallMessage, error)

+ func (m *CallMessage) ParseStartCall() (*StartCallMessage, error)

+ type ChannelCreation struct

+ func (cc *ChannelCreation) Channel() *engine.ObliviousChannel

+ func (cc *ChannelCreation) Done() bool

+ func (cc *ChannelCreation) Pump() (done bool, err error)

+ type ChannelDeleter interface

+ DeleteChannel func(deviceUID []byte) error

+ type ChannelStore interface

+ SaveChannel func(contactDeviceUID, encoded []byte) error

+ type Contact struct

+ Capabilities []string

+ DetailsVersion int

+ DeviceUIDs [][]byte

+ DisplayName string

+ ForcefullyTrusted bool

+ Identity *engine.CryptoIdentity

+ OneToOne bool

+ PublishedDetails string

+ Revoked bool

+ TrustLevel string

+ TrustOrigins []TrustOrigin

+ TrustedDetails string

+ func DecodeContact(b []byte) (*Contact, error)

+ func (c *Contact) Encode() []byte

+ func (c *Contact) IdentityBytes() []byte

+ type ContactBackupInput struct

+ ForcefullyTrusted bool

+ Identity *engine.CryptoIdentity

+ OneToOne bool

+ PublishedDetails engine.IdentityDetailsBackup

+ Revoked bool

+ TrustLevel string

+ TrustOrigins []engine.ContactTrustOrigin

+ TrustedDetails engine.IdentityDetailsBackup

+ type ContactStore interface

+ DeleteContact func(identity []byte) error

+ LoadContactBlobs func() ([][]byte, error)

+ SaveContactBlob func(identity, encoded []byte) error

+ type DeleteDiscussion struct

+ GroupOwner []byte

+ GroupUID []byte

+ GroupV2Identifier []byte

+ OneToOneIdentifier *OneToOneIdentifier

+ type DeleteMessages struct

+ GroupOwner []byte

+ GroupUID []byte

+ GroupV2Identifier []byte

+ OneToOneIdentifier *OneToOneIdentifier

+ References []MessageReference

+ type DeviceTransfer struct

+ func JoinAsDevice(srv *server.Client, wsURL, sessionNumber, deviceName string, serverURL []byte, ...) (*DeviceTransfer, error)

+ func (dt *DeviceTransfer) Close() error

+ func (dt *DeviceTransfer) Restore(st RestoreStore, opts ...Option) (*Session, error)

+ func (dt *DeviceTransfer) SAS() string

+ type DeviceTransferSource struct

+ func OfferDeviceTransfer(srv *server.Client, wsURL string, owned *engine.OwnedCryptoIdentity, ...) (*DeviceTransferSource, error)

+ func (s *DeviceTransferSource) Await() (string, error)

+ func (s *DeviceTransferSource) Close() error

+ func (s *DeviceTransferSource) Confirm(deviceUIDToKeepActive []byte) error

+ func (s *DeviceTransferSource) SessionNumber() string

+ type EmptyCallMessage struct

+ type Group struct

+ AdminPublicKey *engine.PublicKeyOverEC

+ Blob *engine.ServerBlob

+ Identifier engine.GroupIdentifier

+ Keys *engine.BlobKeys

+ OwnNonce []byte

+ func (g *Group) Delete() error

+ func (g *Group) Description() string

+ func (g *Group) DiscardPreparedFor(member *engine.CryptoIdentity)

+ func (g *Group) IsConfirmed(identity *engine.CryptoIdentity) bool

+ func (g *Group) Leave() error

+ func (g *Group) MarkConfirmed(identity *engine.CryptoIdentity)

+ func (g *Group) MemberList() []*engine.GroupMember

+ func (g *Group) Members() []*engine.GroupMember

+ func (g *Group) Name() string

+ func (g *Group) PendingCountFor(member *engine.CryptoIdentity) int

+ type GroupInvitation struct

+ Group *Group

+ Inviter *engine.CryptoIdentity

+ func (inv *GroupInvitation) Accept() ([]OutgoingGroupPing, error)

+ func (inv *GroupInvitation) Decline() error

+ func (inv *GroupInvitation) Description() string

+ func (inv *GroupInvitation) Name() string

+ func (inv *GroupInvitation) TrustedInviter() bool

+ type GroupMemberSpec struct

+ Details string

+ Identity *engine.CryptoIdentity

+ Permissions []string

+ type GroupPingResult struct

+ Response *OutgoingGroupPing

+ Sender *engine.CryptoIdentity

+ type GroupSendResult struct

+ OriginalServerTimestamp int64

+ Pending []*engine.CryptoIdentity

+ SentTo []*engine.CryptoIdentity

+ type GroupStore interface

+ DeleteGroup func(groupUID []byte) error

+ LoadGroupBlobs func() ([][]byte, error)

+ SaveGroupBlob func(groupUID, encoded []byte) error

+ type GroupUpdateResult struct

+ Group *Group

+ Kicks []OutgoingGroupMessage

+ Notifications []OutgoingGroupMessage

+ type IncomingGroupMessage struct

+ Msg *engine.ProtocolMessage

+ ViaChannel string

+ type IntroductionInvitation struct

+ Contact *engine.CryptoIdentity

+ Details string

+ InstanceUID [32]byte

+ Mediator *engine.CryptoIdentity

+ type KeycloakGroup struct

+ Blob *KeycloakGroupBlob

+ Identifier engine.GroupIdentifier

+ Timestamp int64

+ func (g *KeycloakGroup) IsMember(identity []byte) bool

+ type KeycloakGroupBlob struct

+ GroupDetails json.RawMessage

+ GroupUID []byte

+ Members []KeycloakGroupMember

+ PhotoKey []byte

+ PhotoLabel []byte

+ PushTopic string

+ SerializedSharedSettings string

+ Timestamp int64

+ func VerifyKeycloakGroupBlob(signedJWT string, key *engine.JSONWebKey) (*KeycloakGroupBlob, error)

+ type KeycloakGroupDeletion struct

+ GroupUID []byte

+ Timestamp int64

+ type KeycloakGroupKick struct

+ GroupUID []byte

+ Identity []byte

+ Timestamp int64

+ type KeycloakGroupManager struct

+ Groups map[string]*KeycloakGroup

+ Key *engine.JSONWebKey

+ OwnedIdentity []byte

+ ServerURL string

+ func NewKeycloakGroupManager(serverURL string, ownedIdentity []byte, key *engine.JSONWebKey) *KeycloakGroupManager

+ func (m *KeycloakGroupManager) ApplySignedBlob(signedJWT string) (*KeycloakGroup, error)

+ func (m *KeycloakGroupManager) ApplySignedDeletion(signedJWT string) (bool, error)

+ func (m *KeycloakGroupManager) ApplySignedKick(signedJWT string) (bool, error)

+ func (m *KeycloakGroupManager) Update(signedBlobs, signedDeletions, signedKicks []string) error

+ type KeycloakGroupMember struct

+ GroupInvitationNonce []byte

+ Identity []byte

+ KeycloakUserID string

+ Permissions []string

+ SignedUserDetails string

+ type LocationInfo struct

+ Address string

+ Altitude *float64

+ Count *int64

+ Latitude *float64

+ Longitude *float64

+ Precision *float64

+ Quality *int

+ SharingExpiration *int64

+ Timestamp int64

+ Type int

+ type MessageContent struct

+ Body string

+ Expiration *MessageExpiration

+ Forwarded *bool

+ GroupOwner []byte

+ GroupUID []byte

+ GroupV2Identifier []byte

+ Location *LocationInfo

+ Mentions []UserMention

+ OneToOneIdentifier *OneToOneIdentifier

+ OriginalServerTimestamp *int64

+ Reply *MessageReference

+ SenderSequenceNumber int64

+ SenderThreadIdentifier string

+ type MessageExpiration struct

+ ExistenceDuration *int64

+ ReadOnce *bool

+ VisibilityDuration *int64

+ type MessagePayload struct

+ DeleteDiscussion *DeleteDiscussion

+ DeleteMessages *DeleteMessages

+ Message *MessageContent

+ QuerySharedSettings *QuerySharedSettings

+ Reaction *Reaction

+ ReturnReceipt *ReturnReceipt

+ ScreenCapture *ScreenCaptureDetection

+ Settings *SharedSettings

+ UpdateMessage *UpdateMessage

+ WebRTC *WebRTCMessage

+ func DecodeApplicationPayload(plaintext []byte) (*MessagePayload, error)

+ func NewTextMessage(body string) *MessagePayload

+ func ParseMessagePayload(b []byte) (*MessagePayload, error)

+ func (p *MessagePayload) Marshal() ([]byte, error)

+ type MessageReference struct

+ SenderIdentifier []byte

+ SenderSequenceNumber int64

+ SenderThreadIdentifier string

+ type MutedMessage struct

+ Muted bool

+ type OneToOneIdentifier struct

+ IdentityA []byte

+ IdentityB []byte

+ func (o *OneToOneIdentifier) UnmarshalJSON(b []byte) error

+ func (o OneToOneIdentifier) MarshalJSON() ([]byte, error)

+ type Option func(*Session)

+ func WithContactStore(cs ContactStore) Option

+ func WithContext(ctx context.Context) Option

+ func WithDisplayName(name string) Option

+ func WithGroupStore(gs GroupStore) Option

+ func WithLogger(l *slog.Logger) Option

+ func WithPushRegistration(reg server.PushRegistration) Option

+ func WithServerClient(c *server.Client) Option

+ func WithServerUserAgent(ua string) Option

+ type OutgoingAttachment struct

+ Content []byte

+ FileName string

+ MIMEType string

+ type OutgoingGroupMessage struct

+ Message *engine.ProtocolMessage

+ Recipient *engine.CryptoIdentity

+ type OutgoingGroupPing struct

+ Message *engine.ProtocolMessage

+ Recipient *engine.CryptoIdentity

+ type OwnDeviceMarker interface

+ MarkOwnDeviceChannel func(deviceUID []byte) error

+ type QuerySharedSettings struct

+ Expiration *MessageExpiration

+ GroupOwner []byte

+ GroupUID []byte

+ GroupV2Identifier []byte

+ KnownSettingsVersion *int

+ OneToOneIdentifier *OneToOneIdentifier

+ type Reaction struct

+ GroupOwner []byte

+ GroupUID []byte

+ GroupV2Identifier []byte

+ OneToOneIdentifier *OneToOneIdentifier

+ OriginalServerTimestamp *int64

+ Reaction string

+ Reference *MessageReference

+ type ReceiptInfo struct

+ ReaderIdentity []byte

+ Status int64

+ type ReceivedAttachment struct

+ Content []byte

+ Metadata *engine.AttachmentMetadata

+ type ReceivedMessage struct

+ Payload []byte

+ Sender *Contact

+ ServerUID []byte

+ Timestamp int64

+ ViaChannel string

+ type ReceivedMessageWithAttachments struct

+ Descriptors [][]byte

+ HasExtended bool

+ Header []byte

+ PayloadJSON []byte

+ Plaintext []byte

+ Sender *Contact

+ ServerAttachments []*server.AttachmentDownloadInfo

+ ServerUID []byte

+ Timestamp int64

+ ViaChannel string

+ type ReconnectCallMessage struct

+ GzippedSDP []byte

+ SessionDescriptionType string

+ type RestoreStore interface

+ SaveOwnedIdentity func(owned *engine.OwnedCryptoIdentity, deviceUID []byte) error

+ type RestoredBackup struct

+ Format engine.BackupFormat

+ Interop *engine.BackupJSON

+ Snapshot *engine.Snapshot

+ type ReturnReceipt struct

+ Key []byte

+ Nonce []byte

+ type ScreenCaptureDetection struct

+ GroupOwner []byte

+ GroupUID []byte

+ GroupV2Identifier []byte

+ OneToOneIdentifier *OneToOneIdentifier

+ type Session struct

+ ChannelStore ChannelStore

+ DeviceUID []byte

+ EnableFullRatchet bool

+ Now func() int64

+ Owned *engine.OwnedCryptoIdentity

+ Rnd prng.PRNG

+ Server *server.Client

+ func New(owned *engine.OwnedCryptoIdentity, deviceUID []byte, rnd prng.PRNG, ...) *Session

+ func NewWithContext(owned *engine.OwnedCryptoIdentity, deviceUID []byte, rnd prng.PRNG, ...) *Session

+ func Open(st SessionStore, rnd prng.PRNG, opts ...Option) (*Session, error)

+ func RestoreFromSnapshot(st RestoreStore, snapshot []byte, rnd prng.PRNG, opts ...Option) (*Session, error)

+ func (s *Session) AcceptIntroduction(inv *IntroductionInvitation) error

+ func (s *Session) AddChannel(contactDeviceUID []byte, ch *engine.ObliviousChannel)

+ func (s *Session) AddContact(c *Contact) error

+ func (s *Session) AddContactChannel(contact *Contact, deviceUID []byte, ch *engine.ObliviousChannel) error

+ func (s *Session) AddContactViaLink(link string) (*TrustEstablishment, *engine.ObvURLIdentity, error)

+ func (s *Session) AddGroup(g *Group) error

+ func (s *Session) AddGroupMember(g *Group, contact *Contact) (*GroupUpdateResult, error)

+ func (s *Session) AddOwnDeviceChannel(ownDeviceUID []byte, ch *engine.ObliviousChannel)

+ func (s *Session) ApplyInteropBackup(b *engine.BackupJSON) error

+ func (s *Session) Authenticate() error

+ func (s *Session) BeginChannelCreation(contact *engine.CryptoIdentity, contactDeviceUID []byte, instanceUID [32]byte) (*ChannelCreation, error)

+ func (s *Session) BeginOwnedDeviceChannelCreation(otherDeviceUID []byte, instanceUID [32]byte) (*ChannelCreation, error)

+ func (s *Session) BeginTrustEstablishment(contact *engine.CryptoIdentity, contactDeviceUID []byte, instanceUID [32]byte, ...) (*TrustEstablishment, error)

+ func (s *Session) BroadcastSyncAtom(atom *engine.SyncAtom) (sent int, err error)

+ func (s *Session) Channel(contactDeviceUID []byte) *engine.ObliviousChannel

+ func (s *Session) ChannelDeviceForContact(identity []byte) []byte

+ func (s *Session) Contact(identity *engine.CryptoIdentity) *Contact

+ func (s *Session) ContactBackupInputs() []ContactBackupInput

+ func (s *Session) ContactByBytes(identity []byte) *Contact

+ func (s *Session) ContactByDeviceUID(deviceUID []byte) *Contact

+ func (s *Session) ContactSnapshot(identity []byte) *Contact

+ func (s *Session) Contacts() []*Contact

+ func (s *Session) CreateBackup(seed engine.BackupSeed, format engine.BackupFormat, opts BackupOptions) ([]byte, error)

+ func (s *Session) CreateGroup(others []GroupMemberSpec, groupDetails, groupType string) (*Group, error)

+ func (s *Session) CreateInteropBackupFromState(seed engine.BackupSeed, published, latest engine.IdentityDetailsBackup, ...) ([]byte, error)

+ func (s *Session) DeactivateThisDevice() error

+ func (s *Session) DeleteMessages(serverUIDs [][]byte) error

+ func (s *Session) DeliverGroupInvitation(g *Group, member *engine.CryptoIdentity) (viaChannel bool, err error)

+ func (s *Session) DeliverGroupOutgoing(msgs []OutgoingGroupMessage) (sent, pending int, err error)

+ func (s *Session) DeliverGroupPings(pings []OutgoingGroupPing) (sent int, err error)

+ func (s *Session) DiscoverContactDevices(c *Contact) ([][]byte, error)

+ func (s *Session) DiscoverDevices(identity *engine.CryptoIdentity) ([][]byte, error)

+ func (s *Session) DisplayName() string

+ func (s *Session) DownloadAttachmentTo(info *server.AttachmentDownloadInfo, key *engine.AuthEncKey, w io.Writer) error

+ func (s *Session) DownloadAttachments(descriptors [][]byte, serverInfos []*server.AttachmentDownloadInfo) ([]ReceivedAttachment, error)

+ func (s *Session) DownloadExtendedPayload(messageUID, header []byte) ([]byte, error)

+ func (s *Session) FetchGroup(gid engine.GroupIdentifier, keys *engine.BlobKeys) (*Group, error)

+ func (s *Session) GetTurnCredentials(username1, username2 string) (*server.TurnCredentials, error)

+ func (s *Session) Group(gid engine.GroupIdentifier) *Group

+ func (s *Session) GroupByGID2(gid2 []byte) *Group

+ func (s *Session) Groups() []*Group

+ func (s *Session) HasChannel(contactDeviceUID []byte) bool

+ func (s *Session) HasChannelToContact(c *Contact) bool

+ func (s *Session) IntroduceContacts(a, b *Contact) error

+ func (s *Session) InvitationLink(displayName string) string

+ func (s *Session) InviteAllMembers(g *Group) (sent, pending int, err error)

+ func (s *Session) InviteToGroup(g *Group, member *engine.CryptoIdentity, memberDeviceUID []byte) error

+ func (s *Session) OnApplicationMessage(fn func(*ReceivedMessageWithAttachments))

+ func (s *Session) OnCallMessage(fn func(*CallMessage))

+ func (s *Session) OnContactDetailsUpdated(fn func(*Contact))

+ func (s *Session) OnGroupProtocolMessage(fn func(pm *engine.ProtocolMessage, viaChannel string))

+ func (s *Session) OnIntroductionCompleted(fn func(*Contact))

+ func (s *Session) OnIntroductionInvitation(fn func(*IntroductionInvitation))

+ func (s *Session) OnProtocolMessage(fn func(pm *engine.ProtocolMessage, viaChannel string))

+ func (s *Session) OnSyncAtom(fn func(a *engine.SyncAtom, viaChannel string))

+ func (s *Session) OnSyncSnapshot(fn func(snap *engine.Snapshot, viaChannel string))

+ func (s *Session) OneToOneID(c *Contact) *OneToOneIdentifier

+ func (s *Session) PollGroupProtocolMessages() ([]IncomingGroupMessage, error)

+ func (s *Session) ProcessGroupInvitation(msg *engine.ProtocolMessage, inviter *engine.CryptoIdentity) (*GroupInvitation, error)

+ func (s *Session) ProcessGroupKick(msg *engine.ProtocolMessage, g *Group) (kicked bool, kicker *engine.CryptoIdentity, err error)

+ func (s *Session) ProcessGroupMembersUpdate(msg *engine.ProtocolMessage) (*Group, error)

+ func (s *Session) ProcessGroupPing(msg *engine.ProtocolMessage, g *Group) (*GroupPingResult, error)

+ func (s *Session) ProcessReturnReceipt(nonce, encryptedPayload []byte) (info *ReceiptInfo, ok bool, err error)

+ func (s *Session) ProcessTrustEstablishment(pm *engine.ProtocolMessage) (*TrustEstablishment, error)

+ func (s *Session) PublishIdentityDetails(details engine.SerializedIdentityDetails, version int) (int, error)

+ func (s *Session) Receive() error

+ func (s *Session) ReceiveMessages(delete bool) ([]ReceivedMessage, error)

+ func (s *Session) ReceiveMessagesWithAttachments() ([]ReceivedMessageWithAttachments, error)

+ func (s *Session) Register() error

+ func (s *Session) RegisterSnapshotNode(tag string, decoder func([]byte) (engine.SnapshotNode, error))

+ func (s *Session) RejectIntroduction(inv *IntroductionInvitation)

+ func (s *Session) RemoveContact(identity []byte) error

+ func (s *Session) RemoveGroup(gid engine.GroupIdentifier) error

+ func (s *Session) RemoveGroupMember(g *Group, identity []byte) (*GroupUpdateResult, error)

+ func (s *Session) RequestReturnReceipt() (*ReturnReceipt, error)

+ func (s *Session) ResendPreparedTo(g *Group, member *engine.CryptoIdentity, contactDeviceUID []byte) (int, error)

+ func (s *Session) Restore() error

+ func (s *Session) RestoreBackup(seed engine.BackupSeed, blob []byte) (*RestoredBackup, error)

+ func (s *Session) ResyncAfterRestore() error

+ func (s *Session) RunReturnReceiptListener(ctx context.Context, onReceipt func(nonce []byte, info *ReceiptInfo))

+ func (s *Session) SaveGroup(g *Group) error

+ func (s *Session) SendApplicationToContact(c *Contact, encodedPayload []byte) (int, error)

+ func (s *Session) SendAttachmentsToContact(c *Contact, payloadJSON []byte, attachments []OutgoingAttachment) (int, error)

+ func (s *Session) SendAttachmentsToGroup(g *Group, payloadJSON []byte, attachments []OutgoingAttachment) (*GroupSendResult, error)

+ func (s *Session) SendCallMessage(recipient *engine.CryptoIdentity, deviceUIDs [][]byte, callID string, ...) (*server.UploadResult, error)

+ func (s *Session) SendCallMessageToContact(c *Contact, callID string, messageType int, smp any) (*server.UploadResult, error)

+ func (s *Session) SendMessage(recipient *engine.CryptoIdentity, deviceUIDs [][]byte, encodedPayload []byte) (*server.UploadResult, error)

+ func (s *Session) SendMessageToContact(c *Contact, encodedPayload []byte) (*server.UploadResult, error)

+ func (s *Session) SendMessageWithAttachmentStream(recipient *engine.CryptoIdentity, deviceUIDs [][]byte, payloadJSON []byte, ...) (*server.UploadResult, error)

+ func (s *Session) SendMessageWithAttachments(recipient *engine.CryptoIdentity, deviceUIDs [][]byte, payloadJSON []byte, ...) (*server.UploadResult, error)

+ func (s *Session) SendMessageWithAttachmentsExt(recipient *engine.CryptoIdentity, deviceUIDs [][]byte, payloadJSON []byte, ...) (*server.UploadResult, error)

+ func (s *Session) SendMessageWithAttachmentsToContact(c *Contact, payloadJSON []byte, attachments []OutgoingAttachment) (*server.UploadResult, error)

+ func (s *Session) SendOnChannel(recipient *engine.CryptoIdentity, contactDeviceUID, encodedPayload []byte) (*server.UploadResult, error)

+ func (s *Session) SendReturnReceipt(sender *engine.CryptoIdentity, rr *ReturnReceipt, status int64) error

+ func (s *Session) SendSnapshot(ownDeviceUID []byte, snapshot *engine.Snapshot) error

+ func (s *Session) SendToGroup(g *Group, payloadJSON []byte, deviceUIDs map[string][]byte) (*GroupSendResult, error)

+ func (s *Session) SendToGroupAuto(g *Group, payloadJSON []byte) (*GroupSendResult, error)

+ func (s *Session) SetDisplayName(name string)

+ func (s *Session) StreamAttachments(descriptors [][]byte, serverInfos []*server.AttachmentDownloadInfo, ...) error

+ func (s *Session) UpdateGroup(g *Group, newMembers []GroupMemberSpec) (*GroupUpdateResult, error)

+ func (s *Session) UpdateGroupDetails(g *Group, groupDetails string) (*GroupUpdateResult, error)

+ type SessionStore interface

+ LoadChannelsInto func(add func(deviceUID, encoded []byte, ownDevice bool)) error

+ LoadOwnedIdentity func() (*engine.OwnedCryptoIdentity, []byte, error)

+ type SharedSettings struct

+ Expiration *MessageExpiration

+ GroupOwner []byte

+ GroupUID []byte

+ GroupV2Identifier []byte

+ OneToOneIdentifier *OneToOneIdentifier

+ Version int

+ type StartCallMessage struct

+ GzippedSDP []byte

+ SessionDescriptionType string

+ TurnPassword string

+ TurnUsername string

+ type StatusError struct

+ Op string

+ Status server.Status

+ func (e *StatusError) Error() string

+ func (e *StatusError) Is(target error) bool

+ type StreamingAttachment struct

+ FileName string

+ MIMEType string

+ Reader io.ReadSeeker

+ type TrustEstablishment struct

+ func (te *TrustEstablishment) CheckSAS(peerDigits []byte) bool

+ func (te *TrustEstablishment) Confirmed() bool

+ func (te *TrustEstablishment) EstablishChannel() (*ChannelCreation, error)

+ func (te *TrustEstablishment) PeerDeviceUIDs() [][]byte

+ func (te *TrustEstablishment) Pump() (awaitingSAS bool, err error)

+ func (te *TrustEstablishment) ResultContact() *Contact

+ func (te *TrustEstablishment) SAS() []byte

+ type TrustOrigin struct

+ GroupUID []byte

+ Keycloak string

+ Mediator []byte

+ Type int

+ type UpdateMessage struct

+ Body string

+ GroupOwner []byte

+ GroupUID []byte

+ GroupV2Identifier []byte

+ Location *LocationInfo

+ Mentions []UserMention

+ OneToOneIdentifier *OneToOneIdentifier

+ Reference *MessageReference

+ type UserMention struct

+ RangeEnd int

+ RangeStart int

+ UserIdentity []byte

+ type WebRTCMessage struct

+ CallIdentifier string

+ MessageType int

+ SerializedPayload string

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