I have this to my file but still facing the same issue
Please find the code snippet where this error is being generated and post it here.
This way we can attempt to replicate it.
Honestly I don’t where to find the code.
I have only one file that I am running and I am getting the error
python telegramForwarder.py
Can you try making a small change to the TelegramForwarder class. Just add an encoding instruction. So, prior to it writing, we encode the message to utf-8. The print statement just prior has no issue with it being utf-32, but the write does.
for dialog in dialogs:
print(f"Chat ID: {dialog.id}, Title: {dialog.title}")
chats_file.write(f"Chat ID: {dialog.id}, Title: {dialog.title} \n")
Can you change it to :
for dialog in dialogs:
print(f"Chat ID: {dialog.id}, Title: {dialog.title}")
enc = dialog.encode('utf-8')
chats_file.write(f"Chat ID: {enc}, Title: {enc} \n")
This is just an experiment by the way since this scipt is from a published module. This change is not permanent.
Sure Let me do it now.
Thanks
Thanks Paul,
I tried it now I am having different errors
Traceback (most recent call last):
File "C:\Users\ngass\OneDrive\Desktop\Telegram-Autoforwarder-master\telegramForwarder.py", line 125, in <module>
asyncio.run(main())
File "C:\Users\ngass\AppData\Local\Programs\Python\Python312\Lib\asyncio\runners.py", line 194, in run
return runner.run(main)
^^^^^^^^^^^^^^^^
File "C:\Users\ngass\AppData\Local\Programs\Python\Python312\Lib\asyncio\runners.py", line 118, in run
return self._loop.run_until_complete(task)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\ngass\AppData\Local\Programs\Python\Python312\Lib\asyncio\base_events.py", line 687, in run_until_complete
return future.result()
^^^^^^^^^^^^^^^
File "C:\Users\ngass\OneDrive\Desktop\Telegram-Autoforwarder-master\telegramForwarder.py", line 112, in main
await forwarder.list_chats()
File "C:\Users\ngass\OneDrive\Desktop\Telegram-Autoforwarder-master\telegramForwarder.py", line 26, in list_chats
enc = dialog.encode('utf-8')
^^^^^^^^^^^^^
AttributeError: 'Dialog' object has no attribute 'encode'
Ok, try this:
for dialog in dialogs:
print(f"Chat ID: {dialog.id}, Title: {dialog.title}")
temp1 = dialog.id
temp2 = dialog.title
enc1 = temp1.encode('utf-8')
enc2 = temp2.encode('utf-8')
chats_file.write(f"Chat ID: {enc1}, Title: {enc2} \n")
Hello Paul,
same error
File "C:\Users\ngass\OneDrive\Desktop\Telegram-Autoforwarder-master\telegramForwarder.py", line 126, in <module>
asyncio.run(main())
File "C:\Users\ngass\AppData\Local\Programs\Python\Python312\Lib\asyncio\runners.py", line 194, in run
return runner.run(main)
^^^^^^^^^^^^^^^^
File "C:\Users\ngass\AppData\Local\Programs\Python\Python312\Lib\asyncio\runners.py", line 118, in run
return self._loop.run_until_complete(task)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\ngass\AppData\Local\Programs\Python\Python312\Lib\asyncio\base_events.py", line 687, in run_until_complete
return future.result()
^^^^^^^^^^^^^^^
File "C:\Users\ngass\OneDrive\Desktop\Telegram-Autoforwarder-master\telegramForwarder.py", line 113, in main
await forwarder.list_chats()
File "C:\Users\ngass\OneDrive\Desktop\Telegram-Autoforwarder-master\telegramForwarder.py", line 27, in list_chats
enc = temp.encode('utf-8')
^^^^^^^^^^^
AttributeError: 'Dialog' object has no attribute 'encode'
Please see my previous post. I had made a mistake - I corrected it. Please try again with the updated snippet.
Hello Paul,
yes I have updated the code here’s
import time
import asyncio
from telethon.sync import TelegramClient
class TelegramForwarder:
def __init__(self, api_id, api_hash, phone_number):
self.api_id = api_id
self.api_hash = api_hash
self.phone_number = phone_number
self.client = TelegramClient('session_' + phone_number, api_id, api_hash)
async def list_chats(self):
await self.client.connect()
# Ensure you're authorized
if not await self.client.is_user_authorized():
await self.client.send_code_request(self.phone_number)
await self.client.sign_in(self.phone_number, input('Enter the code: '))
# Get a list of all the dialogs (chats)
dialogs = await self.client.get_dialogs()
chats_file = open(f"chats_of_{self.phone_number}.txt", "w")
# Print information about each chat
for dialog in dialogs:
print(f"Chat ID: {dialog.id}, Title: {dialog.title}")
temp = dialog
enc = temp.encode('utf-8')
chats_file.write(f"Chat ID: {enc}, Title: {enc} \n")
print("List of groups printed successfully!")
async def forward_messages_to_channel(self, source_chat_id, destination_channel_id, keywords):
await self.client.connect()
# Ensure you're authorized
if not await self.client.is_user_authorized():
await self.client.send_code_request(self.phone_number)
await self.client.sign_in(self.phone_number, input('Enter the code: '))
last_message_id = (await self.client.get_messages(source_chat_id, limit=1))[0].id
while True:
print("Checking for messages and forwarding them...")
# Get new messages since the last checked message
messages = await self.client.get_messages(source_chat_id, min_id=last_message_id, limit=None)
for message in reversed(messages):
# Check if the message text includes any of the keywords
if keywords:
if message.text and any(keyword in message.text.lower() for keyword in keywords):
print(f"Message contains a keyword: {message.text}")
# Forward the message to the destination channel
await self.client.send_message(destination_channel_id, message.text)
print("Message forwarded")
else:
# Forward the message to the destination channel
await self.client.send_message(destination_channel_id, message.text)
print("Message forwarded")
# Update the last message ID
last_message_id = max(last_message_id, message.id)
# Add a delay before checking for new messages again
await asyncio.sleep(5) # Adjust the delay time as needed
# Function to read credentials from file
def read_credentials():
try:
with open("credentials.txt", "r") as file:
lines = file.readlines()
api_id = lines[0].strip()
api_hash = lines[1].strip()
phone_number = lines[2].strip()
return api_id, api_hash, phone_number
except FileNotFoundError:
print("Credentials file not found.")
return None, None, None
# Function to write credentials to file
def write_credentials(api_id, api_hash, phone_number):
with open("credentials.txt", "w") as file:
file.write(api_id + "\n")
file.write(api_hash + "\n")
file.write(phone_number + "\n")
async def main():
# Attempt to read credentials from file
api_id, api_hash, phone_number = read_credentials()
# If credentials not found in file, prompt the user to input them
if api_id is None or api_hash is None or phone_number is None:
api_id = input("Enter your API ID: ")
api_hash = input("Enter your API Hash: ")
phone_number = input("Enter your phone number: ")
# Write credentials to file for future use
write_credentials(api_id, api_hash, phone_number)
forwarder = TelegramForwarder(api_id, api_hash, phone_number)
print("Choose an option:")
print("1. List Chats")
print("2. Forward Messages")
choice = input("Enter your choice: ")
if choice == "1":
await forwarder.list_chats()
elif choice == "2":
source_chat_id = int(input("Enter the source chat ID: "))
destination_channel_id = int(input("Enter the destination chat ID: "))
print("Enter keywords if you want to forward messages with specific keywords, or leave blank to forward every message!")
keywords = input("Put keywords (comma separated if multiple, or leave blank): ").split(",")
await forwarder.forward_messages_to_channel(source_chat_id, destination_channel_id, keywords)
else:
print("Invalid choice")
# Start the event loop and run the main function
if __name__ == "__main__":
asyncio.run(main())
I have updated it again.
Here’s the updated file version
import time
import asyncio
from telethon.sync import TelegramClient
class TelegramForwarder:
def __init__(self, api_id, api_hash, phone_number):
self.api_id = api_id
self.api_hash = api_hash
self.phone_number = phone_number
self.client = TelegramClient('session_' + phone_number, api_id, api_hash)
async def list_chats(self):
await self.client.connect()
# Ensure you're authorized
if not await self.client.is_user_authorized():
await self.client.send_code_request(self.phone_number)
await self.client.sign_in(self.phone_number, input('Enter the code: '))
# Get a list of all the dialogs (chats)
dialogs = await self.client.get_dialogs()
chats_file = open(f"chats_of_{self.phone_number}.txt", "w")
# Print information about each chat
for dialog in dialogs:
print(f"Chat ID: {dialog.id}, Title: {dialog.title}")
temp1 = dialog.id
temp2 = dialog.title
enc1 = temp1.encode('utf-8')
enc2 = temp2.encode('utf-8')
chats_file.write(f"Chat ID: {enc1}, Title: {enc2} \n")
print("List of groups printed successfully!")
async def forward_messages_to_channel(self, source_chat_id, destination_channel_id, keywords):
await self.client.connect()
# Ensure you're authorized
if not await self.client.is_user_authorized():
await self.client.send_code_request(self.phone_number)
await self.client.sign_in(self.phone_number, input('Enter the code: '))
last_message_id = (await self.client.get_messages(source_chat_id, limit=1))[0].id
while True:
print("Checking for messages and forwarding them...")
# Get new messages since the last checked message
messages = await self.client.get_messages(source_chat_id, min_id=last_message_id, limit=None)
for message in reversed(messages):
# Check if the message text includes any of the keywords
if keywords:
if message.text and any(keyword in message.text.lower() for keyword in keywords):
print(f"Message contains a keyword: {message.text}")
# Forward the message to the destination channel
await self.client.send_message(destination_channel_id, message.text)
print("Message forwarded")
else:
# Forward the message to the destination channel
await self.client.send_message(destination_channel_id, message.text)
print("Message forwarded")
# Update the last message ID
last_message_id = max(last_message_id, message.id)
# Add a delay before checking for new messages again
await asyncio.sleep(5) # Adjust the delay time as needed
# Function to read credentials from file
def read_credentials():
try:
with open("credentials.txt", "r") as file:
lines = file.readlines()
api_id = lines[0].strip()
api_hash = lines[1].strip()
phone_number = lines[2].strip()
return api_id, api_hash, phone_number
except FileNotFoundError:
print("Credentials file not found.")
return None, None, None
# Function to write credentials to file
def write_credentials(api_id, api_hash, phone_number):
with open("credentials.txt", "w") as file:
file.write(api_id + "\n")
file.write(api_hash + "\n")
file.write(phone_number + "\n")
async def main():
# Attempt to read credentials from file
api_id, api_hash, phone_number = read_credentials()
# If credentials not found in file, prompt the user to input them
if api_id is None or api_hash is None or phone_number is None:
api_id = input("Enter your API ID: ")
api_hash = input("Enter your API Hash: ")
phone_number = input("Enter your phone number: ")
# Write credentials to file for future use
write_credentials(api_id, api_hash, phone_number)
forwarder = TelegramForwarder(api_id, api_hash, phone_number)
print("Choose an option:")
print("1. List Chats")
print("2. Forward Messages")
choice = input("Enter your choice: ")
if choice == "1":
await forwarder.list_chats()
elif choice == "2":
source_chat_id = int(input("Enter the source chat ID: "))
destination_channel_id = int(input("Enter the destination chat ID: "))
print("Enter keywords if you want to forward messages with specific keywords, or leave blank to forward every message!")
keywords = input("Put keywords (comma separated if multiple, or leave blank): ").split(",")
await forwarder.forward_messages_to_channel(source_chat_id, destination_channel_id, keywords)
else:
print("Invalid choice")
# Start the event loop and run the main function
if __name__ == "__main__":
asyncio.run(main())
I am still facing the same error
Traceback (most recent call last):
File "C:\Users\ngass\OneDrive\Desktop\Telegram-Autoforwarder-master\telegramForwarder.py", line 128, in <module>
asyncio.run(main())
File "C:\Users\ngass\AppData\Local\Programs\Python\Python312\Lib\asyncio\runners.py", line 194, in run
return runner.run(main)
^^^^^^^^^^^^^^^^
File "C:\Users\ngass\AppData\Local\Programs\Python\Python312\Lib\asyncio\runners.py", line 118, in run
return self._loop.run_until_complete(task)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\ngass\AppData\Local\Programs\Python\Python312\Lib\asyncio\base_events.py", line 687, in run_until_complete
return future.result()
^^^^^^^^^^^^^^^
File "C:\Users\ngass\OneDrive\Desktop\Telegram-Autoforwarder-master\telegramForwarder.py", line 115, in main
await forwarder.list_chats()
File "C:\Users\ngass\OneDrive\Desktop\Telegram-Autoforwarder-master\telegramForwarder.py", line 28, in list_chats
enc1 = temp1.encode('utf-8')
^^^^^^^^^^^^
AttributeError: 'int' object has no attribute 'encode'
Ok, its because in some cases the values are type int. Let’s perform temporary typecasting to string str:
temp1 = str(dialog.id)
temp2 = str(dialog.title)
enc1 = temp1.encode('utf-8')
enc2 = temp2.encode('utf-8')
There’s a problem here.
The result of encoding is bytes, which you’re then interpolating into a string, so if the string contained, say, 'This is a wolf: 🐺' (i.e., 'This is a wolf: \N{WOLF FACE}'), this will give you b'This is a wolf: \xf0\x9f\x90\xba', and that’s what will appear in the file.
I still think it’s better to specify the encoding when opening the file as I posted above.
Thank you Matthew please could you provide an example of what I will input in my file.
Here’s the file content please take a look where you can modify and let me know.
import time
import asyncio
from telethon.sync import TelegramClient
class TelegramForwarder:
def __init__(self, api_id, api_hash, phone_number):
self.api_id = api_id
self.api_hash = api_hash
self.phone_number = phone_number
self.client = TelegramClient('session_' + phone_number, api_id, api_hash)
async def list_chats(self):
await self.client.connect()
# Ensure you're authorized
if not await self.client.is_user_authorized():
await self.client.send_code_request(self.phone_number)
await self.client.sign_in(self.phone_number, input('Enter the code: '))
# Get a list of all the dialogs (chats)
dialogs = await self.client.get_dialogs()
chats_file = open(f"chats_of_{self.phone_number}.txt", "w")
# Print information about each chat
for dialog in dialogs:
print(f"Chat ID: {dialog.id}, Title: {dialog.title}")
temp1 = dialog.id
temp2 = dialog.title
enc1 = temp1.encode('utf-8')
enc2 = temp2.encode('utf-8')
chats_file.write(f"Chat ID: {enc1}, Title: {enc2} \n")
print("List of groups printed successfully!")
async def forward_messages_to_channel(self, source_chat_id, destination_channel_id, keywords):
await self.client.connect()
# Ensure you're authorized
if not await self.client.is_user_authorized():
await self.client.send_code_request(self.phone_number)
await self.client.sign_in(self.phone_number, input('Enter the code: '))
last_message_id = (await self.client.get_messages(source_chat_id, limit=1))[0].id
while True:
print("Checking for messages and forwarding them...")
# Get new messages since the last checked message
messages = await self.client.get_messages(source_chat_id, min_id=last_message_id, limit=None)
for message in reversed(messages):
# Check if the message text includes any of the keywords
if keywords:
if message.text and any(keyword in message.text.lower() for keyword in keywords):
print(f"Message contains a keyword: {message.text}")
# Forward the message to the destination channel
await self.client.send_message(destination_channel_id, message.text)
print("Message forwarded")
else:
# Forward the message to the destination channel
await self.client.send_message(destination_channel_id, message.text)
print("Message forwarded")
# Update the last message ID
last_message_id = max(last_message_id, message.id)
# Add a delay before checking for new messages again
await asyncio.sleep(5) # Adjust the delay time as needed
# Function to read credentials from file
def read_credentials():
try:
with open("credentials.txt", "r") as file:
lines = file.readlines()
api_id = lines[0].strip()
api_hash = lines[1].strip()
phone_number = lines[2].strip()
return api_id, api_hash, phone_number
except FileNotFoundError:
print("Credentials file not found.")
return None, None, None
# Function to write credentials to file
def write_credentials(api_id, api_hash, phone_number):
with open("credentials.txt", "w") as file:
file.write(api_id + "\n")
file.write(api_hash + "\n")
file.write(phone_number + "\n")
async def main():
# Attempt to read credentials from file
api_id, api_hash, phone_number = read_credentials()
# If credentials not found in file, prompt the user to input them
if api_id is None or api_hash is None or phone_number is None:
api_id = input("Enter your API ID: ")
api_hash = input("Enter your API Hash: ")
phone_number = input("Enter your phone number: ")
# Write credentials to file for future use
write_credentials(api_id, api_hash, phone_number)
forwarder = TelegramForwarder(api_id, api_hash, phone_number)
print("Choose an option:")
print("1. List Chats")
print("2. Forward Messages")
choice = input("Enter your choice: ")
if choice == "1":
await forwarder.list_chats()
elif choice == "2":
source_chat_id = int(input("Enter the source chat ID: "))
destination_channel_id = int(input("Enter the destination chat ID: "))
print("Enter keywords if you want to forward messages with specific keywords, or leave blank to forward every message!")
keywords = input("Put keywords (comma separated if multiple, or leave blank): ").split(",")
await forwarder.forward_messages_to_channel(source_chat_id, destination_channel_id, keywords)
else:
print("Invalid choice")
# Start the event loop and run the main function
if __name__ == "__main__":
asyncio.run(main())
As per @MRAB, you have to apply to ALL of your open file actions not just that one:
chats_file = open(f"chats_of_{self.phone_number}.txt", "w", encoding = 'utf-8')
Scan the ENTIRE file, and add this explicit instruction. EVERYWHERE a file is being opened, add the encoding = 'utf-8' instrucition.
I see 3 places where a file is opened. 2 of them open the credentials file, which, most probably, has contents that are ASCII-range, so I wouldn’t worry too much about them.
The 3rd one is the one a chat file is opened for writing, and as the chat might contain, say, emojis, that should be opened for UTF-8.
Actually, the chat files are opened as f"chats_of_{self.phone_number}.txt", which kind of suggests that they’re meant to contain one or more chats, but they’re opened for writing ("w"), which will truncate them each time. If they’re meant to contain multiple chats, then the file mode should be changed from "w" (writing) to "a" (appending).
Hello Matthew,
sorry I don’t understand what you meant and I don’t see encoding in my file
here’s my file content
import time
import asyncio
from telethon.sync import TelegramClient
class TelegramForwarder:
def __init__(self, api_id, api_hash, phone_number):
self.api_id = api_id
self.api_hash = api_hash
self.phone_number = phone_number
self.client = TelegramClient('session_' + phone_number, api_id, api_hash)
async def list_chats(self):
await self.client.connect()
# Ensure you're authorized
if not await self.client.is_user_authorized():
await self.client.send_code_request(self.phone_number)
await self.client.sign_in(self.phone_number, input('Enter the code: '))
# Get a list of all the dialogs (chats)
dialogs = await self.client.get_dialogs()
chats_file = open(f"chats_of_{self.phone_number}.txt", "w")
# Print information about each chat
for dialog in dialogs:
print(f"Chat ID: {dialog.id}, Title: {dialog.title}")
chats_file.write(f"Chat ID: {dialog.id}, Title: {dialog.title} \n")
print("List of groups printed successfully!")
async def forward_messages_to_channel(self, source_chat_id, destination_channel_id, keywords):
await self.client.connect()
# Ensure you're authorized
if not await self.client.is_user_authorized():
await self.client.send_code_request(self.phone_number)
await self.client.sign_in(self.phone_number, input('Enter the code: '))
last_message_id = (await self.client.get_messages(source_chat_id, limit=1))[0].id
while True:
print("Checking for messages and forwarding them...")
# Get new messages since the last checked message
messages = await self.client.get_messages(source_chat_id, min_id=last_message_id, limit=None)
for message in reversed(messages):
# Check if the message text includes any of the keywords
if keywords:
if message.text and any(keyword in message.text.lower() for keyword in keywords):
print(f"Message contains a keyword: {message.text}")
# Forward the message to the destination channel
await self.client.send_message(destination_channel_id, message.text)
print("Message forwarded")
else:
# Forward the message to the destination channel
await self.client.send_message(destination_channel_id, message.text)
print("Message forwarded")
# Update the last message ID
last_message_id = max(last_message_id, message.id)
# Add a delay before checking for new messages again
await asyncio.sleep(5) # Adjust the delay time as needed
# Function to read credentials from file
def read_credentials():
try:
with open("credentials.txt", "r") as file:
lines = file.readlines()
api_id = lines[0].strip()
api_hash = lines[1].strip()
phone_number = lines[2].strip()
return api_id, api_hash, phone_number
except FileNotFoundError:
print("Credentials file not found.")
return None, None, None
# Function to write credentials to file
def write_credentials(api_id, api_hash, phone_number):
with open("credentials.txt", "w") as file:
file.write(api_id + "\n")
file.write(api_hash + "\n")
file.write(phone_number + "\n")
async def main():
# Attempt to read credentials from file
api_id, api_hash, phone_number = read_credentials()
# If credentials not found in file, prompt the user to input them
if api_id is None or api_hash is None or phone_number is None:
api_id = input("Enter your API ID: ")
api_hash = input("Enter your API Hash: ")
phone_number = input("Enter your phone number: ")
# Write credentials to file for future use
write_credentials(api_id, api_hash, phone_number)
forwarder = TelegramForwarder(api_id, api_hash, phone_number)
print("Choose an option:")
print("1. List Chats")
print("2. Forward Messages")
choice = input("Enter your choice: ")
if choice == "1":
await forwarder.list_chats()
elif choice == "2":
source_chat_id = int(input("Enter the source chat ID: "))
destination_channel_id = int(input("Enter the destination chat ID: "))
print("Enter keywords if you want to forward messages with specific keywords, or leave blank to forward every message!")
keywords = input("Put keywords (comma separated if multiple, or leave blank): ").split(",")
await forwarder.forward_messages_to_channel(source_chat_id, destination_channel_id, keywords)
else:
print("Invalid choice")
# Start the event loop and run the main function
if __name__ == "__main__":
asyncio.run(main())
chats_file = open(f"chats_of_{self.phone_number}.txt", "w", encoding = 'utf-8')
Scan the ENTIRE file, and add this explicit instruction. EVERYWHERE a file is being opened, add the encoding = 'utf-8' instrucition.
You mean I should change everywhere I find “W” to “a”?
Hello Matthew,
I tried to change"W" to “a” as requested but I am still facing same error.
Traceback (most recent call last): File "C:\Users\ngass\OneDrive\Desktop\Telegram-Autoforwarder-master\telegramForwarder.py", line 124, in <module> asyncio.run(main()) File "C:\Users\ngass\AppData\Local\Programs\Python\Python312\Lib\asyncio\runners.py", line 194, in run return runner.run(main) ^^^^^^^^^^^^^^^^ File "C:\Users\ngass\AppData\Local\Programs\Python\Python312\Lib\asyncio\runners.py", line 118, in run return self._loop.run_until_complete(task) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ File "C:\Users\ngass\AppData\Local\Programs\Python\Python312\Lib\asyncio\base_events.py", line 687, in run_until_complete return future.result() ^^^^^^^^^^^^^^^ File "C:\Users\ngass\OneDrive\Desktop\Telegram-Autoforwarder-master\telegramForwarder.py", line 111, in main await forwarder.list_chats() File "C:\Users\ngass\OneDrive\Desktop\Telegram-Autoforwarder-master\telegramForwarder.py", line 26, in list_chats chats_file.write(f"Chat ID: {dialog.id}, Title: {dialog.title} \n") File "C:\Users\ngass\AppData\Local\Programs\Python\Python312\Lib\encodings\cp1252.py", line 19, in encode return codecs.charmap_encode(input,self.errors,encoding_table)[0] ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ UnicodeEncodeError: 'charmap' codec can't encode character '\U0001f43a' in position 55: character maps to <undefined> PS C:\Users\ngass\OneDrive\Desktop\Telegram-Autoforwarder-master>