Beebotteを使ってLINEからESP8266のGPIOを制御しよう

//LINEからのPOSTを処理する関数
function doPost(e) {
  //LINEから受け取ったデータをパースし、replyTokenを取り出す
  var replyToken= JSON.parse(e.postData.contents).events[0].replyToken;
  //replyTokenが存在しない場合は処理を終了
  if (typeof replyToken === 'undefined') {
    return;
  }
  //LINE Messaging APIのエンドポイント
  var url = 'https://api.line.me/v2/bot/message/reply';
  //認証に使用するチャネルトークンを入力
  var channelToken = 'あなたのチャネルトークン;

  //LINEから受け取ったデータをパースし、メッセージテキストを取り出す
  var receive_message = JSON.parse(e.postData.contents).events[0].message.text;
  //応答するメッセージのデフォルトのテキストを設定
  var reply_text = receive_message + "\n" + "は無効なメッセージです";

  //ONというメッセージを受け取った場合は「エアコンをつけます」というメッセージをLINEに返す
  if(receive_message == "ON") {
    beebottePub("ac_on"); //ac_onを引数としてbeebottePub関数を実行
    reply_text = "エアコンをつけます";

  //OFFというメッセージを受け取った場合は「エアコンを消します」というメッセージをLINEに返す
  } else if(receive_message == "OFF") {
    beebottePub("ac_off"); //ac_offを引数としてbeebottePub関数を実行
    reply_text = "エアコンを消します";
  }
  
  //LINEに対して応答メッセージを返すためのAPIコールを行う
  UrlFetchApp.fetch(url, {
    'headers': {
      'Content-Type': 'application/json; charset=UTF-8',
      'Authorization': 'Bearer ' + channelToken,
    },
    'method': 'post',
    'payload': JSON.stringify({
      'replyToken': replyToken,
      'messages': [{
        'type': 'text',
        'text': reply_text,
      }],
    }),
  });
  //処理が成功したことを示すレスポンスを返します。
  return ContentService.createTextOutput(JSON.stringify({'content': 'post ok'})).setMimeType(ContentService.MimeType.JSON);
}

function beebottePub(action) {
  var headers = {
    "Content-Type": "application/json",
    "X-Auth-Token": "トークンを入力"
  };
  var json = `{"data":"${action}"}`;
  var options = {
    "headers": headers,
    "method": "post",
    "payload": json
  };
  UrlFetchApp.fetch("https://api.beebotte.com/v1/data/publish/チャネル名/リソース名", options);
}

#include <ESP8266WiFi.h>
#include <WiFiClientSecure.h>
#include <PubSubClient.h> //MQTTクライアントライブラリ
#include <ArduinoJson.h>

#define MQTT_MAX_PACKET_SIZE 64 //MQTTメッセージの最大サイズを指定
#define onPin 14
#define offPin 12

const char* ssid = "あなたのWiFiのSSID";
const char* password = "あなたのWiFiのパスワード";

const char *clientID = "ESP8266";
const char* topic =  "AC_Control/remoteAC"; //チャネル名/リソース名
const char* host = "mqtt.beebotte.com";

//Beebotteからメッセージを受け取ったときに呼び出される関数
void callback(char* topic, byte* payload, unsigned int length) {
  char buffer[MQTT_MAX_PACKET_SIZE];
  
  snprintf(buffer, sizeof(buffer), "%s", payload);   
  Serial.println("received:");
  Serial.print("topic: ");
  Serial.println(topic);
  Serial.println(buffer);

  // 受け取ったメッセージをデコード
  StaticJsonDocument doc;
  DeserializationError error = deserializeJson(doc, buffer);

  if (error) {
    Serial.println("deserializeJson() failed");
    return;
  }

  const char* parsedPayload = doc["data"];

  if (parsedPayload != NULL) {
    Serial.print("payload: ");
    Serial.println(parsedPayload);
    if (strcmp(parsedPayload, "ac_on") == 0) {
      digitalWrite(onPin, LOW);
      delay(500); 
      digitalWrite(onPin, HIGH);
    } else if (strcmp(parsedPayload, "ac_off") == 0) {
      digitalWrite(offPin, LOW);
      delay(500); 
      digitalWrite(offPin, HIGH);
    }
  }
}

WiFiClientSecure wifiClient;
PubSubClient client(host, 8883, wifiClient);
  
void setup() {
  Serial.begin(115200);
  Serial.println();
  WiFi.mode(WIFI_STA);
  
  pinMode(onPin, OUTPUT_OPEN_DRAIN);
  pinMode(offPin, OUTPUT_OPEN_DRAIN);

  digitalWrite(onPin, HIGH);
  digitalWrite(offPin, LOW);
  delay(1000);
  digitalWrite(offPin, HIGH);
}

void loop() {
  if (WiFi.status() != WL_CONNECTED) {
    Serial.print("connecting to ");
    Serial.print(ssid);
    Serial.println("...");
    WiFi.begin(ssid, password);

    if (WiFi.waitForConnectResult() != WL_CONNECTED) {
      Serial.println("failed to connect");
      delay(5000);
      return;
    } else {
      Serial.println("Connected!");
      Serial.println(WiFi.localIP());
    }
  }

  //MQTTに接続
  if (!client.connected()) {
    String username = "token:";
    username += "チャンネルトークン";
    client.connect(clientID, username.c_str(), NULL);

    if (client.connected()) {
      Serial.println("MQTT connected");
      client.setCallback(callback);
      
      client.subscribe(topic);
    } else {
      Serial.print("MQTT connection failed: ");
      Serial.println(client.state());
      delay(5000);
    }
  } else {
    client.loop();
  }
}

{
  "data": "ac_on"
}