usecase

Documentation

Index

• Variables
• type Config
• type DiscordClient
• type MessageCreateHandler
• type MessageStore
• type Service
  • func NewService(ctx context.Context, config *Config, store MessageStore, discord DiscordClient) *Service
  • func (s *Service) DetectMessageTopics(message *entity.Message) mapset.Set[entity.Topic]
  • func (s *Service) ListTopics() map[entity.Topic][]string
  • func (s *Service) SubscribeEvent(ctx context.Context, topics mapset.Set[entity.Topic], ...)
• type Usecase

Variables

var Set = wire.NewSet(
	NewService,
	wire.Bind(new(Usecase), new(*Service)),
)

Types

type Config

type Config struct {
	Topics          map[entity.Topic]string `env:"TOPICS"`
	DiscordWebhooks map[entity.Topic]string `env:"DISCORD_WEBHOOKS"`
}

type DiscordClient

type DiscordClient interface {
	AddMessageCreateHandler(handler MessageCreateHandler)
	ExecuteWebhook(ctx context.Context, id, token string, params *discordgo.WebhookParams) error
	FindGuild(ctx context.Context, id string) (*discordgo.Guild, error)
	FindChannel(ctx context.Context, id string) (*discordgo.Channel, error)
	FindGuildMember(ctx context.Context, guildID string, userID string) (*discordgo.Member, error)
}

type MessageCreateHandler

type MessageCreateHandler func(event *discordgo.MessageCreate) error

type MessageStore

type MessageStore interface {
	PublishMessage(ctx context.Context, message *entity.Message) error
	SubscribeMessage(ctx context.Context, channel chan<- *entity.Message)
}

type Service

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

func NewService

func NewService(ctx context.Context, config *Config, store MessageStore, discord DiscordClient) *Service

func (*Service) DetectMessageTopics

func (s *Service) DetectMessageTopics(message *entity.Message) mapset.Set[entity.Topic]

func (*Service) ListTopics

func (s *Service) ListTopics() map[entity.Topic][]string

func (*Service) SubscribeEvent

func (s *Service) SubscribeEvent(ctx context.Context, topics mapset.Set[entity.Topic], channel chan<- *entity.EventFrame)

type Usecase

type Usecase interface {
	SubscribeEvent(ctx context.Context, topics mapset.Set[entity.Topic], channel chan<- *entity.EventFrame)
}