types

type BatchConfig struct {
	DelayMs            time.Duration
	LongThresholdChars int
	LongDelayMs        time.Duration
	MaxMessages        int
	MaxChars           int
}

type BatchedDispatch struct {
	Message   *NormalizedMessage
	SourceIDs []string
}

type BotAddedEvent struct {
	EventID      string      `json:"event_id"`
	ChatID       string      `json:"chat_id"`
	ChatName     string      `json:"chat_name"`
	UserID       string      `json:"user_id"` // User who added the bot
	CreateTimeMs int64       `json:"create_time_ms"`
	RawEvent     interface{} `json:"raw_event"`
}

type BotIdentity struct {
	OpenID         string
	UserID         string // Optional
	Name           string
	ActivateStatus int
}

type BotIdentityCacheConfig struct {
	TTL                time.Duration
	MinRefreshInterval time.Duration
}

type CardActionContext struct {
	URL           string `json:"url,omitempty"`
	PreviewToken  string `json:"preview_token,omitempty"`
	OpenMessageID string `json:"open_message_id,omitempty"`
	OpenChatID    string `json:"open_chat_id,omitempty"`
}

type CardActionEvent struct {
	EventID      string             `json:"event_id"`
	MessageID    string             `json:"message_id"`
	ChatID       string             `json:"chat_id"`
	Token        string             `json:"token,omitempty"`
	Host         string             `json:"host,omitempty"`
	DeliveryType string             `json:"delivery_type,omitempty"`
	Operator     CardActionOperator `json:"operator"`
	Action       CardActionPayload  `json:"action"`
	Context      CardActionContext  `json:"context"`
	RawEvent     interface{}        `json:"raw_event"`
}

type CardActionOperator struct {
	OpenID    string `json:"open_id,omitempty"`
	UserID    string `json:"user_id,omitempty"`
	TenantKey string `json:"tenant_key,omitempty"`
}

type CardActionPayload struct {
	Value      map[string]interface{} `json:"value,omitempty"`
	Tag        string                 `json:"tag,omitempty"`
	Option     string                 `json:"option,omitempty"`
	Timezone   string                 `json:"timezone,omitempty"`
	Name       string                 `json:"name,omitempty"`
	FormValue  map[string]interface{} `json:"form_value,omitempty"`
	InputValue string                 `json:"input_value,omitempty"`
	Options    []string               `json:"options,omitempty"`
	Checked    bool                   `json:"checked,omitempty"`
}

type Channel interface {
	Send(ctx context.Context, input *SendInput) (*SendResult, error)
	OnMessage(handler func(ctx context.Context, msg *NormalizedMessage) error)
	OnReaction(handler func(ctx context.Context, event *ReactionEvent) error)
	OnComment(handler func(ctx context.Context, event *CommentEvent) error)
	OnBotAdded(handler func(ctx context.Context, event *BotAddedEvent) error)
	OnCardAction(handler func(ctx context.Context, event *CardActionEvent) error)
	OnReject(handler func(ctx context.Context, event *RejectEvent) error)

	// Media download
	DownloadFile(ctx context.Context, fileKey string, mediaType string) ([]byte, error)

	// Lifecycle hooks
	OnReady(handler func())
	OnError(handler func(err error))
	OnReconnecting(handler func())
	OnReconnected(handler func())
	OnDisconnected(handler func())

	// Lifecycle
	Start(ctx context.Context) error
	Stream(ctx context.Context, input *SendInput) (StreamController, error)
	UpdatePolicy(cfg PolicyConfig)
	GetPolicy() PolicyConfig

	// Fetch Bot Identity
	GetBotIdentity(ctx context.Context) *BotIdentity

	// Lifecycle
	Stop(ctx context.Context) error
}

type ChannelConfig struct {
	Safety           SafetyConfig
	Policy           PolicyConfig
	Outbound         OutboundConfig
	BotIdentityCache BotIdentityCacheConfig
}

type ChannelOption func(*ChannelConfig)

type CommentEvent struct {
	EventID      string       `json:"event_id"`
	CommentID    string       `json:"comment_id"`
	FileToken    string       `json:"file_token"`
	FileType     string       `json:"file_type"`
	Operator     OperatorInfo `json:"operator"`
	ReplyID      string       `json:"reply_id"`
	MentionedBot bool         `json:"mentioned_bot"`
	Timestamp    int64        `json:"timestamp"`
	RawEvent     interface{}  `json:"raw_event"`
}

type FeishuChannelError struct {
	Code    FeishuChannelErrorCode
	Message string
	Cause   error
	Context map[string]interface{}
}

type FeishuChannelErrorCode string

type MediaKind string

type Mention struct {
	Key    string `json:"key"`
	UserID string `json:"user_id"` // UserID if available
	OpenID string `json:"open_id"` // OpenID if available
	Name   string `json:"name"`
	IsBot  bool   `json:"is_bot"`
}

type NormalizedMessage struct {
	EventID        string      `json:"event_id"` // Original event ID for tracing/debugging
	MessageID      string      `json:"message_id"`
	ChatID         string      `json:"chat_id"`
	ChatType       string      `json:"chat_type"` // "group" or "p2p"
	UserID         string      `json:"user_id"`
	Content        string      `json:"content"`          // Standard text content
	RawContentType string      `json:"raw_content_type"` // Original message type from Lark API
	Mentions       []Mention   `json:"mentions"`         // Mentions in the message
	MentionAll     bool        `json:"mention_all"`
	MentionedBot   bool        `json:"mentioned_bot"`
	Resources      []Resource  `json:"resources"` // Images, files, etc.
	CreateTimeMs   int64       `json:"create_time_ms"`
	RawEvent       interface{} `json:"raw_event"` // Original event data
}

type OperatorInfo struct {
	OpenID  string `json:"open_id"`
	UserID  string `json:"user_id,omitempty"`
	UnionID string `json:"union_id,omitempty"`
}

type OutboundConfig struct {
	TextChunkLimit      int
	StreamThrottleMs    time.Duration
	StreamThrottleChars int
	Retry               struct {
		MaxAttempts int
		BaseDelayMs time.Duration
	}
}

type PolicyConfig struct {
	GroupAllowlist      []string
	RequireMention      *bool
	RespondToMentionAll *bool
	DMMode              string // "open", "disabled", "allowlist"
	DMAllowlist         []string
}

type PolicyDecision struct {
	Allowed bool
	Reason  RejectReason
}

type ReactionEvent struct {
	EventID      string      `json:"event_id"`
	MessageID    string      `json:"message_id"`
	ReactionType string      `json:"reaction_type"` // e.g. "SMILE"
	OperatorType string      `json:"operator_type,omitempty"`
	UserID       string      `json:"user_id"`
	Action       string      `json:"action"` // "add" or "remove"
	CreateTimeMs int64       `json:"create_time_ms"`
	RawEvent     interface{} `json:"raw_event"`
}

type RejectEvent struct {
	MessageID string `json:"message_id"`
	ChatID    string `json:"chat_id"`
	SenderID  string `json:"sender_id"`
	Reason    string `json:"reason"`
}

type RejectReason string

type Resource struct {
	Type          string `json:"type"`     // "image", "file", "audio", "video", "sticker", etc.
	FileKey       string `json:"file_key"` // The file key used in Lark API
	FileName      string `json:"file_name,omitempty"`
	DurationMs    *int   `json:"duration_ms,omitempty"`
	CoverImageKey string `json:"cover_image_key,omitempty"`
}

type SafetyConfig struct {
	Dedup struct {
		MaxEntries      int
		SweepIntervalMs time.Duration
	}
	Batch                BatchConfig
	StaleMessageWindowMs time.Duration
}

type SendInput struct {
	ReceiveID      string `json:"receive_id,omitempty"` // High priority, auto-detected
	ChatID         string `json:"chat_id,omitempty"`    // Fallback
	UserID         string `json:"user_id,omitempty"`    // Fallback
	MsgType        string `json:"msg_type,omitempty"`   // text, post, image, file, interactive, etc.
	ReplyMessageID string `json:"reply_message_id,omitempty"`

	// Message contents
	Text           string `json:"text,omitempty"`
	Markdown       string `json:"markdown,omitempty"`
	Title          string `json:"title,omitempty"` // Used as Post title if Markdown is set
	ImageKey       string `json:"image_key,omitempty"`
	FileKey        string `json:"file_key,omitempty"`
	AudioKey       string `json:"audio_key,omitempty"`
	VideoKey       string `json:"video_key,omitempty"`
	Card           string `json:"card,omitempty"` // Stringified JSON of the card
	Post           string `json:"post,omitempty"` // Stringified JSON of the post
	ShareChatID    string `json:"share_chat_id,omitempty"`
	ShareUserID    string `json:"share_user_id,omitempty"`
	StickerFileKey string `json:"sticker_file_key,omitempty"`

	// Local file paths (Uploader will automatically upload them before sending)
	ImagePath string `json:"image_path,omitempty"`
	FilePath  string `json:"file_path,omitempty"`

	// Media configuration for uploading
	Media *UploadInput `json:"media,omitempty"`

	// Mentions represents user mentions to be prepended to the message
	Mentions []Mention `json:"mentions,omitempty"`
}

type SendResult struct {
	MessageID string   `json:"message_id"`
	ChunkIDs  []string `json:"chunk_ids,omitempty"` // For messages split into multiple chunks
	ChatID    string   `json:"chat_id,omitempty"`
	Error     error    `json:"error,omitempty"`
}

type StreamController interface {
	// Append adds text to the end of the streaming message.
	Append(ctx context.Context, text string) error
	// UpdateCard updates the message with a new card.
	UpdateCard(ctx context.Context, card string) error
	// Flush forces any pending text to be sent immediately.
	Flush(ctx context.Context) error
	// Close completes the stream. No further updates can be made.
	Close(ctx context.Context) error
}

type UploadInput struct {
	Kind        MediaKind
	SourceURL   string
	SourcePath  string
	SourceBytes []byte
	FileName    string
	Duration    *int
}

type UploadResult struct {
	Kind       MediaKind
	FileKey    string
	DurationMs *int
}