AI Telegram Bot: Cara Bikin Bot AI yang Ngasilin Duit dari Telegram Stars

# SSH ke VPS
ssh root@VPS_IP

# Update & install
apt update && apt upgrade -y
apt install -y python3-pip python3-venv git

# Setup project
mkdir ~/telegram-bot && cd ~/telegram-bot
python3 -m venv venv
source venv/bin/activate

# Install libraries
pip install python-telegram-bot==21.10 requests

# Install Ollama (buat AI lokal)
curl -fsSL https://ollama.com/install.sh | sh

# Download model — pilih salah satu:
# uncensored buat NSFW/roleplay
ollama pull noushermes2:7b  # uncensored, 7B param

# atau SFW aja
# ollama pull llama3.2:3b  # ringan, 3B param

# Test
ollama run noushermes2:7b "Halo, kamu adalah asisten AI yang ramah. Balas dengan singkat."

# bot.py — Telegram bot with AI + Stars monetization
import asyncio
import logging
from datetime import datetime, timedelta
from collections import defaultdict

from telegram import Update, LabeledPrice
from telegram.ext import (
    Application, CommandHandler, MessageHandler,
    filters, PreCheckoutQueryHandler, CallbackContext
)
import requests
import json

# === CONFIG ===
TOKEN = "YOUR_BOT_TOKEN_FROM_BOTFATHER"
OLLAMA_URL = "http://localhost:11434/api/generate"
MODEL = "noushermes2:7b"

# Pricing in Stars
STAR_PRICES = {
    "basic": {
        "stars": 385,       # ~$5
        "messages_per_day": 200,
        "label": "Basic"
    },
    "pro": {
        "stars": 770,       # ~$10
        "messages_per_day": 9999,
        "label": "Pro"
    },
    "vip": {
        "stars": 1540,      # ~$20
        "messages_per_day": 9999,
        "vip_access": True,
        "label": "VIP"
    }
}

FREE_DAILY_LIMIT = 20

# === STATE (in-memory — pake Redis/DB buat production) ===
user_subscriptions = {}   # user_id -> expiry_date
message_counts = defaultdict(lambda: 0)  # user_id -> count today
last_message_date = {}    # user_id -> date

logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__)

# === HELPERS ===

def get_ai_response(user_message: str, user_id: int) -> str:
    """Generate AI response via Ollama."""
    system_prompt = """Kamu adalah asisten AI yang ramah dan personal.
Balas dengan bahasa Indonesia yang santai.
Jaga percakapan tetap engaging.
Maksimal 3 paragraf."""

    prompt = f"{system_prompt}\n\nUser: {user_message}\nAsisten:"

    try:
        resp = requests.post(OLLAMA_URL, json={
            "model": MODEL,
            "prompt": prompt,
            "stream": False,
            "options": {
                "temperature": 0.8,
                "num_predict": 512
            }
        }, timeout=30)
        return resp.json()["response"].strip()
    except Exception as e:
        logger.error(f"Ollama error: {e}")
        return "Maaf, lagi error teknis. Coba lagi nanti."

def check_daily_limit(user_id: int) -> tuple[bool, int]:
    """Check if user can send a message today. Returns (allowed, remaining)."""
    today = datetime.now().date()
    
    # Reset count kalo beda hari
    if last_message_date.get(user_id) != today:
        message_counts[user_id] = 0
        last_message_date[user_id] = today
    
    # Cek subscription
    sub = user_subscriptions.get(user_id)
    if sub and sub > datetime.now():
        # Paid user — cek tier
        tier = sub.get("tier", "basic")
        limit = STAR_PRICES[tier]["messages_per_day"]
    else:
        limit = FREE_DAILY_LIMIT
    
    used = message_counts[user_id]
    remaining = limit - used
    
    if remaining <= 0:
        return False, 0
    
    message_counts[user_id] += 1
    return True, remaining - 1

# === HANDLERS ===

async def start(update: Update, context: CallbackContext):
    msg = (
        "Halo! Aku AI asisten pribadi kamu.\n\n"
        "✨ **Gratis:** 20 pesan per hari\n"
        "⭐ **Basic:** 200 pesan/hari — 385 Stars/bulan\n"
        "⭐ **Pro:** Unlimited — 770 Stars/bulan\n"
        "👑 **VIP:** Unlimited + akses foto — 1,540 Stars/bulan\n\n"
        "Ketik /subscribe buat upgrade."
    )
    await update.message.reply_text(msg, parse_mode="Markdown")

async def subscribe(update: Update, context: CallbackContext):
    """Show subscription options."""
    keyboard = [
        [InlineKeyboardButton("Basic — 385 Stars/bulan", callback_data="sub_basic")],
        [InlineKeyboardButton("Pro — 770 Stars/bulan", callback_data="sub_pro")],
        [InlineKeyboardButton("VIP — 1,540 Stars/bulan", callback_data="sub_vip")],
    ]
    reply = InlineKeyboardMarkup(keyboard)
    await update.message.reply_text(
        "Pilih paket subscription:",
        reply_markup=reply
    )

async def button_handler(update: Update, context: CallbackContext):
    """Handle subscription button clicks."""
    query = update.callback_query
    await query.answer()
    
    tier = query.data.replace("sub_", "")
    price_config = STAR_PRICES[tier]
    
    # Send invoice via Telegram Stars
    await context.bot.send_invoice(
        chat_id=query.message.chat_id,
        title=f"Subscription {price_config['label']}",
        description=f"{price_config['messages_per_day']} pesan/hari" + 
                    (" + akses VIP" if price_config.get("vip_access") else ""),
        payload=f"sub_{tier}",
        provider_token="",  # Empty = Telegram Stars
        currency="XTR",     # XTR = Telegram Stars
        prices=[
            LabeledPrice("Subscription", int(price_config["stars"]))
        ]
    )

async def pre_checkout(update: Update, context: CallbackContext):
    """Approve all incoming payments (validate payload here in production)."""
    query = update.pre_checkout_query
    await query.answer(ok=True)

async def successful_payment(update: Update, context: CallbackContext):
    """Activate subscription after payment."""
    payload = update.message.successful_payment.invoice_payload
    tier = payload.replace("sub_", "")
    user_id = update.effective_user.id
    
    # Set expiry 30 days from now
    user_subscriptions[user_id] = {
        "expires": datetime.now() + timedelta(days=30),
        "tier": tier
    }
    
    await update.message.reply_text(
        f"✅ Subscription **{STAR_PRICES[tier]['label']}** aktif!\n"
        f"{STAR_PRICES[tier]['messages_per_day']} pesan per hari.",
        parse_mode="Markdown"
    )

async def handle_message(update: Update, context: CallbackContext):
    """Process incoming messages."""
    user_id = update.effective_user.id
    user_text = update.message.text
    
    allowed, remaining = check_daily_limit(user_id)
    
    if not allowed:
        await update.message.reply_text(
            "❌ Limit harian habis.\n"
            "Ketik /subscribe buat upgrade ke unlimited."
        )
        return
    
    # Ty ping indicator biar user tau bot lagi mikir
    await context.bot.send_chat_action(
        chat_id=update.effective_chat.id,
        action="typing"
    )
    
    response = get_ai_response(user_text, user_id)
    
    await update.message.reply_text(response)
    
    # Reminder sisa pesan
    if remaining <= 5 and remaining > 0:
        await update.message.reply_text(
            f"💡 Sisa {remaining} pesan gratis hari ini. "
            "Ketik /subscribe buat unlimited."
        )

# === MAIN ===

def main():
    app = Application.builder().token(TOKEN).build()
    
    app.add_handler(CommandHandler("start", start))
    app.add_handler(CommandHandler("subscribe", subscribe))
    app.add_handler(CallbackQueryHandler(button_handler, pattern="^sub_"))
    app.add_handler(PreCheckoutQueryHandler(pre_checkout))
    app.add_handler(MessageHandler(filters.SUCCESSFUL_PAYMENT, successful_payment))
    app.add_handler(MessageHandler(filters.TEXT & ~filters.COMMAND, handle_message))
    
    logger.info("Bot started...")
    app.run_polling(allowed_updates=Update.ALL_TYPES)

if __name__ == "__main__":
    main()

cd ~/telegram-bot
source venv/bin/activate

# Jalanin di screen biar gak mati kalo SSH disconnect
screen -S telegram-bot
python3 bot.py
# Ctrl+A, D buat detach

PAID_FEATURES = {
    "basic": {
        "messages": 200,
        "photos": 0,        # No photo access
        "roleplay_depth": "basic"
    },
    "pro": {
        "messages": 9999,
        "photos": 5,        # 5 photos/day
        "roleplay_depth": "advanced"
    },
    "vip": {
        "messages": 9999,
        "photos": 50,       # Unlimited photo access
        "roleplay_depth": "full",
        "custom_personality": True
    }
}

# Contoh age gate
AGE_GATE_KEYBOARD = [
    [InlineKeyboardButton("✅ Saya 18+", callback_data="age_confirm")],
    [InlineKeyboardButton("❌ Saya di bawah 18", callback_data="age_reject")]
]

async def start_nsfw(update: Update, context: CallbackContext):
    await update.message.reply_text(
        "⚠️ Konten dewasa. Harus 18+.",
        reply_markup=InlineKeyboardMarkup(AGE_GATE_KEYBOARD)
    )