messagelog

Documentation

Index

• type BatchedMessageLogger
  • func NewBatchedMessageLogger(logger zerolog.Logger, db DB, roDB DB, includeChannels []string, ...) *BatchedMessageLogger
  • func (b *BatchedMessageLogger) LogMessages(twitchMsgChan <-chan *command.PrivateMessage) error
  • func (b *BatchedMessageLogger) MessagesFromUserInChannel(username string, broadcasterChannel string) ([]LogEntry, error)
  • func (b *BatchedMessageLogger) PrepareDatabase() error
• type DB
• type LogEntry

Types

type BatchedMessageLogger

type BatchedMessageLogger struct {
	// contains filtered or unexported fields
}

func NewBatchedMessageLogger

func NewBatchedMessageLogger(logger zerolog.Logger, db DB, roDB DB, includeChannels []string, excludeChannels []string) *BatchedMessageLogger

func (*BatchedMessageLogger) LogMessages

func (b *BatchedMessageLogger) LogMessages(twitchMsgChan <-chan *command.PrivateMessage) error

func (*BatchedMessageLogger) MessagesFromUserInChannel

func (b *BatchedMessageLogger) MessagesFromUserInChannel(username string, broadcasterChannel string) ([]LogEntry, error)

func (*BatchedMessageLogger) PrepareDatabase

func (b *BatchedMessageLogger) PrepareDatabase() error

type DB

type DB interface {
	Exec(query string, args ...any) (sql.Result, error)
	Query(query string, args ...any) (*sql.Rows, error)
}

type LogEntry

type LogEntry struct {
	ID               string
	BroadCastID      int
	UserID           int
	BroadcastChannel string
	SentAt           time.Time
	SenderDisplay    string
	PrivateMessage   *command.PrivateMessage
}