WordPress記事公開でThreadsへ自動投稿する仕組みをGASで自作した話【コード編】

// threads_auto_post.gs

function refreshAccessToken() {

  const props = PropertiesService.getScriptProperties();

  const token = props.getProperty('THREADS_ACCESS_TOKEN');

  const url = 'https://graph.threads.net/refresh_access_token'

    + '?grant_type=th_refresh_token'

    + '&access_token=' + token;

  const res = UrlFetchApp.fetch(url);

  const newToken = JSON.parse(res.getContentText()).access_token;

  props.setProperty('THREADS_ACCESS_TOKEN', newToken);

}

// WordPress側からの問い合わせに応答するWebアプリ

function doGet(e) {

  const props = PropertiesService.getScriptProperties();

  const secret = props.getProperty('SECRET');

  if (e.parameter.secret !== secret) {

    return ContentService

      .createTextOutput(JSON.stringify({ error: 'unauthorized' }))

      .setMimeType(ContentService.MimeType.JSON);

  }

  const token = props.getProperty('THREADS_ACCESS_TOKEN');

  return ContentService

    .createTextOutput(JSON.stringify({ token }))

    .setMimeType(ContentService.MimeType.JSON);

}

// 初回セットアップ時、自分のThreadsユーザーIDを調べるためのヘルパー

function getMyThreadsUserId() {

  const token = PropertiesService.getScriptProperties().getProperty('THREADS_ACCESS_TOKEN');

  const res = UrlFetchApp.fetch(

    'https://graph.threads.net/v1.0/me?fields=id,username&access_token=' + token

  );

  Logger.log(res.getContentText());

}

<?php

// functions.php に追記

// 記事公開時にThreadsへの自動投稿をスケジュールする

add_action( 'transition_post_status', function( $new_status, $old_status, $post ) {

    if ( $new_status !== 'publish' || $old_status === 'publish' ) {

        return;

    }

    if ( get_post_meta( $post->ID, '_threads_posted', true ) ) {

        return; // 二重投稿防止

    }

    // 管理画面の「公開」ボタンをブロックしないよう、5秒後に非同期実行

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

}, 10, 3 );

add_action( 'weblog_threads_post_event', 'weblog_post_to_threads' );

function weblog_post_to_threads( $post_id ) {

    if ( get_post_meta( $post_id, '_threads_posted', true ) ) {

        return;

    }

    $post          = get_post( $post_id );

    $access_token  = get_option( 'weblog_threads_access_token' );

    $threads_user  = get_option( 'weblog_threads_user_id' );

    $text          = weblog_build_threads_text( $post );

    // STEP1: コンテナ作成

    $container = wp_remote_post( "https://graph.threads.net/v1.0/{$threads_user}/threads", array(

        'body' => array(

            'media_type'   => 'TEXT',

            'text'         => $text,

            'access_token' => $access_token,

        ),

    ) );

    $body         = json_decode( wp_remote_retrieve_body( $container ) );

    $container_id = $body->id ?? null;

    if ( ! $container_id ) {

        return;

    }

    sleep( 3 ); // Threads側の処理待ち

    // STEP2: 公開

    wp_remote_post( "https://graph.threads.net/v1.0/{$threads_user}/threads_publish", array(

        'body' => array(

            'creation_id'  => $container_id,

            'access_token' => $access_token,

        ),

    ) );

    update_post_meta( $post_id, '_threads_posted', current_time( 'mysql' ) );

}

// 投稿文を組み立てる(ハッシュタグは1つだけ)

function weblog_build_threads_text( $post ) {

    $categories = get_the_category( $post->ID );

    $tag        = $categories ? '#' . $categories[0]->name : '#WordPress';

    return $post->post_title . "\n" . get_permalink( $post ) . "\n\n" . $tag;

}

<?php

// WP-Cronで1日1回、GASにトークンを問い合わせる

add_action( 'weblog_threads_token_sync', function() {

    $gas_url = get_option( 'weblog_threads_gas_url' );

    $secret  = get_option( 'weblog_threads_secret' );

    $url  = add_query_arg( 'secret', rawurlencode( $secret ), $gas_url );

    $res  = wp_remote_get( $url );

    $body = json_decode( wp_remote_retrieve_body( $res ), true );

    if ( ! empty( $body['token'] ) ) {

        update_option( 'weblog_threads_access_token', $body['token'] );

    }

} );

if ( ! wp_next_scheduled( 'weblog_threads_token_sync' ) ) {

    wp_schedule_event( time(), 'daily', 'weblog_threads_token_sync' );

}