slackbot

type Handlers ¶

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

Handlers provides SlackBot management REST API, implementing app.CustomHandler

func NewHandlers(repo repositories.SlackBotRepository) *Handlers

func (h *Handlers) GetName() string

func (h *Handlers) RegisterRoutes(e *echo.Echo, _ *app.Server) error

type SlackSocketManager ¶ added in v1.271.0

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

SlackSocketManager discovers registered SlackBots and manages one leader-elected socket worker per bot group:

• "default": all bots with no custom bot token secret
• <slackbot-id>: each bot with a custom BotTokenSecretName

func NewSlackSocketManager(
	kubeClient kubernetes.Interface,
	namespace string,
	repo repoports.SlackBotRepository,
	eventHandler *controllers.SlackBotEventHandler,
	channelResolver *services.SlackChannelResolver,
	cfg SlackSocketManagerConfig,
) *SlackSocketManager

func (m *SlackSocketManager) Run(ctx context.Context)

func (m *SlackSocketManager) Stop()

type SlackSocketManagerConfig ¶ added in v1.271.0

type SlackSocketManagerConfig struct {
	DefaultAppTokenSecretName string
	DefaultAppTokenSecretKey  string
	DefaultBotTokenSecretName string
	DefaultBotTokenSecretKey  string
	ReconcileInterval         time.Duration
	LeaderElectionConfig      schedule.LeaderElectionConfig
}

SlackSocketManagerConfig holds configuration for SlackSocketManager

type SlackSocketWorker ¶ added in v1.271.0

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

SlackSocketWorker manages one Socket Mode WebSocket connection for a Slack App. For the "default" group (bots with no custom token), botID is "default". For custom bots, botID is the SlackBot entity ID.

func NewSlackSocketWorker(
	botID string,
	appTokenSecretName string,
	appTokenSecretKey string,
	botTokenSecretName string,
	botTokenSecretKey string,
	channelResolver *services.SlackChannelResolver,
	eventHandler *controllers.SlackBotEventHandler,
) *SlackSocketWorker

func (w *SlackSocketWorker) Run(ctx context.Context)