バイスタンプとLINEを繋げてリバイスドライバー風変身エフェクトをつくる

{
  "talks": [
    {
      "use": 0,
      "stamp_id": 1,
      "talk": [
        {"character": "ikki", "text": "おい悪魔! 騙したな!"},
        {"character": "vice", "text": "何がだよ、ちゃんと助けただろが"},
        {"character": "ikki", "text": "俺のかーちゃんをまた食おうとしただろ!"},
        {"character": "vice", "text": "してない! してない!"},
        {"character": "ikki", "text": "とぼけるな!"},
        {"character": "vice", "text": "ちょっとこの人↑、何言っちゃってるんですかぁ?"},
        {"character": "ikki", "text": "もういい、お前には頼らない。俺が家族を守る!"},
        {"character": "vice", "text": "ふふーん、じゃあ俺っちも勝手にするもん!"},
        {"character": "ikki", "text": "勝手にしろ!"}
      ]
    },
    {
      "use": 0,
      "stamp_id": 0,
      "talk": [
        {"character": "vice", "text": "俺っち、待ちきれなーい!"},
        {"character": "ikki", "text": "沸いてきたぜ!"},
        {"character": "vice", "text": "よっ! 五十嵐家の長男坊!\n五十嵐一輝!"},
        {"character": "ikki", "text": "バイス!\nしっかりサポートしろよ!"},
        {"character": "vice", "text": "あいあいさー!"},
        {"character": "ikki", "text": "一気に行くぜ!"}
      ]
    },
    {
      "use": 1,
      "stamp_id": 1,
      "talk": [
        {"character": "vice", "text": "待ってました、変身ターイム!"},
        {"character": "ikki", "text": "はしゃぐな!"},
        {"character": "vice", "text": "早く、早く、俺っち待ちきれなーい!"},
        {"character": "ikki", "text": "分かってるから落ち着け!"},
        {"character": "vice", "text": "俺っちの活躍を全国のみんなが待ってるぜ!"},
        {"character": "ikki", "text": "そんなわけないだろ!"},
        {"character": "vice", "text": "あー、ヤキモチ焼いてるー"},
        {"character": "ikki", "text": "ちょっと黙ってろ!"}
      ]
    },
    (以下同様)
  ]
}

import os
import json
import urllib.request
import boto3
import logging

logger = logging.getLogger()
logger.setLevel(logging.INFO)

URL_REAPLY = 'https://api.line.me/v2/bot/message/reply'
HDADERS = {
            'Content-Type': 'application/json',
            'Authorization': 'Bearer ' + os.environ['LINE_CHANNEL_ACCESS_TOKEN']
          }

def lambda_handler(event, context):

    # S3アクセス準備
    s3 = boto3.client(
        service_name='s3',
        aws_access_key_id = os.environ['ACCESS_KEY_ID'],
        aws_secret_access_key = os.environ['SECRET_ACCESS_KEY'],
        region_name = os.environ['REGION']
    )

    # アイコン画像の取得準備(S3の署名付きURL発行(180秒間))
    icon_urls= {}

    icon_urls['vice'] = s3.generate_presigned_url(
        ClientMethod = 'get_object',
        Params = {
            'Bucket': os.environ['S3_BUCKET'],
            'Key': 'icon/vice.png'
        },
        ExpiresIn = 180,
        HttpMethod = 'GET'
    )

    # API GatewayからHTTP POSTデータを取得
    post_data = json.loads(event['body'])

    # LINEからのアクセス（主にuserIdの初回確認用）
    for message_event in post_data['events']:
        print('userId: '  + message_event['source']['userId'])
        body = {
            'replyToken': message_event['replyToken'],
            'messages': [
                {
                    "type": "text",
                    "text": "確認したぜ!",
                    "sender":{
                        "iconUrl": icon_urls['vice']
                    }
                }
            ]
        }
        req = urllib.request.Request(URL_REAPLY, headers=HDADERS,  method='POST', data=json.dumps(body).encode('utf-8'))
        with urllib.request.urlopen(req) as res:
            logger.info(res.read().decode("utf-8"))

    return {
        'statusCode': 200,
        'body': json.dumps('Revice Driver Effector End.')
    }

import os
import json
import random
import time
import urllib.request
import boto3
import logging

logger = logging.getLogger()
logger.setLevel(logging.INFO)

URL_PUSH = 'https://api.line.me/v2/bot/message/push'
HDADERS = {
            'Content-Type': 'application/json',
            'Authorization': 'Bearer ' + os.environ['LINE_CHANNEL_ACCESS_TOKEN']
          }

def lambda_handler(event, context):

    # S3アクセス準備
    s3 = boto3.client(
        service_name='s3',
        aws_access_key_id = os.environ['ACCESS_KEY_ID'],
        aws_secret_access_key = os.environ['SECRET_ACCESS_KEY'],
        region_name = os.environ['REGION']
    )

    # アイコン画像の取得準備(S3の署名付きURL発行(180秒間))
    icon_urls= {}

    icon_urls['ikki'] = s3.generate_presigned_url(
        ClientMethod = 'get_object',
        Params = {
            'Bucket': os.environ['S3_BUCKET'],
            'Key': 'icon/ikki.png'
        },
        ExpiresIn = 180,
        HttpMethod = 'GET'
    )

    icon_urls['vice'] = s3.generate_presigned_url(
        ClientMethod = 'get_object',
        Params = {
            'Bucket': os.environ['S3_BUCKET'],
            'Key': 'icon/vice.png'
        },
        ExpiresIn = 180,
        HttpMethod = 'GET'
    )

    # メッセージ内容を取得
    state    = int(event["state"])
    stamp_id = int(event["stamp_id"])

    if state == 1: # 変身前

        # シナリオデータを取得
        res   = s3.get_object(Bucket=os.environ['S3_BUCKET'], Key='talks.json')
        body  = res['Body'].read()
        talks_dic = json.loads(body.decode('utf-8'))
        talks = talks_dic['talks']

        # バイスタンプのIDで選択する
        talk_candidate = []
        for index, item in enumerate(talks):
            id = item['stamp_id']
            if id in [0, stamp_id] and item['use'] == 1:
                # id == 0 はバイスタンプに依存しない汎用トーク
                talk_candidate.append(index)

        talk_num = random.choice(talk_candidate)

        # 選択されたトークを開始
        for sentence in talks[talk_num]['talk']:
            line_message = {
                "to": os.environ['LINE_USER_ID'],
                "messages":[
                    {
                        "type": "text",
                        "text": sentence['text'],
                        "sender":{
                            "iconUrl": icon_urls[sentence['character']]
                        }
                    }
                ]
            }

            req = urllib.request.Request(URL_PUSH, headers=HDADERS,  method='POST', data=json.dumps(line_message).encode('utf-8'))
            with urllib.request.urlopen(req) as res:
                logger.info(res.read().decode("utf-8"))

            time.sleep(1.0)

    elif state == 2: # 変身

        # スタンプ画像の取得準備(S3の署名付きURL発行(180秒間))
        stamp_url = s3.generate_presigned_url(
            ClientMethod = 'get_object',
            Params = {
                "Bucket": os.environ['S3_BUCKET'],
                "Key": 'stamp/' + str(stamp_id) + '.png'
            },
            ExpiresIn = 180,
            HttpMethod = 'GET'
        )

        line_message = {
            "to": os.environ['LINE_USER_ID'],
            "messages":[
                {
                    "type": "image",
                    "originalContentUrl": stamp_url,
                    "previewImageUrl": stamp_url,
                    "sender":{
                        "iconUrl": icon_urls['ikki']
                    }
                }
            ]
        }

        req = urllib.request.Request(URL_PUSH, headers=HDADERS,  method='POST', data=json.dumps(line_message).encode('utf-8'))
        with urllib.request.urlopen(req) as res:
            logger.info(res.read().decode("utf-8"))

    else:
        pass

    return "End."

////////// 基本設定 /////////////////////////////////////////////////////////////

// 使用するのがM5Stampでも、M5Atom用のコードでコンパイル＆ボード設定書き込み可能
#include "M5Atom.h"

#define IR_RX_TX_FOR_STAMP_PIN  32
#define IR_RX_TX_FOR_DRIVER_PIN 33

#define STAMP_ID_MIN  1
#define STAMP_ID_MAX 75
#define COMMAND_CHANGE 152

#define RESET_MS 1000

// 全体としての状態
#define STATE_INIT   0
#define STATE_READY  1
#define STATE_CHANGE 2
uint8_t state = STATE_INIT;
uint8_t stamp_id = 0;
boolean is_set_driver = false;

void reset_parameter(){
  state = STATE_INIT;
  stamp_id = 0;
  is_set_driver = false;
  Serial.println("Reset Parameters.");
}

typedef struct send_data {
  uint8_t state;
  uint8_t stamp_id;
} SEND_DATA;

// マルチタスク用設定
QueueHandle_t xQueueMailbox;

////////// ネットワーク処理 //////////////////////////////////////////////////////////

#include <WiFiClient.h>
#include <WiFiClientSecure.h>
#include <PubSubClient.h>

// WiFi設定情報（自分の無線LAN環境）
const char* SSID     = "xxxxxxxxxxxxx";
const char* PASSWORD = "xxxxxxxxxxxxx";

// AWS IoT設定情報
const char* AWS_ENDPOINT = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx.amazonaws.com";
const int   AWS_PORT     = 8883;
const char* PUB_TOPIC    = "xxxxxxxxxxxxxxxx";
const char* CLIENT_ID    = "xxxxxxxxxxxxxxxx";

const char* ROOT_CA = "-----BEGIN CERTIFICATE-----\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"-----END CERTIFICATE-----\n";

const char* CERTIFICATE = "-----BEGIN CERTIFICATE-----\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"-----END CERTIFICATE-----\n";

const char* PRIVATE_KEY = "-----BEGIN RSA PRIVATE KEY-----\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\n" \
"-----END RSA PRIVATE KEY-----\n";

WiFiClientSecure httpsClient;
PubSubClient mqttClient(httpsClient);
char pubMessage[128];

void setup_wifi(){
  Serial.print("Connecting to ");
  Serial.println(SSID);

  uint8_t retry_counter = 0;
  WiFi.begin(SSID, PASSWORD);
  while(WiFi.status() != WL_CONNECTED){
      retry_counter++;
      delay(500);
      Serial.print(".");
      if(retry_counter % 6 == 0){
        // 3秒経って接続できなければ、WiFi.beginを再実行
        WiFi.disconnect();
        WiFi.begin(SSID, PASSWORD);
        Serial.println("");
      }
      if(retry_counter >= 30){
        // 2回やり直してもダメなら、本体そのものをリセット
        ESP.restart();
      }
  }

  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
}

void setup_awsiot(){
  httpsClient.setCACert(ROOT_CA);
  httpsClient.setCertificate(CERTIFICATE);
  httpsClient.setPrivateKey(PRIVATE_KEY);
  mqttClient.setServer(AWS_ENDPOINT, AWS_PORT);
}

void connect_awsiot() {
  while (!mqttClient.connected()) {
    Serial.print("Attempting MQTT connection...");
    if(mqttClient.connect(CLIENT_ID)) {
      Serial.println("Connected.");
    }else{
      Serial.print("Failed, rc=");
      Serial.print(mqttClient.state());
      Serial.println(" Try again in 3 seconds");
      // 3秒後にリトライ
      delay(3000);
    }
  }
}

void send_message(uint8_t state, uint8_t stamp_id){
  sprintf(pubMessage, "{\"state\": %d, \"stamp_id\": %d}", state, stamp_id);
  Serial.print("Publishing message to topic ");
  Serial.println(PUB_TOPIC);
  Serial.println(pubMessage);
  mqttClient.publish(PUB_TOPIC, pubMessage);
  Serial.println("Published.");
}

////////// IR信号送受信処理 ////////////////////////////////////////////////////////////

#define LEN_IR_DATA  8
#define IR_THRESHOLD_FOR_STAMP  800
#define IR_THRESHOLD_FOR_DRIVER 800
#define SEND_IR_DELAY_MS 20

// デバッグ用プリント
void print_binary(uint8_t data){
  for(uint8_t i=0;i<LEN_IR_DATA;i++){
    Serial.print(bitRead(data, LEN_IR_DATA-1-i)); // 8bitの左端から表示
  }
  Serial.println();
}

void send_start(uint8_t pin){
  digitalWrite(pin, HIGH);
  delayMicroseconds(6000);
  digitalWrite(pin, LOW);
  delayMicroseconds(500);
}

void send_bit_0(uint8_t pin){
  digitalWrite(pin, HIGH);
  delayMicroseconds(1500);
  digitalWrite(pin, LOW);
  delayMicroseconds(500);
}

void send_bit_1(uint8_t pin){
  digitalWrite(pin, HIGH);
  delayMicroseconds(500);
  digitalWrite(pin, LOW);
  delayMicroseconds(1500);
}

void send_ir(uint8_t pin, uint8_t data){
  pinMode(pin, OUTPUT); 

  send_start(pin);

  for(uint8_t i=0; i<LEN_IR_DATA; i++){
    // dataを左端から順に送信する
    if(bitRead(data, LEN_IR_DATA-1-i) == 0){
      send_bit_0(pin);
    }else{
      send_bit_1(pin);
    }
  }
}

void stamp_to_driver(){
  // スタンプから送出される信号をドライバーに伝える
  pinMode(IR_RX_TX_FOR_STAMP_PIN, INPUT_PULLUP);

  while(analogRead(IR_RX_TX_FOR_STAMP_PIN) < IR_THRESHOLD_FOR_STAMP){
    // 受信待ち待機
    ;
  }

  // 閾値を超えた(ONになった)ので、5500μs待つ
  delayMicroseconds(5500);

  // 送受信データは丁度1byteなので、1byteの変数に受信結果を収める
  uint8_t recv_data = 0;
  if(analogRead(IR_RX_TX_FOR_STAMP_PIN) >= IR_THRESHOLD_FOR_STAMP){
    // ここでも閾値を超えていれば、スタンプから信号が来たとみなし、およそ2000μsごとの読み取りを開始する
    for(uint8_t i=0; i<LEN_IR_DATA; i++){
      delayMicroseconds(2030);
      if(analogRead(IR_RX_TX_FOR_STAMP_PIN) < IR_THRESHOLD_FOR_STAMP){
        // ON:1500μs, OFF: 500μs ... 0
        // ON: 500μs, OFF:1500μs ... 1
        // なので、2000μ秒ごとのサイクルで1000μsの位置がONなら0、OFFなら1となる
        recv_data = recv_data | (1 << (LEN_IR_DATA-1-i));
      }
    }

    // クラウドへのデータ送信
    if(state == STATE_INIT && STAMP_ID_MIN <= recv_data && recv_data <= STAMP_ID_MAX){
      // バイスタンプのIDを1〜75と仮定
      stamp_id = recv_data;
      state = STATE_READY;
      // キューに送信指示を送る
      SEND_DATA send_data = {state, stamp_id};
      xQueueOverwrite(xQueueMailbox, &send_data);
    }

    delay(SEND_IR_DELAY_MS);

    // 読み取ったデータをドライバーへ伝える
    send_ir(IR_RX_TX_FOR_DRIVER_PIN, recv_data);

    // スタンプからドライバーへ伝えた結果を表示する
    Serial.print("Stamp -> Driver: ");
    //print_binary(recv_data);
    Serial.println(recv_data);
  }

  return;
}

void driver_to_stamp(){
  // ドライバーから送出される信号をスタンプに伝える
  pinMode(IR_RX_TX_FOR_DRIVER_PIN, INPUT_PULLUP);

  unsigned long start_millis = millis();
  while(analogRead(IR_RX_TX_FOR_DRIVER_PIN) < IR_THRESHOLD_FOR_DRIVER){
    if(is_set_driver){
      // ドライバーにセットされているときのみ実施する判定処理
      if(millis() - start_millis > RESET_MS){
        // 所定時間受信がなければ、パラメータをリセットして受信待ちを解除する
        reset_parameter();
        return;
      }
    }
  }

  // 閾値を超えた(ONになった)ので、5500μs待つ
  delayMicroseconds(5500);

  // 送受信データは丁度1byteなので、1byteの変数に受信結果を収める
  uint8_t recv_data = 0;
  if(analogRead(IR_RX_TX_FOR_DRIVER_PIN) >= IR_THRESHOLD_FOR_DRIVER){
    // ここでも閾値を超えていれば、ドライバーから信号が来たとみなし、およそ2000μsごとの読み取りを開始する
    for(uint8_t i=0; i<LEN_IR_DATA; i++){
      delayMicroseconds(2030);
      if(analogRead(IR_RX_TX_FOR_DRIVER_PIN) < IR_THRESHOLD_FOR_DRIVER){
        // ON:1500μs, OFF: 500μs ... 0
        // ON: 500μs, OFF:1500μs ... 1
        // なので、2000μ秒ごとのサイクルで1000μsの位置がONなら0、OFFなら1となる
        recv_data = recv_data | (1 << (LEN_IR_DATA-1-i));
      }
    }

    // ここまで受信できたら、スタンプがドライバーにセットされたと判定
    is_set_driver = true;

    // クラウドへのデータ送信
    if(state == STATE_READY && recv_data == COMMAND_CHANGE){
      state = STATE_CHANGE;
      send_message(state, stamp_id);
    }

    delay(SEND_IR_DELAY_MS);

    // 読み取ったデータをスタンプへ伝える
    send_ir(IR_RX_TX_FOR_STAMP_PIN, recv_data);

    // ドライバーからスタンプへ伝えた結果を表示する
    Serial.print("Stamp <- Driver: ");
    //print_binary(recv_data);
    Serial.println(recv_data);
  }  

  return;
}

////////// タスク定義 ////////////////////////////////////////////////////////////

void wifi_task(void *pvParameters){
  while(1){
    if(mqttClient.connected()){
      // キューに何か入っていれば、データをクラウドに送信する
      if(uxQueueMessagesWaiting(xQueueMailbox) > 0){
        SEND_DATA send_data;
        xQueueReceive(xQueueMailbox, &send_data, 0);
        send_message(send_data.state, send_data.stamp_id);
      }
    }else{
      // 接続が切れていれば、再接続する
      M5.dis.drawpix(0, 0x00ff00); // 赤 (0xGGRRBB)
      connect_awsiot();
      M5.dis.drawpix(0, 0x0000ff); // 青 (0xGGRRBB)
    }
    delay(10);
  }
}

////////// メイン処理 ////////////////////////////////////////////////////////////

void setup(){
  M5.begin(true, false, true); // UART, I2C, LEDの初期化設定。LEDは初期化しないと使えない
  M5.dis.setBrightness(50);
  M5.dis.drawpix(0, 0x00ff00); // 赤 (0xGGRRBB)

  Serial.begin(115200);
  pinMode(IR_RX_TX_FOR_STAMP_PIN, INPUT_PULLUP);
  pinMode(IR_RX_TX_FOR_DRIVER_PIN, INPUT_PULLUP);

  // ネットワーク接続
  setup_wifi();
  setup_awsiot(); 

  // タスク間連携用のキュー（メールボックス）を作成
  xQueueMailbox = xQueueCreate(1, sizeof(SEND_DATA));

  // タスク生成、開始。優先度は loop_task(=1) > wifi_taskにする。
  // WiFi通信はloop_taskとは別のコアで実施させる
  xTaskCreateUniversal(
    wifi_task,          // 作成するタスク関数
    "wifi_task",        // 表示用タスク名
    8192,               // スタックメモリ量
    NULL,               // 起動パラメータ(設定しない)
    0,                  // 優先度 (低 0 <---> 24 高)
    NULL,               // タスクハンドル（設定しない）
    PRO_CPU_NUM         // 実行するコア(PRO_CPU_NUM: 0, APP_CPU_NUM: 1)
  );
}

void loop(){
  stamp_to_driver();
  driver_to_stamp();
  delay(1);
}