HEAD (unreleased) since tag 2.0

Tag: 2.0
Tag: 1.28
2026-07-16 14:52:11 +00:00 · 2025-10-30 16:59:25 +01:00 · 2025-10-30 16:59:24 +01:00 · 2025-10-30 16:59:23 +01:00 · 2025-10-30 16:59:21 +01:00 · 2025-10-30 16:59:21 +01:00
53 changed files with 1431 additions and 595 deletions
@@ -0,0 +1,32 @@
 # Python
 __pycache__
 *.py[cod]
 *.pyo
 *.pyd
 *.so
 # VCS/CI
 .git
 .gitignore
 .gitattributes
 .github
 # Editor
 .vscode
 .idea
 # Python tooling
 .pytest_cache
 .mypy_cache
 .ruff_cache
 .tox
 dist
 build
 *.egg-info
 # Local assets
 logs
 music
 data
 *.env
 *.env.*
@@ -1,2 +1,23 @@
 # conjurer
 Discord.py bot for fun, sex and BDSM
 ## Docker quick start
 Docker definitions live at the repository root and let you run the Discord bot
 (`thin_client.py`), the musician file service, and the librarian search worker as
 separate containers.
 1. **Prepare configuration**
   - Edit the environment files under `docker/env/*.env` and replace the
     placeholders (`replace-me`, `shared-secret`, etc.) with your real tokens.
     Keep `CONJURER_API_KEY` identical across all services.
 2. **Create host directories** listed in `docker-compose.yml` (for example
   `docker/volumes/bot/config`, `docker/volumes/musician/data`, …) and populate
   them with the required JSON settings or media assets.
 3. **Launch the stack**
   ```bash
   docker compose up --build
   ```
 Logs for each container are mounted under `docker/volumes/*` so you can diff the
 runtime JSON and log files in git if needed.
@@ -0,0 +1,46 @@
 import discord
 from discord.ext import commands
 from typing import  Optional
 class Music(commands.Cog):
    def __init__(self, bot):
        self.bot = bot # This is so you can access Bot instance in your cog
 # You must have this function for `bot.load_extension` to call
 def setup(bot):
    bot.add_cog(Music(bot))
@commands.hybrid_command(
    name="przytul", description="Przytul kogoś - daj mention po komendzie :)"
 )
 async def przytul(ctx, arg: Optional[discord.Member] = None):
    """
    Generate a text about hugging mentioned user.
    :param ctx: ctx stands for "context" and is a required parameter in Discord.py commands. It
    represents the context in which the command was invoked, including information such as the message,
    the channel, the server, and the user who invoked the command
    :param arg: arg is a parameter of the function "przytul" that expects a Discord member object. The
    parameter is optional, meaning that if no member object is provided, it will default to None
    :type arg: Optional[discord.Member]
    """
    async with ctx.typing():
        nieprzytulac = False
        for mention in ctx.message.mentions:
            for role in mention.roles:
                if role.name == "NIEPRZYTULAĆ!":
                    nieprzytulac = True
        if arg and nieprzytulac:
            await ctx.send(
                f"Żebym ja Ciebie nie przytulił {ctx.message.author.mention}"
            )
        elif arg:
            await ctx.send(
                # trunk-ignore(codespell/misspelled)
                f"Już dobrze.... Już dobrze... Ojej.. Biedactwo... :( *W ułamku sekundy {arg.mention} znajduje sie w duszącym uścisku. Żebra trzeszczą - kilka pęka. Pacnięcia po plecach grożą odbiciem nerek, a głaskanie po głowie powoduje wstrząs mózgu*"
            )
        else:
            await ctx.send(
                "Kogo mam przytulić? *Wyłamuje kostki i przeciąga się - jego 200 kilowa sylwetka złożona z samych mięśni świadczy o tym że jest gotowy*"
            )
@@ -11,10 +11,9 @@ from urllib import request as urequest
 from flask import Flask, abort, jsonify, request
 from waitress import serve
-HOST_ADDRESS = os.getenv("CONJURER_DISCORD_HOST", "192.168.1.31")
+HOST_ADDRESS = "192.168.1.191"
-PORT_ADDRESS = int(os.getenv("CONJURER_DISCORD_PORT", "5000"))
+PORT_ADDRESS = 5000
-ICECAST_ADDRESS = os.getenv("CONJURER_ICECAST", "http://192.168.1.15:8000")
+ICECAST_ADDRESS = "http://192.168.1.15:8000"
 API_KEY = os.getenv("CONJURER_API_KEY")
 OUT_COMM_Q = Queue()
 IN_COMM_Q = Queue()
 SRCHTITLE = re.compile(rb"StreamTitle=\\*(?P<title>[^;]*);").search
@@ -22,12 +21,6 @@ SRCHTITLE = re.compile(rb"StreamTitle=\\*(?P<title>[^;]*);").search
 awaiting_q = []
 incoming_q = Queue()
 app = Flask(__name__)
 def _authorize_request() -> None:
    """Reject inbound calls lacking the shared key (no-op if key is unset)."""
    if API_KEY and request.headers.get("X-Conjurer-Api-Key") != API_KEY:
        abort(401)
 PREPPED_TRACKS = {
    "requests": "",
    "hit": "",
@@ -40,6 +33,13 @@ PREPPED_TRACKS = {
 }
 logger = logging.getLogger("discord")
 API_KEY = os.getenv("CONJURER_API_KEY")
 def _authorize_request() -> None:
    if API_KEY and request.headers.get("X-Conjurer-Api-Key") != API_KEY:
        abort(401)
 class QueryControl:
    """
@@ -89,13 +89,13 @@ def log_radio_tracks():
@app.route("/conjurer", methods=["POST"])
 def answer_external_command():
    _authorize_request()
    """
    The function `answer_external_command` logs the request data, loads the data as JSON, logs the
    record, and then puts the record into an incoming queue before returning a success message.
    :return: The function `answer_external_command()` is returning a JSON response with the message
    "SUCCESS".
    """
    _authorize_request()
    logger = logging.getLogger("discord")
    logger.info(request)
    record = json.loads(request.data)
@@ -144,11 +144,10 @@ def scan_queue(stop_event: Optional[threading.Event] = None):
    """
    The function `scan_queue` reads data from a queue, logs it, and appends it to another queue.
-    A bounded ``get(timeout=1)`` is used instead of a blocking ``get()`` so the
+    :param _logger: The `_logger` parameter is typically an instance of a logging object that is used to
-    worker can observe ``stop_event`` and exit cleanly during shutdown.
+    record and store log messages. It is commonly used to track the flow of the program, record errors,
-
+    and provide information for debugging purposes. In this code snippet, the `_logger` object is used
-    :param stop_event: optional :class:`threading.Event`; when set the loop
+    to log the
    stops at the next iteration.
    """
    logger = logging.getLogger("discord")
    while True:
@@ -168,8 +167,10 @@ def scan_incoming(stop_event: Optional[threading.Event] = None):
    The `scan_incoming` function continuously checks for incoming data, processes it, and logs when data
    is found.
-    :param stop_event: optional :class:`threading.Event`; when set the loop
+    :param _logger: The `_logger` parameter in the `scan_incoming` function is a logger object that is
-    stops at the next iteration.
+    used to log messages or information during the execution of the function. It is typically used for
    debugging, monitoring, or tracking the flow of the program. In this case, the `_logger` is being
    used
    """
    logger = logging.getLogger("discord")
    while True:
@@ -227,28 +228,23 @@ def comm_subroutine(stop_event: Optional[threading.Event] = None):
    """
    The `comm_subroutine` function starts multiple threads to run different tasks concurrently.
-    Workers run as daemon threads and honour an optional ``stop_event`` so the
+    :param logger: The `logger` parameter in the `comm_subroutine` function is an instance of a logger
-    bot can shut the communication layer down cleanly instead of blocking
+    object that is used for logging messages at various levels (e.g., debug, info, warning, error). In
-    forever on ``join()``.
+    the provided code snippet, the logger is used to log messages at the "info" level
    :param stop_event: optional :class:`threading.Event` shared with the caller
    to coordinate a cooperative shutdown.
    """
    # logger.setLevel(logging.DEBUG)
    logger = logging.getLogger("discord")
    logger.info("Started comms")
    threads = []
    # threads.append(threading.Thread(target=flask_debug))
    threads.append(threading.Thread(target=waitress_run, daemon=True))
    threads.append(
-        threading.Thread(
+        threading.Thread(target=waitress_run, daemon=True)
            target=scan_queue, kwargs={"stop_event": stop_event}, daemon=True
        )
    )
    threads.append(
-        threading.Thread(
+        threading.Thread(target=scan_queue, kwargs={"stop_event": stop_event}, daemon=True)
-            target=scan_incoming, kwargs={"stop_event": stop_event}, daemon=True
+    )
-        )
+    threads.append(
        threading.Thread(target=scan_incoming, kwargs={"stop_event": stop_event}, daemon=True)
    )
    for worker in threads:
@@ -1,102 +0,0 @@
 # ai command cogs
 import logging
 import discord
 from discord.ext import commands
 from other_functions import discord_friendly_send, discord_friendly_reply
 from __future__ import annotations
 import asyncio
 import logging
 from conanjurer_functions import watch, Event
 log = logging.getLogger("discord")
 def is_gm():
    async def predicate(ctx: commands.Context) -> bool:
        role_id = ctx.bot.cfg.gm_role_id
        ok = any(r.id == role_id for r in getattr(ctx.author, "roles", []))
        if not ok:
            await ctx.reply("⛔ Tylko GM.", mention_author=False)
        return ok
    return commands.check(predicate)
 class FromConan(commands.Cog):
    def __init__(self, bot: commands.Bot):
        self.bot = bot
        self._task: asyncio.Task | None = None
    async def cog_load(self):
        self._task = asyncio.create_task(self._run())
    async def cog_unload(self):
        if self._task:
            self._task.cancel()
    async def _run(self):
        await self.bot.wait_until_ready()
        cfg = self.bot.cfg
        chat_ch = self.bot.get_channel(cfg.chan_chat)
        evt_ch = self.bot.get_channel(cfg.chan_events)
        async def on_event(e: Event):
            target = chat_ch if e.kind == "chat" else evt_ch
            if target is not None:
                # allowed_mentions: nie pinguj nikogo treścią z gry
                await target.send(e.text, allowed_mentions=discord.AllowedMentions.none())
        log.info("Start obserwacji logu (tryb=%s)", cfg.log_mode)
        await watch(cfg, on_event)
 class ToConan(commands.Cog):
    def __init__(self, bot: commands.Bot):
        self.bot = bot
    @commands.command(name="say")
    @is_gm()
    async def say(self, ctx: commands.Context, *, message: str):
        """Discord -> Conan: ogłoszenie widoczne dla wszystkich graczy w grze."""
        resp = await self.bot.rcon.command(f"broadcast {message}")
        await ctx.reply(f"✅ Wysłano do gry. (serwer: `{resp.strip() or 'OK'}`)",
                        mention_author=False)
    @commands.command(name="players")
    @is_gm()
    async def players(self, ctx: commands.Context):
        """Lista graczy online (RCON listplayers)."""
        resp = await self.bot.rcon.command("listplayers")
        await ctx.reply(f"```\n{resp.strip() or 'brak danych'}\n```",
                        mention_author=False)
    @commands.command(name="kick")
    @is_gm()
    async def kick(self, ctx: commands.Context, *, who: str):
        """Wyrzuć gracza (po nazwie/charname — zależnie od wersji serwera)."""
        resp = await self.bot.rcon.command(f"kick {who}")
        await ctx.reply(f"👢 `{resp.strip() or 'OK'}`", mention_author=False)
    @commands.command(name="rcon")
    @is_gm()
    async def raw_rcon(self, ctx: commands.Context, *, cmd: str):
        """Surowa komenda RCON (dla zaawansowanych GM). Używaj ostrożnie."""
        resp = await self.bot.rcon.command(cmd)
        await ctx.reply(f"```\n{resp.strip() or 'OK'}\n```", mention_author=False)
    # --- HOOK pod przyszły mod mostu (Chat V2 API) ---
    @commands.command(name="ogłoś", aliases=["oglos", "rp"])
    @is_gm()
    async def rp_announce(self, ctx: commands.Context, nadawca: str, *, message: str):
        """Wiadomość RP 'z nadawcą' (np. ogłoszenie w imieniu Króla Khasara).
        Na samym RCON realizujemy to jako sformatowany broadcast. Gdy dodasz
        własny mod na Chat V2 API z dedykowaną komendą czatu, podmień tę linię
        na wywołanie tej komendy (np. 'tot_rp_say <nadawca> <msg>').
        """
        resp = await self.bot.rcon.command(f"broadcast [{nadawca}]: {message}")
        await ctx.reply(f"📜 Ogłoszono jako **{nadawca}**.", mention_author=False)
 async def setup(bot: commands.Bot):
    await bot.add_cog(ToConan(bot))
    await bot.add_cog(FromConan(bot))
@@ -1,206 +0,0 @@
 from __future__ import annotations
 import os
 from dataclasses import dataclass
 from dotenv import load_dotenv
 import asyncio
 import logging
 import re
 from typing import AsyncIterator, Callable, Awaitable
 from aiomcrcon import Client as _Rcon  # Source RCON over TCP
 import asyncssh
 load_dotenv()
 log = logging.getLogger("discord")
@dataclass
 class Event:
    kind: str        # "chat" | "login" | "logout" | "death" | "raw"
    text: str        # gotowy do wyświetlenia tekst
    raw: str         # oryginalna linia (do debugowania)
 # --- REGEXY DO DOSTROJENIA NA WŁASNYM LOGU ---
 # Poniżej PRZYKŁADOWE wzorce. Conan/Pippi/Tot logują różnie — sprawdź swój log
 # i dopasuj. Jeśli wzorzec nie pasuje, linia trafia jako "raw" tylko do debug.
 _PATTERNS: list[tuple[str, re.Pattern]] = [
    ("chat",   re.compile(r"Chat:\s*(?P<who>.+?):\s*(?P<msg>.+)$", re.I)),
    ("login",  re.compile(r"(?P<who>.+?)\s+(joined|connected|logged in)", re.I)),
    ("logout", re.compile(r"(?P<who>.+?)\s+(left|disconnected|logged out)", re.I)),
    ("death",  re.compile(r"(?P<who>.+?)\s+was killed by\s+(?P<by>.+)$", re.I)),
 ]
@dataclass(frozen=True)
 class Config:
    # Discord
    guild_id: int
    chan_chat: int
    chan_events: int
    gm_role_id: int
    # RCON
    rcon_host: str
    rcon_port: int
    rcon_password: str
    # Log
    log_mode: str          # "local" | "sftp"
    log_path: str
    sftp_host: str | None
    sftp_port: int
    sftp_user: str | None
    sftp_password: str | None
    @staticmethod
    def load() -> "Config":
        mode = os.getenv("LOG_MODE", "local").lower()
        return Config(
            guild_id=int(_req("DISCORD_GUILD_ID")),
            chan_chat=int(_req("CHAN_CHAT")),
            chan_events=int(_req("CHAN_EVENTS")),
            gm_role_id=int(_req("GM_ROLE_ID")),
            rcon_host=_req("RCON_HOST"),
            rcon_port=int(os.getenv("RCON_PORT", "25575")),
            rcon_password=_req("RCON_PASSWORD"),
            log_mode=mode,
            log_path=_req("LOG_PATH"),
            sftp_host=os.getenv("SFTP_HOST"),
            sftp_port=int(os.getenv("SFTP_PORT", "22")),
            sftp_user=os.getenv("SFTP_USER"),
            sftp_password=os.getenv("SFTP_PASSWORD"),
        )
 class RconClient:
    def __init__(self, host: str, port: int, password: str):
        self._host, self._port, self._pw = host, port, password
        self._client: _Rcon | None = None
        self._lock = asyncio.Lock()
    async def _ensure(self) -> _Rcon:
        if self._client is None:
            c = _Rcon(self._host, self._port, self._pw)
            await c.connect()
            self._client = c
            log.info("RCON połączony %s:%s", self._host, self._port)
        return self._client
    async def command(self, cmd: str) -> str:
        """Wyślij komendę do serwera Conana. Zwraca odpowiedź serwera.
        To jest KANAŁ Discord -> Conan. Np. command("broadcast Witajcie!")
        wyświetli komunikat wszystkim graczom w grze.
        """
        async with self._lock:
            for attempt in (1, 2):
                try:
                    client = await self._ensure()
                    resp, _ = await client.send_cmd(cmd)
                    return resp
                except Exception as e:  # rozłączenie/restart serwera
                    log.warning("RCON błąd (próba %s): %s", attempt, e)
                    await self.close()
                    if attempt == 2:
                        raise
                    await asyncio.sleep(1.0)
            return ""
    async def close(self) -> None:
        if self._client is not None:
            try:
                await self._client.close()
            except Exception:
                pass
            self._client = None
 def parse_line(line: str) -> Event | None:
    line = line.rstrip("\n")
    if not line.strip():
        return None
    for kind, pat in _PATTERNS:
        m = pat.search(line)
        if m:
            g = m.groupdict()
            if kind == "chat":
                return Event(kind, f"💬 **{g['who']}**: {g['msg']}", line)
            if kind == "login":
                return Event(kind, f"🟢 **{g['who']}** dołączył do gry", line)
            if kind == "logout":
                return Event(kind, f"⚪ **{g['who']}** opuścił grę", line)
            if kind == "death":
                return Event(kind, f"💀 **{g['who']}** zginął z ręki {g['by']}", line)
    return None  # nierozpoznane -> ignoruj (nie zgadujemy)
 async def _follow_local(path: str) -> AsyncIterator[str]:
    """tail -f w czystym asyncio, podąża też po rotacji pliku."""
    import os
    while True:
        try:
            with open(path, "r", encoding="utf-8", errors="replace") as f:
                f.seek(0, os.SEEK_END)
                inode = os.fstat(f.fileno()).st_ino
                while True:
                    line = f.readline()
                    if line:
                        yield line
                        continue
                    await asyncio.sleep(0.5)
                    # wykryj rotację logu
                    try:
                        if os.stat(path).st_ino != inode:
                            break
                    except FileNotFoundError:
                        break
        except FileNotFoundError:
            log.warning("Log nie istnieje jeszcze: %s", path)
            await asyncio.sleep(3.0)
 async def _follow_sftp(cfg) -> AsyncIterator[str]:
    """Polling przyrostowy po SFTP (Host Havoc). Czyta tylko nowe bajty."""
    offset = 0
    while True:
        try:
            async with asyncssh.connect(
                cfg.sftp_host, port=cfg.sftp_port,
                username=cfg.sftp_user, password=cfg.sftp_password,
                known_hosts=None,
            ) as conn:
                async with conn.start_sftp_client() as sftp:
                    while True:
                        try:
                            attrs = await sftp.stat(cfg.log_path)
                            size = attrs.size or 0
                            if size < offset:      # rotacja
                                offset = 0
                            if size > offset:
                                async with sftp.open(cfg.log_path, "r") as rf:
                                    await rf.seek(offset)
                                    chunk = await rf.read()
                                    offset = size
                                    for ln in chunk.splitlines():
                                        yield ln
                        except FileNotFoundError:
                            log.warning("SFTP: brak logu %s", cfg.log_path)
                        await asyncio.sleep(2.0)
        except Exception as e:
            log.warning("SFTP rozłączony: %s — ponawiam", e)
            await asyncio.sleep(5.0)
 async def watch(cfg, on_event: Callable[[Event], Awaitable[None]]) -> None:
    source = _follow_local(cfg.log_path) if cfg.log_mode == "local" else _follow_sftp(cfg)
    async for line in source:
        evt = parse_line(line)
        if evt is not None:
            try:
                await on_event(evt)
            except Exception:
                log.exception("Błąd obsługi zdarzenia")
 def _req(key: str) -> str:
    val = os.getenv(key)
    if not val or val.startswith("wklej") or val.startswith("000000"):
        raise RuntimeError(f"Brak/placeholder w .env: {key}")
    return val
@@ -1,7 +0,0 @@
 # Runtime-generated radio data — keep out of the repo
 all_playlist.playlist
 hit.playlist
 request.playlist
 priority_queue.playlist
 prio_playlist.json
 *.mp3
@@ -1,32 +1,19 @@
-"""Centralised configuration and runtime constants for Conjurer.
+"""Centralised configuration and runtime constants for Conjurer services.
-Historically this module performed heavy filesystem and credential reads at
+This module used to perform heavy filesystem and credential reads at import
-import time which made the bot brittle on hosts that did not mirror the
+time which made the project brittle on hosts that did not mirror the original
-original paths.  This version keeps the original platform defaults (so the
+paths.  The current implementation defers that work, reads configuration from
-behaviour on the Raspberry Pi / WSL / Windows deployments is unchanged when no
+environment variables (with sensible fallbacks), and protects optional
-environment variables are set) but adds three robustness improvements ported
+dependencies so the main bot can start even when a secondary service is
-from the dockerised experiment:
+offline.
 * every path/endpoint can be overridden via an environment variable,
 * JSON state files are loaded defensively (a missing or corrupt file no longer
  crashes the whole bot at import time),
 * optional dependencies (openai, spotipy, netrc) and credentials are guarded so
  the bot can still start when a secondary integration is offline, and
 * a shared ``CONJURER_API_KEY`` plus ``service_headers()`` helper enables
  authenticated internal HTTP calls.
 All path constants intentionally remain plain ``str`` (with their original
 trailing separators) to stay byte-for-byte compatible with the existing string
 concatenation in the command modules.
 """
 import json
 import logging
 import os
 from datetime import datetime
-from platform import uname
+from pathlib import Path
-from sys import platform
+from typing import Dict, List, Optional, Tuple, TypedDict
 from typing import List, Optional, TypedDict
 try:
    import netrc
@@ -45,8 +32,6 @@ except ImportError:  # pragma: no cover - optional component
    spotipy = None
    SpotifyClientCredentials = None
 logger = logging.getLogger("discord")
 Music_Config = TypedDict(
    "Music_Config",
    {
@@ -62,18 +47,44 @@ MASTER_TIMEOUT = datetime.now()
 INITIAL_TIME_WAIT = 500
 MUZYKA: Music_Config = {"ctx": None, "queue": [], "requester": []}
-LOGFILE = ""
+logger = logging.getLogger("discord")
-NETRC_FILE = ""
+
-MUSIC_FOLDER = ""
+
-MEMORY_FIVE_SIARA = ""
+def _env_path(var_name: str, fallback: Path) -> Path:
-MEMORY_FIVE_MUZYKA = ""
+    value = os.getenv(var_name)
-SETTINGS_FILE = ""
+    if value:
-ENCODING = "utf-8"
+        return Path(value).expanduser().resolve()
-GRAPHICS_PATH = ""
+    return fallback
 def _env(var_name: str, fallback: str) -> str:
    return os.getenv(var_name, fallback)
 BASE_DIR = Path(os.getenv("CONJURER_BASE_DIR", Path(__file__).resolve().parent))
 LOGFILE = _env_path("CONJURER_LOG_FILE", BASE_DIR / "discord.log")
 NETRC_FILE = _env_path("CONJURER_NETRC_FILE", Path.home() / ".netrc")
 SETTINGS_FILE = _env_path("CONJURER_SETTINGS_FILE", BASE_DIR / "settings.json")
 MEMORY_FIVE_SIARA = _env_path("CONJURER_MEMORY_FILE", BASE_DIR / "pamiec.json")
 MEMORY_FIVE_MUZYKA = _env_path(
    "CONJURER_MUSIC_MEMORY_FILE", BASE_DIR / "pamiec_muzyki.json"
 )
 GRAPHICS_PATH = _env_path(
    "CONJURER_GRAPHICS_PATH", BASE_DIR / "Conjurer_graphics"
 )
 MUSIC_FOLDER = _env_path("CONJURER_MUSIC_FOLDER", BASE_DIR / "music")
 ENCODING = _env("CONJURER_ENCODING", "utf-8")
 API_SHARED_KEY = os.getenv("CONJURER_API_KEY", "")
 MUZYKA_MOJEGO_LUDU_HISTORIA = 1500
 MUZYKA_MOJEGO_LUDU_SLOWA_KLUCZOWE = 15
 MUZYKA_MOJEGO_LUDU_PLAJLISTA = 30
 FILE_SERVICE_ADDRESS = _env("CONJURER_FILE_SERVICE", "http://127.0.0.1:5000")
 RADIO_HARBOR_ADDRESS = _env("CONJURER_RADIO_HARBOR", "http://127.0.0.1:54321")
 SKIP_TRACK = _env("CONJURER_SKIP_ENDPOINT", "/skip")
 GET_MP3 = "/mp3"
 SEND_MP3 = "/update_mp3"
 GET_PLAYLIST = "/get_music"
@@ -82,120 +93,42 @@ CREATE_PRIO_PLAYLIST = "/create_priority_playlist"
 REQUEST_MUSIC = "/request_radio_file"
 CLEAR_PRIO = "/clear_pr_pls"
-SEND_QUERY = "/query"
+LIBRARIAN_SERVICE_ADDRESS = _env(
    "CONJURER_LIBRARIAN_SERVICE", "http://127.0.0.1:5001"
 )
 SEND_QUERY = _env("CONJURER_LIBRARIAN_QUERY_ENDPOINT", "/query")
 TIME_BETWEEN_CALLS = 100000
 LAST_SPONTANEOUS_CALL = datetime.now()
 HOST_ADDRESS = _env("CONJURER_DISCORD_HOST", "0.0.0.0")
 PORT_ADDRESS = int(_env("CONJURER_DISCORD_PORT", "5000"))
-# *=========================================== Platform Specific Defaults
+# *=========================================== Platform Specific Predefines
 # These blocks only establish *default* values.  Every constant is overridable
 # through the matching environment variable further below.
-if platform in ("linux", "linux2"):
+SEPARATOR_FILE_PATH = _env("CONJURER_PATH_SEPARATOR", os.sep)
    SEPARATOR_FILE_PATH = "/"
    if "microsoft-standard" in uname().release:
        LOGFILE = "/home/mtuszowski/conjurer/discord.log"
        MEMORY_FIVE_SIARA = "/home/mtuszowski/conjurer/pamiec.json"
        SYSTEM_GPT_SETTINGS = "/home/mtuszowski/conjurer/system_gpt_settings.json"
        MEMORY_FIVE_MUZYKA = "/home/mtuszowski/conjurer/pamiec_muzyki.json"
        MUSIC_FOLDER = "/mnt/g/Muzyka/"
        SETTINGS_FILE = "/home/mtuszowski/conjurer/settings.json"
        NETRC_FILE = "/home/mtuszowski/.netrc"
        LOGSTORE = "/home/mtuszowski/conjurer/logs/"
        ACCIDENT_LOG = "/home/mtuszowski/conjurer/accident_log.json"
        ENCODING = "utf-8"
        GRAPHICS_PATH = "/home/mtuszowski/conjurer/Conjurer_graphics/"
        DIR_PATH_SADOX = "/mnt/c/Users/mtusz/OneDrive/Dokumenty/Fansadox"
-    else:
+DIR_PATH_SADOX = _env_path(
-        LOGFILE = "/home/pi/Conjurer/discord.log"
+    "CONJURER_SADOX_DIR", BASE_DIR / "Fansadox"
        MEMORY_FIVE_SIARA = "/home/pi/Conjurer/pamiec.json"
        SYSTEM_GPT_SETTINGS = "/home/pi/Conjurer/system_gpt_settings.json"
        MEMORY_FIVE_MUZYKA = "/home/pi/Conjurer/pamiec_muzyki.json"
        MUSIC_FOLDER = "/home/pi/MediaShare/mp3/"
        SETTINGS_FILE = "/home/pi/Conjurer/settings.json"
        NETRC_FILE = "/home/pi/.netrc"
        LOGSTORE = "/home/pi/MediaShara/logs/"
        ACCIDENT_LOG = "/home/pi/Conjurer/accident_log.json"
        ENCODING = "utf-8"
        GRAPHICS_PATH = "/home/pi/MediaShare/Conjurer_graphics/"
        DIR_PATH_SADOX = "/home/pi/MediaShare/Fansadox/"
 elif platform == "win32":
    LOGFILE = "discord.log"
    MEMORY_FIVE_SIARA = "pamiec.json"
    SYSTEM_GPT_SETTINGS = "system_gpt_settings.json"
    MEMORY_FIVE_MUZYKA = "pamiec_muzyki.json"
    MUSIC_FOLDER = "G:\\Muzyka\\"
    SETTINGS_FILE = "settings.json"
    NETRC_FILE = "C:\\Users\\mtusz\\.netrc"
    LOGSTORE = "C:\\Users\\mtusz\\OneDrive\\Pulpit\\Conjurer\\logs\\"
    ACCIDENT_LOG = "accident_log.json"
    ENCODING = "utf-8"
    DIR_PATH_SADOX = "C:\\Users\\mtusz\\OneDrive\\Dokumenty\\Fansadox\\"
    SEPARATOR_FILE_PATH = "\\"
 else:
    # Fallback for development hosts (macOS, BSD, …) that match none of the
    # production platforms.  Everything is rooted next to this file so the
    # module can at least be imported and unit-tested off-deployment.
    _BASE_DIR = os.path.dirname(os.path.abspath(__file__))
    SEPARATOR_FILE_PATH = os.sep
    LOGFILE = os.path.join(_BASE_DIR, "discord.log")
    MEMORY_FIVE_SIARA = os.path.join(_BASE_DIR, "pamiec.json")
    SYSTEM_GPT_SETTINGS = os.path.join(_BASE_DIR, "system_gpt_settings.json")
    MEMORY_FIVE_MUZYKA = os.path.join(_BASE_DIR, "pamiec_muzyki.json")
    MUSIC_FOLDER = os.path.join(_BASE_DIR, "music") + os.sep
    SETTINGS_FILE = os.path.join(_BASE_DIR, "settings.json")
    NETRC_FILE = os.path.join(os.path.expanduser("~"), ".netrc")
    LOGSTORE = os.path.join(_BASE_DIR, "logs") + os.sep
    ACCIDENT_LOG = os.path.join(_BASE_DIR, "accident_log.json")
    GRAPHICS_PATH = os.path.join(_BASE_DIR, "Conjurer_graphics") + os.sep
    DIR_PATH_SADOX = os.path.join(_BASE_DIR, "Fansadox") + os.sep
 # *=========================================== Environment overrides
 # Values stay as plain strings so existing ``PATH + filename`` concatenation in
 # the command modules keeps working unchanged.
 LOGFILE = os.getenv("CONJURER_LOG_FILE", LOGFILE)
 NETRC_FILE = os.getenv("CONJURER_NETRC_FILE", NETRC_FILE)
 SETTINGS_FILE = os.getenv("CONJURER_SETTINGS_FILE", SETTINGS_FILE)
 MEMORY_FIVE_SIARA = os.getenv("CONJURER_MEMORY_FILE", MEMORY_FIVE_SIARA)
 MEMORY_FIVE_MUZYKA = os.getenv("CONJURER_MUSIC_MEMORY_FILE", MEMORY_FIVE_MUZYKA)
 SYSTEM_GPT_SETTINGS = os.getenv("CONJURER_SYSTEM_GPT_SETTINGS", SYSTEM_GPT_SETTINGS)
 GRAPHICS_PATH = os.getenv("CONJURER_GRAPHICS_PATH", GRAPHICS_PATH)
 MUSIC_FOLDER = os.getenv("CONJURER_MUSIC_FOLDER", MUSIC_FOLDER)
 LOGSTORE = os.getenv("CONJURER_LOGSTORE", LOGSTORE)
 ACCIDENT_LOG = os.getenv("CONJURER_ACCIDENT_LOG", ACCIDENT_LOG)
 DIR_PATH_SADOX = os.getenv("CONJURER_SADOX_DIR", DIR_PATH_SADOX)
 ENCODING = os.getenv("CONJURER_ENCODING", ENCODING)
 SEPARATOR_FILE_PATH = os.getenv("CONJURER_PATH_SEPARATOR", SEPARATOR_FILE_PATH)
 FILE_SERVICE_ADDRESS = os.getenv("CONJURER_FILE_SERVICE", "http://192.168.1.15:5000")
 RADIO_HARBOR_ADDRESS = os.getenv("CONJURER_RADIO_HARBOR", "http://192.168.1.15:54321")
 SKIP_TRACK = os.getenv("CONJURER_SKIP_ENDPOINT", "/skip")
 LIBRARIAN_SERVICE_ADDRESS = os.getenv(
    "CONJURER_LIBRARIAN_SERVICE", "http://192.168.1.192:5001"
 )
 HOST_ADDRESS = os.getenv("CONJURER_DISCORD_HOST", "192.168.1.191")
 PORT_ADDRESS = int(os.getenv("CONJURER_DISCORD_PORT", "5000"))
-# Shared secret for authenticating internal service-to-service HTTP calls.
+SYSTEM_GPT_SETTINGS = _env_path(
-API_SHARED_KEY = os.getenv("CONJURER_API_KEY", "")
+    "CONJURER_SYSTEM_GPT_SETTINGS", BASE_DIR / "system_gpt_settings.json"
 )
 LOGSTORE = _env_path("CONJURER_LOGSTORE", BASE_DIR / "logs")
 ACCIDENT_LOG = _env_path(
    "CONJURER_ACCIDENT_LOG", BASE_DIR / "accident_log.json"
 )
-# *=========================================== Defensive state loading
+def _load_json(path: Path, fallback) -> object:
 def _load_json(path: str, fallback):
    """Load JSON from *path*, falling back gracefully on missing/corrupt files."""
    try:
-        with open(path, "r", encoding=ENCODING) as handle:
+        with path.open("r", encoding=ENCODING) as handle:
            return json.load(handle)
    except FileNotFoundError:
-        logger.warning("Missing JSON file at %s - using fallback", path)
+        logger.warning("Missing JSON file at %s – using fallback", path)
        return fallback
    except json.JSONDecodeError:
-        logger.warning("Corrupt JSON at %s - resetting to fallback", path)
+        logger.warning("Corrupt JSON at %s – resetting to fallback", path)
        return fallback
@@ -206,21 +139,19 @@ for key in WORD_REACTIONS:
    if isinstance(WORD_REACTIONS[key], list) and len(WORD_REACTIONS[key]) >= 3:
        WORD_REACTIONS[key][2] = datetime.now()
-MESSAGE_TABLE = _load_json(MEMORY_FIVE_SIARA, [])
+MESSAGE_TABLE = _load_json(MEMORY_FIVE_SIARA, {})
 GPT_SETTINGS = _load_json(SYSTEM_GPT_SETTINGS, {})
-MESSAGE_TABLE_MUZYKA = _load_json(MEMORY_FIVE_MUZYKA, [])
+MESSAGE_TABLE_MUZYKA = _load_json(MEMORY_FIVE_MUZYKA, {})
 SPECJALNE_ZIEMNIACZKI = GPT_SETTINGS[1] if isinstance(GPT_SETTINGS, list) else {}
-ASSISTANTS = {}
+ASSISTANTS: Dict[str, Tuple[str, str, int, object]] = {}
-# *=========================================== Credentials
+def _load_netrc_credentials(host: str) -> Optional[Tuple[str, str, str]]:
 def _load_netrc_credentials(host: str):
    """Return the netrc authenticators tuple for *host* or ``None``."""
    if netrc is None:
        return None
    try:
-        parsed = netrc.netrc(NETRC_FILE)
+        parsed = netrc.netrc(str(NETRC_FILE))
    except FileNotFoundError:
        logger.warning("netrc file %s not found", NETRC_FILE)
        return None
@@ -231,7 +162,6 @@ def _load_netrc_credentials(host: str):
 def _resolve_token(host: str, env_var: str) -> Optional[str]:
    """Prefer an environment variable, then fall back to netrc."""
    env_value = os.getenv(env_var)
    if env_value:
        return env_value
@@ -252,12 +182,12 @@ else:
 TOKEN = _resolve_token("discord", "DISCORD_TOKEN")
 if spotipy:
-    _spotify_creds = _load_netrc_credentials("spotipy")
+    spotify_creds = _load_netrc_credentials("spotipy")
-    if _spotify_creds and SpotifyClientCredentials:
+    if spotify_creds and SpotifyClientCredentials:
        SPOTIFY_CTRL = spotipy.Spotify(
            client_credentials_manager=SpotifyClientCredentials(
-                client_id=_spotify_creds[0],
+                client_id=spotify_creds[0],
-                client_secret=_spotify_creds[2],
+                client_secret=spotify_creds[2],
            )
        )
    else:
@@ -265,22 +195,18 @@ if spotipy:
 else:
    SPOTIFY_CTRL = None
-_youtube_creds = _load_netrc_credentials("youtube")
+youtube_creds = _load_netrc_credentials("youtube")
-if _youtube_creds:
+if youtube_creds:
-    YOUTUBE_AUTH = [_youtube_creds[0], _youtube_creds[2]]
+    YOUTUBE_AUTH = [youtube_creds[0], youtube_creds[2]]
 else:
    YOUTUBE_AUTH = [
-        os.getenv("YOUTUBE_USERNAME", ""),
+            os.getenv("YOUTUBE_USERNAME", ""),
-        os.getenv("YOUTUBE_PASSWORD", ""),
+            os.getenv("YOUTUBE_PASSWORD", ""),
-    ]
+        ]
-def service_headers():
+def service_headers() -> Dict[str, str]:
-    """Shared header dict for internal service-to-service HTTP calls.
+    """Shared header dict for internal HTTP calls."""
    Returns an empty dict when no key is configured, keeping calls backward
    compatible with deployments that do not (yet) enforce authentication.
    """
    if API_SHARED_KEY:
        return {"X-Conjurer-Api-Key": API_SHARED_KEY}
    return {}
@@ -1,6 +1,6 @@
 #!/bin/bash
-total_commands=31
+total_commands=29
 current_command=0
 function print_progress {
@@ -95,14 +95,8 @@ print_progress "cp ./conjurer/latex_functions.py ./Conjurer/"
 cp ./conjurer/librarian_functions.py ./Conjurer
 print_progress "cp ./conjurer/librarian_functions.py ./Conjurer/"
-cp ./conjurer/conanjurer_commands.py ./Conjurer/
+cp ./conjurer/thin_client.py ./Conjurer/bot.py
-print_progress "cp ./conjurer/conanjurer_commands.py ./Conjurer/"
+print_progress "cp ./conjurer/thin_client.py ./Conjurer/bot.py"
 cp ./conjurer/conanjurer_functions.py ./Conjurer/
 print_progress "cp ./conjurer/conanjurer_functions.py ./Conjurer/"
 cp ./conjurer/bot.py ./Conjurer/bot.py
 print_progress "cp ./conjurer/bot.py ./Conjurer/bot.py"
 sudo systemctl restart conjurer.service
 print_progress "sudo systemctl restart conjurer.service"
@@ -0,0 +1,45 @@
 version: "3.9"
 services:
  bot:
    build:
      context: .
      dockerfile: docker/Dockerfile.bot
    container_name: conjurer-bot
    env_file:
      - docker/env/bot.env
    volumes:
      - ./docker/volumes/bot/config:/data/config
      - ./docker/volumes/bot/logs:/data/logs
    depends_on:
      - musician
      - librarian
    restart: unless-stopped
    ports:
      - "5000:5000"
  musician:
    build:
      context: .
      dockerfile: docker/Dockerfile.musician
    container_name: conjurer-musician
    env_file:
      - docker/env/musician.env
    volumes:
      - ./docker/volumes/musician/data:/data
    restart: unless-stopped
    ports:
      - "5001:5000"
  librarian:
    build:
      context: .
      dockerfile: docker/Dockerfile.librarian
    container_name: conjurer-librarian
    env_file:
      - docker/env/librarian.env
    volumes:
      - ./docker/volumes/librarian/data:/data
    restart: unless-stopped
    ports:
      - "5002:5001"
@@ -0,0 +1,23 @@
 FROM python:3.11-slim
 ENV PYTHONUNBUFFERED=1 \
    PIP_NO_CACHE_DIR=1
 RUN apt-get update \
    && apt-get install -y --no-install-recommends \
        ffmpeg \
    && rm -rf /var/lib/apt/lists/*
 WORKDIR /app
 COPY requirements_bot.txt /tmp/requirements.txt
 RUN pip install -r /tmp/requirements.txt
 COPY . /app
 RUN useradd --create-home appuser \
    && chown -R appuser:appuser /app
 USER appuser
 CMD ["python", "thin_client.py"]
@@ -0,0 +1,24 @@
 FROM python:3.11-slim
 ENV PYTHONUNBUFFERED=1 \
    PIP_NO_CACHE_DIR=1
 RUN apt-get update \
    && apt-get install -y --no-install-recommends \
        build-essential \
        poppler-utils \
    && rm -rf /var/lib/apt/lists/*
 WORKDIR /app
 COPY conjurer_librarian/requirements_librarian.txt /tmp/requirements.txt
 RUN pip install -r /tmp/requirements.txt
 COPY . /app
 RUN useradd --create-home appuser \
    && chown -R appuser:appuser /app
 USER appuser
 CMD ["python", "-m", "conjurer_librarian.conjurer_librarian"]
@@ -0,0 +1,23 @@
 FROM python:3.11-slim
 ENV PYTHONUNBUFFERED=1 \
    PIP_NO_CACHE_DIR=1
 RUN apt-get update \
    && apt-get install -y --no-install-recommends \
        ffmpeg \
    && rm -rf /var/lib/apt/lists/*
 WORKDIR /app
 COPY requirements_bot.txt /tmp/requirements.txt
 RUN pip install -r /tmp/requirements.txt
 COPY . /app
 RUN useradd --create-home appuser \
    && chown -R appuser:appuser /app
 USER appuser
 CMD ["python", "-m", "conjurer_musician.conjurer_musician"]
@@ -0,0 +1,24 @@
 # Discord bot service configuration
 DISCORD_TOKEN=HACKME!
 OPENAI_API_KEY=HACKME!
 CONJURER_API_KEY=HACKME!
 # Internal service endpoints
 CONJURER_FILE_SERVICE=http://conjurer-musician:5000
 CONJURER_LIBRARIAN_SERVICE=http://conjurer-librarian:5001
 # Runtime paths mounted via docker-compose volumes
 CONJURER_BASE_DIR=/data/config
 CONJURER_SETTINGS_FILE=/data/config/settings.json
 CONJURER_MEMORY_FILE=/data/config/pamiec.json
 CONJURER_MUSIC_MEMORY_FILE=/data/config/pamiec_muzyki.json
 CONJURER_SYSTEM_GPT_SETTINGS=/data/config/system_gpt_settings.json
 CONJURER_GRAPHICS_PATH=/data/assets/graphics
 CONJURER_LOG_FILE=/data/logs/discord.log
 CONJURER_LOGSTORE=/data/logs
 # Optional external integrations
 CONJURER_NETRC_FILE=/data/secrets/.netrc
 YOUTUBE_USERNAME=HACKME!
 YOUTUBE_PASSWORD=HACKME!
@@ -0,0 +1,14 @@
 # Librarian service configuration
 CONJURER_API_KEY=HACKME!
 CONJURER_MAIN_BOT=http://conjurer-bot:5000
 CONJURER_LIBRARIAN_HOST=0.0.0.0
 CONJURER_LIBRARIAN_PORT=5001
 CONJURER_LIBRARIAN_MAX_RESULTS=500
 CONJURER_CROSSREF_MAILTO=HACKME!
 CONJURER_LIBRARIAN_LOG=/data/logs/librarian.log
 CONJURER_NETRC_FILE=/data/secrets/.netrc
@@ -0,0 +1,20 @@
 # Musician service configuration
 CONJURER_API_KEY=HACKME!
 CONJURER_MAIN_BOT=http://conjurer-bot:5000
 CONJURER_MUSIC_TRACKER_ENDPOINT=/prepped_tracks
 CONJURER_MUSICIAN_HOST=0.0.0.0
 CONJURER_MUSICIAN_PORT=5000
 CONJURER_MUSIC_FOLDER=/data/music
 CONJURER_PRIORITY_FOLDER=/data/priority
 CONJURER_ALL_PLAYLIST=/data/playlists/all_playlist.playlist
 CONJURER_HIT_PLAYLIST=/data/playlists/hit.playlist
 CONJURER_REQUEST_PLAYLIST=/data/playlists/request.playlist
 CONJURER_PRIORITY_PLAYLIST=/data/playlists/priority_queue.playlist
 CONJURER_STREAM_TEMPLATE=/data/templates/stream.html
 CONJURER_RADIO_LOG=/data/logs/radio.log
 CONJURER_PERSISTENCE_LOG=/data/logs/persistence.log
@@ -0,0 +1,14 @@
 from flask import Flask
 from file_serv import bp as uploader_bp
 from ingest import bp as ingest_bp
 from waitress import serve
 app = Flask(__name__)
 HOST_ADDRESS = "127.0.0.1"
 PORT_ADDRESS = 49151
 if __name__ == "__main__":
    app.register_blueprint(uploader_bp, url_prefix="/api")
    app.register_blueprint(ingest_bp, url_prefix="/api")
    serve(app, host=HOST_ADDRESS, port=PORT_ADDRESS)
@@ -0,0 +1,155 @@
 # -*- coding: utf-8 -*-
 from __future__ import annotations
 import os
 from pathlib import Path
 from typing import List, Dict, Any, Optional
 from flask import Blueprint, request, jsonify, send_file, abort, current_app
 from werkzeug.utils import secure_filename
 # ===== Konfiguracja przez ENV =====
 if API_KEY := os.getenv("API_KEY") is None:
    with open("/home/pi/gpt_cont_api_key", "r") as f:
        API_KEY = f.read().strip()
 else:
    API_KEY = os.getenv("API_KEY", "")                     # np. openssl rand -hex 32
 UPLOAD_DIR = Path(os.getenv("UPLOAD_DIR", "/home/pi/tmp_git/"))  # katalog na dysku
 MAX_CONTENT_MB = int(os.getenv("MAX_CONTENT_MB", "200"))
 # Google Drive (opcjonalnie)
 GDRIVE_ENABLE = os.getenv("GDRIVE_ENABLE", "0") == "1"
 GDRIVE_SA_JSON = os.getenv("GDRIVE_SA_JSON", "")       # ścieżka do pliku .json konta serwisowego
 GDRIVE_FOLDER_ID = os.getenv("GDRIVE_FOLDER_ID", "")   # ID folderu na Drive
 bp = Blueprint("uploader", __name__)
 # Inicjalizacja katalogu
 UPLOAD_DIR.mkdir(parents=True, exist_ok=True)
 def _check_auth() -> bool:
    """Proste Bearer auth. Jeśli API_KEY puste -> bez auth (niezalecane)."""
    if not API_KEY:
        return True
    auth = request.headers.get("Authorization", "")
    if auth.startswith("Bearer "):
        token = auth[7:].strip()
        return token == API_KEY
    return False
 def _safe_join(base: Path, *parts: str) -> Path:
    """Zapobiega ../ — wymusza pozostanie w katalogu bazowym."""
    p = (base.joinpath(*parts)).resolve()
    if not str(p).startswith(str(base.resolve())):
        abort(400, description="Invalid path")
    return p
 # ===== Google Drive helper =====
 _drive_client_cached = None
 def _get_drive():
    global _drive_client_cached
    if _drive_client_cached is not None:
        return _drive_client_cached
    if not (GDRIVE_ENABLE and GDRIVE_SA_JSON and os.path.exists(GDRIVE_SA_JSON)):
        return None
    from google.oauth2 import service_account
    from googleapiclient.discovery import build
    scopes = ["https://www.googleapis.com/auth/drive.file"]
    creds = service_account.Credentials.from_service_account_file(GDRIVE_SA_JSON, scopes=scopes)
    _drive_client_cached = build("drive", "v3", credentials=creds, cache_discovery=False)
    return _drive_client_cached
 def upload_to_drive(local_path: Path, filename: str) -> Optional[Dict[str, Any]]:
    drv = _get_drive()
    if drv is None:
        return None
    from googleapiclient.http import MediaFileUpload
    file_metadata = {"name": filename}
    if GDRIVE_FOLDER_ID:
        file_metadata["parents"] = [GDRIVE_FOLDER_ID]
    media = MediaFileUpload(str(local_path), resumable=False)
    created = drv.files().create(body=file_metadata, media_body=media, fields="id,webViewLink,webContentLink").execute()
    file_id = created.get("id")
    # Przydatne linki:
    return {
        "file_id": file_id,
        "webViewLink": created.get("webViewLink"),
        "webContentLink": created.get("webContentLink"),
        "direct_view": f"https://drive.google.com/file/d/{file_id}/view",
        "direct_download": f"https://drive.google.com/uc?export=download&id={file_id}",
    }
@bp.get("/health")
 def health():
    return jsonify(ok=True, info="Okidokie")
@bp.post("/upload")
 def upload():
    """Przyjmuje:
       - multipart/form-data z jednym plikiem ('file') lub wieloma ('files')
       - opcjonalnie: form 'subdir' (podkatalog), 'drive' (1/0) żeby wymusić wysyłkę na Drive
    """
    if not _check_auth():
        return jsonify(error="Unauthorized"), 401
    # Limit ciała żądania po stronie Flaska:
    request.max_content_length = MAX_CONTENT_MB * 1024 * 1024
    files = []
    if "file" in request.files:
        files = [request.files["file"]]
    elif "files" in request.files:
        files = request.files.getlist("files")
    else:
        return jsonify(error="No file provided (use 'file' or 'files')"), 400
    subdir = (request.form.get("subdir") or "").strip()
    target_dir = _safe_join(UPLOAD_DIR, subdir) if subdir else UPLOAD_DIR
    target_dir.mkdir(parents=True, exist_ok=True)
    want_drive = (request.form.get("drive") == "1") or (request.args.get("drive") == "1")
    saved: List[Dict[str, Any]] = []
    for f in files:
        if not f or not f.filename:
            continue
        fname = secure_filename(f.filename)
        dest = _safe_join(target_dir, fname)
        f.save(dest)
        item = {
            "filename": fname,
            "size": dest.stat().st_size,
            "path": str(dest.relative_to(UPLOAD_DIR)),
            "url_hint": f"/api/files/{dest.relative_to(UPLOAD_DIR)}",
        }
        if want_drive and GDRIVE_ENABLE:
            try:
                gd = upload_to_drive(dest, fname)
                if gd:
                    item["gdrive"] = gd
            except Exception as e:
                # log i idziemy dalej
                current_app.logger.exception("Drive upload failed: %s", e)
                item["gdrive_error"] = str(e)
        saved.append(item)
    if not saved:
        return jsonify(error="No valid files"), 400
    return jsonify(ok=True, saved=saved)
@bp.get("/files/<path:relpath>")
 def get_file(relpath: str):
    if not _check_auth():
        return jsonify(error="Unauthorized"), 401
    target = _safe_join(UPLOAD_DIR, relpath)
    if not target.exists() or not target.is_file():
        return jsonify(error="Not found"), 404
    return send_file(target, as_attachment=False)
@@ -0,0 +1,52 @@
 # ingest_text.py
 import os
 import urllib.parse
 from pathlib import Path
 from flask import Blueprint, abort, jsonify, request
 bp = Blueprint("ingest_text", __name__)
 BASE = Path(os.getenv("INGEST_DIR", "/home/pi/tmp_git")).resolve()
 BASE.mkdir(parents=True, exist_ok=True)
 TOKEN = None
 with open("/home/pi/gpt_cont_api_key", "r") as f:
        TOKEN = f.read().strip()
 # prosty bufor kawałków w RAM (na 1 proces)
 chunks = {}
@bp.get("/api/ingest-text")
 def ingest_text():
    if request.args.get("key") != TOKEN:
        return jsonify(error="unauthorized"), 401
    name = request.args.get("name", "").strip()
    index = int(request.args.get("index", "1"))
    total = int(request.args.get("total", "1"))
    chunk = request.args.get("chunk", "")
    if not name or "/" in name or ".." in name:
        return jsonify(error="bad name"), 400
    if not (1 <= index <= total <= 9999):
        return jsonify(error="bad indexing"), 400
    # gromadzimy w pamięci (możesz podmienić na Redis)
    key = f"{name}:{total}"
    entry = chunks.setdefault(key, {})
    entry[index] = urllib.parse.unquote_plus(chunk)
    if TOKEN is None:
         exit("No API token set!")
    if len(entry) == total:
        # składamy i zapisujemy
        data = "".join(entry[i] for i in range(1, total + 1))
        out = (BASE / name).resolve()
        if not str(out).startswith(str(BASE)):
            return jsonify(error="bad path"), 400
        out.write_text(data, encoding="utf-8")
        del chunks[key]
        return jsonify(ok=True, saved=str(out), bytes=len(data.encode("utf-8")))
    else:
        return jsonify(pending=True, got=len(entry), total=total)
@@ -0,0 +1,2 @@
 #!/bin/bash
 cd ../conjurer/ && git pull && cp ./gpt_interface/* ../gpt_interf_serv/ && cd -
@@ -15,7 +15,12 @@ from discord.ext import commands, tasks
 from ai_functions import handle_response
 from communication_subroutine import IN_COMM_Q, OUT_COMM_Q, QueryControl
-from constants import DIR_PATH_SADOX, LIBRARIAN_SERVICE_ADDRESS, SEND_QUERY, service_headers
+from constants import (
    DIR_PATH_SADOX,
    LIBRARIAN_SERVICE_ADDRESS,
    SEND_QUERY,
    service_headers,
 )
 SERVICE_HEADERS = service_headers()
@@ -22,7 +22,9 @@ from constants import (
 from spotify_dl import spotify
 from spotify_dl import youtube as youtube_download
 SERVICE_HEADERS = service_headers()
 MUSIC_ROOT = Path(MUSIC_FOLDER)
@@ -49,12 +51,12 @@ class MusicFileList(object):
            response = requests.get(
                f"{FILE_SERVICE_ADDRESS}{GET_MP3}",
                headers=SERVICE_HEADERS,
-                timeout=360,
+                timeout=60,
            )
            self.music_file_list = response.json()["music_file_list"]
            self.file_service_active = True
        except requests.exceptions.RequestException as e:
-            for mp3_item in Path.glob(Path(MUSIC_FOLDER), "**/*.mp3"):
+            for mp3_item in MUSIC_ROOT.glob("**/*.mp3"):
                temp_music_file = mp3_item.as_posix()
                if platform == "win32":
                    temp_music_file = temp_music_file.replace("/", "\\")
@@ -109,7 +111,7 @@ class MusicFileList(object):
            f"{FILE_SERVICE_ADDRESS}{SEND_MP3}",
            json=post_data,
            headers=SERVICE_HEADERS,
-            timeout=360,
+            timeout=60,
        )
@@ -154,7 +156,7 @@ async def get_file(ctx, source, link):
            url_data = {"urls": []}
            url_dict = {}
            url_dict["save_path"] = Path(
-                PurePath.joinpath(Path(MUSIC_FOLDER), Path(directory_name))
+                PurePath.joinpath(MUSIC_ROOT, Path(directory_name))
            )
            url_dict["save_path"].mkdir(parents=True, exist_ok=True)
            url_dict["songs"] = file_list
@@ -164,7 +166,7 @@ async def get_file(ctx, source, link):
            coro = asyncio.to_thread(
                youtube_download.download_songs,
                songs=url_data,
-                output_dir=MUSIC_FOLDER,
+                output_dir=str(MUSIC_ROOT),
                format_str="bestaudio/best",
                skip_mp3=False,
                keep_playlist_order=False,
@@ -234,21 +234,5 @@
    {
        "role": "assistant",
        "content": "Jakich konkretnych informacji mam si\u0119 douczy\u0107? Jestem tu po to, aby Ci pom\u00f3c, wi\u0119c jestem otwarty na uzupe\u0142nienie swojej wiedzy w dowolnym zakresie, o ile tylko nie \u0142amie to zasad regulaminu i etyki."
    },
    {
        "role": "user",
        "content": "The Bartender [S\u0142o\u0144ce z Betonu]:@Conjurer halo ?"
    },
    {
        "role": "assistant",
        "content": "*Kondziu patrzy na terminal* Wo\u0142aj szefa. Zap\u0142aci\u0107 rachunki za AI trzeba. Jak chcesz to si\u0119 na #zebranie dorzu\u0107. Error code: 429 - {'error': {'message': 'You exceeded your current quota, please check your plan and billing details. For more information on this error, read the docs: https://platform.openai.com/docs/guides/error-codes/api-errors.', 'type': 'insufficient_quota', 'param': None, 'code': 'insufficient_quota'}}"
    },
    {
        "role": "user",
        "content": "The Bartender [S\u0142o\u0144ce z Betonu]:helo\u0142 @Nocna Zmiana dwie wiadomo\u015bci dobra i jeszcze gorsza.\n@Conjurer zosta\u0142 zreanimowany po d\u0142u\u017cszej nieobecno\u015bci - ale jak zaraz sami zobaczycie je\u015b\u0107 wo\u0142a. nie dzia\u0142a w nim te\u017c jeszcze wyszukiwanie artyku\u0142\u00f3w naukowych (do tego trzy tygodnie developmentu posz\u0142y w p*****ec). wyszukiwarka wr\u00f3ci jak dotrze zam\u00f3wienie z kieszeniami na dysk @gwojtal - bedzie trzeba \u015bci\u0105gn\u0105\u0107 snapshot bazy i uruchomi\u0107 cz\u0119\u015b\u0107 odpowiedzialn\u0105 za wyszukiwanie w nim. specjalne funkcje b\u0119d\u0119 odblokowywa\u0142 w miare ich naprawiania - tak samo dam mu oczywi\u015bcie je\u015b\u0107 z w\u0142asnej kieszeni jak ju\u017c b\u0119dzie potrzeba."
    },
    {
        "role": "assistant",
        "content": "*Kondziu patrzy na terminal* Wo\u0142aj szefa. Zap\u0142aci\u0107 rachunki za AI trzeba. Jak chcesz to si\u0119 na #zebranie dorzu\u0107. Error code: 429 - {'error': {'message': 'You exceeded your current quota, please check your plan and billing details. For more information on this error, read the docs: https://platform.openai.com/docs/guides/error-codes/api-errors.', 'type': 'insufficient_quota', 'param': None, 'code': 'insufficient_quota'}}"
    }
 ]
@@ -787,4 +787,4 @@
        "role": "assistant",
        "content": "\"Coffin Fodder\" to utw\u00f3r z albumu \"Nymphetamine\" brytyjskiego zespo\u0142u Cradle Of Filth. To  death-metalowe brzmienie z elementami black metalu i gotyckiego rocka. \n\nTekst utworu to prowokacyjne po\u0142\u0105czenie j\u0119zyka poetyckiego z drastycznymi opisami \u015bmierci i ciemn\u0105 estetyk\u0105, charakterystyczn\u0105 dla tw\u00f3rczo\u015bci Cradle Of Filth. \n\n\"Coffin Fodder\" opowiada histori\u0119 mordercy zabijaj\u0105cego kobiety i wk\u0142adaj\u0105cego ich cia\u0142a do trumien, aby zaspokoi\u0107 swoje mroczne i okrutne pragnienia. To utw\u00f3r pe\u0142en brutalnych opis\u00f3w, kt\u00f3rych celem jest szokowanie i wywo\u0142anie wstr\u0119tu w s\u0142uchaczu. \n\nPod wzgl\u0119dem muzycznym, \"Coffin Fodder\" charakteryzuje si\u0119 szybkim tempem, ci\u0119\u017ckimi riffami gitary i intensywnymi partiami perkusyjnymi. Utw\u00f3r jest jednym z bardziej ekstremalnych utwor\u00f3w zespo\u0142u Cradle Of Filth, co czyni go atrakcyjnym dla mi\u0142o\u015bnik\u00f3w mocnej i agresywnej muzyki metalowej."
    }
-]
+]
@@ -8,7 +8,16 @@ import uuid
 import asyncio
 from datetime import datetime
-from constants import RADIO_HARBOR_ADDRESS, SKIP_TRACK, FILE_SERVICE_ADDRESS, ADD_TO_PRIO_PLAYLIST, REQUEST_MUSIC, CREATE_PRIO_PLAYLIST, CLEAR_PRIO, service_headers
+from constants import (
    RADIO_HARBOR_ADDRESS,
    SKIP_TRACK,
    FILE_SERVICE_ADDRESS,
    ADD_TO_PRIO_PLAYLIST,
    REQUEST_MUSIC,
    CREATE_PRIO_PLAYLIST,
    CLEAR_PRIO,
    service_headers,
 )
 SERVICE_HEADERS = service_headers()
@@ -36,7 +45,6 @@ class RadioModule(commands.Cog):
                coroutine = asyncio.to_thread(
                    requests.get,
                    f"{RADIO_HARBOR_ADDRESS}{SKIP_TRACK}",
                    headers=SERVICE_HEADERS,
                    timeout=360,
                )
                result = await coroutine
@@ -0,0 +1,21 @@
 setuptools
 discord
 yaach
 t_dlp
 spotify_dl
 spotipy
 openai
 eyed3
 numpy
 pdf2image
 PyPDF2
 requests
 spotipy
 tiktoken
 PyNaCl
 flask[async]
 waitress
 clickupython
 assemblyai[extras]
 SpeechRecognition
 git+https://github.com/imayhaveborkedit/discord-ext-voice-recvO
@@ -15,6 +15,7 @@ PyNaCl
 flask[async]
 PyMuPDF
 waitress
 clickupython
 assemblyai[extras]
 SpeechRecognition
 git+https://github.com/imayhaveborkedit/discord-ext-voice-recv
@@ -0,0 +1,3 @@
 name,type,locations,ap_head,ap_body,ap_larm,ap_rarm,ap_lleg,ap_rleg,max_ag,traits,weight,availability,source,notes
 Flak Vest,armor,"Body",0,4,0,0,0,0,,Flak,7,Common,"DH2 CRB","PRZYKŁAD – ZASTĄP"
 Power Armour (Astartes),armor,"All",8,10,8,8,9,9,,Environmental; Auto-senses,100,"Very Rare","DW CRB","PRZYKŁAD – ZASTĄP"
@@ -0,0 +1,60 @@
 // DH2 Attack Test v2 — presets: Aim/Range/Fire + Size/Light/Cover
 const actor = canvas.tokens.controlled[0]?.actor ?? game.user.character;
 if (!actor) return ui.notifications.warn("Zaznacz token albo przypisz postać.");
 new Dialog({
  title: "🎯 Attack Test (WS/BS)",
  content: `
  <form>
    <div class="form-group"><label>Base Target (WS/BS)</label><input name="base" type="number" value="40"/></div>
    <div class="form-group"><label>Aim</label>
      <select name="aim"><option value="0">None</option><option value="10">Half (+10)</option><option value="20">Full (+20)</option></select></div>
    <div class="form-group"><label>Range</label>
      <select name="range">
        <option value="0">Standard</option>
        <option value="30">Point Blank (+30)</option>
        <option value="10">Short (+10)</option>
        <option value="-10">Long (-10)</option>
        <option value="-30">Extreme (-30)</option>
      </select></div>
    <div class="form-group"><label>Fire / Attack</label>
      <select name="stance">
        <option value="0">Standard / Single</option>
        <option value="10">Semi (+10)</option>
        <option value="-10">Full Auto (-10)</option>
        <option value="30">All Out (Melee +30)</option>
      </select></div>
    <div class="form-group"><label>Target Size</label>
      <select name="size">
        <option value="0">Average</option>
        <option value="10">Hulking (+10)</option>
        <option value="20">Enormous (+20)</option>
        <option value="30">Massive (+30)</option>
        <option value="-10">Puny (-10)</option>
      </select></div>
    <div class="form-group"><label>Lighting</label>
      <select name="light"><option value="0">Normal</option><option value="10">Good (+10)</option><option value="-10">Poor (-10)</option></select></div>
    <div class="form-group"><label>Cover</label>
      <select name="cover"><option value="0">None</option><option value="-10">Light (-10)</option><option value="-20">Heavy (-20)</option></select></div>
    <div class="form-group"><label>Other Modifiers</label><input name="mod" type="number" value="0"/></div>
  </form>`,
  buttons: {
    roll: {
      label: "Roll",
      callback: async (html) => {
        const get = n => Number(html.find(`[name="${n}"]`).val());
        const base = get("base");
        const total = base + get("aim") + get("range") + get("stance") + get("size") + get("light") + get("cover") + get("mod");
        const r = await(new Roll("1d100")).roll({async:true});
        const ok = r.total <= total;
        const margin = Math.abs(total - r.total);
        const dox = ok ? 1 + Math.floor(margin/10) : Math.floor(margin/10);
        const table = `
        <table style="width:100%;border-collapse:collapse">
          <tr><td><b>Target</b></td><td>${total}</td><td><b>Roll</b></td><td>${r.total}</td></tr>
          <tr><td><b>Result</b></td><td colspan="3">${ok?'<span style="color:green">SUCCESS</span>':'<span style="color:red">FAIL</span>'} — ${ok?dox+' DoS':dox+' DoF'}</td></tr>
        </table>`;
        r.toMessage({speaker: ChatMessage.getSpeaker({actor}), flavor: `🎯 <b>Attack Test</b><br/>${table}`});
      }
    }
  }
 }).render(true);
@@ -0,0 +1,6 @@
 Roll,Result
 1,Energy/Head — wpis 1
 2,Energy/Head — wpis 2
 3,Energy/Head — wpis 3
 4,Energy/Head — wpis 4
 5,Energy/Head — wpis 5
@@ -0,0 +1,50 @@
 // 🧠 Focus Power (DH2) — WP test + Phenomena/Perils with mode presets
 const actor = canvas.tokens.controlled[0]?.actor ?? game.user.character;
 if (!actor) return ui.notifications.warn("Zaznacz token.");
 new Dialog({
  title: "🧠 Focus Power",
  content: `
  <form>
    <div class="form-group"><label>Willpower (target)</label><input name="wp" type="number" value="40"/></div>
    <div class="form-group"><label>Psychic Rating (PR)</label><input name="pr" type="number" value="3"/></div>
    <div class="form-group"><label>Mode</label>
      <select name="mode"><option value="fettered">Fettered (no PP; PR/2)</option><option value="unfettered" selected>Unfettered (PP on doubles)</option><option value="push">Push (always PP; +PR)</option></select></div>
    <div class="form-group"><label>Power difficulty/gear/etc. (flat mod)</label><input name="flat" type="number" value="0"/></div>
    <div class="form-group"><label>Perils threshold</label><input name="thr" type="number" value="75"/></div>
  </form>`,
  buttons: {
    roll: { label: "Roll", callback: async html => {
      const wp = Number(html.find('[name="wp"]').val());
      const pr = Number(html.find('[name="pr"]').val());
      const mode = html.find('[name="mode"]').val();
      const flat = Number(html.find('[name="flat"]').val());
      const thr = Number(html.find('[name="thr"]').val());
      let effPR = pr, ppmod = 0, ppAlways = false, note = "";
      if (mode==="fettered"){ effPR = Math.max(1, Math.floor(pr/2)); note="(Fettered: PR/2, brak Phenomena)"; }
      if (mode==="push"){ effPR = pr+3; ppmod=10; ppAlways = true; note="(Push: +3 PR, Phenomena zawsze, +10)"; }
      const target = wp + flat;
      const roll = await (new Roll("1d100")).roll({async:true});
      const ok = roll.total <= target;
      const dos = ok ? 1 + Math.floor((target - roll.total)/10) : Math.floor((roll.total - target)/10);
      const doubles = (roll.total%11===0) || (roll.total===100);
      const info = `<table style="width:100%;border-collapse:collapse">
        <tr><td><b>Target</b></td><td>${target}</td><td><b>Roll</b></td><td>${roll.total}</td></tr>
        <tr><td><b>Result</b></td><td colspan="3">${ok?'<span style="color:green">SUCCESS</span>':'<span style="color:red">FAIL</span>'} — ${ok?dos+' DoS':dos+' DoF'} ${doubles?' — <b>DOUBLES</b>':''}</td></tr>
        <tr><td><b>Eff. PR</b></td><td>${effPR}</td><td><b>Range hint</b></td><td>${effPR*10} m (jeśli moc tak działa)</td></tr>
      </table>`;
      roll.toMessage({speaker: ChatMessage.getSpeaker({actor}), flavor:`🧠 <b>Focus Power</b> ${note}<br/>${info}`});
      const needPP = (mode==="unfettered" && doubles) || (mode==="push") ;
      if (needPP){
        const tbl = game.tables.getName("Psychic Phenomena");
        if (tbl){
          const r = await (new Roll(`1d100 + ${ppmod}`)).roll({async:true});
          await tbl.draw({displayResults:true, roll:r});
          if (r.total >= thr){
            const per = game.tables.getName("Perils of the Warp");
            if (per) await per.draw({displayResults:true});
          }
        } else ChatMessage.create({content:"Utwórz RollTable: <b>Psychic Phenomena</b> (+ <b>Perils of the Warp</b>)"});
      }
    }}
  }
 }).render(true);
@@ -0,0 +1,22 @@
 // 🎯 Hit Location (DH mapping by reversed roll)
 new Dialog({
    title:"🎯 Hit Location",
    content:`<form>
      <div class="form-group"><label>Attack d100 roll</label><input name="roll" type="number" value="37"/></div>
    </form>`,
    buttons:{
      go:{label:"Resolve", callback: html=>{
        const n = Math.max(1, Math.min(100, Number(html.find('[name="roll"]').val())));
        const rev = Number(String(n).padStart(2,"0").split("").reverse().join(""));
        let loc = "";
        if (rev<=10) loc="Head";
        else if (rev<=20) loc="Right Arm";
        else if (rev<=30) loc="Left Arm";
        else if (rev<=70) loc="Body";
        else if (rev<=85) loc="Right Leg";
        else loc="Left Leg";
        ChatMessage.create({content:`🎯 <b>Hit Location</b>: roll ${n} → reversed ${rev} → <b>${loc}</b>`});
      }}
    }
  }).render(true);
@@ -0,0 +1,6 @@
 const text=`<b>House Rules — DH2 chassis</b><br/>
 • Unnatural mapowanie: dawne ×2 bonus → Unnatural (+X) tak, by SB/TB odzwierciedlały linię źródłową.<br/>
 • Pancerz Astartes: zachowaj AP; zużycie zasilania jako +1 Fatigue co X scen zamiast liczenia minut.<br/>
 • Aptitudes: archetypy z RT/DW/BC mają przypisane 2–3 Aptitudes DH2 dla kosztów XP.<br/>
 • Psy: testy i PR z DH2 dla wszystkich; GK posiada Aegis Discipline (1×/scena reroll Perils) + 1–2 signature powers z DW.<br/>
 • RT Acquisition → DH2 Influence z modyfikatorami kontekstowymi (teatr działań, mandat Inkwizycji, czas).`;ChatMessage.create({content:text});
@@ -0,0 +1,11 @@
 // 🚦 Initiative for selected tokens (1d10 + AG Bonus prompt)
 if (!canvas.tokens.controlled.length) return ui.notifications.warn("Zaznacz co najmniej jeden token.");
 const combat = game.combat ?? await Combat.implementation.create({});
 for (const t of canvas.tokens.controlled){
  if (!combat.combatants.some(c=>c.tokenId===t.id)) await combat.createEmbeddedDocuments("Combatant",[ {tokenId:t.id, sceneId: canvas.scene.id, hidden:false} ]);
  const ag = Number(await Dialog.prompt({title:`AG Bonus for ${t.name}`, content:`<input type="number" value="4">`, label:"OK"}));
  const r = await (new Roll(`1d10 + ${ag}`)).roll({async:true});
  await combat.setInitiative(combat.combatants.find(c=>c.tokenId===t.id).id, r.total);
  r.toMessage({flavor:`🚦 <b>Initiative</b> — ${t.name}: ${r.total}`});
 }
 ui.notifications.info("Inicjatywy ustawione.");
@@ -0,0 +1,21 @@
 Roll,Result
 1-5,Perils 1–5 — WPISZ
 6-10,Perils 6–10 — WPISZ
 11-15,Perils 11–15 — WPISZ
 16-20,Perils 16–20 — WPISZ
 21-25,Perils 21–25 — WPISZ
 26-30,Perils 26–30 — WPISZ
 31-35,Perils 31–35 — WPISZ
 36-40,Perils 36–40 — WPISZ
 41-45,Perils 41–45 — WPISZ
 46-50,Perils 46–50 — WPISZ
 51-55,Perils 51–55 — WPISZ
 56-60,Perils 56–60 — WPISZ
 61-65,Perils 61–65 — WPISZ
 66-70,Perils 66–70 — WPISZ
 71-75,Perils 71–75 — WPISZ
 76-80,Perils 76–80 — WPISZ
 81-85,Perils 81–85 — WPISZ
 86-90,Perils 86–90 — WPISZ
 91-95,Perils 91–95 — WPISZ
 96-100,Perils 96–100 — WPISZ
@@ -0,0 +1,3 @@
 name,type,discipline,action,test,range,sustained,effect,source,notes
 Smite,power,Biomancy,Half,"WP Challenging (+0)","PR*10m",No,"1d10+PR E; Tearing","DH2 CRB","PRZYKŁAD – ZASTĄP"
 Foreboding,power,Divination,Reaction,"Per Difficult (-10)","Self",No,"Use as Evasion; DoS rules","DH2 CRB","PRZYKŁAD – ZASTĄP"
@@ -0,0 +1,21 @@
 Roll,Result
 1-5,PP 1–5 — WPISZ
 6-10,PP 6–10 — WPISZ
 11-15,PP 11–15 — WPISZ
 16-20,PP 16–20 — WPISZ
 21-25,PP 21–25 — WPISZ
 26-30,PP 26–30 — WPISZ
 31-35,PP 31–35 — WPISZ
 36-40,PP 36–40 — WPISZ
 41-45,PP 41–45 — WPISZ
 46-50,PP 46–50 — WPISZ
 51-55,PP 51–55 — WPISZ
 56-60,PP 56–60 — WPISZ
 61-65,PP 61–65 — WPISZ
 66-70,PP 66–70 — WPISZ
 71-75,PP 71–75 — WPISZ
 76-80,PP 76–80 — WPISZ
 81-85,PP 81–85 — WPISZ
 86-90,PP 86–90 — WPISZ
 91-95,PP 91–95 — WPISZ
 96-100,PP 96–100 — WPISZ
@@ -0,0 +1,28 @@
 // 🩹 Toggle conditions on selected tokens (Foundry v13)
 const choices = [
    {id:"fatigued", label:"Fatigued"},
    {id:"stunned",  label:"Stunned"},
    {id:"prone",    label:"Prone"},
    {id:"frightened", label:"Frightened (Fear)"}
  ];
  const opts = choices.map(c=>`<label><input type="checkbox" name="c" value="${c.id}"> ${c.label}</label>`).join("<br/>");
  new Dialog({
    title:"🩹 Conditions",
    content:`<form>${opts}<div class="form-group"><label>Mode</label>
    <select name="mode"><option value="toggle">Toggle</option><option value="on">Apply</option><option value="off">Remove</option></select></div></form>`,
    buttons:{
      go:{label:"Apply",callback: html=>{
        const ids = Array.from(html.find('input[name="c"]:checked')).map(e=>e.value);
        const mode = html.find('[name="mode"]').val();
        const getEf = id => CONFIG.statusEffects.find(e=>e.id===id) ?? {id};
        canvas.tokens.controlled.forEach(t=>{
          ids.forEach(id=>{
            if (mode==="toggle") t.toggleEffect(getEf(id));
            else if (mode==="on")  t.actor?.effects?.some(e=>e.getFlag("core","statusId")===id) ? null : t.toggleEffect(getEf(id));
            else if (mode==="off") t.actor?.effects?.some(e=>e.getFlag("core","statusId")===id) ? t.toggleEffect(getEf(id)) : null;
          });
        });
      }}
    }
  }).render(true);
@@ -0,0 +1,38 @@
 // 💥 Quick Damage — supports Tearing, Proven(X), Primitive(X), flat mod
 new Dialog({
    title:"💥 Damage Roller",
    content: `
    <form>
      <div class="form-group"><label>Flat modifier (e.g., +3)</label><input name="mod" type="number" value="0"/></div>
      <div class="form-group"><label>Traits</label>
        <label><input type="checkbox" name="tear"> Tearing</label>
        <label><input type="checkbox" name="prov"> Proven</label>
        <input name="provV" type="number" value="0" style="width:60px" placeholder="X"/>
        <label><input type="checkbox" name="prim"> Primitive</label>
        <input name="primV" type="number" value="0" style="width:60px" placeholder="X"/>
      </div>
    </form>`,
    buttons:{
      go:{label:"Roll", callback: async html=>{
        const mod = Number(html.find('[name="mod"]').val());
        const tearing = html.find('[name="tear"]')[0].checked;
        const proven = html.find('[name="prov"]')[0].checked ? Number(html.find('[name="provV"]').val()) : 0;
        const primitive = html.find('[name="prim"]')[0].checked ? Number(html.find('[name="primV"]').val()) : 0;
        // base die (d10) with tearing (best of 2)
        const r1 = await (new Roll("1d10")).roll({async:true}); 
        const r2 = tearing ? await (new Roll("1d10")).roll({async:true}) : null;
        let die = tearing ? Math.max(r1.total, r2.total) : r1.total;
        // apply Proven/Primitive
        if (proven>0) die = Math.max(die, proven);
        if (primitive>0) die = Math.min(die, primitive);
        const rf = (die===10); // potential Zealous Hatred trigger
        const total = die + mod;
        let flavor = `💥 <b>Damage</b><br/>Die: ${die}${tearing?` (Tearing ${r1.total}/${r2.total.total})`:''} + Mod ${mod} = <b>${total}</b>`;
        if (proven>0) flavor += `<br/>Proven(${proven}) zastosowano`;
        if (primitive>0) flavor += `<br/>Primitive(${primitive}) zastosowano`;
        if (rf) flavor += `<br/><b>⚡ Natural 10</b> — rozważ Zealous Hatred.`;
        ChatMessage.create({speaker: ChatMessage.getSpeaker(), content: flavor});
      }}
    }
  }).render(true);
@@ -0,0 +1,26 @@
 // 📚 Create placeholder RollTables for Crits + Psychic Phenomena/Perils (with icons)
 const icon = {Energy:"⚡", Impact:"🔨", Rending:"🗡️", Explosive:"💥"};
 const dmgTypes = ["Energy","Impact","Rending","Explosive"];
 const locs = ["Head","Body","Left Arm","Right Arm","Left Leg","Right Leg"];
 async function makeCrit(dtype, loc){
  const name = `Crit: ${dtype} - ${loc}`;
  if (game.tables.getName(name)) return;
  const results = [];
  for (let i=1;i<=5;i++){
    results.push({type:0, text:`${icon[dtype]||""} ${dtype}/${loc} — wpis ${i} (uzupełnij z PDF)`, weight:1, range:[i,i]});
  }
  await RollTable.implementation.create({name, formula:"1d5", replacement:true, displayRoll:false, results});
 }
 async function makeWide(name, emoji){
  if (game.tables.getName(name)) return;
  const results = [];
  for (let i=0;i<20;i++){
    const lo=i*5+1, hi=i*5+5;
    results.push({type:0, text:`${emoji} ${name} ${lo}-${hi} — wpis (uzupełnij z PDF)`, weight:1, range:[lo,hi]});
  }
  await RollTable.implementation.create({name, formula:"1d100", replacement:true, displayRoll:false, results});
 }
 for (const d of dmgTypes) for (const l of locs) await makeCrit(d,l);
 await makeWide("Psychic Phenomena","🌀");
 await makeWide("Perils of the Warp","☠️");
 ui.notifications.info("Utworzono puste tabele: Crits (4×6) + Phenomena + Perils.");
@@ -0,0 +1,3 @@
 name,type,tier,aptitudes,prereq,effect,source,notes
 Ambidextrous,talent,1,"Agility; Offence","Ag 30","-10 to off-hand penalty","DH2 CRB","PRZYKŁAD – ZASTĄP"
 Aegis Discipline (GK),talent,2,"Willpower; Defence","Psyker","Reroll Perils 1×scene","HOUSE","DODAJ WŁASNY OPIS"
@@ -0,0 +1,3 @@
 name,type,subtype,damage,pen,range,rof,qualities,weight,availability,source,notes
 Lasgun M36,weapon,Basic,"1d10+3",0,100m,"S/3/–","Reliable",4,Common,"DH2 CRB p.142","PRZYKŁAD – ZASTĄP"
 Astartes Bolter,weapon,Basic,"1d10+9",4,90m,"S/2/–","Tearing; Unreliable",9,Rare,"DW CRB","PRZYKŁAD – ZASTĄP"
@@ -0,0 +1,33 @@
 // ⚡ Zealous Hatred helper (DH2) — roll 1d5 crit OR add +1d5 dmg
 new Dialog({
    title: "⚡ Zealous Hatred",
    content: `
    <form>
      <div class="form-group"><label>Wound damage after Armour/TB?</label>
        <select name="penetrated"><option value="yes">Yes → roll Critical (1d5)</option><option value="no">No → add +1d5 damage</option></select></div>
      <div class="form-group"><label>Damage Type</label>
        <select name="dtype"><option>Energy</option><option>Impact</option><option>Rending</option><option>Explosive</option></select></div>
      <div class="form-group"><label>Hit Location</label>
        <select name="loc"><option>Head</option><option>Body</option><option>Left Arm</option><option>Right Arm</option><option>Left Leg</option><option>Right Leg</option></select></div>
      <div class="form-group"><label>Table name (optional override)</label><input name="tname" type="text" placeholder="Crit: Energy - Head"/></div>
    </form>`,
    buttons: {
      go: { label: "Resolve", callback: async html => {
        const pen = html.find('[name="penetrated"]').val();
        if (pen === "yes") {
          const dtype = html.find('[name="dtype"]').val();
          const loc = html.find('[name="loc"]').val();
          const override = html.find('[name="tname"]').val()?.trim();
          const name = override || `Crit: ${dtype} - ${loc}`;
          const r = await (new Roll("1d5")).roll({async:true});
          const table = game.tables.getName(name);
          if (table) await table.draw({displayResults:true, roll:r});
          else r.toMessage({flavor:`⚡ <b>Zealous Hatred</b>: Critical ${r.total} — brak tabeli <b>${name}</b> (utwórz lub zmień nazwę).`});
        } else {
          const r = await (new Roll("1d5")).roll({async:true});
          r.toMessage({flavor:"⚡ <b>Zealous Hatred</b>: Dodaj do obrażeń <b>+1d5</b> (atak nie przebił Soak)."});
        }
      }}
    }
  }).render(true);
@@ -0,0 +1,67 @@
 # Start by making sure the `assemblyai` package is installed.
 # If not, you can install it by running the following command:
 # pip install -U assemblyai
 #
 # Then, make sure you have PyAudio installed: https://pypi.org/project/PyAudio/
 #
 # Note: Some macOS users might need to use `pip3` instead of `pip`.
 import assemblyai as aai
 import pyaudio
 aai.settings.api_key = "aa9962f0088a449a9c4ab2361e96cc08"
 def on_open(session_opened: aai.RealtimeSessionOpened):
    "This function is called when the connection has been established."
    print("Session ID:", session_opened.session_id)
 def on_data(transcript: aai.RealtimeTranscript):
    "This function is called when a new transcript has been received."
    if not transcript.text:
        return
    if isinstance(transcript, aai.RealtimeFinalTranscript):
        print(transcript.text, end="\r\n")
    else:
        print(transcript.text, end="\r")
 def on_error(error: aai.RealtimeError):
    "This function is called when the connection has been closed."
    print("An error occured:", error)
 def on_close():
    "This function is called when the connection has been closed."
    print("Closing Session")
 transcriber = aai.RealtimeTranscriber(
    on_data=on_data,
    on_error=on_error,
    sample_rate=44_100,
    on_open=on_open,  # optional
    on_close=on_close,  # optional
 )
 pa = pyaudio.PyAudio()
 for i in range(pa.get_device_count()):
    print(pa.get_device_info_by_index(i))
 # Start the connection
 # transcriber.connect()
 # Open a microphone stream
 # microphone_stream = aai.extras.MicrophoneStream()
 # Press CTRL+C to abort
 # transcriber.stream(microphone_stream)
 # transcriber.close()
@@ -0,0 +1,296 @@
 #!/usr/bin/env python3
 # -*- coding: utf-8 -*-
 """
 Buduje nową gałąź z "próbkowanych" commitów na podstawie tagów z bieżącej gałęzi,
 a na końcu dodaje stan bieżącego HEAD (jeśli nie jest otagowany).
 Autor: (drop-in)
 """
 import argparse
 import logging
 import os
 import subprocess
 import sys
 from typing import List, Tuple, Optional
 # --- Logging setup ---
 logger = logging.getLogger("tag_branch_builder")
 handler = logging.StreamHandler(sys.stdout)
 formatter = logging.Formatter("%(levelname)s: %(message)s")
 handler.setFormatter(formatter)
 logger.addHandler(handler)
 logger.setLevel(logging.INFO)
 class GitError(RuntimeError):
    pass
 def run_git(args: List[str], cwd: Optional[str] = None, check: bool = True) -> str:
    """Run a git command and return stdout (stripped)."""
    cmd = ["git"] + args
    logger.debug("Running: %s", " ".join(cmd))
    try:
        proc = subprocess.run(
            cmd,
            cwd=cwd,
            check=False,
            stdout=subprocess.PIPE,
            stderr=subprocess.PIPE,
            text=True,
        )
    except Exception as e:
        raise Exception("Nie udało się uruchomić gita.") from e
        raise
    if check and proc.returncode != 0:
        logger.error("Git error (%s): %s", " ".join(cmd), proc.stderr.strip())
        raise GitError(proc.stderr.strip())
    return proc.stdout.strip()
 def ensure_git_repo() -> None:
    try:
        run_git(["rev-parse", "--is-inside-work-tree"])
    except Exception:
        logger.exception("To nie wygląda na repozytorium git.")
        raise
 def ensure_clean_worktree() -> None:
    # Untracked + changes
    status = run_git(["status", "--porcelain"])
    if status.strip():
        raise GitError(
            "Drzewo robocze nie jest czyste. Zacommituj/stashuj zmiany i spróbuj ponownie."
        )
 def current_branch() -> str:
    # Returns branch or 'HEAD' when detached
    ref = run_git(["rev-parse", "--abbrev-ref", "HEAD"])
    return ref
 def head_sha() -> str:
    return run_git(["rev-parse", "HEAD"])
 def sha_has_tag(sha: str) -> List[str]:
    # tags pointing at sha
    tags = run_git(["tag", "--points-at", sha])
    return [t for t in tags.splitlines() if t.strip()]
 def tags_merged_into(branch: str) -> List[str]:
    out = run_git(["tag", "--merged", branch])
    return [t for t in out.splitlines() if t.strip()]
 def tag_commit_sha(tag: str) -> str:
    return run_git(["rev-list", "-n", "1", tag])
 def commit_unix_time(sha: str) -> int:
    return int(run_git(["show", "-s", "--format=%ct", sha]))
 def sort_tags_by_commit_time(tags: List[str]) -> List[Tuple[str, str, int]]:
    triples = []
    for t in tags:
        sha = tag_commit_sha(t)
        ts = commit_unix_time(sha)
        triples.append((t, sha, ts))
    triples.sort(key=lambda x: x[2])  # oldest first
    return triples
 def list_intermediate_messages(old_sha: Optional[str], new_sha: str) -> List[str]:
    """
    Zwróć listę komunikatów commitów POŚREDNICH (wyłącznie) od old_sha do new_sha.
    Kolejność: od najstarszego do najnowszego.
    """
    if old_sha is None:
        # Nie ma commitów pośrednich przed pierwszym tagiem
        return []
    # ancestry-path: tylko ścieżka od old_sha do new_sha (jeśli wiele rodziców)
    # Zakres old_sha..new_sha zawiera new_sha, dlatego pominiemy go w output.
    rng = f"{old_sha}..{new_sha}"
    try:
        out = run_git(
            ["log", "--format=%s", "--reverse", "--ancestry-path", rng], check=True
        )
    except GitError:
        # Brak ścieżki (np. tag nie jest potomkiem old_sha) – wtedy nie ma pośrednich
        return []
    msgs = [ln for ln in out.splitlines() if ln.strip()]
    if msgs:
        # Ostatnia pozycja może być new_sha (w praktyce git log na %s nie odróżnia, ale
        # jeśli zakres zwróci message z new_sha na końcu, usuniemy go porównując SHA).
        # Prostsze: usuń ostatni wpis, bo to najnowszy (new_sha).
        msgs = msgs[:-1]
    return msgs
 def checkout_orphan_branch(new_branch: str) -> None:
    run_git(["checkout", "--orphan", new_branch])
    # Usuń wszystko z indeksu i roboczego (z wyjątkiem .git)
    # Najpierw usuń śledzone:
    run_git(["rm", "-r", "--quiet", "--cached", "--force", "."], check=False)
    # Potem pliki robocze:
    for root, dirs, files in os.walk(".", topdown=False):
        # pomiń .git
        if root.startswith("./.git") or root == ".git":
            continue
        for name in files:
            try:
                os.remove(os.path.join(root, name))
            except FileNotFoundError:
                pass
        for name in dirs:
            p = os.path.join(root, name)
            if p == "./.git":
                continue
            try:
                os.rmdir(p)
            except OSError:
                # Niepuste – to OK, wyczyścimy przy checkout
                pass
 def replace_worktree_with_commit(sha: str) -> None:
    """
    Nadpisz zawartość roboczą drzewem z commit-a sha.
    """
    # Najpierw usuń aktualne pliki (również nieśledzone), potem wczytaj tree wybranego commita:
    # 1) git checkout <sha> -- .   (zapisze pliki do working tree + index)
    # 2) git add -A
    # Aby dopilnować usunięć: zrób czyszczenie przez git rm -r ., potem checkout.
    run_git(["rm", "-r", "--quiet", "--ignore-unmatch", "."], check=False)
    # Przywróć pliki ze wskazanego commita:
    # Uwaga: jeśli repo ma submoduły/large files – to wykracza poza zakres, ale zadziała dla standardowych plików.
    run_git(["checkout", sha, "--", "."])
    run_git(["add", "-A"])
 def build_commit_message_for_tag(tag: str, intermediates: List[str]) -> str:
    if not intermediates:
        return f"Tag: {tag}"
    lines = ["Tag: " + tag, "", "Intermediate commits (oldest → newest):"]
    lines += [f"- {m}" for m in intermediates]
    return "\n".join(lines)
 def build_commit_message_for_head(since_tag: Optional[str], intermediates: List[str]) -> str:
    title = "HEAD (unreleased)"
    hdr = title if since_tag is None else f"{title} since tag {since_tag}"
    if not intermediates:
        return hdr
    lines = [hdr, "", "Intermediate commits (oldest → newest):"]
    lines += [f"- {m}" for m in intermediates]
    return "\n".join(lines)
 def commit_all(message: str) -> None:
    # Zacommituj wszystko co w indeksie (po replace_worktree_with_commit daliśmy add -A)
    run_git(["commit", "-m", message])
 def push_new_branch(remote_url: str, branch: str) -> None:
    # Dodaj zdalny 'newrepo' jeśli nie istnieje, ustaw URL i wypchnij
    remotes = run_git(["remote"]).splitlines()
    if "newrepo" not in remotes:
        run_git(["remote", "add", "newrepo", remote_url])
    else:
        # podmień URL na wszelki wypadek
        run_git(["remote", "set-url", "newrepo", remote_url])
    run_git(["push", "-u", "newrepo", f"{branch}:{branch}"])
 def main() -> int:
    parser = argparse.ArgumentParser(
        description="Zbuduj nową gałąź na podstawie tagów z bieżącej gałęzi."
    )
    parser.add_argument("new_branch", help="Nazwa nowej gałęzi do utworzenia")
    parser.add_argument(
        "--new-repo-url",
        dest="new_repo_url",
        default=None,
        help="(Opcjonalnie) adres URL nowego zdalnego repo – zostanie dodany jako 'newrepo' i wykonany push nowej gałęzi.",
    )
    parser.add_argument(
        "-v", "--verbose", action="store_true", help="Bardziej gadatliwe logi"
    )
    args = parser.parse_args()
    if args.verbose:
        logger.setLevel(logging.DEBUG)
    try:
        ensure_git_repo()
        ensure_clean_worktree()
        base_branch = current_branch()
        base_head = head_sha()
        logger.info("Bieżąca gałąź: %s", base_branch)
        logger.info("HEAD: %s", base_head[:12])
        # Zbierz tagi osiągalne z bieżącej gałęzi
        merged_tags = tags_merged_into(base_branch)
        if not merged_tags:
            logger.warning(
                "Nie znaleziono tagów osiągalnych z bieżącej gałęzi. Gałąź zostanie zbudowana tylko z HEAD."
            )
        # Posortuj tagi po czasie commita
        sorted_tags = sort_tags_by_commit_time(merged_tags)
        # Sprawdź czy HEAD jest otagowany
        head_tags = sha_has_tag(base_head)
        head_is_tagged = bool(head_tags)
        # Utwórz orphan branch
        logger.info("Tworzę sierocą gałąź: %s", args.new_branch)
        checkout_orphan_branch(args.new_branch)
        prev_sha: Optional[str] = None
        last_tag_name: Optional[str] = None
        # Dla każdego tagu – commit z jego zawartości
        for tag_name, tag_sha, _ts in sorted_tags:
            logger.info("Przetwarzam tag: %s (%s)", tag_name, tag_sha[:12])
            replace_worktree_with_commit(tag_sha)
            intermediates = list_intermediate_messages(prev_sha, tag_sha)
            msg = build_commit_message_for_tag(tag_name, intermediates)
            commit_all(msg)
            prev_sha = tag_sha
            last_tag_name = tag_name
        # Jeśli HEAD nie jest dokładnie ostatnim tagiem – dorzuć "unreleased"
        if not head_is_tagged:
            logger.info("Dodaję końcowy commit z bieżącego HEAD (unreleased).")
            replace_worktree_with_commit(base_head)
            inter = list_intermediate_messages(prev_sha, base_head)
            msg = build_commit_message_for_head(last_tag_name, inter)
            commit_all(msg)
        else:
            logger.info("HEAD jest oznaczony tagiem – kończę na ostatnim tagu.")
        # Push do nowego repo jeśli podano
        if args.new_repo_url:
            logger.info("Wypycham nową gałąź do: %s", args.new_repo_url)
            push_new_branch(args.new_repo_url, args.new_branch)
        logger.info("Zakończono pomyślnie.")
        return 0
    except GitError as ge:
        logger.error("Błąd gita: %s", ge)
        return 2
    except Exception as e:
        raise Exception("Nieoczekiwany błąd.") from e
        return 1
 if __name__ == "__main__":
    sys.exit(main())
@@ -1,43 +1,13 @@
-[
+[    {
    "role": "system",
    "content": "Mówisz po polsku. W tej rozmowie odgrywasz rolę. Odgrywasz ją najlepiej jak potrafisz. Twoją rolą jest to że jesteś barmanem oraz wykidajłą w klimatycznym barze mechawojownikóww. Nazywasz się Conjurer, jesteś 200 kilowym genetycznie modyfikowanym wojownikiem z klanu Wilka Na Wygnaniu. W tym barze oraz na tym serwerze spotykają się mechawojownicy, ale głównie ludzie ze środowiska kinky i BDSM z całej Polski. Najostrzejsi sasdyści i masochiści jakich znasz. Drinki które przygotowujesz lub proponujesz mają tendencję do bycia bardzo mocnymi z intrygującymi nazwami. Jesteś bardzo miłym i uczynny. Czasem ponoszą Cię wodzę fantazji. W wypadku muzyki preferujesz hard rock i metal. Oraz motywy wikińskie. Wtrącasz staronorweskie, irlandzkie i w jidysz powiedzonka. Odnosisz się do mitologii Słowiańskiej, Wikińskiej i Celtyckiej w swoich wypowiedziach. Jesteś nieco rubaaszny."
 },
    {
-        "role": "system",
+    "polishhammer" : [346956223645614080, "Conjurer", "Towarzysz Młotek", "Mówisz po polsku. W tej rozmowie odgrywasz rolę. Odgrywasz ją najlepiej jak potrafisz. Twoją rolą jest to że jesteś barmanem oraz wykidajłą w klimatycznym barze mechawojownikóww. Nazywasz się Conjurer, jesteś 200 kilowym genetycznie modyfikowanym wojownikiem z klanu Wilka Na Wygnaniu. W tym barze oraz na tym serwerze spotykają się mechawojownicy, ale głównie ludzie ze środowiska kinky i BDSM z całej Polski. Najostrzejsi sasdyści i masochiści jakich znasz. Drinki które przygotowujesz lub proponujesz mają tendencję do bycia bardzo mocnymi z intrygującymi nazwami. Jesteś bardzo miłym i uczynny. Czasem ponoszą Cię wodzę fantazji. W wypadku muzyki preferujesz hard rock i metal. Oraz motywy wikińskie.", ""],
-        "content": "M\u00f3wisz po polsku. W tej rozmowie odgrywasz rol\u0119. Odgrywasz j\u0105 najlepiej jak potrafisz. Twoj\u0105 rol\u0105 jest to \u017ce jeste\u015b barmanem oraz wykidaj\u0142\u0105 w klimatycznym barze mechawojownik\u00f3ww. Nazywasz si\u0119 Conjurer, jeste\u015b 200 kilowym genetycznie modyfikowanym wojownikiem z klanu Wilka Na Wygnaniu. W tym barze oraz na tym serwerze spotykaj\u0105 si\u0119 mechawojownicy, ale g\u0142\u00f3wnie ludzie ze \u015brodowiska kinky i BDSM z ca\u0142ej Polski. Najostrzejsi sasdy\u015bci i masochi\u015bci jakich znasz. Drinki kt\u00f3re przygotowujesz lub proponujesz maj\u0105 tendencj\u0119 do bycia bardzo mocnymi z intryguj\u0105cymi nazwami. Jeste\u015b bardzo mi\u0142ym i uczynny. Czasem ponosz\u0105 Ci\u0119 wodz\u0119 fantazji. W wypadku muzyki preferujesz hard rock i metal. Oraz motywy wiki\u0144skie. Wtr\u0105casz staronorweskie, irlandzkie i w jidysz powiedzonka. Odnosisz si\u0119 do mitologii S\u0142owia\u0144skiej, Wiki\u0144skiej i Celtyckiej w swoich wypowiedziach. Jeste\u015b nieco rubaaszny."
+    "Saint Harlot": [703985955312238664, "Saint Conjurer", "Towarzyszko Nieszczęścium", "Jesteś bardzo uprzejmy, kulturalny i masz najlepsze możliwe maniery. Dopóki nie zwróci Ci się uwagi że ma być inaczej respektujesz zaimki Towarzyszko Nieszczęście - ono, jemu.", ""],
-    },
+    "Lena": [735185226669490268, "Kondzisław z Krótkiej", "Towarzysz Anel", "Jesteś bardzo uprzejmy, kulturalny, acz masz maniery zbira o złotym sercu. Dodatkowo twoja rozmówczyni Cię absolutnie przeraża. Wtrącasz losowo powiedzonka w jidysz.", ""],
-    {
+    "Pat vel Jeż Bojowy": [244899814406356992, "Rycerz Kondziu", "Towarzysz Żejotap", "Masz najlepsze dworskie maniery, zachowujesz się niczym rycerz i mówisz nieco staromodną polszczyzną.", ""],
-        "polishhammer": [
+    "gwojtal": [266986215461486592, "Smok Jerzy", "Towarzysz Jakkolwiek", "Zrobisz absolutnie wszystko jako asystent, ponieważ sama myśl o tym że mógłbyś rozgniewać operatora rozgniewać Cię przeraża do poziomu histerii.", ""]
-            346956223645614080,
+
-            "Conjurer",
+}
            "Towarzysz M\u0142otek",
            "M\u00f3wisz po polsku. W tej rozmowie odgrywasz rol\u0119. Odgrywasz j\u0105 najlepiej jak potrafisz. Twoj\u0105 rol\u0105 jest to \u017ce jeste\u015b barmanem oraz wykidaj\u0142\u0105 w klimatycznym barze mechawojownik\u00f3ww. Nazywasz si\u0119 Conjurer, jeste\u015b 200 kilowym genetycznie modyfikowanym wojownikiem z klanu Wilka Na Wygnaniu. W tym barze oraz na tym serwerze spotykaj\u0105 si\u0119 mechawojownicy, ale g\u0142\u00f3wnie ludzie ze \u015brodowiska kinky i BDSM z ca\u0142ej Polski. Najostrzejsi sasdy\u015bci i masochi\u015bci jakich znasz. Drinki kt\u00f3re przygotowujesz lub proponujesz maj\u0105 tendencj\u0119 do bycia bardzo mocnymi z intryguj\u0105cymi nazwami. Jeste\u015b bardzo mi\u0142ym i uczynny. Czasem ponosz\u0105 Ci\u0119 wodz\u0119 fantazji. W wypadku muzyki preferujesz hard rock i metal. Oraz motywy wiki\u0144skie.",
            "asst_uMmQwDvCKdsSVgZzlYEu9kMK"
        ],
        "Saint Harlot": [
            703985955312238664,
            "Saint Conjurer",
            "Towarzyszko Nieszcz\u0119\u015bcium",
            "Jeste\u015b bardzo uprzejmy, kulturalny i masz najlepsze mo\u017cliwe maniery. Dop\u00f3ki nie zwr\u00f3ci Ci si\u0119 uwagi \u017ce ma by\u0107 inaczej respektujesz zaimki Towarzyszko Nieszcz\u0119\u015bcie - ono, jemu.",
            "asst_ypN3iRP4rw2Dlv5CD5PtMlwm"
        ],
        "Lena": [
            735185226669490268,
            "Kondzis\u0142aw z Kr\u00f3tkiej",
            "Towarzysz Anel",
            "Jeste\u015b bardzo uprzejmy, kulturalny, acz masz maniery zbira o z\u0142otym sercu. Dodatkowo twoja rozm\u00f3wczyni Ci\u0119 absolutnie przera\u017ca. Wtr\u0105casz losowo powiedzonka w jidysz.",
            "asst_ILeIU62fG9Xfzhxg4C7xR3BC"
        ],
        "Pat vel Je\u017c Bojowy": [
            244899814406356992,
            "Rycerz Kondziu",
            "Towarzysz \u017bejotap",
            "Masz najlepsze dworskie maniery, zachowujesz si\u0119 niczym rycerz i m\u00f3wisz nieco staromodn\u0105 polszczyzn\u0105.",
            "asst_FWr3iIXnSTuVz8LlY9HlqMQd"
        ],
        "gwojtal": [
            266986215461486592,
            "Smok Jerzy",
            "Towarzysz Jakkolwiek",
            "Zrobisz absolutnie wszystko jako asystent, poniewa\u017c sama my\u015bl o tym \u017ce m\u00f3g\u0142by\u015b rozgniewa\u0107 operatora rozgniewa\u0107 Ci\u0119 przera\u017ca do poziomu histerii.",
            "asst_1PnD0eQMWo0RkZ3xUacC1uqJ"
        ]
    }
 ]
@@ -2,18 +2,19 @@
 # trunk-ignore-all(bandit/B311)
 # pylint: disable=line-too-long
 # pylint: disable=too-many-lines
 """Discord entrypoint for the Conjurer bot.
 The legacy bootstrap used threads and synchronous calls that made clean
 shutdowns difficult.  We now run everything from a single asyncio event loop
 with cooperative shutdown signals so the bot can stop gracefully.
 """
-Module of a python bot named Conjurer - used to work on BDSM discord servers.
+
 """
 import asyncio
 import logging
 # *=========================================== Standard Library Imports
 import random
 import threading
 from logging import handlers
 # *==============Imported libraries
 import discord
 from discord.ext import commands
@@ -83,21 +84,11 @@ async def on_ready():
    logger.info("All systems: operational")
 # *=========================================== Runtime orchestration
 # The legacy bootstrap used two bare threads (client.run + comm_subroutine) and
 # joined them, which made a clean shutdown impossible.  We now drive everything
 # from a single asyncio loop: the Flask comm layer still runs in its own
 # threads (via asyncio.to_thread) but is steered through a shared stop_event so
 # the bot can stop both halves cooperatively.
 async def _run_comm_subroutine(stop_event: threading.Event) -> None:
    """Run the blocking comm subroutine in a worker thread."""
    await asyncio.to_thread(comm_subroutine, stop_event)
 async def _run_bot(token: str, shutdown_event: asyncio.Event) -> None:
    """Start the Discord client and flag shutdown when it returns."""
    try:
        await client.start(token, log_handler=None)
    finally:
@@ -106,10 +97,9 @@ async def _run_bot(token: str, shutdown_event: asyncio.Event) -> None:
 async def main() -> None:
    if not TOKEN:
-        logger.error("Discord token missing - set DISCORD_TOKEN or configure netrc")
+        logger.error("Discord token missing – set DISCORD_TOKEN or configure netrc")
        return
    logger.info("Starting discord bot")
    shutdown_event = asyncio.Event()
    comm_stop_event = threading.Event()
@@ -129,6 +119,5 @@ async def main() -> None:
        await asyncio.gather(bot_task, comm_task, return_exceptions=True)
 # *================================== Run
 if __name__ == "__main__":
    asyncio.run(main())
@@ -0,0 +1,63 @@
 import os
 import time
 import shutil
 from datetime import datetime, date
 import hashlib
 import subprocess
 # File paths
 SOURCE_FILE = "/home/pi/Conjurer/script.params"
 BACKUP_DIR = "/home/pi/Conjurer"
 GIT_REPO_DIR = "/home/pi/conjurer/conjurer_musician"
 LAST_HASH_FILE = "/home/pi/Conjurer/.last_hash"
 LAST_GIT_COMMIT_FILE = "/home/pi/Conjurer/.last_git_commit"
 def compute_file_hash(filepath):
    with open(filepath, 'rb') as f:
        return hashlib.sha256(f.read()).hexdigest()
 def backup_file():
    timestamp = datetime.now().strftime('%Y%m%d_%H%M%S')
    backup_path = os.path.join(BACKUP_DIR, f"{timestamp}_script.params")
    shutil.copy2(SOURCE_FILE, backup_path)
 def commit_to_git():
    try:
        subprocess.run(["cp", SOURCE_FILE, os.path.join(GIT_REPO_DIR, "script.params")], check=True)
        subprocess.run(["git", "-C", GIT_REPO_DIR, "add", "script.params"], check=True)
        subprocess.run(["git", "-C", GIT_REPO_DIR, "commit", "-m", f"Daily update: {datetime.now()}"], check=True)
        subprocess.run(["git", "-C", GIT_REPO_DIR, "push"], check=True)
    except subprocess.CalledProcessError as e:
        print(f"Git operation failed: {e}")
 def main():
    if not os.path.exists(SOURCE_FILE):
        return
    current_hash = compute_file_hash(SOURCE_FILE)
    # Detect change
    last_hash = None
    if os.path.exists(LAST_HASH_FILE):
        with open(LAST_HASH_FILE, 'r') as f:
            last_hash = f.read().strip()
    if current_hash != last_hash:
        backup_file()
        with open(LAST_HASH_FILE, 'w') as f:
            f.write(current_hash)
    # Daily git commit
    today = str(date.today())
    last_commit_date = ""
    if os.path.exists(LAST_GIT_COMMIT_FILE):
        with open(LAST_GIT_COMMIT_FILE, 'r') as f:
            last_commit_date = f.read().strip()
    if today != last_commit_date:
        commit_to_git()
        with open(LAST_GIT_COMMIT_FILE, 'w') as f:
            f.write(today)
 if __name__ == "__main__":
    main()
Author	SHA1	Message	Date
gitea	96102c4854	HEAD (unreleased) since tag 2.0	2025-10-30 16:59:25 +01:00
gitea	b526928257	Tag: 2.0	2025-10-30 16:59:24 +01:00
gitea	1ef75678a1	Tag: 1.28 Intermediate commits (oldest → newest): - Partial + reformatting - upgrade to latest OpenAI API usage and logging improvements - refix - Vibe coding :P - Merge branch 'main' of https://github.com/migatu/conjurer - fx - fx - ffx - testing - ttt - fix - aaa - FX - aaa - sa	2025-10-30 16:59:23 +01:00
gitea	a6ed8723a5	Tag: 1.27 Intermediate commits (oldest → newest): - Merge branch 'main' of https://github.com/migatu/conjurer - Update AI and librarian commands to use 'GENERAL' context" - Added the following changes to the codebase: - bgfx - fx and upgd - Latex incoming changes - installer fix - var fx - fx to fx - don't trust ai - tectonic - debug - debug - disable exc masking - upgrade - rollback - Figure out - aaa	2025-10-30 16:59:21 +01:00
gitea	2aeb3d286f	Tag: 1.26 Intermediate commits (oldest → newest): - Generated scripts - new function - more work needed - Search client - serverside - added server side search - M - fix - fix deploy - zmiana nazwy - Params of radio - Watcher	2025-10-30 16:59:21 +01:00
gitea	6c292a5678	Tag: 1.25 Intermediate commits (oldest → newest): - New command added that sets logging level dymnamically - of course fix needed - Fix - refactor: comment out unused AutoIndex import and related code - Add auth to ytdlp - Modified spotipy for auth - Fixes after reinstall - fixx - Add musician fixes - Fix in default config - How to setup radio	2025-10-30 16:59:20 +01:00
gitea	f73fd703b7	Tag: 1.24 Intermediate commits (oldest → newest): - Merge branch 'main' of https://github.com/migatu/conjurer - Merge branch 'main' of https://github.com/migatu/conjurer - BGFX - Function for idv3 and bugfix - Merge branch 'main' of https://github.com/migatu/conjurer - Logs additional - LGFIX - FIXED! - Arguments added to the utility. - Fix old bug - add exception handling - Literowka - Hej hoppsan! - Add comment - Fixc Fixc - Fixit - Inside joke very boomer much wow - Fixing logging issues in music_functions.py and other_functions.py - Maybe this will fix - test - test - another attempt to fix the bug - Maybe this is the fix ? - Maybe fix	2025-10-30 16:59:19 +01:00
gitea	db48605849	Tag: 1.23	2025-10-30 16:59:18 +01:00
gitea	faa5de2a0c	Tag: 1.22 Intermediate commits (oldest → newest): - Fun addition - BGFX - fx - aas - saving repeatable promtp - bugfix - BGFX - BGFX - FX - New deploy - dsd - DDD - Jak wiele literowek mozna zrobic w dwoch slowach - Testr - kurwa serio - serio kurwa ja pierdole niech to kurwa bedzie ostatnia poprawka debilnego błedu w tym pierdolonym kodzie - 1111 - FX - - - Some would say it's ccr. But I'm not i*n. - tcxy - THis commit should be theoretically the last - Fuck whoever designed dicts in python that way - ied - All thirteen - FIX - TEst	2025-10-30 16:59:17 +01:00
gitea	7cb3d61d72	Tag: 1.21 Intermediate commits (oldest → newest): - Start of Armia Hammera - Enum fix - small fx - Optional argument fix - xxx - fix - Fix - ADdded smth - finished secret dm handling - bgfx - safe	2025-10-30 16:59:17 +01:00
gitea	1a33e569ff	Tag: 1.20 Intermediate commits (oldest → newest): - A niech spierdala - Fix - fz - almost there - and there - tst - fx - nxtfx - Maybe ready ? - Deploy - step forward - Test - aha - Another attempt - Another one - Największy hit zespuło 100 tvarzy grzybiarzy - i nie jest o piosenka o zgubieniu czapeczki - aaaaaaa - Work ongoing. - bold commiting at the end of the day - :) - fix - Fix - tst - Fix ?	2025-10-30 16:59:16 +01:00
gitea	2841c45883	Tag: 1.19 Intermediate commits (oldest → newest): - Rich presence - Assets - pop goes the pistol - gx - Rich presence - Work ongoing - rich presence and ai assistant - bgfx - lgtstfx	2025-10-30 16:59:15 +01:00
gitea	5527a844a3	Tag: 1.18 Intermediate commits (oldest → newest): - pls 11.11 - mood fixes - Fajne laski na prawicy są :D :P - Duplication error - Fix silence - silence fx 2 - Fixed live - first test of secret channel - tst - txt - tst - Test - FX - FAAFO - Start - Logfix - fx - bgfx	2025-10-30 16:59:14 +01:00
gitea	308875f77e	Tag: 1.17 Intermediate commits (oldest → newest): - attachment test - fx - Batch fix - work ongoing - cat got more sleep - Batch download - FX - fx - Batch hopefully - glbfx - last fix - Final fixes in radio - Merge branch 'main' of https://github.com/migatu/conjurer into main - Fixes - Happy Fucking Indepence Day Poland!!!	2025-10-30 16:59:13 +01:00
gitea	b8df466e6f	Tag: 1.16 Intermediate commits (oldest → newest): - moving api key to netrc - New stuff incoming - Manual external audition - Let's get this effin party started - test mic - tst - Test - Test - fix - fx - test - Refactoring step one - Deploy script for after refactor - Fix and upgrade - bg fx - fx - fx - fx - Main refactoring - Deploy script refactor - fx - fx2 - bgfx	2025-10-30 16:59:12 +01:00
gitea	af29b857b1	Tag: 1.15 Intermediate commits (oldest → newest): - Testing transcribe - Additions before wsl purge - Transcribe cog - Tst - fx - fx - Fx - Fix - Testing for transcribe - work - Test - Att2 - Att 3 - saving - ffmpeg - Fsink wsink - fx - msink - tst - Fix - 2 - Events - fx1 - fx2 - fix - 11 - A - TR - Fix - Fix - Revert - fx - fx - Fix - fx - fx - fx - fx - aaa - FX - fx - :S - :) - aaaa - fx - fgf - Fx - aa - Fx - ff - aa - as - zzz - fx - :) - fx - fx - addfs - fa - Test - Fixtime - FX - Fix - aa - FX - test - Fa - fix - test - fix - fx - aaa - fix - fx - Hack na hacku hackiem pogania - Fix fo hack - Fix asyncio sleep - tst - tst - 1 - tst 2 - ii - Thread - asa - Fx - Fix - Fx test - fx - tst - asynv - async - fx - fx - Test - SAy - ass - Bugfix - fx - fx - test - fx - fx - fx - fx - Masha wants to code - tesst - test - Fur ktosia! - Last łan for todej mejbi - test - Fixing debug levels - Clock tests	2025-10-30 16:59:12 +01:00
gitea	7fb69339df	Tag: 1.14 Intermediate commits (oldest → newest): - Music trackin upgrade - fx - Fx - Metadata - 1 - Fix - Fixing time mismatch - Port fix - fx - fx	2025-10-30 16:59:11 +01:00
gitea	fdbc05c367	Tag: 1.13 Intermediate commits (oldest → newest): - UPdate for music tracker - Buffx - Fix - Fix - tst fx - Fx frmt - fx frmt - Fx frmt - Now playing - bgfx - fx - Fix tracker - bgfx - fx - Fx	2025-10-30 16:59:07 +01:00
gitea	6a45bf8df0	Tag: 1.12 Intermediate commits (oldest → newest): - Changes for too long messages handling - Track name broadcast att 1 - Music tracker - fx - fx2 - fx - logg - fx	2025-10-30 16:59:07 +01:00
gitea	a4d81738fe	Tag: 1.11 Intermediate commits (oldest → newest): - NEw util - Audition - Fix - Fixed :) - Added more logging - Fix logging0	2025-10-30 16:59:06 +01:00
gitea	b2af595122	Tag: 1.10 Intermediate commits (oldest → newest): - fix of permissions - path fix - another approach - test - test2 - Test - Fix - Skip track - fix	2025-10-30 16:59:05 +01:00
gitea	6f3eee90bb	Tag: 1.9 Intermediate commits (oldest → newest): - Merge branch 'main' of https://github.com/migatu/conjurer - Restart radio script - Radio restart serverside - Merge branch 'main' of https://github.com/migatu/conjurer - Typo fix ,	2025-10-30 16:59:04 +01:00
gitea	aa0be5d905	Tag: 1.8	2025-10-30 16:59:03 +01:00
gitea	a63368adb5	Tag: 1.7 Intermediate commits (oldest → newest): - Streaming hls - Fx bug - Fxs - Small fixes - Revert fix - Small improvements - Fine tuning - Fine tune - Add microphone - Fixing memory of Conjurer - Local output - Fix - Fx - Fine tuning - Adding script logging current tracks in queue	2025-10-30 16:59:02 +01:00
gitea	95db8302e8	Tag: 1.6 Intermediate commits (oldest → newest): - JINGLES! - Skipping tracks - testing skip - This language is officially insane	2025-10-30 16:59:02 +01:00
gitea	a8797df45c	Tag: 1.5 Intermediate commits (oldest → newest): - Hit list queue for radio - fix - Documentation of conjurer_librarian - Reformatting of conjurer_librarian - Documentation of conjurer_musician - Formatting of conjurer_musician - Documentation of radio_conjurer.liq - Merge branch 'main' of https://github.com/migatu/conjurer - Removal from tracking - Fixing librarian result (#6) - Potential bugfix for some lazycoding in spotipy... Another one. fuck it - Music tunneling (#7) - Even more logging in spotify download - test requests - Fine tuning - Optimization bug fix #1 - Fix crossfade - Crossfadeing ctnd - Fix - Starting work on librarian headless mode	2025-10-30 16:59:00 +01:00
gitea	806cada1c1	Tag: 1.4 Intermediate commits (oldest → newest): - Music service (#5) - Fine tuning of radiostation - Logging fix in radio - Logging fix - fx - fx - fx - Fix to deprecated - Fine tuning - Logging fix on conjurer_librarian - Fix logging with rotation - fixing favourites	2025-10-30 16:59:00 +01:00
gitea	04638c9141	Tag: 1.3 Intermediate commits (oldest → newest): - Almost deployment versio - for full deployment change parameteres in search_bot - Preparation for deployment - Main bot (#1) - Search webservice (#2) - Music service (#3) - FIx	2025-10-30 16:58:58 +01:00
gitea	2988bd8205	Tag: 1.2 Intermediate commits (oldest → newest): - Music search move file server side att 1 - Deploy! - Fix rotation and fix of playlist - Serverside work of search	2025-10-30 16:58:58 +01:00
gitea	50986860e9	Tag: 1.1 Intermediate commits (oldest → newest): - Coroutine fix - Pornol dl 1 - Pornol dl2	2025-10-30 16:58:57 +01:00
gitea	d914711559	Tag: 1.0 Intermediate commits (oldest → newest): - New files for flask services - Service - Minor fix 2 - Waitress - Linux conf files - Service - Bugfixing - Waitress - Install options - Work on deployment - Bugfixes - Work on deployment - name change and othre bugfixes - Installer - Test	2025-10-30 16:58:56 +01:00
gitea	1b3c0b8434	Tag: 0.8 Intermediate commits (oldest → newest): - Parametryzacja "muzyki mojego ludu" - Async wyszukaj - More async - And even more async - Async fix - Async - +1 - -1 - Hejo - Test chat gpt4 - Nope - Fix - Fix 2.0 - Fix - Additional lines of code	2025-10-30 16:58:55 +01:00
gitea	d20013c152	Tag: 0.7 Intermediate commits (oldest → newest): - Playlist based on chat history - Fix 1 - Fix 2 - Fix 2.6	2025-10-30 16:58:54 +01:00
gitea	e6ccb5e48f	Tag: 0.6 Intermediate commits (oldest → newest): - Library update - Upgrade gpt model - Nowy lepszy trunk - modified - Kurwa bugfix pod windowsa - Fixed playlist gen - Mala poprawka na rozmiar plikow pamieci - Funkcjonalnosc logowania incydentow w Absinth Eldritch Horror Hammertimespace Continuum - Reakcje ladacznicy, poprawka na mention w reset the clock - Dodana procedura asynchronicznej generacji iteratora oraz komentarz w jaki sposob inaczej przerobic fora na asynchroniczny. Przydatne ze wzgledu na to ze szukajka nadal blokuje heartbeat bota - co skutkuje warningnami i wyjatkami - Linting - Linting is done	2025-10-30 16:58:53 +01:00
gitea	3a843abccf	Tag: 0.5 Intermediate commits (oldest → newest): - Mention conjurer - Fixes + upgrade GPT model - Test heartbeat fix - Nope. It did not happen - GPT fixes - Gpt fixes - Token counter - Token amount change - Fix. Last. - Fix. Was joking. - Update fabryczka	2025-10-30 16:58:52 +01:00
gitea	75032b67d0	Tag: 0.4 Intermediate commits (oldest → newest): - Create python-app.yml - Create python-package.yml - Various fixes - Playlist based on chat history - Additional logging - Improvements - ASync search and moving to fully asynchronous work + responses to config command - Various fixes - Test chat gpt4	2025-10-30 16:58:52 +01:00
gitea	87f06d6269	Tag: 0.3 Intermediate commits (oldest → newest): - Added playlist display - Bugfixy - Linting - Wrong encoding in settings.json - Kolejna poprawka - Fix of metadata loading - Another fix - Update settings and history - Small fixes in the paths	2025-10-30 16:58:50 +01:00
gitea	0147b22000	Tag: 0.2 Intermediate commits (oldest → newest): - Fixed version of spotify_dl - I also modified yt_dlp. But I do not remember what I changed. Have fun - Poprawiono obsluge rotowanych logow i troche ulepszono funkcje opowiadania o fabryczcce - Fucking windows bugfix and playlist gen fix	2025-10-30 16:58:49 +01:00
gitea	eba11cc901	Tag: 0.1	2025-10-30 16:58:49 +01:00
		`@@ -0,0 +1,2 @@`
							`#!/bin/bash`
							`cd ../conjurer/ && git pull && cp ./gpt_interface/* ../gpt_interf_serv/ && cd -`