SwitchBot Webhookを使ってデバイスの変更をDiscordで通知する方法

npm install wrangler
wrangler login
wrangler init

import { SwitchBotRequest } from "./types/SwitchBotRequest";

// 対象のデバイス種別(WoContactは開閉センサー)
const targetDeviceType = 'WoContact';

export default {
	async fetch(request: Request, env: Env, ctx: ExecutionContext): Promise<Response> {
		const url = new URL(request.url);
		// POST /hooks
		if (request.method === 'POST' && url.pathname.startsWith('/hooks')) {
			let data: SwitchBotRequest | null = null;

			try {
				data = await request.json<SwitchBotRequest>();
			} catch (e) {
				return new Response('Invalid request', { status: 400 })
			}


			// 対象のデバイスかどうか判定する
			if (data.context.deviceType !== targetDeviceType) {
				return new Response('', { status: 204 });
			}

			// Discord Webhookを送信する
			const webhookUrl = 'https://discord.com/api/webhooks/********';
			const resp = await fetch(webhookUrl, {
				method: 'POST',
				headers: {
					'Content-Type': 'application/json',
				},
				body: JSON.stringify({
					username: 'SwitchBot',
					content: data.context.openState === 'open' ? 'ドアが開きました' : data.context.openState === 'close' ? 'ドアが閉じました' : 'ドアが開きっぱなしです',
				}),
			})

			// 結果のステータスを返す
			return new Response(
				`result: ${resp.statusText}`,
				{
					status: 200,
					headers: {
						'Content-Type': 'text/plain',
					}
				}
			);

		}
		// パスに一致しない場合はエラー
		return new Response('Method Not Allowed', { status: 405 })
	},
};

export type SwitchBotRequest = {
	// イベント種別
	eventType: string;

	// イベントバージョン
	eventVersion: string;

	// 詳細情報
	context: {
		// デバイスのMACアドレス
		deviceMac: string;

		// デバイスの種類(開閉センサー: WoContact)
		deviceType: string;

		// 動体検知(検知: DETECTED, 未検知: NOT_DETECTED)
		detectionState: string;

		// ドアモード(帰宅: IN_DOOR, 外出: OUT_DOOR)
		doorMode: string;

		// 明るさ(明るい: bright, 暗い: dim)
		brightness: string;

		// ドアの開閉状態(開いている: open, 閉じている: close, 開きっぱなし: timeOutNotClose)
		openState: string;

		// イベント送信時のタイムスタンプ
		timeOfSample: number;
	};
};

npm run start

npm run deploy

package switchbot

import (
	"crypto/hmac"
	"crypto/sha256"
	"encoding/base64"
	"fmt"
)

// トークンを署名する
func generateSign(token string, secret string, t int64, nonce string) string {
	v := []byte(fmt.Sprintf("%s%d%s", token, t, nonce))
	h := hmac.New(sha256.New, []byte(secret))
	h.Write(v)
	sign := h.Sum(nil)
	result := base64.StdEncoding.EncodeToString(sign)
	return result
}

package switchbot

import (
	"errors"
	"fmt"
	"io"
	"net/http"
	"time"

	"github.com/google/uuid"
)

const baseURL = "https://api.switch-bot.com"

type SwitchBotClient struct {
	// アクセストークン
	token string

	// シークレットキー
	secret string

	// HTTPリクエストのタイムアウト
	timeout time.Duration
}

func NewSwitchBotClient(token string, secret string, timeout time.Duration) *SwitchBotClient {
	return &SwitchBotClient{
		token:   token,
		secret:  secret,
		timeout: timeout,
	}
}

func (c SwitchBotClient) SendRequest(method string, path string, body io.Reader) ([]byte, error) {
	req, err := http.NewRequest(method, baseURL+path, body)
	if err != nil {
		return nil, err
	}
	// トークンを署名する
	t := time.Now().UnixNano() / int64(time.Millisecond)
	nonce := uuid.New().String()
	sign := generateSign(c.token, c.secret, t, nonce)

	// 必須のリクエストヘッダーをセットする
	req.Header.Set("Content-Type", "application/json; charset=utf-8")
	req.Header.Set("Authorization", c.token)
	req.Header.Set("sign", sign)
	req.Header.Set("t", fmt.Sprint(t))
	req.Header.Set("nonce", nonce)

	client := &http.Client{
		// リソース節約のためにタイムアウトを設定する
		Timeout: c.timeout,
	}
	resp, err := client.Do(req)
	if err != nil {
		return nil, err
	}
	defer resp.Body.Close()

	if resp.StatusCode >= 400 {
		return nil, fmt.Errorf("error: bad status %d", resp.StatusCode)
	}
	fmt.Println("status: ", resp.Status)

	data, err := io.ReadAll(resp.Body)
	if err != nil {
		return nil, err
	}
	return data, nil
}

body := []byte(`{"action":"queryUrl"}`)
resp, err := c.SendRequest("POST", "/v1.1/webhook/queryWebhook", bytes.NewBuffer(body))