Merged

Reviewed-on: #16

README.md

@@ -2,6 +2,7 @@
  cogs made for our Royal butt.
 
 ## Our Cogs:
+- [FitnessCog](./fitnessCog)
 - [RecruitmentCog](./recruitmentCog/)
 - [ReginaldCog](./reginaldCog/)
 - [TrafficCog](./trafficCog)

fitnessCog/__init__.py

@@ -0,0 +1,6 @@
+from redbot.core.bot import Red
+from .fitness import FitnessCog
+
+async def setup(bot: Red):
+    cog = FitnessCog(bot)
+    await bot.add_cog(cog)

fitnessCog/activities/climb.json

@@ -0,0 +1,48 @@
+{
+    "convertable": true,
+    "units": {
+        "meter": {
+            "factor": 1,
+            "aliases": [
+                "meter",
+                "meters",
+                "m",
+                "m."
+            ]
+        },
+        "kilometer": {
+            "factor": 1000,
+            "aliases": [
+                "kilometer",
+                "kilometers",
+                "km",
+                "km."
+            ]
+        },
+        "foot": {
+            "factor": 0.3048,
+            "aliases": [
+                "foot",
+                "feet",
+                "ft",
+                "ft."
+            ]
+        },
+        "mile": {
+            "factor": 1609.344,
+            "aliases": [
+                "mile",
+                "miles",
+                "mi",
+                "mi."
+            ]
+        },
+        "step": {
+            "factor": 0.18,
+            "aliases": [
+                "step",
+                "steps"
+            ]
+        }
+    }
+}

fitnessCog/activities/pushups.json

@@ -0,0 +1,3 @@
+{
+  "convertable": false
+}

fitnessCog/activity_logger.py

@@ -0,0 +1,105 @@
+import csv
+import json
+from pathlib import Path
+from typing import Optional
+
+
+def activity_log_path(activity: str, logs_dir: Optional[Path] = None) -> Path:
+    """
+    Returns the path of the activity log file in .csv format.
+    """
+    logs_dir = logs_dir or (Path.cwd() / "activity_logs")
+    return logs_dir / f"{activity}.csv"
+
+
+def activity_units_path(activity: str, units_dir: Optional[Path] = None) -> Path:
+    """
+    Returns the path of the activity units file in .json format.
+    """
+    units_dir = units_dir or (Path.cwd() / "activities")
+    return units_dir / f"{activity}.json"
+
+
+def is_convertable(activity: str, units_dir: Optional[Path] = None) -> bool:
+    filename = activity_units_path(activity, units_dir)
+    with filename.open("r", encoding="utf-8") as f:
+        raw_data = json.load(f)
+    return bool(raw_data.get("convertable"))
+
+
+def create_activity_log_file(
+    activity: str,
+    *,
+    units_dir: Optional[Path] = None,
+    logs_dir: Optional[Path] = None,
+) -> None:
+    if not activity_units_path(activity, units_dir).exists():
+        raise ValueError(f"{activity} is not a valid activity")
+
+    logs_dir = logs_dir or (Path.cwd() / "activity_logs")
+    logs_dir.mkdir(parents=True, exist_ok=True)
+
+    filename = activity_log_path(activity, logs_dir)
+    if filename.exists():
+        return  # don't re-add headers
+
+    with filename.open("w", newline="", encoding="utf-8") as f:
+        writer = csv.writer(f)
+        writer.writerow(["timestamp", "username", "value"])
+
+
+def convert_units(
+    activity: str,
+    value: int | float,
+    unit: str | None,
+    *,
+    units_dir: Optional[Path] = None,
+) -> float:
+    filename = activity_units_path(activity, units_dir)
+    if not filename.exists():
+        raise ValueError(f"{activity} is not a valid activity")
+
+    # Consider None unit value as factor of 1
+    if unit is None:
+        return float(value)
+
+    with filename.open("r", encoding="utf-8") as f:
+        raw_data = json.load(f)
+
+    units_data = raw_data.get("units") or {}
+    unit_l = unit.lower()
+
+    for _, data in units_data.items():
+        aliases = [a.lower() for a in (data.get("aliases") or [])]
+        if unit_l in aliases:
+            return float(value) * float(data["factor"])
+
+    raise ValueError(f"{unit} is not a valid unit")
+
+
+def log_activity(
+    timestamp: int,
+    username: str,
+    activity: str,
+    value: int | float,
+    unit: str | None,
+    *,
+    units_dir: Optional[Path] = None,
+    logs_dir: Optional[Path] = None,
+) -> None:
+    
+    if not isinstance(value, (int, float)) or value <= 0:
+        raise ValueError(f"{value} is not a valid value")
+
+    filename = activity_log_path(activity, logs_dir)
+    if not filename.exists():
+        create_activity_log_file(activity, units_dir=units_dir, logs_dir=logs_dir)
+
+    if is_convertable(activity, units_dir):
+        converted_value = round(convert_units(activity, value, unit, units_dir=units_dir), 2)
+    else:
+        converted_value = round(float(value), 2)
+
+    with filename.open("a", newline="", encoding="utf-8") as f:
+        writer = csv.writer(f)
+        writer.writerow([timestamp, username, converted_value])

fitnessCog/fitness.py

@@ -0,0 +1,143 @@
+import os
+from pathlib import Path
+
+import discord
+from redbot.core import commands
+from redbot.core.data_manager import cog_data_path
+
+from .activity_logger import log_activity
+
+
+class FitnessCog(commands.Cog):
+    def __init__(self, bot):
+        self.bot = bot
+
+        default_threads = "1457402451530350727,1328363409648910356"
+        threads_raw = os.getenv("THREADS_ID", default_threads)
+
+        self.threads_id: list[int] = []
+        for x in threads_raw.split(","):
+            x = x.strip()
+            if x.isdigit():
+                self.threads_id.append(int(x))
+
+        self.confirm_reactions = os.getenv("CONFIRMATION_REACTIONS", "🐈💨")
+
+        # Units are shipped with the cog in: fitnessCog/activities/*.json
+        self.units_dir: Path = Path(__file__).parent / "activities"
+
+        # Logs are writable and belong in Red's data dir
+        self.logs_dir: Path = cog_data_path(self) / "activity_logs"
+        self.logs_dir.mkdir(parents=True, exist_ok=True)
+
+    @commands.Cog.listener()
+    async def on_message(self, message: discord.Message):
+        if message.author.bot:
+            return
+        if message.channel.id not in self.threads_id:
+            return
+
+        content = (message.content or "").strip()
+        if not content.startswith("!"):
+            return
+
+        cmdline = content[1:].strip().lower()
+        if not cmdline:
+            return
+
+        cmd, *rest = cmdline.split(" ", 1)
+        arg = rest[0].strip() if rest else ""
+
+        if cmd == "getunits":
+            await self.get_units_file(message, arg)
+            return
+
+        if cmd == "getlog":
+            await self.get_log_file(message, arg)
+            return
+
+        await self.log_fitness(message)
+
+    async def get_units_file(self, message: discord.Message, activity: str):
+        try:
+            if not activity:
+                await message.channel.send(
+                    "Usage: `!getunits <activity>` (example: `!getunits pushups`)"
+                )
+                return
+
+            activity = activity.lower().strip()
+            path = self.units_dir / f"{activity}.json"
+
+            if not path.exists():
+                await message.channel.send(f"No units JSON found for `{activity}`.")
+                return
+
+            await message.channel.send(file=discord.File(fp=str(path)))
+
+        except Exception as e:
+            await message.channel.send(str(e))
+
+    async def get_log_file(self, message: discord.Message, activity: str):
+        try:
+            if not activity:
+                await message.channel.send(
+                    "Usage: `!getlog <activity>` (example: `!getlog pushups`)"
+                )
+                return
+
+            activity = activity.lower().strip()
+            path = self.logs_dir / f"{activity}.csv"
+
+            if not path.exists():
+                await message.channel.send(f"No log CSV found for `{activity}`.")
+                return
+
+            await message.channel.send(file=discord.File(fp=str(path)))
+
+        except Exception as e:
+            await message.channel.send(str(e))
+
+    async def log_fitness(self, message: discord.Message):
+        try:
+            parts = message.content[1:].strip().split()
+            if len(parts) < 2:
+                await message.reply(
+                    "Usage: `!<activity> <value> [unit]` (example: `!pushups 20` or `!run 5 km`)"
+                )
+                return
+
+            activity = parts[0]
+
+            try:
+                value = float(parts[1])
+            except ValueError:
+                await message.reply(
+                    "Invalid number. Usage: `!<activity> <value> [unit]` (example: `!run 5 km`)"
+                )
+                return
+
+            unit = parts[2] if len(parts) > 2 else "m"
+
+            timestamp = int(message.created_at.timestamp())
+            username = message.author.name
+
+            log_activity(
+                timestamp,
+                username,
+                activity,
+                value,
+                unit,
+                units_dir=self.units_dir,
+                logs_dir=self.logs_dir,
+            )
+
+            for r in self.confirm_reactions:
+                await message.add_reaction(r)
+
+        except Exception as e:
+            await message.reply(str(e))
+
+
+def setup(bot):
+    bot.add_cog(FitnessCog(bot))

reginaldCog/openai_completion.py

@@ -1,10 +1,11 @@
 import random
 import json
+import asyncio
+from os import environ
 import openai
 from openai import OpenAIError
-from .weather import time_now, get_current_weather, get_weather_forecast
+from weather import time_now, get_current_weather, get_weather_forecast
-from .tools_description import TOOLS
+from tools_description import TOOLS
-from .debug_stuff import debug
 
 CALLABLE_FUNCTIONS = {
     # Dictionary with functions to call.
@@ -21,15 +22,13 @@ class Completion:
         self.__api_key = api_key
         self.__messages = []
 
-    @debug
+    async def create_completion(self):
-    async def create_completion(self, messages: list):
-        self.__messages = messages
         model = self.__model
         try:
             client = openai.AsyncClient(api_key=self.__api_key)
             completion_kwargs = {
                 "model": model,
-                "messages": messages,
+                "messages": self.__messages,
                 "max_tokens": 4096,
                 "temperature": 0.7,
                 "presence_penalty": 0.5,
@@ -47,7 +46,7 @@ class Completion:
                     func_args = json.loads(i_call.function.arguments)
                     tool_call_id = i_call.id
                     self.function_manager(func_name, func_args, tool_call_id)
-                return self.create_completion(messages=self.__messages)
+                return await self.create_completion()
             return response_content
         except OpenAIError as e:
             return self.get_error_message(error_message=str(e), error_type="OpenAIError")
@@ -81,3 +80,14 @@ class Completion:
         result = CALLABLE_FUNCTIONS[func_name](**func_kwargs)
         self.append_message(role="tool", content=result, tool_call_id=tool_call_id)
 
+
+if __name__ == '__main__':
+    async def main():
+        test_message = input('Your input: ')
+        completion = Completion(model='gpt-4.1-mini', api_key=environ.get('OPENAI_API_KEY'))
+        completion.append_message(role='user', content=test_message)
+        result = await completion.create_completion()
+        print(result)
+
+    asyncio.run(main())
+

reginaldCog/tools_description.py

@@ -1,11 +1,17 @@
 TOOLS = [
+    # time_now
     {
         'type': 'function',
         'function': {
             'name': 'time_now',
-            'description': 'Get current date and time in UTC timezone.',
+            'description': '''
+                Get current date and time in UTC timezone.
+                Use this before get_weather_forecast function if user gave you date of forecast
+                instead of number of days.
+            ''',
         }
     },
+    # get_current_weather
     {
         'type': 'function',
         'function': {
@@ -32,6 +38,7 @@ TOOLS = [
             'strict': True
         }
     },
+    # get_weather_forecast
     {
         'type': 'function',
         'function': {
@@ -41,7 +48,8 @@ TOOLS = [
                 forecast and weather alert as json. The data is returned as a Forecast Object.
                 Forecast object contains astronomy data, day weather forecast and hourly interval weather information
                 for a given city.
-                With a free weather API subscription, only up to three days of forecast can be requested.
+                Number of days could be less, depending on the API subscription plan.
+                With a free plan only up to three days of forecast would be returned.
             ''',
             'parameters': {
                 'type': 'object',
@@ -53,16 +61,15 @@ TOOLS = [
                             e.g: "Copenhagen", or "Copenhagen, Louisiana, US", if needed specifying.
                         '''
                     },
-                    'dt': {
+                    'days': {
-                        'type': 'string',
+                        'type': 'integer',
                         'description': '''
-                            The date up until to request the forecast in YYYY-MM-DD format.
+                            Number of days of forecast between 0 and 13, where 0 is only today, 1 up to tomorrow, etc.
-                            Check the **time_now** function first if you unsure which date it is.
                         '''
                     },
                 },
                 'required': [
-                    'location', 'dt'
+                    'location', 'days'
                 ],
                 'additionalProperties': False
             },

reginaldCog/weather.py

@@ -2,27 +2,26 @@ from datetime import datetime, timezone
 from os import environ
 import requests
 import json
-from .debug_stuff import debug
 
 #WEATHER_API_KEY = environ.get('WEATHER_API_KEY')
 URL = 'http://api.weatherapi.com/v1'
 
 
-@debug
 def time_now() -> str:
     return str(datetime.now(timezone.utc))
 
 
-@debug
 def get_current_weather(location: str) -> str:
     weather = Weather(location=location)
     return json.dumps(weather.realtime())
 
 
-@debug
+def get_weather_forecast(location: str, days: int = None) -> str:
-def get_weather_forecast(location: str, days: int = 14, dt: str = '2025-03-24') -> str:
+    days += 1
+    days = max(1, days)
+    days = min(14, days)
     weather = Weather(location=location)
-    return json.dumps(weather.forecast(days=days, dt=dt))
+    return json.dumps(weather.forecast(days=days))
 
 
 class Weather:
@@ -39,7 +38,6 @@ class Weather:
         response = requests.get(url=f'{URL}{method}', params=params)
         return response.json()
 
-    @debug
     def realtime(self):
         method = '/current.json'
         params = {
@@ -48,19 +46,17 @@ class Weather:
         }
         return self.make_request(method=method, params=params)
 
-    @debug
+    def forecast(self, days: int = 14):
-    def forecast(self, days: int = 14, dt: str = '2025-03-24'):
         method = '/forecast.json'
         params = {
             'key': self.api_key,
             'q': self.location,
             'days': days,
-            'dt': dt,
         }
         return self.make_request(method=method, params=params)
 
 
 if __name__ == '__main__':
     test_weather = Weather('Aqtobe')
-    result = json.dumps(test_weather.forecast(days=14, dt='2025-03-24'), indent=2)
+    result = json.dumps(test_weather.forecast(days=13), indent=2)
     print(result)