sudo apt update && sudo apt install -y python3.11 python3.11-venv

mkdir ~/x-ai-bot && cd ~/x-ai-bot
python3.11 -m venv venv
source venv/bin/activate

pip install tweepy openai python-dotenv schedule requests

nano .env

# poster.py — コンテンツの定期投稿
import tweepy
import os
from openai import OpenAI
from dotenv import load_dotenv
import random

load_dotenv()

# X API クライアント
client_x = tweepy.Client(
    consumer_key=os.getenv("X_API_KEY"),
    consumer_secret=os.getenv("X_API_SECRET"),
    access_token=os.getenv("X_ACCESS_TOKEN"),
    access_token_secret=os.getenv("X_ACCESS_SECRET"),
)

# OpenAI クライアント
client_ai = OpenAI(api_key=os.getenv("OPENAI_API_KEY"))

# 投稿テーマのリスト（アカウントのジャンルに合わせて変更）
TOPICS = [
    "AIツールの使い方",
    "生産性向上のヒント",
    "Python プログラミング",
    "VPS活用術",
    "クラウド自動化",
]

def generate_tweet(topic: str) -> str:
    """AIがツイート文を生成する"""
    prompt = f"""
以下のテーマについて、Xで反応を得やすい日本語ツイートを1つ書いてください。

テーマ: {topic}

条件:
- 140文字以内
- 具体的なTipsや気づきを含む
- ハッシュタグを1〜2個付ける
- 絵文字を適度に使う
- 宣伝・スパム感NG
"""
    response = client_ai.chat.completions.create(
        model="gpt-4o-mini",
        messages=[{"role": "user", "content": prompt}],
        max_tokens=200,
    )
    return response.choices[0].message.content.strip()

def post_tweet():
    """ツイートを投稿する"""
    topic = random.choice(TOPICS)
    tweet_text = generate_tweet(topic)

    # 140文字制限チェック
    if len(tweet_text) > 140:
        tweet_text = tweet_text[:137] + "..."

    try:
        response = client_x.create_tweet(text=tweet_text)
        tweet_id = response.data["id"]
        print(f"投稿成功: ID={tweet_id}\n{tweet_text}")
        return True
    except tweepy.TweepyException as e:
        print(f"投稿失敗: {e}")
        return False

if __name__ == "__main__":
    post_tweet()

# replier.py — メンションへの自動リプライ
import tweepy
import os
import json
from openai import OpenAI
from dotenv import load_dotenv

load_dotenv()

client_x = tweepy.Client(
    bearer_token=os.getenv("X_BEARER_TOKEN"),
    consumer_key=os.getenv("X_API_KEY"),
    consumer_secret=os.getenv("X_API_SECRET"),
    access_token=os.getenv("X_ACCESS_TOKEN"),
    access_token_secret=os.getenv("X_ACCESS_SECRET"),
)
client_ai = OpenAI(api_key=os.getenv("OPENAI_API_KEY"))

# 最後に処理したツイートIDを保存（重複防止）
STATE_FILE = "last_seen_id.json"

def load_last_seen_id() -> str | None:
    if os.path.exists(STATE_FILE):
        with open(STATE_FILE) as f:
            return json.load(f).get("id")
    return None

def save_last_seen_id(tweet_id: str):
    with open(STATE_FILE, "w") as f:
        json.dump({"id": tweet_id}, f)

def generate_reply(mention_text: str) -> str:
    """メンション内容に対するリプライを生成"""
    prompt = f"""
以下のツイートへの自然な日本語リプライを書いてください。
丁寧で役に立つ内容にしてください。140文字以内で。

ツイート: {mention_text}
"""
    response = client_ai.chat.completions.create(
        model="gpt-4o-mini",
        messages=[{"role": "user", "content": prompt}],
        max_tokens=150,
    )
    return response.choices[0].message.content.strip()

def process_mentions():
    """未返信のメンションを取得してリプライする"""
    last_id = load_last_seen_id()

    # 自分のユーザーIDを取得
    me = client_x.get_me()
    my_id = me.data.id

    # メンションを取得
    kwargs = {"since_id": last_id} if last_id else {}
    mentions = client_x.get_users_mentions(
        id=my_id,
        max_results=10,
        tweet_fields=["text", "author_id"],
        **kwargs,
    )

    if not mentions.data:
        print("新しいメンションなし")
        return

    for mention in reversed(mentions.data):
        text = mention.text.strip()
        # 自分自身へのリプライは除外
        if str(mention.author_id) == str(my_id):
            continue

        reply_text = generate_reply(text)
        try:
            client_x.create_tweet(
                text=reply_text,
                in_reply_to_tweet_id=mention.id,
            )
            print(f"リプライ送信: {mention.id}\n→ {reply_text}")
        except tweepy.TweepyException as e:
            print(f"リプライ失敗: {e}")

    # 最新のIDを保存
    save_last_seen_id(str(mentions.data[0].id))

if __name__ == "__main__":
    process_mentions()

crontab -e