first commit

Author: Goojoe

.env.example

@@ -0,0 +1,27 @@
+# Telegram Bot Token
+TELEGRAM_BOT_TOKEN=your_telegram_bot_token_here
+
+# Webhook Configuration
+WEBHOOK_URL=https://yourname-project.hf.space
+WEBHOOK_PATH=/api/v1/webhook
+
+# Cache Settings
+CACHE_TIMEOUT=5
+CACHE_TTL_MINUTES=10
+
+# Privacy Settings
+REDACT_USER_DATA=True
+
+BOC_URL=https://www.bankofchina.com/sourcedb/whpj/enindex_1619.html
+
+# Timezone Settings
+TIMEZONE=Asia/Shanghai
+
+# Application Settings
+APP_HOST=0.0.0.0
+APP_PORT=7860
+APP_WORKERS=1
+DEBUG=False
+
+SUPPORTED_CURRENCIES=USD,EUR,JPY,GBP,AUD,CAD,CHF,HKD,SGD,SEK,DKK,NOK,NZD,THB,PHP,MOP,KRW,CNY,AED,BRL,IDR,INR,RUB,SAR,TRY,TWD,ZAR
+CURRENCY_NAMES=USD:美元,EUR:欧元,JPY:日元,GBP:英镑,AUD:澳大利亚元,CAD:加拿大元,CHF:瑞士法郎,HKD:港币,SGD:新加坡元,SEK:瑞典克朗,DKK:丹麦克朗,NOK:挪威克朗,NZD:新西兰元,THB:泰国铢,PHP:菲律宾比索,MOP:澳门元,KRW:韩元,CNY:人民币,AED:阿联酋迪拉姆,BRL:巴西雷亚尔,IDR:印尼盾,INR:印度卢比,RUB:俄罗斯卢布,SAR:沙特里亚尔,TRY:土耳其里拉,TWD:新台币,ZAR:南非兰特

.github/workflows/docker-publish.yml

@@ -0,0 +1,189 @@
+# .github/workflows/docker-publish-ghcr.yml
+
+name: Docker Image CI (GHCR - CET_BOT)
+
+on:
+  push:
+    branches: [master]
+    paths-ignore:
+      - "**.md"
+      - "docs/**"
+  workflow_dispatch:
+
+jobs:
+  check_commit:
+    name: Check Build Settings
+    runs-on: ubuntu-latest
+    outputs:
+      should_build: ${{ steps.check.outputs.should_build }}
+      apply_tags: ${{ steps.check.outputs.apply_tags }}
+    steps:
+      - name: Checkout Repository
+        uses: actions/checkout@v4
+        with:
+          fetch-depth: 2
+
+      - name: Get commit message
+        id: get_commit_message
+        run: |
+          COMMIT_MSG=$(git log -1 --pretty=format:"%s")
+          echo "commit_message=$COMMIT_MSG" >> $GITHUB_OUTPUT
+          echo "Commit message: $COMMIT_MSG"
+
+      - name: Set build settings
+        id: check
+        run: |
+          COMMIT_MSG="${{ steps.get_commit_message.outputs.commit_message }}"
+          if [[ "${{ github.event_name }}" == "workflow_dispatch" ]]; then
+            echo "should_build=true" >> $GITHUB_OUTPUT
+            echo "apply_tags=true" >> $GITHUB_OUTPUT
+            echo "Workflow dispatched manually. Building with tags..."
+          elif [[ "${{ github.event_name }}" == "push" && "${{ github.ref }}" == "refs/heads/master" ]]; then
+            echo "should_build=true" >> $GITHUB_OUTPUT
+            # Only apply tags if commit message contains 'build'
+            if [[ "$COMMIT_MSG" == *"build"* ]]; then
+              echo "apply_tags=true" >> $GITHUB_OUTPUT
+              echo "Push to master branch with 'build' in commit message. Building with tags..."
+            else
+              echo "apply_tags=false" >> $GITHUB_OUTPUT
+              echo "Push to master branch without 'build' in commit message. Building without tags..."
+            fi
+          else
+            echo "should_build=false" >> $GITHUB_OUTPUT
+            echo "apply_tags=false" >> $GITHUB_OUTPUT
+            echo "Not a master branch push or manual dispatch. Skipping build."
+          fi
+
+  read_version:
+    name: Read Version
+    runs-on: ubuntu-latest
+    outputs:
+      version: ${{ steps.get_version.outputs.version }}
+    steps:
+      - name: Checkout Repository
+        uses: actions/checkout@v4
+
+      - name: Read version from file
+        id: get_version
+        run: |
+          VERSION=$(grep -oP 'version=\K[0-9]+\.[0-9]+\.[0-9]+' version.txt)
+          echo "Version read from file: $VERSION"
+          echo "version=$VERSION" >> $GITHUB_OUTPUT
+
+  build_and_push:
+    name: Build and Push CET_BOT Image to GHCR
+    runs-on: ubuntu-latest
+    needs: [check_commit, read_version]
+    if: ${{ needs.check_commit.outputs.should_build == 'true' }}
+    permissions:
+      contents: write
+      packages: write
+
+    steps:
+      - name: Checkout Repository
+        uses: actions/checkout@v4
+        with:
+          fetch-depth: 0
+
+      - name: Set up QEMU
+        uses: docker/setup-qemu-action@v3
+
+      - name: Set up Docker Buildx
+        uses: docker/setup-buildx-action@v3
+
+      - name: Login to GitHub Container Registry
+        uses: docker/login-action@v3
+        with:
+          registry: ghcr.io
+          username: ${{ github.actor }}
+          password: ${{ secrets.GITHUB_TOKEN }}
+
+      # --- 新增步骤：转换所有者名称为小写 ---
+      - name: Convert owner name to lowercase
+        id: owner_lc
+        run: echo "OWNER_LC=$(echo ${{ github.repository_owner }} | tr '[:upper:]' '[:lower:]')" >> $GITHUB_ENV
+      # ------------------------------------
+
+      # Test image deletion section removed as per requirement
+
+      # Removed GitHub repository tagging
+
+      - name: Create Version Tag
+        if: ${{ needs.check_commit.outputs.apply_tags == 'true' }}
+        run: |
+          VERSION=${{ needs.read_version.outputs.version }}
+          echo "Creating tag v$VERSION"
+          git config user.name "GitHub Actions"
+          git config user.email "[email protected]"
+          git tag -a "v$VERSION" -m "Release version $VERSION"
+          git push origin "v$VERSION"
+
+      - name: Build and push Docker image to GHCR with tags
+        id: build-and-push-with-tags
+        if: ${{ needs.check_commit.outputs.apply_tags == 'true' }}
+        uses: docker/build-push-action@v5
+        with:
+          context: .
+          file: ./Dockerfile
+          push: true
+          tags: | # --- 使用转换后的小写所有者名称和版本号 ---
+            ghcr.io/${{ env.OWNER_LC }}/cet_bot:latest
+            ghcr.io/${{ env.OWNER_LC }}/cet_bot:sha-${{ github.sha }}
+            ghcr.io/${{ env.OWNER_LC }}/cet_bot:v${{ needs.read_version.outputs.version }}
+          labels: |
+            org.opencontainers.image.title=CET_BOT
+            org.opencontainers.image.source=${{ github.server_url }}/${{ github.repository }}
+            org.opencontainers.image.revision=${{ github.sha }}
+            org.opencontainers.image.created=${{ steps.build-and-push-with-tags.outputs.metadata.image.created }}
+
+      # Test build section removed as per requirement
+
+      - name: Build and push Docker image to GHCR without version tags
+        id: build-and-push-without-tags
+        if: ${{ needs.check_commit.outputs.apply_tags == 'false' && needs.check_commit.outputs.should_build == 'true' }}
+        uses: docker/build-push-action@v5
+        with:
+          context: .
+          file: ./Dockerfile
+          push: true
+          tags: | # --- 使用唯一标识符和主分支标签 ---
+            ghcr.io/${{ env.OWNER_LC }}/cet_bot:commit-${{ github.sha }}
+            ghcr.io/${{ env.OWNER_LC }}/cet_bot:master
+          # platforms: linux/amd64,linux/arm64
+          labels: |
+            org.opencontainers.image.title=CET_BOT
+            org.opencontainers.image.source=${{ github.server_url }}/${{ github.repository }}
+            org.opencontainers.image.revision=${{ github.sha }}
+            org.opencontainers.image.created=${{ steps.build-and-push-without-tags.outputs.metadata.image.created }}
+      # (可选) 输出构建的镜像 Digest 和元数据
+      # - name: Print image digest
+      #   run: echo ${{ steps.build-and-push.outputs.digest }}
+      # - name: Print image metadata
+      #   run: echo '${{ steps.build-and-push.outputs.metadata }}'
+
+  create_release:
+    name: Create GitHub Release
+    runs-on: ubuntu-latest
+    needs: [read_version, build_and_push, check_commit]
+    if: ${{ needs.check_commit.outputs.apply_tags == 'true' }}
+    permissions:
+      contents: write
+    steps:
+      - name: Checkout Repository
+        uses: actions/checkout@v4
+
+      - name: Create Release
+        uses: actions/create-release@v1
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+        with:
+          tag_name: v${{ needs.read_version.outputs.version }}
+          release_name: Release v${{ needs.read_version.outputs.version }}
+          draft: false
+          prerelease: false
+          body: |
+            Release version ${{ needs.read_version.outputs.version }}
+
+            Docker image available at:
+            - ghcr.io/${{ github.repository_owner }}/cet_bot:v${{ needs.read_version.outputs.version }}
+            - ghcr.io/${{ github.repository_owner }}/cet_bot:latest

.gitignore

@@ -0,0 +1,28 @@
+# 配置文件（包含敏感信息）
+config.yaml
+
+# 缓存文件
+chinaBank-Exchange-TelegramBot.html # 旧的缓存文件（根目录）
+data/ # 包含下载的 HTML 等缓存数据
+__pycache__/
+*.py[cod]
+*$py.class
+
+# 环境文件
+.env
+*venv/
+env/
+ENV/
+
+# 日志文件
+*.log
+
+# 系统文件
+.DS_Store
+Thumbs.db
+
+# IDE相关
+.idea/
+.vscode/
+*.swp
+*.swo

Dockerfile

@@ -0,0 +1,19 @@
+FROM python:3.11-slim
+
+WORKDIR /app
+
+# 复制依赖文件
+COPY requirements.txt .
+
+# 安装依赖
+RUN pip install --no-cache-dir -r requirements.txt
+
+# 复制应用代码
+COPY . .
+COPY .env.example .env
+
+# 暴露端口（Hugging Face Spaces 使用 7860 端口）
+EXPOSE 7860
+
+# 启动应用（注意：指向 app.main:app 而不是原来的 app.master:app）
+CMD ["uvicorn", "main:app", "--host", "0.0.0.0", "--port", "7860"]

Dockerfile.hf

@@ -0,0 +1,10 @@
+FROM ghcr.io/goojoe/cet_bot:latest
+
+ENV TELEGRAM_BOT_TOKEN=${TELEGRAM_BOT_TOKEN}
+ENV CACHE_TTL_MINUTES=${CACHE_TTL_MINUTES}
+ENV WEBHOOK_URL=${WEBHOOK_URL}
+
+EXPOSE 7860
+
+CMD ["uvicorn", "main:app", "--host", "0.0.0.0", "--port", "7860"]
+

README.md

@@ -0,0 +1,37 @@
+# 中国银行汇率查询 Telegram 机器人
+
+这是一个提供中国银行汇率查询服务的 Telegram 机器人。用户可以通过简单的命令获取最新的汇率信息。
+
+## 功能
+
+- FastAPI
+
+- 查询最新的中国银行外汇汇率
+- 支持多种货币转换
+- 实时数据更新和异步缓存
+- 用户日志隐私保护(可关闭)
+
+## 本地部署
+
+```
+python -m venv .venv
+pip install -r requirements.txt
+# Activate virtual environment
+.\.venv\Scripts\Activate.ps1
+
+# Start Uvicorn server
+uvicorn main:app --host 0.0.0.0 --port 7860 --reload
+```
+
+## hf space部署说明
+
+此项目已配置为在 Hugging Face Space 上运行。部署后，您需要：
+
+1. 在 Space 设置中配置以下环境变量：
+   - `TELEGRAM_BOT_TOKEN`: 您的 Telegram 机器人令牌
+   - `WEBHOOK_URL`: 您的 Hugging Face Space URL (例如 https://yourname-project.hf.space)
+   - `CACHE_TTL_MINUTES`: 缓存超时时间（分钟）
+
+2. 确保 Telegram 机器人已通过 BotFather 创建并获取了令牌
+
+3. 部署完成后，机器人将自动设置 webhook 并开始响应用户消息

app/api/v1/endpoints/webhook.py

@@ -0,0 +1,67 @@
+"""
+Webhook Endpoint for Telegram Bot
+
+This module defines the FastAPI endpoint that receives webhook updates from Telegram
+and forwards them to the bot's dispatcher for processing.
+"""
+from fastapi import APIRouter, Request, Depends, HTTPException
+from aiogram.types import Update
+import json
+from app.bot.bot_instance import application
+from app.utils.redact import sanitize_user_data
+from app.core.config import settings
+
+router = APIRouter()
+
+@router.post("")
+async def telegram_webhook(request: Request):
+    """
+    Endpoint for receiving webhook updates from Telegram.
+
+    This endpoint accepts POST requests from Telegram containing updates,
+    and passes them to the appropriate handlers via the dispatcher.
+    """
+    # Get the update data from the request
+    update_data = await request.json()
+
+    # Convert the data to an Update object
+    telegram_update = Update.model_validate(update_data)
+
+    # Log update type for debugging (with sensitive information removed)
+    import logging
+    logger = logging.getLogger(__name__)
+
+    # Get JSON representation of the update
+    update_json = telegram_update.model_dump_json(exclude_none=True)
+    update_dict = json.loads(update_json)
+
+    # Sanitize the update data
+    sanitized_update = sanitize_user_data(update_dict)
+
+    # Log sanitized update
+    logger.info(f"Received update: {json.dumps(sanitized_update)}")
+
+    try:
+        # Log command information for debugging
+        if telegram_update.message and telegram_update.message.text and telegram_update.message.text.startswith('/'):
+            command_text = telegram_update.message.text.split()[0]
+            logger.info(f"Received command: {command_text} from user: [REDACTED_ID]")
+
+            # Log entity information if available
+            if telegram_update.message.entities:
+                for entity in telegram_update.message.entities:
+                    logger.info(f"Entity: {entity.type} at offset {entity.offset}, length {entity.length}")
+
+        # Process the update with aiogram v3 style
+        await application["dispatcher"].feed_update(
+            bot=application["bot"],
+            update=telegram_update
+        )
+
+        # Note: We've removed the fallback mechanism because it was causing duplicate messages.
+        # The aiogram dispatcher is already handling the commands correctly.
+    except Exception as e:
+        logger.error(f"Error processing update: {e}", exc_info=True)
+
+    # Return a success response
+    return {"status": "success"}