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.TextConversationTarget, error)
- func (c *Connector) CleanupExternalMCPRelay(ctx context.Context, replyTarget *events.SlackReplyTarget)
- func (c *Connector) CleanupPendingReplyPlaceholder(ctx context.Context, replyTarget *events.SlackReplyTarget)
- func (c *Connector) DeleteUserQuestion(ctx context.Context, target events.TextConversationTarget) error
- func (c *Connector) ResolveChannelName(ctx context.Context, channelID string) (string, error)
- func (c *Connector) SendCronjobChannelThread(ctx context.Context, channelID, relativePath, agent, ranAt, text string, ...) error
- func (c *Connector) SendExternalMCPRelay(ctx context.Context, channelID, threadTS string, relay events.ExternalMCPRelay) (*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, bus *events.Bus, threadRouter harnessbridge.PrimaryTextRouter, oneOffCronjobs primarytext.OneOffCronjobRunner, answerQuestion func(context.Context, string, events.AskUserQuestionAnswer) bool, 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.TextConversationTarget, error)
AskUserQuestion posts one in-message Slack question.
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) DeleteUserQuestion ¶ added in v0.0.12
func (c *Connector) DeleteUserQuestion(ctx context.Context, target events.TextConversationTarget) error
DeleteUserQuestion deletes one Slack question message.
func (*Connector) ResolveChannelName ¶ added in v0.0.33
ResolveChannelName returns the configured canonical name for a Slack channel ID.
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