base

type Adapter ¶

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

Adapter is the base adapter implementing common functionality

func NewAdapter(
	platform string,
	config Config,
	logger *slog.Logger,
	opts ...AdapterOption,
) *Adapter

func (a *Adapter) GetOrCreateSession(key, userID string) string

func (a *Adapter) GetSession(key string) (*Session, bool)

func (a *Adapter) HandleMessage(ctx context.Context, msg *ChatMessage) error

func (a *Adapter) Handler() MessageHandler

func (a *Adapter) Logger() *slog.Logger

func (a *Adapter) Platform() string

func (a *Adapter) SendMessage(ctx context.Context, sessionID string, msg *ChatMessage) error

func (a *Adapter) SetHandler(handler MessageHandler)

func (a *Adapter) SetLogger(logger *slog.Logger)

func (a *Adapter) Start(ctx context.Context) error

func (a *Adapter) Stop() error

func (a *Adapter) SystemPrompt() string

func (a *Adapter) WebhookHandler() http.Handler

func (a *Adapter) WebhookPath() string

type AdapterOption ¶

type AdapterOption func(*Adapter)

AdapterOption configures the base adapter

func WithHTTPHandler(path string, handler http.HandlerFunc) AdapterOption

func WithMessageParser(parser MessageParser) AdapterOption

func WithMessageSender(sender MessageSender) AdapterOption

func WithMetadataExtractor(extractor MetadataExtractor) AdapterOption

func WithSessionTimeout(timeout time.Duration) AdapterOption

func WithoutServer() AdapterOption

type Attachment ¶

type Attachment struct {
	Type     string `json:"type"`
	URL      string `json:"url"`
	Title    string `json:"title"`
	Text     string `json:"text"`
	ThumbURL string `json:"thumb_url,omitempty"`
}

type ChatAdapter ¶

type ChatAdapter interface {
	Platform() string
	SystemPrompt() string
	Start(ctx context.Context) error
	Stop() error
	SendMessage(ctx context.Context, sessionID string, msg *ChatMessage) error
	HandleMessage(ctx context.Context, msg *ChatMessage) error
	SetHandler(MessageHandler)
}

type ChatMessage ¶

type ChatMessage struct {
	Platform    string
	SessionID   string
	UserID      string
	Content     string
	MessageID   string
	Timestamp   time.Time
	Metadata    map[string]any
	RichContent *RichContent
}

type Config ¶

type Config struct {
	ServerAddr   string
	SystemPrompt string
}

Config is the common configuration for all adapters

type HTTPClient ¶

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

HTTPClient provides common HTTP request patterns for chat adapters. This eliminates the duplicate HTTP request building code across adapters.

func NewHTTPClient() *HTTPClient

func NewHTTPClientWithConfig(timeout time.Duration, maxRetries int) *HTTPClient

func (c *HTTPClient) Get(ctx context.Context, url string, headers map[string]string) ([]byte, error)

func (c *HTTPClient) PostJSON(ctx context.Context, url string, payload any, headers map[string]string) ([]byte, error)

func (c *HTTPClient) PostJSONWithResponse(ctx context.Context, url string, payload any, headers map[string]string, dest any) error

type MessageHandler ¶

type MessageHandler func(ctx context.Context, msg *ChatMessage) error

type MessageParser ¶

type MessageParser func(body []byte, metadata map[string]any) (*ChatMessage, error)

MessageParser parses incoming requests into ChatMessage

type MessageSender ¶

type MessageSender func(ctx context.Context, sessionID string, msg *ChatMessage) error

MessageSender sends messages to the platform

type MetadataExtractor ¶

type MetadataExtractor func(update any) map[string]any

MetadataExtractor extracts platform-specific metadata from incoming requests

type ParseMode ¶

type ParseMode string

const (
	ParseModeNone     ParseMode = ""
	ParseModeMarkdown ParseMode = "markdown"
	ParseModeHTML     ParseMode = "html"
)

type RichContent ¶

type RichContent struct {
	ParseMode      ParseMode
	InlineKeyboard any
	Blocks         []any
	Embeds         []any
	Attachments    []Attachment
}

type SenderFunc ¶

type SenderFunc func(ctx context.Context, sessionID string, msg *ChatMessage) error

SenderFunc is the function signature for sending messages to a platform.

type SenderWithMutex ¶

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

SenderWithMutex provides thread-safe sender management for chat adapters. This eliminates the duplicate sender/senderMu pattern across all adapters.

func NewSenderWithMutex() *SenderWithMutex

func NewSenderWithMutexFunc(sender SenderFunc) *SenderWithMutex

func (s *SenderWithMutex) HasSender() bool

func (s *SenderWithMutex) SendMessage(ctx context.Context, sessionID string, msg *ChatMessage) error

func (s *SenderWithMutex) Sender() SenderFunc

func (s *SenderWithMutex) SetSender(fn SenderFunc)

type Session ¶

type Session struct {
	SessionID  string
	UserID     string
	Platform   string
	LastActive time.Time
}

Session represents a user session in a chat platform

type WebhookProvider ¶

type WebhookProvider interface {
	WebhookPath() string
	WebhookHandler() http.Handler
}

WebhookProvider exposes HTTP handlers for unified server integration

type WebhookRunner ¶

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

WebhookRunner manages the lifecycle of webhook processing goroutines. This eliminates the duplicate webhookWg pattern across all adapters.

func NewWebhookRunner(logger *slog.Logger) *WebhookRunner

func (r *WebhookRunner) Run(ctx context.Context, handler MessageHandler, msg *ChatMessage)

func (r *WebhookRunner) Stop() bool

func (r *WebhookRunner) Wait(timeout time.Duration) bool

func (r *WebhookRunner) WaitDefault() bool