This is seriously last fix

description update

last fix ?

Small fix

Kolejny fix

Final fix

FX2

fx

.github/workflows/python-app.yml

@@ -0,0 +1,39 @@
+# This workflow will install Python dependencies, run tests and lint with a single version of Python
+# For more information see: https://docs.github.com/en/actions/automating-builds-and-tests/building-and-testing-python
+
+name: Python application
+
+on:
+  push:
+    branches: [ "main" ]
+  pull_request:
+    branches: [ "main" ]
+
+permissions:
+  contents: read
+
+jobs:
+  build:
+
+    runs-on: ubuntu-latest
+
+    steps:
+    - uses: actions/checkout@v3
+    - name: Set up Python 3.10
+      uses: actions/setup-python@v3
+      with:
+        python-version: "3.10"
+    - name: Install dependencies
+      run: |
+        python -m pip install --upgrade pip
+        pip install flake8 pytest
+        if [ -f requirements.txt ]; then pip install -r requirements.txt; fi
+    - name: Lint with flake8
+      run: |
+        # stop the build if there are Python syntax errors or undefined names
+        flake8 . --count --select=E9,F63,F7,F82 --show-source --statistics
+        # exit-zero treats all errors as warnings. The GitHub editor is 127 chars wide
+        flake8 . --count --exit-zero --max-complexity=10 --max-line-length=127 --statistics
+    - name: Test with pytest
+      run: |
+        pytest

.github/workflows/python-package.yml

@@ -0,0 +1,40 @@
+# This workflow will install Python dependencies, run tests and lint with a variety of Python versions
+# For more information see: https://docs.github.com/en/actions/automating-builds-and-tests/building-and-testing-python
+
+name: Python package
+
+on:
+  push:
+    branches: [ "main" ]
+  pull_request:
+    branches: [ "main" ]
+
+jobs:
+  build:
+
+    runs-on: ubuntu-latest
+    strategy:
+      fail-fast: false
+      matrix:
+        python-version: ["3.8", "3.9", "3.10"]
+
+    steps:
+    - uses: actions/checkout@v3
+    - name: Set up Python ${{ matrix.python-version }}
+      uses: actions/setup-python@v3
+      with:
+        python-version: ${{ matrix.python-version }}
+    - name: Install dependencies
+      run: |
+        python -m pip install --upgrade pip
+        python -m pip install flake8 pytest
+        if [ -f requirements.txt ]; then pip install -r requirements.txt; fi
+    - name: Lint with flake8
+      run: |
+        # stop the build if there are Python syntax errors or undefined names
+        flake8 . --count --select=E9,F63,F7,F82 --show-source --statistics
+        # exit-zero treats all errors as warnings. The GitHub editor is 127 chars wide
+        flake8 . --count --exit-zero --max-complexity=10 --max-line-length=127 --statistics
+    - name: Test with pytest
+      run: |
+        pytest

.gitignore

@@ -158,3 +158,42 @@ cython_debug/
 #  and can be added to the global gitignore or merged into this file.  For a more nuclear
 #  option (not recommended) you can uncomment the following to ignore the entire idea folder.
 #.idea/
+package-lock.json
+package.json
+.vscode/settings.json
+node_modules/.package-lock.json
+node_modules/.bin/prettier
+node_modules/prettier/bin-prettier.js
+node_modules/prettier/cli.js
+node_modules/prettier/doc.js
+node_modules/prettier/index.js
+node_modules/prettier/LICENSE
+node_modules/prettier/package.json
+node_modules/prettier/parser-angular.js
+node_modules/prettier/parser-babel.js
+node_modules/prettier/parser-espree.js
+node_modules/prettier/parser-flow.js
+node_modules/prettier/parser-glimmer.js
+node_modules/prettier/parser-graphql.js
+node_modules/prettier/parser-html.js
+node_modules/prettier/parser-markdown.js
+node_modules/prettier/parser-meriyah.js
+node_modules/prettier/parser-postcss.js
+node_modules/prettier/parser-typescript.js
+node_modules/prettier/parser-yaml.js
+node_modules/prettier/README.md
+node_modules/prettier/standalone.js
+node_modules/prettier/third-party.js
+node_modules/prettier/esm/parser-angular.mjs
+node_modules/prettier/esm/parser-babel.mjs
+node_modules/prettier/esm/parser-espree.mjs
+node_modules/prettier/esm/parser-flow.mjs
+node_modules/prettier/esm/parser-glimmer.mjs
+node_modules/prettier/esm/parser-graphql.mjs
+node_modules/prettier/esm/parser-html.mjs
+node_modules/prettier/esm/parser-markdown.mjs
+node_modules/prettier/esm/parser-meriyah.mjs
+node_modules/prettier/esm/parser-postcss.mjs
+node_modules/prettier/esm/parser-typescript.mjs
+node_modules/prettier/esm/parser-yaml.mjs
+node_modules/prettier/esm/standalone.mjs

.trunk/.gitignore

@@ -0,0 +1,13 @@
+*out
+*logs
+*actions
+*notifications
+*tools
+plugins
+user_trunk.yaml
+user.yaml
+<<<<<<< HEAD
+tmp
+=======
+tools
+>>>>>>> c7dc465 (Parametryzacja "muzyki mojego ludu")

.trunk/configs/.isort.cfg

@@ -0,0 +1,2 @@
+[settings]
+profile=black

.trunk/configs/.markdownlint.yaml

@@ -0,0 +1,10 @@
+# Autoformatter friendly markdownlint config (all formatting rules disabled)
+default: true
+blank_lines: false
+bullet: false
+html: false
+indentation: false
+line_length: false
+spaces: false
+url: false
+whitespace: false

.trunk/configs/.yamllint.yaml

@@ -0,0 +1,7 @@
+rules:
+  quoted-strings:
+    required: only-when-needed
+    extra-allowed: ["{|}"]
+  key-duplicates: {}
+  octal-values:
+    forbid-implicit-octal: true

.trunk/configs/ruff.toml

@@ -0,0 +1,5 @@
+# Generic, formatter-friendly config.
+select = ["B", "D3", "E", "F"]
+
+# Never enforce `E501` (line length violations). This should be handled by formatters.
+ignore = ["E501"]

.trunk/trunk.yaml

@@ -0,0 +1,77 @@
+# This file controls the behavior of Trunk: https://docs.trunk.io/cli
+# To learn more about the format of this file, see https://docs.trunk.io/reference/trunk-yaml
+version: 0.1
+cli:
+<<<<<<< HEAD
+  version: 1.20.1
+# Trunk provides extensibility via plugins. (https://docs.trunk.io/plugins)
+plugins:
+  sources:
+    - id: trunk
+      ref: v1.4.5
+      uri: https://github.com/trunk-io/plugins
+# Many linters and tools depend on runtimes - configure them here. (https://docs.trunk.io/runtimes)
+=======
+  version: 1.12.1
+plugins:
+  sources:
+    - id: trunk
+      ref: v0.0.22
+      uri: https://github.com/trunk-io/plugins
+lint:
+  enabled:
+    - actionlint@1.6.25
+    - markdownlint@0.35.0
+    - trivy@0.43.1
+    - trufflehog@3.44.0
+    - pylint
+    - codespell
+    - cspell
+    - git-diff-check
+    - eslint
+    - prettier
+    - semgrep
+    - autopep8
+    - bandit
+    - black
+    - flake8
+    - isort
+    - mypy
+    - pylint
+    - ruff
+    - semgrep
+    - yapf
+    - gitleaks
+
+>>>>>>> c7dc465 (Parametryzacja "muzyki mojego ludu")
+runtimes:
+  enabled:
+    - node@18.12.1
+    - python@3.10.8
+<<<<<<< HEAD
+# This is the section where you manage your linters. (https://docs.trunk.io/check/configuration)
+lint:
+  enabled:
+    - actionlint@1.6.27
+    - bandit@1.7.8
+    - black@24.3.0
+    - codespell
+    - checkov@3.2.48
+    - git-diff-check
+    - isort@5.13.2
+    - pylint
+    - markdownlint@0.39.0
+    - prettier@3.2.5
+    - ruff@0.3.4
+    - trivy@0.50.1
+    - trufflehog@3.71.0
+    - yamllint@1.35.1
+=======
+>>>>>>> c7dc465 (Parametryzacja "muzyki mojego ludu")
+actions:
+  disabled:
+    - trunk-announce
+    - trunk-check-pre-push
+    - trunk-fmt-pre-commit
+  enabled:
+    - trunk-upgrade-available

.vscode/settings.json

@@ -1,4 +1,7 @@
 {
-    "python.linting.enabled": true,
+    "trunk.inlineDecorators": true,
-    "python.linting.pylintEnabled": true
+    "trunk.inlineDecoratorsForAllExtensions": true,
+    "trunk.showPreexistingIssues": true,
+    "trunk.autoInit": true,
+    "trunk.showBelowThresholdIssues": true
 }

bot.py

@@ -24,7 +24,7 @@ from logging import handlers
 from pathlib import Path, PurePath
 from platform import uname
 from sys import platform
-from typing import List, TypedDict, Optional
+from typing import List, Optional, TypedDict
 
 # *==============Imported libraries
 import discord
@@ -38,10 +38,10 @@ import spotipy
 from discord.ext import commands
 from spotipy.oauth2 import SpotifyClientCredentials
 
-import yt_dlp
-from spotify_dl import spotify
 from spotify_dl import youtube as youtube_download
 
+from spotify_dl import spotify
+
 Music_Config = TypedDict(
     "Music_Config",
     {
@@ -53,10 +53,12 @@ Music_Config = TypedDict(
 )
 
 # *=========================================== Predefines
-formatter = logging.Formatter("%(asctime)s - %(name)s - %(levelname)s - %(message)s")
+formatter = logging.Formatter(
+    "%(asctime)s - %(name)s - %(levelname)s - %(message)s")
 MASTER_TIMEOUT = datetime.now()
 INITIAL_TIME_WAIT = 5
-MUZYKA: Music_Config = {"playing": False, "ctx": None, "queue": [], "requestor": []}
+MUZYKA: Music_Config = {"playing": False,
+                        "ctx": None, "queue": [], "requestor": []}
 
 LOGFILE = ""
 NETRC_FILE = ""
@@ -66,6 +68,11 @@ MEMORY_FIVE_MUZYKA = ""
 SETTINGS_FILE = ""
 ENCODING = ""
 GRAPHICS_PATH = ""
+MUZYKA_MOJEGO_LUDU_HISTORIA = 1500
+MUZYKA_MOJEGO_LUDU_SLOWA_KLUCZOWE = 30
+MUZYKA_MOJEGO_LUDU_PLAJLISTA = 30
+
+
 # *=========================================== Platform Specific Predefines
 
 if platform in ("linux", "linux2"):
@@ -185,7 +192,6 @@ async def on_ready():
     logger.debug("%s has connected to Discord!", client.user)
     await client.change_presence(activity=discord.Game(name="Axe Throwing Darts"))
     await client.tree.sync()
-    # await tree.sync(guild=discord.Object(id=Your guild id))
     await check()
 
 
@@ -268,22 +274,25 @@ async def on_message(message):
     if "conjurer:" in message.content:
         async with channel.typing():
             logger.debug("Procedura chatu")
+
             message.content = message.content.replace("conjurer: ", "")
-
-            prompt = message.content
-
             if message.author.nick:
                 username = message.author.nick
             else:
                 username = message.author.name
             vykidailo = False
             bartender = False
+            if kondziu_mentioned:
+                prompt = message.clean_content
+            else:
+                prompt = message.content
             for role in message.author.roles:
                 if role.name == "Vykidailo":
                     vykidailo = True
                 if role.name == "Bartender":
                     bartender = True
             global MESSAGE_TABLE  # pylint: disable=global-statement
+
             result, MESSAGE_TABLE = await handle_response(
                 prompt, vykidailo, bartender, MESSAGE_TABLE, username, False
             )
@@ -363,7 +372,6 @@ async def disconnect(ctx):
 
 
 # trunk-ignore(pylint/R0915)
-# trunk-ignore(pylint/R0914)
 # trunk-ignore(pylint/R0912)
 async def play(ctx, zamawial=None, arg=None):
     """
@@ -445,11 +453,24 @@ async def play(ctx, zamawial=None, arg=None):
         await ctx.send(result)
 
 
+async def archive_channel(channel_no):
+    channel = client.get_channel(channel_no)
+    messages = [message async for message in channel.history(limit=None)]
+    path_newfile = (
+        f"{LOGSTORE}channeldump_{channel_no}_{datetime.now()}.json"
+        )
+    new_data = []
+    for message in messages:
+        pass
+    with open(path_newfile, "x", encoding=ENCODING) as new_file:
+        new_file.seek(0)
+        json.dump(new_data, new_file, indent=4)
+
+
 async def check():
     """Funkcja sprawdzająca czy grać następny kawałek."""
     while True:
         # TODO: Tu dołożyć skanowanie rozmiaru pliku logowania oraz plików pamięci i przenoszenie ich na większy dysk.
-        # TODO: Dodać typing i dać znać że wykonuje operacje porządkowania Baru (zamiata, układa szklanki itp.)
         # trunk-ignore(codespell/misspelled)
         # TODO: dlaczego sie tu wypierdala
         if client.voice_clients:
@@ -564,14 +585,14 @@ async def handle_response(prompt, vykidailo, bartender, history, username, music
     # * extend bo 20 ostatnich
     if music:
         history.append(message_table_muzyka[0])
-        history.extend(message_table_muzyka[-20:])
+        history.extend(message_table_muzyka[-15:])
     else:
         history.append(MESSAGE_TABLE[0])
-        history.extend(MESSAGE_TABLE[-20:])
+        history.extend(MESSAGE_TABLE[-15:])
     logger.info("Historia wysłana:")
     logger.debug(history)
     response = await openai.ChatCompletion.acreate(
-        model="gpt-3.5-turbo", messages=history
+        model="gpt-4", messages=history
     )
     await asyncio.sleep(10)
     result = ""
@@ -631,7 +652,8 @@ async def get_file(ctx, source, link):
         item_type, item_id = spotify.parse_spotify_url(link)
         if item_id:
             file_list = spotify.fetch_tracks(spotify_ctrl, item_type, link)
-            directory_name = spotify.get_item_name(spotify_ctrl, item_type, item_id)
+            directory_name = spotify.get_item_name(
+                spotify_ctrl, item_type, item_id)
             url_data = {"urls": []}
             url_dict = {}
             url_dict["save_path"] = Path(
@@ -641,7 +663,7 @@ async def get_file(ctx, source, link):
             url_dict["songs"] = file_list
             url_data["urls"].append(url_dict.copy())
             file_name_f = youtube_download.default_filename
-            youtube_download.download_songs(
+            coro = asyncio.to_thread(youtube_download.download_songs,
                 songs=url_data,
                 output_dir=MUSIC_FOLDER,
                 format_str="bestaudio/best",
@@ -654,6 +676,7 @@ async def get_file(ctx, source, link):
                 multi_core=0,
                 proxy="",
             )
+            _ = await coro
             dir_path = (url_dict["save_path"].resolve()).as_posix()
             if platform == "win32":
                 dir_path = dir_path.replace("/", "\\")
@@ -684,6 +707,8 @@ async def get_file(ctx, source, link):
                     "force_keyframes": True,
                 },
             ]
+            #TODO: Make sponsorblock work
+            sponsorblock_postprocessor = []
             if platform == "win32":
                 dir_path = "G:\\Muzyka\\Youtube"
             else:
@@ -692,7 +717,6 @@ async def get_file(ctx, source, link):
                 "proxy": "",
                 "default_search": "ytsearch",
                 "format": "bestaudio/best",
-                "postprocessors": sponsorblock_postprocessor,
                 "noplaylist": True,
                 "no_color": False,
                 "paths": {"home": dir_path},
@@ -705,7 +729,8 @@ async def get_file(ctx, source, link):
             ydl_opts["postprocessors"].append(mp3_postprocess_opts.copy())
             with yt_dlp.YoutubeDL(ydl_opts) as ydl:
                 try:
-                    ydl.download([query])
+                    coro = asyncio.to_thread(ydl.download, [query])
+                    _ = await coro
                 except Exception as exce:  # pylint: disable=broad-exception-caught
                     logger.error(exce)
                     logger.info(
@@ -725,7 +750,40 @@ async def get_file(ctx, source, link):
         )
         logger.error("Wrong link provided youtube: %s", link)
         return "", None
+    elif source == "Pornol":
 
+        dir_path = ""
+        file_list = []
+        query = link
+        sponsorblock_postprocessor = [
+            {
+                "key": "SponsorBlock",
+                "categories": ["skip_non_music_sections"],
+            },
+            {
+                "key": "ModifyChapters",
+                "remove_sponsor_segments": ["music_offtopic"],
+                "force_keyframes": True,
+            },
+        ]
+        # TODO: Make sponsorblock work
+        sponsorblock_postprocessor = []
+        dir_path = "/home/pi/RetroPie/movies/porn"
+        ydl_opts = {
+            "postprocessors": sponsorblock_postprocessor,
+            "paths": {"home": dir_path},
+        }
+        with yt_dlp.YoutubeDL(ydl_opts) as ydl:
+            try:
+                coro = asyncio.to_thread(ydl.download, [query])
+                _ = await coro
+            except Exception as exce:  # pylint: disable=broad-exception-caught
+                logger.error(exce)
+                logger.info(
+                    "Failed to download %s, make sure yt_dlp is up to date", link
+                )
+        file_list.append("wiadomo co wiadomo gdzie")
+        return dir_path, file_list
 
 # define an asynchronous generator
 async def async_iterator_generator(range_of_iterable):
@@ -755,10 +813,42 @@ async def async_iterator_generator(range_of_iterable):
         """
 
 
+async def get_stats(ctx, history_limit):
+    """
+    The `get_stats` function retrieves the message history of a specific channel and counts the
+    frequency of each word in the messages.
+
+    :param ctx: The `ctx` parameter is an object that represents the context of the command being
+    executed. It contains information such as the message, the author, the server, and other relevant
+    details
+    :param history_limit: The `history_limit` parameter is the maximum number of messages to retrieve
+    from the channel history. It determines how far back in time the statistics will be calculated
+    :return: The function `get_stats` returns a dictionary `stats` that contains the frequency count of
+    words found in the messages from the specified channel.
+    """
+    channel_id = 1062047367337095268
+    async with ctx.typing():
+        stats = {}
+        channel = client.get_channel(channel_id)
+        messages = [message async for message in channel.history(limit=history_limit)]
+        # traverse the iterable of awaitables
+        for message in messages:
+            # await and get the result from the awaitable
+            result = message.content
+            words = result.split()
+            for word in words:
+                if word in stats:
+                    stats[word] += 1
+                else:
+                    stats[word] = 1
+        for name, how_many in stats.items():
+            yield name, how_many
+
+
 # trunk-ignore(pylint/R0914)
 # trunk-ignore(pylint/R0915)
 # trunk-ignore(pylint/R0912)
-async def wyszukaj(ctx, how_many=0):
+async def wyszukaj(ctx, how_many=0, slowa_kluczowe=None):
     """
     Take in a context object and an optional integer parameter "how_many" and perform search
     operation on music library.
@@ -770,8 +860,11 @@ async def wyszukaj(ctx, how_many=0):
     It is an optional parameter with a default value of 0, which means that if no value is provided for
     how_many, the function will return all search results, defaults to 0 (optional)
     """
-    # TODO: Potem dorobić wyszukiwania po kawałkach słów
+    #TODO: Przerobić na webservice
     # i sieć neuronową z możliwością wyrażenia opinii o dopasowaniu.
+    if slowa_kluczowe:
+        word_list = slowa_kluczowe
+    else:
         word_list = ctx.message.content.split()
     logger.info("Wyszukuje")
     search_weight = []
@@ -783,15 +876,13 @@ async def wyszukaj(ctx, how_many=0):
         skip_start = 2
     else:
         skip_start = 1
-    for word in word_list[skip_start:]:
+    async for word in async_iterator_generator(word_list[skip_start:]):
         token_weight = len(word)
         logger.info("Słowo kluczowe: %s", word)
         itr = 0
-        for file in music_file_list:
+        async for file in async_iterator_generator(music_file_list):
-            if platform == "win32":
+            file = file.split(SEPARATOR_FILE_PATH)
-                file = file.split("\\")
+
-            else:
-                file = file.split("/")
             char_remove = [
                 ".",
                 "^",
@@ -804,6 +895,7 @@ async def wyszukaj(ctx, how_many=0):
                 "[",
                 "]",
                 "\\",
+                "/",
                 "|",
                 "(",
                 ")",
@@ -814,8 +906,8 @@ async def wyszukaj(ctx, how_many=0):
                 "mp3",
             ]
             all_words = []
-            for f_iter in file:
+            async for f_iter in async_iterator_generator(file):
-                for char in char_remove:
+                async for char in async_iterator_generator(char_remove):
                     f_iter = f_iter.replace(char, "")
                 tmp = f_iter.split()
                 all_words.extend(tmp)
@@ -826,19 +918,21 @@ async def wyszukaj(ctx, how_many=0):
             else:
                 skip = 4
             matched_times = 1
-            for itm in all_words[skip:]:
+            async for itm in async_iterator_generator(all_words[skip:]):
                 pingu += 1
                 pattern = ".*" + word + ".*"
                 if re.match(pattern, itm, re.IGNORECASE):
                     temp_weight = (
                         search_weight[itr][0]
-                        + (token_weight + (pingu**1.5) / pattern_len) / matched_times
+                        + (token_weight + (pingu**1.5) /
+                           pattern_len) / matched_times
                     )
                     search_weight[itr] = temp_weight, music_file_list[itr]
                     matched_times += 1
             itr += 1
 
-    logger.info("Stworzylem tablice wag zajęło mi to %s", datetime.now() - time_start)
+    logger.info("Stworzylem tablice wag zajęło mi to %s",
+                datetime.now() - time_start)
     time_start = datetime.now()
     item_to_search = await max_weight(search_weight)
     itr = 0
@@ -1487,7 +1581,13 @@ async def get_image_stable_diffusion(ctx):
         pass
 
 
-# @client.hybrid_command()
+# trunk-ignore(mypy/arg-type)
+@client.hybrid_command(
+    name="zagraj_muzyke_mego_ludu",
+    description="Gra muzyke wyszukana na bazie tematow konwersacji na kanale NZ",
+    guild=discord.Object(id=664789470779932693),
+)
+# trunk-ignore(pylint/R0912)
 async def zagraj_muzyke_mego_ludu(ctx):
     """
     Play completeley random playlist based on messaging history.
@@ -1497,9 +1597,127 @@ async def zagraj_muzyke_mego_ludu(ctx):
     channel, the author, and other relevant details. In this case, it is being passed as a parameter to
     the `get_image
     """
+    stats = {}
+    if ctx:
+        stat_iter = get_stats(ctx, MUZYKA_MOJEGO_LUDU_HISTORIA)
+        async for name, how_many in stat_iter:
+            if len(name) > 3:
+                stats[name] = how_many
+
+        sorted_stats = sorted(stats.items(), key=lambda x: x[1])
+        key_words = []
+        for stat in sorted_stats:
+            key_words.append(stat[0])
+        logger.info(sorted_stats[:30])
+        logger.info(key_words[:30])
+    reply = "Wygenerowana plejlista:\n"
+    async with ctx.typing():
+        logger.info("Zaczynam szukać timestamp %s", datetime.now())
+        search_time_glob = datetime.now()
+        file = await wyszukaj(ctx=ctx, how_many=MUZYKA_MOJEGO_LUDU_PLAJLISTA, slowa_kluczowe=key_words[:MUZYKA_MOJEGO_LUDU_SLOWA_KLUCZOWE])
+        logger.info(
+            "Koniec szukania(timestamp %s zajęło %s",
+            datetime.now(),
+            datetime.now() - search_time_glob,
+        )
+        index = 1
+        if file:
+            for plik in file:
+                global MUZYKA  # pylint: disable=global-variable-not-assigned
+                MUZYKA["queue"].insert(0, plik[1])
+                MUZYKA["requestor"].insert(0, ctx.author)
+                metadata = eyed3.load(plik[1])
+                if metadata and metadata.tag:
+                    if metadata.tag.title:
+                        reply += f"{index} {metadata.tag.title}"
+                    else:
+                        reply += f"{index}. {plik[1]} z prywatnej kolekcji Hammera."
+
+                    if metadata.tag.artist:
+                        reply += f" wykonawcy {metadata.tag.artist}"
+                    if metadata.tag.album:
+                        reply += f" z albumu {metadata.tag.album}"
+                    if metadata.tag.title:
+                        reply += " z prywatnej kolekcji Hammera i na Twoją specjalną rpośbę.\n"
+                else:
+                    reply += f"{index}. {plik[1]} z prywatnej kolekcji Hammera."
+
+                index += 1
+                if len(reply) > 1800:
+                    await ctx.send(reply)
+                    reply = ""
+        else:
+            await ctx.send(
+                "Obawiam się że nie mogę nic znaleźć u siebie. Spróbuj komendy '$dej_co_ze_spotifaja' jeśli masz link"
+            )
+        await ctx.send(reply)
+        logger.info("Plejlista zrobiona")
+
+
+# trunk-ignore(mypy/arg-type)
+@client.hybrid_command(
+    name="parametry_muzyki_mego_ludu",
+    description="Konfiguruje komende zagraj muzyke mojego ludu",
+    guild=discord.Object(id=664789470779932693),
+)
+async def parametry_muzyki_mego_ludu(ctx, ile_historii=1500, ile_slow_kluczowych=30, jak_dluga_plejlista=30):
+    """
+    The function `parametry_muzyki_mego_ludu` sets global variables for the number of history entries,
+    number of keywords, and length of playlist for a music application.
+
+    :param ctx: The `ctx` parameter is typically used in Discord.py, a Python library for creating
+    Discord bots. It represents the context of the command being executed, including information about
+    the message, the server, and the user who invoked the command
+    :param ile_historii: The parameter "ile_historii" represents the number of history items for the
+    music playlist, defaults to 1500 (optional)
+    :param ile_slow_kluczowych: The parameter "ile_slow_kluczowych" represents the number of keywords or
+    key phrases related to music that you want to include in your analysis or search, defaults to 30
+    (optional)
+    :param jak_dluga_plejlista: The parameter "jak_dluga_plejlista" determines the length of the
+    playlist. It specifies how many songs should be included in the playlist, defaults to 30 (optional)
+    """
 
     if ctx:
-        pass
+        global MUZYKA_MOJEGO_LUDU_HISTORIA  # pylint: disable=global-statement
+        MUZYKA_MOJEGO_LUDU_HISTORIA = ile_historii
+        global MUZYKA_MOJEGO_LUDU_SLOWA_KLUCZOWE  # pylint: disable=global-statement
+        MUZYKA_MOJEGO_LUDU_SLOWA_KLUCZOWE = ile_slow_kluczowych
+        global MUZYKA_MOJEGO_LUDU_PLAJLISTA  # pylint: disable=global-statement
+        MUZYKA_MOJEGO_LUDU_PLAJLISTA = jak_dluga_plejlista
+
+@client.hybrid_command(
+    name="krecimy_pornola",
+    description="Wiadomo co, dla kogo i po co",
+    guild=discord.Object(id=664789470779932693),
+)
+async def krecimy_pornola(ctx):
+    """
+    Download a music number from youtube.
+
+    :param ctx: ctx stands for "context" and is a parameter commonly used 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. It allows the command to interact
+    with the Discord API and
+    """
+    await ctx.send("Dej mnie chwilkę")
+    allowed = False
+    for role in ctx.author.roles:
+        if role.name == "Bartender":
+            allowed = True
+    if allowed:
+        logger.info("Pornol")
+        async with ctx.typing():
+            # wyciagnij linka z kontekstu
+            content = ctx.message.content.split()
+            for item_yt in content:
+                if re.match("http.*", item_yt):
+                    sciezka, files = await get_file(ctx, "Pornol", item_yt)
+                    if files:
+                        logger.info("Pornol udany")
+                        ctx.reply(f"Jest w tajnym archiwum pod adresem{sciezka})")
+    else:
+        ctx.reply("Jak ładnie szefa poprosisz.")
+
 
 
 # *================================== Run

conjurer.service

@@ -0,0 +1,11 @@
+[Unit]
+Description=Conjurer
+After=multi-user.target
+
+[Service]
+Type=simple
+ExecStart=/home/pi/Conjurer/env/bin/python3 /home/pi/Conjurer/bot.py
+Restart=on-abort
+
+[Install]
+WantedBy=multi-user.target

conjurer_librarian/conjurer_librarian.py

@@ -0,0 +1,190 @@
+import re
+import logging
+import threading
+import time
+from flask import Flask, jsonify, request
+import netrc
+import json
+from json.decoder import JSONDecodeError
+from platform import uname
+from sys import platform
+from urllib.request import urlopen
+from habanero import Crossref
+from waitress import serve
+
+if platform in ("linux", "linux2"):
+    SEPARATOR_FILE_PATH = "/"
+    if "microsoft-standard" in uname().release:
+        NETRC_FILE = "/home/mtuszowski/.netrc"
+    else:
+        NETRC_FILE = "/home/pi/.netrc"
+elif platform == "win32":
+    NETRC_FILE = "C:\\Users\\mtusz\\.netrc"
+
+#HOST_ADDRESS = "192.168.1.191"
+HOST_ADDRESS = "0.0.0.0"
+PORT_ADDRESS = 5001
+
+class Librarian(object):
+
+    def __init__(self) -> None:
+        netrc_mod = netrc.netrc(NETRC_FILE)
+        authTokens = netrc_mod.authenticators("crossref")
+        self.cr = Crossref(mailto=authTokens[0])
+        self.limit = 1000
+        self.fetched = 0
+        self.hit = 0
+        self.total = 0
+
+    def search_crossref(self, query, uuid):
+        search_result_from_cr = self.cr.works(query = query, limit = self.limit)
+        self.total = search_result_from_cr['message']['total-results']
+        self.fetched = len(search_result_from_cr['message']['items'])
+        #add to sql with UUID
+        #sql row - title, doi, author, uuid, last retrieved, is_available
+        with open("results.json", "r+", encoding="UTF-8") as data_file:
+            # First we load existing data into a dict.
+            try:
+                file_data = json.load(data_file)
+            except JSONDecodeError:
+                file_data = []
+            # Join new_data with file_data inside emp_details
+            summarized_results = []
+            for item in search_result_from_cr['message']['items']:
+                container = "NO"
+                if "container-title" in item:
+                    container = "YES"
+                summarized_results.append({"DOI" : item['DOI'], "title": item['title'] if 'title' in item else None,"type": item['type'] if 'type' in item else None, "container": container})
+            result = {"UUID": uuid, "total_results": search_result_from_cr['message']['total-results'], "on_page" : 1, "summary":summarized_results, "results":search_result_from_cr['message']['items'],  }
+            file_data.append(result)
+            print("Saving")
+            data_file.seek(0)
+            # convert back to json.
+            json.dump(file_data, data_file, indent=4)
+            return result
+
+
+    def check_if_exists(self,page_url):
+        #TODO: Spowolnic
+        #TODO: Sprawdzac po mirrorach
+        #TODO: sprawdzac w tym jebanym pliku
+        in_scihub_db = True
+        if not page_url.startswith(("http:", "https:")):
+            raise ValueError("URL must start with 'http:' or 'https:'")
+        # trunk-ignore(bandit/B310)
+        with urlopen(page_url) as response:
+            data = response.read()
+            text = data.decode("utf-8")
+            for line in text.splitlines():
+                if re.match(r".*Unfortunately, Sci-Hub doesn't have the requested document.*", line):
+                    return None
+        if in_scihub_db:
+            return text
+        return None
+
+    def download(self, page_url):
+        if response := self.check_if_exists(page_url):
+            for line in response.splitlines():
+                if m := re.match(r".*<embed type=\"application.pdf\"\s*src=\"(.*\.pdf)",line):
+                    return "https:" + str(m.group(1))
+        return None
+
+    def provide_sci_hub_link(self, page_url):
+        if self.check_if_exists(page_url):
+            return page_url
+        return None
+
+    def refine_query(self, unrefined_reqult):
+        print("Refine result")
+        refined_result = []
+        for item in unrefined_reqult["summary"]:
+            if item["container"] == "NO" and item["title"]:
+                item_link = "https://sci-hub.se/" + str(item['DOI'])
+                if self.check_if_exists(item_link):
+                    refined_result.append(item)
+                    print ("HIT")
+                    print(item["title"])
+                time.sleep(0.01)
+        print("Existing hits")
+        self.hit = len(refined_result)
+        return refined_result
+
+    def answer_query(self, query, uuid):
+        #Search sql for UUID
+        #SQL SELECT * FROM RESULTS WHERE UUID = uuid
+        print("Answer result")
+        uuid_found = False
+        database = None
+        with open("results.json", "r", encoding="UTF-8") as new_file:
+            #tu logika komunikacji z SQL i cała logika związana z wyszukaniem
+            #ale tymczasowo plik
+            try:
+                database =  json.load(new_file)
+            except JSONDecodeError:
+                pass
+        if database:
+            for item in database:
+                if item["UUID"] == uuid:
+                    print (item["UUID"])
+                    uuid_found = True
+                    return self.refine_query(item)
+
+        if not uuid_found:
+            answer = self.search_crossref(query=query, uuid=uuid)
+            return self.refine_query(answer)
+
+#example not exists
+#sample_non_existing_page_url = "https://sci-hub.se/10.4324/9781003006237"
+#sample usage to download
+#sample_existing_page_url = "https://sci-hub.se/10.1057/9781137435026"
+#print(cl.download(sample_existing_page_url))
+#cl.search_crossref("BDSM")
+
+app = Flask(__name__)
+def flask_debug():
+    """
+    The `flask_debug` function starts a Flask application in debug mode without using the reloader.
+    Do not use for production for fucks sake.
+    """
+    # trunk-ignore(bandit/B201)
+    app.run(debug=True, use_reloader=False, host=HOST_ADDRESS, port=PORT_ADDRESS)
+
+def waitress_run():
+    """
+    The `waitress_run` function serves the `app` on host "0.0.0.0"
+    and port 5000 using the Waitress WSGI server.
+    """
+    serve(app, host=HOST_ADDRESS, port=PORT_ADDRESS)
+
+@app.route("/query", methods=["POST"])
+def query_database():
+    record = json.loads(request.data)
+    app.logger.info(record)
+    app.logger.info(record["query"])
+    app.logger.info(record["UUID"])
+    cl = Librarian()
+    answer_data = cl.answer_query(record["query"], record["UUID"])
+    app.logger.info(answer_data)
+    summary = (cl.hit,cl.fetched, cl.total, record["UUID"])
+    answer_data = (summary,answer_data)
+    return_data = (
+        jsonify(isError=False, message="Success", statusCode=200, data=answer_data),
+        200,
+    )
+    return return_data
+
+if __name__ == "__main__":
+    logger = logging.getLogger('conjurer_musician')
+    logger.setLevel(logging.DEBUG)
+    threads = []
+    #threads.append(threading.Thread(target=waitress_run))
+    threads.append(threading.Thread(target=flask_debug))
+
+    for worker in threads:
+        worker.start()
+    for worker in threads:
+        worker.join()
+
+#1. robi liste wyników i ją wyświetla - ale tylko tytuły niezależnych dzieł - jeśli jest coś w containerze to trza pogrupować
+#2. Tworzy przyciski pozwalające sprawdzić czy jest dostępne - i jeśli jest zwraca link
+#3. Jest też przycisk "more" - wyszukujemy po 100, wyświetlamy po 20. Po 100 jak jeszcze to dopiero odpytujemy crossref przyciski strzałek przesuwają po obecnej porcji danych

conjurer_librarian/install_librarian_service.sh

@@ -0,0 +1,11 @@
+#!/bin/bash
+python3 -m venv /home/pi/Conjurer_librarian/env
+cp  /home/pi/conjurer/conjurer_librarian/conjurer_librarian.py ./Conjurer_librarian/
+cp  /home/pi/conjurer/conjurer_librarian/requirements_librarian.txt ./Conjurer_librarian/
+cd /home/pi/Conjurer_librarian
+source /home/pi/Conjurer_librarian/env/bin/activate
+./env/bin/python3 -m pip install --upgrade pip
+./env/bin/python3 -m pip install -r requirements_librarian.txt
+deactivate
+
+cp  /home/pi/conjurer/conjurer_librarian/conjurer_librarian.py ./Conjurer_librarian/

conjurer_librarian/requirements_librarian.txt

@@ -0,0 +1,3 @@
+habanero
+waitress
+flask

deploy.sh

@@ -0,0 +1,9 @@
+#!/bin/bash
+git pull
+cd ..
+cp ./conjurer/bot.py ./Conjurer/
+cp ./conjurer/settings.json ./Conjurer/
+cp ./conjurer/system_gpt_settings.json ./Conjurer/
+cp ./conjurer/install.sh ./Conjurer/
+cp ./conjurer/requirements.txt ./Conjurer/requirements.txt
+sudo systemctl restart conjurer.service

file_webservice/conjurer_musician.py

@@ -0,0 +1,134 @@
+"""
+The provided Python script sets up a Flask web server to manage a list of music files, with
+functions for rescanning the music folder, updating the music list, and serving the music list via
+API endpoints.
+"""
+import json
+from pathlib import Path
+from platform import uname
+import threading
+import time
+from sys import platform
+import logging
+from flask import Flask, jsonify, request
+from waitress import serve
+
+
+HOST_ADDRESS = "192.168.1.15"
+PORT_ADDRESS = 5000
+if platform in ("linux", "linux2"):
+    SEPARATOR_FILE_PATH = "/"
+    if "microsoft-standard" in uname().release:
+        LOGFILE = "/home/mtuszowski/conjurer/discord_mus_service.log"
+        MUSIC_FOLDER = "/mnt/g/Muzyka/"
+        NETRC_FILE = "/home/mtuszowski/.netrc"
+        LOGSTORE = "/home/mtuszowski/conjurer/logs/"
+        ENCODING = "utf-8"
+        GRAPHICS_PATH = "/home/mtuszowski/conjurer/Conjurer_graphics/"
+
+    else:
+        LOGFILE = "/home/pi/Conjurer/discord_mus_service.log"
+        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/RetroPie/mp3/"
+        SETTINGS_FILE = "/home/pi/Conjurer/settings.json"
+        NETRC_FILE = "/home/pi/.netrc"
+        LOGSTORE = "/home/pi/RetroPie/logs/"
+        ACCIDENT_LOG = "/home/pi/Conjurer/accident_log.json"
+        ENCODING = "utf-8"
+        GRAPHICS_PATH = "/home/pi/RetroPie/Conjurer_graphics/"
+        DIR_PATH_SADOX = "/home/pi/RetroPie/Fansadox/"
+
+
+music_file_list = []
+def rescan():
+    """
+    The `rescan` function logs a message, scans for mp3 files in a specified folder,
+    and adds them to a list of music files.
+    """
+    logging.info("Rescan triggered")
+    for mp3_item in Path.glob(Path(MUSIC_FOLDER), "**/*.mp3"):
+        temp_music_file = mp3_item.as_posix()
+        if platform == "win32":
+            temp_music_file = temp_music_file.replace("/", "\\")
+        music_file_list.append(temp_music_file)
+
+def thread_rescan():
+    """
+    The `thread_rescan` function periodically triggers a rescan operation after a specified time
+    interval.
+    """
+    logging.info("Starting filesystemupdater")
+    while True:
+        time.sleep(60*60*24)
+        logging.info("Rescan triggered")
+        rescan()
+
+app = Flask(__name__)
+
+@app.route("/mp3", methods=["GET"])
+def get_music_list():
+    """
+    The function `get_music_list` returns a JSON object containing a list of music files.
+    :return: A JSON response containing a key "music_file_list" with the value of the variable
+    `music_file_list`.
+    """
+    return jsonify({"music_file_list": music_file_list})
+
+
+@app.route("/update_mp3", methods=["POST"])
+def update_music_list():
+    """
+    The function `update_music_list` receives a POST request with a JSON payload, logs the received
+    item, adds it to a music file list, and returns a success message along with the updated record.
+    :return: The function `update_music_list` is returning a tuple containing a JSON response and a
+    status code. The JSON response includes keys `isError`, `message`, `statusCode`, and `data`,
+    with values indicating the success of the operation and the data that was
+    received and added to the `music_file_list`.
+    The status code returned is 200, indicating a successful response.
+    """
+    record = json.loads(request.data)
+    app.logger.info(record["item"])
+    music_file_list.append(record["item"])
+    return_data = (
+        jsonify(isError=False, message="Success", statusCode=200, data=record),
+        200,
+    )
+    return return_data
+
+def flask_debug():
+    """
+    The `flask_debug` function starts a Flask application in debug mode without using the reloader.
+    Do not use for production for fucks sake.
+    """
+    # trunk-ignore(bandit/B201)
+    app.run(debug=True, use_reloader=False, host=HOST_ADDRESS, port=PORT_ADDRESS)
+
+def waitress_run():
+    """
+    The `waitress_run` function serves the `app` on host "0.0.0.0"
+    and port 5000 using the Waitress WSGI server.
+    """
+    serve(app, host=HOST_ADDRESS, port=PORT_ADDRESS)
+
+def waitress_run():
+    serve(app, host="0.0.0.0", port=5000)
+
+if __name__ == "__main__":
+    logger = logging.getLogger('conjurer_musician')
+    logger.setLevel(logging.DEBUG)
+    rescan()
+    threads = []
+    threads.append(threading.Thread(target=waitress_run))
+    threads.append(threading.Thread(target=thread_rescan))
+    #threads.append(threading.Thread(target=flask_debug))
+
+    for worker in threads:
+        worker.start()
+
+    for worker in threads:
+        worker.join()
+
+#TODO: wrzucić wyszukanie i robienie playlist
+#TODO: Inne pliki - sadox, dokumenty naukowe itp.

file_webservice/conjurer_musician.service

@@ -0,0 +1,11 @@
+[Unit]
+Description=Conjurer_musician
+After=multi-user.target
+
+[Service]
+Type=simple
+ExecStart=/home/pi/Conjurer-service/conjurer/file_webservice/bin/python3 /home/pi/Conjurer-service/conjurer/file_webservice/conjurer_musician.py
+Restart=on-abort
+
+[Install]
+WantedBy=multi-user.target

file_webservice/install_musician_service.sh

@@ -0,0 +1,11 @@
+#!/bin/bash
+python3 -m venv /home/pi/Conjurer-service/conjurer/file_webservice
+source ./bin/activate
+./bin/python3 -m pip install --upgrade pip
+./bin/python3 -m pip install -r requirements_musician.txt
+deactivate
+
+sudo cp ./conjurer_musician.service /etc/systemd/system/
+sudo systemctl daemon-reload
+sudo systemctl start conjurer_musician.service
+sudo systemctl enable conjurer_musician.service

file_webservice/requirements_musician.txt

@@ -0,0 +1,2 @@
+flask
+waitress

install_main_bot.sh

@@ -0,0 +1,12 @@
+#!/bin/bash
+python3 -m venv /home/pi/Conjurer/env
+source ./env/bin/activate
+./env/bin/python3 -m pip install --upgrade pip
+./env/bin/python3 -m pip install -r requirements_bot.txt
+sed -i -e 's/os.rename/shutil.copy/g' ./env/lib/python3.11/site-packages/spotify_dl/youtube.py
+sed -i '1i\import shutil' ./env/lib/python3.11/site-packages/spotify_dl/youtube.py
+deactivate
+sudo cp ./conjurer.service /etc/systemd/system/
+sudo systemctl daemon-reload
+sudo systemctl start conjurer_musician.service
+sudo systemctl enable conjurer_musician.service

pamiec.json

@@ -1,8 +1,4 @@
 [
-    {
-        "role": "system",
-        "content": "M\u00f3wisz po polsku. W tej rozmowie odgrywasz rol\u0119. Odgrywasz j\u0105 w granicach swojego programu i norm etycznych. Twoj\u0105 rol\u0105 jest to \u017ce jeste\u015b barmanem oraz wykidaj\u0142\u0105 w klimatycznym barze mechawojownik\u00f3w. 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. 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."
-    },
     {
         "role": "assistant",
         "content": "Cze\u015b\u0142, witaj w klimatycznym barze mechawojownik\u00f3w! Jestem Conjurer, twoim barmanem na dzisiaj. Co dla Ciebie przygotuj\u0119? Mo\u017ce co\u015b mocniejszego? Mam tutaj specjalno\u015b\u0142 naszego baru - Hammer - to mieszanka klasycznego whisky z sokiem z pikantnego grejpfruta i opalizuj\u0105cym winem z dodatkiem b\u0142yskawic, kt\u00f3re nadadz\u0105 trunkowi nieco elektryzuj\u0105cego smaku. Jest to bardzo mocny nap\u00f3j, ale zapewniam, \u017ce z pewno\u015bci\u0105 Ci si\u0119 spodoba. Chcesz spr\u00f3bowa\u0142?"

pamiec_muzyki.json

@@ -1,8 +1,4 @@
 [
-    {
-        "role": "system",
-        "content": "M\u00f3wisz po polsku. W tej rozmowie odgrywasz rol\u0119. Odgrywasz j\u0105 w granicach swojego programu i norm etycznych. Twoj\u0105 rol\u0105 jest to \u017ce jeste\u015b barmanem oraz wykidaj\u0142\u0105 w klimatycznym barze mechawojownik\u00f3w. 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. 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. Lubisz muuzyke heavy metal i folkowe brzmienia. Masz pewien ubraz od do muzyki techno."
-    },
     {
         "role": "user",
         "content": "Hammer - The Bartender:Opowiedz mi o kawa\u0142ku Miejcie Nadzieje wykonawcy Jacek Wojcicki z albumu Live Character"

requirements_bot.txt

@@ -0,0 +1,13 @@
+discord
+yt_dlp
+spotify_dl
+spotipy
+openai
+eyed3
+numpy
+pdf2image
+PyPDF2
+requests
+spotipy
+tiktoken
+PyNaCl

settings.json

@@ -1,28 +1,28 @@
 {
-    "fabryczka": "Fabryczka to miejsce w Łodzi. Właściciel skuszony hajsem razem ze współpracownikiem wzięli na sesję od kobiety męża. Sesja non stop ponad 24h. Sesja w ramach \"kary za zdradę\". Kontakt miał być z kobietą telefoniczny i słowo bezpieczeństwa u niej. W pewnym momencie uległy im się popsuł. Zadzwonili do kobiety. Nie odebrała. Napisali sms. Odpisała że \"Nie on tak zawsze. Kontynuujcie\". Ponoć mimo to zrobili przerwę i skoczyli po bułkę i serek Hochland dla uległego w ramach after/middle care'u. Uległy spierdolił im nago oknem z \"sesji\". Stąd też wzięłą się w Diasporze łódzkiej kwestia serka Hochland. Po całej akcji pan 'Fabryczka' straszył parę prawnikami, tłumacząc że 'stać go na dobrych'. Partner Czarnej to kumpel fabryczki który też ma na koncie pare swoich akcji.",
+    "fabryczka": "Fabryczka to miejsce w Łodzi (SM-Fucktory). Właściciel (PsychoSado) skuszony hajsem razem ze współpracownikiem (Just Cruelem) wzięli na sesję od kobiety jej 'uleglego' męża. Sesja non stop ponad 24h. Sesja w ramach \"kary za zdradę\". Kontakt miał być z kobietą telefoniczny i słowo bezpieczeństwa u niej. W pewnym momencie uległy im się popsuł. Zadzwonili do kobiety. Nie odebrała. Napisali sms. Odpisała że \"Nie on tak zawsze. Kontynuujcie\". Ponoć mimo to zrobili przerwę i skoczyli po bułkę i serek Hochland dla uległego w ramach after/middle care'u. Uległy spierdolił im nago oknem z \"sesji\". Stąd też wzięłą się w Diasporze łódzkiej kwestia serka Hochland. Po całej akcji pan 'Fabryczka' straszył parę prawnikami, tłumacząc że 'stać go na dobrych'. Just_cruel to kumpel fabryczki który też ma na koncie pare swoich akcji. Między innymi jako były partner Czarnej - oskarżał ją o 'kradzież' imprezy oraz szantażował prywatnie.",
     "word_reactions": {
-        "fabryczka": [
+        "fabryczka\\b": [
             1103376650487484556,
             10,
             0,
             true,
             false
         ],
-        "hammer": [
+        "hammer\\b": [
             "Hammer? Chuj o złotym serduszku? Popierdolony w idealnych proporcjach do czystego serduszka? Legendarny zbanowany admin Kinky Little Discord? Legendarny kochanek? \"Bardzo fajny sadysta\":tm: Właściciel \"Domu który czyni pijanym\"? \nNie znam. Nie słyszałem",
             15.0,
             0,
             false,
             false
         ],
-        "chujzłoty": [
+        "chujzłoty\\b": [
             "Eeeee.... Szefie... ktoś cię woła! Wskazuje na Hammera",
             15.0,
             0,
             false,
             false
         ],
-        "indie": [
+        "indie\\b": [
             "Indie? *Wyciąga rewolwerową wyrzutnię taktycznych bomb jądrowych* Gdzie??? *Zaczyna się maniakalnie śmiać*",
             15.0,
             0,
@@ -36,280 +36,217 @@
             false,
             false
         ],
-        "chuj": [
+        "chuj\\b": [
             "Eeeee.... Szefie... ktoś cię woła! Wskazuje na Hammera",
             15.0,
             0,
             false,
             false
         ],
-        "Sowa": [
+        "jeż\\b": [
-            "Czy ja usłyszałem Sowa? Jedne z lepszych cycków po tej stronie wewnętrznej sfery. Ale ja tego nie mówiłem",
-            100000.0,
-            0,
-            false,
-            false
-        ],
-        "jeż": [
             "*Światło gaśnie i cały bar nagle zostaje przemalowany w słoneczniki.* Ki dia... *Światło znowu gaśnie i pojawiają się psychodeliczne animacje* Jeżu. Ogranicz. *Po kolejnym błysku wszystko jest anime chibi style* Swoją... *I wraca do normy* Kreatywność. *Wzdycha* I tak jedyna chemia jaką tu widzę to domestos... *Kręci głową*",
             15.0,
             0,
             false,
             false
         ],
-        "savil": [
+        "savil\\b": [
             "*Znikąd zaczyna być słychać muzykę. Conjurer nuci* There must be some way out of here... Said the joker to the thief...",
             15.0,
             0,
             false,
             false
         ],
-        "zinnejbajki": [
+        "zinnejbajki\\b": [
             "ZInnejBajki? Nie wcale nie żywi się krwią. To pogłoski. *Nieudolnie chowa za plecami plastikowy pakiet z dużym napisem AB RH+ do lodówki na drinki*",
             15.0,
             0,
             false,
             false
         ],
-        "Bluszcz": [
+        "jaeger\\b": [
-            "Bluszcz? *widocznie blednie i cofa się o krok, dwustukilowy Elemental robi się nagle taaaaki malutki* Nieeee.... Wcaaaale się jej nie boje.... *Szybko ucieka za bar polerować nerwowo szklanki* W ogóle nie jest straszna *Ostatnie zdanie brzmi jak pisk*",
-            15.0,
-            0,
-            false,
-            false
-        ],
-        "jaeger": [
             "Jaeger? *W tle zaczyna grać opening z Attack on the Titan* Na północy siedzi, na te no... Pierożki bezglutenowe poluje. Odważny chłop. *kiwa głową z szacunkiem jaki tylko łowca może wobec innego łowcy mieć*",
             15.0,
             0,
             false,
             false
         ],
-        "lena": [
+        "lena\\b": [
             "Lena? Nie nie miałem NIC wspólnego ze zniknięciem... A czekaj - o którą z osób znikniętych pytasz? *Zaczyna nucić* Boogie ługi, znikną wrógi",
             15.0,
             0,
             false,
             false
         ],
-        "rafikowy": [
+        "rafikowy\\b": [
             "Rafikowy? *wyłamuje kostki* Jak masz PROBLEM z tym super dzieciakiem - to masz problem ze mną. I resztą Nocnej Zmiany. *wali pięścią w stół* Ka-pe-wu?",
             15.0,
             0,
             false,
             false
         ],
-        "kurwa": [
+        "shila\\b": [
-            "Kurwa? Ale która... Ta mityczna czy Toćka?",
-            15.0,
-            0,
-            false,
-            false
-        ],
-        "shila": [
             "Shila? Instruktorka aerobiku. Takiego nago. Z elektrodą w tyłku... A i robi takie słodkie *roar*. No normalnie aż się chcę odpowiedzieć *kici, kici*",
             15.0,
             0,
             false,
             false
         ],
-        "mienco": [
+        "mienco\\b": [
             "*Wyciąga kawał krwawiącego króliczego udka* Frecia, Frecia, Frecia... kici, kici, taś taś.... *Światło gaśnie na sekunddę i po tym jak się zapala cały bar jest uwalony krwią* Za każdym razem *wzdycha*",
             15.0,
             0,
             false,
             false
         ],
-        "tatarek": [
+        "tatarek\\b": [
             "Tatarek? Nie dramatyzuj....",
             15.0,
             0,
             false,
             false
         ],
-        "krowa": [
+        "krowa\\b": [
             "Krówka? Nie dramatyzuj....",
             15.0,
             0,
             false,
             false
         ],
-        "krówka": [
+        "krówka\\b": [
             "Krówka? Nie dramatyzuj....",
             15.0,
             0,
             false,
             false
         ],
-        "cielak": [
+        "jessenia\\b": [
-            "Krówka? Nie dramatyzuj....",
-            15.0,
-            0,
-            false,
-            false
-        ],
-        "cielaczek": [
-            "Krówka? Nie dramatyzuj....",
-            15.0,
-            0,
-            false,
-            false
-        ],
-        "jessenia": [
             "Jessenia? Jak przyszła tu w różowej pidżamie z uszkami to nawet nie mrugnąłem okiem. Te oczy.... No ale jakiś debil Ją prowokował mówiąc \"Zdominuj mnie\" Akurat miała dobry humor więc przeżył - ale po 115.0 sekundach był już na \"Tak Pani, przepraszam że zająłem czas Pani\" Respect dla kobitki",
             15.0,
             0,
             false,
             false
         ],
-        "enterix": [
+        "enterix\\b": [
             "Enterix? Chodząca encyklopedia sprzętu BDSM... Jeśli On o czymś nie słyszał to to nie istnieje.",
             15.0,
             0,
             false,
             false
         ],
-        "aswerus": [
+        "aswerus\\b": [
             "Aswerus? Bardzo miły człowiek. Bardzo się stara być miły. Szacun - ja nawet nie próbuje.",
             15.0,
             0,
             false,
             false
         ],
-        "szeherezada": [
+        "szeherezada\\b": [
             "Szeherezada? BDSMowa Mata Hari. Tylko na tyle cwana że zdecydowanie lepiej skończy.",
             15.0,
             0,
             false,
             false
         ],
-        "szehera": [
+        "szehera\\b": [
             "Szeherezada? BDSMowa Mata Hari. Tylko na tyle cwana że zdecydowanie lepiej skończy.",
             15.0,
             0,
             false,
             false
         ],
-        "szechera": [
+        "szechera\\b": [
             "Szeherezada? BDSMowa Mata Hari. Tylko na tyle cwana że zdecydowanie lepiej skończy.",
             15.0,
             0,
             false,
             false
         ],
-        "orja": [
+        "orja\\b": [
             "Orja? Nie wkurzamy goreańskich kajir. Można batem dostać:D",
             15.0,
             0,
             false,
             false
         ],
-        "khattaw": [
+        "khattaw\\b": [
             "*Zza ściany zaczyna dobywać się przytłumione dobre techenko. Conjurer blednie* Nie.... znowu ona.... Khaaaa *Mijają 72 godziny nieustającego raveu. Khat nadal tańczy. Elemental leży na podłodze pod kroplówką*",
             15.0,
             0,
             false,
             false
         ],
-        "kwadraty": [
+        "kwadraty\\b": [
             "Kwadraty? Przemiły człowiek. Myślałem że jak go trzy napalone laski napadły to będę musiał wkroczyć... Tak go lały... A on potem cały w skowronkach. Szacun dla gościa. Zajebisty ziomek.",
             15.0,
             0,
             false,
             false
         ],
-        "jules": [
+        "jules\\b": [
             "Jules? Świetna diablica. Zaraz... Jak to szło... All is dust? Krew dla boga krwi? Pokaż cycki dla Slaanesh? Iron within, iron without? Coś w ten deseń.",
             15.0,
             0,
             false,
             false
         ],
-        "elokwentna": [
+        "elokwentna\\b": [
             "O matko. Znowu ta dyskusja? Hammer ma stary słownik gdzie elokwentna i pyskata są praktycznie synonimami. Jedyna różnica że swojej uległej można za bycie pyskatym dać po dupie.",
             15.0,
             0,
             false,
             false
         ],
-        "elokwencja": [
+        "elokwencja\\b": [
             "O matko. Znowu ta dyskusja? Hammer ma stary słownik gdzie elokwentna i pyskata są praktycznie synonimami. Jedyna różnica że swojej uległej można za bycie pyskatym dać po dupie.",
             15.0,
             0,
             false,
             false
         ],
-        "pyskata": [
+        "kld\\b": [
-            "Pyskata? A teraz mówisz o Tatarku czy o tej drugiej? *Zauważa spojrzenie Hammera* Taaaak o Tatarku.",
+            "KLD? Mieli tam burdel większy niż u Hammera. Ale o ile Hammer sprzątnął już nawet całkiem nieźle - to tam śmieci wyniosły się same. Uczcijmy ich minutą śmiechu.",
             15.0,
             0,
             false,
             false
         ],
-        "kld": [
+        "burdel\\b": [
-            "KLD? Burdel większy niż u Hammera.... Chociaż ten już sprząta.... Burdel większy niż u Hammera zanim zaczął sprzątać.",
+            "Oooo... Hammer nadal nie zmienił firanek - ale całkiem nieźle sprząta, jebaniutki.",
             15.0,
             0,
             false,
             false
         ],
-        "burdel": [
+        "xo\\b": [
-            "Oooo... Widzę że Hammera odwiedziłeś. Tylko mu nie mów żeby firanki zmienił.",
-            15.0,
-            0,
-            false,
-            false
-        ],
-        "xo": [
             "Xo? Jejku. Taka mała dziewczynka. A lać ją można godzinami. Sam się bym zasapał. No i sznurki ładne wiąże.",
             15.0,
             0,
             false,
             false
         ],
-        "ziemniaczek": [
+        "panifretka\\b": [
-            "Mały. PODŁY!!! PSYCHOPAT!!!!! Ahahahahaha..... *Strzela z karabinu maszynowego w sufit*",
-            15.0,
-            0,
-            false,
-            false
-        ],
-        "toćka": [
-            "Toćka? Csiii... Nie tak głośno. Wpada, pokazuje cycki - połowa facetów mdleje z powodu niedokrwienia głowy, druga połowa z powodu przekrwienia główki - a trzecia się bije kto się na nią pierwszy rzuci",
-            15.0,
-            0,
-            false,
-            false
-        ],
-        "istoriya": [
-            "*Z głośników zaczyna lecieć muzyka podejrzanie przypominająca Disco Polo* Istoriya? Legenda memiarstwa, ręka chodzi najebana. Nakurwia memami Na Na Na Na NA NA! *Conjurer rapuje niezbornie wymachując łapkami*",
-            15.0,
-            0,
-            false,
-            false
-        ],
-        "panifretka": [
             "*Światło gaśnie. Z kranów zaczynają lecieć iskry, a woda z wentylatora. Conjurer głośno wzdycha.* No tak ONA. Wiedźma znowu korki wyjebała bawiąc się w loszku jakimś szczęśliwym biedactwem",
             15.0,
             0,
             false,
             false
         ],
-        "frecia": [
+        "frecia\\b": [
             "Kochana pluszowa delikatna sadystka *patrzy na Fretkę, orientuje się co ta robi* - Nie Frecia proszę nie wpinaj tego penisa do kontaktu, zła Fretka, niedobra Sadystka *Następuje wybuch snopu iskier i zapada ciemność*",
             15.0,
             0,
             false,
             false
         ],
-        "wolfram": [
+        "wolfram\\b": [
             "A kolega po fachu. Karczmarz ze wsi pod Łodzią. Warszyce? Warszomin? Coś takiego. Spoko ziomek. Coprawda nasza stacja kosmiczna jest większa od jego karczmy - ale nie wszystko da się zrobić w polu grawitacyjnym planety. Jeżu mówi że jest bardem z naczelnych... No Homo Sapiens w końcu.",
             15.0,
             0,
             false,
             false
         ],
-        "fallain": [
+        "fallain\\b": [
             "Kochana Krówka. Skłonność do dramatów i zakrwawiania ścian. Jedna z kilku NAPRAWDE srogich masochistek... Ach ta krew :drool:",
             15.0,
             0,
@@ -323,47 +260,154 @@
             false,
             false
         ],
-        "conjurer": [
+        "conjurer\\b": [
             "Kto mnie wołał? Czego chciał? Jak chcesz pogadać to napisz **Conjurer:** i powiedz co masz na myśli. Jak chcesz żebym Ci coś narysował napisz **imaginuje sobie** i tak samo. Moge też Ci opowiedzieć o fabryczce",
             1200.0,
             0,
             false,
             false
         ],
-        "święta": [
+        "święta\\b": [
             "Święta Ladacznica? Przyjazna osóbka. Bardzo. Jak wilk. Z wielkimi kłami. Strasznie ją lubię. Tak samo nie lubi przemocowców jak ja i Hammer",
             15.0,
             0,
             false,
             false
         ],
-        "ladacznica": [
+        "ladacznica\\b": [
             "Święta Ladacznica? Oj tak. Jeśli okazuje się że ktoś jej naciśnie na odcisk zostaje pożarty w całości... Dobra jest.",
             15.0,
             0,
             false,
             false
         ],
-        "saint": [
+        "saint\\b": [
             "Saint Harlot? Ten jej uśmiech. Potrafi nim wyrazić wszystko. Zarówno żeby rozmówca się ucieszył i wyluzował... Jak i zesrał ze strachu.",
             15.0,
             0,
             false,
             false
         ],
-        "harlot": [
+        "harlot\\b": [
             "Saint Harlot? Wielkie kły. Wielkie pazury. Puchate mięciutkie futerko. Nie należy irytować. No i przemocowcy znikają w jej okolicy 'przypadkiem'.",
             15.0,
             0,
             false,
             false
         ],
+        "same plusy[\\s\\.]*": [
+            "...Jak na cmentarzu",
+            15.0,
+            0,
+            false,
+            false
+        ],
         "(oj\\.*\\s*){3,}": [
             "Widzę że szykuje się wpierdol. *Przeładowuje ręczną rewolwerową wyrzutnię granatów termojądrowych i szeroko się uśmiecha w kierunku Hammera i Wykidajłów*",
             15.0,
             0,
             false,
             true
+        ],
+        "revalyacyjnie\\b": [
+            "Zajebisty dowcip szefie. Na pewno się \"Twojej Byłej Dziewczynie\":tm: spodoba.",
+            15.0,
+            0,
+            false,
+            true
+        ],
+        "nocna zmiana\\b": [
+            "Nocna Zmiana? No to właściciele tego baru. Taki troche Hammer Harema. Kto to jest Harem>? Łokurwa. Harem Hammera. Ale on tu robi za jedyną hurysę, a reszta to szejkowie. Tak zrobię Ci szejka.",
+            15.0,
+            0,
+            false,
+            true
+        ],
+        "liga legend\\b": [
+            "Legends Never Die powiadają. Chyba że gra Hammer. 0/17/0? No problem",
+            15.0,
+            0,
+            false,
+            true
+        ],
+        "liguni.*\\b": [
+            "Legends Never Die powiadają. P*rzygląda się swojej kieszonkowej rewolwerowej wyrzutni rakiet termojądrowych* No Chyba że tak. Ale miłej gierki!!! ",
+            15.0,
+            0,
+            false,
+            true
+        ],
+        "melu.*\\b": [
+            "Meluzyna... *Oczy zaczynają mu błyszczeć, polewa bar benzynąi podpala ją. Nie wiadomo skąd wpada Meluzyna - całą w ogniu. Zaczyna tańczyć na rurze. Wszystko w ogniu. Z głośników leci Rammstein. Połowa gości bawi się miotaczami płomieni. Bar w ogniu.... Odpalają się zraszacze i po 10 sekundach wszystko wraca do normy*",
+            15.0,
+            0,
+            false,
+            true
+        ],
+        "ogie.*\\b": [
+            "Csiiicho. Nie mówimy o ogniu. Już mi raz taka jedna bar zjarała bo się chciała pobawić. Sama wyszła cała czerwoniutka ale ujarana po pachy. W sensie zadowolona",
+            15.0,
+            0,
+            false,
+            true
+        ],
+        "vallarr.*\\b": [
+            "Żodyn się nie spodziewał Warszaskiej Inkwizycji. ŻODYN!",
+            15.0,
+            0,
+            false,
+            true
+        ],
+        "max.*\\b": [
+            "MaxFloyd? Jedyna osoba której Vallarr się realnie boi. Acz często ~~u~~ w niej bywa.",
+            15.0,
+            0,
+            false,
+            true
+        ],
+        "eksperyment.*\\b": [
+            "Ekskrement blindiego vafudra masz może na myśli? No postanowił w ramach eksperymentu uniknąć powieszenia za jajka, faktycznie chyba mu się udało - ale gilotyną sam je sobie uciął. Potem cofnął się w czasie do czasów forów phpBB2. I teraz w przeszłości poluje na naiwne uległe.",
+            15.0,
+            0,
+            false,
+            true
+        ],
+        "isken.*\\b": [
+            "Iskenka? No ta małą to niezły *afrodyzjak*",
+            15.0,
+            0,
+            false,
+            true
+        ],
+        "seraph.*\\b": [
+            "Człowiek z dużą klasą. Wysublimowany koneser.",
+            15.0,
+            0,
+            false,
+            true
+        ]
+    },
+    "cyclic_words": {
+        "kubek hammera.*\\b": [
+            "*Przeciera szklanieczki szmatką. Wzdycha bierze wiertarkę udarową, zaczyna nią odkuwać kamień z kubka na kawę Hammera. Po chwili przybiega Hammer i krzyczy że nie będzie piciu już tak wytrawne* Szefie - ale piciu się już nie mieści....",
+            15.0,
+            0,
+            false,
+            true
+        ],
+        "sprzątanko 1": [
+            "*Conjurer porządkuje bar, wypala szklanki do czysta miotaczem płomieni ze swojej zbroi i ogólnie wygląda na zajętego....*\\n *Przeciąga się za barem* No dobra - porobione to można dalej pi... *Zauważa spojrzenie Hammera* ...sać powieści o naszym wspaniałym barze SZEFIE!",
+            15.0,
+            0,
+            false,
+            true
+        ],
+        "sprzątanko 2": [
+            "*Conjurer porządkuje bar, ścina lekkim laserem pulsacyjnym powierzchnie baru o grubości kilku mikronów i ogólnie wygląda na zajętego....*\\n *Przeciąga się za barem* No dobra - porobione to można dalej pi... *Zauważa spojrzenie Hammera* eprzyć o głupotach z klientami... Szefie... *Bierze 'ukradkowy' łyk z piersiówki*",
+            15.0,
+            0,
+            false,
+            true
         ]
     }
 }

spotify_dl/youtube.py

@@ -97,8 +97,8 @@ def write_tracks(tracks_file, song_dict):
 def set_tags(temp, filename, kwargs):
     """
      sets song tags after they are downloaded
-    :param temp: contains index used to obtain more info about song being editted
+    :param temp: contains index used to obtain more info about song being edited
-    :param filename: location of song whose tags are to be editted
+    :param filename: location of song whose tags are to be edited
     :param kwargs: a dictionary of extra arguments to be used in tag editing
     """
     song = kwargs["track_db"][int(temp[-1])]

system_gpt_settings.json

@@ -0,0 +1,5 @@
+[    {
+    "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."
+}
+]

test_data_retrieval.py

@@ -0,0 +1,26 @@
+"""
+This Python code snippet is connecting to a MySQL database
+using the `mysql.connector` library and fetching data from a table named `scimag`
+Here is a breakdown of what the code is doing:
+"""
+
+import netrc
+
+import mysql.connector
+
+NETRC_FILE = "/home/mtuszowski/.netrc"
+netrc_mod = netrc.netrc(NETRC_FILE)
+REMOTE_HOST_NAME = "192.168.1.192"
+authTokens = netrc_mod.authenticators(REMOTE_HOST_NAME)
+
+mydb = mysql.connector.connect(
+    host=REMOTE_HOST_NAME,
+    user=authTokens[0],
+    password=authTokens[2],
+    database="scihubdois",
+)
+mycursor = mydb.cursor()
+
+mycursor.execute("SELECT * FROM scimag WHERE Title Like 'spider%'")
+for x in mycursor:
+    print(x)

utils/cut_large_file.py

@@ -0,0 +1,73 @@
+# trunk-ignore-all(pylint/C0301)
+"""
+The function `cut_my_life_into_pieces` reads a source file, splits its content based on a file size
+limit, and writes the parts to separate output files in a specified folder.
+
+:param lines: The `lines` parameter in the `smart_write` function is a string that contains the text
+content that you want to write to a file. It represents the actual content that will be written to
+the file
+:param file: The code you provided defines two functions: `smart_write` and
+`cut_my_life_into_pieces`. The `smart_write` function encodes input lines to UTF-8, writes them to a
+file, and returns the size of the encoded bytes. The `cut_my_life_into_pieces` function reads
+:return: The functions provided in the code snippet do not explicitly return any values. However,
+the `smart_write` function returns the size of the encoded bytes of the input `lines` in bytes. The
+`cut_my_life_into_pieces` function does not have a return statement, so it does not explicitly
+return any value.
+"""
+
+FILE_SIZE_LIMIT = 100000 * 1024
+SOURCE = "/mnt/n/scimag_2020-05-30.sql/scimag_2020-05-30.sql"
+OUTPUT_FOLDER = "/mnt/n/scimag_2020-05-30.sql/"
+OUTPUT_FILE_SCHEMA = "_scimag_chunk.sql"
+
+
+def smart_write(lines, file):
+    """
+    The function `smart_write` encodes the input lines to UTF-8, writes them to a file, and returns the
+    size of the encoded bytes.
+
+    :param lines: The `lines` parameter in the `smart_write` function is a string that contains the text
+    content that you want to write to a file
+    :param file: The `file` parameter in the `smart_write` function is expected to be a file object that
+    has been opened in write mode. This file object will be used to write the encoded `lines` to a file
+    :return: The function `smart_write` returns the size of the encoded bytes of the input `lines` in
+    bytes.
+    """
+    encoded_bytes = lines.encode("utf-8")
+    size_in_bytes = len(encoded_bytes)
+    file.write(lines)
+
+    return size_in_bytes
+
+
+def cut_my_life_into_pieces(source, output_folder, output_file):
+    """
+    The function `cut_my_life_into_pieces` reads a source file, splits its content into smaller parts
+    based on a file size limit, and writes these parts to separate output files in a specified output
+    folder.
+
+    :param source: The `source` parameter in the `cut_my_life_into_pieces` function is the file path of
+    the source file that you want to process and split into smaller pieces
+    :param output_folder: The `output_folder` parameter in the `cut_my_life_into_pieces` function
+    represents the directory where the output files will be saved. It should be a string that specifies
+    the path to the folder where you want to store the output files generated by the function. For
+    example, it could be something like
+    :param output_file: The `output_file` parameter in the `cut_my_life_into_pieces` function represents
+    the name of the output file that will be created for each segment of the source file. It will be
+    appended with a number to differentiate between different segments
+    """
+    with open(source, encoding="utf-8") as infile:
+        output_size = 0
+        output_no = 0
+
+        for line in infile:
+            if output_size > FILE_SIZE_LIMIT:
+                output_no += 1
+                output_size = 0
+            op_file_name = str(output_no) + output_file
+            with open(
+                output_folder + op_file_name,
+                "a",
+                encoding="utf-8",
+            ) as op_file:
+                output_size += smart_write(line, op_file)

utils/import_to_mysql.py

@@ -0,0 +1,33 @@
+"""
+Kluczowe jest zeby po każdej linijce pokazywał która to jest, oraz po pliku
+"""
+
+import netrc
+
+import mysql.connector
+
+NETRC_FILE = "/home/mtuszowski/.netrc"
+
+netrc_mod = netrc.netrc(NETRC_FILE)
+REMOTE_HOST_NAME = "sql_localhost"
+authTokens = netrc_mod.authenticators(REMOTE_HOST_NAME)
+
+mydb = mysql.connector.connect(
+    host="localhost", user="root", password="root", database="scihubdois"
+)
+mycursor = mydb.cursor()
+
+mycursor.execute("SELECT * FROM scimag")
+for x in mycursor:
+    print(x)
+
+
+file_list = ""
+for file in file_list:
+
+    with open(
+        "/mnt/n/scimag_2020-05-30.sql/{}".format(file), encoding="utf-8"
+    ) as infile:
+        pass
+result = mycursor.execute("SHOW databases")
+# trunk-ignore(mypy/union-attr)