connector

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Feb 16, 2025 License: AGPL-3.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	LoginFlowIDToken = "token"

	LoginStepToken    = "me.lxduo.pylon.login.token"
	LoginStepComplete = "me.lxduo.pylon.login.complete"
)
View Source 
const (
	DirectChatTopic = "Pylon direct chat"
)
View Source 
const MaxFileSize = 128 * 1024 * 1024
View Source 
const MaxImageSize = 128 * 1024 * 1024
View Source 
const MaxTextLength = 4096

Variables

View Source 
var ExampleConfig string

Functions

This section is empty.

Types

type Config 

type Config struct {
	DisplaynameTemplate string `yaml:"displayname_template"`

	Onebot struct {
		Endpoint       string        `yaml:"endpoint"`
		RequestTimeout time.Duration `yaml:"request_timeout"`
	} `yaml:"onebot"`
	// contains filtered or unexported fields
}

func (*Config) FormatDisplayname 

func (c *Config) FormatDisplayname(params DisplaynameParams) string

func (*Config) PostProcess 

func (c *Config) PostProcess() error

func (*Config) UnmarshalYAML 

func (c *Config) UnmarshalYAML(node *yaml.Node) error

type DisplaynameParams 

type DisplaynameParams struct {
	Alias string
	Name  string
	ID    string
}

type GhostMetadata 

type GhostMetadata struct {
	LastSync jsontime.Unix `json:"last_sync,omitempty"`
}

type OnebotMessageEvent 

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

func (*OnebotMessageEvent) AddLogContext 

func (evt *OnebotMessageEvent) AddLogContext(c zerolog.Context) zerolog.Context

func (*OnebotMessageEvent) ConvertMessage 

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

func (*OnebotMessageEvent) GetChatInfo 

func (evt *OnebotMessageEvent) GetChatInfo(ctx context.Context, portal *bridgev2.Portal) (*bridgev2.ChatInfo, error)

func (*OnebotMessageEvent) GetID 

func (evt *OnebotMessageEvent) GetID() networkid.MessageID

func (*OnebotMessageEvent) GetPortalKey 

func (evt *OnebotMessageEvent) GetPortalKey() networkid.PortalKey

func (*OnebotMessageEvent) GetSender 

func (evt *OnebotMessageEvent) GetSender() bridgev2.EventSender

func (*OnebotMessageEvent) GetTargetMessage 

func (evt *OnebotMessageEvent) GetTargetMessage() networkid.MessageID

func (*OnebotMessageEvent) GetTimestamp 

func (evt *OnebotMessageEvent) GetTimestamp() time.Time

func (*OnebotMessageEvent) GetType 

func (evt *OnebotMessageEvent) GetType() bridgev2.RemoteEventType

func (*OnebotMessageEvent) PostHandle 

func (evt *OnebotMessageEvent) PostHandle(ctx context.Context, portal *bridgev2.Portal)

func (*OnebotMessageEvent) ShouldCreatePortal 

func (evt *OnebotMessageEvent) ShouldCreatePortal() bool

type PortalMetadata 

type PortalMetadata struct {
	LastSync jsontime.Unix `json:"last_sync,omitempty"`
}

type PylonClient 

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

func (*PylonClient) Connect 

func (pc *PylonClient) Connect(ctx context.Context)

func (*PylonClient) Disconnect 

func (pc *PylonClient) Disconnect()

func (*PylonClient) EnqueueGhostResync 

func (pc *PylonClient) EnqueueGhostResync(ghost *bridgev2.Ghost)

func (*PylonClient) EnqueuePortalResync 

func (pc *PylonClient) EnqueuePortalResync(portal *bridgev2.Portal)

func (*PylonClient) GetCapabilities 

func (pc *PylonClient) GetCapabilities(ctx context.Context, portal *bridgev2.Portal) *event.RoomFeatures

func (*PylonClient) GetChatInfo 

func (pc *PylonClient) GetChatInfo(ctx context.Context, portal *bridgev2.Portal) (*bridgev2.ChatInfo, error)

func (*PylonClient) GetUserInfo 

func (pc *PylonClient) GetUserInfo(ctx context.Context, ghost *bridgev2.Ghost) (*bridgev2.UserInfo, error)

func (*PylonClient) HandleMatrixMessage 

func (pc *PylonClient) HandleMatrixMessage(ctx context.Context, msg *bridgev2.MatrixMessage) (*bridgev2.MatrixMessageResponse, error)

func (*PylonClient) HandleMatrixMessageRemove 

func (pc *PylonClient) HandleMatrixMessageRemove(ctx context.Context, msg *bridgev2.MatrixMessageRemove) error

func (*PylonClient) IsLoggedIn 

func (pc *PylonClient) IsLoggedIn() bool

func (*PylonClient) IsThisUser 

func (pc *PylonClient) IsThisUser(ctx context.Context, userID networkid.UserID) bool

func (*PylonClient) LogoutRemote 

func (pc *PylonClient) LogoutRemote(ctx context.Context)

func (*PylonClient) ResolveIdentifier 

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

type PylonConnector 

type PylonConnector struct {
	Bridge  *bridgev2.Bridge
	Config  Config
	MsgConv *msgconv.MessageConverter
	Service *onebot.Service
}

func (*PylonConnector) CreateLogin 

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

func (*PylonConnector) GetBridgeInfoVersion 

func (pc *PylonConnector) GetBridgeInfoVersion() (info, caps int)

func (*PylonConnector) GetCapabilities 

func (pc *PylonConnector) GetCapabilities() *bridgev2.NetworkGeneralCapabilities

func (*PylonConnector) GetConfig 

func (pc *PylonConnector) GetConfig() (example string, data any, upgrader up.Upgrader)

func (*PylonConnector) GetDBMetaTypes 

func (pc *PylonConnector) GetDBMetaTypes() database.MetaTypes

func (*PylonConnector) GetLoginFlows 

func (pc *PylonConnector) GetLoginFlows() []bridgev2.LoginFlow

func (*PylonConnector) GetName 

func (pc *PylonConnector) GetName() bridgev2.BridgeName

func (*PylonConnector) Init 

func (pc *PylonConnector) Init(bridge *bridgev2.Bridge)

func (*PylonConnector) LoadUserLogin 

func (pc *PylonConnector) LoadUserLogin(ctx context.Context, login *bridgev2.UserLogin) error

func (*PylonConnector) SetMaxFileSize 

func (pc *PylonConnector) SetMaxFileSize(maxSize int64)

func (*PylonConnector) Start 

func (pc *PylonConnector) Start(ctx context.Context) error

func (*PylonConnector) Stop 

func (pc *PylonConnector) Stop()

type TokenLogin 

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

func (*TokenLogin) Cancel 

func (tl *TokenLogin) Cancel()

func (*TokenLogin) Start 

func (tl *TokenLogin) Start(ctx context.Context) (*bridgev2.LoginStep, error)

func (*TokenLogin) Wait 

func (tl *TokenLogin) Wait(ctx context.Context) (*bridgev2.LoginStep, error)

type UserLoginMetadata 

type UserLoginMetadata struct {
	Token string `json:"token"`
}

Source Files

View all Source files

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.