irc

Documentation

Index

• type Handler
  • func NewHandler(log zerolog.Logger, sse *sse.Server, network domain.IrcNetwork, ...) *Handler
  • func (h *Handler) AddChannelHealth(channel string)
  • func (h *Handler) CurrentNick() string
  • func (h *Handler) GetNetwork() *domain.IrcNetwork
  • func (h *Handler) InitIndexers(definitions []*domain.IndexerDefinition)
  • func (h *Handler) JoinChannel(channel string, password string) error
  • func (h *Handler) JoinChannels()
  • func (h *Handler) NickChange(nick string) error
  • func (h *Handler) NickServIdentify(password string) error
  • func (h *Handler) PartChannel(channel string) error
  • func (h *Handler) PreferredNick() string
  • func (h *Handler) ReportStatus(netw *domain.IrcNetworkWithHealth)
  • func (h *Handler) Restart() error
  • func (h *Handler) Run() (err error)
  • func (h *Handler) Send(command string, params ...string) error
  • func (h *Handler) SendMsg(channel, msg string) error
  • func (h *Handler) SendToAnnounceProcessor(channel string, msg string) error
  • func (h *Handler) SetNetwork(network *domain.IrcNetwork)
  • func (h *Handler) Stop()
  • func (h *Handler) Stopped() bool
  • func (h *Handler) UpdateNetwork(network *domain.IrcNetwork)
• type Service
  • func NewService(log logger.Logger, sse *sse.Server, repo domain.IrcRepo, ...) Service

Types

type Handler

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

func NewHandler

func NewHandler(log zerolog.Logger, sse *sse.Server, network domain.IrcNetwork, definitions []*domain.IndexerDefinition, releaseSvc release.Service, notificationSvc notification.Service) *Handler

func (*Handler) AddChannelHealth

func (h *Handler) AddChannelHealth(channel string)

func (*Handler) CurrentNick

func (h *Handler) CurrentNick() string

CurrentNick returns our current nick set by the server

func (*Handler) GetNetwork

func (h *Handler) GetNetwork() *domain.IrcNetwork

func (*Handler) InitIndexers

func (h *Handler) InitIndexers(definitions []*domain.IndexerDefinition)

func (*Handler) JoinChannel

func (h *Handler) JoinChannel(channel string, password string) error

JoinChannel sends join command

func (*Handler) JoinChannels

func (h *Handler) JoinChannels()

JoinChannels sends multiple join commands

func (*Handler) NickChange

func (h *Handler) NickChange(nick string) error

NickChange sets a new nick for our user

func (*Handler) NickServIdentify

func (h *Handler) NickServIdentify(password string) error

NickServIdentify sends NickServ Identify commands

func (*Handler) PartChannel

func (h *Handler) PartChannel(channel string) error

PartChannel parts/leaves channel

func (*Handler) PreferredNick

func (h *Handler) PreferredNick() string

PreferredNick returns our preferred nick from settings

func (*Handler) ReportStatus

func (h *Handler) ReportStatus(netw *domain.IrcNetworkWithHealth)

func (*Handler) Restart

func (h *Handler) Restart() error

Restart stops the network and then runs it

func (*Handler) Run

func (h *Handler) Run() (err error)

func (*Handler) Send

func (h *Handler) Send(command string, params ...string) error

func (*Handler) SendMsg

func (h *Handler) SendMsg(channel, msg string) error

func (*Handler) SendToAnnounceProcessor

func (h *Handler) SendToAnnounceProcessor(channel string, msg string) error

func (*Handler) SetNetwork

func (h *Handler) SetNetwork(network *domain.IrcNetwork)

func (*Handler) Stop

func (h *Handler) Stop()

Stop the network and quit

func (*Handler) Stopped

func (h *Handler) Stopped() bool

func (*Handler) UpdateNetwork

func (h *Handler) UpdateNetwork(network *domain.IrcNetwork)

type Service

type Service interface {
	StartHandlers()
	StopHandlers()
	StopNetwork(id int64) error
	StopAndRemoveNetwork(id int64) error
	StopNetworkIfRunning(id int64) error
	RestartNetwork(ctx context.Context, id int64) error
	ListNetworks(ctx context.Context) ([]domain.IrcNetwork, error)
	GetNetworksWithHealth(ctx context.Context) ([]domain.IrcNetworkWithHealth, error)
	GetNetworkByID(ctx context.Context, id int64) (*domain.IrcNetwork, error)
	DeleteNetwork(ctx context.Context, id int64) error
	StoreNetwork(ctx context.Context, network *domain.IrcNetwork) error
	UpdateNetwork(ctx context.Context, network *domain.IrcNetwork) error
	StoreChannel(ctx context.Context, networkID int64, channel *domain.IrcChannel) error
	SendCmd(ctx context.Context, req *domain.SendIrcCmdRequest) error
	ManualProcessAnnounce(ctx context.Context, req *domain.IRCManualProcessRequest) error
}

func NewService

func NewService(log logger.Logger, sse *sse.Server, repo domain.IrcRepo, releaseSvc release.Service, indexerSvc indexer.Service, notificationSvc notification.Service) Service