LonamiWebs/Telethon
1
1
Fork 0
mirror of https://github.com/LonamiWebs/Telethon.git synced 2024-11-22 09:26:37 +03:00
Code Issues Packages Projects Releases Wiki Activity

Revert "Mark certain SQLiteSession methods as async"

Browse Source 
This reverts commit f913ea6b75.
This commit is contained in:
Lonami Exo 2022-08-30 12:22:05 +02:00
parent 44e3651adf
commit 88b2b9372d
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
telethon/sessions/sqlite.py
View File

@ -201,7 +201,7 @@ class SQLiteSession(MemorySession):
)) ))
c.close() c.close()
async def get_update_state(self, entity_id): def get_update_state(self, entity_id):
row = self._execute('select pts, qts, date, seq from update_state ' row = self._execute('select pts, qts, date, seq from update_state '
'where id = ?', entity_id) 'where id = ?', entity_id)
if row: if row:
@ -210,7 +210,7 @@ class SQLiteSession(MemorySession):
date, tz=datetime.timezone.utc) date, tz=datetime.timezone.utc)
return types.updates.State(pts, qts, date, seq, unread_count=0) return types.updates.State(pts, qts, date, seq, unread_count=0)
async def set_update_state(self, entity_id, state): def set_update_state(self, entity_id, state):
self._execute('insert or replace into update_state values (?,?,?,?,?)', self._execute('insert or replace into update_state values (?,?,?,?,?)',
entity_id, state.pts, state.qts, entity_id, state.pts, state.qts,
state.date.timestamp(), state.seq) state.date.timestamp(), state.seq)
@ -229,7 +229,7 @@ class SQLiteSession(MemorySession):
finally: finally:
c.close() c.close()
async def save(self): def save(self):
"""Saves the current session object as session_user_id.session""" """Saves the current session object as session_user_id.session"""
# This is a no-op if there are no changes to commit, so there's # This is a no-op if there are no changes to commit, so there's
# no need for us to keep track of an "unsaved changes" variable. # no need for us to keep track of an "unsaved changes" variable.
@ -254,7 +254,7 @@ class SQLiteSession(MemorySession):
finally: finally:
c.close() c.close()
async def close(self): def close(self):
"""Closes the connection unless we're working in-memory""" """Closes the connection unless we're working in-memory"""
if self.filename != ':memory:': if self.filename != ':memory:':
if self._conn is not None: if self._conn is not None:
@ -262,7 +262,7 @@ class SQLiteSession(MemorySession):
self._conn.close() self._conn.close()
self._conn = None self._conn = None
async def delete(self): def delete(self):
"""Deletes the current session file""" """Deletes the current session file"""
if self.filename == ':memory:': if self.filename == ':memory:':
return True return True
@ -282,7 +282,7 @@ class SQLiteSession(MemorySession):
# Entity processing # Entity processing
async def process_entities(self, tlo): def process_entities(self, tlo):
""" """
Processes all the found entities on the given TLObject, Processes all the found entities on the given TLObject,
unless .save_entities is False. unless .save_entities is False.