Sync from GitHub with Git LFS

scripts/publish_to_blogger.py

@@ -1,57 +1,118 @@
-import json
 import os
+import sys
+import json
 import hashlib
 import markdown2
-# from googleapiclient.discovery import build
-# from google.oauth2.credentials import Credentials
-# from googleapiclient.errors import HttpError
 import pickle
-import sys
+import time
+from googleapiclient.discovery import build
+from googleapiclient.errors import HttpError
+
+# Настройки
+SCRIPT_DIR = os.path.dirname(os.path.abspath(__file__))
+JSON_FILE = os.path.abspath(os.path.join(SCRIPT_DIR, "..", "published_posts.json"))
+LOCK_FILE = os.path.abspath(os.path.join(SCRIPT_DIR, "publish.lock"))
+
+# Блокировка, чтобы скрипт не запускался дважды
+if os.path.exists(LOCK_FILE):
+    print("⚠ Скрипт уже запущен — выходим.")
+    sys.exit(0)
+
+with open(LOCK_FILE, "w") as f:
+    f.write("locked")
 
-# Файлы — всегда в корне репозитория
-JSON_FILE = os.path.join(os.getcwd(), "published_posts.json")
-
-# Загружаем список опубликованных постов
-if os.path.exists(JSON_FILE):
-    try:
-        with open(JSON_FILE, 'r', encoding='utf-8') as f:
-            published = json.load(f)
-        print(f"✅ Загружен список опубликованных постов: {list(published.keys())}")
-        print(f"Содержимое JSON при загрузке:\n{json.dumps(published, ensure_ascii=False, indent=2)}")
-    except json.JSONDecodeError:
-        print("⚠ published_posts.json пустой или поврежден — начинаем с нуля.")
+try:
+    # Загружаем токен
+    TOKEN_FILE = os.environ.get('TOKEN_FILE', 'token.pkl')
+    with open(TOKEN_FILE, 'rb') as f:
+        creds = pickle.load(f)
+
+    service = build('blogger', 'v3', credentials=creds)
+    BLOG_ID = os.environ['BLOG_ID']
+
+    # Загружаем список опубликованных постов
+    if os.path.exists(JSON_FILE):
+        try:
+            with open(JSON_FILE, 'r', encoding='utf-8') as f:
+                published = json.load(f)
+            print(f"✅ Загружен список опубликованных постов: {list(published.keys())}")
+        except json.JSONDecodeError:
+            print("⚠ published_posts.json пустой или поврежден — начинаем с нуля.")
+            published = {}
+    else:
+        print("⚠ published_posts.json не найден — начинаем с нуля.")
         published = {}
-else:
-    published = {}
-    print("⚠ published_posts.json не найден — начинаем с нуля.")
 
-# Обход markdown файлов
-for root, _, files in os.walk("docs"):
-    for filename in files:
-        if not filename.endswith(".md"):
-            continue
+    # Обходим markdown-файлы
+    for root, _, files in os.walk("docs"):
+        for filename in files:
+            if not filename.endswith(".md"):
+                continue
+
+            path = os.path.join(root, filename)
+            title = os.path.splitext(filename)[0]
+
+            with open(path, 'r', encoding='utf-8') as f:
+                md_content = f.read()
+
+            html_content = markdown2.markdown(md_content)
+            content_hash = hashlib.md5(md_content.encode('utf-8')).hexdigest()
+
+            # Пропускаем если ничего не изменилось
+            if title in published and published[title]['hash'] == content_hash:
+                continue
+
+            print(f"📝 Новый или изменённый пост: {title}")
 
-        path = os.path.join(root, filename)
-        title = os.path.splitext(filename)[0]
+            post = {
+                "kind": "blogger#post",
+                "title": title,
+                "content": html_content
+            }
 
-        with open(path, 'r', encoding='utf-8') as f:
-            md_content = f.read()
+            try:
+                # Если отладка — просто обновляем JSON
+                if os.environ.get('DEBUG_PUBLISH', '0') == '1':
+                    post_id = published.get(title, {}).get("id", "DUMMY_ID")
+                    published[title] = {"id": post_id, "hash": content_hash}
+                    print("✅ Скрипт завершён в отладочном режиме (публикация отключена).")
+                    with open(JSON_FILE, 'w', encoding='utf-8') as f:
+                        json.dump(published, f, ensure_ascii=False, indent=2)
+                    sys.exit(0)
 
-        content_hash = hashlib.md5(md_content.encode('utf-8')).hexdigest()
+                # Публикуем новый или обновляем существующий
+                if title in published:
+                    post_id = published[title]['id']
+                    updated_post = service.posts().update(
+                        blogId=BLOG_ID, postId=post_id, body=post
+                    ).execute()
+                    print(f"♻️ Пост обновлён: {updated_post['url']}")
+                    published[title] = {"id": post_id, "hash": content_hash}
+                else:
+                    new_post = service.posts().insert(
+                        blogId=BLOG_ID, body=post, isDraft=False
+                    ).execute()
+                    print(f"🆕 Пост опубликован: {new_post['url']}")
+                    published[title] = {"id": new_post['id'], "hash": content_hash}
 
-        if title in published and published[title]['hash'] == content_hash:
-            print(f"⏭ Без изменений: {title}")
-            continue
+                # Сохраняем прогресс
+                with open(JSON_FILE, 'w', encoding='utf-8') as f:
+                    json.dump(published, f, ensure_ascii=False, indent=2)
 
-        # В отладочном режиме пропускаем публикацию в Blogger
-        print(f"📝 Новый или изменённый пост: {title}")
-        published[title] = {"id": "DUMMY_ID", "hash": content_hash}
+                # Публикуем только один пост за запуск
+                print("✅ Завершаем выполнение после одного поста.")
+                sys.exit(0)
 
-# Логируем JSON перед записью
-print(f"Содержимое JSON перед записью:\n{json.dumps(published, ensure_ascii=False, indent=2)}")
+            except HttpError as e:
+                if e.resp.status == 403 and "quotaExceeded" in str(e):
+                    print("⚠ Достигнут лимит Blogger API. Попробуйте снова позже.")
+                    sys.exit(1)
+                else:
+                    raise
 
-# Сохраняем JSON (можно оставить)
-with open(JSON_FILE, 'w', encoding='utf-8') as f:
-    json.dump(published, f, ensure_ascii=False, indent=2)
+    print("🎉 Все посты уже актуальны — новых публикаций нет.")
 
-print("✅ Скрипт завершён в отладочном режиме (публикация отключена).")
+finally:
+    # Удаляем блокировку
+    if os.path.exists(LOCK_FILE):
+        os.remove(LOCK_FILE)