何したの？

実は弊社には集中力を持続させるためちょいちょいお昼寝する方が多いのです。
しかし、寝すぎてしまう人もちらほら・・・

そこで、お昼寝する前に、「15分寝る」場合は /sleep 15とコマンドを叩いて、時間が経ったら @here 〇〇さんを起こしましょうと通知できるようにしました。（それをみたひとに起こしてもらうという運用で）

構成

Cloud Functions for Firebase
- Typescript で記述
Slack
- incoming webhook
- slash command

サーバーレスは最高。

事前にやっておくこと

チャンネルIDの取得

conversations.listのテスター
テスターを利用して、通知を行うチャンネルのIDを取得しておきます。

incoming webhookの設定

リマインダーを投稿するチャンネルのincoming webhookを設定して起きます。

slash commandの設定

オリジナルのコマンドを動かせるように設定します。今回は /sleep にしました。

実装

今回はfunctionふたつ用意するだけなのでとてもシンプルです。

一つはhttpリクエストで発火する関数、もう一つはcronjobで発行されるPubSubトピックメッセージで発火する関数です。
詳しくはこちらの記事を見てね。FirebaseでTwitterをbot化する

流れとしては、
1. /sleep をslackで実行すると,httpリクエスト(POST)が飛ぶ
2. httpリクエスト(POST)が飛んできたらリマインダをデータベースに登録。
3. 毎分実行されるcronジョブでリマインダを投稿、データベースからリマインダ情報を削除

という流れになります。

実際に作ったソースコードがこちら

index.ts

import * as functions from 'firebase-functions';
import * as admin from 'firebase-admin';
import * as axios from 'axios';
import {myMoment} from './myMoment';//moment-timezoneを利用して作成したクラス。後述
import * as shortid from 'shortid';

// slackのincoming webhookのurl
const URL = 'https://hooks.slack.com/services/XXXXXXXXX/XXXXXXXXX/XXXXXXXXXXXXXXXXX';

// dbに繋がるようにする
admin.initializeApp(functions.config().firebase);
const db = admin.firestore();

// httpリクエストで発火する関数
export const setReminder = functions.https.onRequest(async (req,res) => {
  console.log('fire!');
  try {
    if(req.method === 'POST'){
      const min = parseInt(req.body.text || 30);
      const user_id = req.body.user_id;
      const remindTime = myMoment().add(min, 'minutes').format('X');
      await db.collection('reminders').doc(shortid.generate()).set({
        user_id,
        remindTime
      });
      res.send('reminder is set.');
    }else{
      throw new Error('only post method is accepted');
    }

  } catch (error) {
    console.error('error');
    res.status(500).send(error);
  }
})

// cronjobで発火する関数
export const notifyReminder = functions.pubsub.topic('minutes-tick').onPublish(async (event) => {
  console.log('fire!');
  try {
    const now = myMoment().format('X');
    const queryData = await db.collection('reminders').where('remindTime', '<=', now).orderBy('remindTime', 'asc').get();
    const promises = queryData.docs.map(element => {
      const key = element.id;
      const data = element.data();
      return axios.default.post(URL, {
        text: `<!here> <@${data.user_id}>さんを起こしましょう`
      }).then(async () => {
        console.log(`finish to remind ${data.user_id}`);
        await db.collection('reminders').doc(key).delete();
      }).catch(error => {
        throw error;
      });
    });
    await Promise.all(promises);

  } catch (error) {
    console.error('error');
  }
});

myMoment.ts


import * as moment from 'moment-timezone';

moment.tz.setDefault("Asia/Tokyo");

moment.locale("ja", {
  weekdays: [
    "日曜日",
    "月曜日",
    "火曜日",
    "水曜日",
    "木曜日",
    "金曜日",
    "土曜日"
  ],
  weekdaysShort: ["日", "月", "火", "水", "木", "金", "土"]
});

export const myMoment = moment;

動作結果

ちゃんと動作してる！やったね！

まとめ

slackにコマンドを追加した
意外と簡単に追加できる
とりあえずバックエンドは迷ったら #Firebaseしろ

Firebase を駆使して Slack の slash command をつくってみた