#!/usr/bin/python
# -*- coding: utf-8 -*-
# 原作者不知道
from telethon import TelegramClient, events, sync

import httpx
import time
import json
import re
import asyncio

# 三个地方需要修改，分别是22行的api_id、23行的api_hash、25行的cks，运行后首先输入手机号码，记得+86，然后输入Telegram发送的验证码，就可以监控频道并领取京豆了。测试方法：取消注释79行，往群里发送(https://api.m.jd.com)，要带括号，有输出就没问题了

# 首先输入下面的命令安装模块，然后打开https://my.telegram.org，点击API development tools根据信息填写api_id和api_hash，然后填写cookie

# pip3 install telethon pysocks httpx 或者 py -3 -m pip install telethon pysocks httpx


# These example values won't work. You must get your own api_id and
# api_hash from https://my.telegram.org, under API Development.
# 必须填写 api_id api_hash proxy
api_id = 
api_hash = ''
# cookies中间用&分开
cks = ""


async def send_live(cks, url):
    if len(cks) > 0:
        str_ck = cks.split('&')
        for i in range(1, len(str_ck) + 1):
            if len(str_ck[i - 1]) > 0:
                # print(str_ck[i-1])
                # header
                header = {
                    "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/88.0.4324.104 Safari/537.36",
                    "Cookie": str_ck[i - 1],
                }
                # 访问url
                async with httpx.AsyncClient() as client:
                    r = await client.get(url=url, headers=header)
                # r = await httpx.get(url=url, headers=header)
                print(r.text)
                await asyncio.sleep(0.5)




# 使用代理proxy
#client = TelegramClient('test', api_id, api_hash, proxy=("http", '34.92.63.71', 8101))
# 不使用代理
client = TelegramClient('test', api_id, api_hash)

client.start()


async def main():
    # Getting information about yourself
    me = await client.get_me()

    # "me" is a user object. You can pretty-print
    # any Telegram object with the "stringify" method:
    # print(me.stringify())

    # When you print something, you see a representation of it.
    # You can access all attributes of Telegram objects with
    # the dot operator. For example, to get the username:
    # username = me.username
    # print(username)
    # print(me.phone)

    # You can print all the dialogs/conversations that you are part of:
    async for dialog in client.iter_dialogs():
        print(dialog.name, 'has ID', dialog.id)

p1 = re.compile(r'[(](https://api\.m\.jd\.com.*?)[)]', re.S)

#@client.on(events.NewMessage)
#@client.on(events.NewMessage(chats=[-1001479368440]))# 群
#@client.on(events.NewMessage(chats=[-1001197524983]))# 频道
@client.on(events.NewMessage(chats=[-1001173715142]))#自己
async def my_event_handler(event):
    #print(event.raw_text)
        print(event.message.sender_id,event.message.text)
        # if event.message.sender_id == '1663824060':
        sec = re.findall(p1, event.message.text)
        if sec!=None:
            await send_live(cks,sec[0])




with client:
    client.loop.run_until_complete(main())
    client.loop.run_forever()