TwitterでTILしたらGitHubに草が生える #Node.js

はじめに

TIL(Today I Learned): 今日学んだこと

をtwitterのつぶやきで行おうと思いました

#til というハッシュタグで学びをつぶやく
1日1回自分の投稿の #til ハッシュタグを拾いに行く
GitHubにコミット

というのがいけないかな〜と思ったのがきっかけです

AWSで CloudWatch Events + Lambda Functions あたりでできそうな気がしたのでやってみます

参考

準備

AWSアカウント
Twitter開発者アカウント
TILをコミットしていくGitHubリポジトリ

Twitter APIを利用するためには開発者アカウントの登録が必要です

※ 利用目的とか審査とかあってやや面倒です…

手順

Amazon CloudWatch Eventsで定期的にAWS Lambdaを起動
LambdaでTwitter APIを叩いて #til ツイートを取得
#til ツイートがあればGitHub APIを叩いてコミットする

アプリケーションの動きとしては上記の流れを想定します

なのでやらないといけないことは、

Lambda Functionsの作成
1. Twitter APIを叩いて #til ツイートを取得するjsを作る
2. GitHub APIを叩いてコミットするjsを作る
3. Lambdaに登録する
定期的にLambda Functionsを実行するCloudWatch Eventsの作成

という感じになります

1. Lambda Functionsの作成

最終的にはこんなjsができあがりました

色々詰め込み過ぎだし改善の余地は大いにありそうですが、中身を見ていきます

1-1. Twitter APIを叩いて `#til` ツイートを取得する

Twitter開発者アカウントを登録してアプリ作成を行うと、以下の値が得られます

Consumer API key
Consumer API secret key
Access token
Access token secret

これらを環境変数から設定し、twitterモジュールを利用します

const Twitter = require('twitter');

const twitterClient = new Twitter({
  consumer_key: process.env.API_KEY,
  consumer_secret: process.env.API_SECRET,
  access_token_key: process.env.ACCESS_TOKEN,
  access_token_secret: process.env.ACCESS_TOKEN_SECRET,
});

あとはTwitter APIのドキュメントを見ながら、特定のツイートを取得するように実装します

  const nowString = `${now.getFullYear()}-${now.getMonth() + 1}-${now.getDate() - 1}`;
  const params = {
    q: `(from:${process.env.ACCOUNT_NAME}) since:${nowString} ${TARGET_HASHTAG}`,
    count: process.env.MAX_COUNT || 5,
  };

  const tweets = await twitterClient.get('search/tweets', params).catch(() => []);

ACCOUNT_NAME は自分のTwitterアカウントを環境変数で設定します

最終的には毎日日付が変わったタイミングぐらいで実行させるので、前日以降のツイートに絞っています

※ jsの日付処理貧弱すぎない？みんなmoment.jsとか使うの？

実際はこのあとに各ツイートのハッシュタグを厳密にチェックしてますが、だいたい↑ぐらいでお目当てのツイートは取得できるはずです

1-2. GitHub APIを叩いてPRを作成する

これが地味に大変だった…

CLIなら git add して git commit して git push するだけのかんたんなお仕事ですが、APIでやろうとするとある程度踏み入った理解が必要になります

流れとしては blob を作って tree を作って commit を作って HEADのSHAを書き換える ということになります

    const prevRefsHead = await getRefsHead();
    const commitSha = prevRefsHead.object.sha;
    const prevCommit = await getCommit(commitSha);
    const blob = await postBlob(data[i]);
    const tree = await postTree(prevCommit.tree.sha, blob.sha, i + 1);
    const commit = await postCommit(commitSha, tree.sha, i + 1);
    await patchRefsHead(commit.sha);
    await sleep(1);