Skip to content

Fixed Class Plus Button Issue #2

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
debojit-dev0 wants to merge 6 commits into
base: main
Choose a base branch
from
Open

Fixed Class Plus Button Issue #2

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
e265548
Update start.py
debojit-dev0 Sep 6, 2025
b135158
Update start.py
debojit-dev0 Sep 6, 2025
642fe16
Update start.py
debojit-dev0 Sep 6, 2025
8defd7d
Update classplus.py
debojit-dev0 Sep 6, 2025
bb4f344
Fix reply_to_message_id reference in classplus.py
debojit-dev0 Sep 6, 2025
ee8601e
Update classplus.py
debojit-dev0 Sep 6, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
195 changes: 57 additions & 138 deletions Extractor/modules/classplus.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,24 +1,19 @@
import requests
import os
import json
import asyncio
from pyrogram import Client, filters, idle
from pyrogram import filters
from Extractor import app
from config import SUDO_USERS

api = 'https://api.classplusapp.com/v2'

# ------------------------------------------------------------------------------------------------------------------------------- #

def create_html_file(file_name, batch_name, contents):
tbody = ''
parts = contents.split('\n')
for part in parts:
split_part = [item.strip() for item in part.split(':', 1)]

text = split_part[0] if split_part[0] else 'Untitled'
url = split_part[1].strip() if len(split_part) > 1 and split_part[1].strip() else 'No URL'

tbody += f'<tr><td>{text}</td><td><a href="{url}" target="_blank">{url}</a></td></tr>'

with open('Extractor/core/template.html', 'r') as fp:
Expand All @@ -27,87 +22,69 @@ def create_html_file(file_name, batch_name, contents):
with open(file_name, 'w') as fp:
fp.write(file_content.replace('{{tbody_content}}', tbody).replace('{{batch_name}}', title))

# ------------------------------------------------------------------------------------------------------------------------------- #

async def get_course_content(session, course_id, folder_id=0):

fetched_contents = []

params = {
'courseId': course_id,
'folderId': folder_id,
}

res = session.get(f'{api}/course/content/get', params=params)

if res.status_code == 200:
res = res.json()

contents = res['data']['courseContent']

for content in contents:

if content['contentType'] == 1:
resources = content['resources']

if resources['videos'] or resources['files']:
sub_contents = await get_course_content(session, course_id, content['id'])
fetched_contents += sub_contents

else:
name = content['name']
url = content['url']
fetched_contents.append(f'{name}: {url}')

return fetched_contents

async def classplus_txt(message, session, user_id):
async def classplus_txt(app, message, user_id=None):
headers = {
'accept-encoding': 'gzip',
'accept-language': 'EN',
'api-version': '35',
'app-version': '1.4.73.2',
'build-number': '35',
'connection': 'Keep-Alive',
'content-type': 'application/json',
'device-details': 'Xiaomi_Redmi 7_SDK-32',
'device-id': 'c28d3cb16bbdac01',
'host': 'api.classplusapp.com',
'region': 'IN',
'user-agent': 'Mobile-Android',
'webengage-luid': '00000187-6fe4-5d41-a530-26186858be4c'
"accept-encoding": "gzip",
"accept-language": "EN",
"api-version": "35",
"app-version": "1.4.73.2",
"build-number": "35",
"connection": "Keep-Alive",
"content-type": "application/json",
"device-details": "Xiaomi_Redmi 7_SDK-32",
"device-id": "c28d3cb16bbdac01",
"host": "api.classplusapp.com",
"region": "IN",
"user-agent": "Mobile-Android",
"webengage-luid": "00000187-6fe4-5d41-a530-26186858be4c",
}

session = requests.Session()
session.headers.update(headers)
try:
reply = await message.chat.ask(
reply = await app.ask(
message.chat.id,
(
'**'
'Send your credentials as shown below.\n\n'
'Organisation Code\n'
'Phone Number\n\n'
'OR\n\n'
'Access Token'
'**'
"**Send your credentials as shown below.**\n\n"
"Organisation Code\n"
"Phone Number\n\n"
"OR\n\n"
"Access Token"
),
reply_to_message_id=message.message_id
reply_to_message_id=message.id,
timeout=120
)
creds = reply.text

session.headers.update(headers)

logged_in = False

if '\n' in creds:
org_code, phone_no = [cred.strip() for cred in creds.split('\n')]

if org_code.isalpha() and phone_no.isdigit() and len(phone_no) == 10:
res = session.get(f'{api}/orgs/{org_code}')

if res.status_code == 200:
res = res.json()

org_id = int(res['data']['orgId'])

data = {
'countryExt': '91',
'mobile': phone_no,
Expand All @@ -116,26 +93,18 @@ async def classplus_txt(message, session, user_id):
'eventType': 'login',
'otpHash': 'j7ej6eW5VO'
}

res = session.post(f'{api}/otp/generate', data=json.dumps(data))

if res.status_code == 200:
res = res.json()

session_id = res['data']['sessionId']

reply = await message.chat.ask(
(
'**'
'Send OTP ?'
'**'
),
reply_to_message_id=reply.message_id
reply_otp = await app.ask(
message.chat.id,
'**Send OTP?**',
reply_to_message_id=reply.id,
timeout=120
)

if reply.text.isdigit():
otp = reply.text.strip()

if reply_otp.text.isdigit():
otp = reply_otp.text.strip()
data = {
'otp': otp,
'sessionId': session_id,
Expand All @@ -144,161 +113,111 @@ async def classplus_txt(message, session, user_id):
'countryExt': '91',
'mobile': phone_no,
}

res = session.post(f'{api}/users/verify', data=json.dumps(data))

if res.status_code == 200:
res = res.json()

user_id = res['data']['user']['id']
token = res['data']['token']

session.headers['x-access-token'] = token

await reply.reply(
await app.send_message(
message.chat.id,
(
'**'
'Your Access Token for future uses - \n\n'
'**'
'<pre>'
f'{token}'
'</pre>'
'**Your Access Token for future uses -**\n\n'
f'<pre>{token}</pre>'
),
quote=True
reply_to_message_id=reply_otp.id
)

logged_in = True

else:
raise Exception('Failed to verify OTP.')

else:
raise Exception('Failed to validate OTP.')

else:
raise Exception('Failed to generate OTP.')

else:
raise Exception('Failed to get organization Id.')

else:
raise Exception('Failed to validate credentials.')

else:

token = creds.strip()
session.headers['x-access-token'] = token


res = session.get(f'{api}/users/details')

if res.status_code == 200:
res = res.json()

user_id = res['data']['responseData']['user']['id']
logged_in = True

else:
raise Exception('Failed to get user details.')


if logged_in:

params = {
'userId': user_id,
'tabCategoryId': 3
}

res = session.get(f'{api}/profiles/users/data', params=params)

if res.status_code == 200:
res = res.json()

courses = res['data']['responseData']['coursesData']

if courses:
text = ''

for cnt, course in enumerate(courses):
name = course['name']
text += f'{cnt + 1}. {name}\n'

reply = await message.chat.ask(
reply_course = await app.ask(
message.chat.id,
(
'**'
'Send index number of the course to download.\n\n'
'**Send index number of the course to download.**\n\n'
f'{text}'
'**'
),
reply_to_message_id=reply.message_id
reply_to_message_id=reply.id,
timeout=120
)

if reply.text.isdigit() and int(reply.text) <= len(courses):

selected_course_index = int(reply.text.strip())

if reply_course.text.isdigit() and int(reply_course.text) <= len(courses):
selected_course_index = int(reply_course.text.strip())
course = courses[selected_course_index - 1]

selected_course_id = course['id']
selected_course_name = course['name']

loader = await reply.reply(
(
'**'
'Extracting course...'
'**'
),
quote=True
loader = await app.send_message(
message.chat.id,
'**Extracting course...**',
reply_to_message_id=reply_course.id
)

course_content = await get_course_content(session, selected_course_id)

await loader.delete()

if course_content:

caption = (f"App Name : Classplus\nBatch Name : {selected_course_name}")

text_file = "Classplus"
with open(f'{text_file}.txt', 'w') as f:
f.write('\n'.join(course_content))

await app.send_document(message.chat.id, document=f"{text_file}.txt", caption=caption)

html_file = f'{text_file}.html'
create_html_file(html_file, selected_course_name, '\n'.join(course_content))

await app.send_document(message.chat.id, html_file, caption=caption)
os.remove(f'{text_file}.txt')
os.remove(html_file)


else:
raise Exception('Did not found any content in course.')
raise Exception('Did not find any content in course.')
else:
raise Exception('Failed to validate course selection.')
else:
raise Exception('Did not found any course.')
raise Exception('Did not find any course.')
else:
raise Exception('Failed to get courses.')



except Exception as e:
print(f"Error: {e}")
await message.reply(
await app.send_message(
message.chat.id,
(
'**'
f'Error : {e}'
'**'
),
quote=True
reply_to_message_id=message.id
)

@app.on_message(filters.command("extract") & filters.user(SUDO_USERS))
async def extract_handler(client, message):
session = requests.Session()
await classplus_txt(message, session, user_id=None)
await classplus_txt(client, message)

app.start()
idle()
if __name__ == "__main__":
app.run()
20 changes: 1 addition & 19 deletions Extractor/modules/start.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -574,7 +574,7 @@ async def handle_callback(_, query):


elif query.data=="classplus_":
await classplus_txt(app, query.message)
await classplus_txt(app, query.message, query.from_user.id)

elif query.data == 'pw_':
await query.message.reply_text(
Expand All @@ -595,24 +595,6 @@ async def handle_callback(_, query):
api = "yesofficerapi.classx.co.in"
name = "yes officer"
await appex_v3_txt(app, query.message, api, name)


















elif query.data=="close_data":
await query.message.delete()
await query.message.reply_to_message.delete()