connector

package

v0.0.0-...-4a6319b Latest Latest Go to latest Published: May 17, 2025 License: AGPL-3.0 Imports: 17 Imported by: 0

Documentation ¶

Index ¶

func ConvertEditMessage(ctx context.Context, portal *bridgev2.Portal, intent bridgev2.MatrixAPI, ...) (*bridgev2.ConvertedEdit, error)
func ConvertMessage(ctx context.Context, portal *bridgev2.Portal, intent bridgev2.MatrixAPI, ...) (*bridgev2.ConvertedMessage, error)
type MessagesClient
type MessagesConnector
type MessagesLogin
type UserLoginMetadata

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ConvertEditMessage ¶

func ConvertEditMessage(ctx context.Context, portal *bridgev2.Portal, intent bridgev2.MatrixAPI, existing []*database.Message, data macos.Message) (*bridgev2.ConvertedEdit, error)

func ConvertMessage ¶

func ConvertMessage(ctx context.Context, portal *bridgev2.Portal, intent bridgev2.MatrixAPI, data macos.Message) (*bridgev2.ConvertedMessage, error)

Types ¶

type MessagesClient ¶

type MessagesClient struct {
	UserLogin                    *bridgev2.UserLogin
	MacOSMessagesClient          *macos.MacOSMessagesClient
	MacOSContactsClient          *macos.MacOSContactsClient
	MessagesDBWatcherStopChannel chan struct{}
	MessagesChannel              chan *macos.Message
	ReadReceiptsChannel          chan *macos.ReadReceipt
	HandleMessagesStopChannel    chan struct{}
	DryRun                       bool
}

func (*MessagesClient) Connect ¶

func (m *MessagesClient) Connect(ctx context.Context)

func (*MessagesClient) Disconnect ¶

func (m *MessagesClient) Disconnect()

func (*MessagesClient) GetCapabilities ¶

func (m *MessagesClient) GetCapabilities(ctx context.Context, portal *bridgev2.Portal) *event.RoomFeatures

func (*MessagesClient) GetChatInfo ¶

func (m *MessagesClient) GetChatInfo(ctx context.Context, portal *bridgev2.Portal) (*bridgev2.ChatInfo, error)

func (*MessagesClient) GetUserInfo ¶

func (m *MessagesClient) GetUserInfo(ctx context.Context, ghost *bridgev2.Ghost) (*bridgev2.UserInfo, error)

func (*MessagesClient) HandleAvatarOrMemberLeave ¶

func (m *MessagesClient) HandleAvatarOrMemberLeave(message *macos.Message)

func (*MessagesClient) HandleEdit ¶

func (m *MessagesClient) HandleEdit(message *macos.Message)

func (*MessagesClient) HandleMatrixMessage ¶

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

HandleMatrixMessage implements bridgev2.NetworkAPI.

func (*MessagesClient) HandleMember ¶

func (m *MessagesClient) HandleMember(message *macos.Message)

func (*MessagesClient) HandleMessage ¶

func (m *MessagesClient) HandleMessage(message *macos.Message)

func (*MessagesClient) HandleName ¶

func (m *MessagesClient) HandleName(message *macos.Message)

func (*MessagesClient) HandleNormalMessage ¶

func (m *MessagesClient) HandleNormalMessage(message *macos.Message)

func (*MessagesClient) HandleRetraction ¶

func (m *MessagesClient) HandleRetraction(message *macos.Message)

func (*MessagesClient) HandleTapback ¶

func (m *MessagesClient) HandleTapback(message *macos.Message)

func (*MessagesClient) HandleiMessage ¶

func (m *MessagesClient) HandleiMessage(message *macos.Message) error

func (*MessagesClient) HandleiMessageReadReceipt ¶

func (m *MessagesClient) HandleiMessageReadReceipt(readReciept *macos.ReadReceipt)

func (*MessagesClient) IsLoggedIn ¶

func (m *MessagesClient) IsLoggedIn() bool

func (*MessagesClient) IsThisUser ¶

func (m *MessagesClient) IsThisUser(ctx context.Context, userID networkid.UserID) bool

func (*MessagesClient) LogoutRemote ¶

func (m *MessagesClient) LogoutRemote(ctx context.Context)

func (*MessagesClient) PortalKeyFromMessage ¶

func (m *MessagesClient) PortalKeyFromMessage(message *macos.Message) networkid.PortalKey

func (*MessagesClient) QueueMemberChatInfoChange ¶

func (m *MessagesClient) QueueMemberChatInfoChange(portalKey networkid.PortalKey, messageGUID string, userID networkid.UserID, membership event.Membership)

func (*MessagesClient) QueueRemoteEventWrapper ¶

func (m *MessagesClient) QueueRemoteEventWrapper(evt bridgev2.RemoteEvent)

type MessagesConnector ¶

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

func (*MessagesConnector) CreateLogin ¶

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

func (*MessagesConnector) GetBridgeInfoVersion ¶

func (m *MessagesConnector) GetBridgeInfoVersion() (info int, capabilities int)

func (*MessagesConnector) GetCapabilities ¶

func (m *MessagesConnector) GetCapabilities() *bridgev2.NetworkGeneralCapabilities

func (*MessagesConnector) GetConfig ¶

func (m *MessagesConnector) GetConfig() (example string, data any, upgrader configupgrade.Upgrader)

func (*MessagesConnector) GetDBMetaTypes ¶

func (m *MessagesConnector) GetDBMetaTypes() database.MetaTypes

func (*MessagesConnector) GetLoginFlows ¶

func (m *MessagesConnector) GetLoginFlows() []bridgev2.LoginFlow

func (*MessagesConnector) GetName ¶

func (m *MessagesConnector) GetName() bridgev2.BridgeName

func (*MessagesConnector) Init ¶

func (m *MessagesConnector) Init(b *bridgev2.Bridge)

func (*MessagesConnector) LoadUserLogin ¶

func (m *MessagesConnector) LoadUserLogin(ctx context.Context, login *bridgev2.UserLogin) (err error)

func (*MessagesConnector) Start ¶

func (m *MessagesConnector) Start(context.Context) error

type MessagesLogin ¶

type MessagesLogin struct {
	User      *bridgev2.User
	Connector *MessagesConnector
	UserID    string
}

func (*MessagesLogin) Cancel ¶

func (m *MessagesLogin) Cancel()

func (*MessagesLogin) Start ¶

func (m *MessagesLogin) Start(ctx context.Context) (*bridgev2.LoginStep, error)

func (*MessagesLogin) SubmitUserInput ¶

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

type UserLoginMetadata ¶

type UserLoginMetadata struct {
	UserID string `json:"user_id"`
}

Source Files ¶

View all Source files

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