# Обмен сообщениями с ботом
        @client.on(events.NewMessage(chats=dogeclick_channel, incoming=True))
        async def join_start(event):
                message = event.raw_text
                if 'that is not a valid forwarded message' in message:
                        await client(GetBotCallbackAnswerRequest(
                                peer=dogeclick_channel,
                                msg_id=event.message.id,
                                data=event.message.reply_markup.rows[1].buttons[1].data
                        ))

                elif 'Forward a message to' in message:
                        channel_msg = event.original_update.message.reply_markup.rows[0].buttons[0].url
                        print_msg_time(f'URL @{channel_msg}')
                        Link = 'telegram.me'
                        if Link in channel_msg:
                                if '?' in Link:
                                        channel = re.search(r'telegram.me\/(.*?)\?', channel_msg).group(1)
                                                                                                                                                                                                                 elif '?' not in Link:
                                        channel = re.search(r'telegram.me\/(.*)', channel_msg).group(1)
                                        fragment = urllib.parse.urlparse(channel).fragment
                                        channel_name = channel.split("?")
                                        channel_name = (format(channel_name[0]))
                                        if 'start' in channel:
                                                channel_name1 = (format(channel[1]))
                                                fragment = urllib.parse.urlparse(channel_name1).fragment
                                                channel_name1 = channel.split("=")
                                                channel_name1 = (format(channel_name1[1]))
                        else:

                                if '?' in Link:
                                        channel = re.search(r't.me\/(.*?)\?', channel_msg).group(1)

                                elif '?' not in Link:
                                        channel = re.search(r't.me\/(.*)', channel_msg).group(1)
                                        fragment = urllib.parse.urlparse(channel).fragment
                                        channel_name = channel.split("?")
                                        channel_name = (format(channel_name[0]))
                                        if 'start' in channel:
                                                channel_name1 = (format(channel[1]))
                                                fragment = urllib.parse.urlparse(channel_name1).fragment
                                                channel_name1 = channel.split("=")
                                                channel_name1 = (format(channel_name1[1]))
                                        else:
                                                channel_name1 = 'startt'

                        # Отправка команды start в бот
                        if channel_name1 in channel_msg:
                                print_msg_time(f'Обмен сообщениями с ботом: @{channel_name}...')
                                try:
                                        await client.send_message(channel_name, "/start {}".format(channel_name1[1]))
                                        time.sleep(2)
                                except ChatWriteForbiddenError:
                                        await client(JoinChannelRequest(channel_name))

                        elif channel_name in channel_msg:
                                print_msg_time(f'Обмен сообщениями с ботом: @{channel_name}...')
                                try:
                                        await client.send_message(channel_name, '/start')
                                        time.sleep(2)
                                except ChatWriteForbiddenError:
                                        await client(JoinChannelRequest(channel_name))
                        else:
                                print_msg_time(Fore.RED + 'Бот не найден!'+ Fore.RED +' Пропуск рекламы...\n')
                                await client(GetBotCallbackAnswerRequest(
                                        peer=dogeclick_channel,
                                        msg_id=event.message.id,
                                        data=event.message.reply_markup.rows[1].buttons[1].data
                                ))

                        # Переслать сообщение боту
                        @client.on(events.NewMessage(chats=channel_name, incoming=True))
                        async def earned_amount(event):
                                msg_id = event.message.id,
                                if msg_id is not None:
                                        await client.forward_messages(dogeclick_channel, msg_id, channel_name)

        # Если сообщение не соответствует
        @client.on(events.NewMessage(chats=dogeclick_channel, incoming=True))
        async def earand_err(event):
                message = event.raw_text
                if 'that is not a valid forwarded message' in message:
                        await join_start(event)