server

Documentation

Index

• Constants
• Variables
• func NewAuthSessionManager() *authSessionManager
• type HandshakeStateCtx
  • func (m *HandshakeStateCtx) DebugString() string
• type Server
  • func New(c config.Config) *Server
  • func (s *Server) Close()
  • func (s *Server) GatewaySendDataToGateway(ctx context.Context, in *gateway.TLGatewaySendDataToGateway) (reply *mtproto.Bool, err error)
  • func (s *Server) GetAuthKey(authKeyId int64) *mtproto.AuthKeyInfo
  • func (s *Server) GetConnByConnID(id uint64) *net2.TcpConnection
  • func (s *Server) OnConnectionClosed(conn *net2.TcpConnection)
  • func (s *Server) OnConnectionDataArrived(conn *net2.TcpConnection, msg interface{}) error
  • func (s *Server) OnNewConnection(conn *net2.TcpConnection)
  • func (s *Server) Ping(ctx context.Context) (err error)
  • func (s *Server) PutAuthKey(keyInfo *mtproto.AuthKeyInfo)
  • func (s *Server) SendToClient(conn *net2.TcpConnection, authKey *authKeyUtil, b []byte) error
  • func (s *Server) Serve() error
• type Session
  • func NewSession(c config.Config) *Session

Constants

const (
	STATE_ERROR              = 0x0000
	STATE_CONNECTED2         = 0x0100
	STATE_HANDSHAKE          = 0x0200
	STATE_pq                 = 0x0201
	STATE_pq_res             = 0x0202
	STATE_pq_ack             = 0x0203
	STATE_DH_params          = 0x0204
	STATE_DH_params_res      = 0x0205
	STATE_DH_params_res_fail = 0x0206
	STATE_DH_params_ack      = 0x0207
	STATE_dh_gen             = 0x0208
	STATE_dh_gen_res         = 0x0209
	STATE_dh_gen_res_retry   = 0x020a
	STATE_dh_gen_res_fail    = 0x020b
	STATE_dh_gen_ack         = 0x020c
	STATE_AUTH_KEY           = 0x0300
)

const (
	RES_STATE_NONE  = 0x00
	RES_STATE_OK    = 0x01
	RES_STATE_ERROR = 0x02
)

const (
	SHA_DIGEST_LENGTH = 20
)

Variables

var (
	ErrSessionNotFound = errors.New("not found session")
)

Functions

func NewAuthSessionManager

func NewAuthSessionManager() *authSessionManager

Types

type HandshakeStateCtx

type HandshakeStateCtx struct {
	State       int32  `json:"state,omitempty"`
	ResState    int32  `json:"res_state,omitempty"`
	Nonce       []byte `json:"nonce,omitempty"`
	ServerNonce []byte `json:"server_nonce,omitempty"`
	NewNonce    []byte `json:"new_nonce,omitempty"`
	A           []byte `json:"a,omitempty"`
	P           []byte `json:"p,omitempty"`

	ExpiresIn int32 `json:"expires_in,omitempty"`
	// contains filtered or unexported fields
}

func (*HandshakeStateCtx) DebugString

func (m *HandshakeStateCtx) DebugString() string

type Server

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

func New

func New(c config.Config) *Server

func (*Server) Close

func (s *Server) Close()

func (*Server) GatewaySendDataToGateway

func (s *Server) GatewaySendDataToGateway(ctx context.Context, in *gateway.TLGatewaySendDataToGateway) (reply *mtproto.Bool, err error)

GatewaySendDataToGateway gateway.sendDataToGateway auth_key_id:long session_id:long payload:bytes = Bool;

func (*Server) GetAuthKey

func (s *Server) GetAuthKey(authKeyId int64) *mtproto.AuthKeyInfo

func (*Server) GetConnByConnID

func (s *Server) GetConnByConnID(id uint64) *net2.TcpConnection

func (*Server) OnConnectionClosed

func (s *Server) OnConnectionClosed(conn *net2.TcpConnection)

func (*Server) OnConnectionDataArrived

func (s *Server) OnConnectionDataArrived(conn *net2.TcpConnection, msg interface{}) error

func (*Server) OnNewConnection

func (s *Server) OnNewConnection(conn *net2.TcpConnection)

/////////////////////////////////////////////////////////////////////////////////////////////

func (*Server) Ping

func (s *Server) Ping(ctx context.Context) (err error)

Ping ping the resource.

func (*Server) PutAuthKey

func (s *Server) PutAuthKey(keyInfo *mtproto.AuthKeyInfo)

func (*Server) SendToClient

func (s *Server) SendToClient(conn *net2.TcpConnection, authKey *authKeyUtil, b []byte) error

func (*Server) Serve

func (s *Server) Serve() error

type Session

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

func NewSession

func NewSession(c config.Config) *Session