wecom

package

v0.4.0 Latest Latest Go to latest Published: Apr 29, 2026 License: MIT Imports: 25 Imported by: 0

Details

This section is empty.

This section is empty.

func New(opts map[string]any) (channel.Channel, error)

New creates a WeCom channel adapter.

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

HTTPChannel implements channel.Channel for WeCom HTTP webhook.

func (p *HTTPChannel) Name() string

func (p *HTTPChannel) ReconstructReplyCtx(sessionKey string) (any, error)

func (p *HTTPChannel) RegisterHTTPRoutes(r chi.Router, callbackPath string, handler channel.MessageHandler)

func (p *HTTPChannel) Reply(ctx context.Context, rctx any, content string) error

func (p *HTTPChannel) Send(ctx context.Context, rctx any, content string) error

func (p *HTTPChannel) Start(handler channel.MessageHandler) error

func (p *HTTPChannel) Stop() error

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

WSChannel implements channel.Channel using WeChat Work WebSocket long-connection mode.

func (p *WSChannel) AppendStream(ctx context.Context, rctx any, streamID string, content string) error

AppendStream appends content to an existing stream.

func (p *WSChannel) FinishStream(ctx context.Context, rctx any, streamID string, finalContent string) error

FinishStream ends the streaming message with final content.

func (p *WSChannel) Name() string

func (p *WSChannel) ReconstructReplyCtx(sessionKey string) (any, error)

func (p *WSChannel) Reply(ctx context.Context, rctx any, content string) error

func (p *WSChannel) Send(ctx context.Context, rctx any, content string) error

func (p *WSChannel) Start(handler channel.MessageHandler) error

func (p *WSChannel) StartStream(ctx context.Context, rctx any, content string) (string, error)

StartStream starts a new streaming message, returns the stream ID.

func (p *WSChannel) Stop() error