listen

package

v0.0.0-...-4c708ec Latest Latest Go to latest Published: Dec 21, 2023 License: MIT Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitlab.com/bancast/streamtools/twitch-tools

Links

Open Source Insights

Documentation ¶

Index ¶

func Bot(ctx context.Context, logger logr.Logger, controller *twitch.Controller, ...)
func GetTwitchIDContext(ctx context.Context) string
func NewGrpc(ctx context.Context, logger logr.Logger, serverFlags *gateway.ServerFlags, ...) error
func NewListenCommand(logger *logging.Logger) *cobra.Command
func SetTwitchIDContext(ctx context.Context, twitch_id string) context.Context
type IRCClient
type TwitchChatServer
- func NewChatServer(logger logr.Logger, controller *twitch.Controller) *TwitchChatServer
- func (t TwitchChatServer) Send(ctx context.Context, msg *chat.TwitchChatRequest) (*chat.TwitchChatResponse, error)
type TwitchIDKey
type TwitchSinker
- func NewTwitchSinker(client grpc.ClientConnInterface) *TwitchSinker

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Bot ¶

func Bot(ctx context.Context, logger logr.Logger, controller *twitch.Controller, sink *TwitchSinker, loginChan chan string)

Bot create a loop that reacts to login events and spins up a new IRC client to twitch chat. This allows us to listen for messages on the channels we subscribe to, and send them off to the sink for processing.

func GetTwitchIDContext ¶

func GetTwitchIDContext(ctx context.Context) string

func NewGrpc ¶

func NewGrpc(ctx context.Context, logger logr.Logger, serverFlags *gateway.ServerFlags, controller *twitch.Controller) error

func NewListenCommand ¶

func NewListenCommand(logger *logging.Logger) *cobra.Command

func SetTwitchIDContext ¶

func SetTwitchIDContext(ctx context.Context, twitch_id string) context.Context

Types ¶

type IRCClient ¶

type IRCClient struct {
	*twitchIRC.Client
	Channel string
}

type TwitchChatServer ¶

type TwitchChatServer struct {
	chat.UnimplementedTwitchChatServer
	grpcUtils.DisabledAuth
	// contains filtered or unexported fields
}

func NewChatServer ¶

func NewChatServer(logger logr.Logger, controller *twitch.Controller) *TwitchChatServer

func (TwitchChatServer) Send ¶

func (t TwitchChatServer) Send(ctx context.Context, msg *chat.TwitchChatRequest) (*chat.TwitchChatResponse, error)

type TwitchIDKey ¶

type TwitchIDKey struct{}

type TwitchSinker ¶

type TwitchSinker struct {
	Client sink.TwitchMessageSinkClient
}

func NewTwitchSinker ¶

func NewTwitchSinker(client grpc.ClientConnInterface) *TwitchSinker

func (*TwitchSinker) MapBadges ¶

func (t *TwitchSinker) MapBadges(badges map[string]int) map[string]int64

func (*TwitchSinker) MapEmotes ¶

func (t *TwitchSinker) MapEmotes(emotes []*twitchIRC.Emote) []*messages.Emote

func (*TwitchSinker) MapUser ¶

func (t *TwitchSinker) MapUser(user twitchIRC.User) *messages.User

func (*TwitchSinker) NewClearChatMessageHandler ¶

func (t *TwitchSinker) NewClearChatMessageHandler(ctx context.Context, f func(twitchIRC.ClearChatMessage)) func(twitchIRC.ClearChatMessage)

func (*TwitchSinker) NewClearMessageHandler ¶

func (t *TwitchSinker) NewClearMessageHandler(ctx context.Context, f func(twitchIRC.ClearMessage)) func(twitchIRC.ClearMessage)

func (*TwitchSinker) NewGlobalUserStateMessageHandler ¶

func (t *TwitchSinker) NewGlobalUserStateMessageHandler(ctx context.Context, f func(twitchIRC.GlobalUserStateMessage)) func(twitchIRC.GlobalUserStateMessage)

func (*TwitchSinker) NewNoticeMessageHandler ¶

func (t *TwitchSinker) NewNoticeMessageHandler(ctx context.Context, f func(twitchIRC.NoticeMessage)) func(twitchIRC.NoticeMessage)

func (*TwitchSinker) NewPrivateMessageHandler ¶

func (t *TwitchSinker) NewPrivateMessageHandler(ctx context.Context, f func(twitchIRC.PrivateMessage)) func(twitchIRC.PrivateMessage)

func (*TwitchSinker) NewReconnectMessageHandler ¶

func (t *TwitchSinker) NewReconnectMessageHandler(ctx context.Context, f func(twitchIRC.ReconnectMessage)) func(twitchIRC.ReconnectMessage)

func (*TwitchSinker) NewRoomStateMessageHandler ¶

func (t *TwitchSinker) NewRoomStateMessageHandler(ctx context.Context, f func(twitchIRC.RoomStateMessage)) func(twitchIRC.RoomStateMessage)

func (*TwitchSinker) NewUserJoinMessageHandler ¶

func (t *TwitchSinker) NewUserJoinMessageHandler(ctx context.Context, f func(twitchIRC.UserJoinMessage)) func(twitchIRC.UserJoinMessage)

func (*TwitchSinker) NewUserNoticeMessageHandler ¶

func (t *TwitchSinker) NewUserNoticeMessageHandler(ctx context.Context, f func(twitchIRC.UserNoticeMessage)) func(twitchIRC.UserNoticeMessage)

func (*TwitchSinker) NewUserPartMessageHandler ¶

func (t *TwitchSinker) NewUserPartMessageHandler(ctx context.Context, f func(twitchIRC.UserPartMessage)) func(twitchIRC.UserPartMessage)

func (*TwitchSinker) NewUserStateMessageHandler ¶

func (t *TwitchSinker) NewUserStateMessageHandler(ctx context.Context, f func(twitchIRC.UserStateMessage)) func(twitchIRC.UserStateMessage)

func (*TwitchSinker) NewWhisperMessageHandler ¶

func (t *TwitchSinker) NewWhisperMessageHandler(ctx context.Context, f func(twitchIRC.WhisperMessage)) func(twitchIRC.WhisperMessage)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL