internal

Documentation

Index

• Constants
• Variables
• type Bot
  • func New(db *pgxpool.Pool) *Bot
  • func (b *Bot) AddMessage(ctx context.Context, tx pgx.Tx, params []schema.AddMessageParams, ...) error
  • func (b *Bot) AddThreadMessages(ctx context.Context, tx pgx.Tx, params []schema.AddThreadMessageParams, ...) error
  • func (b *Bot) EnsureChannel(ctx context.Context, tx pgx.Tx, channelID string) (bool, error)
  • func (b *Bot) GetChannel(ctx context.Context, channelID string) (schema.ChannelsV2, error)
  • func (b *Bot) GetMessage(ctx context.Context, channelID string, slackTs string) (schema.GetMessageRow, error)
  • func (b *Bot) Init(riverClient *river.Client[pgx.Tx], docsConfig *docs.Config) 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

Constants

const (
	SourceBackfill messageSource
)

Variables

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

Types

type Bot

type Bot struct {
	DB          *pgxpool.Pool
	DocsConfig  *docs.Config
	RiverClient *river.Client[pgx.Tx]
}

func New

func New(db *pgxpool.Pool) *Bot

func (*Bot) AddMessage

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

func (*Bot) AddThreadMessages

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

func (*Bot) EnsureChannel

func (b *Bot) EnsureChannel(ctx context.Context, tx pgx.Tx, channelID string) (bool, error)

func (*Bot) GetChannel

func (b *Bot) GetChannel(ctx context.Context, channelID string) (schema.ChannelsV2, error)

func (*Bot) GetMessage

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

func (*Bot) Init

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

func (*Bot) NotifyMessage

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

func (*Bot) NotifyReactionAdded

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

func (*Bot) NotifyReactionRemoved

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

func (*Bot) UpdateChannel

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