SORACOM Funkを使ってみた。

AWS Summit TokyoでデバイスからLambdaを呼ぶには、FunnelからAWS IoT Coreを通すのがおすすめって聞いてたのに。。。(泣き笑い)っていう人です。（流石に事前に新サービス教えてもらえるわけがないw）

---

変更履歴

• 2019/07/11 添付したソースに不具合が見つかったのと、一部記述を修正

---

SORACOM Funk発表

さて、2019/7/3のSORACOM discovery 2019で、「SORACOM Funk」というサービスが発表されました。

今まで、デバイスから、AWS Lambdaを呼び出すには、

• Beam -> Amazon API Gateway -> Lambda
• Funnel -> AWS IoT Core -> Lambda

と言う手段がありましたが、
なんと、

• Funk -> Lambda

で
できるようになりました！
1つなくなっただけですが、これは大きい。
（怒られそうだけど、Amazon API GatewayとかAWS IoT Coreとか微妙にめんどいw）

実のところ、
上記の通り、デバイスから、Funnel経由で、AWS IoT Coreを呼び出して、Lambdaを実行するっていうのを試していたのですが。。。
不要
になりました。はい。

やってみた。

以前作ったSORACOM LTE-M Button powered by AWS(以下 #あのボタン)でボタン押したら、Slackに通知するLambdaがあったので、
LTE-M Button for Enterprise(以下 #しろボタン)とLTE-M Button Plus(以下 #ひげボタン)を押したら、FunkからそのLambdaを呼び出して、Slackに通知する仕組みを作ってみました。

なお、同じことがこちらに詳しく書いてありますー。

ゴールはこんな感じ(通知のアイコンがユニコーンガンダムなのは完全に趣味です。)

上から、#あのボタン #しろボタン #ひげボタン での通知

---

Slackはすでに設定済みなので割愛してます。すみません。

AWS側

権限設定

FunkからLambdaをInvokeするためのユーザーを作ります。
権限は最小権限だと以下になります。最小と言いつつ、Lambdaは全部叩けるようになっていますが。。。
そして、最初PowerUser権限持ってるユーザーでやってました。。。

{
   "Version": "2012-10-17",
   "Statement": [
     {
       "Sid": "SoracomFunkLambdaInvoke",
       "Effect": "Allow",
       "Action": [
           "lambda:InvokeFunction"
       ],
       "Resource": "arn:aws:lambda:*:*:function:*"
     }
   ]
 }

作成完了後に表示されるアクセスキーとシークレットキーは紛失すると再発行になるので、忘れずにメモっておく＆ダウンロードしておきましょう。漏洩注意（Lambdaしか叩けませんが、それでも何かするかもしれません）

Lambda

ソースはこんな感じ（あまり綺麗でなくてすみません）

• 3種類(#あのボタン と #しろボタン/#ひげボタン)のボタンに対応しています。
• #あのボタンからのリクエストの際は、SORACOM APIの/gadgets/{product_id}/{serial_number}からボタンの情報を取得
• #しろボタン/#ひげボタンからのリクエストの際は、同じくSORACOM APIの/subscribers/{imsi}からSIMの情報(現状利用しているのは名前だけ)を取得しています。
• Funkからのリクエストでは、context.clientContext.customオブジェクト内にIMSIなどの情報が入っています。#あのボタンの場合はeventオブジェクト内にデバイスID等が入っています。
  • 今後実装される簡易位置情報等の情報もcontext.clientContext.custom内に入ってくるんじゃないかと。

index.js

'use strict'
const request = require('request');
const moment = require('moment-timezone');
const AWS = require('aws-sdk');
AWS.config.update({ region: 'ap-northeast-1' });
const kms = new AWS.KMS();

const encryptedSlackWebHookUrl = process.env['SLACK_WEBHOOK_URL'];
let decryptedSlackWebHookUrl;
const encryptedSoracomKey = process.env['SORACOM_KEY'];
let decryptedSoracomKey;
const encryptedSoracomKeyId = process.env['SORACOM_KEY_ID'];
let decryptedSoracomKeyId;

const clickTypeNameJp = {
  'SINGLE': 'クリック',
  'DOUBLE': 'ダブルクリック',
  'LONG':'長押し'
}

/**
 * 初期化
 * @param  {[type]} event   [description]
 * @param  {[type]} context [description]
 * @return {[type]}         [description]
 */
const initialize = (event, context) => {
  return new Promise((resolve) => {
    console.log(JSON.stringify(event, 2));
    console.log(JSON.stringify(context, 2));
    const stash = {
      apiKey:'',
      token:'',
      serialNumber: '',
      imsi:'',
      remainingLife: '',
      clickType: '',
      clickTypeName: '',
      reportedTime:  '',
      batteryLevel: 0,
      gadgetInfo:{},
      simInfo:{},
      isButton: false,
    };
    if (event.deviceEvent) {
      stash.isButton = true;
      stash.serialNumber = event.deviceInfo.deviceId;
      stash.remainingLife =  event.deviceInfo.remainingLife;
      stash.clickType = event.deviceEvent.buttonClicked.clickType;
      stash.clickTypeName = clickTypeNameJp[`${event.deviceEvent.buttonClicked.clickType}`];
      stash.reportedTime = event.deviceEvent.buttonClicked.reportedTime;
    } else {

      stash.clickType = event.clickType;
      stash.clickTypeName = clickTypeNameJp[`${event.clickTypeName}`];
      stash.batteryLevel = event.batteryLevel;
      stash.imsi = context.clientContext.custom.imsi;
    }

    console.log(stash);
    resolve(stash);
  });
};
/**
 * キー情報復号化処理
 * @param  {[type]} stash [description]
 * @return {[type]}       [description]
 */
const decryptedUrl = (stash) => {
  return new Promise((resolve, reject) => {
      if (!decryptedSlackWebHookUrl) {

        kms.decrypt({ CiphertextBlob: new Buffer(encryptedSlackWebHookUrl, 'base64') }, (err, data) => {
            if (err) {
                console.log('Decrypt error:', err);
                reject(err);
            }
            decryptedSlackWebHookUrl = data.Plaintext.toString('ascii');
            resolve(stash);
        });
      } else {
        resolve(stash);
      }
  });
};
/**
 * キー情報復号化処理
 * @param  {[type]} stash [description]
 * @return {[type]}       [description]
 */
const decryptedKey = (stash) => {
  return new Promise((resolve, reject) => {
    if (!decryptedSoracomKey && !decryptedSoracomKeyId) {
        kms.decrypt({ CiphertextBlob: new Buffer(encryptedSoracomKey, 'base64') }, (err, data) => {
            if (err) {
                console.log('Decrypt error:', err);
                reject(err);
            }
            decryptedSoracomKey = data.Plaintext.toString('ascii');
            kms.decrypt({ CiphertextBlob: new Buffer(encryptedSoracomKeyId, 'base64') }, (err, data) => {
                if (err) {
                    console.log('Decrypt error:', err);
                    reject(err);
                }
                decryptedSoracomKeyId = data.Plaintext.toString('ascii');
                resolve(stash);
            });
        });

    } else {
      resolve(stash);
    }
  });
};
/**
 * SORACOM API Auth
 * @param  {[type]} stash [description]
 * @return {[type]}       [description]
 */
const getSoracomApiAuth = (stash) => {
  return new Promise((resolve, reject) => {
    const optionsAuth = {
      url: 'https://api.soracom.io/v1/auth',
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
        'Accept': 'application/json'
      },
      json: {
        'authKeyId':decryptedSoracomKeyId,
        'authKey':decryptedSoracomKey,
        'tokenTimeoutSeconds':86400
      }
    };
    // SORACOM Auth APIコール
    request(optionsAuth, function (error, response, body) {
      if (error) {
        console.log('Auth API Error: ' + error);
        reject(error);
      } else if (response.statusCode != 200) {
        console.log('Auth API Error response.statusCode: ' + response.statusCode);
        const err = {
          'statusCode': response.statusCode
        }
        reject(err);
      } else {
        console.log('APIコール成功(auth)');
        stash.apiKey = body.apiKey;
        stash.token = body.token;
        resolve(stash);
      }
    });
  });
};
/**
 * SORACOM SIM/ボタン情報取得
 * @param  {[type]} stash [description]
 * @return {[type]}       [description]
 */
const getSimGadgetInfo = (stash) => {
  return new Promise((resolve, reject) => {
    const apiKey = stash.apiKey;
    const token = stash.token;
    let options = {}
    const baseUrl = 'https://api.soracom.io/v1'
    if (stash.isButton) {

      options = {
        url: `${baseUrl}/gadgets/button/${stash.serialNumber}`,
        method: 'GET',
        headers: {
          'Content-Type': 'application/json',
          'Accept': 'application/json',
          'X-Soracom-API-Key': apiKey,
          'X-Soracom-Token': token
        }
      };
    } else {
      options = {
        url: `${baseUrl}/subscribers/${stash.imsi}`,
        method: 'GET',
        headers: {
          'Content-Type': 'application/json',
          'Accept': 'application/json',
          'X-Soracom-API-Key': apiKey,
          'X-Soracom-Token': token
        }
      };
    }
    // APIコール
    request(options, function (error, response, body) {
      if (error) {
        console.log('Gadgets API Error: ' + error);
        reject(error);

      } else if (response.statusCode != 200) {
        console.log('SORACOM API Error Response.statusCode: ' + response.statusCode);
        const err = {
          'statusCode': response.statusCode
        }
        reject(err);
      } else {
        console.log('APIコール成功 body:' + JSON.parse(body).operatorId);
        if (stash.isButton) {
          stash.gadgetInfo = JSON.parse(body);
        } else {
          stash.simInfo = JSON.parse(body);
        }
        resolve(stash);
      }
    });
  });
};

/**
 * Slack POST
 * @param  {[type]} stash [description]
 * @return {[type]}       [description]
 */
const postSlackMessage = (stash) => {
  return new Promise((resolve, reject) => {
    console.log('slack Call');
    let messageArray = [];
    if (stash.isButton) {
      const gadget = stash.gadgetInfo;
      messageArray.push(`ボタン ${gadget.tags.name} が${stash.clickTypeName}されました。`);
      const useCount = 1500 - gadget.attributes.remainingCount;
      messageArray.push(`現在のクリック数は${useCount}で残り${gadget.attributes.remainingCount}です。`);
      messageArray.push(`有効期限は${moment(gadget.attributes.contractEndingTime).tz("Asia/Tokyo").format('YYYY-MM-DD hh:mm:ss')}です。`);
    } else {
      const sim = stash.simInfo;
      messageArray.push(`ボタン ${sim.tags.name} が${stash.clickTypeName}されました。`);
      const battryLevelInfo = '電池残量は十分です。'
      if (stash.batteryLevel < 0.3) {
        battryLevelInfo = 'そろそろ電池交換の時期です。'
      }
      messageArray.push(`バッテリー残量は${stash.batteryLevel}です。${battryLevelInfo}`);
    }
    const message = messageArray.join('\n');
    // リクエスト設定
    const options = {
      url: decryptedSlackWebHookUrl,
      headers: {
        'Content-type': 'application/json'
      },
      body: {
        "text": message
      },
      json: true
    };

    // メッセージ送信
    request.post(options, function(error, response, body) {
      if (!error && response.statusCode == 200) {
        console.log('Slack API Successful!');
        resolve(stash);
      } else {
        if (error) {
            console.log('Slack API Error: ' + error);
            reject(error);
        } else {
          console.log('Slack API Error: ' + response.statusCode);
          const err = {
            'statusCode': response.statusCode
          }
          reject(err);
        }
      }
    });

  });
};
/**
 * Main処理
 * @param  {[type]}   event    [description]
 * @param  {[type]}   context  [description]
 * @param  {Function} callback [description]
 * @return {[type]}            [description]
 */
exports.handler = (event, context, callback) => {

  initialize(event, context)
    .then(decryptedKey)
    .then(getSoracomApiAuth)
    .then(getSimGadgetInfo)
    .then(decryptedUrl)
    .then(postSlackMessage)
    .catch(callback);
};

SORACOM側

SORACOMのユーザーコンソールで設定していきます。
- 作ったLambda Invoke用のユーザーのアクセスキーとシークレットキーを認証情報ストアに登録します。

• #しろボタンと#ひげボタン を利用するSIMグループに所属させます。
  

• 所属させたSIMグループの基本設定を選んで、次の項目を順次設定していきます。

  • SORACOM Air for Cellular設定でバイナリーパーサー設定を「ON」にし、フォーマットに「@button」を入力して保存
  • SORACOM Funk設定で、有効（ON）にした上で、以下を入力して、保存
    • サービス : AWS Lambda
    • 送信データ方式: JSON
    • 認証情報 : 認証情報ストアに登録した認証情報
    • 関数のARN : 呼び出し先のLambdaのARN（Lambdaのコンソールの右上に表示されている）
  • Unified Endpoint設定で、レスポンスのフォーマットで「SORACOM Funk」を選択して、保存

あとは、おもむろにボタンを押す！

Slackに通知がくれば、OKです。

ダメな場合ですが、
ボタンの場合、点滅が15秒ほど続いたあと、赤点滅する場合は、通信に失敗しています。
その前に赤点滅になる場合は、通信はできていますが、
設定が足りないなどで、Lambda関数を呼び出せていない、Lambda関数に問題がある可能性が高いので、
設定やLambda関数を再度確認してみてください。

---

いや、ほんと楽になりました。
次はWioLTEからリクエストしてみることにします。
流石にボタンじゃレスポンスまでは見れないので。。。

参考資料

• SORACOM discovery 2019 B1セッション資料