mtproto

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

type Error struct {
	Code     int    // 420
	Message  string // FLOOD_WAIT_3
	Type     string // FLOOD_WAIT
	Argument int    // 3
}

type Handler func(b *bin.Buffer) error

type MessageIDSource interface {
	New(t proto.MessageType) int64
}

type Options struct {
	// PublicKeys of telegram.
	//
	// If not provided, embedded public keys will be used.
	PublicKeys []*rsa.PublicKey

	// Transport to use. Default dialer will be used if not provided.
	Transport Transport
	// Network to use. Defaults to tcp.
	Network string
	// Random is random source. Defaults to crypto.
	Random io.Reader
	// Logger is instance of zap.Logger. No logs by default.
	Logger *zap.Logger
	// Handler will be called on received message.
	Handler Handler
	// AckBatchSize is maximum ack-s to buffer.
	AckBatchSize int
	// AckInterval is maximum time to buffer ack.
	AckInterval time.Duration

	RetryInterval time.Duration
	MaxRetries    int
	MessageID     MessageIDSource
	Clock         clock.Clock
	OnReconnect   func() error
	Types         *tmap.Map

	Key  crypto.AuthKeyWithID
	Salt int64
}

type Session struct {
	Key  crypto.AuthKeyWithID
	Salt int64
}

type Transport interface {
	Codec() transport.Codec
	DialContext(ctx context.Context, network, address string) (transport.Conn, error)
}