Raye's Journey

export default defineComponent({
  props: {
    myDataStore: { type: "data_store" },
  },
  async run({ steps, $ }) {
    let items = steps.merge_rss_feeds.$return_value
    let lastItemId = await this.myDataStore.get("guid");
    let firstItem = items[0]
    let newItems = [];
    function getId(item) {
      return item.guid;
    }

    if (lastItemId) {
      for (const item of items) {
        if (getId(item) === lastItemId) {
          break;
        }
        newItems.push(item)
      }
    } else {
      newItems = [firstItem]
    }

    await this.myDataStore.set("guid",getId(firstItem))
    return newItems.reverse() // 先に古いメッセージを送信し、その後最新のメッセージを送信
  },
})

import { axios } from "@pipedream/platform"
export default defineComponent({
  props: {
    telegram_bot_api: {
      type: "app",
      app: "telegram_bot_api",
    },
    chat_id: {
      type: "string",
      label: "Chatid",
      default: "@RayeJourney",
    },
  },
  async run({steps, $}) {
    const items = steps.data_stores.$return_value 
    const results = []; // 各メッセージ送信操作の結果を格納するための配列
    for (const item of items) {
      // 送信するメッセージ内容を構築
      const message = `📝 ${item.title} #blog\n\n${item.url}`;

      // メッセージを送信
      const result = await axios($, {
        url: `https://api.telegram.org/bot${this.telegram_bot_api.$auth.token}/sendMessage`,
        method: 'POST',
        headers: {
          'Content-Type': 'application/json',
        },
        data: {
          chat_id: `${this.chatid}`, 
          text: message,
          parse_mode: 'HTML', // メッセージ内容にHTMLが含まれている場合はこのパラメータを設定
        },
      });

      // 各送信操作の結果を結果配列に追加
      results.push(result.data);
    }

    // すべての送信操作の結果を返す
    return results;
  },
})

telegram_bot_api: {
  type: "app",
  app: "telegram_bot_api",
},
chat_id: {
  type: "string",
  label: "Chatid",
  default: "@RayeJourney",
},

import { axios } from "@pipedream/platform"
export default defineComponent({
  props: {
    my_data_store: { 
      type: "data_store",
      label: "MyDataStore"
    },
    my_data_key: {
      type: "string",
      label: "MyDataKey",
      default: "xlog"
    },
    telegram_bot_api: {
      type: "app",
      app: "telegram_bot_api",
    },
    chat_id: {
      type: "string",
      label: "Chatid",
      default: "@RayeJourney",
    },
    message_template: { // メッセージは動的に埋め込む必要があるため、message_templateに変更
      type: "string",
      label: "Message",
      default: "📝 ${item.title} #blog\n\n${item.link}"
    }
  },
  async run({steps, $}) {
    const items = steps.merge_rss_feeds.$return_value // RSSから取得した情報を直接取得、最新のものが最初に来る
    // DBを取得
    let lastItem = await this.my_data_store.get(`${this.my_data_key}`) // 正しいデータストレージアクセス方法を使用していることを確認
    
    const results = []; // runメソッドの先頭に移動
    let newItem = []; // 送信するメッセージを格納
    const getId = (item) => {
      return item.link;
    };

    const sendMsg = async (item) => { // sendMsgは非同期であることを確認
      // 動的にメッセージ内容を構築
      const message = this.message_template.replace('${item.title}', item.title).replace('${item.link}', item.link);
      try {
        const result = await axios($, {
          url: `https://api.telegram.org/bot${this.telegram_bot_api.$auth.token}/sendMessage`,
          method: 'POST',
          headers: {
            'Content-Type': 'application/json',
          },
          data: {
            chat_id: this.chat_id, // this.chat_idを直接使用
            text: message,
            parse_mode: 'HTML',
          },
        });
        results.push(result.data); // 結果をresults配列に追加
      } catch (error) {
        console.error("メッセージ送信エラー:", error);
        // エラーを処理し、結果にエラー情報を追加
        results.push({error: "メッセージ送信に失敗しました", details: error.toString()});
      }
    };

    // 最新と最古の項目を正しく処理するためのロジックを確認
    for(const item of items){ // 最古のものを優先して処理するのではなく、最新のものから始める必要があります。古いものも追加されてしまうためです。
      if(lastItem && getId(item) === getId(lastItem)){
        break; // 最後に処理した項目を見つけた場合、処理を停止
      }
      newItem.push(item)
    }

    for(const item of newItem.reverse()){
      await sendMsg(item); // メッセージ送信を待機
    } 
    // データストレージ内のlastItemを今回処理した最新の項目に更新
    if (items.length > 0) {
      await this.my_data_store.set(this.my_data_key, items[0]); // items[0]が最新の項目であると仮定
    }

    // すべての送信操作の結果を返す
    return results;
  },
})