connection

Documentation

Index

• type KikProxyConnection
  • func (c *KikProxyConnection) Run()
• type XmppLogger
  • func NewXmppLogger(outputFile string) (*XmppLogger, error)
  • func (x XmppLogger) Close() error
  • func (x XmppLogger) OnNewStanza(data []byte, isOutgoing bool) error

Types

type KikProxyConnection

type KikProxyConnection struct {
	UserId   string
	IsAuthed bool

	ClientConn  net.Conn
	ClientInput node.NodeInputStream

	KikConn  net.Conn
	KikInput node.NodeInputStream

	RateLimiter *ratelimit.KikRateLimiter

	IsConnected atomic.Bool

	Logger *XmppLogger
}

func (*KikProxyConnection) Run

func (c *KikProxyConnection) Run()

This routine blocks until the connection is finished.

type XmppLogger

type XmppLogger struct {
	Writer io.WriteCloser
}

func NewXmppLogger

func NewXmppLogger(outputFile string) (*XmppLogger, error)

func (XmppLogger) Close

func (x XmppLogger) Close() error

func (XmppLogger) OnNewStanza

func (x XmppLogger) OnNewStanza(data []byte, isOutgoing bool) error