IoT初心者がSORACOM Buttonのボタンが押されたらkintoneに記録するハンズオンの準備

'use strict';

require('date-utils');
const fetch = require('node-fetch');

// kintone
const Host     = "cybozu.com";
const Protocol = "https://";
const Path     = "/k/v1/record.json";

exports.handler = async (event) => {
    
    // 簡単なセキュリティ対策例（環境変数のSeacretと合致するかチェック）
    if(event.headers.seacret !== process.env['Seacret']){
        let response = {
            statusCode: 400,
            body: JSON.stringify('Bad Request.'),
        };
        return response;
    }
    
    // kintoneに送るデータを編集
    let json = JSON.parse(event.body);
    let dt = new Date();    
    let parm = { 
        "日時": { "value" : dt.toFormat("YYYY-MM-DDTHH24:MI:SSZ") },
        "ボタンアクション": { "value" : json.clickTypeName },
        "バッテリーレベル": { "value" : json.batteryLevel },
        "IMSI": { "value" : event.headers['x-soracom-imsi'] },
        "IMEI": { "value" : event.headers['x-soracom-imei'] }
    };
    if(event.headers['x-soracom-geo-position-query-result'] === 'success'){
        let latlang = event.headers['x-soracom-geo-position'].split(';');
        parm.緯度 = { "value" : latlang[0] };
        parm.経度 = { "value" : latlang[1] };
    }
    
    // kintoneにデータを追加
    let url = Protocol + event.headers['kintone-host'] + '.' + Host + Path;
    await PostKintoneRecode(url, event.headers['kintone-appid'], event.headers['kintone-token'], parm);
    
    // レスポンスを返す
    let response = {
        statusCode: 200,
        body: JSON.stringify('Post Data.'),
    };
};

// kintoneにデータを追加
async function PostKintoneRecode(url, appId, token, parm)
{
    try {
        const headers = {
            'Content-type': 'application/json',
            'X-Cybozu-API-Token': token
        };
        const body = JSON.stringify({ 'app' : appId, 'record' : parm });
        const response = await fetch(url, {
            method: 'post',
            body: body,
            headers: headers
        });
        const data = await response.json();
        console.log(data);
        return true;
    } catch (error) {
        console.log(JSON.stringify(error));
        return false;
    }
}

'use strict';

require('date-utils');
const fetch = require('node-fetch');

// kintone
const Host     = "cybozu.com";
const Protocol = "https://";
const Path     = "/k/v1/record.json";

// AWS IoT
const endpoint = process.env['Endpoint'];
const topic    = "soracom/button"
const aws      = require('aws-sdk');
const region   = 'ap-northeast-1';

exports.handler = async (event) => {
    
    // 簡単なセキュリティ対策例（環境変数のSeacretと合致するかチェック）
    if(event.headers.seacret !== process.env['Seacret']){
        let response = {
            statusCode: 400,
            body: JSON.stringify('Bad Request.'),
        };
        return response;
    }
    
    // kintoneに送るデータを編集
    let json = JSON.parse(event.body);
    let dt = new Date();    
    let parm = { 
        "日時": { "value" : dt.toFormat("YYYY-MM-DDTHH24:MI:SSZ") },
        "ボタンアクション": { "value" : json.clickTypeName },
        "バッテリーレベル": { "value" : json.batteryLevel },
        "IMSI": { "value" : event.headers['x-soracom-imsi'] },
        "IMEI": { "value" : event.headers['x-soracom-imei'] }
    };
    if(event.headers['x-soracom-geo-position-query-result'] === 'success'){
        let latlang = event.headers['x-soracom-geo-position'].split(';');
        parm.緯度 = { "value" : latlang[0] };
        parm.経度 = { "value" : latlang[1] };
    }
    
    // kintoneにデータを追加
    let url = Protocol + event.headers['kintone-host'] + '.' + Host + Path;
    await PostKintoneRecode(url, event.headers['kintone-appid'], event.headers['kintone-token'], parm);
    
    // パトランプ用MQTTS送信（publish）
    let iotdata = new aws.IotData( {endpoint: endpoint, region: region});
    var params = {
        topic: topic,
        payload: json.clickTypeName + " " + event.headers['x-soracom-imei'],
        qos: 0
    };
    await iotdata.publish(params).promise();
    
    // レスポンスを返す
    let response = {
        statusCode: 200,
        body: JSON.stringify('Post Data.'),
    };
};

// kintoneにデータを追加
async function PostKintoneRecode(url, appId, token, parm)
{
    try {
        const headers = {
            'Content-type': 'application/json',
            'X-Cybozu-API-Token': token
        };
        const body = JSON.stringify({ 'app' : appId, 'record' : parm });
        const response = await fetch(url, {
            method: 'post',
            body: body,
            headers: headers
        });
        const data = await response.json();
        console.log(data);
        return true;
    } catch (error) {
        console.log(JSON.stringify(error));
        return false;
    }
}

using System.Runtime.InteropServices;

namespace ConsoleApp1
{
    public class Patlamp
    {
       // ＜重要＞ここで USB_PAT_Tower.dll のメソッド等を DllImport します 
       // 著作が曖昧なため、こちらへの引用はしていません
       // 
       // USB_PAT_Tower.dll の各メソッド等を DllImport するコードは 
       // 株式会社パトライト さんのサンプル \LR6-USB_Sample_code\CS\Samplecode\Form1.cs 
       // を参考にをそのまま引用したため掲載を避けました
       // サンプルは https://www.patlite.co.jp/login/ にて会員登録後に無償でダウンロードできます
       
       private int UTPOpen = -1;

        public Patlamp()
        {
            UTPOpen = UPT_Open();
            if(UTPOpen == 0)
            {
                UPT_Reset();
            }
        }

        public void Red()
        {
            if (UTPOpen == 0)
            {
                UPT_SetTower(ON_STATIC, OFF_STATIC, OFF_STATIC, OFF_STATIC, ON_STATIC);
            }
        }

        public void Yellow()
        {
            if (UTPOpen == 0)
            {
                UPT_SetTower(OFF_STATIC, ON_STATIC, OFF_STATIC, ON_STATIC, OFF_STATIC);
            }
        }

        public void Green()
        {
            if (UTPOpen == 0)
            {
                UPT_SetTower(OFF_STATIC, OFF_STATIC, ON_STATIC, OFF_STATIC, OFF_STATIC);
            }
        }

        public void all()
        {
            if (UTPOpen == 0)
            {
                UPT_SetTower(ON_STATIC, ON_STATIC, ON_STATIC, OFF_STATIC, OFF_STATIC);
            }
        }

        public void Beep()
        {
            if (UTPOpen == 0)
            {
                UPT_SetBuzEx(ON_STATIC, 0, BUZ_PITCH1, BUZ_PITCH_DFLT);
            }
        }

        public void Clear()
        {
            if (UTPOpen == 0)
            {
                UPT_SetTower(OFF_STATIC, OFF_STATIC, OFF_STATIC, OFF_STATIC, OFF_STATIC);
            }
        }

        public void Reset()
        {
            if (UTPOpen == 0)
            {
                UPT_Reset();
            }
        }

        public void Close()
        {
            if (UTPOpen == 0)
            {
                UPT_Close();
                UTPOpen = -1;
            }
        }
    }
}

using System;
using System.Security.Cryptography.X509Certificates;
using System.Text;
using System.Threading;
using uPLibrary.Networking.M2Mqtt;
using uPLibrary.Networking.M2Mqtt.Messages;

namespace ConsoleApp1
{
    class Program
    {

        const string endpoint = "AWS IoTCore MQTTS Host Address";
        const string caname = "key/AmazonRootCA1.pem";
        const string pfxname = "key/SoracomHanzon.pfx";
        const string pfxpassword = "SSLパスワード";
        const string topic = "soracom/button";

        static void Main(string[] args)
        {
            var patlamp = new Patlamp();
            patlamp.Clear();
            patlamp.Close();

            var caCert = X509Certificate.CreateFromCertFile(caname);
            var clientCert = new X509Certificate2(pfxname, pfxpassword);

            AWSIot iot = new AWSIot(endpoint, clientCert, caCert);

            // Subscribe
            iot.Recv += Recv;
            iot.Subscribe(topic);

            Console.ReadLine();
        }

        // MQTTSでメッセージを受信した
        static void Recv(string message)
        {
            int sleep = 500;
            Console.WriteLine(message);

            var patlamp = new Patlamp();
            // ボタンを1回押したら緑を1回点灯
            if (message.IndexOf("SINGLE") >= 0)
            {
                patlamp.Beep();
                patlamp.Green();
                Thread.Sleep(sleep);
                patlamp.Reset();
            }
            // ボタンを長押ししたら黄色を長めに点灯
            else if(message.IndexOf("LONG") >= 0)
            {
                patlamp.Beep();
                patlamp.Yellow();
                Thread.Sleep(sleep * 3);
                patlamp.Reset();
            }
            // ボタンを2回押したら赤を2回点灯
            else if (message.IndexOf("DOUBLE") >= 0)
            {
                patlamp.Beep();
                patlamp.Red();
                Thread.Sleep(sleep);
                patlamp.Reset();
                Thread.Sleep(sleep);
                patlamp.Beep();
                patlamp.Red();
                Thread.Sleep(sleep);
                patlamp.Reset();
            }
            patlamp.Close();
        }
    }

    delegate void RevcHandler(string message);

    class AWSIot
    {
        public event RevcHandler Recv = null;
        private const int BrokerPort = 8883;
        MqttClient client;

        public AWSIot(string endpoint, X509Certificate2 clientCert, X509Certificate rootCa)
        {
            client = new MqttClient(endpoint, BrokerPort, true, rootCa, clientCert, MqttSslProtocols.TLSv1_2);
            client.MqttMsgPublishReceived += MessageReceived;
            string clientId = Guid.NewGuid().ToString();
            client?.Connect(clientId);
            if (client.IsConnected)
            {
                Console.WriteLine("AWSIot Connected.");
            }
        }

        public void Subscribe(string Topic)
        {
            client.Subscribe(new[] { Topic }, new[] { MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE });
        }

        public void Publish(string Topic, string message)
        {
            client.Publish(Topic, Encoding.UTF8.GetBytes(message));
        }

        void MessageReceived(object sender, uPLibrary.Networking.M2Mqtt.Messages.MqttMsgPublishEventArgs e)
        {
            Recv(new String(Encoding.UTF8.GetChars(e.Message)));
        }
    }
}