WordPress記事をThreadsに自動投稿する方法【コード版】｜functions.phpで作る仕組みと、ハマった落とし穴

define('THREADS_ACCESS_TOKEN', 'xxxxxxxxxx');   // Meta申請編で取得したトークン
define('THREADS_USER_ID', 'xxxxxxxxxx');         // Meta申請編で確認したユーザーID
define('THREADS_WEBHOOK_SECRET', 'ランダムな長い文字列');       // GAS編で決めた合言葉
define('THREADS_GAS_WEBAPP_URL', 'https://script.google.com/macros/s/xxxxx/exec'); // GAS編で発行したURL

// ---- 1. 公開イベントを検知して非同期投稿を予約 ----
add_action('transition_post_status', 'weblog_schedule_threads_post', 10, 3);

function weblog_schedule_threads_post($new_status, $old_status, $post) {
    if ($new_status !== 'publish' || $old_status === 'publish') {
        return;
    }
    if ($post->post_type !== 'post') {
        return;
    }
    if (get_post_meta($post->ID, '_threads_posted', true)) {
        return;
    }

    wp_schedule_single_event(time() + 5, 'weblog_threads_post_event', array($post->ID));
}

// ---- 2. 実際にThreadsへ投稿する処理 ----
add_action('weblog_threads_post_event', 'weblog_execute_threads_post');

function weblog_execute_threads_post($post_id) {
    if (get_post_meta($post_id, '_threads_posted', true)) {
        return;
    }

    $token = weblog_get_threads_access_token();
    if (empty($token) || !defined('THREADS_USER_ID')) {
        error_log('[Threads自動投稿] トークン未設定のため投稿をスキップしました。post_id=' . $post_id);
        return;
    }

    $post = get_post($post_id);
    if (!$post || $post->post_status !== 'publish') {
        return;
    }

    $text = weblog_build_threads_text($post);
    $result = weblog_post_to_threads($text, $token);

    $record = array(
        'time'   => current_time('mysql'),
        'title'  => get_the_title($post_id),
        'url'    => get_permalink($post_id),
        'status' => $result['success'] ? '成功' : '失敗',
        'detail' => $result['success'] ? ('thread_id: ' . $result['id']) : $result['error'],
    );
    update_option('threads_last_result', $record);

    if ($result['success']) {
        update_post_meta($post_id, '_threads_posted', current_time('mysql'));
        error_log('[Threads自動投稿] 投稿成功 post_id=' . $post_id . ' thread_id=' . $result['id']);
    } else {
        error_log('[Threads自動投稿] 投稿失敗 post_id=' . $post_id . ' エラー=' . $result['error']);
        wp_mail(
            get_option('admin_email'),
            '[' . get_bloginfo('name') . '] Threads自動投稿に失敗しました',
            "記事「" . $record['title'] . "」のThreads自動投稿に失敗しました。\n\n" .
            "エラー内容: " . $result['error'] . "\n\n" .
            "記事URL: " . $record['url'] . "\n\n" .
            "※手動でThreadsに投稿するか、管理画面「設定 > Threads自動投稿」で状況を確認してください。"
        );
    }
}

// ---- 3. 投稿文の組み立て ----
// ※ Threadsは1投稿につき「トピックタグ」を1つしか認識しない仕様のため
//   （2つ目以降は#記号付きのただの文字列として残るだけで機能しない）、
//   タグは1つだけに絞る。カテゴリがあればカテゴリ名を、無ければ既定値を使う。
function weblog_build_threads_text($post) {
    $title = get_the_title($post);
    $url = get_permalink($post);

    $tag = '#WordPress';
    $categories = get_the_category($post->ID);
    if (!empty($categories)) {
        $clean_name = preg_replace('/[\s　・\/／\-]/u', '', $categories[0]->name);
        if ($clean_name !== '') {
            $tag = '#' . $clean_name;
        }
    }

    return "{$title}\n\n{$url}\n\n{$tag}";
}

// ---- 4. アクセストークンの取得（wp_options優先、なければwp-config.phpの初期値） ----
function weblog_get_threads_access_token() {
    $option_token = get_option('threads_access_token');
    if (!empty($option_token)) {
        return $option_token;
    }
    return defined('THREADS_ACCESS_TOKEN') ? THREADS_ACCESS_TOKEN : '';
}

// ---- 5. Threads API呼び出し（コンテナ作成 → 公開の2ステップ） ----
function weblog_post_to_threads($text, $token) {
    $base = 'https://graph.threads.net/v1.0';
    $user_id = THREADS_USER_ID;

    $create_response = wp_remote_post("{$base}/{$user_id}/threads", array(
        'timeout' => 15,
        'body' => array(
            'media_type' => 'TEXT',
            'text' => $text,
            'access_token' => $token,
        ),
    ));

    if (is_wp_error($create_response)) {
        return array('success' => false, 'error' => $create_response->get_error_message());
    }

    $create_body = json_decode(wp_remote_retrieve_body($create_response), true);
    if (empty($create_body['id'])) {
        return array('success' => false, 'error' => wp_remote_retrieve_body($create_response));
    }
    $creation_id = $create_body['id'];

    sleep(3); // Meta推奨：コンテナ作成後、公開前に少し待機

    $publish_response = wp_remote_post("{$base}/{$user_id}/threads_publish", array(
        'timeout' => 15,
        'body' => array(
            'creation_id' => $creation_id,
            'access_token' => $token,
        ),
    ));

    if (is_wp_error($publish_response)) {
        return array('success' => false, 'error' => $publish_response->get_error_message());
    }

    $publish_body = json_decode(wp_remote_retrieve_body($publish_response), true);
    if (empty($publish_body['id'])) {
        return array('success' => false, 'error' => wp_remote_retrieve_body($publish_response));
    }

    return array('success' => true, 'id' => $publish_body['id']);
}

// ---- 6. WP-CronでGASのWebアプリへ定期的に問い合わせ、トークンを取得する（PULL方式） ----
register_activation_hook(__FILE__, 'weblog_activate_poll_schedule');
function weblog_activate_poll_schedule() {
    if (!wp_next_scheduled('weblog_poll_token_event')) {
        wp_schedule_event(time(), 'daily', 'weblog_poll_token_event');
    }
}

register_deactivation_hook(__FILE__, 'weblog_deactivate_poll_schedule');
function weblog_deactivate_poll_schedule() {
    wp_clear_scheduled_hook('weblog_poll_token_event');
}

add_action('init', function () {
    if (!wp_next_scheduled('weblog_poll_token_event')) {
        wp_schedule_event(time(), 'daily', 'weblog_poll_token_event');
    }
});

add_action('weblog_poll_token_event', 'weblog_poll_gas_token');

function weblog_poll_gas_token() {
    if (!defined('THREADS_GAS_WEBAPP_URL') || !defined('THREADS_WEBHOOK_SECRET')) {
        error_log('[Threads自動投稿] THREADS_GAS_WEBAPP_URL または THREADS_WEBHOOK_SECRET が未設定です。');
        return;
    }

    $url = add_query_arg('secret', rawurlencode(THREADS_WEBHOOK_SECRET), THREADS_GAS_WEBAPP_URL);
    $response = wp_remote_get($url, array('timeout' => 15));

    if (is_wp_error($response)) {
        weblog_notify_poll_failure($response->get_error_message());
        return;
    }

    $code = wp_remote_retrieve_response_code($response);
    $body = json_decode(wp_remote_retrieve_body($response), true);

    if ($code !== 200 || empty($body['access_token'])) {
        weblog_notify_poll_failure('HTTPステータス: ' . $code . ' / 応答: ' . wp_remote_retrieve_body($response));
        return;
    }

    $current = get_option('threads_access_token');
    if ($current !== $body['access_token']) {
        update_option('threads_access_token', $body['access_token']);
        update_option('threads_token_updated_at', current_time('mysql'));
        update_option('threads_poll_last_checked_at', current_time('mysql'));

        wp_mail(
            get_option('admin_email'),
            '[' . get_bloginfo('name') . '] Threadsトークンを自動反映しました',
            "GASで更新された新しいアクセストークンをWordPressに反映しました。\n日時: " . current_time('mysql')
        );
    } else {
        update_option('threads_poll_last_checked_at', current_time('mysql'));
    }
}

function weblog_notify_poll_failure($detail) {
    $last_notified = get_option('threads_poll_failure_notified_at');
    if ($last_notified && (time() - strtotime($last_notified)) < DAY_IN_SECONDS) {
        error_log('[Threads自動投稿] GASへの問い合わせ失敗（通知は24時間以内のためスキップ）: ' . $detail);
        return;
    }
    update_option('threads_poll_failure_notified_at', current_time('mysql'));
    error_log('[Threads自動投稿] GASへの問い合わせ失敗: ' . $detail);

    wp_mail(
        get_option('admin_email'),
        '[' . get_bloginfo('name') . '] Threadsトークン取得（GAS連携）に失敗しました',
        "WordPressからGASのWebアプリへのトークン取得に失敗しました。\n\n詳細: " . $detail .
        "\n\nTHREADS_GAS_WEBAPP_URL の設定や、GAS側のデプロイ状態を確認してください。"
    );
}

// ---- 7. 手動で「今すぐGASに問い合わせる」を実行するハンドラ ----
add_action('admin_post_weblog_manual_poll_token', 'weblog_handle_manual_poll_token');

function weblog_handle_manual_poll_token() {
    if (!current_user_can('manage_options')) {
        wp_die('権限がありません。');
    }
    check_admin_referer('weblog_manual_poll_token_action');

    weblog_poll_gas_token();

    wp_safe_redirect(add_query_arg('polled', '1', admin_url('options-general.php?page=weblog-threads-status')));
    exit;
}

// ---- 8. 管理画面にステータス表示ページを追加（設定 > Threads自動投稿） ----
add_action('admin_menu', function () {
    add_options_page(
        'Threads自動投稿',
        'Threads自動投稿',
        'manage_options',
        'weblog-threads-status',
        'weblog_render_threads_status_page'
    );
});

function weblog_render_threads_status_page() {
    $token_updated_at = get_option('threads_token_updated_at', '未実行（wp-config.phpの初期トークンを使用中）');
    $expires_in = get_option('threads_token_expires_in');
    $last_result = get_option('threads_last_result', array());
    ?>
    <div class="wrap">
        <h1>Threads自動投稿 ステータス</h1>

        <?php if (isset($_GET['polled'])): ?>
        <div class="notice notice-info is-dismissible"><p>GASへの問い合わせを実行しました。</p></div>
        <?php endif; ?>

        <form method="post" action="<?php echo esc_url(admin_url('admin-post.php')); ?>" style="margin:16px 0;">
            <?php wp_nonce_field('weblog_manual_poll_token_action'); ?>
            <input type="hidden" name="action" value="weblog_manual_poll_token">
            <?php submit_button('今すぐGASに問い合わせる', 'secondary', 'submit', false); ?>
        </form>

        <h2>トークン</h2>
        <table class="widefat striped" style="max-width:700px;">
            <tr><th style="width:200px;">最終更新</th><td><?php echo esc_html($token_updated_at); ?></td></tr>
            <tr><th>最終チェック（GASへの問い合わせ）</th><td><?php echo esc_html(get_option('threads_poll_last_checked_at', '-')); ?></td></tr>
            <?php if ($expires_in): ?>
            <tr><th>有効期限（更新時点から）</th><td><?php echo esc_html(round($expires_in / 86400)); ?>日</td></tr>
            <?php endif; ?>
        </table>

        <h2 style="margin-top:24px;">直近の投稿</h2>
        <table class="widefat striped" style="max-width:700px;">
            <tr><th style="width:200px;">記事タイトル</th><td><?php echo esc_html($last_result['title'] ?? '-'); ?></td></tr>
            <tr><th>結果</th><td><?php echo esc_html($last_result['status'] ?? '-'); ?></td></tr>
            <tr><th>詳細</th><td><?php echo esc_html($last_result['detail'] ?? '-'); ?></td></tr>
            <tr><th>日時</th><td><?php echo esc_html($last_result['time'] ?? '-'); ?></td></tr>
        </table>
    </div>
    <?php
}

// ---- 9. 直近の投稿が失敗している場合、管理画面上部に注意バナーを表示 ----
add_action('admin_notices', function () {
    $last_result = get_option('threads_last_result', array());
    if (!empty($last_result['status']) && $last_result['status'] === '失敗') {
        echo '<div class="notice notice-error"><p><strong>Threads自動投稿が失敗しました：</strong>「'
            . esc_html($last_result['title']) . '」 - ' . esc_html($last_result['detail'])
            . ' <a href="' . esc_url(admin_url('options-general.php?page=weblog-threads-status')) . '">詳細を見る</a></p></div>';
    }
});