mtproto

type Handler interface {
	OnMessage(server *Server, req *Request) error
}

type HandlerFunc func(server *Server, req *Request) error

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

type KeyStorage interface {
	// Save persists an auth key. Saving an existing key is not an error.
	Save(ctx context.Context, key crypto.AuthKey) error
	// Get returns the key by its 8-byte ID. The boolean is false when absent.
	Get(ctx context.Context, id [8]byte) (crypto.AuthKey, bool, error)
}

type Request struct {
	// DC is the DC ID of the server that received the request.
	DC int
	// Session is the user session the request arrived on.
	Session Session
	// MsgID is the message ID of the RPC request.
	MsgID int64
	// Buf contains the RPC request body.
	Buf *bin.Buffer
	// RequestCtx is the request context.
	RequestCtx context.Context
}

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

type ServerOptions struct {
	// DC is the DC ID of this server. Defaults to 2.
	DC int
	// Random is the random source. Defaults to crypto.DefaultRand.
	Random io.Reader
	// Logger is the zap logger. No logs by default.
	Logger *zap.Logger
	// Keys persists auth keys. Defaults to an in-memory store.
	Keys KeyStorage
	// Clock to use. Defaults to clock.System.
	Clock clock.Clock
	// MessageID generates server message IDs. Defaults to proto.NewMessageIDGen.
	MessageID mtproto.MessageIDSource
	// Types is a type map used in verbose logging of incoming messages.
	Types *tmap.Map
	// ReadTimeout is the connection read timeout.
	ReadTimeout time.Duration
	// WriteTimeout is the connection write timeout.
	WriteTimeout time.Duration
	// Providers supplies the OpenTelemetry tracer and meter for this layer.
	// The zero value yields no-op instrumentation.
	Providers obs.Providers
}

type Session struct {
	// ID is a session ID.
	ID int64
	// AuthKey is the attached auth key.
	AuthKey crypto.AuthKey
}