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 "Add missing async keywords in SQLiteSession"

Browse Source 
This reverts commit 0f5eeb29e7.
This commit is contained in:
Lonami Exo 2022-08-30 12:32:23 +02:00
parent 7d21b40401
commit e87e6738b5
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
telethon/sessions/sqlite.py
View File

@ -303,11 +303,11 @@ class SQLiteSession(MemorySession):
finally: finally:
c.close() c.close()
async def get_entity_rows_by_phone(self, phone): def get_entity_rows_by_phone(self, phone):
return self._execute( return self._execute(
'select id, hash from entities where phone = ?', phone) 'select id, hash from entities where phone = ?', phone)
async def get_entity_rows_by_username(self, username): def get_entity_rows_by_username(self, username):
c = self._cursor() c = self._cursor()
try: try:
results = c.execute( results = c.execute(
@ -328,7 +328,7 @@ class SQLiteSession(MemorySession):
finally: finally:
c.close() c.close()
async def get_entity_rows_by_name(self, name): def get_entity_rows_by_name(self, name):
return self._execute( return self._execute(
'select id, hash from entities where name = ?', name) 'select id, hash from entities where name = ?', name)
@ -346,7 +346,7 @@ class SQLiteSession(MemorySession):
# File processing # File processing
async def get_file(self, md5_digest, file_size, cls): def get_file(self, md5_digest, file_size, cls):
row = self._execute( row = self._execute(
'select id, hash from sent_files ' 'select id, hash from sent_files '
'where md5_digest = ? and file_size = ? and type = ?', 'where md5_digest = ? and file_size = ? and type = ?',
@ -356,7 +356,7 @@ class SQLiteSession(MemorySession):
# Both allowed classes have (id, access_hash) as parameters # Both allowed classes have (id, access_hash) as parameters
return cls(row[0], row[1]) return cls(row[0], row[1])
async def cache_file(self, md5_digest, file_size, instance): def cache_file(self, md5_digest, file_size, instance):
if not isinstance(instance, (InputDocument, InputPhoto)): if not isinstance(instance, (InputDocument, InputPhoto)):
raise TypeError('Cannot cache %s instance' % type(instance)) raise TypeError('Cannot cache %s instance' % type(instance))