qq

Documentation

Index

• type QQChannel
  • func NewQQChannel(cfg config.QQConfig, messageBus *bus.MessageBus) (*QQChannel, error)
  • func (c *QQChannel) Send(ctx context.Context, msg bus.OutboundMessage) error
  • func (c *QQChannel) SendMedia(ctx context.Context, msg bus.OutboundMediaMessage) error
  • func (c *QQChannel) Start(ctx context.Context) error
  • func (c *QQChannel) StartTyping(ctx context.Context, chatID string) (func(), error)
  • func (c *QQChannel) Stop(ctx context.Context) error

Types

type QQChannel

type QQChannel struct {
	*channels.BaseChannel
	// contains filtered or unexported fields
}

func NewQQChannel

func NewQQChannel(cfg config.QQConfig, messageBus *bus.MessageBus) (*QQChannel, error)

func (*QQChannel) Send

func (c *QQChannel) Send(ctx context.Context, msg bus.OutboundMessage) error

func (*QQChannel) SendMedia

func (c *QQChannel) SendMedia(ctx context.Context, msg bus.OutboundMediaMessage) error

SendMedia implements the channels.MediaSender interface. QQ RichMediaMessage requires an HTTP/HTTPS URL — local file paths are not supported. If part.Ref is already an http(s) URL it is used directly; otherwise we try the media store, and skip with a warning if the resolved path is not an HTTP URL.

func (*QQChannel) Start

func (c *QQChannel) Start(ctx context.Context) error

func (*QQChannel) StartTyping

func (c *QQChannel) StartTyping(ctx context.Context, chatID string) (func(), error)

StartTyping implements channels.TypingCapable. It sends an InputNotify (msg_type=6) immediately and re-sends every 8 seconds. The returned stop function is idempotent and cancels the goroutine.

func (*QQChannel) Stop

func (c *QQChannel) Stop(ctx context.Context) error