Add Telechat files

Dockerfile

@@ -0,0 +1,23 @@
+# Use an official Python runtime as a parent image
+FROM python:3.9
+
+# Set the working directory in the container
+WORKDIR /app
+
+# Copy the current directory contents into the container at /app
+COPY . /app
+
+# Install any needed packages specified in requirements.txt
+RUN pip install --no-cache-dir -r requirements.txt
+
+# Set environment variables, including TRANSFORMERS_CACHE
+ENV TRANSFORMERS_CACHE /app/cache
+
+# Set cache directory permissions
+RUN mkdir -p /app/cache && chmod 777 /app/cache
+
+# Make port 7860 available to the world outside this container
+EXPOSE 7860
+
+# Define the command to run your application
+CMD ["uvicorn", "main:app", "--host", "0.0.0.0", "--port", "7860"]

main.py

@@ -0,0 +1,124 @@
+from fastapi import FastAPI
+from fastapi import Form, Depends, Body
+from concurrent.futures import ThreadPoolExecutor
+from telethon.tl.functions.messages import ExportChatInviteRequest
+from telethon.sessions import StringSession
+
+import asyncio
+from telethon.sync import TelegramClient
+from telethon.tl import functions
+import requests, json, os
+
+app = FastAPI()
+
+api_id = os.environ.get('api_id')
+api_hash = os.environ.get('api_hash')
+phone_number = os.environ.get('phone_number')
+
+user_admin = os.environ.get('user_admin')
+user_creator = os.environ.get('user_creator')
+user_mentor = os.environ.get('user_mentor')
+admin_notifier_chat_id = os.environ.get('admin_notifier_chat_id')
+
+current_session_string = "1BJWap1sBu43IhVJj9siFBcuC8MYtjC7ebqcCnnTTytu_HM7QWoYFOe38xjlvDhJyF2vtuJDblEvSzXkoe31EIjTLdj23m0oDzNxmQJt0_J-UI7fcTpbJSeppcdxuCK4-dU3fQ2Ap_51I0NljF1TpQ6NrO6JArLOMXE9PVdvFiGRKvMM78_zfFGccPUt3fSwPidFdTNBy1bbTFzYI7nviB1jf3WeSnHzN3ORuSs_uMmOXTH12qI92mFto1-E-4Ct8MprM2lwqPO-hosyrRaA8sBTec8AQanjFK0ft5SbXpCpJYV8dFdsufiQrqnysCa4PAJ9Hf305FlC3BVnl5yUtXX6sG1pxsaU="
+
+# Create a new Telegram client
+client = TelegramClient(StringSession(current_session_string), api_id, api_hash)
+
+register_new_chat_google_apps_script_url = os.environ.get('script_url')
+
+def register_new_chat(group_title, chat_id, start_date, instructor_name, session_days, invite_link):
+    response = requests.get(register_new_chat_google_apps_script_url, params={"newChatCreated": True, "chatTitle": group_title, "chatID": chat_id, "startDate": start_date, "instructorName": instructor_name, "sessionDays": session_days, "inviteLink": invite_link})
+    data = json.loads(response.text)
+    print(f"reponse from the API is {data}")
+    return data
+
+async def create_group(group_title, event_type, start_date, duration, recurrence_days, recurrence, calendar_id, instructor_name):
+    print("Now creating group..")    
+    # await client.start(phone_number)
+    print("Client started..")
+    try:
+        # Create a group
+        result = await client(functions.messages.CreateChatRequest(
+            users=[user_admin],
+            title=group_title
+        ))
+
+        # Get the created chat ID
+        chat_id = result.chats[0].id
+        # Get the group invite link
+        invite = await client(ExportChatInviteRequest(chat_id))
+        invite_link = invite.link
+        print(f'Group invite link: {invite_link}')
+
+        print(f'Group created successfully! Chat ID: {chat_id}')
+
+        # Additional processing with the new parameters
+        print(f'Event Type: {event_type}')
+        print(f'Start Date: {start_date}')
+        print(f'Duration: {duration}')
+        print(f'Recurrence Days: {recurrence_days}')
+        print(f'Recurrence: {recurrence}')
+        print(f'Calendar ID: {calendar_id}')
+        print(f'Instructor name: {instructor_name}')
+
+        register_new_chat_result = register_new_chat(group_title, chat_id, start_date, instructor_name, recurrence_days, invite_link)
+
+        # Leave the group
+        await client(functions.messages.DeleteChatUserRequest(
+            chat_id=chat_id,
+            user_id='me',
+        ))
+        
+        await client.delete_dialog(chat_id)
+        print('Left the group successfully!')
+        print("Status: ", register_new_chat_result)
+        
+        if register_new_chat_result['Status'] == 'Chat details was added sucessfully to the repo':
+            # message = f"🆕 *New Event was created successfully:*\n🟡 *Event/Chat title:* {group_title}\n📆 *Start Date:* {start_date}\n🔗 *Invite link:* {invite_link}\n👩‍🏫 *Instructor:* {instructor_name}\n🌓 *Session days:* {recurrence_days}"
+            message = (
+                f"🆕 <b>New Event was created successfully:</b>\n"
+                f"🟡 <b>Event/Chat title:</b> {group_title}\n"
+                f"📆 <b>Start Date:</b> {start_date}\n"
+                f"🔗 <b>Invite link:</b> {invite_link}\n"
+                f"👩‍🏫 <b>Instructor:</b> {instructor_name}\n"
+                f"🌓 <b>Session days:</b> {recurrence_days}"
+            )
+
+            # Send the invite link to the group chat
+            await client.send_message(
+                entity=admin_notifier_chat_id,
+                message=message,
+                parse_mode='html'
+            )
+    except Exception as e:
+        print(f"Error creating/leaving the group: {e}")
+
+    finally:
+        # Close the client connection
+        await client.disconnect()
+
+@app.post("/createGroups")
+async def create_groups(
+    group_title: str = Form(...),
+    event_type: str = Form(...),
+    start_date: str = Form(...),
+    duration: str = Form(...),
+    recurrence_days: str = Form(...),
+    recurrence: str = Form(...),
+    calendar_id: str = Form(...),
+    instructor_name: str = Form(...)
+):
+    print("Received a request")
+    
+    loop = asyncio.get_event_loop()
+    with ThreadPoolExecutor() as executor:
+        await loop.run_in_executor(
+            executor,
+            lambda: asyncio.run_coroutine_threadsafe(
+                create_group(group_title, event_type, start_date, duration, recurrence_days, recurrence, calendar_id, instructor_name),
+                loop
+            )
+        )
+
+    return {"status": "Supergroup creation initiated"}

requirements.txt

@@ -0,0 +1,5 @@
+uvicorn
+telethon
+python-multipart
+requests
+fastapi