cptext/Plugins at main · rishavdevkr/cptext · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
#!/usr/bin/env python3
# -*- coding: utf-8 -*-
# (c) xmysteriousx

import logging
logging.basicConfig(level=logging.DEBUG,
                    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s')
logger = logging.getLogger(__name__)

import os
import asyncio
import json
import shutil

if bool(os.environ.get("WEBHOOK", False)):
    from sample_config import Config
else:
    from config import Config

import pyrogram
logging.getLogger("pyrogram").setLevel(logging.WARNING)

from pyrogram import Client, filters

@Client.on_message(filters.document & filters.private)
async def extracter(bot, update):
    try:
        json_location = Config.DOWNLOAD_LOCATION + "/" + str(update.from_user.id) + "/raw.json"
        link_file_location = Config.DOWNLOAD_LOCATION + "/" + str(update.from_user.id) + "/links.txt"
        tmp_directory_for_each_user = Config.DOWNLOAD_LOCATION + "/" + str(update.from_user.id)
        await bot.download_media(
            message=update,
            file_name=json_location
        )
        f = open(json_location,'r', encoding = "utf8")
        data = json.loads(f.read())
        for i in data['jsonChapterDetails']:
            for j in i['defaultResources']:
                course_link=j['resLink']
                if course_link.isdecimal():
                    continue
                if "upload" in course_link:
                    continue
                course_name=j['resName']
                try:
                    if "%3A%2F%2F" in course_link:
                        course_link = course_link.replace("%3A%2F%2F", "://")
                    if "%2F" in course_link:
                        course_link = course_link.replace("%2F", "/")
                    if "%3F" in course_link:
                        course_link = course_link.replace("%3F", "?")
                    if "%3D" in course_link:
                        course_link = course_link.replace("%3D", "=")
                    if "content.jwplatform.com" in course_link:
                        course_link = course_link.replace("content.jwplatform.com", "cdn.jwplayer.com")
                    if "-" in course_link and "cdn.jwplayer.com" in course_link:
                        course_link_parts = course_link.split("-")
                        base_link = course_link_parts[0]
                        course_link = base_link + ".m3u8"
                except Exception as e:
                    logger.info(e)
                    pass
                try:
                    if "+%7C%7C+" in course_name:
                        course_name = course_name.replace("+%7C%7C+", "_")
                    if "+" in course_name:
                        course_name = course_name.replace("+", " ")
                    if "%09" in course_name:
                        course_name = course_name.replace("%09", "")
                except Exception as e:
                    logger.info(e)
                    pass
                try:
                    t = open(link_file_location,"a")
                    t.write(f"{course_name}:{course_link}")
                    t.write("\n")
                except Exception as e:
                    logger.info(e)
                    pass
        f.close()
        t.close()
        await bot.send_document(
            chat_id=update.chat.id,
            document=link_file_location,
            reply_to_message_id=update.message_id
        )
        shutil.rmtree(tmp_directory_for_each_user)
    except Exception as e:
        logger.info(e)
        pass