network

Documentation

Index

• Constants
• Variables
• type EncryptType
• type Packet
• type Request
• type RequestParams
  • func (p RequestParams) Bool(k string) bool
  • func (p RequestParams) Int32(k string) int32
• type RequestType
• type Response
• type TCPClient
  • func (t *TCPClient) Close()
  • func (t *TCPClient) Connect(addr string) error
  • func (t *TCPClient) PlannedDisconnect(f func(*TCPClient))
  • func (t *TCPClient) ReadBytes(len int) ([]byte, error)
  • func (t *TCPClient) ReadInt32() (int32, error)
  • func (t *TCPClient) SetProxy(proxyAddr string) bool
  • func (t *TCPClient) UnexpectedDisconnect(f func(*TCPClient, error))
  • func (t *TCPClient) Write(buf []byte) error
• type Transport
  • func (t *Transport) PackPacket(req *Request) []byte
  • func (t *Transport) ReadResponse(head []byte) (*Response, error)

Constants

const (
	RequestTypeLogin  = 0x0A
	RequestTypeSimple = 0x0B
)

Variables

var (
	ErrSessionExpired    = errors.New("session expired")
	ErrPacketDropped     = errors.New("packet dropped")
	ErrInvalidPacketType = errors.New("invalid packet type")
)

var ErrConnectionClosed = errors.New("connection closed")

Types

type EncryptType

type EncryptType uint32

const (
	EncryptTypeNoEncrypt EncryptType = iota // 0x00
	EncryptTypeD2Key                        // 0x01
	EncryptTypeEmptyKey                     // 0x02
)

type Packet

type Packet struct {
	SequenceId  uint16
	CommandName string
	Payload     []byte
	Params      RequestParams
}

type Request

type Request struct {
	Type        RequestType
	EncryptType EncryptType
	SequenceID  int32
	Uin         int64
	CommandName string
	Body        []byte
}

type RequestParams

type RequestParams map[string]any

func (RequestParams) Bool

func (p RequestParams) Bool(k string) bool

func (RequestParams) Int32

func (p RequestParams) Int32(k string) int32

type RequestType

type RequestType uint32

type Response

type Response struct {
	Type        RequestType
	EncryptType EncryptType
	SequenceID  int32
	Uin         int64
	CommandName string
	Body        []byte

	Message string
}

type TCPClient

type TCPClient struct {
	Dial func(network, addr string) (net.Conn, error)
	// contains filtered or unexported fields
}

func (*TCPClient) Close

func (t *TCPClient) Close()

func (*TCPClient) Connect

func (t *TCPClient) Connect(addr string) error

func (*TCPClient) PlannedDisconnect

func (t *TCPClient) PlannedDisconnect(f func(*TCPClient))

PlannedDisconnect 预料中的断开连接 如调用 Close() Connect()

func (*TCPClient) ReadBytes

func (t *TCPClient) ReadBytes(len int) ([]byte, error)

func (*TCPClient) ReadInt32

func (t *TCPClient) ReadInt32() (int32, error)

func (*TCPClient) SetProxy

func (t *TCPClient) SetProxy(proxyAddr string) bool

func (*TCPClient) UnexpectedDisconnect

func (t *TCPClient) UnexpectedDisconnect(f func(*TCPClient, error))

UnexpectedDisconnect 未预料的断开连接

func (*TCPClient) Write

func (t *TCPClient) Write(buf []byte) error

type Transport

type Transport struct {
	Sig     *auth.SigInfo
	Version *auth.AppVersion
	Device  *auth.Device
}

Transport is a network transport.

func (*Transport) PackPacket

func (t *Transport) PackPacket(req *Request) []byte

PackPacket packs a packet.

func (*Transport) ReadResponse

func (t *Transport) ReadResponse(head []byte) (*Response, error)