Bikin bot Telegram AI Agent (versi trigger)

# 1. buat folder project
mkdir bot-ai && cd bot-ai

# 2. siapkan package.json
npm init -y

# 3. pasang library yang dibutuhkan
#    - node-telegram-bot-api : sambungan ke Telegram (Trigger + kirim pesan)
#    - ai + zod              : AI Agent, tools, dan validasi input
npm install node-telegram-bot-api ai zod

TELEGRAM_TOKEN=123456789:AAE-ContohTokenKamu_RAHASIA
AI_GATEWAY_API_KEY=vck_contoh_key_dari_vercel
SERPAPI_KEY=serpapi_contoh_key_buat_pencarian

// bot.js — PART 1: TRIGGER "When chat message received"
const TelegramBot = require('node-telegram-bot-api')
const { jalankanAgent } = require('./agent')

const bot = new TelegramBot(process.env.TELEGRAM_TOKEN, { polling: true })

// trigger: setiap ada pesan masuk, fungsi ini jalan
bot.on('message', async (msg) => {
  const chatId = msg.chat.id
  const teks = msg.text || ''
  if (!teks) return

  // tampilkan "sedang mengetik..." biar terasa hidup
  await bot.sendChatAction(chatId, 'typing')

  // ⬇️ pesan diteruskan ke AI Agent (Part 2) lalu dicek di Part 3
  await tanganiPesan(chatId, teks)
})

console.log('Bot AI Agent berjalan...')

// agent.js — PART 2: AI AGENT (otak dari workflow)
const { generateText, tool, stepCountIs } = require('ai')
const { z } = require('zod')

// (a) MEMORY — "Window Buffer Memory":
//     simpan beberapa pesan terakhir per chat, bukan seluruh riwayat.
const ingatan = {}
const MAX_PESAN = 10
const ambilMemori = (chatId) => ingatan[chatId] || []
function simpanMemori(chatId, role, content) {
  ingatan[chatId] = [...ambilMemori(chatId), { role, content }].slice(-MAX_PESAN)
}

// (b) TOOL — "SerpAPI": alat agar agent bisa cari info terbaru di Google
const cariGoogle = tool({
  description: 'Cari informasi terbaru di internet lewat Google (SerpAPI).',
  inputSchema: z.object({ query: z.string().describe('kata kunci pencarian') }),
  execute: async ({ query }) => {
    const url =
      'https://serpapi.com/search.json?q=' +
      encodeURIComponent(query) +
      '&api_key=' + process.env.SERPAPI_KEY
    const res = await fetch(url)
    const data = await res.json()
    return (
      data.organic_results?.slice(0, 3).map((r) => r.snippet).join('\n') ||
      'Tidak ada hasil.'
    )
  },
})

// (c) AGENT — gabungkan MODEL + MEMORY + TOOLS jadi satu "otak"
async function jalankanAgent(chatId, pesanUser) {
  simpanMemori(chatId, 'user', pesanUser)

  const { text } = await generateText({
    model: 'openai/gpt-4o-mini',          // ← "OpenAI Chat Model"
    system: 'Kamu asisten yang ramah, menjawab singkat dalam Bahasa Indonesia.',
    messages: ambilMemori(chatId),        // ← "Window Buffer Memory"
    tools: { cariGoogle },                // ← "SerpAPI" (tool yang boleh dipakai)
    stopWhen: stepCountIs(5),             // batas: maksimal 5 langkah berpikir
  })

  simpanMemori(chatId, 'assistant', text)
  return text
}

module.exports = { jalankanAgent }

// bot.js — PART 3: IF (cek hasil) → Success / Failure
// tempel fungsi ini di bawah Part 1.
async function tanganiPesan(chatId, teks) {
  try {
    // panggil AI Agent (Part 2)
    const jawaban = await jalankanAgent(chatId, teks)

    // ✅ CABANG TRUE — "Success: Send message"
    await bot.sendMessage(chatId, jawaban)
  } catch (err) {
    // ❌ CABANG FALSE — "Failure: Send message"
    console.error('Agent gagal:', err)
    await bot.sendMessage(
      chatId,
      '⚠️ Maaf, lagi ada gangguan sebentar. Coba kirim lagi ya.',
    )
  }
}

// bot.js — versi lengkap (Part 1 + Part 3 jadi satu file)
const TelegramBot = require('node-telegram-bot-api')
const { jalankanAgent } = require('./agent')

const bot = new TelegramBot(process.env.TELEGRAM_TOKEN, { polling: true })

// PART 1 — TRIGGER: pesan masuk
bot.on('message', async (msg) => {
  const chatId = msg.chat.id
  const teks = msg.text || ''
  if (!teks) return
  await bot.sendChatAction(chatId, 'typing')
  await tanganiPesan(chatId, teks)
})

// PART 3 — IF: berhasil → Success, gagal → Failure
async function tanganiPesan(chatId, teks) {
  try {
    const jawaban = await jalankanAgent(chatId, teks) // PART 2 (otak)
    await bot.sendMessage(chatId, jawaban)            // ✅ Success
  } catch (err) {
    console.error('Agent gagal:', err)
    await bot.sendMessage(chatId, '⚠️ Maaf, lagi ada gangguan. Coba lagi ya.') // ❌ Failure
  }
}

console.log('Bot AI Agent berjalan...')

# tes dulu di komputer/HP (memuat .env otomatis)
node --env-file=.env bot.js

# jalankan terus-menerus di VPS dengan PM2
pm2 start "node --env-file=.env bot.js" --name bot-ai
pm2 save
pm2 status