Sync from GitHub with Git LFS

scripts/publish_to_blogger.py

@@ -1,8 +1,16 @@
-import os
+import time
 import json
-import pickle
-from googleapiclient.discovery import build
+import os
+import hashlib
 import markdown2
+from googleapiclient.discovery import build
+from google.oauth2.credentials import Credentials
+from googleapiclient.errors import HttpError
+import pickle
+
+# Файлы
+SCRIPT_DIR = os.path.dirname(os.path.abspath(__file__))
+JSON_FILE = os.path.join(SCRIPT_DIR, "published_posts.json")
 
 # Загружаем токен
 TOKEN_FILE = os.environ.get('TOKEN_FILE', 'token.pkl')
@@ -12,56 +20,73 @@ with open(TOKEN_FILE, 'rb') as f:
 service = build('blogger', 'v3', credentials=creds)
 BLOG_ID = os.environ['BLOG_ID']
 
-# published_posts.json рядом со скриптом
-SCRIPT_DIR = os.path.dirname(os.path.abspath(__file__))
-JSON_FILE = os.path.join(SCRIPT_DIR, 'published_posts.json')
-
-# Безопасная загрузка JSON
-if os.path.exists(JSON_FILE) and os.path.getsize(JSON_FILE) > 0:
+# Загружаем список опубликованных постов
+if os.path.exists(JSON_FILE):
     try:
         with open(JSON_FILE, 'r', encoding='utf-8') as f:
             published = json.load(f)
-    except (json.JSONDecodeError, ValueError):
+        print(f"Успешно загружен список опубликованных постов: {published}")
+    except json.JSONDecodeError:
+        print("published_posts.json пустой или поврежден — начинаем с нуля.")
         published = {}
 else:
     published = {}
 
-print("Успешно загружен список опубликованных постов:", published)
+# Обход markdown файлов
+for root, _, files in os.walk("docs"):
+    for filename in files:
+        if not filename.endswith(".md"):
+            continue
 
-# Папка с Markdown-файлами
-POSTS_DIR = os.path.join(os.path.dirname(SCRIPT_DIR), 'docs')
+        path = os.path.join(root, filename)
+        title = os.path.splitext(filename)[0]
 
-for filename in os.listdir(POSTS_DIR):
-    if filename.endswith('.md'):
-        with open(os.path.join(POSTS_DIR, filename), 'r', encoding='utf-8') as f:
+        with open(path, 'r', encoding='utf-8') as f:
             md_content = f.read()
-        html_content = markdown2.markdown(md_content)
 
-        title = filename.replace('.md', '')
-        content_hash = hash(md_content)
+        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:
-            print(f"Пост без изменений: {title}")
+            print(f"Без изменений: {title}")
             continue
 
         post = {
-            'title': title,
-            'content': html_content
+            "kind": "blogger#post",
+            "title": title,
+            "content": html_content
         }
 
-        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}
+        try:
+            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}
+
+            # 💾 сохраняем прогресс
+            with open(JSON_FILE, 'w', encoding='utf-8') as f:
+                json.dump(published, f, ensure_ascii=False, indent=2)
+
+            # 🕒 пауза в 10 мин.
+            print("Пауза 10 мин. перед следующим постом...")
+            time.sleep(600)
 
-# сохраняем обновлённый список постов
-with open(JSON_FILE, 'w', encoding='utf-8') as f:
-    json.dump(published, f, ensure_ascii=False, indent=2)
+        except HttpError as e:
+            if e.resp.status == 403 and "quotaExceeded" in str(e):
+                print("⚠ Достигнут лимит Blogger API. Засыпаем на 1 час...")
+                time.sleep(1 * 3600)
+                continue
+            else:
+                raise