internal

package

v0.0.2 Latest Latest Go to latest Published: Feb 18, 2025 License: AGPL-3.0 Imports: 16 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.MessagesV2, error)

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

func (b *Bot) Notify(ctx context.Context, ev *slackevents.MessageEvent) 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
slack_integration
storage
schema
schema/dto
web