毎日AtCoderを解いていないと怒ってくるchokudai botを作った話

事の発端

ぼくがICPC後に急に競プロにハマり始めて、でも案外（案外でもないか）毎日精進を続けるのは難しかったので学科Slackにそれをサポートする botを配置しようという話になりました。

結論から言うと、1ヶ月ぐらいはうまく機能しましたが、だんだんみんな怒られるのに慣れてきてただただbotの投稿が流れるだけになってしまいました。

同じシステムを採用するなら、やる気に満ち溢れている数人だけで採用するのがいいと思います。

↓こんな感じで怒ってくる

仕様

• 毎晩8時に、その日に一問も解いていない場合 AtCoderやれ とメンションが来る
• 10時になっても問題を解いていないとさらに そろそろAtCoderやれ とメンションが来る
• 11時になっても問題を解いていないとさらに いい加減AtCoderやれ とメンションが来る
• Ratedな問題を解いた場合のみ、解いた問題の合計得点が200点以下なら、上述したメッセージが もうちょっとAtCoderやれ に変わる
• 次の日の0:10に前日に解いた問題のSummaryと何日連続で解いたかのStreakが表示される
• お叱りに対し、 やらない と返信するとその日の通知をミュートできる

こんな感じですかね。

実態

（このときのぼくは別のことでめっちゃ不機嫌でした、、ゆるして）

実装

Hubotで書きました。 script/main.jsを以下のように設定します（ユーザ名のところや時間の設定のところは省きました）。

const puppeteer = require('puppeteer');
const cron = require('cron').CronJob;

// https://stackoverflow.com/questions/9768444/possible-eventemitter-memory-leak-detected
require('events').EventEmitter.defaultMaxListeners = 0

// ここにAtCoderユーザ名とSlackIDのペアを設定する
const id = {
  'xuzijian629': 'XXXXXXXX'
};
let latestPointsum = {};
let mute = {};

async function getSolvedProblems(user, date, update) {
  let ret = {solved: []};
  try {
    const browser = await puppeteer.launch();
    const page = await browser.newPage();
    await page.goto(`https://kenkoooo.com/atcoder/?user=${user}&kind=user`, {waitUntil: "networkidle2", timeout: 3000000});
    await page.waitFor(60000);
    let streak = await page.$('#root > div > div > div > div > div:nth-child(3) > div:nth-child(7) > h3');
    ret['streak'] = await (await streak.getProperty('textContent')).jsonValue();
    let longestStreak = await page.$('#root > div > div > div > div > div:nth-child(3) > div:nth-child(6) > h3');
    ret['isLongest'] = ret['streak'] === await (await longestStreak.getProperty('textContent')).jsonValue();
    if (ret['streak'] === '1 days') {
      ret['streak'] = '1 day';
    }
    let pointsum = await page.$('#root > div > div > div > div > div:nth-child(3) > div:nth-child(5) > h3');
    let sumvalue = await (await pointsum.getProperty('textContent')).jsonValue();
    sumvalue = Number(sumvalue);
    if (latestPointsum[user]) {
      ret['pointsum'] = sumvalue - latestPointsum[user];
    } else {
      ret['pointsum'] = undefined;
    }
    if (update) {
      latestPointsum[user] = sumvalue;
    }

    let problems = await page.$$('.react-bs-container-body > table > tbody > tr');
    let links = await page.$$('.react-bs-container-body > table > tbody > tr > td > a');
    let saved = {};
    for (let i = 0; i < problems.length; i++) {
      let problem = await (await problems[i].getProperty('textContent')).jsonValue();
      let link = await (await links[2 * i].getProperty('href')).jsonValue();
      if (problem.match(date) && problem.match('ACdetails') && !(link in saved)) {
        ret['solved'].push({
          problem: problem.match(/^20\d{2}-\d{2}-\d{2}(.*)ACdetails/)[1],
          link: link
        });
        saved[link] = 1;
      }
    }
    browser.close();
  } catch(e) {
    console.error(e);
  }
  return ret;
}

async function notifyIfUnsolved(robot, user, message, retry) {
  try {
    if (mute[id[user]]) return;
    const today = (new Date(Date.now() + 9 * 3600000)).toISOString().slice(0,10);
    let solved = await getSolvedProblems(user, today, false);
    if (solved['solved'].length === 0 && retry > 0) {
      console.log(`retrying for ${user}`);
      notifyIfUnsolved(robot, user, message, retry - 1);
      return;
    }
    console.log(`${user} solved:`);
    console.log(solved);
    if (solved['solved'].length === 0) {
      robot.send({room: '#daily_atcoder'}, `<@${id[user]}> ${message}`);
      return;
    }
    if (solved['pointsum'] && solved['pointsum'] < 300) {
      robot.send({room: '#daily_atcoder'}, `<@${id[user]}> もうちょっとAtCoderやれ`);
      return;
    }
  } catch(e) {
    console.error(e);
    notifyIfUnsolved(robot, user, message, retry - 1);
  }
}

async function summarize(robot, user, retry) {
  try {
    const today = (new Date(Date.now() + 9 * 3600000 - 600000)).toISOString().slice(0,10);
    let solved = await getSolvedProblems(user, today, true);
    if (solved['solved'].length === 0 && retry > 0) {
      console.log(`retrying for ${user}`);
      summarize(robot, user, retry - 1);
      return;
    }
    console.log(`${user} solved:`);
    console.log(solved);
    if (solved['solved'].length) {
      message = '';
      message += `<@${id[user]}> solved *${solved['solved'].length} problem${solved['solved'].length > 1 ? 's' : ''}*!!`;
      if (solved['pointsum']) message += ` Total *${solved['pointsum']} points* (Rated only)`;
      message += '\n';
      if (user in id) {
        message += `That's *${solved['streak']}* in a row to solve problems at AtCoder!${solved['isLongest'] ? " That's a new record!!" : ''}\n`;
      }

      for (let s of solved['solved']) {
        message += `${s.problem} ${s.link}\n`;
      }
      robot.send({room: '#daily_atcoder'}, message.slice(0, message.length - 1));
      mute[id[user]] = false;
    }
  } catch(e) {
    console.error(e);
    summarize(robot, user, retry - 1);
  }
}

async function init() {
  const today = (new Date(Date.now() + 9 * 3600000)).toISOString().slice(0,10);
  for (let user in id) {
    await getSolvedProblems(user, today, true, 2);
  }
}

module.exports = robot => {
  robot.hear(/test$/, res => {
    res.send('hoge');
  });

  robot.hear(/やらない$/, res => {
    mute[res.message.user.id] = true;
  });

  !(async() => {
    await init();
  })();

  // まあ他にも各投稿について設定します
  new cron('0 9 0 * * *', () => {
    for (let user in id) {
      !(async() => {
        await summarize(robot, user, 2);
      })();
    }
  }, null, true, 'Asia/Tokyo');
}

最後に

chokudaiさんはリアルにはめっちゃ優しい人なんでこんなこと言わないです