【AWS入門】電車遅延をSMS通知してくれるアプリを作成した（TwitterAPI利用）

$ curl --request GET 'https://api.twitter.com/2/tweets/counts/recent?start_time=2022-06-17T10:40:00.000Z&end_time=2022-06-17T10:45:00.000Z&granularity=day&query=JR' --header 'Authorization: Bearer {Bearer Tokenの値}'

{
    "data": [
        {
            "end": "2022-06-17T10:45:00.000Z",
            "start": "2022-06-17T10:40:00.000Z",
            "tweet_count": 478
        }
    ],
    "meta": { "total_tweet_count": 478 }
}

$ npm init -y
$ touch index.js
$ npm install

$ git init
$ git remote add origin git@github.com:<ユーザ名>/<リポジトリ名>.git
$ git branch -m main
$ git add .
$ git commit -m "initial commit"
$ git push origin main

$ npm install axios dotenv @aws-sdk/client-sns

const axios = require("axios");
require("dotenv").config();

module.exports.getTweetCount = async (startTime, endTime, query) => {
    // startTimeの書式："2022-05-12T22:00:00.000Z"
    // endTimeの書式："2022-05-13T00:00:00.000Z"
    // queryの書式："池袋線"

    const url = "https://api.twitter.com/2/tweets/counts/recent";

    const granularity = "day";
    const token = process.env.TOKEN;

    console.log(`startTime:${startTime}`)
    console.log(`endTime:${endTime}`)
    
    const req = encodeURI(
        `${url}?query=${query}&start_time=${startTime}&end_time=${endTime}&granularity=${granularity}`
    );

    try {
        const res = await axios.get(req, { headers: { Authorization: `Bearer ${token}` } });
        return res.data;
    } catch (error) {
        console.log(error);
    }
};

TOKEN=Twitterから払いだされたAPIキー

axios.get(<APIのURL>, <ヘッダーなどのconfig>)

const { setDateTime, getTweetCount } = require("./utils/utils");

const index = () => {
    const now = new Date();
    const now1mAgo = setDateTime(now, 0, 1);
    const yesterday = setDateTime(now, 1, 1);
    const now30mAgo = setDateTime(now, 0, 31);
    const yesterday30mAgo = setDateTime(now, 1, 31);

    const todayData = await getTweetCount(
        now30mAgo.toISOString(),
        now1mAgo.toISOString(),
        "山手線"
    );
    const yesterdayData = await getTweetCount(
        yesterday30mAgo.toISOString(),
        yesterday.toISOString(),
        "山手線"
    );

    const todayCount = todayData.data[0].tweet_count;
    const yesterdayCount = yesterdayData.data[0].tweet_count;

};

module.exports.setDateTime = (datetime, day = 0, minute = 0) => {
    return new Date(
        datetime.getFullYear(),
        datetime.getMonth(),
        datetime.getDate() - day,
        datetime.getHours(),
        datetime.getMinutes() - minute,
        datetime.getSeconds(),
        datetime.getMilliseconds()
    );
};

const todayCount = todayData.data[0].tweet_count;
const yesterdayCount = yesterdayData.data[0].tweet_count;

const REGION = "ap-northeast-1" //e.g. "us-east-1"
const { SNSClient, PublishCommand  } = require("@aws-sdk/client-sns") // npm install @aws-sdk/client-sns が必要

module.exports.sns = async (todayCount, yesterdayCount) => {
  
  const client = new SNSClient({ region: REGION })

  const params = {
    Message: `ツイート数が増えました。今日のカウント数：${todayCount}。昨日のカウント数：${yesterdayCount}` ,
    TopicArn: "arn:aws:sns:ap-northeast-1:<AWSアカウント>:ay-s-topic-test",
  }
  const command = new PublishCommand(params)

  try {
    const data = await client.send(command)
    console.log(data)
  } catch (error) {
    console.log(`error: ${error}`)
  } finally {
  }
}

module.exports.handler = index;

client.send(command)