3_bot_script_example.js

import { relayInit } from "nostr-tools";
import { upsertTableOrCreate, getSingle } from "nostr-key-value";
import dotenv from "dotenv";
import { postNostr, currUnixtime } from "./util/util.js";

dotenv.config();

// 必要な設定をしていきます。
const relayUrl = "wss://relay-jp.nostr.wirednet.jp";
const nsec = process.env.NSEC;
const npub = process.env.NPUB;
const tableName = "home_system";
const tableTitle = "home_system";

// Nostr 投稿文言作成
const send = (content, targetEvent = null) => {
  const created = targetEvent ? targetEvent.created_at + 1 : currUnixtime();
  const ev = {
    kind: 1,
    content: content,
    tags: [],
    created_at: created,
  };
  if (targetEvent) {
    ev.tags.push(["e", targetEvent.id]);
    ev.tags.push(["p", targetEvent.pubkey]);
  }
  postNostr(ev, nsec, relayUrl);
};

// メイン関数
const main = async () => {
  const relay = relayInit(relayUrl);
  relay.on("error", () => {
    throw "failed to connnect";
  });

  await relay.connect();
  const sub = relay.sub([
    // { kinds: [1], "#p": [getPublicKey(NPUB)], since: currUnixtime() - 60 },
    { kinds: [1], since: currUnixtime() },
  ]);

  // リプライ返信
  sub.on("event", async (ev) => {
    if (ev.content.match(/^扉の状態は？$/i)) {
      // 扉の状態を取得して、返事する処理
      const single = await getSingle([relayUrl], npub, tableName, "door_status");
      const result = single ?? "わかんない！"
      send(result, ev);
    }
    if (ev.content.match(/^開けて$/i)) {
      // 扉を開けて、状態をDBに保存する処理
      const values = [["door_status", "開いてる！"]];
      const table_ev = await upsertTableOrCreate(
        [relayUrl],
        npub,
        tableName,
        tableTitle,
        [],
        values
      );
      postNostr(table_ev, nsec, relayUrl);
      send("開けたよ！", ev);
    }
    if (ev.content.match(/^閉めて$/i)) {
      // 扉を閉めて、状態をDBに保存する処理
      const values = [["door_status", "閉まってる！"]];
      const table_ev = await upsertTableOrCreate(
        [relayUrl],
        npub,
        tableName,
        tableTitle,
        [],
        values
      );
      postNostr(table_ev, nsec, relayUrl);
      send("閉めたよ！！", ev);
    }
    if (ev.content.match(/^光あれ$/i)) {
      send("世界は光に包まれた", ev);
    }
  });
};

main().catch((e) => console.error(e));