mirror of
https://github.com/pyrogram/pyrogram
synced 2025-08-28 12:57:52 +00:00
Make use of the "with" context manager
This commit is contained in:
parent
95821f088b
commit
5e8be0e6ef
@ -28,25 +28,22 @@ target = "me" # "me" refers to your own chat (Saved Messages)
|
|||||||
messages = [] # List that will contain all the messages of the target chat
|
messages = [] # List that will contain all the messages of the target chat
|
||||||
offset_id = 0 # ID of the last message of the chunk
|
offset_id = 0 # ID of the last message of the chunk
|
||||||
|
|
||||||
app.start()
|
with app:
|
||||||
|
while True:
|
||||||
|
try:
|
||||||
|
m = app.get_history(target, offset_id=offset_id)
|
||||||
|
except FloodWait as e: # For very large chats the method call can raise a FloodWait
|
||||||
|
print("waiting {}".format(e.x))
|
||||||
|
time.sleep(e.x) # Sleep X seconds before continuing
|
||||||
|
continue
|
||||||
|
|
||||||
while True:
|
if not m.messages:
|
||||||
try:
|
break
|
||||||
m = app.get_history(target, offset_id=offset_id)
|
|
||||||
except FloodWait as e: # For very large chats the method call can raise a FloodWait
|
|
||||||
print("waiting {}".format(e.x))
|
|
||||||
time.sleep(e.x) # Sleep X seconds before continuing
|
|
||||||
continue
|
|
||||||
|
|
||||||
if not m.messages:
|
messages += m.messages
|
||||||
break
|
offset_id = m.messages[-1].message_id
|
||||||
|
|
||||||
messages += m.messages
|
print("Messages: {}".format(len(messages)))
|
||||||
offset_id = m.messages[-1].message_id
|
|
||||||
|
|
||||||
print("Messages: {}".format(len(messages)))
|
|
||||||
|
|
||||||
app.stop()
|
|
||||||
|
|
||||||
# Now the "messages" list contains all the messages sorted by date in
|
# Now the "messages" list contains all the messages sorted by date in
|
||||||
# descending order (from the most recent to the oldest one)
|
# descending order (from the most recent to the oldest one)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user