syncer

Documentation

Index

• type Client
• type SyncOptions
• type SyncStats
• type Syncer
  • func New(client Client, store *store.Store, logger *slog.Logger) *Syncer
  • func (s *Syncer) DiscoverGuilds(ctx context.Context) ([]*discordgo.UserGuild, error)
  • func (s *Syncer) RunTail(ctx context.Context, guildIDs []string, repairEvery time.Duration) error
  • func (s *Syncer) SetAttachmentTextEnabled(enabled bool)
  • func (s *Syncer) Sync(ctx context.Context, opts SyncOptions) (SyncStats, error)

Types

type Client

type Client interface {
	Self(context.Context) (*discordgo.User, error)
	Guilds(context.Context) ([]*discordgo.UserGuild, error)
	Guild(context.Context, string) (*discordgo.Guild, error)
	GuildChannels(context.Context, string) ([]*discordgo.Channel, error)
	ThreadsActive(context.Context, string) ([]*discordgo.Channel, error)
	GuildThreadsActive(context.Context, string) ([]*discordgo.Channel, error)
	ThreadsArchived(context.Context, string, bool) ([]*discordgo.Channel, error)
	GuildMembers(context.Context, string) ([]*discordgo.Member, error)
	ChannelMessages(context.Context, string, int, string, string) ([]*discordgo.Message, error)
	ChannelMessage(context.Context, string, string) (*discordgo.Message, error)
	Tail(context.Context, discordclient.EventHandler) error
}

type SyncOptions

type SyncOptions struct {
	Full         bool
	GuildIDs     []string
	ChannelIDs   []string
	Concurrency  int
	Since        time.Time
	Embeddings   bool
	SkipMembers  bool
	LatestOnly   bool
	RepairReason string
}

type SyncStats

type SyncStats struct {
	Guilds   int `json:"guilds"`
	Channels int `json:"channels"`
	Threads  int `json:"threads"`
	Members  int `json:"members"`
	Messages int `json:"messages"`
}

type Syncer

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

func New

func New(client Client, store *store.Store, logger *slog.Logger) *Syncer

func (*Syncer) DiscoverGuilds

func (s *Syncer) DiscoverGuilds(ctx context.Context) ([]*discordgo.UserGuild, error)

func (*Syncer) RunTail

func (s *Syncer) RunTail(ctx context.Context, guildIDs []string, repairEvery time.Duration) error

func (*Syncer) SetAttachmentTextEnabled

func (s *Syncer) SetAttachmentTextEnabled(enabled bool)

func (*Syncer) Sync

func (s *Syncer) Sync(ctx context.Context, opts SyncOptions) (SyncStats, error)