import json
import os

# 1. Read post from content-queue/posts-source.md
posts_source_path = '/root/workspaces/telegram_pro_import/content-queue/posts-source.md'
content = open(posts_source_path, 'r', encoding='utf-8').read()

# Extract post content for vytjazhki-miele-2026
# It starts after "slug: vytjazhki-miele-2026" metadata block
post_marker = "🆕Линейка вытяжек Miele 2026:"
start_idx = content.find(post_marker)
if start_idx == -1:
    print("Miele hoods post not found in posts-source.md")
    exit(1)

post_text = content[start_idx:].strip()

# Write to posts/vytjazhki-miele-2026_post.md
post_dest_path = '/root/workspaces/telegram_pro_import/posts/vytjazhki-miele-2026_post.md'
with open(post_dest_path, 'w', encoding='utf-8') as f:
    f.write(post_text)
print("Created posts/vytjazhki-miele-2026_post.md")

# 2. Add to articles_queue.json at the top
queue_path = '/root/workspaces/telegram_pro_import/articles_queue.json'
queue = json.load(open(queue_path, 'r', encoding='utf-8'))

# Check if slug already exists to prevent duplicates
slugs = [item['slug'] for item in queue]
if 'vytjazhki-miele-2026' not in slugs:
    new_entry = {
        "post_file": "posts/vytjazhki-miele-2026_post.md",
        "slug": "vytjazhki-miele-2026",
        "title": "Вытяжки Miele 2026: какую выбрать для кухни",
        "status": "pending",
        "updated_at": "2026-06-22T11:12:00Z"
    }
    # Insert at the beginning so it is processed first
    queue.insert(0, new_entry)

    with open(queue_path, 'w', encoding='utf-8') as f:
        json.dump(queue, f, indent=2, ensure_ascii=False)
    print("Added vytjazhki-miele-2026 to the top of articles_queue.json.")
else:
    print("vytjazhki-miele-2026 already in articles_queue.json.")