무료 텔레그램 봇 빌더

"""DashCloud 텔레그램 봇 빌더로 생성된 봇 (requests 롱폴링).

환경변수:
  TELEGRAM_BOT_TOKEN  (필수) @BotFather에서 발급한 봇 토큰
  TELEGRAM_API_BASE   (선택) 기본 https://api.telegram.org
"""
import json
import os
import time
from datetime import datetime
from pathlib import Path
from zoneinfo import ZoneInfo

import requests

TOKEN = os.environ["TELEGRAM_BOT_TOKEN"]
API_BASE = os.environ.get("TELEGRAM_API_BASE", "https://api.telegram.org").rstrip("/")
API = f"{API_BASE}/bot{TOKEN}"
CHAT_ID = os.environ.get("TELEGRAM_CHAT_ID", "")
ADMIN_CHAT_ID = os.environ.get("ADMIN_CHAT_ID", "")
KST = ZoneInfo("Asia/Seoul")
STATE_PATH = Path("state.json")

COMMANDS = {
    "start": {
        "description": "봇 시작",
        "response": "안녕하세요! 무엇을 도와드릴까요?",
        "admin": False,
    },
    "help": {
        "description": "도움말",
        "response": "사용 가능한 명령어를 안내해 드립니다.",
        "admin": False,
    },
}

KEYWORD_REPLIES = [
    (["안녕", "하이"], "안녕하세요!"),
]

WELCOME_TEXT = None

SCHEDULES = [
]

UPBIT = None


def load_state():
    if STATE_PATH.exists():
        try:
            return json.loads(STATE_PATH.read_text())
        except json.JSONDecodeError:
            pass
    return {"offset": 0, "schedule_done": {}, "upbit_armed": True}


def save_state(state):
    STATE_PATH.write_text(json.dumps(state, ensure_ascii=False))


def call(method, **payload):
    res = requests.post(f"{API}/{method}", json=payload, timeout=40)
    res.raise_for_status()
    return res.json()


def send(chat_id, text, markup=None):
    if not chat_id:
        print("[bot] chat_id가 없어 전송을 건너뜁니다", flush=True)
        return
    payload = {"chat_id": chat_id, "text": text, "disable_web_page_preview": True}
    if markup:
        payload["reply_markup"] = markup
    call("sendMessage", **payload)


def handle_message(message):
    text = (message.get("text") or "").strip()
    chat_id = (message.get("chat") or {}).get("id")
    if not text or chat_id is None:
        return
    if text == "/id":
        send(chat_id, f"이 채팅의 chat_id: {chat_id}")
        return
    if text.startswith("/"):
        name = text[1:].split()[0].split("@")[0].lower()
        entry = COMMANDS.get(name)
        if entry:
            if entry.get("admin") and str(chat_id) != str(ADMIN_CHAT_ID):
                send(chat_id, "관리자 전용 명령입니다.")
                return
            send(chat_id, entry["response"], entry.get("markup"))
        return
    lowered = text.lower()
    for words, response in KEYWORD_REPLIES:
        if any(word.lower() in lowered for word in words):
            send(chat_id, response)
            return


def process_update(update, state):
    message = update.get("message") or update.get("edited_message") or {}
    handle_message(message)


def background_loop(state):
    while True:
        try:
            save_state(state)
        except Exception as error:
            print(f"[bot] 백그라운드 오류: {error}", flush=True)
        time.sleep(15)


def register_commands():
    entries = [
        {"command": name, "description": entry["description"] or "설명 없음"}
        for name, entry in COMMANDS.items()
    ]
    if not entries:
        return
    try:
        call("setMyCommands", commands=entries)
        print(f"[bot] 명령어 메뉴 {len(entries)}개 등록", flush=True)
    except Exception as error:
        print(f"[bot] 명령어 메뉴 등록 실패: {error}", flush=True)


def main():
    state = load_state()
    register_commands()
    if not CHAT_ID and (SCHEDULES or UPBIT):
        print("[bot] TELEGRAM_CHAT_ID가 비어 있습니다. 봇에 /id 를 보내 확인하세요.", flush=True)
    print(
        f"[bot] 시작 · 명령어 {len(COMMANDS)}개 · 키워드 {len(KEYWORD_REPLIES)}개 · 예약 {len(SCHEDULES)}개",
        flush=True,
    )
    threading.Thread(target=background_loop, args=(state,), daemon=True).start()
    offset = int(state.get("offset") or 0)
    while True:
        try:
            data = call("getUpdates", offset=offset, timeout=30)
            for update in data.get("result", []):
                offset = int(update["update_id"]) + 1
                state["offset"] = offset
                process_update(update, state)
        except Exception as error:
            print(f"[bot] 오류: {error}", flush=True)
            time.sleep(3)


if __name__ == "__main__":
    main()