Upload folder using huggingface_hub

.github/workflows/sync_to_huggingface.yml

@@ -5,6 +5,10 @@ on:
     branches: [ "main", "master" ]
   workflow_dispatch:
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 jobs:
   sync-to-hub:
     runs-on: ubuntu-latest

bot.py

@@ -2021,6 +2021,9 @@ async def handle_youtube(message: Message, url: str) -> None:
 
 @dp.callback_query(F.data.startswith("yt:"))
 async def yt_callback(cb: CallbackQuery) -> None:
+    if cb.message is None:
+         await _safe_callback_answer(cb, "Ошибка: сообщение не найдено.", show_alert=True)
+         return
     parts = cb.data.split(":")
     if len(parts) != 3:
          await _safe_callback_answer(cb, "Некорректный формат сессии.")
@@ -2079,6 +2082,7 @@ async def yt_callback(cb: CallbackQuery) -> None:
             if not download_success:
                 raise Exception("Не удалось загрузить медиа ни через Cobalt API, ни через резервный шлюз yt-dlp.")
 
+            reply_id = cb.message.reply_to_message.message_id if cb.message.reply_to_message else None
             if is_audio:
                 dst_mp3 = os.path.join(tmp_dir, "output.mp3")
                 if await _audio_from_file_ffmpeg(src_file, dst_mp3):
@@ -2090,7 +2094,7 @@ async def yt_callback(cb: CallbackQuery) -> None:
                 with open(send_file_p, "rb") as f:
                      await bot.send_audio(
                          chat_id=cb.message.chat.id, audio=BufferedInputFile(f.read(), filename=f"{title[:60]}.mp3"),
-                         title=title, performer=uploader, reply_to_message_id=cb.message.reply_to_message.message_id
+                         title=title, performer=uploader, reply_to_message_id=reply_id
                      )
             else:
                 dst_mp4 = os.path.join(tmp_dir, "output.mp4")
@@ -2103,7 +2107,7 @@ async def yt_callback(cb: CallbackQuery) -> None:
                      await bot.send_video(
                          chat_id=cb.message.chat.id, video=BufferedInputFile(f.read(), filename=f"{title[:60]}.mp4"),
                          caption=f"<b>{_html_mod.escape(title)}</b>\nОтправитель: {_html_mod.escape(uploader)}",
-                         parse_mode=ParseMode.HTML, reply_to_message_id=cb.message.reply_to_message.message_id
+                         parse_mode=ParseMode.HTML, reply_to_message_id=reply_id
                      )
     except Exception as exc:
         log.exception("YouTube downloader callback failed: ")
@@ -2181,6 +2185,9 @@ async def cmd_model(message: Message) -> None:
 
 @dp.callback_query(F.data.startswith("model:"))
 async def cb_gemini_model(cb: CallbackQuery) -> None:
+    if cb.message is None:
+         await _safe_callback_answer(cb, "Ошибка: сообщение не найдено.", show_alert=True)
+         return
     mid = cb.data.split(":", 1)[1]
     if mid not in GEMINI_MODELS:
          await _safe_callback_answer(cb, "Выбранная модель не поддерживается.")
@@ -2458,6 +2465,9 @@ async def _show_or_menu(message: Message, category: str, cat_label: str) -> None
 
 @dp.callback_query(F.data.startswith("or_model:"))
 async def cb_or_model(cb: CallbackQuery) -> None:
+    if cb.message is None:
+         await _safe_callback_answer(cb, "Ошибка: сообщение не найдено.", show_alert=True)
+         return
     try:
         parts = cb.data.split(":")
         if len(parts) == 3:
@@ -2599,6 +2609,7 @@ async def _process_media_group_buffers(mgid: str) -> None:
     await _handle_message_core(main_msg)
 
 async def _handle_message_core(message: Message) -> None:
+    state = get_state(message.chat.id)
     t = message.text or message.caption or ""
     is_private = message.chat.type == ChatType.PRIVATE
     is_guest = is_guest_message(message)
@@ -2609,10 +2620,8 @@ async def _handle_message_core(message: Message) -> None:
         url = extract_url(t)
         if not url:
             if t.strip():
-                 state = get_state(message.chat.id)
                  username = message.from_user.username or message.from_user.first_name or "User"
                  state["ctx"].append(f"@{username}: {t.strip()}")
-            state = get_state(message.chat.id)
             _save_media_to_history(_msg_media_source(message), state)
             save_state_to_disk()
             return
@@ -2750,6 +2759,11 @@ async def _handle_message_core(message: Message) -> None:
              with contextlib.suppress(Exception):
                   os.unlink(med_path)
 
+@dp.errors()
+async def global_error_handler(event: Any) -> bool:
+    log.error("Global error handler caught exception: %s", event.exception, exc_info=event.exception)
+    return True
+
 @dp.message()
 async def handle_message(message: Message) -> None:
     if message.media_group_id:
@@ -2798,15 +2812,18 @@ async def _raw_get_updates(offset: int | None = None) -> list[dict]:
 async def _process_raw_update(raw_update: dict) -> None:
     if not isinstance(raw_update, dict):
          return
-    guest = raw_update.get("guest_message")
-    if isinstance(guest, dict):
-        try:
-             await _handle_message_core(Message.model_validate(guest, context={"bot": bot}))
-        except Exception as exc:
-             log.warning("[guest] Guest processing failed: %s", exc)
-        return
-    upd = Update.model_validate(raw_update, context={"bot": bot})
-    await dp.feed_update(bot, upd)
+    try:
+        guest = raw_update.get("guest_message")
+        if isinstance(guest, dict):
+            try:
+                 await _handle_message_core(Message.model_validate(guest, context={"bot": bot}))
+            except Exception as exc:
+                 log.warning("[guest] Guest processing failed: %s", exc)
+            return
+        upd = Update.model_validate(raw_update, context={"bot": bot})
+        await dp.feed_update(bot, upd)
+    except Exception as exc:
+        log.warning("[update] Raw update processing failed: %s", exc)
 
 async def _polling_loop() -> None:
     load_state_from_disk()

src/files_data.ts

@@ -171,6 +171,10 @@ on:
     branches: [ "main", "master" ]
   workflow_dispatch:
 
+concurrency:
+  group: \${{ github.workflow }}-\${{ github.ref }}
+  cancel-in-progress: true
+
 jobs:
   sync-to-hub:
     runs-on: ubuntu-latest
@@ -179,15 +183,47 @@ jobs:
         uses: actions/checkout@v4
         with:
           fetch-depth: 0
-          lfs: true
+
+      - name: Set up Python
+        uses: actions/setup-python@v5
+        with:
+          python-version: '3.10'
 
       - name: Push to Hugging Face Spaces
         env:
           HF_TOKEN: \${{ secrets.HF_TOKEN }}
         run: |
-          git config --global user.email "sync@github.dev"
-          git config --global user.name "GitHub Sync Action"
-          git push --force https://oauth2:\$HF_TOKEN@huggingface.co/spaces/SilverElixir/SilverGemini HEAD:refs/heads/main
+          if [ -z "$HF_TOKEN" ]; then
+            echo "=========================================================================="
+            echo "ERROR: HF_TOKEN is missing or empty!"
+            echo "Please add HF_TOKEN as repository secret under:"
+            echo "Settings -> Secrets and variables -> Actions"
+            echo "=========================================================================="
+            exit 1
+          fi
+          
+          python -m pip install --upgrade pip
+          pip install huggingface_hub
+          
+          cat << 'EOF' > sync.py
+          import os
+          from huggingface_hub import HfApi
+          
+          token = os.environ.get("HF_TOKEN")
+          repo_id = "SilverElixir/SilverGemini"
+          
+          print(f"Uploading all files to Hugging Face Space: {repo_id}...")
+          api = HfApi(token=token)
+          api.upload_folder(
+              folder_path=".",
+              repo_id=repo_id,
+              repo_type="space",
+              ignore_patterns=[".git", ".git/**", "sync.py", "__pycache__", "**/*.pyc"]
+          )
+          print("Upload completed successfully!")
+          EOF
+          
+          python sync.py
 `
   }
 ];