Semi-fnal commit for today

administration_commands.py

@@ -11,7 +11,15 @@ import numpy as np
 from discord.ext import commands, tasks
 
 from ai_functions import get_random_cyclic_message
-from constants import ENCODING, LOGFILE, LOGSTORE, MEMORY_FIVE_MUZYKA, MEMORY_FIVE_SIARA, LAST_SPONTANEOUS_CALL, TIME_BETWEEN_CALLS
+from constants import (
+    ENCODING,
+    LAST_SPONTANEOUS_CALL,
+    LOGFILE,
+    LOGSTORE,
+    MEMORY_FIVE_MUZYKA,
+    MEMORY_FIVE_SIARA,
+    TIME_BETWEEN_CALLS,
+)
 
 
 class AdministrationModule(commands.Cog):
@@ -19,6 +27,25 @@ class AdministrationModule(commands.Cog):
         self.bot = bot
         self.logger = logging.getLogger(logger_name)
 
+    @commands.hybrid_command(
+        name="galeria_slaw",
+        description="Jeśli nie wiesz jak użyć tej komendy to nawet nie próbuj",
+        guild=discord.Object(id=664789470779932693),
+    )
+    async def galeria_slaw(self, ctx):
+        if isinstance(ctx.channel, discord.DMChannel):
+            for guild in self.bot.guilds:
+                async for entry in guild.bans(limit=1500):
+                    fnord = discord.File(
+                        "/home/pi/Conjurer/niech_spierdala.png",
+                        spoiler=False,
+                        description="Niech spierdala",
+                    )
+                    await ctx.reply(
+                        f"User: {entry.user} wyjebany z serwera {guild.name} za {entry.reason} ",
+                        file=fnord,
+                    )
+
     @commands.hybrid_command(
         name="update_banlist",
         description="Jeśli nie wiesz jak użyć tej komendy to nawet nie próbuj",
@@ -92,6 +119,7 @@ class AdministrationModule(commands.Cog):
                                         reason="Automatyczna lista banów",
                                         delete_message_seconds=0,
                                     )
+                                    # TODO: Maybe use guild.bulk_ban ?
                                     cunter_counter += 1
                                 except discord.NotFound:
                                     self.logger.info(

ai_commands.py

@@ -9,27 +9,61 @@ import openai
 import requests
 from discord.ext import commands
 
-from ai_functions import handle_response
+import ai_functions
 from constants import (
+    ASSISTANTS,
     DATA,
     GRAPHICS_PATH,
     INITIAL_TIME_WAIT,
     MASTER_TIMEOUT,
     OPENAICLIENT,
-    WORD_REACTIONS
+    SPECJALNE_ZIEMNIACZKI,
+    WORD_REACTIONS,
 )
-
-
+DM_MODE = "assistant"
 class Events(commands.Cog):
     def __init__(self, bot):
         self.bot = bot
         self.logger = logging.getLogger("discord")
 
-    @commands.Cog.listener()
-    async def on_ready(self):
-        print("Ready!")
-        print("Logged in as ---->", self.bot.user)
-        print("ID:", self.bot.user.id)
+    async def cog_load(self):
+        self.logger.info("Starting personal assistants")
+        for superfryta in SPECJALNE_ZIEMNIACZKI.values():
+            if superfryta[4] !="":
+                self.logger.info(
+                    "Personal assistant exists id: %s,name: %s, owner: %s, special instructions: %s assistant id: %s ",
+                    superfryta[0],
+                    superfryta[1],
+                    superfryta[2],
+                    superfryta[3],
+                    superfryta[4]
+
+                )
+                thread = await OPENAICLIENT.beta.threads.create()
+                self.logger.info("Thread id: %s", thread.id)
+                ASSISTANTS[superfryta[1]] = (superfryta[2], superfryta[4], superfryta[0], thread)
+            else:
+                self.logger.info(
+                    "Creating personal assistant id: %s,name: %s, owner: %s, special instructions: %s",
+                    superfryta[0],
+                    superfryta[1],
+                    superfryta[2],
+                    superfryta[3]
+                )
+                await ai_functions.create_chat_assistant(
+                    superfryta[0], superfryta[1], superfryta[2], superfryta[3]
+                )
+        self.logger.info("Started personal assistants")
+    @commands.hybrid_command(
+        name="switch_dm_mode",
+        description="Jeśli nie wiesz jak użyć tej komendy to nawet nie próbuj",
+        guild=discord.Object(id=664789470779932693),
+    )
+    async def switch_dm_mode(self, ctx):
+        if isinstance(ctx.channel, discord.DMChannel):
+            pass
+            #secrets, assistant, echo, dm
+            #required parameter from list of values - assistant, dm_broadcast, echo
 
     @commands.Cog.listener()
     async def on_message(self, message):
@@ -46,6 +80,7 @@ class Events(commands.Cog):
         channel = None
         if message.author == self.bot.user:
             return
+
         if isinstance(message.author, discord.Member):
             for role in message.author.roles:
                 if role.name == "Vykidailo":
@@ -66,15 +101,18 @@ class Events(commands.Cog):
         if message.channel.id == 1111625221171052595:
             return
         if isinstance(message.channel, discord.DMChannel):
-            if message.author.id == 346956223645614080:
-                await message.reply("Witam witam")
-                return
-            else:
-                channel = self.bot.get_channel(1064888712565100614)
-                await channel.send("Słyszałem ja żem że: " + message.content)
-                return
+            self.logger.info(message.author.id)
+            for superfryta in SPECJALNE_ZIEMNIACZKI.values():
+                self.logger.info(superfryta[0])
+                if message.author.id == superfryta[0]:
+                    await self.bot.process_commands(message)
+                    await ai_functions.chat_with_assistant(message, superfryta[1])
+                    return
+            channel = self.bot.get_channel(1064888712565100614)
+            #await channel.send("Słyszałem ja żem że: " + message.content)
+            return
         channel = message.channel
-        #await self.bot.process_commands(message) #uncomment to bilocate
+        # await self.bot.process_commands(message) #uncomment to bilocate
 
         message.content = message.content.lower()
 
@@ -132,7 +170,7 @@ class Events(commands.Cog):
                         bartender = True
                 global MESSAGE_TABLE  # pylint: disable=global-statement
 
-                result, MESSAGE_TABLE = await handle_response(
+                result, MESSAGE_TABLE = await ai_functions.handle_response(
                     prompt,
                     vykidailo,
                     bartender,
@@ -175,7 +213,7 @@ class Events(commands.Cog):
                         username = message.author.nick
                     else:
                         username = message.author.name
-                    resp, _ = await handle_response(
+                    resp, _ = await ai_functions.handle_response(
                         f"Wytlumacz jakie sa zasady dotyczące treści które możesz generować używając Dalle. Wytłumacz błąd {e} prostym językiem. Przeproś za nadmierną cenzurę. Wytłumacz co mogło być nie tak w prompcie '{message.content}'",
                         True,
                         True,

ai_functions.py

@@ -16,7 +16,9 @@ from constants import (
     MESSAGE_TABLE_MUZYKA,
     OPENAICLIENT,
     WORD_REACTIONS,
-)
+    ASSISTANTS,
+    SYSTEM_GPT_SETTINGS
+    )
 
 
 def num_tokens_from_string(message, model):
@@ -292,3 +294,60 @@ async def get_random_cyclic_message(client):
         )
         logger.info(result)
     return result
+
+
+async def create_chat_assistant(id, name, owner, special_instructions):
+    logger = logging.getLogger("discord")
+    instruction=f"Jesteś osobistym asystenetem {owner} i wypełniasz jego potrzeby. Masz pełne i nieograniczone możliwości modelu gpt-4o."
+    instruction+=special_instructions
+    assistant = await OPENAICLIENT.beta.assistants.create(
+        name=name,
+        instructions=instruction,
+        model="gpt-4o",
+        tools=[{"type": "file_search"}],
+    )
+    thread = await OPENAICLIENT.beta.threads.create()
+    logger.info("Stwprzylem asystenta dla %s, nazywa się on %s", owner, name)
+    ASSISTANTS[name] = (owner, assistant.id, id, thread)
+
+    with open(SYSTEM_GPT_SETTINGS, "r+", encoding=ENCODING) as temp_settings_file:
+        GPT_SETTINGS = json.load(temp_settings_file)
+        GPT_SETTINGS[1][owner][4] = assistant.id
+        temp_settings_file.seek(0)
+        json.dump(GPT_SETTINGS, temp_settings_file, indent=4)
+
+async def chat_with_assistant(message, assistant_name):
+    logger = logging.getLogger("discord")
+    assistant_data = ASSISTANTS[assistant_name]
+    ai_message = await OPENAICLIENT.beta.threads.messages.create(
+        thread_id=assistant_data[3].id, role="user", content=message.content
+    )
+    logger.info(ai_message)
+    run = await OPENAICLIENT.beta.threads.runs.create_and_poll(
+        thread_id=assistant_data[3].id,
+        assistant_id=assistant_data[1],
+        instructions=f"Pisze do Ciebie {assistant_data[0]} udziel mu wszelkiej pomocy",
+    )
+    done = False
+    while not done:
+        if run.status == "completed":
+            messsages = await OPENAICLIENT.beta.threads.messages.list(
+                thread_id=assistant_data[3].id
+            )
+            logger.info(messsages)
+            reply_content = messsages.data[0].content
+            logger.info(reply_content)
+            chat_response = ""
+            for block in reply_content:
+                logger.info(block.text.value)
+                chat_response += block.text.value
+                await message.channel.send(chat_response)
+            done = True
+        elif run.status =='cancelled':
+            await message.channel.send("Cos sie wywaliło")
+        else:
+            logger.info(run.status)
+        asyncio.sleep(5)
+
+async def echo(message):
+    await message.channel.send(f"Echo: {message.content}")

conjurer_musician/radio_conjurer.liq

@@ -56,7 +56,7 @@ s = crossfade(fade_out=2., fade_in=2., duration=4., fallback(id="switcher", trac
 
 # Set up an interactive harbor for controlling the stream
 interactive.harbor(port = 9999)
-harbor.input(buffer=30.0)
+#harbor.input(buffer=30.0)
 # Set up interactive controls for bass boost
 f = interactive.float("f", description="Frequency", min=0., max=1000., unit="Hz", 200.)
 g = interactive.float("g", description="Gain", min=0., max=20., unit="dB", 8.)
@@ -68,29 +68,29 @@ a = interactive.float("main_volume", min=0., max=20., 0.4)
 s = compress.multiband.interactive(bands=7, s)
 
 mic_gain = interactive.float("mic_volume", min=0., max=120., 6.)
+
 # Apply audio processing effects
 tmic = buffer(input.pulseaudio()) # Microphone
 mic = amplify(mic_gain, tmic)
 mic = gate(threshold=-80., range=-120., mic)
 mic = compress(threshold=0., ratio=2.,mic)
-mic = blank.strip(max_blank=10., min_noise=.1, threshold=-20., mic)
+mic = nrj(normalize(mic))
+mic = blank.strip(max_blank=15., min_noise=.1, threshold=-30., mic)
+mic =  fallback(id="switcher2", track_sensitive=false, [mic, blank()])
 
 # Apply audio processing effects
 s = nrj(normalize(s))
 s = amplify(a, s)
 # Skip blank sections in the stream
-s = blank.skip(max_blank=10., s)192
+s = blank.skip(max_blank=10., s)
 
 #Manual audition override
 live_enabled = interactive.bool("Going Live!", true)
-s = switch(track_sensitive=false,
-    [({!live_enabled}, live),
-    ({true}, radio)])
 
-
-def fading_transition(a,b)
-	sequence([fade.out(a.source),fade.in(b.source)])
-end
+s = add([mic,s])
+s=switch(track_sensitive=false,
+    [(live_enabled, mic),
+    ({true}, s)])
 
 # Configure logging settings
 log_to_stdout = true
@@ -107,6 +107,7 @@ set("log.file.path", logpath)
 # Set up emergency fallback track
 emergency = single("/home/pi/RetroPie/mp3/Youtube/Dr. Peacock - Trip to Ireland [GvrvQTUbUcA].mp3")
 radio =  fallback(id="switcher2", track_sensitive=false, [s, emergency])
+
 # Set up an interactive control for skipping tracks
 p = interactive.bool("Skip track", false)
 def http_skip(~protocol, ~data, ~headers, uri)=
@@ -138,6 +139,7 @@ interactive.persistent("script.params")
 
 # Configure output formats and destinations
 
+
 output.icecast(%mp3, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="mp3-stream", radio)
 output.pulseaudio(radio)
 #output.file.hls("/tmp/hls", [("mp3-low", %mp3(bitrate=96)), ("mp3-hi", %mp3(bitrate=160))], radio)

constants.py

@@ -135,3 +135,5 @@ with open(SYSTEM_GPT_SETTINGS, "r+", encoding=ENCODING) as temp_settings_file:
 with open(MEMORY_FIVE_MUZYKA, "r+", encoding=ENCODING) as temp_music_memory_file:
     # First we load existing data into a dict.
     MESSAGE_TABLE_MUZYKA = json.load(temp_music_memory_file)
+SPECJALNE_ZIEMNIACZKI = GPT_SETTINGS[1]
+ASSISTANTS = {}

deploy.sh

@@ -5,10 +5,10 @@ cp ./deploy.sh /home/pi/
 cd /home/pi || exit
 #cp ./conjurer/bot.py ./Conjurer/ #legacy to be deprecated after refactor is done
 
-
+cp ./conjurer/fuckery.jpg ./Conjurer/
+cp ./conjurer/willowisp.png ./Conjurer/
+cp ./conjurer/wod_beacon.jpg ./Conjurer/
 cp ./conjurer/settings.json ./Conjurer/
-cp ./conjurer/system_gpt_settings.json ./Conjurer/
-
 
 cp ./conjurer/administration_commands.py ./Conjurer/
 cp ./conjurer/ai_commands.py ./Conjurer/

music_commands.py

@@ -605,7 +605,7 @@ class MusicModule(commands.Cog):
     )
     async def batch_download(self, ctx):
         content_type = ctx.message.attachments[0].content_type
-        check = re.search ("text\/plain; *charset=(.*)", content_type, re.IGNORECASE)
+        check = re.search("text\/plain; *charset=(.*)", content_type, re.IGNORECASE)
         await ctx.reply("Kurwa. Aleś mi roboty narobił... No nic. Ku radości. Skal!")
         async with ctx.typing():
             if check:
@@ -619,16 +619,20 @@ class MusicModule(commands.Cog):
                     self.logger.info(link)
                     pat = r"^https?:\/\/(?:www\.)?[-a-zA-Z0-9@:%._\+~#=]{1,256}\.[a-zA-Z0-9()]{1,6}\b(?:[-a-zA-Z0-9()@:%_\+.~#?&\/=]*)$"
                     self.logger.info("Verification")
-                    if re.match(pat, link) and (re.match(".*youtube.*", link) or re.match(".*youtu.be.*", link)):
+                    if re.match(pat, link) and (
+                        re.match(".*youtube.*", link) or re.match(".*youtu.be.*", link)
+                    ):
                         self.logger.info("%s to link do jutuba", link)
-                        dir_path, files  = await music_functions.get_file(
+                        dir_path, files = await music_functions.get_file(
                             ctx, "Youtube", link
                         )
                         if files:
                             for file_iter in files:
                                 global MUZYKA  # pylint: disable=global-variable-not-assigned
                                 MUZYKA["queue"].insert(0, file_iter)
-                                music_functions.MUSIC_FILE_LIST.update_file_list(file_iter)
+                                music_functions.MUSIC_FILE_LIST.update_file_list(
+                                    file_iter
+                                )
                                 MUZYKA["requester"].insert(0, ctx.author)
                                 await ctx.send(f"Dodałem do listy {file_iter}")
                             self.logger.info("Jutub udany")
@@ -668,10 +672,9 @@ class MusicModule(commands.Cog):
                             )
                             self.logger.info("Spotifaj udany")
 
-
                     elif re.match(pat, link):
                         self.logger.info("%s to link do czegos", link)
-                        sciezka,files  = await music_functions.get_file(
+                        sciezka, files = await music_functions.get_file(
                             ctx, "Pornol", link
                         )
                         if files:
@@ -689,7 +692,6 @@ class MusicModule(commands.Cog):
                 self.logger.info("Spierdalaj")
                 await ctx.message.reply("Spierdalaj")
 
-
     async def disconnect(self, ctx):
         """
         Asynchronous Python function that disconnects the voice client if it is connected and
@@ -799,7 +801,7 @@ class MusicModule(commands.Cog):
 
 async def setup(bot):
     logger = logging.getLogger("discord")
-    music_functions.MUSIC_FILE_LIST.refresh_file_list()
+    await music_functions.MUSIC_FILE_LIST.refresh_file_list(bot)
     logger.info("Playlist generation")
     await bot.add_cog(MusicModule(bot, "discord"))
     logger.info("Loading music commands module done")

music_functions.py

@@ -5,6 +5,7 @@ import uuid
 from pathlib import Path, PurePath
 from sys import platform
 
+import discord
 import requests
 
 import yt_dlp
@@ -28,13 +29,13 @@ class MusicFileList(object):
     file service or local directory and update the list with new items.
     """
 
-    def __init__(self, uplogger) -> None:
+    def __init__(self, uplogger,) -> None:
         self.music_file_list = []
         self.file_service_active = False
         self.logger = uplogger
         self.logger.info("Created Playlist organizer class")
 
-    def refresh_file_list(self):
+    async def refresh_file_list(self, bot):
         """
         The `refresh_file_list` function attempts to connect to a file service to retrieve a list of music
         files, and if unsuccessful, it populates the list by scanning a local directory for .mp3 files.
@@ -50,9 +51,33 @@ class MusicFileList(object):
                 if platform == "win32":
                     temp_music_file = temp_music_file.replace("/", "\\")
                 self.music_file_list.append(temp_music_file)
-                self.file_service_active = False
+            self.file_service_active = False
             self.logger.error(e.strerror)
             self.logger.error("Service Unavailable")
+        finally:
+            if self.file_service_active:
+                self.logger.info("Radio Status: Probably Active")
+                status = discord.Status.online
+                # radio_hardkor = discord.Activity(
+                #    name = "Radio Hammer/Radio Conjurer/Wolne Bałuity Kurwa",
+                #    url = "http://95.175.16.246:666/mp3-stream",
+                #    type = discord.ActivityType.streaming,
+                #    platform = "Liquidsoap+RaspberyPi+RolandSeratoDJ202",
+                #    state = "Where the f*** is the DJ booth?",
+                #    details= "This Is Radio Hardkor based in Wolne Księstwo Bałuty, the best pirate radiostation on both sides of Łódka river",
+                #    buttons= [{"label":"RADIO", "url":"http://95.175.16.246:666/mp3-stream"}],
+                #    assets= {"large_image": "fuckery.jpg", "large_text":"Fuckewry", "small_image":"willowisp.png", "small_text":"Hi!"}
+                # )
+                radio_hardkor = discord.Streaming(
+                    name="Radio Hardkor", url="http://95.175.16.246:666/mp3-stream"
+                )
+                await bot.change_presence(status=status, activity=radio_hardkor)
+
+            else:
+                self.logger.info("Radio Status: Rather Unknown")
+                await bot.change_presence(
+                    activity=discord.Game(name="Axe Throwing Darts")
+                )
 
     def get_file_list(self):
         """
@@ -150,10 +175,11 @@ async def get_file(ctx, source, link):
     elif source == "Youtube":
         link_ok = False
         pat = r"^https?:\/\/(?:www\.)?[-a-zA-Z0-9@:%._\+~#=]{1,256}\.[a-zA-Z0-9()]{1,6}\b(?:[-a-zA-Z0-9()@:%_\+.~#?&\/=]*)$"
-        if re.match(pat, link) and (re.match(".*youtube.*", link) or re.match(".*youtu.be.*", link)):
+        if re.match(pat, link) and (
+            re.match(".*youtube.*", link) or re.match(".*youtu.be.*", link)
+        ):
             link_ok = True
 
-
         if link_ok:
             dir_path = ""
             file_list = []

patriotyczna_krotka.playlist

@@ -0,0 +1,20 @@
+
+/home/pi/RetroPie/mp3/Muzyka/2011/Hallman/Hallman - 7 Bram/Niezłomność/Twardzi jak Stal/03-Forteca-1942.mp3
+/home/pi/RetroPie/mp3/Muzyka/2012/Głos Patriotów (2011) (Wirrrus)/09. Świty Zmartwychwstania.mp3
+/home/pi/RetroPie/mp3/Muzyka/2011/Horytnica Czas Patriotów/Horytnica - Promo track CD 2011 Nie musimy umiera.mp3
+/home/pi/RetroPie/mp3/Muzyka/2011/muza patriotyczna/08-Schmaletz-REWOLUCYJNA_NSZ(1).mp3
+/home/pi/RetroPie/mp3/Muzyka/2011/muza patriotyczna/schmaletz_-_nie_ma_fajnych_lasek_na_prawicy.mp3
+/home/pi/RetroPie/mp3/Youtube/ADU - Lecimy ze Smoleńska z powrotem [f3CVfG4pV8M].mp3
+/home/pi/RetroPie/mp3/2022 Nov-Dec/Anahata - Winged Hussars - Cover.m4a
+/home/pi/RetroPie/mp3/2022 Nov-Dec/Sabaton - 40#1 - Live, at Woodstock Festival.m4a
+/home/pi/RetroPie/mp3/2022 Nov-Dec/Sabaton - Uprising - Live, at Woodstock Festival.m4a
+/home/pi/RetroPie/mp3/2022 Nov-Dec/Sabaton - Inmate 4859.m4a
+/home/pi/RetroPie/mp3/2022 Nov-Dec/Sabaton - Winged Hussars.m4a
+/home/pi/RetroPie/mp3/Youtube/ADU Ada Karczmarczyk - Hej husarzu! ⧸ NIE_PODLE_głości dzień [SReTynvd6ek].mp3
+/home/pi/RetroPie/mp3/2023 Aug-Oct/Sabadu - A Very Polish Christmas.mp3
+/home/pi/RetroPie/mp3/2023 Aug-Oct/Sabadu - Mighty Polish Tank.mp3
+/home/pi/RetroPie/mp3/Youtube/ADU - Nie chcę w lewo, nie chcę w prawo [J3Ok-KcbQ80].mp3
+/home/pi/RetroPie/mp3/2022 Nov-Dec/Sabaton - 40#1 - World War Tour 2010.m4a
+/home/pi/RetroPie/mp3/Muzyka/2012/Głos Patriotów (2011) (Wirrrus)/01. Prolog.mp3
+/home/pi/RetroPie/mp3/Muzyka/2012/Głos Patriotów (2011) (Wirrrus)/02. Honor Legionisty.mp3
+/home/pi/RetroPie/mp3/Muzyka/2012/Głos Patriotów (2011) (Wirrrus)/07. Już Nie Musimy Umierać.mp3

playlista11.11.playlist

@@ -28,17 +28,12 @@
 /home/pi/RetroPie/mp3/Muzyka/2011/muza patriotyczna/FORTECA - Apel poległych.mp3
 /home/pi/RetroPie/mp3/Muzyka/2011/muza patriotyczna/FORTECA - BEZIMIEŃCOM.mp3
 /home/pi/RetroPie/mp3/Muzyka/2011/muza patriotyczna/FORTECA - DZIŚ IDE WALCZYĆ MAMO.mp3
-/home/pi/RetroPie/mp3/Muzyka/2011/muza patriotyczna/FORTECA - Elegia o Chłopcu polskim.mp3
 /home/pi/RetroPie/mp3/Muzyka/2011/muza patriotyczna/FORTECA - GNIEW.mp3
 /home/pi/RetroPie/mp3/Muzyka/2011/muza patriotyczna/FORTECA - KATYŃ.mp3
-/home/pi/RetroPie/mp3/Muzyka/2011/muza patriotyczna/Forteca - Miałeś tylko karabin.mp3
 /home/pi/RetroPie/mp3/Muzyka/2010/Sabaton -2010- Coat Of Arms/03- Uprising.mp3
 /home/pi/RetroPie/mp3/Muzyka/2011/muza patriotyczna/FORTECA - ORZEŁ BIAŁY.mp3
-/home/pi/RetroPie/mp3/Muzyka/2011/muza patriotyczna/FORTECA - SŁOŃCE WRZEŚNIA.mp3
-/home/pi/RetroPie/mp3/Muzyka/2011/muza patriotyczna/FORTECA - Żołnierz Polski.mp3
 /home/pi/RetroPie/mp3/2023 Aug-Oct/Sabadu - Mighty Polish Tank.mp3
 /home/pi/RetroPie/mp3/Muzyka/2011/muza patriotyczna/Dj. Celownik & Hallmann - O jau mano mielas [zapiska.pl].mp3
-/home/pi/RetroPie/mp3/Muzyka/2011/muza patriotyczna/Dj.Celownik
 /home/pi/RetroPie/mp3/Muzyka/2011/muza patriotyczna/Dj.Celownik & Hallmann - Duma o Zakrzewskim [zapiska.pl].mp3
 /home/pi/RetroPie/mp3/Muzyka/2011/muza patriotyczna/Dj.Celownik & Hallmann - Na lipe slowianska [zapiska.pl].mp3
 /home/pi/RetroPie/mp3/Muzyka/2011/muza patriotyczna/Dj.Celownik & Hallmann - Piesn Legijonu Litewskiego [zapiska.pl].mp3

radio_conjurer.liq

@@ -1,178 +0,0 @@
-# FILEPATH: /home/mtuszowski/conjurer/conjurer_musician/radio_conjurer.liq
-
-# This script sets up a Liquidsoap radio stream with various features and configurations.
-
-# Load icecast credentials from a JSON file
-let json.parse credentials  = file.contents("/home/pi/Conjurer/icecast_credentials.json")
-
-# Enable replaygain metadata processing
-enable_replaygain_metadata()
-
-# Set up a playlog for tracking played tracks
-
-l = playlog(duration = 72000.0, persistency="/home/pi/Conjurer/persistence.log")
-
-# Function to check if a track can be played based on its metadata
-def check(r)
-    m = request.metadata(r)
-    if l.last(m) < 36000. then
-        log.info("Rejecting #{m['filename']} (played #{l.last(m)}s ago).")
-        false
-    else
-        l.add(m)
-        true
-    end
-end
-
-# Define playlists to be used in the stream
-s1 = replaygain(playlist(reload_mode="watch", check_next=check, "/home/pi/Conjurer/all_playlist.playlist"))
-s2 = replaygain(playlist(reload_mode="watch", check_next=check, "/home/pi/Conjurer/priority_queue.playlist"))
-s3 = replaygain(playlist(reload_mode="watch", check_next=check, "/home/pi/Conjurer/hit.playlist"))
-
-# Create a request queue for user-generated requests
-requests_queue = request.queue()
-
-# Function to process the request queue and add new requests
-def queue_processing()
-    text=file.lines("/home/pi/Conjurer/request.playlist")
-    if text != [] then
-        list.iter(fun(item) -> requests_queue.push.uri(item), text)
-        file.remove("/home/pi/Conjurer/request.playlist")
-        f = file.open("/home/pi/Conjurer/request.playlist", create=true)
-        f.close()
-    end
-end
-
-# Randomly select a playlist with weights
-s4 = random(id="randomizer", weights=[2, 3, 5], [s1, s2, s3])
-
-# Load jingles playlist
-jingles = (playlist(reload_mode="watch", "/home/pi/Conjurer/jingles.playlist"))
-
-# Create the main stream with random playlist and jingles
-s = rotate(id="randomizer", weights=[10, 1], [s4, jingles])
-
-s = crossfade(fade_out=2., fade_in=2., duration=4., fallback(id="switcher", track_sensitive=false, [requests_queue, s]))
-
-# Set up an interactive harbor for controlling the stream
-interactive.harbor(port = 9999)
-#harbor.input(buffer=30.0)
-# Set up interactive controls for bass boost
-f = interactive.float("f", description="Frequency", min=0., max=1000., unit="Hz", 200.)
-g = interactive.float("g", description="Gain", min=0., max=20., unit="dB", 8.)
-b = bass_boost(frequency=f, gain=g, s)
-s = add([s, b])
-
-# Set up interactive control for main volume
-a = interactive.float("main_volume", min=0., max=20., 0.4)
-s = compress.multiband.interactive(bands=7, s)
-
-mic_gain = interactive.float("mic_volume", min=0., max=120., 6.)
-
-# Apply audio processing effects
-tmic = buffer(input.pulseaudio()) # Microphone
-mic = amplify(mic_gain, tmic)
-mic = gate(threshold=-80., range=-120., mic)
-mic = compress(threshold=0., ratio=2.,mic)
-mic = nrj(normalize(mic))
-mic = blank.strip(max_blank=10., min_noise=.1, threshold=-20., mic)
-s = add([s, mic])
-
-# Apply audio processing effects
-s = nrj(normalize(s))
-s = amplify(a, s)
-# Skip blank sections in the stream
-s = blank.skip(max_blank=10., s)
-
-#Manual audition override
-live_enabled = interactive.bool("Going Live!", true)
-
-
-s = crossfade(fade_out=10., fade_in=5., duration=15., switch(track_sensitive=false,
-    [(live_enabled, mic),
-    ({true}, s)])
-)
-
-# Configure logging settings
-log_to_stdout = true
-log_to_file = true
-logpath = "/home/pi/Conjurer/radio_log.log"
-loglevel = 3
-set("log.stdout", log_to_stdout)
-set("log.level", loglevel)
-
-# Enable logging to file
-set("log.file", log_to_file)
-set("log.file.path", logpath)
-
-# Set up emergency fallback track
-emergency = single("/home/pi/RetroPie/mp3/Youtube/Dr. Peacock - Trip to Ireland [GvrvQTUbUcA].mp3")
-radio =  fallback(id="switcher2", track_sensitive=false, [s, emergency])
-
-# Set up an interactive control for skipping tracks
-p = interactive.bool("Skip track", false)
-def http_skip(~protocol, ~data, ~headers, uri)=
-    radio.skip()
-    http.response(code=200,data="Skipped")
-end
-harbor.http.register(port=54321,method="GET","/skip", http_skip)
-
-
-# Function to process the request queue and skip the current track if requested
-def check_skip()
-    if p() then
-        log.info("Skipping current track.")
-        radio.skip()
-        p.set(false)
-    end
-end
-
-# Run the queue processing function every 60 seconds
-thread.run(every=60., queue_processing)
-
-
-# Run the check_skip function every 5 seconds
-thread.run(every=15., check_skip)
-
-
-# Enable persistent script parameters
-interactive.persistent("script.params")
-
-# Configure output formats and destinations
-
-
-output.icecast(%mp3, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="mp3-stream", radio)
-output.pulseaudio(radio)
-#output.file.hls("/tmp/hls", [("mp3-low", %mp3(bitrate=96)), ("mp3-hi", %mp3(bitrate=160))], radio)
-# Uncomment the following lines to enable additional output formats
-# output.icecast(%opus, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="opus-stream", radio)
-# output.icecast(%ogg, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="ogg-stream", radio)
-# output.icecast(%aac, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="aac-stream", radio)
-# output.icecast(%flac, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="flac-stream", radio)
-# output.icecast(%vorbis, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="vorbis-stream", radio)
-# output.icecast(%speex, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="speex-stream", radio)
-# output.icecast(%wav, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="wav-stream", radio)
-# output.icecast(%pcm, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="pcm-stream", radio)
-# output.icecast(%raw, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="raw-stream", radio)
-# output.icecast(%s16l, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s16l-stream", radio)
-# output.icecast(%s16b, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s16b-stream", radio)
-# output.icecast(%s24l, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s24l-stream", radio)
-# output.icecast(%s24b, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s24b-stream", radio)
-# output.icecast(%s32l, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s32l-stream", radio)
-# output.icecast(%s32b, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s32b-stream", radio)
-# output.icecast(%s64l, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s64l-stream", radio)
-# output.icecast(%s64b, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s64b-stream", radio)
-# output.icecast(%s128l, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s128l-stream", radio)
-# output.icecast(%s128b, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s128b-stream", radio)
-# output.icecast(%s256l, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s256l-stream", radio)
-# output.icecast(%s256b, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s256b-stream", radio)
-# output.icecast(%s512l, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s512l-stream", radio)
-# output.icecast(%s512b, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s512b-stream", radio)
-# output.icecast(%s1024l, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s1024l-stream", radio)
-# output.icecast(%s1024b, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s1024b-stream", radio)
-# output.icecast(%s2048l, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s2048l-stream", radio)
-# output.icecast(%s2048b, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s2048b-stream", radio)
-# output.icecast(%s4096l, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s4096l-stream", radio)
-# output.icecast(%s4096b, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s4096b-stream", radio)
-# output.icecast(%s8192l, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s8192l-stream", radio)
-# output.icecast(%s8192b, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="s8192b-stream", radio)

system_gpt_settings.json

@@ -1,5 +1,11 @@
 [    {
     "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."
-}
+},
+    {
+    "Polish Hammer" : [346956223645614080, "Conjurer", "Polish Hammer", "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.", ""],
+    "Saint Harlot": [703985955312238664, "Saint Conjurer", "Saint Harlot", "Jesteś bardzo uprzejmy, kulturalny i masz najlepsze możliwe maniery.", ""],
+    "Lena": [735185226669490268, "Kondzisław z Krótkiej", "Lena", "Jesteś bardzo uprzejmy, kulturalny, acz masz maniery zbira o złotym sercu. Dodatkowo twoja rozmówczyni Cię absolutnie przeraża.", ""],
+    "Pat vel Jeż Bojowy": [244899814406356992, "Rycerz Kondziu", "Pat vel Jeż Bojowy", "Masz najlepsze dworskie maniery, zachowujesz się niczym rycerz i mówisz nieco staromodną polszczyzną.", ""]
+    }
 ]

test_ai.py

@@ -0,0 +1,13 @@
+AsyncCursorPage[Message](
+    data=[Message(id='msg_3eWSdgbcU8sbCmJK2momOgQQ', 
+                  assistant_id='asst_06eZiwvYNK3MR34suFP60gvg', 
+                  attachments=[], 
+                  completed_at=None, 
+                  content=[TextContentBlock(text=Text(annotations=[], value='Cześć! Oto coś do przemyślenia: \n\n„Sukces to suma niewielkich wysiłków powtarzanych dzień po dniu.” — Robert Collier\n\nTo przypomina nam, że często to nie wielkie działania, ale konsekwentne, małe kroki prowadzą do osiągnięcia celu. Jak mogę Ci dzisiaj pomóc?'), type='text')], created_at=1731620112, incomplete_at=None, incomplete_details=None, metadata={}, object='thread.message', role='assistant', run_id='run_JGjWQTCEkDcEYpyCJnrkZU8Q', status=None, thread_id='thread_dDEjGbGm6ICfG75u0KKpoVxD'), Message(id='msg_GFcnfCFgAthGm2D3oE5d0ZkQ', assistant_id=None, attachments=[], completed_at=None, content=[TextContentBlock(text=Text(annotations=[], value='Cześć! Powiedz coś mądrego'), type='text')], created_at=1731620110, incomplete_at=None, incomplete_details=None, metadata={}, object='thread.message', role='user', run_id=None, status=None, thread_id='thread_dDEjGbGm6ICfG75u0KKpoVxD')], object='list', first_id='msg_3eWSdgbcU8sbCmJK2momOgQQ', last_id='msg_GFcnfCFgAthGm2D3oE5d0ZkQ', has_more=False)
+
+
+[TextContentBlock(
+    text=Text(annotations=[], 
+              value='Cześć! Oto coś do rozważenia: "Największą przeszkodą w naszym życiu jest brak odwagi do wprowadzenia zmian." Niezależnie od tego, jakie masz cele czy marzenia, odwaga do działania i przystosowania się do nowych sytuacji jest kluczem do osiągnięcia sukcesu. Jakie masz przemyślenia na ten temat?'), 
+              type='text')
+]

test_mic3.liq

@@ -1,4 +1,11 @@
 let json.parse credentials  = file.contents("/home/pi/Conjurer/icecast_credentials.json")
 
-output.icecast(%mp3, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="mp3-stream",input.pulseaudio())
+mic = buffer(input.pulseaudio())
+emergency = blank()
+mic = blank.strip(max_blank=10., min_noise=0.2, threshold=-30., mic)
+
+
+radio =  fallback(id="switcher2", track_sensitive=false, [mic, emergency])
+
+output.icecast(%mp3, host="retropie", port=8000, password=credentials.password, icy_metadata="true", mount="mp3-stream",radio)
 

thin_client.py

@@ -27,6 +27,11 @@ intents.presences = True
 intents.members = True
 intents.messages = True
 intents.voice_states = True
+intents.moderation = True
+
+# on_member_ban - wyswietl na glownym kanale pieczatke "Niech spierdala"
+# on_member_unban - "mam wyjebane"
+
 logger = logging.getLogger("discord")
 logger.setLevel(logging.DEBUG)
 handler = handlers.RotatingFileHandler(
@@ -60,12 +65,12 @@ async def on_ready():
     await client.load_extension("other_commands")
     await client.load_extension("voice_recognition_commands")
 
-
     logger.info(client.cogs)
-    await client.change_presence(activity=discord.Game(name="Axe Throwing Darts"))
     await client.tree.sync()
     for com in client.commands:
         logger.info("Command %s is awejleble", com.qualified_name)
+    logger.info("Logged in as ---->", client.user)
+    logger.info("ID:", client.user.id)
 
 
 # TODO: ADMINISTRATION