const request = require("request");
const fs = require("fs");
const csvParse = require("csv-parse/lib/sync");
const csvStr = require("csv-stringify/lib/sync");

// 開発時用にapiからのデータをjsonで保存
// 1時間に60リクエストまでなので
// getQiitaItems("天気", function(data) {
//   console.log(data.length);
//   fs.writeFile("test.json", JSON.stringify(data));
// });
// return 0;

let outputCsv = [["年月", "平均気温", "Qiita投稿数"]];

// 気象庁からの気温データcsvファイルの読み込み
let tempData = csvParse(fs.readFileSync("temp.csv"));

// qiita記事の天気に関する記事読み込み
// 開発用にローカルjsonファイルの読み込み
let articleData = JSON.parse(fs.readFileSync("test.json"));

// api使用バージョン
// getQiitaItems("天気", function (articleData) {
// });

// 一番古い記事の日付取得
let date = new Date(articleData[articleData.length - 1].created_at);

// 今月まで回す
while (formatDate(date, "yyyy-MM") != "2019-05") {
  let temp = getTemperature(date, tempData);
  let articleNum = getArticleNum(date, articleData);

  console.log(formatDate(date, "yyyy-MM") + " : " + temp + " : " + articleNum);

  outputCsv.push([formatDate(date, "yyyy-MM"), temp, articleNum]);
  // 次のループは翌月のデータ
  date.setMonth(date.getMonth() + 1);
}

// csvファイル出力
fs.writeFileSync("output.csv", csvStr(outputCsv));

function getTemperature(date, tempData) {
  // エラー処理したい
  let row = tempData[date.getFullYear() - 1897];
  return row[date.getMonth() + 1];
}

function getArticleNum(date, articleData) {
  let num = 0;
  for (let i = 0; i < articleData.length; i++) {
    if (articleData[i].created_at.slice(0, 7) == formatDate(date, "yyyy-MM")) {
      num++;
    }
  }
  return num;
}

function getQiitaItems(query, cb) {
  let resData = [];
  let page = 1;
  requestQiitaItems(page);

  function requestQiitaItems(page) {
    let uri =
      "https://qiita.com/api/v2/items?page=" + page + "&per_page=100&query=";
    uri += encodeURIComponent(query);

    console.log("request " + page + "times : uri=" + uri);
    request(uri, itemsCb);
  }

  function itemsCb(err, res, body) {
    if (err) {
      return err;
    }

    // console.log(res.headers.link);
    const info = JSON.parse(body);
    resData = resData.concat(info);

    if (info.length < 100) {
      cb(resData);
    } else {
      page++;
      requestQiitaItems(page);
    }
  }
}

// date: 日付オブジェクト
// format: 書式フォーマット
function formatDate(date, format) {
  format = format.replace(/yyyy/g, date.getFullYear());
  format = format.replace(/MM/g, ("0" + (date.getMonth() + 1)).slice(-2));
  format = format.replace(/dd/g, ("0" + date.getDate()).slice(-2));
  format = format.replace(/HH/g, ("0" + date.getHours()).slice(-2));
  format = format.replace(/mm/g, ("0" + date.getMinutes()).slice(-2));
  format = format.replace(/ss/g, ("0" + date.getSeconds()).slice(-2));
  format = format.replace(/SSS/g, ("00" + date.getMilliseconds()).slice(-3));
  return format;
}