bridgev2

package

Versions in this module

v0

v0.21.1

Oct 16, 2024

Changes in this version

+ var ErrIgnoringPollFromRelayedUser error = WrapErrorInStatus(errors.New("ignoring poll event from relayed user")).WithIsCertain(true).WithSendNotice(false)

+ var ErrPollsNotSupported error = WrapErrorInStatus(errors.New("this bridge does not support polls")).WithIsCertain(true).WithErrorAsMessage()

+ func DisappearingMessageNotice(expiration time.Duration, implicit bool) *event.MessageEventContent

type FetchMessagesResponse

+ CompleteCallback func()

+ type MatrixConnectorWithURLPreviews interface

+ GetURLPreview func(ctx context.Context, url string) (*event.LinkPreview, error)

type MatrixMessageResponse

+ PostSave func(context.Context, *database.Message)

+ StreamOrder int64

+ type MatrixPollStart struct

+ Content *event.PollStartEventContent

+ type MatrixPollVote struct

+ Content *event.PollResponseEventContent

+ VoteTo *database.Message

type MessageStatusEventInfo

+ NewEventID id.EventID

+ SourceEventID id.EventID

+ StreamOrder int64

type NetworkRoomCapabilities

+ Polls bool

+ type PollHandlingNetworkAPI interface

+ HandleMatrixPollStart func(ctx context.Context, msg *MatrixPollStart) (*MatrixMessageResponse, error)

+ HandleMatrixPollVote func(ctx context.Context, msg *MatrixPollVote) (*MatrixMessageResponse, error)

+ type RemoteDeleteOnlyForMe interface

+ DeleteOnlyForMe func() bool

+ type RemotePostHandler interface

+ PostHandle func(ctx context.Context, portal *Portal)

+ type StoppableNetwork interface

+ Stop func()

type UserLogin

+ func (ul *UserLogin) QueueRemoteEvent(evt RemoteEvent)

+ func (ul *UserLogin) TrackAnalytics(event string, props map[string]any)

v0.21.0

Sep 16, 2024

Changes in this version

+ var ErrUnsupportedMediaType error = WrapErrorInStatus(errors.New("unsupported media type")).WithErrorAsMessage().WithIsCertain(true).WithSendNotice(true)

type BackfillMessage

+ func (b *BackfillMessage) AddLogContext(c zerolog.Context) zerolog.Context

+ func (b *BackfillMessage) ConvertMessage(ctx context.Context, portal *Portal, intent MatrixAPI) (*ConvertedMessage, error)

+ func (b *BackfillMessage) GetID() networkid.MessageID

+ func (b *BackfillMessage) GetPortalKey() networkid.PortalKey

+ func (b *BackfillMessage) GetSender() EventSender

+ func (b *BackfillMessage) GetTimestamp() time.Time

+ func (b *BackfillMessage) GetTransactionID() networkid.TransactionID

+ func (b *BackfillMessage) GetType() RemoteEventType

type Bridge

+ func (br *Bridge) MigrateToSplitPortals(ctx context.Context) bool

+ func (br *Bridge) ResendBridgeInfo(ctx context.Context)

+ func (br *Bridge) TrackAnalytics(userID id.UserID, event string, props map[string]any)

+ type CallbackError struct

+ Type string

+ Wrapped error

+ func (ce CallbackError) Error() string

+ func (ce CallbackError) Unwrap() error

type ChatMemberList

+ MemberMap map[networkid.UserID]ChatMember

type FetchMessagesResponse

+ AggressiveDeduplication bool

+ type FileStreamCallback func(file io.Writer) (*FileStreamResult, error)

+ type FileStreamResult struct

+ FileName string

+ MimeType string

+ ReplacementFile string

type MatrixAPI

+ DownloadMediaToFile func(ctx context.Context, uri id.ContentURIString, file *event.EncryptedFileInfo, ...) error

+ UploadMediaStream func(ctx context.Context, roomID id.RoomID, size int64, requireFile bool, ...) (url id.ContentURIString, file *event.EncryptedFileInfo, err error)

+ type MatrixConnectorWithAnalytics interface

+ TrackAnalytics func(userID id.UserID, event string, properties map[string]any)

type MatrixMessage

+ func (evt *MatrixMessage) AddPendingToIgnore(txnID networkid.TransactionID)

+ func (evt *MatrixMessage) AddPendingToSave(message *database.Message, txnID networkid.TransactionID, ...)

+ func (evt *MatrixMessage) RemovePending(txnID networkid.TransactionID)

type MatrixMessageResponse

+ RemovePending networkid.TransactionID

type PortalInternals

+ func (portal *PortalInternals) CutoffMessages(ctx context.Context, messages []*BackfillMessage, ...) []*BackfillMessage

+ func (portal *PortalInternals) GetEventCtxWithLog(rawEvt any, idx int) context.Context

+ func (portal *PortalInternals) HandleSingleEvent(ctx context.Context, rawEvt any, doneCallback func())

+ func (portal *PortalInternals) HandleSingleEventAsync(idx int, rawEvt any)

+ type RemoteEchoHandler func(RemoteMessage, *database.Message) (bool, error)

type RespError

+ func (re RespError) WithMessage(msg string, args ...any) RespError

+ func (re RespError) Write(w http.ResponseWriter)

type User

+ func (user *User) GetUserLogins() []*UserLogin

+ func (user *User) TrackAnalytics(event string, props map[string]any)

v0.20.0

Aug 16, 2024

Changes in this version

+ const BackfillMinBackoffAfterRoomCreate

+ const BackfillQueueErrorBackoff

+ const BackfillQueueMaxEmptyBackoff

+ var AcceptInvite = MembershipChangeType

+ var AcceptKnock = MembershipChangeType

+ var BanInvited = MembershipChangeType

+ var BanJoined = MembershipChangeType

+ var BanKnocked = MembershipChangeType

+ var BanLeft = MembershipChangeType

+ var ErrIgnoringRemoteEvent = errors.New("ignoring remote event")

+ var ErrMediaConvertFailed error = WrapErrorInStatus(errors.New("failed to convert media")).WithMessage("failed to convert media").WithIsCertain(true).WithSendNotice(true)

+ var ErrMediaDownloadFailed error = WrapErrorInStatus(errors.New("failed to download media")).WithMessage("failed to download media").WithIsCertain(true).WithSendNotice(true)

+ var ErrMediaReuploadFailed error = WrapErrorInStatus(errors.New("failed to reupload media")).WithMessage("failed to reupload media").WithIsCertain(true).WithSendNotice(true)

+ var ErrMembershipNotSupported error = WrapErrorInStatus(errors.New("this bridge does not support changing group membership")).WithIsCertain(true).WithErrorAsMessage().WithSendNotice(false)

+ var ErrNoStatus = errors.New("omit message status")

+ var ErrPowerLevelsNotSupported error = WrapErrorInStatus(errors.New("this bridge does not support changing group power levels")).WithIsCertain(true).WithErrorAsMessage().WithSendNotice(false)

+ var ErrResolveIdentifierTryNext = errors.New("that identifier is not available via this login")

+ var ErrUnsupportedMessageType error = WrapErrorInStatus(errors.New("unsupported message type")).WithErrorAsMessage().WithIsCertain(true).WithSendNotice(true)

+ var Invite = MembershipChangeType

+ var Join = MembershipChangeType

+ var Kick = MembershipChangeType

+ var Knock = MembershipChangeType

+ var Leave = MembershipChangeType

+ var ProfileChange = MembershipChangeType

+ var RejectInvite = MembershipChangeType

+ var RejectKnock = MembershipChangeType

+ var RetractKnock = MembershipChangeType

+ var RevokeInvite = MembershipChangeType

+ var Unban = MembershipChangeType

+ func CleanNonInternationalPhoneNumber(phone string) (string, error)

+ func DeleteManyPortals(ctx context.Context, portals []*Portal, ...)

type BackfillMessage

+ LastThreadMessage networkid.MessageID

+ ShouldBackfillThread bool

+ StreamOrder int64

+ TxnID networkid.TransactionID

+ type BackfillingNetworkAPIWithLimits interface

+ GetBackfillMaxBatchCount func(ctx context.Context, portal *Portal, task *database.BackfillTask) int

type Bridge

+ func (br *Bridge) GetAllPortals(ctx context.Context) ([]*Portal, error)

+ func (br *Bridge) GetDMPortalsWith(ctx context.Context, otherUserID networkid.UserID) ([]*Portal, error)

+ func (br *Bridge) GetExistingGhostByID(ctx context.Context, id networkid.UserID) (*Ghost, error)

+ func (br *Bridge) IsGhostMXID(userID id.UserID) bool

+ func (br *Bridge) RunBackfillQueue()

+ func (br *Bridge) StartConnectors() error

+ func (br *Bridge) StartLogins() error

+ func (br *Bridge) WakeupBackfillQueue()

type BridgeStateQueue

+ func (bsq *BridgeStateQueue) GetPrevUnsent() status.BridgeState

type ChatInfo

+ CanBackfill bool

type ChatMember

+ UserInfo *UserInfo

type ChatMemberList

+ OtherUserID networkid.UserID

type ConvertedEdit

+ AddedParts *ConvertedMessage

type ConvertedEditPart

+ DontBridge bool

+ NewMentions *event.Mentions

type ConvertedMessagePart

+ DontBridge bool

+ type DeleteOpts struct

+ DontCleanupRooms bool

+ LogoutRemote bool

type EventSender

+ ForceDMUser bool

+ type ExtraUpdater func(context.Context, T) bool

+ func MergeExtraUpdaters[T any](funcs ...ExtraUpdater[T]) ExtraUpdater[T]

type FetchMessagesParams

+ BundledData any

+ Task *database.BackfillTask

+ type GhostOrUserLogin interface

+ type IdentifierValidatingNetwork interface

+ ValidateUserID func(id networkid.UserID) bool

+ type LoginCookieField struct

+ ID string

+ Pattern string

+ Required bool

+ Sources []LoginCookieFieldSource

+ type LoginCookieFieldSource struct

+ CookieDomain string

+ Name string

+ RequestURLRegex string

+ Type LoginCookieFieldSourceType

+ type LoginCookieFieldSourceType string

+ const LoginCookieTypeCookie

+ const LoginCookieTypeLocalStorage

+ const LoginCookieTypeRequestBody

+ const LoginCookieTypeRequestHeader

+ const LoginCookieTypeSpecial

type LoginCookiesParams

+ ExtractJS string

+ Fields []LoginCookieField

type LoginInputFieldType

+ const LoginInputFieldTypeToken

+ type MarkAsDMMatrixAPI interface

+ MarkAsDM func(ctx context.Context, roomID id.RoomID, otherUser id.UserID) error

+ type MarkedUnreadHandlingNetworkAPI interface

+ HandleMarkedUnread func(ctx context.Context, msg *MatrixMarkedUnread) error

type MatrixConnector

+ GenerateReactionEventID func(roomID id.RoomID, targetMessage *database.Message, sender networkid.UserID, ...) id.EventID

+ type MatrixConnectorWithNameDisambiguation interface

+ IsConfusableName func(ctx context.Context, roomID id.RoomID, userID id.UserID, name string) ([]id.UserID, error)

+ type MatrixConnectorWithPostRoomBridgeHandling interface

+ HandleNewlyBridgedRoom func(ctx context.Context, roomID id.RoomID) error

+ type MatrixConnectorWithPublicMedia interface

+ GetPublicMediaAddress func(contentURI id.ContentURIString) string

+ type MatrixMarkedUnread = MatrixRoomMeta[*event.MarkedUnreadEventContent]

+ type MatrixMembershipChange struct

+ Target GhostOrUserLogin

+ TargetGhost *Ghost

+ TargetUserLogin *UserLogin

+ Type MembershipChangeType

type MatrixMessageResponse

+ HandleEcho func(RemoteMessage, *database.Message) (bool, error)

+ Pending networkid.TransactionID

+ type MatrixMute = MatrixRoomMeta[*event.BeeperMuteEventContent]

+ type MatrixPowerLevelChange struct

+ Ban *SinglePowerLevelChange

+ Events map[string]*SinglePowerLevelChange

+ EventsDefault *SinglePowerLevelChange

+ Invite *SinglePowerLevelChange

+ Kick *SinglePowerLevelChange

+ Redact *SinglePowerLevelChange

+ StateDefault *SinglePowerLevelChange

+ Users map[id.UserID]*UserPowerLevelChange

+ UsersDefault *SinglePowerLevelChange

type MatrixReaction

+ ReactionToOverride *database.Reaction

+ type MatrixRoomTag = MatrixRoomMeta[*event.TagEventContent]

+ type MatrixSendExtra struct

+ MessageMeta *database.Message

+ PartIndex int

+ ReactionMeta *database.Reaction

+ StreamOrder int64

+ Timestamp time.Time

+ type MembershipChangeType struct

+ From event.Membership

+ IsSelf bool

+ To event.Membership

+ type MembershipHandlingNetworkAPI interface

+ HandleMatrixMembership func(ctx context.Context, msg *MatrixMembershipChange) (bool, error)

+ type MuteHandlingNetworkAPI interface

+ HandleMute func(ctx context.Context, msg *MatrixMute) error

type OrigSender

+ DisambiguatedName string

+ FormattedName string

+ RequiresDisambiguation bool

+ UserID id.UserID

type Portal

+ func (portal *Portal) Internal() *PortalInternals

+ func (portal *Portal) RemoveMXID(ctx context.Context) error

+ func (portal *Portal) UpdateInfoFromGhost(ctx context.Context, ghost *Ghost) (changed bool)

+ type PortalBridgeInfoFillingNetwork interface

+ FillPortalBridgeInfo func(portal *Portal, content *event.BridgeEventContent)

+ type PortalInternals Portal

+ func (portal *PortalInternals) AddToParentSpaceAndSave(ctx context.Context, save bool)

+ func (portal *PortalInternals) ApplyRelationMeta(content *event.MessageEventContent, ...)

+ func (portal *PortalInternals) CheckConfusableName(ctx context.Context, userID id.UserID, name string) bool

+ func (portal *PortalInternals) CheckMessageContentCaps(ctx context.Context, caps *NetworkRoomCapabilities, ...) bool

+ func (portal *PortalInternals) CheckPendingMessage(ctx context.Context, evt RemoteMessage) (bool, *database.Message)

+ func (portal *PortalInternals) CompileBatchMessage(ctx context.Context, source *UserLogin, msg *BackfillMessage, ...)

+ func (portal *PortalInternals) CreateMatrixRoomInLoop(ctx context.Context, source *UserLogin, info *ChatInfo, backfillBundle any) error

+ func (portal *PortalInternals) CreateParentAndAddToSpace(ctx context.Context, source *UserLogin)

+ func (portal *PortalInternals) DoForwardBackfill(ctx context.Context, source *UserLogin, lastMessage *database.Message, ...)

+ func (portal *PortalInternals) DoThreadBackfill(ctx context.Context, source *UserLogin, threadID networkid.MessageID)

+ func (portal *PortalInternals) EventLoop()

+ func (portal *PortalInternals) FetchThreadBackfill(ctx context.Context, source *UserLogin, anchor *database.Message) *FetchMessagesResponse

+ func (portal *PortalInternals) FetchThreadInsideBatch(ctx context.Context, source *UserLogin, dbMsg *database.Message, ...)

+ func (portal *PortalInternals) GetBridgeInfo() (string, event.BridgeEventContent)

+ func (portal *PortalInternals) GetInitialMemberList(ctx context.Context, members *ChatMemberList, source *UserLogin, ...) (invite, functional []id.UserID, err error)

+ func (portal *PortalInternals) GetIntentAndUserMXIDFor(ctx context.Context, sender EventSender, source *UserLogin, ...) (intent MatrixAPI, extraUserID id.UserID)

+ func (portal *PortalInternals) GetIntentForMXID(ctx context.Context, userID id.UserID) (MatrixAPI, error)

+ func (portal *PortalInternals) GetRelationMeta(ctx context.Context, currentMsg networkid.MessageID, ...) (replyTo, threadRoot, prevThreadEvent *database.Message)

+ func (portal *PortalInternals) GetTargetMessagePart(ctx context.Context, evt RemoteEventWithTargetMessage) (*database.Message, error)

+ func (portal *PortalInternals) GetTargetReaction(ctx context.Context, evt RemoteReactionRemove) (*database.Reaction, error)

+ func (portal *PortalInternals) GetTargetUser(ctx context.Context, userID id.UserID) (GhostOrUserLogin, error)

+ func (portal *PortalInternals) HandleCreateEvent(evt *portalCreateEvent)

+ func (portal *PortalInternals) HandleMatrixEdit(ctx context.Context, sender *UserLogin, origSender *OrigSender, ...)

+ func (portal *PortalInternals) HandleMatrixEvent(sender *User, evt *event.Event)

+ func (portal *PortalInternals) HandleMatrixMembership(ctx context.Context, sender *UserLogin, origSender *OrigSender, ...)

+ func (portal *PortalInternals) HandleMatrixMessage(ctx context.Context, sender *UserLogin, origSender *OrigSender, ...)

+ func (portal *PortalInternals) HandleMatrixPowerLevels(ctx context.Context, sender *UserLogin, origSender *OrigSender, ...)

+ func (portal *PortalInternals) HandleMatrixReaction(ctx context.Context, sender *UserLogin, evt *event.Event)

+ func (portal *PortalInternals) HandleMatrixReadReceipt(ctx context.Context, user *User, eventID id.EventID, receipt event.ReadReceipt)

+ func (portal *PortalInternals) HandleMatrixReceipts(ctx context.Context, evt *event.Event)

+ func (portal *PortalInternals) HandleMatrixRedaction(ctx context.Context, sender *UserLogin, origSender *OrigSender, ...)

+ func (portal *PortalInternals) HandleMatrixTyping(ctx context.Context, evt *event.Event)

+ func (portal *PortalInternals) HandleRemoteBackfill(ctx context.Context, source *UserLogin, backfill RemoteBackfill)

+ func (portal *PortalInternals) HandleRemoteChatDelete(ctx context.Context, source *UserLogin, evt RemoteChatDelete)

+ func (portal *PortalInternals) HandleRemoteChatInfoChange(ctx context.Context, source *UserLogin, evt RemoteChatInfoChange)

+ func (portal *PortalInternals) HandleRemoteChatResync(ctx context.Context, source *UserLogin, evt RemoteChatResync)

+ func (portal *PortalInternals) HandleRemoteDeliveryReceipt(ctx context.Context, source *UserLogin, evt RemoteDeliveryReceipt)

+ func (portal *PortalInternals) HandleRemoteEdit(ctx context.Context, source *UserLogin, evt RemoteEdit)

+ func (portal *PortalInternals) HandleRemoteEvent(source *UserLogin, evt RemoteEvent)

+ func (portal *PortalInternals) HandleRemoteMarkUnread(ctx context.Context, source *UserLogin, evt RemoteMarkUnread)

+ func (portal *PortalInternals) HandleRemoteMessage(ctx context.Context, source *UserLogin, evt RemoteMessage)

+ func (portal *PortalInternals) HandleRemoteMessageRemove(ctx context.Context, source *UserLogin, evt RemoteMessageRemove)

+ func (portal *PortalInternals) HandleRemoteReaction(ctx context.Context, source *UserLogin, evt RemoteReaction)

+ func (portal *PortalInternals) HandleRemoteReactionRemove(ctx context.Context, source *UserLogin, evt RemoteReactionRemove)

+ func (portal *PortalInternals) HandleRemoteReactionSync(ctx context.Context, source *UserLogin, evt RemoteReactionSync)

+ func (portal *PortalInternals) HandleRemoteReadReceipt(ctx context.Context, source *UserLogin, evt RemoteReadReceipt)

+ func (portal *PortalInternals) HandleRemoteTyping(ctx context.Context, source *UserLogin, evt RemoteTyping)

+ func (portal *PortalInternals) HandleRemoteUpsert(ctx context.Context, source *UserLogin, evt RemoteMessageUpsert, ...) bool

+ func (portal *PortalInternals) LockedUpdateInfoFromGhost(ctx context.Context, ghost *Ghost)

+ func (portal *PortalInternals) PeriodicTypingUpdater()

+ func (portal *PortalInternals) QueueEvent(ctx context.Context, evt portalEvent)

+ func (portal *PortalInternals) RedactMessageParts(ctx context.Context, parts []*database.Message, intent MatrixAPI, ts time.Time)

+ func (portal *PortalInternals) RemoveInPortalCache(ctx context.Context)

+ func (portal *PortalInternals) SendBackfill(ctx context.Context, source *UserLogin, messages []*BackfillMessage, ...)

+ func (portal *PortalInternals) SendBatch(ctx context.Context, source *UserLogin, messages []*BackfillMessage, ...)

+ func (portal *PortalInternals) SendConvertedEdit(ctx context.Context, targetID networkid.MessageID, senderID networkid.UserID, ...)

+ func (portal *PortalInternals) SendConvertedMessage(ctx context.Context, id networkid.MessageID, intent MatrixAPI, ...) []*database.Message

+ func (portal *PortalInternals) SendConvertedReaction(ctx context.Context, senderID networkid.UserID, intent MatrixAPI, ...)

+ func (portal *PortalInternals) SendErrorStatus(ctx context.Context, evt *event.Event, err error)

+ func (portal *PortalInternals) SendLegacyBackfill(ctx context.Context, source *UserLogin, messages []*BackfillMessage, ...)

+ func (portal *PortalInternals) SendRemoteErrorNotice(ctx context.Context, intent MatrixAPI, err error, ts time.Time, ...)

+ func (portal *PortalInternals) SendRoomMeta(ctx context.Context, sender MatrixAPI, ts time.Time, eventType event.Type, ...) bool

+ func (portal *PortalInternals) SendStateWithIntentOrBot(ctx context.Context, sender MatrixAPI, eventType event.Type, stateKey string, ...) (resp *mautrix.RespSendEvent, err error)

+ func (portal *PortalInternals) SendSuccessStatus(ctx context.Context, evt *event.Event)

+ func (portal *PortalInternals) SendTypings(ctx context.Context, userIDs []id.UserID, typing bool)

+ func (portal *PortalInternals) SetMXIDToExistingRoom(roomID id.RoomID) bool

+ func (portal *PortalInternals) SyncParticipants(ctx context.Context, members *ChatMemberList, source *UserLogin, ...) error

+ func (portal *PortalInternals) ToggleSpace(ctx context.Context, spaceID id.RoomID, canonical, remove bool) error

+ func (portal *PortalInternals) UnlockedDelete(ctx context.Context) error

+ func (portal *PortalInternals) UnlockedDeleteCache()

+ func (portal *PortalInternals) UnlockedReID(ctx context.Context, target networkid.PortalKey) error

+ func (portal *PortalInternals) UpdateAvatar(ctx context.Context, avatar *Avatar, sender MatrixAPI, ts time.Time) bool

+ func (portal *PortalInternals) UpdateLogger()

+ func (portal *PortalInternals) UpdateName(ctx context.Context, name string, sender MatrixAPI, ts time.Time) bool

+ func (portal *PortalInternals) UpdateOtherUser(ctx context.Context, members *ChatMemberList) (changed bool)

+ func (portal *PortalInternals) UpdateParent(ctx context.Context, newParent networkid.PortalID, source *UserLogin) bool

+ func (portal *PortalInternals) UpdateTopic(ctx context.Context, topic string, sender MatrixAPI, ts time.Time) bool

+ func (portal *PortalInternals) UpdateUserLocalInfo(ctx context.Context, info *UserLocalPortalInfo, source *UserLogin, ...)

+ type PowerLevelHandlingNetworkAPI interface

+ HandleMatrixPowerLevels func(ctx context.Context, msg *MatrixPowerLevelChange) (bool, error)

+ type PowerLevelOverrides struct

+ Ban *int

+ Custom func(*event.PowerLevelsEventContent) bool

+ Events map[event.Type]int

+ EventsDefault *int

+ Invite *int

+ Kick *int

+ Redact *int

+ StateDefault *int

+ UsersDefault *int

+ func (plc *PowerLevelOverrides) Apply(actor id.UserID, content *event.PowerLevelsEventContent) (changed bool)

+ type ReactionSyncData struct

+ HasAllUsers bool

+ Users map[networkid.UserID]*ReactionSyncUser

+ func (rsd *ReactionSyncData) ToBackfill() []*BackfillReaction

+ type ReactionSyncUser struct

+ HasAllReactions bool

+ MaxCount int

+ Reactions []*BackfillReaction

+ type RemoteChatDelete interface

+ DeleteOnlyForMe func() bool

+ type RemoteChatResyncBackfillBundle interface

+ GetBundledBackfillData func() any

+ type RemoteDeliveryReceipt interface

+ GetReceiptTargets func() []networkid.MessageID

type RemoteEventType

+ const RemoteEventChatDelete

+ const RemoteEventMessageUpsert

+ const RemoteEventReactionSync

+ type RemoteEventWithBundledParts interface

+ GetTargetDBMessage func() []*database.Message

+ type RemoteEventWithStreamOrder interface

+ GetStreamOrder func() int64

+ type RemoteEventWithUncertainPortalReceiver interface

+ PortalReceiverIsUncertain func() bool

+ type RemoteMessageUpsert interface

+ HandleExisting func(ctx context.Context, portal *Portal, intent MatrixAPI, ...) (UpsertResult, error)

+ type RemoteMessageWithTransactionID interface

+ GetTransactionID func() networkid.TransactionID

+ type RemoteReactionSync interface

+ GetReactions func() *ReactionSyncData

+ type RemoteReadReceipt interface

+ GetLastReceiptTarget func() networkid.MessageID

+ GetReadUpTo func() time.Time

+ GetReceiptTargets func() []networkid.MessageID

+ type RespError mautrix.RespError

+ func WrapRespErr(err error, target mautrix.RespError) RespError

+ func WrapRespErrManual(err error, code string, status int) RespError

+ func (re RespError) AppendMessage(append string, args ...any) RespError

+ func (re RespError) Error() string

+ func (re RespError) Is(err error) bool

type SimpleRemoteEvent

+ BackfillData *FetchMessagesResponse

+ ResyncBackfillNeeded bool

+ ResyncChatInfo *ChatInfo

+ func (sre *SimpleRemoteEvent[T]) CheckNeedsBackfill(ctx context.Context, latestMessage *database.Message) (bool, error)

+ func (sre *SimpleRemoteEvent[T]) GetBackfillData(ctx context.Context, portal *Portal) (*FetchMessagesResponse, error)

+ func (sre *SimpleRemoteEvent[T]) GetChatInfo(ctx context.Context, portal *Portal) (*ChatInfo, error)

+ type SinglePowerLevelChange struct

+ NewIsSet bool

+ NewLevel int

+ OrigLevel int

+ type TagHandlingNetworkAPI interface

+ HandleRoomTag func(ctx context.Context, msg *MatrixRoomTag) error

+ type UpsertResult struct

+ ContinueMessageHandling bool

+ SaveParts bool

+ SubEvents []RemoteEvent

type UserLogin

+ func (ul *UserLogin) FillBridgeState(state status.BridgeState) status.BridgeState

+ func (ul *UserLogin) KickUserFromPortalsForBadCredentials(ctx context.Context)

+ type UserPowerLevelChange struct

+ Target GhostOrUserLogin

v0.19.0

Jul 16, 2024

Changes in this version

+ const DisappearCheckInterval

+ const PortalEventBuffer

+ var ErrCaptionsNotAllowed error = WrapErrorInStatus(errors.New("captions are not supported here")).WithIsCertain(true)

+ var ErrDatabaseError error = WrapErrorInStatus(errors.New("database error")).WithMessage("internal database error").WithIsCertain(true).WithSendNotice(true)

+ var ErrDirectMediaNotEnabled = errors.New("direct media is not enabled")

+ var ErrEditTargetTooManyEdits error = WrapErrorInStatus(errors.New("the message has been edited too many times")).WithIsCertain(true)

+ var ErrEditTargetTooOld error = WrapErrorInStatus(errors.New("the message is too old to be edited")).WithIsCertain(true)

+ var ErrEditsNotSupported error = WrapErrorInStatus(errors.New("this bridge does not support edits")).WithIsCertain(true)

+ var ErrEditsNotSupportedInPortal error = WrapErrorInStatus(errors.New("edits are not allowed in this chat")).WithIsCertain(true)

+ var ErrIgnoringReactionFromRelayedUser error = WrapErrorInStatus(errors.New("ignoring reaction event from relayed user")).WithIsCertain(true).WithSendNotice(false)

+ var ErrLocationMessagesNotAllowed error = WrapErrorInStatus(errors.New("location messages are not supported here")).WithIsCertain(true)

+ var ErrNoPortal error = WrapErrorInStatus(errors.New("room is not a portal")).WithIsCertain(true).WithSendNotice(false)

+ var ErrNotLoggedIn = errors.New("not logged in")

+ var ErrPanicInEventHandler error = WrapErrorInStatus(errors.New("panic in event handler")).WithSendNotice(true).WithErrorAsMessage()

+ var ErrReactionsNotSupported error = WrapErrorInStatus(errors.New("this bridge does not support reactions")).WithIsCertain(true)

+ var ErrRedactionsNotSupported error = WrapErrorInStatus(errors.New("this bridge does not support deleting messages")).WithIsCertain(true)

+ var ErrRoomMetadataNotSupported error = WrapErrorInStatus(errors.New("this bridge does not support changing room metadata")).WithIsCertain(true).WithSendNotice(false)

+ var ErrTargetMessageNotFound error = WrapErrorInStatus(errors.New("target message not found")).WithErrorAsMessage().WithIsCertain(true).WithSendNotice(false)

+ var ErrUnexpectedParsedContentType error = WrapErrorInStatus(errors.New("unexpected parsed content type")).WithErrorAsMessage().WithIsCertain(true).WithSendNotice(true)

+ var Unmuted = time.Date(2024, 1, 1, 0, 0, 0, 0, time.UTC)

+ func CleanPhoneNumber(phone string) (string, error)

+ type APNsPushConfig struct

+ BundleID string

+ type Avatar struct

+ Get func(ctx context.Context) ([]byte, error)

+ Hash [32]byte

+ ID networkid.AvatarID

+ MXC id.ContentURIString

+ Remove bool

+ func (a *Avatar) Reupload(ctx context.Context, intent MatrixAPI, currentHash [32]byte) (id.ContentURIString, [32]byte, error)

+ type BackfillMessage struct

+ ID networkid.MessageID

+ Reactions []*BackfillReaction

+ Sender EventSender

+ Timestamp time.Time

+ type BackfillReaction struct

+ DBMetadata map[string]any

+ Emoji string

+ EmojiID networkid.EmojiID

+ ExtraContent map[string]any

+ Sender EventSender

+ TargetPart *networkid.PartID

+ Timestamp time.Time

+ type BackfillingNetworkAPI interface

+ FetchMessages func(ctx context.Context, fetchParams FetchMessagesParams) (*FetchMessagesResponse, error)

+ type Bridge struct

+ Bot MatrixAPI

+ Commands CommandProcessor

+ Config *bridgeconfig.BridgeConfig

+ DB *database.Database

+ DisappearLoop *DisappearLoop

+ ID networkid.BridgeID

+ Log zerolog.Logger

+ Matrix MatrixConnector

+ Network NetworkConnector

+ func NewBridge(bridgeID networkid.BridgeID, db *dbutil.Database, log zerolog.Logger, ...) *Bridge

+ func (br *Bridge) FindCachedPortalReceiver(id networkid.PortalID, maybeReceiver networkid.UserLoginID) networkid.PortalKey

+ func (br *Bridge) FindPortalReceiver(ctx context.Context, id networkid.PortalID, ...) (networkid.PortalKey, error)

+ func (br *Bridge) GetAllPortalsWithMXID(ctx context.Context) ([]*Portal, error)

+ func (br *Bridge) GetCachedUserLoginByID(id networkid.UserLoginID) *UserLogin

+ func (br *Bridge) GetCurrentBridgeStates() (states []status.BridgeState)

+ func (br *Bridge) GetExistingPortalByKey(ctx context.Context, key networkid.PortalKey) (*Portal, error)

+ func (br *Bridge) GetExistingUserByMXID(ctx context.Context, userID id.UserID) (*User, error)

+ func (br *Bridge) GetExistingUserLoginByID(ctx context.Context, id networkid.UserLoginID) (*UserLogin, error)

+ func (br *Bridge) GetGhostByID(ctx context.Context, id networkid.UserID) (*Ghost, error)

+ func (br *Bridge) GetGhostByMXID(ctx context.Context, mxid id.UserID) (*Ghost, error)

+ func (br *Bridge) GetPortalByKey(ctx context.Context, key networkid.PortalKey) (*Portal, error)

+ func (br *Bridge) GetPortalByMXID(ctx context.Context, mxid id.RoomID) (*Portal, error)

+ func (br *Bridge) GetUserByMXID(ctx context.Context, userID id.UserID) (*User, error)

+ func (br *Bridge) GetUserLoginsInPortal(ctx context.Context, portal networkid.PortalKey) ([]*UserLogin, error)

+ func (br *Bridge) NewBridgeStateQueue(user status.BridgeStateFiller) *BridgeStateQueue

+ func (br *Bridge) QueueMatrixEvent(ctx context.Context, evt *event.Event)

+ func (br *Bridge) QueueRemoteEvent(login *UserLogin, evt RemoteEvent)

+ func (br *Bridge) ReIDPortal(ctx context.Context, source, target networkid.PortalKey) (ReIDResult, *Portal, error)

+ func (br *Bridge) SendGlobalBridgeState(state status.BridgeState)

+ func (br *Bridge) Start() error

+ func (br *Bridge) Stop()

+ func (br *Bridge) UnlockedGetPortalByKey(ctx context.Context, key networkid.PortalKey, onlyIfExists bool) (*Portal, error)

+ type BridgeName struct

+ BeeperBridgeType string

+ DefaultCommandPrefix string

+ DefaultPort uint16

+ DisplayName string

+ NetworkID string

+ NetworkIcon id.ContentURIString

+ NetworkURL string

+ func (bn BridgeName) AsBridgeInfoSection() event.BridgeInfoSection

+ type BridgeStateQueue struct

+ func (bsq *BridgeStateQueue) Destroy()

+ func (bsq *BridgeStateQueue) GetPrev() status.BridgeState

+ func (bsq *BridgeStateQueue) Send(state status.BridgeState)

+ func (bsq *BridgeStateQueue) SetPrev(prev status.BridgeState)

+ type ChatInfo struct

+ Avatar *Avatar

+ Disappear *database.DisappearingSetting

+ ExtraUpdates func(context.Context, *Portal) bool

+ JoinRule *event.JoinRulesEventContent

+ Members *ChatMemberList

+ Name *string

+ ParentID *networkid.PortalID

+ Topic *string

+ Type *database.RoomType

+ UserLocal *UserLocalPortalInfo

+ type ChatInfoChange struct

+ ChatInfo *ChatInfo

+ MemberChanges *ChatMemberList

+ type ChatMember struct

+ Membership event.Membership

+ Nickname string

+ PowerLevel int

+ PrevMembership event.Membership

+ type ChatMemberList struct

+ CheckAllLogins bool

+ IsFull bool

+ Members []ChatMember

+ PowerLevels *PowerLevelChanges

+ TotalMemberCount int

+ type CommandProcessor interface

+ Handle func(ctx context.Context, roomID id.RoomID, eventID id.EventID, user *User, ...)

+ type ConfigValidatingNetwork interface

+ ValidateConfig func() error

+ type ContactListingNetworkAPI interface

+ GetContactList func(ctx context.Context) ([]*ResolveIdentifierResponse, error)

+ type ConvertedEdit struct

+ DeletedParts []*database.Message

+ ModifiedParts []*ConvertedEditPart

+ type ConvertedEditPart struct

+ Content *event.MessageEventContent

+ Extra map[string]any

+ Part *database.Message

+ TopLevelExtra map[string]any

+ Type event.Type

+ type ConvertedMessage struct

+ Disappear database.DisappearingSetting

+ Parts []*ConvertedMessagePart

+ ReplyTo *networkid.MessageOptionalPartID

+ ThreadRoot *networkid.MessageID

+ func (cm *ConvertedMessage) MergeCaption() bool

+ type ConvertedMessagePart struct

+ Content *event.MessageEventContent

+ DBMetadata any

+ Extra map[string]any

+ ID networkid.PartID

+ Type event.Type

+ func MergeCaption(textPart, mediaPart *ConvertedMessagePart) *ConvertedMessagePart

+ func (cmp *ConvertedMessagePart) ToEditPart(part *database.Message) *ConvertedEditPart

+ type CreateChatResponse struct

+ Portal *Portal

+ PortalInfo *ChatInfo

+ PortalKey networkid.PortalKey

+ type DBUpgradeError struct

+ Err error

+ Section string

+ func (e DBUpgradeError) Error() string

+ func (e DBUpgradeError) Unwrap() error

+ type DirectMediableNetwork interface

+ Download func(ctx context.Context, mediaID networkid.MediaID) (mediaproxy.GetMediaResponse, error)

+ SetUseDirectMedia func()

+ type DisappearLoop struct

+ NextCheck time.Time

+ func (dl *DisappearLoop) Add(ctx context.Context, dm *database.DisappearingMessage)

+ func (dl *DisappearLoop) Start()

+ func (dl *DisappearLoop) StartAll(ctx context.Context, roomID id.RoomID)

+ func (dl *DisappearLoop) Stop()

+ type EditHandlingNetworkAPI interface

+ HandleMatrixEdit func(ctx context.Context, msg *MatrixEdit) error

+ type EventSender struct

+ IsFromMe bool

+ Sender networkid.UserID

+ SenderLogin networkid.UserLoginID

+ type FCMPushConfig struct

+ SenderID string

+ type FetchMessagesParams struct

+ AnchorMessage *database.Message

+ Count int

+ Cursor networkid.PaginationCursor

+ Forward bool

+ Portal *Portal

+ ThreadRoot networkid.MessageID

+ type FetchMessagesResponse struct

+ ApproxProgress float64

+ ApproxRemainingCount int

+ ApproxTotalCount int

+ Cursor networkid.PaginationCursor

+ Forward bool

+ HasMore bool

+ MarkRead bool

+ Messages []*BackfillMessage

+ type FileRestriction struct

+ MaxSize int64

+ MimeTypes []string

+ type Ghost struct

+ Bridge *Bridge

+ Intent MatrixAPI

+ Log zerolog.Logger

+ func (ghost *Ghost) UpdateAvatar(ctx context.Context, avatar *Avatar) bool

+ func (ghost *Ghost) UpdateContactInfo(ctx context.Context, identifiers []string, isBot *bool) bool

+ func (ghost *Ghost) UpdateInfo(ctx context.Context, info *UserInfo)

+ func (ghost *Ghost) UpdateInfoIfNecessary(ctx context.Context, source *UserLogin, evtType RemoteEventType)

+ func (ghost *Ghost) UpdateName(ctx context.Context, name string) bool

+ type GroupCreatingNetworkAPI interface

+ CreateGroup func(ctx context.Context, name string, users ...networkid.UserID) (*CreateChatResponse, error)

+ type IdentifierResolvingNetworkAPI interface

+ ResolveIdentifier func(ctx context.Context, identifier string, createChat bool) (*ResolveIdentifierResponse, error)

+ type LoginCompleteParams struct

+ UserLogin *UserLogin

+ UserLoginID networkid.UserLoginID

+ type LoginCookiesParams struct

+ CookieDomain string

+ CookieKeys []string

+ LocalStorageKeys []string

+ SpecialExtractJS string

+ SpecialKeys []string

+ URL string

+ UserAgent string

+ type LoginDisplayAndWaitParams struct

+ Data string

+ ImageURL string

+ Type LoginDisplayType

+ type LoginDisplayType string

+ const LoginDisplayTypeCode

+ const LoginDisplayTypeEmoji

+ const LoginDisplayTypeNothing

+ const LoginDisplayTypeQR

+ type LoginFlow struct

+ Description string

+ ID string

+ Name string

+ type LoginInputDataField struct

+ Description string

+ ID string

+ Name string

+ Pattern string

+ Type LoginInputFieldType

+ Validate func(string) (string, error)

+ func (f *LoginInputDataField) FillDefaultValidate()

+ type LoginInputFieldType string

+ const LoginInputFieldType2FACode

+ const LoginInputFieldTypeEmail

+ const LoginInputFieldTypePassword

+ const LoginInputFieldTypePhoneNumber

+ const LoginInputFieldTypeUsername

+ type LoginProcess interface

+ Cancel func()

+ Start func(ctx context.Context) (*LoginStep, error)

+ type LoginProcessCookies interface

+ SubmitCookies func(ctx context.Context, cookies map[string]string) (*LoginStep, error)

+ type LoginProcessDisplayAndWait interface

+ Wait func(ctx context.Context) (*LoginStep, error)

+ type LoginProcessUserInput interface

+ SubmitUserInput func(ctx context.Context, input map[string]string) (*LoginStep, error)

+ type LoginStep struct

+ CompleteParams *LoginCompleteParams

+ CookiesParams *LoginCookiesParams

+ DisplayAndWaitParams *LoginDisplayAndWaitParams

+ Instructions string

+ StepID string

+ Type LoginStepType

+ UserInputParams *LoginUserInputParams

+ type LoginStepType string

+ const LoginStepTypeComplete

+ const LoginStepTypeCookies

+ const LoginStepTypeDisplayAndWait

+ const LoginStepTypeUserInput

+ type LoginSubmit struct

+ type LoginUserInputParams struct

+ Fields []LoginInputDataField

+ type MatrixAPI interface

+ CreateRoom func(ctx context.Context, req *mautrix.ReqCreateRoom) (id.RoomID, error)

+ DeleteRoom func(ctx context.Context, roomID id.RoomID, puppetsOnly bool) error

+ DownloadMedia func(ctx context.Context, uri id.ContentURIString, file *event.EncryptedFileInfo) ([]byte, error)

+ EnsureInvited func(ctx context.Context, roomID id.RoomID, userID id.UserID) error

+ EnsureJoined func(ctx context.Context, roomID id.RoomID) error

+ GetMXID func() id.UserID

+ InviteUser func(ctx context.Context, roomID id.RoomID, userID id.UserID) error

+ MarkRead func(ctx context.Context, roomID id.RoomID, eventID id.EventID, ts time.Time) error

+ MarkTyping func(ctx context.Context, roomID id.RoomID, typingType TypingType, ...) error

+ MarkUnread func(ctx context.Context, roomID id.RoomID, unread bool) error

+ MuteRoom func(ctx context.Context, roomID id.RoomID, until time.Time) error

+ SendMessage func(ctx context.Context, roomID id.RoomID, eventType event.Type, ...) (*mautrix.RespSendEvent, error)

+ SendState func(ctx context.Context, roomID id.RoomID, eventType event.Type, stateKey string, ...) (*mautrix.RespSendEvent, error)

+ SetAvatarURL func(ctx context.Context, avatarURL id.ContentURIString) error

+ SetDisplayName func(ctx context.Context, name string) error

+ SetExtraProfileMeta func(ctx context.Context, data any) error

+ TagRoom func(ctx context.Context, roomID id.RoomID, tag event.RoomTag, isTagged bool) error

+ UploadMedia func(ctx context.Context, roomID id.RoomID, data []byte, fileName, mimeType string) (url id.ContentURIString, file *event.EncryptedFileInfo, err error)

+ type MatrixCapabilities struct

+ AutoJoinInvites bool

+ BatchSending bool

+ type MatrixConnector interface

+ BatchSend func(ctx context.Context, roomID id.RoomID, req *mautrix.ReqBeeperBatchSend) (*mautrix.RespBeeperBatchSend, error)

+ BotIntent func() MatrixAPI

+ GenerateContentURI func(ctx context.Context, mediaID networkid.MediaID) (id.ContentURIString, error)

+ GenerateDeterministicEventID func(roomID id.RoomID, portalKey networkid.PortalKey, messageID networkid.MessageID, ...) id.EventID

+ GetCapabilities func() *MatrixCapabilities

+ GetMemberInfo func(ctx context.Context, roomID id.RoomID, userID id.UserID) (*event.MemberEventContent, error)

+ GetMembers func(ctx context.Context, roomID id.RoomID) (map[id.UserID]*event.MemberEventContent, error)

+ GetPowerLevels func(ctx context.Context, roomID id.RoomID) (*event.PowerLevelsEventContent, error)

+ GhostIntent func(userID networkid.UserID) MatrixAPI

+ Init func(*Bridge)

+ NewUserIntent func(ctx context.Context, userID id.UserID, accessToken string) (MatrixAPI, string, error)

+ ParseGhostMXID func(userID id.UserID) (networkid.UserID, bool)

+ SendBridgeStatus func(ctx context.Context, state *status.BridgeState) error

+ SendMessageStatus func(ctx context.Context, status *MessageStatus, evt *MessageStatusEventInfo)

+ ServerName func() string

+ Start func(ctx context.Context) error

+ Stop func()

+ type MatrixConnectorWithServer interface

+ GetPublicAddress func() string

+ GetRouter func() *mux.Router

+ type MatrixEdit struct

+ EditTarget *database.Message

+ type MatrixEventBase struct

+ Content ContentType

+ Event *event.Event

+ OrigSender *OrigSender

+ Portal *Portal

+ type MatrixMessage struct

+ ReplyTo *database.Message

+ ThreadRoot *database.Message

+ type MatrixMessageRemove struct

+ TargetMessage *database.Message

+ type MatrixMessageResponse struct

+ DB *database.Message

+ type MatrixReaction struct

+ ExistingReactionsToKeep []*database.Reaction

+ PreHandleResp *MatrixReactionPreResponse

+ TargetMessage *database.Message

+ type MatrixReactionPreResponse struct

+ Emoji string

+ EmojiID networkid.EmojiID

+ MaxReactions int

+ SenderID networkid.UserID

+ type MatrixReactionRemove struct

+ TargetReaction *database.Reaction

+ type MatrixReadReceipt struct

+ EventID id.EventID

+ ExactMessage *database.Message

+ LastRead time.Time

+ Portal *Portal

+ ReadUpTo time.Time

+ Receipt event.ReadReceipt

+ type MatrixRoomAvatar = MatrixRoomMeta[*event.RoomAvatarEventContent]

+ type MatrixRoomMeta struct

+ PrevContent ContentType

+ type MatrixRoomName = MatrixRoomMeta[*event.RoomNameEventContent]

+ type MatrixRoomTopic = MatrixRoomMeta[*event.TopicEventContent]

+ type MatrixTyping struct

+ IsTyping bool

+ Portal *Portal

+ Type TypingType

+ type MaxFileSizeingNetwork interface

+ SetMaxFileSize func(maxSize int64)

+ type MessageStatus struct

+ DeliveredTo []id.UserID

+ DisableMSS bool

+ ErrorAsMessage bool

+ ErrorReason event.MessageStatusReason

+ InternalError error

+ IsCertain bool

+ Message string

+ RetryNum int

+ SendNotice bool

+ Status event.MessageStatus

+ Step status.MessageCheckpointStep

+ func WrapErrorInStatus(err error) MessageStatus

+ func (ms *MessageStatus) ToCheckpoint(evt *MessageStatusEventInfo) *status.MessageCheckpoint

+ func (ms *MessageStatus) ToMSSEvent(evt *MessageStatusEventInfo) *event.BeeperMessageStatusEventContent

+ func (ms *MessageStatus) ToNoticeEvent(evt *MessageStatusEventInfo) *event.MessageEventContent

+ func (ms MessageStatus) Error() string

+ func (ms MessageStatus) Unwrap() error

+ func (ms MessageStatus) WithErrorAsMessage() MessageStatus

+ func (ms MessageStatus) WithErrorReason(reason event.MessageStatusReason) MessageStatus

+ func (ms MessageStatus) WithIsCertain(certain bool) MessageStatus

+ func (ms MessageStatus) WithMessage(msg string) MessageStatus

+ func (ms MessageStatus) WithSendNotice(send bool) MessageStatus

+ func (ms MessageStatus) WithStatus(status event.MessageStatus) MessageStatus

+ func (ms MessageStatus) WithStep(step status.MessageCheckpointStep) MessageStatus

+ type MessageStatusEventInfo struct

+ EventID id.EventID

+ EventType event.Type

+ MessageType event.MessageType

+ RoomID id.RoomID

+ Sender id.UserID

+ ThreadRoot id.EventID

+ func StatusEventInfoFromEvent(evt *event.Event) *MessageStatusEventInfo

+ type NetworkAPI interface

+ Connect func(ctx context.Context) error

+ Disconnect func()

+ GetCapabilities func(ctx context.Context, portal *Portal) *NetworkRoomCapabilities

+ GetChatInfo func(ctx context.Context, portal *Portal) (*ChatInfo, error)

+ GetUserInfo func(ctx context.Context, ghost *Ghost) (*UserInfo, error)

+ HandleMatrixMessage func(ctx context.Context, msg *MatrixMessage) (message *MatrixMessageResponse, err error)

+ IsLoggedIn func() bool

+ IsThisUser func(ctx context.Context, userID networkid.UserID) bool

+ LogoutRemote func(ctx context.Context)

+ type NetworkConnector interface

+ CreateLogin func(ctx context.Context, user *User, flowID string) (LoginProcess, error)

+ GetCapabilities func() *NetworkGeneralCapabilities

+ GetConfig func() (example string, data any, upgrader configupgrade.Upgrader)

+ GetDBMetaTypes func() database.MetaTypes

+ GetLoginFlows func() []LoginFlow

+ GetName func() BridgeName

+ Init func(*Bridge)

+ LoadUserLogin func(ctx context.Context, login *UserLogin) error

+ Start func(context.Context) error

+ type NetworkGeneralCapabilities struct

+ AggressiveUpdateInfo bool

+ DisappearingMessages bool

+ type NetworkRoomCapabilities struct

+ AllowedReactions []string

+ Captions bool

+ DefaultFileRestriction *FileRestriction

+ DeleteMaxAge time.Duration

+ Deletes bool

+ EditMaxAge time.Duration

+ EditMaxCount int

+ Edits bool

+ Files map[event.MessageType]FileRestriction

+ FormattedText bool

+ LocationMessages bool

+ MaxCaptionLength int

+ MaxTextLength int

+ ReactionCount int

+ Reactions bool

+ ReadReceipts bool

+ Replies bool

+ RoomMentions bool

+ Threads bool

+ UserMentions bool

+ type NewLoginParams struct

+ DeleteOnConflict bool

+ DontReuseExisting bool

+ LoadUserLogin func(context.Context, *UserLogin) error

+ type OrigSender struct

+ User *User

+ type Portal struct

+ Bridge *Bridge

+ Log zerolog.Logger

+ Parent *Portal

+ Relay *UserLogin

+ func (portal *Portal) CreateMatrixRoom(ctx context.Context, source *UserLogin, info *ChatInfo) error

+ func (portal *Portal) Delete(ctx context.Context) error

+ func (portal *Portal) DoBackwardsBackfill(ctx context.Context, source *UserLogin)

+ func (portal *Portal) FindPreferredLogin(ctx context.Context, user *User, allowRelay bool) (*UserLogin, *database.UserPortal, error)

+ func (portal *Portal) GetInitialMemberList(ctx context.Context, members *ChatMemberList, source *UserLogin, ...) (invite, functional []id.UserID, err error)

+ func (portal *Portal) GetIntentFor(ctx context.Context, sender EventSender, source *UserLogin, ...) MatrixAPI

+ func (portal *Portal) GetTopLevelParent() *Portal

+ func (portal *Portal) ProcessChatInfoChange(ctx context.Context, sender EventSender, source *UserLogin, ...)

+ func (portal *Portal) Save(ctx context.Context) error

+ func (portal *Portal) SetRelay(ctx context.Context, relay *UserLogin) error

+ func (portal *Portal) SyncParticipants(ctx context.Context, members *ChatMemberList, source *UserLogin, ...) error

+ func (portal *Portal) UpdateAvatar(ctx context.Context, avatar *Avatar, sender MatrixAPI, ts time.Time) bool

+ func (portal *Portal) UpdateBridgeInfo(ctx context.Context)

+ func (portal *Portal) UpdateDisappearingSetting(ctx context.Context, setting database.DisappearingSetting, sender MatrixAPI, ...) bool

+ func (portal *Portal) UpdateInfo(ctx context.Context, info *ChatInfo, source *UserLogin, sender MatrixAPI, ...)

+ func (portal *Portal) UpdateName(ctx context.Context, name string, sender MatrixAPI, ts time.Time) bool

+ func (portal *Portal) UpdateParent(ctx context.Context, newParent networkid.PortalID, source *UserLogin) bool

+ func (portal *Portal) UpdateTopic(ctx context.Context, topic string, sender MatrixAPI, ts time.Time) bool

+ type PortalInfo = ChatInfo

+ type PowerLevelChanges struct

+ Ban *int

+ Custom func(*event.PowerLevelsEventContent) bool

+ Events map[event.Type]int

+ EventsDefault *int

+ Invite *int

+ Kick *int

+ Redact *int

+ StateDefault *int

+ UsersDefault *int

+ func (plc *PowerLevelChanges) Apply(content *event.PowerLevelsEventContent) (changed bool)

+ type PushConfig struct

+ APNs *APNsPushConfig

+ FCM *FCMPushConfig

+ Web *WebPushConfig

+ type PushType int

+ const PushTypeAPNs

+ const PushTypeFCM

+ const PushTypeUnknown

+ const PushTypeWeb

+ func PushTypeFromString(str string) PushType

+ func (pt PushType) GoString() string

+ func (pt PushType) String() string

+ type PushableNetworkAPI interface

+ GetPushConfigs func() *PushConfig

+ RegisterPushNotifications func(ctx context.Context, pushType PushType, token string) error

+ type ReIDResult int

+ const ReIDResultError

+ const ReIDResultNoOp

+ const ReIDResultSourceDeleted

+ const ReIDResultSourceReIDd

+ const ReIDResultSourceTombstonedIntoTarget

+ const ReIDResultTargetDeletedAndSourceReIDd

+ type ReactionHandlingNetworkAPI interface

+ HandleMatrixReaction func(ctx context.Context, msg *MatrixReaction) (reaction *database.Reaction, err error)

+ HandleMatrixReactionRemove func(ctx context.Context, msg *MatrixReactionRemove) error

+ PreHandleMatrixReaction func(ctx context.Context, msg *MatrixReaction) (MatrixReactionPreResponse, error)

+ type ReadReceiptHandlingNetworkAPI interface

+ HandleMatrixReadReceipt func(ctx context.Context, msg *MatrixReadReceipt) error

+ type RedactionHandlingNetworkAPI interface

+ HandleMatrixMessageRemove func(ctx context.Context, msg *MatrixMessageRemove) error

+ type RemoteBackfill interface

+ GetBackfillData func(ctx context.Context, portal *Portal) (*FetchMessagesResponse, error)

+ type RemoteChatInfoChange interface

+ GetChatInfoChange func(ctx context.Context) (*ChatInfoChange, error)

+ type RemoteChatResync interface

+ type RemoteChatResyncBackfill interface

+ CheckNeedsBackfill func(ctx context.Context, latestMessage *database.Message) (bool, error)

+ type RemoteChatResyncWithInfo interface

+ GetChatInfo func(ctx context.Context, portal *Portal) (*ChatInfo, error)

+ type RemoteEdit interface

+ ConvertEdit func(ctx context.Context, portal *Portal, intent MatrixAPI, ...) (*ConvertedEdit, error)

+ type RemoteEvent interface

+ AddLogContext func(c zerolog.Context) zerolog.Context

+ GetPortalKey func() networkid.PortalKey

+ GetSender func() EventSender

+ GetType func() RemoteEventType

+ type RemoteEventThatMayCreatePortal interface

+ ShouldCreatePortal func() bool

+ type RemoteEventType int

+ const RemoteEventBackfill

+ const RemoteEventChatInfoChange

+ const RemoteEventChatResync

+ const RemoteEventDeliveryReceipt

+ const RemoteEventEdit

+ const RemoteEventMarkUnread

+ const RemoteEventMessage

+ const RemoteEventMessageRemove

+ const RemoteEventReaction

+ const RemoteEventReactionRemove

+ const RemoteEventReadReceipt

+ const RemoteEventTyping

+ const RemoteEventUnknown

+ func (ret RemoteEventType) String() string

+ type RemoteEventWithTargetMessage interface

+ GetTargetMessage func() networkid.MessageID

+ type RemoteEventWithTargetPart interface

+ GetTargetMessagePart func() networkid.PartID

+ type RemoteEventWithTimestamp interface

+ GetTimestamp func() time.Time

+ type RemoteMarkUnread interface

+ GetUnread func() bool

+ type RemoteMessage interface

+ ConvertMessage func(ctx context.Context, portal *Portal, intent MatrixAPI) (*ConvertedMessage, error)

+ GetID func() networkid.MessageID

+ type RemoteMessageRemove interface

+ type RemotePreHandler interface

+ PreHandle func(ctx context.Context, portal *Portal)

+ type RemoteReaction interface

+ GetReactionEmoji func() (string, networkid.EmojiID)

+ type RemoteReactionRemove interface

+ GetRemovedEmojiID func() networkid.EmojiID

+ type RemoteReactionWithExtraContent interface

+ GetReactionExtraContent func() map[string]any

+ type RemoteReactionWithMeta interface

+ GetReactionDBMetadata func() any

+ type RemoteReceipt interface

+ GetLastReceiptTarget func() networkid.MessageID

+ GetReadUpTo func() time.Time

+ GetReceiptTargets func() []networkid.MessageID

+ type RemoteTyping interface

+ GetTimeout func() time.Duration

+ type RemoteTypingWithType interface

+ GetTypingType func() TypingType

+ type ResolveIdentifierResponse struct

+ Chat *CreateChatResponse

+ Ghost *Ghost

+ UserID networkid.UserID

+ UserInfo *UserInfo

+ type RoomAvatarHandlingNetworkAPI interface

+ HandleMatrixRoomAvatar func(ctx context.Context, msg *MatrixRoomAvatar) (bool, error)

+ type RoomMetaEventContent interface

+ type RoomNameHandlingNetworkAPI interface

+ HandleMatrixRoomName func(ctx context.Context, msg *MatrixRoomName) (bool, error)

+ type RoomTopicHandlingNetworkAPI interface

+ HandleMatrixRoomTopic func(ctx context.Context, msg *MatrixRoomTopic) (bool, error)

+ type SimpleRemoteEvent struct

+ ChatInfoChange *ChatInfoChange

+ ConvertEditFunc func(ctx context.Context, portal *Portal, intent MatrixAPI, ...) (*ConvertedEdit, error)

+ ConvertMessageFunc func(ctx context.Context, portal *Portal, intent MatrixAPI, data T) (*ConvertedMessage, error)

+ CreatePortal bool

+ Data T

+ Emoji string

+ EmojiID networkid.EmojiID

+ ID networkid.MessageID

+ LogContext func(c zerolog.Context) zerolog.Context

+ PortalKey networkid.PortalKey

+ ReactionDBMeta any

+ Sender EventSender

+ TargetMessage networkid.MessageID

+ Timestamp time.Time

+ Type RemoteEventType

+ func (sre *SimpleRemoteEvent[T]) AddLogContext(c zerolog.Context) zerolog.Context

+ func (sre *SimpleRemoteEvent[T]) ConvertEdit(ctx context.Context, portal *Portal, intent MatrixAPI, ...) (*ConvertedEdit, error)

+ func (sre *SimpleRemoteEvent[T]) ConvertMessage(ctx context.Context, portal *Portal, intent MatrixAPI) (*ConvertedMessage, error)

+ func (sre *SimpleRemoteEvent[T]) GetChatInfoChange(ctx context.Context) (*ChatInfoChange, error)

+ func (sre *SimpleRemoteEvent[T]) GetID() networkid.MessageID

+ func (sre *SimpleRemoteEvent[T]) GetPortalKey() networkid.PortalKey

+ func (sre *SimpleRemoteEvent[T]) GetReactionDBMetadata() any

+ func (sre *SimpleRemoteEvent[T]) GetReactionEmoji() (string, networkid.EmojiID)

+ func (sre *SimpleRemoteEvent[T]) GetRemovedEmojiID() networkid.EmojiID

+ func (sre *SimpleRemoteEvent[T]) GetSender() EventSender

+ func (sre *SimpleRemoteEvent[T]) GetTargetMessage() networkid.MessageID

+ func (sre *SimpleRemoteEvent[T]) GetTimestamp() time.Time

+ func (sre *SimpleRemoteEvent[T]) GetType() RemoteEventType

+ func (sre *SimpleRemoteEvent[T]) ShouldCreatePortal() bool

+ type TypingHandlingNetworkAPI interface

+ HandleMatrixTyping func(ctx context.Context, msg *MatrixTyping) error

+ type TypingType int

+ const TypingTypeRecordingMedia

+ const TypingTypeText

+ const TypingTypeUploadingMedia

+ type User struct

+ Bridge *Bridge

+ CommandState unsafe.Pointer

+ Log zerolog.Logger

+ Permissions bridgeconfig.Permissions

+ func (user *User) DoublePuppet(ctx context.Context) MatrixAPI

+ func (user *User) GetCachedUserLogins() []*UserLogin

+ func (user *User) GetDefaultLogin() *UserLogin

+ func (user *User) GetFormattedUserLogins() string

+ func (user *User) GetManagementRoom(ctx context.Context) (id.RoomID, error)

+ func (user *User) GetUserLoginIDs() []networkid.UserLoginID

+ func (user *User) LoginDoublePuppet(ctx context.Context, token string) error

+ func (user *User) LogoutDoublePuppet(ctx context.Context)

+ func (user *User) NewLogin(ctx context.Context, data *database.UserLogin, params *NewLoginParams) (*UserLogin, error)

+ func (user *User) Save(ctx context.Context) error

+ type UserInfo struct

+ Avatar *Avatar

+ ExtraUpdates func(context.Context, *Ghost) bool

+ Identifiers []string

+ IsBot *bool

+ Name *string

+ type UserLocalPortalInfo struct

+ MutedUntil *time.Time

+ Tag *event.RoomTag

+ type UserLogin struct

+ Bridge *Bridge

+ BridgeState *BridgeStateQueue

+ Client NetworkAPI

+ Log zerolog.Logger

+ User *User

+ func (ul *UserLogin) AddPortalToSpace(ctx context.Context, portal *Portal, userPortal *database.UserPortal) error

+ func (ul *UserLogin) Delete(ctx context.Context, state status.BridgeState, logoutRemote bool)

+ func (ul *UserLogin) Disconnect(done func())

+ func (ul *UserLogin) GetMXID() id.UserID

+ func (ul *UserLogin) GetRemoteID() string

+ func (ul *UserLogin) GetRemoteName() string

+ func (ul *UserLogin) GetSpaceRoom(ctx context.Context) (id.RoomID, error)

+ func (ul *UserLogin) Logout(ctx context.Context)

+ func (ul *UserLogin) MarkAsPreferredIn(ctx context.Context, portal *Portal) error

+ func (ul *UserLogin) MarkInPortal(ctx context.Context, portal *Portal)

+ func (ul *UserLogin) Save(ctx context.Context) error

+ type UserSearchingNetworkAPI interface

+ SearchUsers func(ctx context.Context, query string) ([]*ResolveIdentifierResponse, error)

+ type WebPushConfig struct

+ VapidKey string

v0.19.0-beta.1

Jun 16, 2024

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