ИИ адаптирует один пост сразу для VK и Telegram: автопостинг без копирования и вставки

import anthropic
import requests
import json
import sqlite3
from datetime import datetime

# Токены
CLAUDE_KEY = "YOUR_CLAUDE_KEY"
VK_TOKEN = "YOUR_VK_TOKEN"          # права: wall, photos
VK_OWNER_ID = "-123456789"          # ID группы со знаком минус
TG_BOT_TOKEN = "YOUR_BOT_TOKEN"
TG_CHANNEL_ID = "@your_channel"

client = anthropic.Anthropic(api_key=CLAUDE_KEY)

# ─── Адаптация через Claude ───────────────────────────────────────

def adapt_post(source_text: str) -> dict:
  """Возвращает {'vk': '...', 'telegram': '...'}"""

  prompt = f"""Адаптируй текст для двух платформ. Верни JSON с двумя ключами.

ИСХОДНЫЙ ТЕКСТ:
{source_text}

Правила для VK (ключ "vk"):
- Длина 500–900 символов
- Сохрани все факты и цифры из исходника
- 3–5 хэштегов в конце (#маркетинг, #бизнес, #smm)
- CTA в конце: призыв перейти по ссылке или подписаться
- Форматирование через абзацы, без маркдауна

Правила для Telegram (ключ "telegram"):
- Длина 150–350 символов
- Эмодзи в начале каждого смыслового блока
- Без хэштегов
- CTA — призыв написать или нажать кнопку
- Текст должен читаться за 20 секунд

Верни только JSON без markdown-обёртки:
{{"vk": "текст для VK", "telegram": "текст для Telegram"}}"""

  message = client.messages.create(
      model="claude-haiku-4-5",
      max_tokens=1500,
      messages=[{"role": "user", "content": prompt}]
  )

  raw = message.content[0].text.strip()
  return json.loads(raw)

# ─── Публикация в VK ─────────────────────────────────────────────

def post_to_vk(text: str, image_url: str = None) -> dict:
  params = {
      "owner_id": VK_OWNER_ID,
      "from_group": 1,
      "message": text,
      "access_token": VK_TOKEN,
      "v": "5.199"
  }
  if image_url:
      # Загрузка картинки — отдельный метод, здесь упрощено
      params["attachments"] = image_url
  r = requests.post("https://api.vk.com/method/wall.post", params=params)
  return r.json()

# ─── Публикация в Telegram ───────────────────────────────────────

def post_to_telegram(text: str, button_url: str = None, button_label: str = "Подробнее") -> dict:
  payload = {
      "chat_id": TG_CHANNEL_ID,
      "text": text,
      "parse_mode": "HTML"
  }
  if button_url:
      payload["reply_markup"] = {
          "inline_keyboard": [[
              {"text": button_label, "url": button_url}
          ]]
      }
  r = requests.post(
      f"https://api.telegram.org/bot{TG_BOT_TOKEN}/sendMessage",
      json=payload
  )
  return r.json()

# ─── Очередь публикаций (SQLite) ─────────────────────────────────

def init_db():
  conn = sqlite3.connect("posts_queue.db")
  conn.execute("""
      CREATE TABLE IF NOT EXISTS queue (
          id INTEGER PRIMARY KEY AUTOINCREMENT,
          source_text TEXT NOT NULL,
          scheduled_at TEXT NOT NULL,
          link TEXT,
          published INTEGER DEFAULT 0,
          created_at TEXT DEFAULT CURRENT_TIMESTAMP
      )
  """)
  conn.commit()
  return conn

def get_pending_posts(conn):
  """Берём посты, время которых наступило."""
  now = datetime.now().isoformat()
  cur = conn.execute(
      "SELECT id, source_text, link FROM queue "
      "WHERE published = 0 AND scheduled_at <= ? "
      "ORDER BY scheduled_at LIMIT 5",
      (now,)
  )
  return cur.fetchall()

def mark_published(conn, post_id: int):
  conn.execute("UPDATE queue SET published = 1 WHERE id = ?", (post_id,))
  conn.commit()

# ─── Основной цикл ───────────────────────────────────────────────

def run():
  conn = init_db()
  posts = get_pending_posts(conn)

  if not posts:
      print("Нет постов для публикации.")
      return

  for post_id, source_text, link in posts:
      print(f"Адаптируем пост #{post_id}...")
      adapted = adapt_post(source_text)

      vk_result = post_to_vk(adapted["vk"])
      tg_result = post_to_telegram(
          adapted["telegram"],
          button_url=link,
          button_label="Читать полностью"
      )

      if "response" in vk_result and tg_result.get("ok"):
          mark_published(conn, post_id)
          print(f"Пост #{post_id} опубликован в обеих платформах.")
      else:
          print(f"Ошибка: VK={vk_result}, TG={tg_result}")

if __name__ == "__main__":
  run()

import sqlite3
from datetime import datetime

conn = sqlite3.connect("posts_queue.db")

# Пример: опубликовать завтра в 10:00
conn.execute("""
  INSERT INTO queue (source_text, scheduled_at, link)
  VALUES (?, ?, ?)
""", (
  """
  Запустили новый сервис: автоматическая адаптация постов для соцсетей.
  Claude читает исходный текст и делает версии для VK и Telegram.
  Экономит 40-60 минут в день. Работает через Python и API Anthropic.
  Запуск занимает 30 минут для тех кто умеет запускать скрипты.
  """,
  "2026-06-02T10:00:00",
  "https://example.com/blog/autoposting"
))
conn.commit()
print("Пост добавлен в очередь.")

# Проверять очередь каждые 15 минут
*/15 * * * * /usr/bin/python3 /home/user/autopost/autopost.py >> /home/user/autopost/autopost.log 2>&1