【GAS】LISTENやStandFM(RSS)の更新をBlueskyに自動投稿！コード＆設定方法を紹介

/************** 設定値 *****************/
const FEED_URL  = 'ここにRSSフィードのURLをいれる';  // 取得したい RSSフィード
const SHEET_NAME = 'Feed';                     // 書き込み先シート名

/**
 * Blueskyのトークン保管（Script Properties）
 * Apps Script エディタ → プロジェクト設定 → スクリプト プロパティ で保存
 *    BSKY_USER:  your-handle.bsky.social
 *    BSKY_APP_PWD: xxxx-xxxx-xxxx-xxxx
 */
/****************************************/

/**
 * ========== 初回セットアップ専用 ==========
 * RSS フィードを読み取り、スプレッドシートへ保存するだけ。
 * Bluesky には投稿しない。
 *
 * 使い方: 手動で 1 回実行 → シートを確認 → 必要なら Posted を手動で FALSE に変更してください
 * TRUE: 投稿済として扱う
 * FALSE: 未投稿として扱う→運用用のプログラムを動かしたときにBlueskyに投稿される対象
 */
function initFetchFeed() {
  const items = getRss(FEED_URL);
  if (items.length === 0) { Logger.log('取得結果 0 件'); return; }

  const ss    = SpreadsheetApp.getActiveSpreadsheet();
  const sheet = ss.getSheetByName(SHEET_NAME) || ss.insertSheet(SHEET_NAME);

  // ヘッダー行を用意
  if (sheet.getLastRow() === 0) {
    sheet.appendRow(['Title','Link','Description','FetchedAt',
                     'Posted','PostedAt','BlueskyURL']);
  }

  /* ===== 既存リンクを取得（データ行がある時だけ） ===== */
  let existing = new Set();
  if (sheet.getLastRow() > 1) {                   // 行データが存在する場合のみ
    existing = new Set(
      sheet.getRange(2, 2, sheet.getLastRow() - 1, 1)
           .getValues()
           .flat()
    );
  }

  /* ===== 新規行を作成 ===== */
  const newRows = items
    .filter(it => !existing.has(it.link))
    .map(({title, link, description}) => [
      title, link, description, new Date(),
      true, '', ''    // Posted / PostedAt / BlueskyURL
    ]);

  if (newRows.length === 0) { Logger.log('新規 0 行'); return; }

  sheet.getRange(sheet.getLastRow() + 1, 1, newRows.length, 7)
       .setValues(newRows);

  Logger.log(`初回取得: ${newRows.length} 行を追加（投稿は行いません）`);
}

/**
 * ========== 運用用 ==========
 * (A) 新着フィードをシートへ追加
 * (B) Posted = FALSE の行を Bluesky へ投稿
 * 　↳ 投稿成功した行は Posted=TRUE, PostedAt, BlueskyURL を更新
 *
 * これを時間駆動トリガ（例: 15 分ごと）に設定しておく。
 */
function updateFeedAndPost() {
  /* --------- (A) 新着を取得してシートへ追加 --------- */
  const items = getRss(FEED_URL);
  const ss    = SpreadsheetApp.getActiveSpreadsheet();
  const sheet = ss.getSheetByName(SHEET_NAME) || ss.insertSheet(SHEET_NAME);

  if (sheet.getLastRow() === 0) {
    sheet.appendRow(['Title','Link','Description','FetchedAt',
                     'Posted','PostedAt','BlueskyURL']);
  }

  const existing = new Set(
    sheet.getRange(2, 2, Math.max(0, sheet.getLastRow()-1), 1)
         .getValues()
         .flat()
  );
  const freshRows = items
    .filter(it => !existing.has(it.link))
    .map(({title, link, description}) => [
      title, link, description, new Date(),
      false, '', ''
    ]);

  if (freshRows.length) {
    sheet.getRange(sheet.getLastRow()+1, 1, freshRows.length, 7)
         .setValues(freshRows);
    Logger.log(`新規追加: ${freshRows.length} 行`);
  } else {
    Logger.log('新規記事なし');
  }

  /* --------- (B) 未投稿行を Bluesky へ投稿 --------- */
  postUnsentToBluesky();   // ここは既に作成済みの関数を呼ぶだけ
}

/*================================================================
  RSSフィードを取得する
  @param url RSSフィードのURL
  @returns RSSフィードの結果の配列
================================================================*/

const getRss = (url = '') => {
  if (url) {
    const xml = UrlFetchApp.fetch(url).getContentText()
    const document = XmlService.parse(xml)
    const root = document.getRootElement()
    const rss1 = root.getChildren('item', XmlService.getNamespace('http://purl.org/rss/1.0/'))
    const atom = root.getChildren('entry', XmlService.getNamespace('http://www.w3.org/2005/Atom'))

    if (rss1.length > 0) {
      // RSS 1.0
      return processingRSS10(root)
    } else if (atom.length > 0) {
      // Atom
      return processingAtom(root)
    } else {
      // RSS 2.0
      return processingRSS20(root)
    }
  } else {
    return []
  }
}
/**
 * RSS 1.0 を処理
 * @param {XmlService.Element} root
 * @return {{title:string,link:string,description:string}[]}
 */
function processingRSS10(root) {
  const RSS = XmlService.getNamespace('http://purl.org/rss/1.0/');
  const items = root.getChildren('item', RSS);

  return items.map(item => ({
    title:       item.getChildText('title', RSS),
    link:        item.getChildText('link',  RSS),
    description: item.getChildText('description', RSS) || ''
  }));
}

/**
 * RSS 2.0 を処理
 * @param {XmlService.Element} root
 * @return {{title:string,link:string,description:string}[]}
 */
function processingRSS20(root) {
  const items = root.getChild('channel').getChildren('item');

  return items.map(item => ({
    title:       item.getChildText('title')       || '',
    link:        item.getChildText('link')        || '',
    // description がない場合は content:encoded を fallback
    description: item.getChildText('description') ||
                 (item.getChildText('content:encoded') || '')
  }));
}

/**
 * Atom フィードを処理
 * @param {XmlService.Element} root
 * @return {{title:string,link:string,description:string}[]}
 */
function processingAtom(root) {
  const ATOM  = XmlService.getNamespace('http://www.w3.org/2005/Atom');
  const items = root.getChildren('entry', ATOM);

  return items.map(item => ({
    title:       item.getChildText('title', ATOM) || '',
    link:        item.getChild('link', ATOM)
                    ?.getAttribute('href')
                    ?.getValue() || '',
    description: item.getChildText('summary', ATOM) ||
                 item.getChildText('content', ATOM)  || ''
  }));
}

/**
 * Bluesky へ未投稿行を送信し、シートを更新する
 * シートに残っている Posted=FALSE の行だけ Bluesky へ投稿し
 * 成功したら Posted / PostedAt / BlueskyURL を更新する
 * 失敗時したら Posted は FALSE のまま残るので再実行でリトライ可
 * 本文は 300 文字制限を自動トリム
 * 外部リンクカードにサムネイル画像を付与（og:image → blob アップロード）
 */
function postUnsentToBluesky() {
  const ss    = SpreadsheetApp.getActiveSpreadsheet();
  const sheet = ss.getSheetByName(SHEET_NAME);
  if (!sheet) return;

  /* ===== 認証 ===== */
  const USER = PropertiesService.getScriptProperties().getProperty('BSKY_USER');
  const PWD  = PropertiesService.getScriptProperties().getProperty('BSKY_APP_PWD');
  if (!USER || !PWD) { Logger.log('USER/PWD 未設定'); return; }

  let accessJwt, did, handle;
  try {
    const loginRes = UrlFetchApp.fetch(
      'https://bsky.social/xrpc/com.atproto.server.createSession',
      { method:'post', contentType:'application/json', muteHttpExceptions:true,
        payload: JSON.stringify({ identifier: USER, password: PWD }) }
    );
    if (loginRes.getResponseCode() !== 200) {
      Logger.log(`[LOGIN] ${loginRes.getResponseCode()} : ${loginRes.getContentText()}`);
      return;
    }
    ({ accessJwt, did, handle } = JSON.parse(loginRes.getContentText()));
  } catch (e) { Logger.log(`LOGIN 例外: ${e}`); return; }

  /* ===== シート読み込み ===== */
  const data = sheet.getDataRange().getValues(); data.shift();      // ヘッダー
  const col  = { title:0, link:1, desc:2, posted:4, postedAt:5, url:6 };
  const bearer = { Authorization:`Bearer ${accessJwt}` };

  const tagsArr = ['#声日記', '#LISTEN', '#standfm', '#音声配信'];   // ←←←←←←←←←←←←←←←←←←← 好きなタグに変更できます
  const tagsStr = tagsArr.join(' ');
  const tagLen  = tagsStr.length + 2;                               // "\n\n" + tags

  data.forEach((row, i) => {
    if (row[col.posted] === true) return;          // 投稿済みスキップ

    const url   = row[col.link];

    /* ---------- 1) 本文（300 文字制限） ---------- */
    const title = trimTitle(row[col.title], 300 - url.length - tagLen - 1);
    const text  = `${title}\n${url}\n\n${tagsStr}`;

    /* ---------- 2) facet 生成 ---------- */
    const facets = buildFacets(text, url, tagsArr);

    /* ---------- 3) サムネイル取得 & blob アップロード ---------- */
    let thumbBlob;
    try {
      const thumbUrl = extractOgImage(url);
      if (thumbUrl) {
        const imgResp = UrlFetchApp.fetch(thumbUrl, { muteHttpExceptions:true });
        const blob    = imgResp.getBlob();
        if (blob.getBytes().length <= 950000) {                 // 950KB 以下だけアップ
          const uploadRes = UrlFetchApp.fetch(
            'https://bsky.social/xrpc/com.atproto.repo.uploadBlob',
            { method:'post', headers: bearer, payload: blob }
          );
          if (uploadRes.getResponseCode() === 200) {
            thumbBlob = JSON.parse(uploadRes.getContentText()).blob;
          }
        }
      }
    } catch(e) { Logger.log(`[THUMB] row=${i+2} : ${e}`); }

    /* ---------- 4) レコード ---------- */
    const record = {
      $type : 'app.bsky.feed.post',
      text,
      facets,
      createdAt : new Date().toISOString(),
      embed : {
        $type : 'app.bsky.embed.external',
        external : {
          uri        : url,
          title      : row[col.title],
          description: row[col.desc] || '',
          ...(thumbBlob ? { thumb: thumbBlob } : {})
        }
      }
    };

    /* ---------- 5) 投稿 ---------- */
    try {
      const resp = UrlFetchApp.fetch(
        'https://bsky.social/xrpc/com.atproto.repo.createRecord',
        { method:'post', contentType:'application/json', headers: bearer,
          muteHttpExceptions:true,
          payload: JSON.stringify({ repo:did, collection:'app.bsky.feed.post', record }) }
      );
      Logger.log(`[POST] row=${i+2} status=${resp.getResponseCode()}`);
      if (resp.getResponseCode() !== 200) return;

      const { uri } = JSON.parse(resp.getContentText());
      const webUrl  = atUriToWebUrl(uri, handle);
      const r       = i + 2;
      sheet.getRange(r, col.posted+1 ).setValue(true);
      sheet.getRange(r, col.postedAt+1).setValue(new Date());
      sheet.getRange(r, col.url+1    ).setValue(webUrl);
      Utilities.sleep(1500);
    } catch(e) {
      Logger.log(`[POST 例外] row=${i+2} : ${e}`);
    }
  });
}

/* =======================================================
   URL / タグを facet 化するユーティリティ
======================================================= */
function buildFacets(text, link, tags) {
  const utf8Len = s => Utilities.newBlob(s).getBytes().length;
  const facets = [];

  /* --- URL facet --- */
  const linkPos = text.indexOf(link);
  if (linkPos !== -1) {
    facets.push({
      index: {
        byteStart: utf8Len(text.slice(0, linkPos)),
        byteEnd  : utf8Len(text.slice(0, linkPos + link.length))
      },
      features: [{ $type: 'app.bsky.richtext.facet#link', uri: link }]
    });
  }

  /* --- Tag facets --- */
  tags.forEach(tag => {
    const pos = text.indexOf(tag);
    if (pos === -1) return;
    facets.push({
      index: {
        byteStart: utf8Len(text.slice(0, pos)),
        byteEnd  : utf8Len(text.slice(0, pos + tag.length))
      },
      features: [{ $type: 'app.bsky.richtext.facet#tag', tag: tag.slice(1) }]
    });
  });

  return facets;
}

/* 文字数トリム */
function trimTitle(title, maxLen) {
  if (title.length <= maxLen) return title;
  return title.slice(0, maxLen - 1) + '…';
}

/* og:image 抽出（最初の 1 枚）*/
function extractOgImage(pageUrl) {
  try {
    const html = UrlFetchApp.fetch(pageUrl, { muteHttpExceptions:true, followRedirects:true })
                  .getContentText();
    const m = html.match(/<meta[^>]+property=["']og:image["'][^>]+content=["']([^"']+)["']/i);
    return m ? m[1] : null;
  } catch(e) { return null; }
}

/**
 * at:// 形式 URI → https://bsky.app/… に変換
 * @param {string} atUri 例: at://did:plc:xxx/app.bsky.feed.post/3ke…
 * @param {string} handle ユーザーの @handle
 */
function atUriToWebUrl(atUri, handle) {
  // rkey は URI の最後のスラッシュ以降
  const rkey = atUri.split('/').pop();
  return `https://bsky.app/profile/${handle}/post/${rkey}`;
}

//////////////////////////////
// デバック用 //
//////////////////////////////

/**
 * もしBlueskyのログインにうまくいかない場合、以下のコードでログイン確認をする
 * 200 が返れば資格情報は正しい
 * 成功例: [LOGIN] status=200 body={"accessJwt":"eyJhbGciOi...","did":"did:plc:xxx", ...}

 * 401 が返る → handle / app-password のどちらかが不正
*/
function testBlueskyLogin() {
  const USER = PropertiesService.getScriptProperties().getProperty('BSKY_USER')?.trim();
  const PWD  = PropertiesService.getScriptProperties().getProperty('BSKY_APP_PWD')?.trim();

// ログインIDとAPPパスワードの確認
Logger.log(`USER='${USER}' PWD='${PWD}' len=${PWD.length}`);
  const res = UrlFetchApp.fetch(
    'https://bsky.social/xrpc/com.atproto.server.createSession',
    {
      method: 'post',
      contentType: 'application/json',
      muteHttpExceptions: true,
      payload: JSON.stringify({ identifier: USER, password: PWD })
    }
  );
  Logger.log('status=%s\nbody=%s', res.getResponseCode(), res.getContentText());
}

/** 
 * BlueskyのログインIDに、目に見えない文字が混入していないか確認するコード
 * 見えない特殊文字 (U+202C / RTL Mark など) 
 * 6d 61 … 6c だけなら ASCII なので問題なし
 * 末尾に 202c や 200f などが出たら 制御文字 が混入している
*/
function debugUserString() {
  const raw = PropertiesService.getScriptProperties().getProperty('BSKY_USER') || '';
  Logger.log('len=%s chars=%s', raw.length,
    [...raw].map(c => c.charCodeAt(0).toString(16)).join(' '));
}