GASを中継サーバーにLINEからPico Wを遠隔操作する方法｜Webhookとポーリングで双方向通信【自作スマートリモコン 第5回】

// スクリプトプロパティ（GASの簡易データベース）を使って状態を管理します
const PROPERTY_KEY = 'AIR_CON_SIGNAL';

// 1. LINEからメッセージを受け取る関数 (Webhook)
function doPost(e) {
  try {
    const jsonString = e.postData.contents;
    const data = JSON.parse(jsonString);
    
    // LINEからのイベントを取得
    const event = data.events[0];
    if (event && event.type === 'message' && event.message.type === 'text') {
      const userMessage = event.message.text;
      const properties = PropertiesService.getScriptProperties();
      
      // 送られてきたメッセージの内容によって、保存する命令（ステータス）を変える
      if (userMessage.includes("冷房")) {
        properties.setProperty(PROPERTY_KEY, "COOL_ON");
      } else if (userMessage.includes("停止")) {
        properties.setProperty(PROPERTY_KEY, "COOL_OFF");
      } else if (userMessage.includes("現在の温度は")) {
        properties.setProperty(PROPERTY_KEY, "GET_TEMP");
      }
    }
    
    return ContentService.createTextOutput(JSON.stringify({status: 'post_success'}))
                         .setMimeType(ContentService.MimeType.JSON);
  } catch(error) {
    return ContentService.createTextOutput(JSON.stringify({status: 'error', message: error.toString()}))
                         .setMimeType(ContentService.MimeType.JSON);
  }
}

// 2. Pico Wから「命令ある？」と確認しにくる関数
function doGet(e) {
  const properties = PropertiesService.getScriptProperties();
  const currentSignal = properties.getProperty(PROPERTY_KEY) || "NONE";
  
  // Pico Wに現在のステータスを返す
  const responseData = { signal: currentSignal };
  
  // 何かしらの命令（NONE以外）があったら、確認されたのでリセット（消去）する
  if (currentSignal !== "NONE") {
    properties.setProperty(PROPERTY_KEY, "NONE");
  }
  
  return ContentService.createTextOutput(JSON.stringify(responseData))
                       .setMimeType(ContentService.MimeType.JSON);
}

#main.py

import machine
import dht
import network
import time
import urequests
import json
import gc

# 起動時のパーツ立ち上がりを待つ（超重要！）
time.sleep(3)

# --- 1. ご自身の環境に書き換えてください ---
WIFI_SSID = "あなたのWi-Fi_SSID"
WIFI_PASSWORD = "あなたのWi-Fi_パスワード"
LINE_TOKEN = "あなたのLINE_チャンネルアクセストークン"
USER_ID = "あなたのLINE_ユーザーID"

# 🔴 先ほど取得したGASのウェブアプリURL
GAS_URL = "https://script.google.com/macros/s/XXXXX/exec"

# --- 2. 見守りとピンの設定 ---
ALERT_TEMP = 28          # 警告温度
CHECK_INTERVAL = 10      # チェック間隔(秒)
TX_PIN = 17              # 赤外線LEDピン

# --- 3. エアコン信号データ（※前回取得した数字のリストに書き換えてください） ---
COOL_ON_DATA = [4307, 4535, 480, 1667, ...] 
COOL_OFF_DATA = [4368, 4507, 476, 1605, ...] 

sensor = dht.DHT11(machine.Pin(15))
wlan = network.WLAN(network.STA_IF)

def connect_wifi():
    wlan.active(True)
    if not wlan.isconnected():
        wlan.connect(WIFI_SSID, WIFI_PASSWORD)
        timeout = 15
        while not wlan.isconnected() and timeout > 0:
            time.sleep(1)
            timeout -= 1
        if not wlan.isconnected():
            machine.reset()

def send_ir(data):
    pwm = machine.PWM(machine.Pin(TX_PIN))
    pwm.freq(38000)
    def pwm_on(): pwm.duty_u16(21845)
    def pwm_off(): pwm.duty_u16(0)
    is_on = True
    for us in data:
        if is_on: pwm_on()
        else: pwm_off()
        time.sleep_us(us)
        is_on = not is_on
    pwm_off()
    pwm.deinit()

def send_line(message):
    response = None
    try:
        connect_wifi()
        url = "https://api.line.me/v2/bot/message/push"
        headers = {"Content-Type": "application/json; charset=UTF-8", "Authorization": f"Bearer {LINE_TOKEN}"}
        payload = {"to": USER_ID, "messages": [{"type": "text", "text": message}]}
        response = urequests.post(url, data=json.dumps(payload).encode('utf-8'), headers=headers)
    except Exception:
        pass
    finally:
        if response:
            try: response.close()
            except: pass

def check_gas_command():
    response = None
    try:
        connect_wifi()
        response = urequests.get(GAS_URL)
        if response.status_code in [301, 302, 303, 307, 308]:
            redirect_url = response.headers.get('location') if hasattr(response, 'headers') else None
            response.close()
            response = None
            if redirect_url: response = urequests.get(redirect_url)
            else: return "NONE"
        
        text_data = response.text
        if text_data.startswith('<'): return "NONE"
        return json.loads(text_data).get("signal", "NONE")
    except Exception:
        return "NONE"
    finally:
        if response:
            try: response.close()
            except: pass

# --- メイン処理 ---
send_line("遠隔エアコン操作システムが起動しました！監視と命令待ちを開始します。")
alert_sent = False
error_count = 0

while True:
    try:
        sensor.measure()
        temp = sensor.temperature()
        humidity = sensor.humidity()
        
        if temp >= ALERT_TEMP:
            if not alert_sent:
                send_line(f"【警告】室温が{temp}°Cになりました！エアコンを確認してください。（湿度: {humidity}%）")
                alert_sent = True
        else:
            if alert_sent:
                send_line(f"室温が{temp}°Cに下がりました。安全圏内です。")
                alert_sent = False
                
        cmd = check_gas_command()
        if cmd == "COOL_ON":
            send_ir(COOL_ON_DATA)
            send_line(f"エアコンに冷房ON信号を送信しました。（現在の室温: {temp}°C）")
        elif cmd == "COOL_OFF":
            send_ir(COOL_OFF_DATA)
            send_line(f"冷房OFFの信号を発信しました。（現在の室温: {temp}°C）")
        elif cmd == "GET_TEMP":
            send_line(f"現在のお部屋の状況です。\n温度: {temp}°C\n湿度: {humidity}%")
            
        error_count = 0
            
    except Exception:
        error_count += 1
        time.sleep(5)
        if error_count >= 5: machine.reset() # 連続エラー時はシステム再起動
        
    finally:
        gc.collect() # メモリ解放
        time.sleep(CHECK_INTERVAL)