main.py

from telegram import Update
from telegram.ext import Application, CommandHandler, ContextTypes
import json
import os
TOKEN = os.getenv("TOKEN")
CHAT_ID = int(os.getenv("CHAT_ID"))
from apscheduler.schedulers.background import BackgroundScheduler
from datetime import datetime
import asyncio
async def start(update: Update, context: ContextTypes.DEFAULT_TYPE):
    await update.message.reply_text(
        "Hello Naresh!\n\n"
        "/addtask\n"
        "/tasks\n"
        "/deletetask"
    )
async def addtask(update: Update, context: ContextTypes.DEFAULT_TYPE):

    if len(context.args) < 2:
        await update.message.reply_text(
            "Usage:\n/addtask HH:MM Task Name"
        )
        return

    task_time = context.args[0]
    task_name = " ".join(context.args[1:])

    with open("tasks.json", "r") as f:
        data = json.load(f)

    data["tasks"].append(
        {
            "time": task_time,
            "task": task_name
        }
    )

    with open("tasks.json", "w") as f:
        json.dump(data, f, indent=4)

    await update.message.reply_text(
        f"✅ Task Added\n\n{task_time} - {task_name}"
    )
async def tasks(update: Update, context: ContextTypes.DEFAULT_TYPE):

    with open("tasks.json", "r") as f:
        data = json.load(f)

    if not data["tasks"]:
        await update.message.reply_text(
            "No tasks available."
        )
        return

    message = "📋 Your Tasks\n\n"

    for i, task in enumerate(data["tasks"], start=1):
        message += (
            f"{i}. {task['time']} - {task['task']}\n"
        )

    await update.message.reply_text(message)
async def deletetask(update: Update, context: ContextTypes.DEFAULT_TYPE):

    if len(context.args) != 1:
        await update.message.reply_text(
            "Usage:\n/deletetask task_number"
        )
        return

    try:
        task_index = int(context.args[0]) - 1

        with open("tasks.json", "r") as f:
            data = json.load(f)

        if task_index < 0 or task_index >= len(data["tasks"]):
            await update.message.reply_text(
                "❌ Invalid task number"
            )
            return

        deleted_task = data["tasks"].pop(task_index)

        with open("tasks.json", "w") as f:
            json.dump(data, f, indent=4)

        await update.message.reply_text(
            f"✅ Deleted\n\n{deleted_task['time']} - {deleted_task['task']}"
        )

    except ValueError:
        await update.message.reply_text(
            "❌ Enter a valid task number"
        )
def check_tasks(app):

    current_time = datetime.now().strftime("%H:%M")

    with open("tasks.json", "r") as f:
        data = json.load(f)

    for task in data["tasks"]:

        if task["time"] == current_time:

            asyncio.run(
                app.bot.send_message(
                    chat_id=CHAT_ID,
                    text=f"🔔 Reminder\n\n{task['task']}"
                )
            )

app = Application.builder().token(TOKEN).build()

app.add_handler(CommandHandler("start", start))
app.add_handler(CommandHandler("addtask", addtask))
app.add_handler(CommandHandler("tasks", tasks))
app.add_handler(CommandHandler("deletetask", deletetask))
scheduler = BackgroundScheduler()

scheduler.add_job(
    check_tasks,
    "interval",
    minutes=1,
    args=[app]
)

scheduler.start()
print("Reminder Scheduler Started...")
app.run_polling()