Documentation
¶
Overview ¶
Package slackconnector bridges Slack events into rocketclaw.
Index ¶
- type Connector
- func (c *Connector) CleanupPendingReplyPlaceholder(ctx context.Context, replyTarget *events.SlackReplyTarget)
- func (c *Connector) SendCronjobChannelThread(ctx context.Context, channelID, relativePath, agent, ranAt, text string, ...) error
- func (c *Connector) SendDiscordRelay(ctx context.Context, text string) (*events.SlackReplyTarget, error)
- func (c *Connector) SendExternalMCPRelay(ctx context.Context, channelID, text string, ...) (*events.SlackReplyTarget, error)
- func (c *Connector) SendExternalMCPThreadRelay(ctx context.Context, channelID, threadTS, text string, ...) (*events.SlackReplyTarget, error)
- func (c *Connector) SendResponse(ctx context.Context, msg *events.OutboundMessage) error
- func (c *Connector) SendWebVoiceRelay(ctx context.Context, text string) (*events.SlackReplyTarget, error)
- func (c *Connector) Start(ctx context.Context) error
- func (c *Connector) Stop(context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connector ¶
type Connector struct {
// contains filtered or unexported fields
}
Connector bridges Slack DM events into the shared rocketclaw bus.
func New ¶
func New(cfg *config.SlackConfig, bus *events.Bus, emergencySafeWords []string, threadAgents config.ThreadAgents, threadRouter harnessbridge.PrimaryTextRouter, oneOffCronjobs primarytext.OneOffCronjobRunner, interruptMainTurn func() *events.InboundMessage, logger *slog.Logger) *Connector
New constructs a Slack connector.
func (*Connector) CleanupPendingReplyPlaceholder ¶
func (c *Connector) CleanupPendingReplyPlaceholder(ctx context.Context, replyTarget *events.SlackReplyTarget)
CleanupPendingReplyPlaceholder removes a relay placeholder that no response turn claimed.
func (*Connector) SendCronjobChannelThread ¶
func (c *Connector) SendCronjobChannelThread(ctx context.Context, channelID, relativePath, agent, ranAt, text string, attachments []events.OutboundAttachment) error
SendCronjobChannelThread posts one scheduled cronjob result in a new Slack channel thread.
func (*Connector) SendDiscordRelay ¶
func (c *Connector) SendDiscordRelay(ctx context.Context, text string) (*events.SlackReplyTarget, error)
SendDiscordRelay mirrors a Discord utterance into Slack before the main session handles it.
func (*Connector) SendExternalMCPRelay ¶
func (c *Connector) SendExternalMCPRelay(ctx context.Context, channelID, text string, attachments []events.OutboundAttachment) (*events.SlackReplyTarget, error)
SendExternalMCPRelay mirrors an external MCP prompt into Slack before the main session handles it.
func (*Connector) SendExternalMCPThreadRelay ¶
func (c *Connector) SendExternalMCPThreadRelay(ctx context.Context, channelID, threadTS, text string, attachments []events.OutboundAttachment) (*events.SlackReplyTarget, error)
SendExternalMCPThreadRelay mirrors an external MCP follow-up into an existing Slack thread.
func (*Connector) SendResponse ¶
SendResponse posts or updates a streamed response message in Slack.
func (*Connector) SendWebVoiceRelay ¶
func (c *Connector) SendWebVoiceRelay(ctx context.Context, text string) (*events.SlackReplyTarget, error)
SendWebVoiceRelay mirrors a browser web voice utterance into Slack before the main session handles it.
Source Files