Struct PtsState 

pub struct PtsState {
    pub pts: i32,
    pub qts: i32,
    pub date: i32,
    pub seq: i32,
    pub channel_pts: HashMap<i64, i32>,
    pub last_update_at: Option<Instant>,
    pub getting_diff_for: HashSet<i64>,
}

Full MTProto sequence-number state, including per-channel counters.

All fields are pub so that connect() can restore them from the persisted session without going through an artificial constructor.

Fields

pts: i32

Main pts counter (messages, non-channel updates).

qts: i32

G-18: Secondary counter for secret-chat updates.

date: i32

Date of the last received update (Unix timestamp).

seq: i32

G-19: Combined-container sequence number.

channel_pts: HashMap<i64, i32>

Per-channel pts counters. channel_id → pts.

last_update_at: Option<Instant>

G-16: Timestamp of last received update for deadline-based gap detection.

getting_diff_for: HashSet<i64>

Fix #4: Channels currently awaiting a getChannelDifference response. If a channel is in this set, no new gap-fill task is spawned for it — matches grammers’ getting_diff_for guard that prevents 1 gap → N tasks.

Implementations

impl PtsState

pub fn from_server_state(s: &State) -> Self

pub fn touch(&mut self)

Record that an update was received now (resets the deadline timer).

pub fn deadline_exceeded(&self) -> bool

G-16: Returns true if no update has been received for > 15 minutes.

pub fn check_pts(&self, new_pts: i32, pts_count: i32) -> PtsCheckResult

Check whether new_pts is in order given pts_count new updates.

pub fn check_qts(&self, new_qts: i32, qts_count: i32) -> PtsCheckResult

G-18: Check a qts value (secret chat updates).

pub fn check_seq(&self, _new_seq: i32, seq_start: i32) -> PtsCheckResult

G-19: Check top-level seq for UpdatesCombined containers.

pub fn check_channel_pts( &self, channel_id: i64, new_pts: i32, pts_count: i32, ) -> PtsCheckResult

Check a per-channel pts value.

pub fn advance(&mut self, new_pts: i32)

Advance the global pts.

pub fn advance_qts(&mut self, new_qts: i32)

Advance the qts (G-18).

pub fn advance_seq(&mut self, new_seq: i32)

Advance seq (G-19).

pub fn advance_channel(&mut self, channel_id: i64, new_pts: i32)

Advance a per-channel pts.

Trait Implementations

impl Clone for PtsState

fn clone(&self) -> PtsState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PtsState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PtsState

fn default() -> PtsState

Returns the “default value” for a type.