television/src/discordbot/discordbot.py

import asyncio
import os
import requests
import discord
from discord.ext import commands, tasks
from datetime import datetime
from apscheduler.schedulers.asyncio import AsyncIOScheduler

# Read env variables
bot_token = os.environ.get('DISCORDBOT_TOKEN', 'token')
scheduler_hostname = os.environ.get('SCHEDULER_API_HOSTNAME', 'tv.example.com')

# Discord API Intents
intents = discord.Intents.all()
intents.members = True
intents.guilds = True
intents.messages = True
intents.reactions = True
intents.presences = True
intents.message_content = True

# Discord client
bot = commands.Bot(command_prefix="!", intents=intents)

# Scheduler
scheduler = AsyncIOScheduler()

counter = 0

@bot.event
async def on_ready():
    print(f'Logged in as {bot.user.name} ({bot.user.id})')
    scheduler.start()
      
@bot.command(name='hello')
async def hello(ctx):
    await ctx.channel.send('Hello!')

@bot.command(name='epg')    
async def epg(ctx):
    try:
        db_url = f'https://{scheduler_hostname}/database'
        if requests.get(db_url).status_code == 200:
            response = requests.get(db_url)
            response.raise_for_status()
            content = response.json()
            await ctx.channel.send('epg:')
            await ctx.channel.send(type(content))
            await ctx.channel.send(f'`{content}`')

            if content != {}:
                for item in content:
                    if item['start_at'] == 'now' or item['start_at'] == 'never':
                        await ctx.channel.send('x')
                        continue
                    else:
                        await ctx.channel.send('x')
                        await ctx.channel.send(item['start_at'])
            else:
                await ctx.channel.send('Empty database!')
    except Exception as e:
        print(e)

@bot.command(name='time')
async def time():
    await bot.channel.send('The time is: `%s`' % datetime.now())

@bot.command(name='start')
async def start_task(ctx):
    # Schedule a task to run every 5 seconds
    scheduler.add_job(func=my_task, id='my_task_id')
    #scheduler.add_job(func=tick, id='tick_id', args=(ctx))

@bot.command(name='show')
async def show_task(ctx):
    global counter
    ctx.channel.send(str(counter))

@tasks.loop(seconds=10)
async def my_task():
    global counter
    counter += 1

# Run the bot with your token
bot.run(bot_token)