new files

gemini.py

@@ -8,8 +8,11 @@ from io import BytesIO
 import markdown
 from bs4 import BeautifulSoup
 from flask import Flask, abort, request, send_from_directory
+
 from google import genai
 from google.genai import types
+from google.genai.types import Tool, GenerateContentConfig, GoogleSearch
+
 from linebot.v3 import WebhookHandler
 from linebot.v3.exceptions import InvalidSignatureError
 from linebot.v3.messaging import (
@@ -21,14 +24,31 @@ from linebot.v3.messaging import (
     ReplyMessageRequest,
     TextMessage,
 )
-from linebot.v3.webhooks import ImageMessageContent, MessageEvent, TextMessageContent
+from linebot.v3.webhooks import (
+    ImageMessageContent,
+    MessageEvent,
+    TextMessageContent,
+)
+
 from PIL import Image
+from linebot.v3.webhooks import VideoMessageContent
 
 # === 初始化 Google Gemini ===
 GOOGLE_API_KEY = os.environ.get("GOOGLE_API_KEY")
-google_client = genai.Client(api_key=GOOGLE_API_KEY)
-text_system_prompt = "你是一個中文的AI助手，請用繁體中文回答"
-chat = google_client.chats.create(model="gemini-2.0-flash")
+client = genai.Client(api_key=GOOGLE_API_KEY)
+
+google_search_tool = Tool(
+    google_search=GoogleSearch()
+)
+
+chat = client.chats.create(
+    model="gemini-2.5-pro-preview-05-06",
+    config=GenerateContentConfig(
+        system_instruction="你是一個中文的AI助手，請用繁體中文回答",
+        tools=[google_search_tool],
+        response_modalities=["TEXT"],
+    )
+)
 
 # === 初始設定 ===
 static_tmp_path = tempfile.gettempdir()
@@ -38,7 +58,8 @@ base_url = os.getenv("SPACE_HOST")  # e.g., "your-space-name.hf.space"
 # === Flask 應用初始化 ===
 app = Flask(__name__)
 logging.basicConfig(
-    level=logging.INFO, format="%(asctime)s - %(levelname)s - %(message)s"
+    level=logging.INFO,
+    format="%(asctime)s - %(levelname)s - %(message)s"
 )
 app.logger.setLevel(logging.INFO)
 
@@ -51,9 +72,10 @@ handler = WebhookHandler(channel_secret)
 
 # === AI Query 包裝 ===
 def query(payload):
-    response = chat.send_message(f"{text_system_prompt}：{payload}")
+    response = chat.send_message(message=payload)
     return response.text
 
+
 # === 靜態圖檔路由 ===
 @app.route("/images/<filename>")
 def serve_image(filename):
@@ -89,7 +111,7 @@ def handle_text_message(event):
         prompt = user_input[3:].strip()
         try:
             # 使用 Gemini 生成圖片
-            response = google_client.models.generate_content(
+            response = client.models.generate_content(
                 model="gemini-2.0-flash-exp-image-generation",
                 contents=prompt,
                 config=types.GenerateContentConfig(
@@ -123,7 +145,7 @@ def handle_text_message(event):
                                 ],
                             )
                         )
-                    
+
         except Exception as e:
             app.logger.error(f"Gemini API error: {e}")
             with ApiClient(configuration) as api_client:
@@ -170,14 +192,18 @@ def handle_image_message(event):
 
     # === 以下是解釋圖片 === #
     image = Image.open(tf.name)
-    response = google_client.models.generate_content(
+    response = client.models.generate_content(
         model="gemini-2.0-flash",
+        config=types.GenerateContentConfig(
+            system_instruction="你是一個資深的面相命理師，如果有人上手掌的照片，就幫他解釋手相，如果上傳正面臉部的照片，就幫他解釋面相，照片要先去背，如果是一般的照片，就正常說明照片不用算命，請用繁體中文回答",
+            response_modalities=["TEXT"],
+            tools=[google_search_tool],
+        ),
         contents=[image, "用繁體中文描述這張圖片"],
     )
     app.logger.info(response.text)
 
     # === 以下是回傳圖片部分 === #
-
     with ApiClient(configuration) as api_client:
         line_bot_api = MessagingApi(api_client)
         line_bot_api.reply_message(
@@ -191,69 +217,51 @@ def handle_image_message(event):
                 ],
             )
         )
-'''
-@handler.add(MessageEvent, message=ImageMessageContent)
-def handle_image_message(event):
 
-    # === 以下是處理圖片回傳部分 === #
+# === 處理影片訊息 ===
 
+@handler.add(MessageEvent, message=VideoMessageContent)
+def handle_video_message(event):
+    # 下載影片內容
     with ApiClient(configuration) as api_client:
         blob_api = MessagingApiBlob(api_client)
         content = blob_api.get_message_content(message_id=event.message.id)
-        image_bytes = content
-
-    # Step 2：轉成 base64 字串
-    base64_string = base64.b64encode(image_bytes).decode("utf-8")
 
-    # Step 3：組成 OpenAI 的 data URI 格式
-    data_uri = f"data:image/png;base64,{base64_string}"
-    app.logger.info(f"Data URI: {data_uri}")
-
-    # Step 4：將圖片存到本地端
+    # 儲存影片到本地
     with tempfile.NamedTemporaryFile(
-        dir=static_tmp_path, suffix=".jpg", delete=False
+        dir=static_tmp_path, suffix=".mp4", delete=False
     ) as tf:
         tf.write(content)
         filename = os.path.basename(tf.name)
 
-    image_url = f"https://{base_url}/images/{filename}"
-
-    app.logger.info(f"Image URL: {image_url}")
-
-    # === 以下是處理解釋圖片部分 === #
-    response = client.responses.create(
-        model="gpt-4.1-nano",
-        input=[
-            {
-                "role": "user",
-                "content": [
-                    {
-                        "type": "input_text",
-                        "text": "describe the image in traditional chinese",
-                    },
-                    {
-                        "type": "input_image",
-                        "image_url": data_uri,
-                    },
-                ],
-            }
-        ],
-    )
-    app.logger.info(response.output_text)
+    video_url = f"https://{base_url}/images/{filename}"
+    app.logger.info(f"Video URL: {video_url}")
 
-    # === 以下是回傳圖片部分 === #
+    # 影片說明
+    try:
+        response = client.models.generate_content(
+            model="gemini-2.0-flash",
+            config=types.GenerateContentConfig(
+                system_instruction="你是一個專業的影片解說員，請用繁體中文簡要說明這段影片的內容。",
+                response_modalities=["TEXT"],
+                tools=[google_search_tool],
+            ),
+            contents=[{"mime_type": "video/mp4", "data": content}, "用繁體中文描述這段影片"],
+        )
+        description = response.text
+    except Exception as e:
+        app.logger.error(f"Gemini API error (video): {e}")
+        description = "抱歉，無法解釋這段影片內容。"
 
+    # 回傳影片連結與說明
     with ApiClient(configuration) as api_client:
         line_bot_api = MessagingApi(api_client)
         line_bot_api.reply_message(
             ReplyMessageRequest(
                 reply_token=event.reply_token,
                 messages=[
-                    ImageMessage(
-                        original_content_url=image_url, preview_image_url=image_url
-                    ),
-                    TextMessage(text=response.output_text),
+                    TextMessage(text=f"影片連結：{video_url}"),
+                    TextMessage(text=description),
                 ],
             )
-        )
-'''
+        )

multiturn.py

@@ -0,0 +1,88 @@
+"""
+東吳大學資料系 2025 LINEBOT
+"""
+
+import os
+
+from flask import Flask, abort, request
+from bs4 import BeautifulSoup
+import markdown
+
+from google import genai
+from google.genai import types # 加入system prompot所需的types模組
+
+from linebot.v3 import WebhookHandler
+from linebot.v3.exceptions import InvalidSignatureError
+from linebot.v3.messaging import (
+    ApiClient,
+    Configuration,
+    MessagingApi,
+    ReplyMessageRequest,
+    TextMessage,
+)
+from linebot.v3.webhooks import MessageEvent, TextMessageContent
+
+
+# Initialize Google Gemini
+GOOGLE_API_KEY = os.getenv("GOOGLE_API_KEY")
+client = genai.Client(api_key=GOOGLE_API_KEY)
+chat = client.chats.create(model="gemini-2.0-flash",
+    config=types.GenerateContentConfig(
+        system_instruction="你是一個中文的AI助手，請用繁體中文回答"    
+    )
+)
+
+# Initialize Flask app
+app = Flask(__name__)
+channel_secret = os.getenv("YOUR_CHANNEL_SECRET")
+channel_access_token = os.getenv("YOUR_CHANNEL_ACCESS_TOKEN")
+configuration = Configuration(access_token=channel_access_token)
+handler = WebhookHandler(channel_secret)
+
+
+def query(payload: str) -> str:
+    """Send a prompt to Gemini and return the response text."""
+    response = chat.send_message(message=payload)
+    return response.text
+
+
+@app.route("/", methods=["GET"])
+def home():
+    """Health check endpoint."""
+    return {"message": "Line Webhook Server"}
+
+
+@app.route("/", methods=["POST"])
+def callback():
+    """Handle incoming webhook from LINE."""
+    signature = request.headers.get("X-Line-Signature")
+    body = request.get_data(as_text=True)
+    app.logger.info("Request body: %s", body)
+
+    try:
+        handler.handle(body, signature)
+    except InvalidSignatureError:
+        app.logger.warning(
+            "Invalid signature. Please check channel credentials."
+        )
+        abort(400)
+
+    return "OK"
+
+
+@handler.add(MessageEvent, message=TextMessageContent)
+def handle_text_message(event):
+    """Handle incoming text message event."""
+    user_input = event.message.text.strip()
+    response_text = query(user_input)
+    html_msg = markdown.markdown(response_text)
+    soup = BeautifulSoup(html_msg, "html.parser")
+
+    with ApiClient(configuration) as api_client:
+        line_bot_api = MessagingApi(api_client)
+        line_bot_api.reply_message_with_http_info(
+            ReplyMessageRequest(
+                reply_token=event.reply_token,
+                messages=[TextMessage(text=soup.get_text())],
+            )
+        )

replybot.py

@@ -0,0 +1,84 @@
+"""
+東吳大學資料系 2025 LINEBOT
+"""
+
+import os
+
+from flask import Flask, abort, request
+from bs4 import BeautifulSoup
+import markdown
+
+from google import genai
+from linebot.v3 import WebhookHandler
+from linebot.v3.exceptions import InvalidSignatureError
+from linebot.v3.messaging import (
+    ApiClient,
+    Configuration,
+    MessagingApi,
+    ReplyMessageRequest,
+    TextMessage,
+)
+from linebot.v3.webhooks import MessageEvent, TextMessageContent
+
+
+# Initialize Google Gemini
+GOOGLE_API_KEY = os.getenv("GOOGLE_API_KEY")
+client = genai.Client(api_key=GOOGLE_API_KEY)
+
+# Initialize Flask app
+app = Flask(__name__)
+channel_secret = os.getenv("YOUR_CHANNEL_SECRET")
+channel_access_token = os.getenv("YOUR_CHANNEL_ACCESS_TOKEN")
+configuration = Configuration(access_token=channel_access_token)
+handler = WebhookHandler(channel_secret)
+
+
+def query(payload: str) -> str:
+    """Send a prompt to Gemini and return the response text."""
+    response = client.models.generate_content(
+        model="gemini-2.0-flash",
+        contents=[payload]
+    )
+    return response.text
+
+
+@app.route("/", methods=["GET"])
+def home():
+    """Health check endpoint."""
+    return {"message": "Line Webhook Server"}
+
+
+@app.route("/", methods=["POST"])
+def callback():
+    """Handle incoming webhook from LINE."""
+    signature = request.headers.get("X-Line-Signature")
+    body = request.get_data(as_text=True)
+    app.logger.info("Request body: %s", body)
+
+    try:
+        handler.handle(body, signature)
+    except InvalidSignatureError:
+        app.logger.warning(
+            "Invalid signature. Please check channel credentials."
+        )
+        abort(400)
+
+    return "OK"
+
+
+@handler.add(MessageEvent, message=TextMessageContent)
+def handle_text_message(event):
+    """Handle incoming text message event."""
+    user_input = event.message.text.strip()
+    response_text = query(user_input)
+    html_msg = markdown.markdown(response_text)
+    soup = BeautifulSoup(html_msg, "html.parser")
+
+    with ApiClient(configuration) as api_client:
+        line_bot_api = MessagingApi(api_client)
+        line_bot_api.reply_message_with_http_info(
+            ReplyMessageRequest(
+                reply_token=event.reply_token,
+                messages=[TextMessage(text=soup.get_text())],
+            )
+        )

requirements.txt

@@ -1,8 +1,8 @@
-Flask
-gunicorn
-line-bot-sdk
-markdown
-beautifulsoup4
-openai
-google-genai
-Pillow
+Flask # 執行LINE Bot Webhook Server需要的套件
+gunicorn # 執行正式的web server，讓他來反向代理執行中的Flask
+line-bot-sdk # LINE Bot的必須安裝項
+markdown # 讓輸出格式漂亮，並且解析markdown文件用的套件
+beautifulsoup4 # 讓輸出格式漂亮的套件
+openai # 使用OpenAI的模型(此次課程為示範不使用)
+google-genai # 使用Google Gemini API的套件
+Pillow # 處理圖片

system_prompt.py

@@ -0,0 +1,88 @@
+"""
+東吳大學資料系 2025 LINEBOT
+"""
+
+import os
+
+from flask import Flask, abort, request
+from bs4 import BeautifulSoup
+import markdown
+
+from google import genai
+from google.genai import types # 加入system prompot所需的types模組
+
+from linebot.v3 import WebhookHandler
+from linebot.v3.exceptions import InvalidSignatureError
+from linebot.v3.messaging import (
+    ApiClient,
+    Configuration,
+    MessagingApi,
+    ReplyMessageRequest,
+    TextMessage,
+)
+from linebot.v3.webhooks import MessageEvent, TextMessageContent
+
+
+# Initialize Google Gemini
+GOOGLE_API_KEY = os.getenv("GOOGLE_API_KEY")
+client = genai.Client(api_key=GOOGLE_API_KEY)
+
+# Initialize Flask app
+app = Flask(__name__)
+channel_secret = os.getenv("YOUR_CHANNEL_SECRET")
+channel_access_token = os.getenv("YOUR_CHANNEL_ACCESS_TOKEN")
+configuration = Configuration(access_token=channel_access_token)
+handler = WebhookHandler(channel_secret)
+
+
+def query(payload: str) -> str:
+    """Send a prompt to Gemini and return the response text."""
+    response = client.models.generate_content(
+        model="gemini-2.0-flash",
+        config=types.GenerateContentConfig(
+            system_instruction="你是一個中文的AI助手，請用繁體中文回答"),
+        contents=payload
+    )
+    return response.text
+
+
+@app.route("/", methods=["GET"])
+def home():
+    """Health check endpoint."""
+    return {"message": "Line Webhook Server"}
+
+
+@app.route("/", methods=["POST"])
+def callback():
+    """Handle incoming webhook from LINE."""
+    signature = request.headers.get("X-Line-Signature")
+    body = request.get_data(as_text=True)
+    app.logger.info("Request body: %s", body)
+
+    try:
+        handler.handle(body, signature)
+    except InvalidSignatureError:
+        app.logger.warning(
+            "Invalid signature. Please check channel credentials."
+        )
+        abort(400)
+
+    return "OK"
+
+
+@handler.add(MessageEvent, message=TextMessageContent)
+def handle_text_message(event):
+    """Handle incoming text message event."""
+    user_input = event.message.text.strip()
+    response_text = query(user_input)
+    html_msg = markdown.markdown(response_text)
+    soup = BeautifulSoup(html_msg, "html.parser")
+
+    with ApiClient(configuration) as api_client:
+        line_bot_api = MessagingApi(api_client)
+        line_bot_api.reply_message_with_http_info(
+            ReplyMessageRequest(
+                reply_token=event.reply_token,
+                messages=[TextMessage(text=soup.get_text())],
+            )
+        )

with_logs.py

@@ -0,0 +1,94 @@
+"""
+東吳大學資料系 2025 LINEBOT
+"""
+
+import logging
+import os
+
+from flask import Flask, abort, request
+from bs4 import BeautifulSoup
+import markdown
+
+from google import genai
+from google.genai import types # 加入system prompot所需的types模組
+
+from linebot.v3 import WebhookHandler
+from linebot.v3.exceptions import InvalidSignatureError
+from linebot.v3.messaging import (
+    ApiClient,
+    Configuration,
+    MessagingApi,
+    ReplyMessageRequest,
+    TextMessage,
+)
+from linebot.v3.webhooks import MessageEvent, TextMessageContent
+
+
+# Initialize Google Gemini
+GOOGLE_API_KEY = os.getenv("GOOGLE_API_KEY")
+client = genai.Client(api_key=GOOGLE_API_KEY)
+chat = client.chats.create(model="gemini-2.0-flash")
+
+# Initialize Flask app
+app = Flask(__name__)
+logging.basicConfig(
+    level=logging.INFO, format="%(asctime)s - %(levelname)s - %(message)s"
+)
+app.logger.setLevel(logging.INFO)
+
+channel_secret = os.getenv("YOUR_CHANNEL_SECRET")
+channel_access_token = os.getenv("YOUR_CHANNEL_ACCESS_TOKEN")
+configuration = Configuration(access_token=channel_access_token)
+handler = WebhookHandler(channel_secret)
+
+
+def query(payload: str) -> str:
+    """Send a prompt to Gemini and return the response text."""
+    response = chat.send_message(
+        config=types.GenerateContentConfig(
+            system_instruction="你是一個中文的AI助手，請用繁體中文回答"),
+        message=payload
+    )
+    return response.text
+
+
+@app.route("/", methods=["GET"])
+def home():
+    """Health check endpoint."""
+    return {"message": "Line Webhook Server"}
+
+
+@app.route("/", methods=["POST"])
+def callback():
+    """Handle incoming webhook from LINE."""
+    signature = request.headers.get("X-Line-Signature")
+    body = request.get_data(as_text=True)
+    app.logger.info("Request body: %s", body)
+
+    try:
+        handler.handle(body, signature)
+    except InvalidSignatureError:
+        app.logger.warning(
+            "Invalid signature. Please check channel credentials."
+        )
+        abort(400)
+
+    return "OK"
+
+
+@handler.add(MessageEvent, message=TextMessageContent)
+def handle_text_message(event):
+    """Handle incoming text message event."""
+    user_input = event.message.text.strip()
+    response_text = query(user_input)
+    html_msg = markdown.markdown(response_text)
+    soup = BeautifulSoup(html_msg, "html.parser")
+
+    with ApiClient(configuration) as api_client:
+        line_bot_api = MessagingApi(api_client)
+        line_bot_api.reply_message_with_http_info(
+            ReplyMessageRequest(
+                reply_token=event.reply_token,
+                messages=[TextMessage(text=soup.get_text())],
+            )
+        )

with_search.py

@@ -0,0 +1,100 @@
+"""
+東吳大學資料系 2025 LINEBOT
+"""
+
+import logging
+import os
+
+from flask import Flask, abort, request
+from bs4 import BeautifulSoup
+import markdown
+
+from google import genai
+from google.genai import types # 加入system prompot所需的types模組
+from google.genai.types import Tool, GenerateContentConfig, GoogleSearch
+
+google_search_tool = Tool(
+    google_search = GoogleSearch()
+)
+
+from linebot.v3 import WebhookHandler
+from linebot.v3.exceptions import InvalidSignatureError
+from linebot.v3.messaging import (
+    ApiClient,
+    Configuration,
+    MessagingApi,
+    ReplyMessageRequest,
+    TextMessage,
+)
+from linebot.v3.webhooks import MessageEvent, TextMessageContent
+
+
+# Initialize Google Gemini
+GOOGLE_API_KEY = os.getenv("GOOGLE_API_KEY")
+client = genai.Client(api_key=GOOGLE_API_KEY)
+chat = client.chats.create(model="gemini-2.0-flash",
+    config=GenerateContentConfig(
+        system_instruction="你是一個中文的AI助手，請用繁體中文回答",
+        tools=[google_search_tool],
+        response_modalities=["TEXT"], 
+    ))
+
+# Initialize Flask app
+app = Flask(__name__)
+logging.basicConfig(
+    level=logging.INFO, format="%(asctime)s - %(levelname)s - %(message)s"
+)
+app.logger.setLevel(logging.INFO)
+
+channel_secret = os.getenv("YOUR_CHANNEL_SECRET")
+channel_access_token = os.getenv("YOUR_CHANNEL_ACCESS_TOKEN")
+configuration = Configuration(access_token=channel_access_token)
+handler = WebhookHandler(channel_secret)
+
+
+def query(payload: str) -> str:
+    """Send a prompt to Gemini and return the response text."""
+    response = chat.send_message(message=payload)
+    return response.text
+
+
+@app.route("/", methods=["GET"])
+def home():
+    """Health check endpoint."""
+    return {"message": "Line Webhook Server"}
+
+
+@app.route("/", methods=["POST"])
+def callback():
+    """Handle incoming webhook from LINE."""
+    signature = request.headers.get("X-Line-Signature")
+    body = request.get_data(as_text=True)
+    app.logger.info("Request body: %s", body)
+
+    try:
+        handler.handle(body, signature)
+    except InvalidSignatureError:
+        app.logger.warning(
+            "Invalid signature. Please check channel credentials."
+        )
+        abort(400)
+
+    return "OK"
+
+
+@handler.add(MessageEvent, message=TextMessageContent)
+def handle_text_message(event):
+    """Handle incoming text message event."""
+    user_input = event.message.text.strip()
+    response_text = query(user_input)
+    html_msg = markdown.markdown(response_text)
+    soup = BeautifulSoup(html_msg, "html.parser")
+
+    with ApiClient(configuration) as api_client:
+        line_bot_api = MessagingApi(api_client)
+        line_bot_api.reply_message_with_http_info(
+            ReplyMessageRequest(
+                reply_token=event.reply_token,
+                messages=[TextMessage(text=soup.get_text())],
+            )
+        )