proto

type DecompressionBombErr ¶

type DecompressionBombErr struct {
	Compressed   int
	Decompressed int
}

DecompressionBombErr means that GZIP decode detected decompression bomb which decompressed payload is significantly higher than initial compressed size and stopped decompression to prevent OOM.

func (d *DecompressionBombErr) Error() string

type GZIP ¶

type GZIP struct {
	Data []byte
}

GZIP represents a Packed Object.

Used to replace any other object (or rather, a serialization thereof) with its archived (gzipped) representation.

func (g *GZIP) Decode(b *bin.Buffer) (rErr error)

func (g GZIP) Encode(b *bin.Buffer) (rErr error)

type Message ¶

type Message struct {
	ID    int64
	SeqNo int
	Bytes int
	Body  []byte
}

Message is element of MessageContainer.

func (m *Message) Decode(b *bin.Buffer) error

func (m *Message) Encode(b *bin.Buffer) error

type MessageContainer ¶

type MessageContainer struct {
	Messages []Message
}

MessageContainer contains slice of messages.

func (m *MessageContainer) Decode(b *bin.Buffer) error

func (m *MessageContainer) Encode(b *bin.Buffer) error

type MessageID ¶

type MessageID int64

MessageID represents 64-bit message id.

func NewMessageID(now time.Time, typ MessageType) MessageID

func NewMessageIDNano(nano int64, typ MessageType) MessageID

func (id MessageID) String() string

func (id MessageID) Time() time.Time

func (id MessageID) Type() MessageType

type MessageIDBuf ¶

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

MessageIDBuf stores the last N received message ids and is used in replay attack mitigation.

It works like TDLib's MessageIdDuplicateChecker: ids are kept sorted in a buffer of 2N, so an id is checked by binary search, an increasing id (the common case) is appended, and the oldest N are dropped at once when the buffer is full.

func NewMessageIDBuf(n int) *MessageIDBuf

func (b *MessageIDBuf) Consume(newID int64) bool

func (b *MessageIDBuf) Reset()

type MessageIDGen ¶

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

MessageIDGen is message id generator that provides collision prevention.

Ids follow TDLib (AuthData::next_message_id): the time of now() with 22 random bits XORed into the fraction, and if that is not above the last id (now() returned the same or an earlier time, e.g. after a correction of the server time offset), the last id plus a random multiple of 4. So ids always increase, and their lower bits don't reveal the clock resolution.

func NewMessageIDGen(now func() time.Time) *MessageIDGen

func (g *MessageIDGen) New(t MessageType) int64

func (g *MessageIDGen) Reset()

type MessageType ¶

type MessageType byte

MessageType is type of message determined by message id.

A message is rejected over 300 seconds after it is created or 30 seconds before it is created (this is needed to protect from replay attacks).

The identifier of a message container must be strictly greater than those of its nested messages.

const (
	// MessageUnknown reports that message id has unknown time and probably
	// should be ignored.
	MessageUnknown MessageType = iota
	// MessageFromClient is client message identifiers.
	MessageFromClient
	// MessageServerResponse is a response to a client message.
	MessageServerResponse
	// MessageFromServer is a message from the server.
	MessageFromServer
)

func (m MessageType) String() string

type Result ¶

type Result struct {
	RequestMessageID int64
	Result           []byte
}

Result is rpc_result#f35c6d01.

func (r *Result) Decode(b *bin.Buffer) error

func (r *Result) Encode(b *bin.Buffer) error

type UnencryptedMessage ¶

type UnencryptedMessage struct {
	MessageID   int64
	MessageData []byte
}

UnencryptedMessage is plaintext message.

func (u *UnencryptedMessage) Decode(b *bin.Buffer) error

func (u UnencryptedMessage) Encode(b *bin.Buffer) error