imbridge

May 2, 2026

Changes in this version

type Bridge

+ func (b *Bridge) SetChannelRoutingMode(channelID, mode string)

Apr 17, 2026

Changes in this version

type BridgeBinding

+ RoutingMode string

+ WorkspaceID string

Apr 8, 2026

Changes in this version

type InboundMessage

+ QuotedMediaData []byte

+ QuotedMediaFilename string

+ QuotedMediaType string

+ QuotedSender string

+ QuotedText string

type MatrixMessage

+ QuotedMediaData []byte

+ QuotedMediaFilename string

+ QuotedMediaType string

+ QuotedSender string

+ QuotedText string

type TelegramMessage

+ ReplyToMessage *TelegramMessage

Mar 30, 2026

Changes in this version

type Bridge

+ func (b *Bridge) SetChannelRequireMention(channelID string, requireMention bool)

Mar 30, 2026

Changes in this version

+ const TelegramDefaultBaseURL

+ func MatrixSendImage(ctx context.Context, homeserverURL, accessToken, roomID string, ...) error

+ func MatrixSendText(ctx context.Context, homeserverURL, accessToken, roomID, text string) error

+ func MatrixSendTyping(ctx context.Context, homeserverURL, accessToken, userID, roomID string, ...) error

+ func MatrixWhoami(ctx context.Context, homeserverURL, accessToken string) (string, error)

+ func TelegramGetFile(ctx context.Context, baseURL, botToken, fileID string) ([]byte, error)

+ func TelegramSendChatAction(ctx context.Context, baseURL, botToken string, chatID int64, action string) error

+ func TelegramSendMessage(ctx context.Context, baseURL, botToken string, chatID int64, text string) error

+ func TelegramSendPhoto(ctx context.Context, baseURL, botToken string, chatID int64, photoData []byte, ...) error

+ type Bridge struct

+ func NewBridge(db BridgeDB, resolver SandboxResolver, exec ExecCommander, ...) *Bridge

+ func (b *Bridge) FindProviderByJID(jid string) Provider

+ func (b *Bridge) GetProvider(name string) Provider

+ func (b *Bridge) Providers() []Provider

+ func (b *Bridge) StartPoller(binding BridgeBinding)

+ func (b *Bridge) StopAllPollers()

+ func (b *Bridge) StopPoller(channelID string)

+ func (b *Bridge) StopTyping(channelID, userID string)

+ type BridgeBinding struct

+ ChannelID string

+ Credentials Credentials

+ Cursor string

+ Provider Provider

+ RequireMention bool

+ type BridgeDB interface

+ GetAllChannelMeta func(channelID, userID string) (map[string]string, error)

+ GetChannelMeta func(channelID, userID, key string) (string, error)

+ GetSandboxForChannel func(channelID string) (sandboxID, podIP, bridgeSecret string, err error)

+ UpdateIMChannelCursor func(channelID, cursor string) error

+ UpsertChannelMeta func(channelID, userID, key, value string) error

+ type ConfigurableProvider interface

+ ValidateCredentials func(ctx context.Context, baseURL, token string) (botID string, err error)

+ type Credentials struct

+ BaseURL string

+ BotID string

+ BotToken string

+ ChannelID string

+ type DisconnectProvider interface

+ Disconnect func(sandboxID, botID string)

+ type ExecCommander interface

+ ExecSimple func(ctx context.Context, sandboxID string, command []string) (string, error)

+ type ImageSendProvider interface

+ SendImage func(ctx context.Context, creds *Credentials, toUserID string, imageData []byte, ...) error

+ type InboundMessage struct

+ FromUserID string

+ IsGroup bool

+ MediaData []byte

+ MediaFilename string

+ MediaType string

+ Metadata map[string]string

+ SenderName string

+ Text string

+ type InitializableProvider interface

+ InitProvider func(dbURL string) error

+ type MatrixCryptoClient struct

+ func (cc *MatrixCryptoClient) SendImage(ctx context.Context, roomID string, imageData []byte, caption string) error

+ func (cc *MatrixCryptoClient) SendText(ctx context.Context, roomID, text string) error

+ func (cc *MatrixCryptoClient) SendTyping(ctx context.Context, roomID string, typing bool, timeoutMs int) error

+ func (cc *MatrixCryptoClient) SyncAndDecrypt(ctx context.Context, selfUserID string, since string, timeoutSec int, ...) ([]MatrixMessage, string, error)

+ type MatrixCryptoManager struct

+ func NewMatrixCryptoManager(mainDBURL string, encKey []byte) *MatrixCryptoManager

+ func (m *MatrixCryptoManager) GetOrCreate(ctx context.Context, creds *Credentials, recoveryKey string) (*MatrixCryptoClient, error)

+ func (m *MatrixCryptoManager) Remove(sandboxID, botID string)

+ type MatrixMessage struct

+ EventID string

+ IsDM bool

+ MediaData []byte

+ MediaFilename string

+ MediaType string

+ Mentioned bool

+ RoomID string

+ SenderID string

+ Text string

+ Timestamp int64

+ func MatrixSync(ctx context.Context, homeserverURL, accessToken, selfUserID, since string, ...) ([]MatrixMessage, string, error)

+ type MatrixProvider struct

+ CryptoManager *MatrixCryptoManager

+ func (p *MatrixProvider) ConfigureE2EE(ctx context.Context, creds *Credentials, recoveryKey string) error

+ func (p *MatrixProvider) Disconnect(sandboxID, botID string)

+ func (p *MatrixProvider) InitProvider(dbURL string) error

+ func (p *MatrixProvider) JIDSuffix() string

+ func (p *MatrixProvider) Name() string

+ func (p *MatrixProvider) Poll(ctx context.Context, creds *Credentials, cursor string) (*PollResult, error)

+ func (p *MatrixProvider) Send(ctx context.Context, creds *Credentials, toUserID, text string, ...) error

+ func (p *MatrixProvider) SendImage(ctx context.Context, creds *Credentials, toUserID string, imageData []byte, ...) error

+ func (p *MatrixProvider) StartTyping(ctx context.Context, creds *Credentials, userID string, meta map[string]string, ...)

+ func (p *MatrixProvider) ValidateCredentials(ctx context.Context, baseURL, token string) (string, error)

+ type PollResult struct

+ Messages []InboundMessage

+ NewCursor string

+ ShouldBackoff time.Duration

+ type Provider interface

+ JIDSuffix func() string

+ Name func() string

+ Poll func(ctx context.Context, creds *Credentials, cursor string) (*PollResult, error)

+ Send func(ctx context.Context, creds *Credentials, toUserID, text string, ...) error

+ type RateLimitError struct

+ RetryAfter time.Duration

+ func (e *RateLimitError) Error() string

+ type SandboxResolver interface

+ GetPodIP func(sandboxID string) string

+ type TelegramBotInfo struct

+ FirstName string

+ ID int64

+ IsBot bool

+ Username string

+ func TelegramGetMe(ctx context.Context, baseURL, botToken string) (*TelegramBotInfo, error)

+ type TelegramChat struct

+ ID int64

+ Type string

+ type TelegramDocument struct

+ FileID string

+ FileName string

+ FileSize int

+ FileUniqueID string

+ MimeType string

+ type TelegramMessage struct

+ Caption string

+ Chat TelegramChat

+ Document *TelegramDocument

+ From *TelegramUser

+ MessageID int64

+ Photo []TelegramPhoto

+ Text string

+ type TelegramPhoto struct

+ FileID string

+ FileSize int

+ FileUniqueID string

+ Height int

+ Width int

+ type TelegramProvider struct

+ func (p *TelegramProvider) DefaultBaseURL() string

+ func (p *TelegramProvider) JIDSuffix() string

+ func (p *TelegramProvider) Name() string

+ func (p *TelegramProvider) Poll(ctx context.Context, creds *Credentials, cursor string) (*PollResult, error)

+ func (p *TelegramProvider) Send(ctx context.Context, creds *Credentials, toUserID, text string, ...) error

+ func (p *TelegramProvider) SendImage(ctx context.Context, creds *Credentials, toUserID string, imageData []byte, ...) error

+ func (p *TelegramProvider) StartTyping(ctx context.Context, creds *Credentials, userID string, meta map[string]string, ...)

+ func (p *TelegramProvider) ValidateCredentials(ctx context.Context, baseURL, token string) (string, error)

+ type TelegramUpdate struct

+ Message *TelegramMessage

+ UpdateID int64

+ func TelegramGetUpdates(ctx context.Context, baseURL, botToken string, offset int64, timeout int) ([]TelegramUpdate, error)

+ type TelegramUser struct

+ FirstName string

+ ID int64

+ IsBot bool

+ LastName string

+ Username string

+ type TypingProvider interface

+ StartTyping func(ctx context.Context, creds *Credentials, userID string, meta map[string]string, ...)

+ type WeixinProvider struct

+ func (p *WeixinProvider) ClearSession(sandboxID string)

+ func (p *WeixinProvider) DefaultBaseURL() string

+ func (p *WeixinProvider) GetSession(sandboxID string) *weixin.Session

+ func (p *WeixinProvider) JIDSuffix() string

+ func (p *WeixinProvider) Name() string

+ func (p *WeixinProvider) Poll(ctx context.Context, creds *Credentials, cursor string) (*PollResult, error)

+ func (p *WeixinProvider) PollQRLogin(ctx context.Context, qrCode string) (*weixin.StatusResult, error)

+ func (p *WeixinProvider) Send(ctx context.Context, creds *Credentials, toUserID, text string, ...) error

+ func (p *WeixinProvider) SendImage(ctx context.Context, creds *Credentials, toUserID string, imageData []byte, ...) error

+ func (p *WeixinProvider) SetSession(sandboxID string, session *weixin.Session)

+ func (p *WeixinProvider) StartQRLogin(ctx context.Context) (*weixin.Session, error)

+ func (p *WeixinProvider) StartTyping(ctx context.Context, creds *Credentials, userID string, meta map[string]string, ...)

+ func (p *WeixinProvider) TakeSession(sandboxID string) *weixin.Session