Всем привет, нужна ваша помощь. требуется объединить два скрипта, сам пытался не получилось.
from pyrogram import Client, filters # телеграм клиент
1) скрипт
import shelve # файловая база данных
db = shelve.open('data.db', writeback=True)
# Создать можно на my.telegram.org
API_ID = ******
API_HASH = '********'
PRIVATE_PUBLIC = '*****' # скрытый паблик для управления ботом
PUBLIC_PUBLIC = '********' # паблик куда будем репостить
SOURCE_PUBLICS = [*********] #pizdem
PHONE_NUMBER = '*********' # номер зарегистрованный в телеге
# создаем клиент телеграм
app = Client("cyberpunk", api_id=API_ID, api_hash=API_HASH,
phone_number=PHONE_NUMBER)
# обработчик нового сообщения
# вызывается при появлении нового поста в одном из пабликов-доноров
@app.on_message(filters.chat(SOURCE_PUBLICS))
def new_channel_post(client, message):
# сохраняем пост в базу (функцию add_post_to_db определим потом)
post_id = add_post_to_db(message)
# пересылаем пост в скрытый паблик
message.forward(PRIVATE_PUBLIC)
# в скрытый паблик отправляем присвоенный id поста
client.send_message(PRIVATE_PUBLIC, post_id)
# потом для пересылки в публичный паблик админ должен отправить боту этот id
# функция сохранения поста в бд
# генерирует уникальный id для поста и возвратит этот id
def add_post_to_db(message):
try:
# генерируем уникальный id для поста, равен максимальному в базе + 1
new_id = max(int(k) for k in db.keys()
if k.isdigit()) + 1
except:
# если постов еще нет в базе вылетит ошибка и мы попадем сюда
# тогда id ставим = 1
new_id = 1
# запись в базу необходимой информации про пост
# Обратите внимание, shelve поддеживает только строковые ключи
db[str(new_id)] = {
'username': message.sender_chat.username, # паблик-донор
'message_id': message.id, # внутренний id сообщения
}
return new_id
# обработчик нового сообщения из скрытого паблика
# если админ пишет в паблик `132+` это значит переслать пост с id = 132 в публичный паблик
@app.on_message(filters.chat(PRIVATE_PUBLIC)
& filters.regex(r'\d+\+') # фильтр текста сообщения `{число}+`
)
def post_request(client, message):
# получаем id поста из сообщения (обрезаем "+" в конце)
post_id = str(message.text).strip('+')
# получаем из базы пост по этому id
post = db.get(post_id)
if post is None:
# если нет в базе пишем в скрытый паблик ошибку
client.send_message(PRIVATE_PUBLIC,
'`ERROR NO POST ID IN DB`')
# и выходим
return
try:
# по данным из базы, получаем pyrogram обьект сообщения
msg = client.get_messages(post['username'], post['message_id'])
# пересылаем его в паблик
msg.forward(PUBLIC_PUBLIC)
# отправляем сообщение в скрытый паблик о успехе
client.send_message(PRIVATE_PUBLIC, f'`ПОСТ ОПУБЛИКОВАН!`')
except Exception as e:
# если произойдет какая-то ошибка в 3 строчках выше - сообщим админу
client.send_message(PRIVATE_PUBLIC, f'`ОШИБКА {e}`')
if __name__ == '__main__':
print('Atempt to run telegrabber')
app.run() # эта строка запустит все обработчики
2)скрипт
from telethon import TelegramClient, events
from telethon import errors
import asyncio
import re
api_id = *****
api_hash = '********'
my_channel_id = '*******'
channels = '*******'
Bad_Keys = ['*****']
KEYS = {
"***": '***'
}
KEYS = {
"*********'
}
tags = ''
client = TelegramClient('myGrab', api_id, api_hash)
print("GRAB - Started")
@client.on(events.NewMessage(chats=channels))
async def my_event_handler(event):
text = event.raw_text
for i in KEYS:
text = re.sub(i, KEYS, text)
try:
await client.send_message(my_channel_id, message=text + tags, file=event.message.media)
except errors.FloodWaitError as e:
print(f'[!] Ошибка флуда ждем: {e.seconds} секунд')
await asyncio.sleep(e.seconds)
except Exception as e:
print('[!] Ошибка', e)
client.start()
client.run_until_disconnected()
from pyrogram import Client, filters # телеграм клиент
1) скрипт
import shelve # файловая база данных
db = shelve.open('data.db', writeback=True)
# Создать можно на my.telegram.org
API_ID = ******
API_HASH = '********'
PRIVATE_PUBLIC = '*****' # скрытый паблик для управления ботом
PUBLIC_PUBLIC = '********' # паблик куда будем репостить
SOURCE_PUBLICS = [*********] #pizdem
PHONE_NUMBER = '*********' # номер зарегистрованный в телеге
# создаем клиент телеграм
app = Client("cyberpunk", api_id=API_ID, api_hash=API_HASH,
phone_number=PHONE_NUMBER)
# обработчик нового сообщения
# вызывается при появлении нового поста в одном из пабликов-доноров
@app.on_message(filters.chat(SOURCE_PUBLICS))
def new_channel_post(client, message):
# сохраняем пост в базу (функцию add_post_to_db определим потом)
post_id = add_post_to_db(message)
# пересылаем пост в скрытый паблик
message.forward(PRIVATE_PUBLIC)
# в скрытый паблик отправляем присвоенный id поста
client.send_message(PRIVATE_PUBLIC, post_id)
# потом для пересылки в публичный паблик админ должен отправить боту этот id
# функция сохранения поста в бд
# генерирует уникальный id для поста и возвратит этот id
def add_post_to_db(message):
try:
# генерируем уникальный id для поста, равен максимальному в базе + 1
new_id = max(int(k) for k in db.keys()
if k.isdigit()) + 1
except:
# если постов еще нет в базе вылетит ошибка и мы попадем сюда
# тогда id ставим = 1
new_id = 1
# запись в базу необходимой информации про пост
# Обратите внимание, shelve поддеживает только строковые ключи
db[str(new_id)] = {
'username': message.sender_chat.username, # паблик-донор
'message_id': message.id, # внутренний id сообщения
}
return new_id
# обработчик нового сообщения из скрытого паблика
# если админ пишет в паблик `132+` это значит переслать пост с id = 132 в публичный паблик
@app.on_message(filters.chat(PRIVATE_PUBLIC)
& filters.regex(r'\d+\+') # фильтр текста сообщения `{число}+`
)
def post_request(client, message):
# получаем id поста из сообщения (обрезаем "+" в конце)
post_id = str(message.text).strip('+')
# получаем из базы пост по этому id
post = db.get(post_id)
if post is None:
# если нет в базе пишем в скрытый паблик ошибку
client.send_message(PRIVATE_PUBLIC,
'`ERROR NO POST ID IN DB`')
# и выходим
return
try:
# по данным из базы, получаем pyrogram обьект сообщения
msg = client.get_messages(post['username'], post['message_id'])
# пересылаем его в паблик
msg.forward(PUBLIC_PUBLIC)
# отправляем сообщение в скрытый паблик о успехе
client.send_message(PRIVATE_PUBLIC, f'`ПОСТ ОПУБЛИКОВАН!`')
except Exception as e:
# если произойдет какая-то ошибка в 3 строчках выше - сообщим админу
client.send_message(PRIVATE_PUBLIC, f'`ОШИБКА {e}`')
if __name__ == '__main__':
print('Atempt to run telegrabber')
app.run() # эта строка запустит все обработчики
2)скрипт
from telethon import TelegramClient, events
from telethon import errors
import asyncio
import re
api_id = *****
api_hash = '********'
my_channel_id = '*******'
channels = '*******'
Bad_Keys = ['*****']
KEYS = {
"***": '***'
}
KEYS = {
"*********'
}
tags = ''
client = TelegramClient('myGrab', api_id, api_hash)
print("GRAB - Started")
@client.on(events.NewMessage(chats=channels))
async def my_event_handler(event):
text = event.raw_text
for i in KEYS:
text = re.sub(i, KEYS, text)
try:
await client.send_message(my_channel_id, message=text + tags, file=event.message.media)
except errors.FloodWaitError as e:
print(f'[!] Ошибка флуда ждем: {e.seconds} секунд')
await asyncio.sleep(e.seconds)
except Exception as e:
print('[!] Ошибка', e)
client.start()
client.run_until_disconnected()
