chatapps

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

type AdapterMetrics struct {
	MessagesReceived atomic.Int64
	MessagesSent     atomic.Int64
	MessagesFailed   atomic.Int64
	LastMessageAt    atomic.Int64
	Uptime           atomic.Int64
}

type Attachment struct {
	Type     string `json:"type"`                // image, file, audio
	URL      string `json:"url"`                 // URL to the content
	Title    string `json:"title"`               // Optional title
	Text     string `json:"text"`                // Optional description
	ThumbURL string `json:"thumb_url,omitempty"` // Thumbnail for images
}

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
}

type ChatMessage struct {
	Platform    string
	SessionID   string
	UserID      string
	Content     string
	MessageID   string
	Timestamp   time.Time
	Metadata    map[string]any
	RichContent *RichContent `json:"rich_content,omitempty"` // Optional rich content
}

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

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

type DingTalkCallbackRequest struct {
	MsgType        string `json:"msgtype"`
	ConversationID string `json:"conversationId"`
	SenderID       string `json:"senderId"`
	SenderNick     string `json:"senderNick"`
	IsAdmin        bool   `json:"isAdmin"`
	RobotCode      string `json:"robotCode"`
	Text           struct {
		Content string `json:"content"`
	} `json:"text"`
	EventType string `json:"eventType"`
}

type DingTalkCallbackResponse struct {
	MsgType string `json:"msgtype"`
	Text    struct {
		Content string `json:"content"`
	} `json:"text"`
}

type DingTalkConfig struct {
	AppID         string
	AppSecret     string
	CallbackURL   string
	CallbackToken string
	CallbackKey   string
	ServerAddr    string
	MaxMessageLen int // Maximum message length (default 5000 for DingTalk)
	SystemPrompt  string
}

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

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

type DiscordConfig struct {
	BotToken     string // Discord Bot Token
	ServerAddr   string
	PublicKey    string // For interaction verification
	SystemPrompt string // Custom system prompt for the AI agent
}

type DiscordEmbed struct {
	Title       string                 `json:"title,omitempty"`
	Description string                 `json:"description,omitempty"`
	URL         string                 `json:"url,omitempty"`
	Color       int                    `json:"color,omitempty"`
	Fields      []DiscordEmbedField    `json:"fields,omitempty"`
	Footer      *DiscordEmbedFooter    `json:"footer,omitempty"`
	Thumbnail   *DiscordEmbedThumbnail `json:"thumbnail,omitempty"`
	Image       *DiscordEmbedImage     `json:"image,omitempty"`
	Timestamp   string                 `json:"timestamp,omitempty"`
}

type DiscordEmbedField struct {
	Name   string `json:"name"`
	Value  string `json:"value"`
	Inline bool   `json:"inline,omitempty"`
}

type DiscordEmbedFooter struct {
	Text    string `json:"text"`
	IconURL string `json:"icon_url,omitempty"`
}

type DiscordEmbedImage struct {
	URL string `json:"url"`
}

type DiscordEmbedThumbnail struct {
	URL string `json:"url"`
}

type DiscordGuildMember struct {
	User struct {
		ID       string `json:"id"`
		Username string `json:"username"`
		Bot      bool   `json:"bot"`
	} `json:"user"`
	Nick     string   `json:"nick"`
	Roles    []string `json:"roles"`
	JoinedAt string   `json:"joined_at"`
}

type DiscordInteraction struct {
	Type    int             `json:"type"`
	Data    json.RawMessage `json:"data"`
	GuildID string          `json:"guild_id"`
	Channel string          `json:"channel_id"`
	Member  struct {
		User struct {
			ID       string `json:"id"`
			Username string `json:"username"`
		} `json:"user"`
	} `json:"member"`
	Message json.RawMessage `json:"message"`
}

type DiscordMessage struct {
	Content string `json:"content"`
}

type DiscordMessageResponse struct {
	ID        string `json:"id"`
	ChannelID string `json:"channel_id"`
	Content   string `json:"content"`
	Timestamp string `json:"timestamp"`
}

type DiscordSession struct {
	SessionID  string
	UserID     string
	ChannelID  string
	GuildID    string
	Platform   string
	LastActive time.Time
}

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

type EngineHolderOptions struct {
	Logger           *slog.Logger
	Adapters         *AdapterManager
	Timeout          time.Duration
	IdleTimeout      time.Duration
	Namespace        string
	PermissionMode   string
	AllowedTools     []string
	DisallowedTools  []string
	DefaultWorkDir   string
	DefaultTaskInstr string
}

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

type EngineMessageHandlerOption func(*EngineMessageHandler)

type HealthCheck struct {
	Name      string
	Status    string
	LastCheck time.Time
	LastError string
	Interval  time.Duration
	CheckFunc func() error
}

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

type InlineKeyboardButton struct {
	Text         string `json:"text"`
	URL          string `json:"url,omitempty"`
	CallbackData string `json:"callback_data,omitempty"`
}

type InlineKeyboardMarkup struct {
	InlineKeyboard [][]InlineKeyboardButton `json:"inline_keyboard"`
}

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

type Logger interface {
	Info(msg string, args ...any)
	Debug(msg string, args ...any)
	Error(msg string, args ...any)
	Warn(msg string, args ...any)
}

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

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

type ParseMode string

type PlatformConfig struct {
	Platform         string `yaml:"platform"`
	SystemPrompt     string `yaml:"system_prompt"`
	TaskInstructions string `yaml:"task_instructions"`

	// WhatsApp specific (optional)
	WhatsApp *WhatsAppAdapterConfig `yaml:"whatsapp,omitempty"`
}

type QueueError struct {
	Message string
}

type QueuedMessage struct {
	Platform  string
	SessionID string
	Message   *ChatMessage
	Retries   int
	CreatedAt time.Time
}

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

type RetryConfig struct {
	MaxAttempts int
	BaseDelay   time.Duration
	MaxDelay    time.Duration
}

type RichContent struct {
	// Formatting
	ParseMode ParseMode `json:"parse_mode,omitempty"`

	// Telegram specific
	InlineKeyboard *InlineKeyboardMarkup `json:"inline_keyboard,omitempty"`

	// Slack specific
	Blocks []SlackBlock `json:"blocks,omitempty"`

	// Discord specific
	Embeds []DiscordEmbed `json:"embeds,omitempty"`

	// Common attachments
	Attachments []Attachment `json:"attachments,omitempty"`
}

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

type SlackBlock map[string]any

type SlackConfig struct {
	BotToken      string // xoxb- token
	AppToken      string // xapp- token for Socket Mode
	SigningSecret string
	ServerAddr    string
	SystemPrompt  string
}

type SlackEvent struct {
	Token     string          `json:"token"`
	TeamID    string          `json:"team_id"`
	APIAppID  string          `json:"api_app_id"`
	Type      string          `json:"type"`
	EventID   string          `json:"event_id"`
	EventTime int64           `json:"event_time"`
	Event     json.RawMessage `json:"event"`
	Challenge string          `json:"challenge"`
}

type SlackEventResponse struct {
	Challenge string `json:"challenge"`
}

type SlackInteractivePayload struct {
	Type           string          `json:"type"`
	Challenge      string          `json:"challenge,omitempty"`
	Token          string          `json:"token"`
	TeamID         string          `json:"team_id"`
	TeamDomain     string          `json:"team_domain"`
	EnterpriseID   string          `json:"enterprise_id,omitempty"`
	EnterpriseName string          `json:"enterprise_name,omitempty"`
	ChannelID      string          `json:"channel_id"`
	ChannelName    string          `json:"channel_name"`
	UserID         string          `json:"user_id"`
	UserName       string          `json:"user_name"`
	Command        string          `json:"command,omitempty"`
	Text           string          `json:"text"`
	ResponseURL    string          `json:"response_url"`
	TriggerID      string          `json:"trigger_id"`
	View           json.RawMessage `json:"view,omitempty"`
}

type SlackMessageEvent struct {
	Type        string `json:"type"`
	Channel     string `json:"channel"`
	ChannelType string `json:"channel_type"`
	User        string `json:"user"`
	Text        string `json:"text"`
	TS          string `json:"ts"`
	EventTS     string `json:"event_ts"`
	BotID       string `json:"bot_id,omitempty"`
	SubType     string `json:"subtype,omitempty"`
}

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

type StreamAdapter interface {
	ChatAdapter
	// SendStreamMessage sends a message and returns a stream handler for updates
	SendStreamMessage(ctx context.Context, sessionID string, msg *ChatMessage) (StreamHandler, error)
	// UpdateMessage updates an existing message (for edit support)
	UpdateMessage(ctx context.Context, sessionID, messageID string, msg *ChatMessage) error
}

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

type StreamHandler func(ctx context.Context, sessionID string, chunk string, isFinal bool) error

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

type TelegramConfig struct {
	BotToken     string // Bot Token from @BotFather
	WebhookURL   string // Public URL for webhook
	ServerAddr   string // Local server address
	SecretToken  string // Secret token for webhook verification (required for security)
	SystemPrompt string // Custom system prompt for the AI agent
}

type TelegramMessageResponse struct {
	OK     bool         `json:"ok"`
	Result *TelegramMsg `json:"result"`
}

type TelegramMsg struct {
	MessageID int64 `json:"message_id"`
	Chat      struct {
		ID int64 `json:"id"`
	} `json:"chat"`
	Date int64  `json:"date"`
	Text string `json:"text"`
}

type TelegramSession struct {
	SessionID  string
	UserID     string
	ChatID     int64
	Platform   string
	LastActive time.Time
}

type TelegramUpdate struct {
	UpdateID int64 `json:"update_id"`
	Message  struct {
		MessageID int64 `json:"message_id"`
		From      struct {
			ID        int64  `json:"id"`
			FirstName string `json:"first_name"`
			LastName  string `json:"last_name"`
			Username  string `json:"username"`
		} `json:"from"`
		Chat struct {
			ID    int64  `json:"id"`
			Type  string `json:"type"`
			Title string `json:"title,omitempty"`
		} `json:"chat"`
		Date     int64  `json:"date"`
		Text     string `json:"text"`
		Entities []struct {
			Type   string `json:"type"`
			Offset int    `json:"offset"`
			Length int    `json:"length"`
		} `json:"entities,omitempty"`
	} `json:"message"`
	CallbackQuery *struct {
		ID   string `json:"id"`
		From struct {
			ID        int64  `json:"id"`
			FirstName string `json:"first_name"`
			LastName  string `json:"last_name"`
			Username  string `json:"username"`
		} `json:"from"`
		Message struct {
			Chat struct {
				ID int64 `json:"id"`
			} `json:"chat"`
			MessageID int64  `json:"message_id"`
			Data      string `json:"data"`
		} `json:"message,omitempty"`
	} `json:"callback_query,omitempty"`
}

type TelegramWebhookResponse struct {
	OK          bool   `json:"ok"`
	Description string `json:"description"`
}

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

type WhatsAppAdapterConfig struct {
	PhoneNumberID string `yaml:"phone_number_id"`
	AccessToken   string `yaml:"access_token"`
	VerifyToken   string `yaml:"verify_token"`
	ServerAddr    string `yaml:"server_addr"`
	APIVersion    string `yaml:"api_version"`
}

type WhatsAppConfig struct {
	PhoneNumberID string
	AccessToken   string
	VerifyToken   string
	ServerAddr    string
	APIVersion    string
	SystemPrompt  string
}

type WhatsAppIncomingMessage struct {
	Object string `json:"object"`
	Entry  []struct {
		ID      string `json:"id"`
		Changes []struct {
			Value struct {
				MessagingProduct string `json:"messaging_product"`
				Metadata         struct {
					DisplayPhoneNumber string `json:"display_phone_number"`
					PhoneNumberID      string `json:"phone_number_id"`
				} `json:"metadata"`
				Messages []struct {
					From string `json:"from"`
					ID   string `json:"id"`
					Text struct {
						Body string `json:"body"`
					} `json:"text"`
					Type string `json:"type"`
				} `json:"messages"`
			} `json:"value"`
		} `json:"changes"`
	} `json:"entry"`
}

type WhatsAppResponse struct {
	MessagingProduct string            `json:"messaging_product"`
	To               string            `json:"to"`
	Type             string            `json:"type"`
	Text             *WhatsAppTextBody `json:"text,omitempty"`
}

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

type WhatsAppTextBody struct {
	Body string `json:"body"`
}