internal

package

v0.0.7 Latest Latest Go to latest Published: Feb 26, 2025 License: AGPL-3.0 Imports: 17 Imported by: 0

Details

View Source

const (
	SourceSlack messageSource = iota
	SourceBackfill
)

View Source

var (
	ErrMessageNotFound = errors.New("message not found")
)

func TimeToTs(t time.Time) string

func TsToTime(ts string) (time.Time, error)

type Bot struct {
	DB *pgxpool.Pool
	// contains filtered or unexported fields
}

func New(ctx context.Context, db *pgxpool.Pool) (*Bot, error)

func (b *Bot) AddMessage(ctx context.Context, tx pgx.Tx, params []schema.AddMessageParams, source messageSource) error

func (b *Bot) AddThreadMessages(ctx context.Context, tx pgx.Tx, params []schema.AddThreadMessageParams) error

func (b *Bot) GetMessage(
	ctx context.Context,
	channelID string,
	slackTs string,
) (schema.GetMessageRow, error)

func (b *Bot) Init(riverClient *river.Client[pgx.Tx]) error

func (b *Bot) NotifyMessage(ctx context.Context, ev *slackevents.MessageEvent) error

func (b *Bot) NotifyReactionAdded(ctx context.Context, ev *slackevents.ReactionAddedEvent) error

func (b *Bot) NotifyReactionRemoved(ctx context.Context, ev *slackevents.ReactionRemovedEvent) error

func (b *Bot) UpdateChannel(ctx context.Context, tx pgx.Tx, params schema.UpdateChannelAttrsParams) error

Path	Synopsis
background
backfill_thread_worker
channel_onboard_worker
classifier_worker
modules_worker
llm
modules
channel_monitor
channel_monitor/mocks Package mocks is a generated GoMock package.	Package mocks is a generated GoMock package.
commands
recent_activity
report
runbook
usage
slack_integration
storage
schema
schema/dto
web