Documentation
¶
Overview ¶
Package slackconnector bridges Slack events into rocketclaw.
Index ¶
- type Connector
- func (c *Connector) AbortResponse(msg *events.OutboundMessage)
- func (c *Connector) AskUserQuestion(ctx context.Context, req *events.AskUserQuestionRequest) (events.AskUserQuestionAnswer, error)
- func (c *Connector) CleanupExternalMCPRelay(ctx context.Context, replyTarget *events.SlackReplyTarget)
- func (c *Connector) CleanupPendingReplyPlaceholder(ctx context.Context, replyTarget *events.SlackReplyTarget)
- func (c *Connector) HandleBroadcast(ctx context.Context, broadcast *events.Broadcast) events.BroadcastAcknowledgement
- func (c *Connector) SendCronjobChannelThread(ctx context.Context, channelID, relativePath, agent, ranAt, text string, ...) error
- func (c *Connector) SendExternalMCPRelay(ctx context.Context, channelID, threadTS string, ...) (*events.SlackReplyTarget, error)
- func (c *Connector) SendResponse(ctx context.Context, msg *events.OutboundMessage) error
- func (c *Connector) Start(ctx context.Context) error
- func (c *Connector) StartNewThreadRoot(ctx context.Context, req *events.StartNewThreadRequest) (events.StartNewThreadRootResult, 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, publisher events.OutboundPublisher, threadRouter harnessbridge.PrimaryTextRouter, oneOffCronjobs oneOffCronjobRunner, logger *slog.Logger) *Connector
New constructs a Slack connector.
func (*Connector) AbortResponse ¶ added in v0.0.33
func (c *Connector) AbortResponse(msg *events.OutboundMessage)
AbortResponse releases Slack state after final response delivery cannot recover.
func (*Connector) AskUserQuestion ¶ added in v0.0.12
func (c *Connector) AskUserQuestion(ctx context.Context, req *events.AskUserQuestionRequest) (events.AskUserQuestionAnswer, error)
AskUserQuestion posts one in-message Slack question and waits for the human answer.
func (*Connector) CleanupExternalMCPRelay ¶ added in v0.0.33
func (c *Connector) CleanupExternalMCPRelay(ctx context.Context, replyTarget *events.SlackReplyTarget)
CleanupExternalMCPRelay removes a failed new-conversation relay and its placeholders.
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) HandleBroadcast ¶ added in v0.0.45
func (c *Connector) HandleBroadcast(ctx context.Context, broadcast *events.Broadcast) events.BroadcastAcknowledgement
HandleBroadcast delivers live output and connector-specific relays to Slack.
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) SendExternalMCPRelay ¶
func (c *Connector) SendExternalMCPRelay(ctx context.Context, channelID, threadTS string, relay *events.ExternalMCPRelay) (*events.SlackReplyTarget, error)
SendExternalMCPRelay mirrors one external MCP request into a Slack root or thread.
func (*Connector) SendResponse ¶
SendResponse posts or updates a streamed response message in Slack.
func (*Connector) StartNewThreadRoot ¶ added in v0.0.16
func (c *Connector) StartNewThreadRoot(ctx context.Context, req *events.StartNewThreadRequest) (events.StartNewThreadRootResult, error)
StartNewThreadRoot posts the root message for a model-created Slack conversation.
Source Files