# AWS Lambda で Node.js を使って ChatWork にメッセージ送信する方法

const https = require("https");
const querystring = require("querystring");

// 環境変数から取得
const token = process.env.CHATWORK_TOKEN;
const room_id = process.env.CHATWORK_ROOM_ID;
const env = process.env.ENVIRONMENT;

exports.handler = function (event, context) {
  // メッセージの作成
  const postMessage =
    (env == "production" ? "[toall] " : "") +
    `${env} エラー発生! [code]${JSON.stringify(event)}[/code]`;

  // リクエストデータの準備
  const post_data = querystring.stringify({ body: postMessage });

  // リクエストオプション
  const options = {
    host: "api.chatwork.com",
    path: `/v2/rooms/${room_id}/messages`,
    headers: {
      "X-ChatWorkToken": token,
      "Content-Type": "application/x-www-form-urlencoded",
    },
    method: "POST",
  };

  // HTTPリクエストの送信
  const post_req = https.request(options, function (res) {
    res.setEncoding("utf8");
    res.on("data", function (chunk) {
      console.log("Response: " + chunk);
      context.succeed();
    });
    res.on("error", function (e) {
      console.log("Got error: " + e.message);
      context.fail("FAILURE");
    });
  });

  post_req.write(post_data);
  post_req.end();
};

const https = require("https");
const querystring = require("querystring");
const zlib = require("zlib");

const token = process.env.CHATWORK_TOKEN;
const room_id = process.env.CHATWORK_ROOM_ID;

exports.handler = function (event, context) {
  console.log("Event.awslogs: ", event.awslogs);

  // base64デコード
  const payload = Buffer.from(event.awslogs.data, "base64");

  // gzip解凍
  const parsed = JSON.parse(zlib.gunzipSync(payload).toString("utf8"));

  // 最新のログイベントを取得
  const logEvent = parsed["logEvents"][parsed["logEvents"].length - 1];

  // メッセージの作成
  const postMessage = `エラー発生! [code]${JSON.stringify(logEvent)}[/code]`;

  // リクエストデータの準備
  const post_data = querystring.stringify({ body: postMessage });

  // リクエストオプション
  const options = {
    host: "api.chatwork.com",
    path: `/v2/rooms/${room_id}/messages`,
    headers: {
      "X-ChatWorkToken": token,
      "Content-Type": "application/x-www-form-urlencoded",
    },
    method: "POST",
  };

  // HTTPリクエストの送信
  const post_req = https.request(options, function (res) {
    res.setEncoding("utf8");
    res.on("data", function (chunk) {
      console.log("Response: " + chunk);
      context.succeed();
    });
    res.on("error", function (e) {
      console.log("Got error: " + e.message);
      context.fail("FAILURE");
    });
  });

  post_req.write(post_data);
  post_req.end();
};