tgtest

Documentation

Overview

Package tgtest provides test Telegram server for end-to-end test.

Index

• type BufferedConn
  • func NewBufferedConn(conn transport.Conn) *BufferedConn
  • func (c *BufferedConn) Close() error
  • func (c *BufferedConn) Push(b *bin.Buffer)
  • func (c *BufferedConn) Recv(ctx context.Context, b *bin.Buffer) error
  • func (c *BufferedConn) Send(ctx context.Context, b *bin.Buffer) error
• type Handler
• type HandlerFunc
  • func (h HandlerFunc) OnMessage(s Session, msgID int64, in *bin.Buffer) error
• type Server
  • func NewServer(name string, suite Suite, codec func() transport.Codec, h Handler) *Server
  • func NewUnstartedServer(name string, suite Suite, codec func() transport.Codec) *Server
  • func TestTransport(s Suite, message string, codec func() transport.Codec) *Server
  • func (s *Server) AddSession(key crypto.AuthKey)
  • func (s *Server) Addr() net.Addr
  • func (s *Server) Close()
  • func (s *Server) ForceDisconnect(k Session)
  • func (s *Server) Key() *rsa.PublicKey
  • func (s *Server) Send(k Session, t proto.MessageType, encoder bin.Encoder) error
  • func (s *Server) SendAck(k Session, ids ...int64) error
  • func (s *Server) SendConfig(k Session, id int64) error
  • func (s *Server) SendPong(k Session, msgID, pingID int64) error
  • func (s *Server) SendResult(k Session, id int64, msg bin.Encoder) error
  • func (s *Server) SendUpdates(k Session, updates ...tg.UpdateClass) error
  • func (s *Server) Serve() error
  • func (s *Server) SetHandler(handler Handler)
  • func (s *Server) SetHandlerFunc(handler func(s Session, msgID int64, in *bin.Buffer) error)
  • func (s *Server) Start()
• type Session
• type Suite
  • func NewSuite(ctx context.Context, tb testing.TB, log *zap.Logger) Suite
• type TB

Types

type BufferedConn

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

func NewBufferedConn

func NewBufferedConn(conn transport.Conn) *BufferedConn

func (*BufferedConn) Close

func (c *BufferedConn) Close() error

func (*BufferedConn) Push

func (c *BufferedConn) Push(b *bin.Buffer)

func (*BufferedConn) Recv

func (c *BufferedConn) Recv(ctx context.Context, b *bin.Buffer) error

func (*BufferedConn) Send

func (c *BufferedConn) Send(ctx context.Context, b *bin.Buffer) error

type Handler

type Handler interface {
	OnMessage(s Session, msgID int64, in *bin.Buffer) error
}

type HandlerFunc

type HandlerFunc func(s Session, msgID int64, in *bin.Buffer) error

HandlerFunc is functional adapter for Handler.OnMessage method.

func (HandlerFunc) OnMessage

func (h HandlerFunc) OnMessage(s Session, msgID int64, in *bin.Buffer) error

type Server

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

func NewServer

func NewServer(name string, suite Suite, codec func() transport.Codec, h Handler) *Server

func NewUnstartedServer

func NewUnstartedServer(name string, suite Suite, codec func() transport.Codec) *Server

func TestTransport

func TestTransport(s Suite, message string, codec func() transport.Codec) *Server

func (*Server) AddSession

func (s *Server) AddSession(key crypto.AuthKey)

func (*Server) Addr

func (s *Server) Addr() net.Addr

func (*Server) Close

func (s *Server) Close()

func (*Server) ForceDisconnect

func (s *Server) ForceDisconnect(k Session)

func (*Server) Key

func (s *Server) Key() *rsa.PublicKey

func (*Server) Send

func (s *Server) Send(k Session, t proto.MessageType, encoder bin.Encoder) error

func (*Server) SendAck

func (s *Server) SendAck(k Session, ids ...int64) error

func (*Server) SendConfig

func (s *Server) SendConfig(k Session, id int64) error

func (*Server) SendPong

func (s *Server) SendPong(k Session, msgID, pingID int64) error

func (*Server) SendResult

func (s *Server) SendResult(k Session, id int64, msg bin.Encoder) error

func (*Server) SendUpdates

func (s *Server) SendUpdates(k Session, updates ...tg.UpdateClass) error

func (*Server) Serve

func (s *Server) Serve() error

func (*Server) SetHandler

func (s *Server) SetHandler(handler Handler)

func (*Server) SetHandlerFunc

func (s *Server) SetHandlerFunc(handler func(s Session, msgID int64, in *bin.Buffer) error)

func (*Server) Start

func (s *Server) Start()

type Session

type Session struct {
	SessionID int64
	crypto.AuthKey
}

type Suite

type Suite struct {
	testing.TB
	Ctx context.Context
	Log *zap.Logger
}

func NewSuite

func NewSuite(ctx context.Context, tb testing.TB, log *zap.Logger) Suite

type TB

type TB interface {
	Log(args ...interface{})
	Logf(format string, args ...interface{})
	Fatal(args ...interface{})
}