Merge pull request 'massive changes' (#3) from dev into main

Reviewed-on: https://codeberg.org/salmonik/senator-sperma/pulls/3
stable enough

18 files changed, 1547 insertions, 0 deletions

diff --git a/tests/cogs/test_ai.py b/tests/cogs/test_ai.py
new file mode 100644
index 0000000..a1c3fd4
--- /dev/null
+++ b/tests/cogs/test_ai.py
@@ -0,0 +1,83 @@
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock
+import discord
+import httpx
+from tests.conftest import MockApplicationContext
+
+
+@pytest.fixture
+def ai_cog(bot):
+    from cogs.ai import AI
+    cog = AI(bot)
+    return cog
+
+
+@pytest.fixture
+def mock_ai_response():
+    return {
+        "choices": [
+            {
+                "message": {
+                    "content": "Test response from AI"
+                }
+            }
+        ]
+    }
+
+
+@pytest.mark.asyncio
+async def test_senator_command_success(ai_cog, mock_channel, mock_guild, bot, mock_ai_response):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    mock_response = MagicMock()
+    mock_response.json = MagicMock(return_value=mock_ai_response)
+
+    mock_client = MagicMock()
+    mock_client.post = AsyncMock(return_value=mock_response)
+    mock_client.__aenter__ = AsyncMock(return_value=mock_response)
+    mock_client.__aexit__ = AsyncMock(return_value=None)
+
+    with patch('cogs.ai.httpx.AsyncClient') as mock_httpx:
+        instance = mock_httpx.return_value.__aenter__.return_value
+        instance.post = AsyncMock(return_value=mock_response)
+        with patch.object(ctx, 'send_followup', new_callable=AsyncMock) as mock_followup:
+            await ai_cog.senator.callback(ai_cog, ctx, text="Hello", tts=False)
+            mock_followup.assert_called_once_with("Test response from AI")
+
+
+@pytest.mark.asyncio
+async def test_senator_command_empty_choices(ai_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    mock_response = MagicMock()
+    mock_response.json = MagicMock(return_value={"choices": []})
+
+    mock_client = MagicMock()
+    mock_client.post = AsyncMock(return_value=mock_response)
+    mock_client.__aenter__ = AsyncMock(return_value=mock_response)
+    mock_client.__aexit__ = AsyncMock(return_value=None)
+
+    with patch('cogs.ai.httpx.AsyncClient') as mock_httpx:
+        instance = mock_httpx.return_value.__aenter__.return_value
+        instance.post = AsyncMock(return_value=mock_response)
+        with patch.object(ctx, 'send_followup', new_callable=AsyncMock) as mock_followup:
+            await ai_cog.senator.callback(ai_cog, ctx, text="Hello", tts=False)
+            mock_followup.assert_called_once_with("bot siem zesroł")
+
+
+@pytest.mark.asyncio
+async def test_senator_command_no_choices_key(ai_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    mock_response = MagicMock()
+    mock_response.json = MagicMock(return_value={})
+
+    with patch('cogs.ai.httpx.AsyncClient') as mock_httpx:
+        instance = mock_httpx.return_value.__aenter__.return_value
+        instance.post = AsyncMock(return_value=mock_response)
+        with patch('cogs.ai.logger') as mock_logger:
+            try:
+                await ai_cog.senator.callback(ai_cog, ctx, text="Hello", tts=False)
+            except KeyError:
+                pass
+            assert mock_logger.info.called
diff --git a/tests/cogs/test_assistant.py b/tests/cogs/test_assistant.py
new file mode 100644
index 0000000..9a33232
--- /dev/null
+++ b/tests/cogs/test_assistant.py
@@ -0,0 +1,66 @@
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock
+from tests.conftest import MockApplicationContext
+
+
+@pytest.fixture
+def assistant_cog():
+    with patch('os.getenv', return_value="test_keyword"):
+        from cogs.assistant import Jarvis
+
+        mock_bot = MagicMock()
+        mock_bot.user = MagicMock()
+        mock_bot.user.id = 111
+
+        cog = Jarvis(mock_bot)
+    return cog
+
+
+def test_assistant_keyword_default(assistant_cog):
+    assert assistant_cog.keyword == "test_keyword"
+
+
+@pytest.mark.asyncio
+async def test_assistant_on_message_ignored_bot_message(assistant_cog):
+    mock_author = MagicMock()
+    mock_author.id = 456
+    mock_author.bot = True
+
+    mock_message = MagicMock()
+    mock_message.author = mock_author
+
+    with patch.object(assistant_cog, 'assistant', new_callable=AsyncMock) as mock_assistant:
+        await assistant_cog.on_message(mock_message)
+        mock_assistant.assert_not_called()
+
+
+@pytest.mark.asyncio
+async def test_assistant_on_message_mentions_bot(assistant_cog):
+    mock_message = MagicMock()
+    mock_message.author = MagicMock()
+    mock_message.author.id = 123
+
+    mock_mention = MagicMock()
+    mock_mention.id = 111
+    mock_message.mentions = [mock_mention]
+    mock_message.content = "test"
+
+    with patch.object(assistant_cog, 'assistant', new_callable=AsyncMock) as mock_assistant:
+        await assistant_cog.on_message(mock_message)
+        mock_assistant.assert_called_once_with(mock_message)
+
+
+@pytest.mark.asyncio
+async def test_assistant_on_message_keyword_match(assistant_cog):
+    assistant_cog.keyword = "test"
+
+    mock_message = MagicMock()
+    mock_message.author = MagicMock()
+    mock_message.author.id = 123
+
+    mock_message.mentions = []
+    mock_message.content = "test message with test keyword"
+
+    with patch.object(assistant_cog, 'assistant', new_callable=AsyncMock) as mock_assistant:
+        await assistant_cog.on_message(mock_message)
+        mock_assistant.assert_called_once_with(mock_message)
diff --git a/tests/cogs/test_compression_conversion.py b/tests/cogs/test_compression_conversion.py
new file mode 100644
index 0000000..f9d3427
--- /dev/null
+++ b/tests/cogs/test_compression_conversion.py
@@ -0,0 +1,139 @@
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock
+import os
+import discord
+from tests.conftest import MockApplicationContext
+
+
+def test_compression_filetype_video():
+    from cogs.compression import filetype
+    assert filetype("test.mp4") == "Video"
+    assert filetype("test.avi") == "Video"
+
+
+def test_compression_filetype_audio():
+    from cogs.compression import filetype
+    assert filetype("test.mp3") == "Audio"
+    assert filetype("test.wav") == "Audio"
+
+
+def test_compression_filetype_image():
+    from cogs.compression import filetype
+    assert filetype("test.jpg") == "Image"
+    assert filetype("test.png") == "Image"
+
+
+def test_conversion_filetype():
+    from cogs.conversion import filetype
+    assert filetype("test.mp4") == "Video"
+    assert filetype("test.mp3") == "Audio"
+    assert filetype("test.jpg") == "Image"
+    assert filetype("test.xyz") == "Unknown"
+
+
+@pytest.mark.asyncio
+async def test_build_conversion_command_video():
+    with patch('os.getenv', return_value="https://example.com"):
+        with patch('cogs.utils.temp.get_temp_dir', return_value="/tmp"):
+            with patch('cogs.utils.settings.get_baseurl', return_value="https://example.com"):
+                import importlib
+                import cogs.conversion
+                importlib.reload(cogs.conversion)
+                from cogs.conversion import Conversion
+
+                cog = Conversion.__new__(Conversion)
+                cog._baseurl = "https://example.com"
+                cog._uploadurl = "https://example.com"
+
+                cmd = cog._build_conversion_command("Video", "/tmp/test.mp4", "/tmp/output.mp4", "")
+                assert cmd is not None
+                assert "ffmpeg" in cmd
+
+
+@pytest.mark.asyncio
+async def test_build_conversion_command_image():
+    with patch('os.getenv', return_value="https://example.com"):
+        with patch('cogs.utils.temp.get_temp_dir', return_value="/tmp"):
+            with patch('cogs.utils.settings.get_baseurl', return_value="https://example.com"):
+                import importlib
+                import cogs.conversion
+                importlib.reload(cogs.conversion)
+                from cogs.conversion import Conversion
+
+                cog = Conversion.__new__(Conversion)
+                cog._baseurl = "https://example.com"
+                cog._uploadurl = "https://example.com"
+
+                cmd = cog._build_conversion_command("Image", "/tmp/test.jpg", "/tmp/output.png", "")
+                assert cmd is not None
+                assert "magick" in cmd
+
+
+@pytest.mark.asyncio
+async def test_build_conversion_command_unknown():
+    with patch('os.getenv', return_value="https://example.com"):
+        with patch('cogs.utils.temp.get_temp_dir', return_value="/tmp"):
+            with patch('cogs.utils.settings.get_baseurl', return_value="https://example.com"):
+                import importlib
+                import cogs.conversion
+                importlib.reload(cogs.conversion)
+                from cogs.conversion import Conversion
+
+                cog = Conversion.__new__(Conversion)
+                cog._baseurl = "https://example.com"
+                cog._uploadurl = "https://example.com"
+
+                cmd = cog._build_conversion_command("Unknown", "/tmp/test.xyz", "/tmp/output.abc", "")
+                assert cmd is None
+
+
+@pytest.mark.asyncio
+async def test_compression_get_command_video():
+    with patch('os.getenv', return_value="https://example.com"):
+        with patch('cogs.utils.temp.get_temp_dir', return_value="/tmp"):
+            with patch('cogs.utils.settings.get_baseurl', return_value="https://example.com"):
+                import importlib
+                import cogs.compression
+                importlib.reload(cogs.compression)
+                from cogs.compression import Compression
+
+                cog = Compression.__new__(Compression)
+                cog.temp_dir = "/tmp"
+
+                cmd = cog._get_compression_command("Video", "/tmp/test.mp4", "/tmp/output.mp4")
+                assert cmd is not None
+                assert "ffmpeg" in cmd
+
+
+@pytest.mark.asyncio
+async def test_compression_get_command_image():
+    with patch('os.getenv', return_value="https://example.com"):
+        with patch('cogs.utils.temp.get_temp_dir', return_value="/tmp"):
+            with patch('cogs.utils.settings.get_baseurl', return_value="https://example.com"):
+                import importlib
+                import cogs.compression
+                importlib.reload(cogs.compression)
+                from cogs.compression import Compression
+
+                cog = Compression.__new__(Compression)
+                cog.temp_dir = "/tmp"
+
+                cmd = cog._get_compression_command("Image", "/tmp/test.jpg", "/tmp/output.jpg")
+                assert cmd is not None
+
+
+@pytest.mark.asyncio
+async def test_compression_get_command_unknown():
+    with patch('os.getenv', return_value="https://example.com"):
+        with patch('cogs.utils.temp.get_temp_dir', return_value="/tmp"):
+            with patch('cogs.utils.settings.get_baseurl', return_value="https://example.com"):
+                import importlib
+                import cogs.compression
+                importlib.reload(cogs.compression)
+                from cogs.compression import Compression
+
+                cog = Compression.__new__(Compression)
+                cog.temp_dir = "/tmp"
+
+                cmd = cog._get_compression_command("Unknown", "/tmp/test.xyz", "/tmp/output.xyz")
+                assert cmd is None
diff --git a/tests/cogs/test_cron.py b/tests/cogs/test_cron.py
new file mode 100644
index 0000000..93031f8
--- /dev/null
+++ b/tests/cogs/test_cron.py
@@ -0,0 +1,166 @@
+import json
+import os
+import pytest
+from datetime import datetime
+from unittest.mock import MagicMock, patch
+
+from cogs.cron import Cron
+
+
+@pytest.fixture
+def mock_bot():
+    bot = MagicMock()
+    bot.loop = MagicMock()
+    bot.is_closed = MagicMock(return_value=False)
+    bot.wait_until_ready = MagicMock()
+    bot.loop.create_task = MagicMock(return_value=MagicMock())
+    return bot
+
+
+def create_cog(mock_bot, tmp_path):
+    with patch.object(Cron, "__init__", lambda self, bot: None):
+        cog = Cron.__new__(Cron)
+        cog.bot = mock_bot
+        cog.scheduled_tasks = []
+        cog.cron_file = str(tmp_path / "cron_jobs.json")
+        cog.task = MagicMock()
+        return cog
+
+
+class TestLoadTasks:
+    def test_load_tasks_file_not_exists(self, mock_bot, tmp_path):
+        cog = create_cog(mock_bot, tmp_path)
+        cog.cron_file = str(tmp_path / "nonexistent.json")
+        cog.load_tasks()
+        assert cog.scheduled_tasks == []
+
+    def test_load_tasks_empty_file(self, mock_bot, tmp_path):
+        cron_file = tmp_path / "empty.json"
+        cron_file.write_text("")
+        cog = create_cog(mock_bot, tmp_path)
+        cog.cron_file = str(cron_file)
+        cog.load_tasks()
+        assert cog.scheduled_tasks == []
+
+    def test_load_tasks_valid_file(self, mock_bot, tmp_path):
+        cron_file = tmp_path / "valid.json"
+        tasks = [{"id": 1, "cron_expression": "* * * * *", "type": "audio", "channel_id": 123, "active": True}]
+        cron_file.write_text(json.dumps(tasks))
+        cog = create_cog(mock_bot, tmp_path)
+        cog.cron_file = str(cron_file)
+        cog.load_tasks()
+        assert len(cog.scheduled_tasks) == 1
+        assert cog.scheduled_tasks[0]["id"] == 1
+
+    def test_load_tasks_io_error(self, mock_bot, tmp_path):
+        cog = create_cog(mock_bot, tmp_path)
+        with patch("builtins.open", side_effect=IOError("test error")):
+            cog.load_tasks()
+        assert cog.scheduled_tasks == []
+
+
+class TestSaveTasks:
+    def test_save_tasks_with_real_file(self, mock_bot, tmp_path):
+        cron_file = tmp_path / "cron_jobs.json"
+        cog = create_cog(mock_bot, tmp_path)
+        cog.cron_file = str(cron_file)
+        cog.scheduled_tasks = [{"id": 1, "cron_expression": "* * * * *"}]
+        cog.save_tasks()
+        assert os.path.exists(cron_file)
+        with open(cron_file) as f:
+            loaded = json.load(f)
+        assert len(loaded) == 1
+
+    def test_save_tasks_creates_directory_structure(self, mock_bot, tmp_path):
+        cog = create_cog(mock_bot, tmp_path)
+        new_dir = tmp_path / "new_dir"
+        cron_file = new_dir / "cron_jobs.json"
+        cog.cron_file = str(cron_file)
+        cog.scheduled_tasks = [{"id": 1}]
+
+        cog.save_tasks()
+
+        assert os.path.exists(new_dir)
+
+
+class TestShouldRunTask:
+    def test_should_run_task_invalid_cron(self, mock_bot, tmp_path):
+        cog = create_cog(mock_bot, tmp_path)
+        task = {"cron_expression": "invalid"}
+        now = datetime.now()
+        result = cog.should_run_task(task, now)
+        assert result is False
+
+    def test_should_run_task_missing_cron_expression(self, mock_bot, tmp_path):
+        cog = create_cog(mock_bot, tmp_path)
+        task = {}
+        now = datetime.now()
+        result = cog.should_run_task(task, now)
+        assert result is False
+
+
+class TestCogUnload:
+    def test_cog_unload_cancels_task(self, mock_bot, tmp_path):
+        with patch.object(Cron, "__init__", lambda self, bot: None):
+            cog = Cron.__new__(Cron)
+            cog.bot = mock_bot
+            cog.task = MagicMock()
+
+            cog.cog_unload()
+            cog.task.cancel.assert_called_once()
+
+
+class TestTaskManagement:
+    def test_add_task_increments_id(self, mock_bot, tmp_path):
+        cog = create_cog(mock_bot, tmp_path)
+        cog.scheduled_tasks = [
+            {"id": 1, "cron_expression": "* * * * *"},
+            {"id": 2, "cron_expression": "0 * * * *"},
+        ]
+
+        new_id = max([t["id"] for t in cog.scheduled_tasks], default=0) + 1
+        assert new_id == 3
+
+    def test_find_task_by_id(self, mock_bot, tmp_path):
+        cog = create_cog(mock_bot, tmp_path)
+        cog.scheduled_tasks = [
+            {"id": 1, "cron_expression": "* * * * *"},
+            {"id": 2, "cron_expression": "0 * * * *"},
+        ]
+
+        found_task = next((t for t in cog.scheduled_tasks if t["id"] == 2), None)
+        assert found_task is not None
+        assert found_task["cron_expression"] == "0 * * * *"
+
+    def test_remove_task_by_index(self, mock_bot, tmp_path):
+        cog = create_cog(mock_bot, tmp_path)
+        cog.scheduled_tasks = [
+            {"id": 1, "cron_expression": "* * * * *"},
+            {"id": 2, "cron_expression": "0 * * * *"},
+        ]
+
+        cog.scheduled_tasks.pop(0)
+        assert len(cog.scheduled_tasks) == 1
+        assert cog.scheduled_tasks[0]["id"] == 2
+
+    def test_toggle_task_active(self, mock_bot, tmp_path):
+        cog = create_cog(mock_bot, tmp_path)
+        cog.scheduled_tasks = [{"id": 1, "active": True}]
+
+        cog.scheduled_tasks[0]["active"] = False
+        assert cog.scheduled_tasks[0]["active"] is False
+
+        cog.scheduled_tasks[0]["active"] = True
+        assert cog.scheduled_tasks[0]["active"] is True
+
+
+class TestTaskTypes:
+    def test_task_type_audio_aliases(self, mock_bot, tmp_path):
+        audio_types = ("zagraj_audio", "audio")
+        for task_type in audio_types:
+            assert task_type in ("zagraj_audio", "audio")
+
+    def test_task_type_message_aliases(self, mock_bot, tmp_path):
+        message_types = ("wyślij_wiadomość", "send_message")
+        for task_type in message_types:
+            assert task_type in ("wyślij_wiadomość", "send_message")
diff --git a/tests/cogs/test_downloader.py b/tests/cogs/test_downloader.py
new file mode 100644
index 0000000..6ac8ae7
--- /dev/null
+++ b/tests/cogs/test_downloader.py
@@ -0,0 +1,93 @@
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock
+import discord
+from tests.conftest import MockApplicationContext, MockMessage
+
+
+@pytest.fixture
+def downloader_cog(bot):
+    from cogs.downloader import Downloader
+    cog = Downloader(bot)
+    return cog
+
+
+@pytest.mark.asyncio
+async def test_download_command_success_file(downloader_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    mock_file_path = "/tmp/test_video.mp4"
+
+    with patch('cogs.downloader.Downloader.download_standalone', return_value={
+        "status": "success",
+        "type": "file",
+        "content": mock_file_path,
+        "filename": "test_video.mp4"
+    }):
+        with patch('discord.File', return_value=MagicMock()) as mock_file:
+            with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+                await downloader_cog.download.callback(downloader_cog, ctx, url="https://example.com/video", catbox=False, fformat="mp4", filename_user=None)
+                mock_respond.assert_called_once()
+                call_args = mock_respond.call_args
+                assert 'file' in str(call_args) or mock_file.called
+
+
+@pytest.mark.asyncio
+async def test_download_command_success_url(downloader_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    with patch('cogs.downloader.Downloader.download_standalone', return_value={
+        "status": "success",
+        "type": "url",
+        "content": "https://catbox.2137697.xyz/sperma/test.mp4"
+    }):
+        with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+            await downloader_cog.download.callback(downloader_cog, ctx, url="https://example.com/video", catbox=True, fformat="mp4", filename_user=None)
+            mock_respond.assert_called_once()
+            call_args = mock_respond.call_args
+            assert "pobioron" in str(call_args)
+
+
+@pytest.mark.asyncio
+async def test_download_command_error(downloader_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    with patch('cogs.downloader.Downloader.download_standalone', return_value={
+        "status": "error",
+        "type": "error",
+        "content": "Download failed",
+        "details": "Connection timeout"
+    }):
+        with patch('cogs.downloader.logger') as mock_logger:
+            await downloader_cog.download.callback(downloader_cog, ctx, url="https://badurl.com", catbox=False, fformat="mp4", filename_user=None)
+            assert mock_logger.error.called
+
+
+@pytest.mark.asyncio
+async def test_message_download_with_url(downloader_cog, mock_channel, mock_guild, bot, mock_user):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    mock_message = MagicMock()
+    mock_message.content = "Check this out https://example.com/video"
+
+    with patch('cogs.downloader.Downloader.download_standalone', return_value={
+        "status": "success",
+        "type": "file",
+        "content": "/tmp/test.mp4"
+    }):
+        with patch.object(downloader_cog, 'download', new_callable=AsyncMock) as mock_download:
+            await downloader_cog.message_download.callback(downloader_cog, ctx, message=mock_message)
+            mock_download.assert_called_once()
+
+
+@pytest.mark.asyncio
+async def test_message_download_no_url(downloader_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    mock_message = MagicMock()
+    mock_message.content = "No URL here"
+
+    with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+        await downloader_cog.message_download.callback(downloader_cog, ctx, message=mock_message)
+        mock_respond.assert_called_once()
+        call_args = mock_respond.call_args
+        assert "Brak" in str(call_args)
diff --git a/tests/cogs/test_math_commands.py b/tests/cogs/test_math_commands.py
new file mode 100644
index 0000000..5c78027
--- /dev/null
+++ b/tests/cogs/test_math_commands.py
@@ -0,0 +1,55 @@
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock
+from tests.conftest import MockApplicationContext
+
+
+@pytest.fixture
+def math_cog(bot):
+    from cogs.math_commands import Math
+    cog = Math(bot)
+    return cog
+
+
+@pytest.mark.asyncio
+async def test_math_command_valid_expression(math_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    mock_process = MagicMock()
+    mock_process.returncode = 0
+    mock_process.communicate = AsyncMock(return_value=(b"4", b""))
+
+    with patch('cogs.math_commands.asyncio.create_subprocess_exec', return_value=mock_process) as mock_subprocess:
+        with patch('cogs.math_commands.re.search', return_value=None):
+            with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+                await math_cog.math.callback(math_cog, ctx, equation="2+2")
+                mock_subprocess.assert_called_once()
+                mock_respond.assert_called_once()
+
+
+@pytest.mark.asyncio
+async def test_math_command_invalid_expression(math_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    with patch('cogs.math_commands.re.search', return_value=MagicMock()):
+        with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+            await math_cog.math.callback(math_cog, ctx, equation="eval(1)")
+            mock_respond.assert_called_once()
+            args = mock_respond.call_args
+            assert "Invalid" in str(args)
+
+
+@pytest.mark.asyncio
+async def test_math_command_process_error(math_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    mock_process = MagicMock()
+    mock_process.returncode = 1
+    mock_process.communicate = AsyncMock(return_value=(b"", b"Error: invalid expression"))
+
+    with patch('cogs.math_commands.asyncio.create_subprocess_exec', return_value=mock_process):
+        with patch('cogs.math_commands.re.search', return_value=None):
+            with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+                await math_cog.math.callback(math_cog, ctx, equation="2++")
+                mock_respond.assert_called_once()
+                args = mock_respond.call_args
+                assert "error" in str(args).lower() or "Error" in str(args)
diff --git a/tests/cogs/test_music_audio.py b/tests/cogs/test_music_audio.py
new file mode 100644
index 0000000..7ea902e
--- /dev/null
+++ b/tests/cogs/test_music_audio.py
@@ -0,0 +1,93 @@
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock
+import os
+from tests.conftest import MockApplicationContext
+
+
+@pytest.mark.asyncio
+async def test_validate_voice_channel_not_in_voice():
+    from cogs.music.audio_playback import AudioPlaybackManager
+
+    mock_ctx = MagicMock()
+    mock_ctx.author.voice = None
+    mock_ctx.respond = AsyncMock()
+
+    result = await AudioPlaybackManager.validate_voice_channel(mock_ctx)
+
+    assert result is None
+    mock_ctx.respond.assert_called_once()
+
+
+@pytest.mark.asyncio
+async def test_validate_voice_channel_in_voice():
+    from cogs.music.audio_playback import AudioPlaybackManager
+
+    mock_channel = MagicMock()
+    mock_ctx = MagicMock()
+    mock_ctx.author.voice = MagicMock()
+    mock_ctx.author.voice.channel = mock_channel
+    mock_ctx.respond = AsyncMock()
+
+    result = await AudioPlaybackManager.validate_voice_channel(mock_ctx)
+
+    assert result == mock_channel
+
+
+@pytest.mark.asyncio
+async def test_prepare_file_source_file_not_found():
+    from cogs.music.audio_playback import AudioPlaybackManager
+
+    display_name, absolute_path = await AudioPlaybackManager.prepare_file_source("/nonexistent/file.mp3")
+
+    assert display_name is None
+    assert absolute_path is None
+
+
+@pytest.mark.asyncio
+async def test_prepare_file_source_absolute_path():
+    from cogs.music.audio_playback import AudioPlaybackManager
+
+    with patch('os.path.exists', return_value=True):
+        with patch('os.path.isabs', return_value=True):
+            display_name, absolute_path = await AudioPlaybackManager.prepare_file_source("/tmp/test.mp3")
+
+            assert display_name == "test"
+            assert absolute_path == "/tmp/test.mp3"
+
+
+@pytest.mark.asyncio
+async def test_prepare_source_url():
+    from cogs.music.audio_playback import AudioPlaybackManager
+
+    source, _, is_url = await AudioPlaybackManager.prepare_source(MagicMock(), "https://example.com/stream")
+
+    assert is_url == True
+    assert source == "https://example.com/stream"
+
+
+@pytest.mark.asyncio
+async def test_prepare_source_local_file():
+    from cogs.music.audio_playback import AudioPlaybackManager
+
+    with patch('os.path.exists', return_value=True):
+        source, display_name, is_url = await AudioPlaybackManager.prepare_source(MagicMock(), "/tmp/test.mp3")
+
+        assert is_url == False
+        assert display_name == "test"
+
+
+@pytest.mark.asyncio
+async def test_cleanup_temp_file():
+    from cogs.music.audio_playback import AudioPlaybackManager
+
+    with patch('os.path.exists', return_value=True):
+        with patch('os.remove'):
+            await AudioPlaybackManager.cleanup_temp_file("/tmp/test.mp3")
+
+
+@pytest.mark.asyncio
+async def test_cleanup_temp_file_not_exists():
+    from cogs.music.audio_playback import AudioPlaybackManager
+
+    with patch('os.path.exists', return_value=False):
+        await AudioPlaybackManager.cleanup_temp_file("/nonexistent/file.mp3")
diff --git a/tests/cogs/test_music_external_play.py b/tests/cogs/test_music_external_play.py
new file mode 100644
index 0000000..fd4b625
--- /dev/null
+++ b/tests/cogs/test_music_external_play.py
@@ -0,0 +1,116 @@
+import pytest
+import os
+import asyncio
+import tempfile
+from unittest.mock import AsyncMock, patch, MagicMock
+from tests.conftest import MockApplicationContext
+
+
+@pytest.fixture
+def play_commands_cog(bot):
+    with patch('cogs.utils.temp.get_temp_dir', return_value="/tmp"):
+        from cogs.music.play_commands import PlayCommands
+        cog = PlayCommands(bot)
+    return cog
+
+
+@pytest.fixture
+def temp_mp3_file():
+    with tempfile.NamedTemporaryFile(suffix='.mp3', delete=False) as f:
+        f.write(b'fake mp3 content')
+        temp_path = f.name
+    yield temp_path
+    if os.path.exists(temp_path):
+        os.remove(temp_path)
+
+
+@pytest.mark.asyncio
+async def test_external_url_pattern_matches_youtube(play_commands_cog):
+    from cogs.music.play_commands import EXTERNAL_URL_PATTERN
+
+    assert EXTERNAL_URL_PATTERN.match("https://youtube.com/watch?v=test")
+    assert EXTERNAL_URL_PATTERN.match("https://youtu.be/test")
+    assert EXTERNAL_URL_PATTERN.match("https://www.youtube.com/watch?v=test")
+
+
+@pytest.mark.asyncio
+async def test_external_url_pattern_matches_soundcloud(play_commands_cog):
+    from cogs.music.play_commands import EXTERNAL_URL_PATTERN
+
+    assert EXTERNAL_URL_PATTERN.match("https://soundcloud.com/artist/track")
+    assert EXTERNAL_URL_PATTERN.match("https://api.soundcloud.com/tracks")
+
+
+@pytest.mark.asyncio
+async def test_external_url_pattern_matches_bandcamp(play_commands_cog):
+    from cogs.music.play_commands import EXTERNAL_URL_PATTERN
+
+    assert EXTERNAL_URL_PATTERN.match("https://artist.bandcamp.com/track")
+
+
+@pytest.mark.asyncio
+async def test_external_url_pattern_rejects_copyparty(play_commands_cog):
+    from cogs.music.play_commands import EXTERNAL_URL_PATTERN
+
+    assert not EXTERNAL_URL_PATTERN.match("https://catbox.2137697.xyz/sperma/file.mp3")
+    assert not EXTERNAL_URL_PATTERN.match("some search query")
+
+
+@pytest.mark.asyncio
+async def test_play_command_calls_external_handler(play_commands_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    with patch.object(play_commands_cog, '_handle_external_url_play', new_callable=AsyncMock) as mock_handler:
+        mock_handler.return_value = None
+        mock_defer = AsyncMock()
+        ctx.defer = mock_defer
+        ctx.respond = AsyncMock()
+
+        await play_commands_cog.play.callback(
+            play_commands_cog, ctx,
+            melodia="https://youtube.com/watch?v=test",
+            file=None, compressed=False
+        )
+
+        mock_handler.assert_called_once_with(ctx, "https://youtube.com/watch?v=test")
+
+
+@pytest.mark.asyncio
+async def test_play_command_calls_local_handler(play_commands_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    with patch.object(play_commands_cog, '_handle_local_file_play', new_callable=AsyncMock) as mock_handler:
+        mock_handler.return_value = None
+        mock_defer = AsyncMock()
+        ctx.defer = mock_defer
+        ctx.respond = AsyncMock()
+
+        await play_commands_cog.play.callback(
+            play_commands_cog, ctx,
+            melodia="some search query",
+            file=None, compressed=False
+        )
+
+        mock_handler.assert_called_once_with(ctx, "some search query", False)
+
+
+@pytest.mark.asyncio
+async def test_upload_to_copyparty_async(play_commands_cog, temp_mp3_file, monkeypatch):
+    monkeypatch.setenv("COPYPARTY_URL_UPLOAD", "https://catbox.2137697.xyz/sperma/")
+    monkeypatch.setenv("COPYPARTY_PASSWORD", "testpassword")
+
+    mock_response = AsyncMock()
+    mock_response.status = 200
+    mock_response.text = AsyncMock(return_value="")
+    mock_response.json = AsyncMock(return_value={"fileurl": "https://example.com/file.mp3"})
+    mock_response.__aenter__ = AsyncMock(return_value=mock_response)
+    mock_response.__aexit__ = AsyncMock()
+
+    mock_session_context = AsyncMock()
+    mock_session_context.__aenter__ = AsyncMock(return_value=mock_session_context)
+    mock_session_context.__aexit__ = AsyncMock()
+    mock_session_context.post = MagicMock(return_value=mock_response)
+
+    with patch('aiohttp.ClientSession', return_value=mock_session_context):
+        await play_commands_cog._upload_to_copyparty_async(temp_mp3_file)
+        mock_session_context.post.assert_called_once()
diff --git a/tests/cogs/test_music_join.py b/tests/cogs/test_music_join.py
new file mode 100644
index 0000000..3c7ca6e
--- /dev/null
+++ b/tests/cogs/test_music_join.py
@@ -0,0 +1,53 @@
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock
+from tests.conftest import MockApplicationContext
+
+
+@pytest.fixture
+def join_cog(bot):
+    from cogs.music.join import Join
+    cog = Join(bot)
+    return cog
+
+
+@pytest.fixture
+def stop_cog(bot):
+    from cogs.music.stop import Stop
+    cog = Stop(bot)
+    return cog
+
+
+@pytest.mark.asyncio
+async def test_join_command_success(join_cog, mock_channel, mock_guild, bot, mock_user):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+    ctx.user = mock_user
+    ctx.author = mock_user
+
+    mock_voice_channel = MagicMock()
+    mock_voice = MagicMock()
+    mock_voice_channel.connect = AsyncMock(return_value=mock_voice)
+
+    ctx.author.voice = MagicMock()
+    ctx.author.voice.channel = mock_voice_channel
+
+    with patch.object(mock_voice_channel, 'connect', new_callable=AsyncMock, return_value=mock_voice):
+        with patch.object(ctx, 'respond', new_callable=AsyncMock):
+            with patch.object(ctx.interaction, 'delete_original_response', new_callable=AsyncMock):
+                await join_cog.join.callback(join_cog, ctx)
+
+
+@pytest.mark.asyncio
+async def test_stop_command_success(stop_cog, mock_channel, mock_guild, bot, mock_user):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+    ctx.user = mock_user
+    ctx.author = mock_user
+
+    mock_voice_client = MagicMock()
+    mock_voice_client.disconnect = AsyncMock()
+    ctx.voice_client = mock_voice_client
+
+    with patch.object(ctx, 'respond', new_callable=AsyncMock):
+        with patch.object(ctx.interaction, 'delete_original_response', new_callable=AsyncMock):
+            await stop_cog.stop.callback(stop_cog, ctx)
+
+            mock_voice_client.disconnect.assert_called_once()
diff --git a/tests/cogs/test_music_play.py b/tests/cogs/test_music_play.py
new file mode 100644
index 0000000..e720c9a
--- /dev/null
+++ b/tests/cogs/test_music_play.py
@@ -0,0 +1,104 @@
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock
+import os
+from tests.conftest import MockApplicationContext
+
+
+@pytest.fixture
+def play_commands_cog(bot):
+    with patch('cogs.utils.temp.get_temp_dir', return_value="/tmp"):
+        from cogs.music.play_commands import PlayCommands
+        cog = PlayCommands(bot)
+    return cog
+
+
+@pytest.fixture
+def loop_cog(bot):
+    from cogs.music.loop import Loop
+    cog = Loop(bot)
+    return cog
+
+
+@pytest.mark.asyncio
+async def test_create_search_embed_empty(play_commands_cog):
+    embed, view = await play_commands_cog._create_search_embed([])
+
+    assert embed.title == "Wyniki wyszukiwania"
+    assert len(view.children) == 0
+
+
+@pytest.mark.asyncio
+async def test_create_search_embed_with_candidates(play_commands_cog):
+    candidates = [
+        "https://example.com/test1.mp3",
+        "https://example.com/test2.mp3"
+    ]
+
+    embed, view = await play_commands_cog._create_search_embed(candidates)
+
+    assert embed.title == "Wyniki wyszukiwania"
+    assert len(embed.fields) == 2
+
+
+@pytest.mark.asyncio
+async def test_play_command_no_file_or_search(play_commands_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+        await play_commands_cog.play.callback(play_commands_cog, ctx, melodia=None, file=None, compressed=False)
+        mock_respond.assert_called_once()
+        args = mock_respond.call_args
+        assert "Musisz podać" in str(args)
+
+
+@pytest.mark.asyncio
+async def test_play_command_both_file_and_search(play_commands_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    mock_file = MagicMock()
+    mock_file.filename = "test.mp3"
+
+    with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+        await play_commands_cog.play.callback(play_commands_cog, ctx, melodia="test", file=mock_file, compressed=False)
+        mock_respond.assert_called_once()
+        args = mock_respond.call_args
+        assert "nie oba" in str(args) or "LUB" in str(args)
+
+
+def test_loop_cog_is_looping_initial(loop_cog):
+    assert loop_cog.is_looping(123) == False
+
+
+def test_loop_cog_set_looping(loop_cog):
+    loop_cog.set_looping(123, True)
+    assert loop_cog.is_looping(123) == True
+
+
+@pytest.mark.asyncio
+async def test_loop_command_toggle_on(loop_cog, mock_channel, mock_guild, bot, mock_user):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+    ctx.user = mock_user
+    ctx.author = mock_user
+    ctx.guild.id = 123
+
+    with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+        await loop_cog.loop.callback(loop_cog, ctx)
+        mock_respond.assert_called_once()
+        args = mock_respond.call_args
+        assert "włączony" in str(args)
+
+
+@pytest.mark.asyncio
+async def test_loop_command_toggle_off(loop_cog, mock_channel, mock_guild, bot, mock_user):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+    ctx.user = mock_user
+    ctx.author = mock_user
+    ctx.guild.id = 456
+
+    loop_cog.set_looping(456, True)
+
+    with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+        await loop_cog.loop.callback(loop_cog, ctx)
+        mock_respond.assert_called_once()
+        args = mock_respond.call_args
+        assert "wyłączony" in str(args)
diff --git a/tests/cogs/test_qr.py b/tests/cogs/test_qr.py
new file mode 100644
index 0000000..2a132ca
--- /dev/null
+++ b/tests/cogs/test_qr.py
@@ -0,0 +1,75 @@
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock, mock_open
+import os
+from cogs.qr import QR
+from tests.conftest import MockApplicationContext
+
+
+@pytest.fixture
+def qr_cog(bot):
+    cog = QR(bot)
+    return cog
+
+
+@pytest.fixture
+def mock_temp_file():
+    with patch('tempfile.NamedTemporaryFile') as mock:
+        mock_file = MagicMock()
+        mock_file.name = "/tmp/test_qr.png"
+        mock.return_value = mock_file
+        yield mock_file
+
+
+@pytest.mark.asyncio
+async def test_qr_generate_success(qr_cog, mock_channel, mock_guild, bot, mock_temp_file):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    with patch('cogs.qr.QR._generate_qr') as mock_generate:
+        with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+            with patch('os.path.exists', return_value=True):
+                with patch('os.unlink'):
+                    await qr_cog.qr.callback(qr_cog, ctx, text="https://example.com")
+                    mock_generate.assert_called_once()
+                    mock_respond.assert_called_once()
+
+
+@pytest.mark.asyncio
+async def test_qr_generate_empty_text(qr_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    with patch('cogs.qr.QR._generate_qr'):
+        with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+            with patch('os.path.exists', return_value=False):
+                await qr_cog.qr.callback(qr_cog, ctx, text="")
+                mock_respond.assert_called_once()
+
+
+@pytest.mark.asyncio
+async def test_qr_decode_not_available(qr_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    mock_attachment = MagicMock()
+    mock_attachment.url = "https://example.com/qr.png"
+
+    with patch('cogs.qr._ensure_qr', return_value=False):
+        with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+            await qr_cog.decode.callback(qr_cog, ctx, image=mock_attachment)
+            mock_respond.assert_called_once()
+            args = mock_respond.call_args
+            assert "nie jest dostępne" in str(args) or "not available" in str(args).lower()
+
+
+@pytest.mark.asyncio
+async def test_qr_decode_download_failure(qr_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    mock_attachment = MagicMock()
+    mock_attachment.url = "https://example.com/qr.png"
+
+    with patch('cogs.qr._ensure_qr', return_value=True):
+        with patch.object(qr_cog, '_download_image', return_value=None):
+            with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+                await qr_cog.decode.callback(qr_cog, ctx, image=mock_attachment)
+                mock_respond.assert_called_once()
+                args = mock_respond.call_args
+                assert "Nie udało się" in str(args) or "failed" in str(args).lower()
diff --git a/tests/cogs/test_say.py b/tests/cogs/test_say.py
new file mode 100644
index 0000000..13cad40
--- /dev/null
+++ b/tests/cogs/test_say.py
@@ -0,0 +1,38 @@
+import pytest
+from unittest.mock import AsyncMock, patch
+from cogs.say import Say
+from tests.conftest import MockApplicationContext
+
+
+@pytest.fixture
+def say_cog(bot):
+    cog = Say(bot)
+    return cog
+
+
+@pytest.mark.asyncio
+async def test_say_command(say_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    with patch.object(ctx, 'send', new_callable=AsyncMock) as mock_send:
+        await say_cog.say.callback(say_cog, ctx, "Hello World")
+        mock_send.assert_called_once_with(content="Hello World")
+
+
+@pytest.mark.asyncio
+async def test_say_command_empty_text(say_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    with patch.object(ctx, 'send', new_callable=AsyncMock) as mock_send:
+        await say_cog.say.callback(say_cog, ctx, "")
+        mock_send.assert_called_once_with(content="")
+
+
+@pytest.mark.asyncio
+async def test_say_command_long_text(say_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+    long_text = "A" * 2000
+
+    with patch.object(ctx, 'send', new_callable=AsyncMock) as mock_send:
+        await say_cog.say.callback(say_cog, ctx, long_text)
+        mock_send.assert_called_once_with(content=long_text)
diff --git a/tests/cogs/test_search.py b/tests/cogs/test_search.py
new file mode 100644
index 0000000..8c04dfc
--- /dev/null
+++ b/tests/cogs/test_search.py
@@ -0,0 +1,83 @@
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock
+import discord
+from tests.conftest import MockApplicationContext
+
+
+@pytest.fixture
+def search_cog(bot):
+    from cogs.search import Search
+    cog = Search(bot)
+    return cog
+
+
+@pytest.mark.asyncio
+async def test_search_command_success(search_cog, mock_channel, mock_guild, bot, mock_user):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+    ctx.user = mock_user
+    ctx.author = mock_user
+
+    search_cog._cached_results[mock_user.id] = {
+        "testfile.mp4": "https://example.com/files/testfile.mp4"
+    }
+
+    with patch.object(ctx, 'send_followup', new_callable=AsyncMock) as mock_followup:
+        await search_cog.search.callback(search_cog, ctx, filename="testfile.mp4")
+        mock_followup.assert_called_once_with("https://example.com/files/testfile.mp4")
+        assert mock_user.id not in search_cog._cached_results
+
+
+@pytest.mark.asyncio
+async def test_search_command_no_cache(search_cog, mock_channel, mock_guild, bot, mock_user):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+    ctx.user = mock_user
+    ctx.author = mock_user
+
+    with patch.object(ctx, 'send_followup', new_callable=AsyncMock) as mock_followup:
+        await search_cog.search.callback(search_cog, ctx, filename="testfile.mp4")
+        mock_followup.assert_called_once_with("Search results expired. Please search again.")
+
+
+@pytest.mark.asyncio
+async def test_search_command_file_not_found(search_cog, mock_channel, mock_guild, bot, mock_user):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+    ctx.user = mock_user
+    ctx.author = mock_user
+
+    search_cog._cached_results[mock_user.id] = {
+        "testfile.mp4": "https://example.com/files/testfile.mp4"
+    }
+
+    with patch.object(ctx, 'send_followup', new_callable=AsyncMock) as mock_followup:
+        await search_cog.search.callback(search_cog, ctx, filename="nonexistent.mp4")
+        mock_followup.assert_called_once_with("File 'nonexistent.mp4' not found.")
+
+
+@pytest.mark.asyncio
+async def test_search_command_empty_filename(search_cog, mock_channel, mock_guild, bot, mock_user):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+    ctx.user = mock_user
+    ctx.author = mock_user
+
+    with patch.object(ctx, 'reply', new_callable=AsyncMock) as mock_reply:
+        await search_cog.search.callback(search_cog, ctx, filename="")
+        mock_reply.assert_called_once_with("Please select a file from the autocomplete options.")
+
+
+@pytest.mark.asyncio
+async def test_file_autocomplete(search_cog, mock_channel, mock_guild, bot, mock_user):
+    mock_autocomplete_ctx = MagicMock()
+    mock_autocomplete_ctx.value = "test"
+    mock_autocomplete_ctx.interaction = MagicMock()
+    mock_autocomplete_ctx.interaction.user = mock_user
+
+    with patch('cogs.utils.file_search.UniversalSearcher.search_copyparty_autocomplete', new_callable=AsyncMock) as mock_search:
+        mock_search.return_value = [
+            "https://example.com/files/test1.mp4",
+            "https://example.com/files/test2.mp4"
+        ]
+
+        choices = await search_cog.file_autocomplete(mock_autocomplete_ctx)
+
+        assert len(choices) == 2
+        assert mock_user.id in search_cog._cached_results
diff --git a/tests/cogs/test_trigger.py b/tests/cogs/test_trigger.py
new file mode 100644
index 0000000..6aaaa11
--- /dev/null
+++ b/tests/cogs/test_trigger.py
@@ -0,0 +1,106 @@
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock
+import sqlite3
+from tests.conftest import MockApplicationContext
+
+
+@pytest.fixture
+def trigger_cog(bot):
+    with patch('cogs.trigger.get_connection') as mock_conn:
+        mock_conn.return_value.__enter__ = MagicMock(return_value=MagicMock())
+        mock_conn.return_value.__exit__ = MagicMock(return_value=False)
+        from cogs.trigger import Trigger
+        cog = Trigger(bot)
+    return cog
+
+
+@pytest.fixture
+def mock_db_connection():
+    with patch('cogs.trigger.get_connection') as mock_get_conn:
+        mock_conn = MagicMock()
+        mock_cursor = MagicMock()
+        mock_conn.cursor.return_value = mock_cursor
+        mock_get_conn.return_value.__enter__ = MagicMock(return_value=mock_conn)
+        mock_get_conn.return_value.__exit__ = MagicMock(return_value=False)
+        yield mock_conn, mock_cursor
+
+
+@pytest.mark.asyncio
+async def test_trigger_create_command(trigger_cog, mock_channel, mock_guild, bot, mock_db_connection):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    mock_conn, mock_cursor = mock_db_connection
+    mock_cursor.fetchone.return_value = None
+
+    with patch('cogs.trigger.get_connection') as mock_get_conn:
+        mock_conn = MagicMock()
+        mock_cursor = MagicMock()
+        mock_conn.cursor.return_value = mock_cursor
+        mock_get_conn.return_value.__enter__ = MagicMock(return_value=mock_conn)
+        mock_get_conn.return_value.__exit__ = MagicMock(return_value=False)
+
+        with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+            await trigger_cog.create.callback(trigger_cog, ctx, name="test_trigger")
+            mock_respond.assert_called_once_with("trigger added")
+
+
+@pytest.mark.asyncio
+async def test_trigger_add_command(trigger_cog, mock_channel, mock_guild, bot, mock_db_connection):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    with patch('cogs.trigger.get_connection') as mock_get_conn:
+        mock_conn = MagicMock()
+        mock_cursor = MagicMock()
+        mock_cursor.fetchone.return_value = (1,)  # trigger exists
+        mock_conn.cursor.return_value = mock_cursor
+        mock_get_conn.return_value.__enter__ = MagicMock(return_value=mock_conn)
+        mock_get_conn.return_value.__exit__ = MagicMock(return_value=False)
+
+        with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+            await trigger_cog.add.callback(trigger_cog, ctx, name="test_trigger", trigger="hello", response="Hi there!")
+            mock_respond.assert_called_once_with("trigger updated")
+
+
+@pytest.mark.asyncio
+async def test_trigger_add_command_not_found(trigger_cog, mock_channel, mock_guild, bot, mock_db_connection):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    with patch('cogs.trigger.get_connection') as mock_get_conn:
+        mock_conn = MagicMock()
+        mock_cursor = MagicMock()
+        mock_cursor.fetchone.return_value = None  # trigger not found
+        mock_conn.cursor.return_value = mock_cursor
+        mock_get_conn.return_value.__enter__ = MagicMock(return_value=mock_conn)
+        mock_get_conn.return_value.__exit__ = MagicMock(return_value=False)
+
+        with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+            await trigger_cog.add.callback(trigger_cog, ctx, name="nonexistent", trigger="hello", response="Hi")
+            mock_respond.assert_called_once_with("Trigger not found.")
+
+
+@pytest.mark.asyncio
+async def test_trigger_delete_command(trigger_cog, mock_channel, mock_guild, bot, mock_db_connection):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    with patch('cogs.trigger.get_connection') as mock_get_conn:
+        mock_conn = MagicMock()
+        mock_cursor = MagicMock()
+        mock_cursor.fetchone.return_value = (1,)  # trigger exists
+        mock_conn.cursor.return_value = mock_cursor
+        mock_get_conn.return_value.__enter__ = MagicMock(return_value=mock_conn)
+        mock_get_conn.return_value.__exit__ = MagicMock(return_value=False)
+
+        with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+            await trigger_cog.delete.callback(trigger_cog, ctx, name="test_trigger")
+            mock_respond.assert_called_once_with("trigger deleted")
+
+
+@pytest.mark.asyncio
+async def test_trigger_help_command(trigger_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+        await trigger_cog.help.callback(trigger_cog, ctx)
+        mock_respond.assert_called_once()
+        args = mock_respond.call_args
+        assert "Trigger create" in str(args)
diff --git a/tests/cogs/test_tts.py b/tests/cogs/test_tts.py
new file mode 100644
index 0000000..de68580
--- /dev/null
+++ b/tests/cogs/test_tts.py
@@ -0,0 +1,58 @@
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock
+import discord
+from tests.conftest import MockApplicationContext
+
+
+@pytest.fixture
+def tts_cog(bot):
+    from cogs.tts import TTS
+    cog = TTS(bot)
+    return cog
+
+
+@pytest.mark.asyncio
+async def test_tts_file_output(tts_cog, mock_channel, mock_guild, bot, mock_user):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+    ctx.user = mock_user
+    ctx.author = mock_user
+
+    "/tmp/test_tts.mp3"
+
+    with patch('cogs.tts.gTTS') as _:
+        with patch('os.path.exists', return_value=True):
+            with patch('os.unlink'):
+                with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+                    with patch('cogs.tts.get_volume', return_value=1.0):
+                        await tts_cog.tts.callback(tts_cog, ctx, text="Hello", output="file")
+                        mock_respond.assert_called_once()
+
+
+@pytest.mark.asyncio
+async def test_tts_voice_output_not_in_channel(tts_cog, mock_channel, mock_guild, bot, mock_user):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+    ctx.user = mock_user
+    ctx.author = mock_user
+    ctx.author.voice = None
+
+    with patch('cogs.tts.gTTS'):
+        with patch('os.path.exists', return_value=True):
+            with patch('os.unlink'):
+                with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+                    with patch('cogs.tts.get_volume', return_value=1.0):
+                        await tts_cog.tts.callback(tts_cog, ctx, text="Hello", output="vc")
+
+
+@pytest.mark.asyncio
+async def test_tts_error_handling(tts_cog, mock_channel, mock_guild, bot, mock_user):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+    ctx.user = mock_user
+    ctx.author = mock_user
+
+    with patch('cogs.tts.gTTS', side_effect=Exception("TTS Error")):
+        with patch('os.path.exists', return_value=False):
+            with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+                await tts_cog.tts.callback(tts_cog, ctx, text="Hello", output="file")
+                mock_respond.assert_called_once()
+                args = mock_respond.call_args
+                assert "Error" in str(args) or "eror" in str(args)
diff --git a/tests/cogs/test_vclogs.py b/tests/cogs/test_vclogs.py
new file mode 100644
index 0000000..2003478
--- /dev/null
+++ b/tests/cogs/test_vclogs.py
@@ -0,0 +1,83 @@
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock
+import json
+from tests.conftest import MockApplicationContext
+
+
+def test_format_duration():
+    from cogs.vclogs import format_duration
+
+    assert format_duration(30) == "30s"
+    assert format_duration(90) == "1m 30s"
+    assert format_duration(3661) == "1h 1m 1s"
+
+
+def test_load_activity_data():
+    with patch('builtins.open', MagicMock()):
+        with patch('os.path.exists', return_value=True):
+            with patch('json.load', return_value={"123": {"active": True}}):
+                from cogs.vclogs import load_activity_data
+                data = load_activity_data()
+                assert isinstance(data, dict)
+
+
+def test_save_activity_data():
+    with patch('builtins.open', MagicMock()) as mock_open:
+        with patch('json.dump'):
+            from cogs.vclogs import save_activity_data
+            save_activity_data({"123": {"active": True}})
+            mock_open.assert_called_once()
+
+
+@pytest.fixture
+def vclogs_cog(bot):
+    with patch('cogs.vclogs.get_voice_manager'):
+        with patch('cogs.vclogs.get_volume', return_value=1.0):
+            with patch('cogs.vclogs.save_settings'):
+                from cogs.vclogs import VcLogs
+                cog = VcLogs(bot)
+    return cog
+
+
+@pytest.mark.asyncio
+async def test_handle_state_change_deaf_true(vclogs_cog):
+    mock_member = MagicMock()
+    mock_member.display_name = "TestUser"
+    mock_channel = MagicMock()
+
+    tts_text, channel = await vclogs_cog.handle_state_change(mock_member, mock_channel, 'deaf', True, None)
+
+    assert "jest bity przez ojca" in tts_text
+
+
+@pytest.mark.asyncio
+async def test_handle_state_change_deaf_false(vclogs_cog):
+    mock_member = MagicMock()
+    mock_member.display_name = "TestUser"
+    mock_channel = MagicMock()
+
+    tts_text, channel = await vclogs_cog.handle_state_change(mock_member, mock_channel, 'deaf', False, None)
+
+    assert "uciek od ojca" in tts_text
+
+
+@pytest.mark.asyncio
+async def test_handle_state_change_mute_true(vclogs_cog):
+    mock_member = MagicMock()
+    mock_member.display_name = "TestUser"
+    mock_channel = MagicMock()
+
+    tts_text, channel = await vclogs_cog.handle_state_change(mock_member, mock_channel, 'mute', True, None)
+
+    assert "idzie robić jajecznice" in tts_text
+
+
+@pytest.mark.asyncio
+async def test_handle_state_change_mute_false(vclogs_cog):
+    mock_member = MagicMock()
+    mock_member.display_name = "TestUser"
+    mock_channel = MagicMock()
+
+    tts_text, channel = await vclogs_cog.handle_state_change(mock_member, mock_channel, 'mute', False, None)
+
+    assert "zrobił jajecznice" in tts_text
diff --git a/tests/cogs/test_voice.py b/tests/cogs/test_voice.py
new file mode 100644
index 0000000..ade29cb
--- /dev/null
+++ b/tests/cogs/test_voice.py
@@ -0,0 +1,79 @@
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock
+import asyncio
+from tests.conftest import MockApplicationContext
+
+
+@pytest.mark.asyncio
+async def test_get_voice_manager():
+    from cogs.voice import get_voice_manager, VoiceManager
+
+    mock_bot = MagicMock()
+    mock_bot.user = MagicMock()
+    mock_bot.user.id = 12345
+
+    manager1 = get_voice_manager(mock_bot)
+    manager2 = get_voice_manager(mock_bot)
+
+    assert isinstance(manager1, VoiceManager)
+    assert manager1 is manager2
+
+
+@pytest.mark.asyncio
+async def test_voice_manager_join_channel_not_found():
+    from cogs.voice import VoiceManager
+
+    mock_bot = MagicMock()
+    mock_bot.get_channel.return_value = None
+
+    manager = VoiceManager(mock_bot)
+    result = await manager.join_by_channel_id(999)
+
+    assert result is None
+
+
+@pytest.mark.asyncio
+async def test_voice_manager_join_invalid_channel():
+    from cogs.voice import VoiceManager
+
+    mock_bot = MagicMock()
+    mock_channel = MagicMock()
+    mock_bot.get_channel.return_value = mock_channel
+
+    manager = VoiceManager(mock_bot)
+    result = await manager.join_by_channel_id(999)
+
+    assert result is None
+
+
+@pytest.mark.asyncio
+async def test_voice_manager_get_voice_status_not_connected():
+    from cogs.voice import VoiceManager
+
+    mock_bot = MagicMock()
+    mock_guild = MagicMock()
+
+    with patch('cogs.voice.VoiceManager.get_voice_client', return_value=None):
+        manager = VoiceManager(mock_bot)
+        voice_client, is_connected, is_playing = await manager.get_voice_status(mock_guild)
+
+        assert voice_client is None
+        assert is_connected == False
+        assert is_playing == False
+
+
+@pytest.mark.asyncio
+async def test_voice_manager_stop():
+    from cogs.voice import VoiceManager
+
+    mock_bot = MagicMock()
+    mock_guild = MagicMock()
+    mock_voice_client = MagicMock()
+    mock_voice_client.disconnect = AsyncMock()
+
+    with patch('cogs.voice.VoiceManager.get_voice_client', return_value=mock_voice_client):
+        manager = VoiceManager(mock_bot)
+        await manager.stop(mock_guild)
+
+        mock_voice_client.stop.assert_called_once()
+        mock_voice_client.disconnect.assert_called_once()
diff --git a/tests/cogs/test_web.py b/tests/cogs/test_web.py
new file mode 100644
index 0000000..e0d2208
--- /dev/null
+++ b/tests/cogs/test_web.py
@@ -0,0 +1,57 @@
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock
+from cogs.web import Web
+from tests.conftest import MockApplicationContext
+
+
+@pytest.fixture
+def web_cog(bot):
+    cog = Web(bot)
+    return cog
+
+
+@pytest.mark.asyncio
+async def test_web_command_success(web_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    mock_response = MagicMock()
+    mock_response.status_code = 200
+    mock_response.text = '''
+        <html>
+            <a class="result__a" href="https://example.com">Test Result</a>
+            <a class="result__a" href="https://example.com/2">Test Result 2</a>
+        </html>
+    '''
+
+    with patch('cogs.web.requests.get', return_value=mock_response) as mock_get:
+        with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+            await web_cog.web.callback(web_cog, ctx, query="test query")
+            mock_get.assert_called_once()
+            mock_respond.assert_called_once()
+
+
+@pytest.mark.asyncio
+async def test_web_command_no_results(web_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    mock_response = MagicMock()
+    mock_response.status_code = 200
+    mock_response.text = '<html><body></body></html>'
+
+    with patch('cogs.web.requests.get', return_value=mock_response):
+        with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+            await web_cog.web.callback(web_cog, ctx, query="test")
+            mock_respond.assert_called_once_with(content="No results found.", ephemeral=True)
+
+
+@pytest.mark.asyncio
+async def test_web_command_http_error(web_cog, mock_channel, mock_guild, bot):
+    ctx = MockApplicationContext(bot=bot, channel=mock_channel, guild=mock_guild)
+
+    mock_response = MagicMock()
+    mock_response.status_code = 500
+
+    with patch('cogs.web.requests.get', return_value=mock_response):
+        with patch.object(ctx, 'respond', new_callable=AsyncMock) as mock_respond:
+            await web_cog.web.callback(web_cog, ctx, query="test")
+            mock_respond.assert_called_once_with(content="Error: 500", ephemeral=True)